diff --git a/internal/p2p/conn/connection.go b/internal/p2p/conn/connection.go index 6a80417ad..0c05d8724 100644 --- a/internal/p2p/conn/connection.go +++ b/internal/p2p/conn/connection.go @@ -807,6 +807,8 @@ func (ch *Channel) sendBytes(bytes []byte) bool { return true case <-time.After(defaultSendTimeout): return false + case <-ch.conn.Quit(): + return false } }