Function New

internal/session/session.go:79–95

New creates a session with a random ID is the caller's responsibility — pass it in. needsSYN should be true on the client side (so the first frame carries the SYN flag and Target), false on the server side (created from a received SYN).

(id [frame.SessionIDLen]byte, target string, needsSYN bool)

// the SYN flag and Target), false on the server side (created from a received
// SYN).
func New(id [frame.SessionIDLen]byte, target string, needsSYN bool) *Session {
	s := &Session{
		ID:        id,
		Target:    target,
		rxQueue:   make(map[uint64]*frame.Frame),
		RxChan:    make(chan []byte, 1024),
		synNeeded: needsSYN,
		rxInbox:   make(chan *frame.Frame, rxInboxCap),
		rxDone:    make(chan struct{}),
	}
	if needsSYN {
		s.firstQueuedAt = time.Now()
	}
	s.txCond = sync.NewCond(&s.mu)
	go s.rxLoop()
	return s
}

// Stop signals the rxLoop goroutine to exit. Must be called after removing the
// session from the routing table so no new ProcessRx calls can arrive.