Avoid to block thread while write to a nil channel

if session disconnected during sendBytes, session.messageOut may be set to nil before write in session.onDisconnect()
quickfixgo · May 8, 2023 · 3ce9479 · 3ce9479
1 parent 07872e7
commit 3ce9479
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/session.go b/session.go
@@ -367,6 +367,11 @@ func (s *session) EnqueueBytesAndSend(msg []byte) {
 }
 
 func (s *session) sendBytes(msg []byte) {
+	if s.messageOut == nil {
+		s.log.OnEventf("Failed to send: disconnected")
+		return
+	}
+
 	s.log.OnOutgoing(msg)
 	s.messageOut <- msg
 	s.stateTimer.Reset(s.HeartBtInt)