From 3b644df0828a9019fa64cf20d98639f9dec052df Mon Sep 17 00:00:00 2001 From: xtaci Date: Sun, 14 Dec 2025 12:59:31 +0800 Subject: [PATCH] add a comment --- session.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/session.go b/session.go index 1ec9a9d..e2a40ef 100644 --- a/session.go +++ b/session.go @@ -386,6 +386,9 @@ func (s *Session) recvLoop() { select { case <-s.bucketNotify: case <-s.die: + // If it returns here, Accept() and OpenStream() are unblocked with io.ErrClosedPipe, + // causing recvLoop to exit gracefully. If recvLoop is blocked in io.ReadFull, however, + // it will be unblocked by a socket read error instead. return } }