Error when closing stream

dominant-strategies · Mar 1, 2024 · ae24f43 · ae24f43
1 parent 19453a1
commit ae24f43
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/p2p/peerManager/peerManager.go b/p2p/peerManager/peerManager.go
@@ -187,14 +187,16 @@ func (pm *BasicPeerManager) prunePeerConnection(peerID p2p.PeerID) error {
 	if ok {
 		log.Global.WithField("peerID", peerID).Debug("Pruned connection with peer")
 		severStream(peerID, stream)
-		return nil
 	}
 	return errStreamNotFound
 }
 
 func severStream(key interface{}, value interface{}) {
 	stream := value.(network.Stream)
-	stream.Close()
+	err := stream.Close()
+	if err != nil {
+		log.Global.WithField("err", err).Error("Failed to close stream")
+	}
 }
 
 func (pm *BasicPeerManager) SetP2PBackend(host quaiprotocol.QuaiP2PNode) {