Method queueRST

internal/exit/exit.go:546–552

queueRST enqueues a RST frame for the given session to be delivered to owner on its next poll. Also wakes that client's long-poll so the RST is flushed immediately rather than after the long-poll deadline.

(owner [frame.ClientIDLen]byte, sessionID [frame.SessionIDLen]byte)

// owner on its next poll. Also wakes that client's long-poll so the RST is
// flushed immediately rather than after the long-poll deadline.
func (s *Server) queueRST(owner [frame.ClientIDLen]byte, sessionID [frame.SessionIDLen]byte) {
	rst := &frame.Frame{SessionID: sessionID, Flags: frame.FlagRST}
	s.mu.Lock()
	s.pendingRSTs[owner] = append(s.pendingRSTs[owner], rst)
	s.mu.Unlock()
	s.kick(owner)
}

func (s *Server) queueVersionResponse(owner [frame.ClientIDLen]byte, sessionID [frame.SessionIDLen]byte) {
	payload, err := protocol.EncodeVersionInfo(s.version, MaxFramePayload, []string{"zstd", "raw_base64"})