Merge pull request #2924 from nspcc-dev/drain-queues-on-disconnect

network: drain send queues on peer disconnection

pkg/network/tcp_peer.go

@@ -250,6 +250,16 @@ func (p *TCPPeer) handleQueues() {
 		p2pSkipCounter++
 	}
 	p.Disconnect(err)
+drainloop:
+	for {
+		select {
+		case <-p.hpSendQ:
+		case <-p.p2pSendQ:
+		case <-p.sendQ:
+		default:
+			break drainloop
+		}
+	}
 }
 
 // StartProtocol starts a long running background loop that interacts