fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-06-06 14:41:21 +00:00
Code Issues Projects Releases Wiki Activity

Fix panic in raw swarm (#571)

Browse Source
This commit is contained in:
Pierre Krieger 2018-10-18 09:42:20 +01:00 committed by GitHub
parent 840663e181
commit a77c1a6bf7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
core/src/nodes/raw_swarm.rs
View File

@ -720,14 +720,15 @@ where
}; };
let closed_endpoint = reach_attempts.connected_points let closed_endpoint = reach_attempts.connected_points
.insert(event.peer_id().clone(), opened_endpoint.clone()) .insert(event.peer_id().clone(), opened_endpoint.clone());
.expect("We insert into connected_points whenever a connection is opened and remove \
only when a connection is closed ; the underlying API is guaranteed to always \
deliver a connection closed message after it has been opened, and no two \
closed messages ; qed");
let (outcome, peer_id) = event.accept(); let (outcome, peer_id) = event.accept();
if outcome == CollectionNodeAccept::ReplacedExisting { if outcome == CollectionNodeAccept::ReplacedExisting {
let closed_endpoint = closed_endpoint
.expect("We insert into connected_points whenever a connection is opened and \
remove only when a connection is closed ; the underlying API is guaranteed \
to always deliver a connection closed message after it has been opened, \
and no two closed messages ; qed");
return (Default::default(), RawSwarmEvent::Replaced { return (Default::default(), RawSwarmEvent::Replaced {
peer_id, peer_id,
endpoint: opened_endpoint, endpoint: opened_endpoint,