go-yamux/v2/session.go

23 type Session struct {  struct
26 	remoteGoAway int32
30 	localGoAway int32
34 	nextStreamID uint32
37 	config *Config
40 	logger *log.Logger
43 	conn net.Conn
46 	reader io.Reader
49 	pingLock   sync.Mutex
50 	pingID     uint32
51 	activePing *ping
56 	streams    map[uint32]*Stream
57 	inflight   map[uint32]struct{}
58 	streamLock sync.Mutex
63 	synCh chan struct{}
66 	acceptCh chan *Stream
69 	sendCh chan []byte
72 	pongCh, pingCh chan uint32
76 	recvDoneCh chan struct{}
81 	sendDoneCh chan struct{}
84 	client bool
87 	shutdown     bool
88 	shutdownErr  error
89 	shutdownCh   chan struct{}
90 	shutdownLock sync.Mutex
94 	keepaliveLock   sync.Mutex
95 	keepaliveTimer  *time.Timer
96 	keepaliveActive bool
136 func (s *Session) IsClosed() bool {
147 func (s *Session) CloseChan() <-chan struct{} {
152 func (s *Session) NumStreams() int {
160 func (s *Session) Open(ctx context.Context) (net.Conn, error) {
169 func (s *Session) OpenStream(ctx context.Context) (*Stream, error) {
217 func (s *Session) Accept() (net.Conn, error) {
227 func (s *Session) AcceptStream() (*Stream, error) {
245 func (s *Session) Close() error {
272 func (s *Session) exitErr(err error) {
283 func (s *Session) GoAway() error {
288 func (s *Session) goAway(reason uint32) header {
295 func (s *Session) Ping() (dur time.Duration, err error) {
354 func (s *Session) startKeepalive() {
384 func (s *Session) stopKeepalive() {
393 func (s *Session) extendKeepalive() {
410 func (s *Session) sendMsg(hdr header, body []byte, deadline <-chan struct{}) error {
435 func (s *Session) send() {
441 func (s *Session) sendLoop() error {
545 func (s *Session) recv() {
562 func (s *Session) recvLoop() error {
598 func (s *Session) handleStreamMessage(hdr header) error {
650 func (s *Session) handlePing(hdr header) error {
682 func (s *Session) handleGoAway(hdr header) error {
701 func (s *Session) incomingStream(id uint32) error {
746 func (s *Session) closeStream(id uint32) {
762 func (s *Session) establishStream(id uint32) {