Merge branch 'master' into lexnv/pending-outbound-fix

paritytech · Dec 3, 2024 · c731f19 · c731f19
2 parents bf8e695 + 7612ec9
commit c731f19
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/protocol/request_response/mod.rs b/src/protocol/request_response/mod.rs
@@ -292,6 +292,9 @@ impl RequestResponseProtocol {
     async fn on_connection_closed(&mut self, peer: PeerId) {
         tracing::debug!(target: LOG_TARGET, ?peer, protocol = %self.protocol, "connection closed");
 
+        // Remove any pending outbound substreams for this peer.
+        self.pending_outbound.retain(|_, context| context.peer != peer);
+
         let Some(context) = self.peers.remove(&peer) else {
             tracing::error!(
                 target: LOG_TARGET,