Fix wrong value put for pending_opening (#7633)

* Fix wrong value put for pending_opening * Oops, didn't even try compiling it
paritytech · Nov 30, 2020 · 779c801 · 779c801
1 parent 2fbab76
commit 779c801
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/client/network/src/protocol/generic_proto/handler.rs b/client/network/src/protocol/generic_proto/handler.rs
@@ -684,6 +684,7 @@ impl ProtocolsHandler for NotifsHandler {
 							_ => unreachable!()
 						};
 
+						debug_assert_eq!(pending_opening.len(), self.out_protocols.len());
 						for (n, is_pending) in pending_opening.iter().enumerate() {
 							if *is_pending {
 								continue;
@@ -740,8 +741,9 @@ impl ProtocolsHandler for NotifsHandler {
 
 				match &mut self.state {
 					State::Open { .. } => {
+						let pending_opening = self.out_protocols.iter().map(|_| false).collect();
 						self.state = State::Closed {
-							pending_opening: Vec::new(),
+							pending_opening,
 						};
 					},
 					State::Opening { out_substreams, .. } => {