Method kick

internal/exit/exit.go:891–897

kick wakes the long-poll handler currently serving owner so it drains pending TX frames immediately. A non-blocking send keeps repeated kicks from blocking the upstream-read goroutine when the owner is not currently polling — the buffered len-1 channel collapses bursts into a single wake.

(owner [frame.ClientIDLen]byte)

// from blocking the upstream-read goroutine when the owner is not currently
// polling — the buffered len-1 channel collapses bursts into a single wake.
func (s *Server) kick(owner [frame.ClientIDLen]byte) {
	ch := s.activityFor(owner)
	select {
	case ch <- struct{}{}:
	default:
	}
}

// activityFor returns owner's wake channel, lazily allocating it on first
// use. Channels are kept for the life of the server; with a small number of