Method EnqueueTx

internal/session/session.go:132–150

EnqueueTx appends bytes to the session's tx buffer. Blocks while the buffer exceeds TxBufHighWater. Safe to call concurrently with DrainTx.

(data []byte)

// EnqueueTx appends bytes to the session's tx buffer. Blocks while the buffer
// exceeds TxBufHighWater. Safe to call concurrently with DrainTx.
func (s *Session) EnqueueTx(data []byte) {
	s.mu.Lock()
	for len(s.txBuf) > TxBufHighWater && !s.closeReq {
		s.txCond.Wait()
	}
	if s.closeReq {
		s.mu.Unlock()
		return
	}
	s.txBuf = append(s.txBuf, data...)
	if s.firstQueuedAt.IsZero() {
		s.firstQueuedAt = time.Now()
	}
	cb := s.OnTx
	s.mu.Unlock()
	if cb != nil {
		cb()
	}
}

// EnqueueInitialData appends data to the tx buffer while synNeeded is still
// true, so the first DrainTx call bundles it into the SYN frame's payload