Lines Matching defs:Session
19 type Session struct { struct
22 remoteGoAway int32
26 localGoAway int32
30 nextStreamID uint32
33 config *Config
36 logger *log.Logger
39 conn io.ReadWriteCloser
42 bufRead *bufio.Reader
45 pings map[uint32]chan struct{}
46 pingID uint32
47 pingLock sync.Mutex
52 streams map[uint32]*Stream
53 inflight map[uint32]struct{}
54 streamLock sync.Mutex
59 synCh chan struct{}
62 acceptCh chan *Stream
66 sendCh chan sendReady
70 recvDoneCh chan struct{}
73 shutdown bool
74 shutdownErr error
75 shutdownCh chan struct{}
76 shutdownLock sync.Mutex
117 func (s *Session) IsClosed() bool {
127 func (s *Session) NumStreams() int {
135 func (s *Session) Open() (net.Conn, error) {
144 func (s *Session) OpenStream() (*Stream, error) {
190 func (s *Session) Accept() (net.Conn, error) {
200 func (s *Session) AcceptStream() (*Stream, error) {
214 func (s *Session) Close() error {
239 func (s *Session) exitErr(err error) {
250 func (s *Session) GoAway() error {
255 func (s *Session) goAway(reason uint32) header {
263 func (s *Session) Ping() (time.Duration, error) {
300 func (s *Session) keepalive() {
317 func (s *Session) waitForSend(hdr header, body io.Reader) error {
325 func (s *Session) waitForSendErr(hdr header, body io.Reader, errCh chan error) error {
351 func (s *Session) sendNoWait(hdr header) error {
366 func (s *Session) send() {
405 func (s *Session) recv() {
412 func (s *Session) recvLoop() error {
453 func (s *Session) handleStreamMessage(hdr header) error {
505 func (s *Session) handlePing(hdr header) error {
534 func (s *Session) handleGoAway(hdr header) error {
553 func (s *Session) incomingStream(id uint32) error {
595 func (s *Session) closeStream(id uint32) {
610 func (s *Session) establishStream(id uint32) {