Skip to content

Commit 0933dfd

Browse files
committed
check deadline before sendMsg, because select is randomly, sometimes it will write successfully after deadline
Signed-off-by: Asutorufa <[email protected]>
1 parent 828214b commit 0933dfd

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

session.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -487,6 +487,8 @@ func (s *Session) sendMsg(hdr header, body []byte, deadline <-chan struct{}) err
487487
select {
488488
case <-s.shutdownCh:
489489
return s.shutdownErr
490+
case <-deadline:
491+
return ErrTimeout
490492
default:
491493
}
492494

0 commit comments

Comments
 (0)