Skip to content

Commit e689338

Browse files
committed
Code review comment: clear inventory state regardless of event id
Signed-off-by: Jacinta Ferrant <[email protected]>
1 parent f5881e6 commit e689338

File tree

1 file changed

+15
-15
lines changed

1 file changed

+15
-15
lines changed

stackslib/src/net/p2p.rs

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -2116,21 +2116,6 @@ impl PeerNetwork {
21162116
"public addr" => nk.addrbytes.pretty_print(),
21172117
"reason" => %reason
21182118
);
2119-
// remove inventory state
2120-
if let Some(inv_state) = self.inv_state.as_mut() {
2121-
debug!(
2122-
"{:?}: Remove inventory state for epoch 2.x {nk:?}",
2123-
&self.local_peer
2124-
);
2125-
inv_state.del_peer(&nk);
2126-
}
2127-
if let Some(inv_state) = self.inv_state_nakamoto.as_mut() {
2128-
debug!(
2129-
"{:?}: Remove inventory state for Nakamoto {nk:?}",
2130-
&self.local_peer
2131-
);
2132-
inv_state.del_peer(&NeighborAddress::from_neighbor_key(nk.clone(), pubkh));
2133-
}
21342119
self.pending_messages.remove(&(event_id, nk.clone()));
21352120
self.pending_stacks_messages.remove(&(event_id, nk.clone()));
21362121

@@ -2152,6 +2137,21 @@ impl PeerNetwork {
21522137
self.relay_handles.remove(&event_id);
21532138
self.peers.remove(&event_id);
21542139
}
2140+
// remove inventory state
2141+
if let Some(inv_state) = self.inv_state.as_mut() {
2142+
debug!(
2143+
"{:?}: Remove inventory state for epoch 2.x {nk:?}",
2144+
&self.local_peer
2145+
);
2146+
inv_state.del_peer(&nk);
2147+
}
2148+
if let Some(inv_state) = self.inv_state_nakamoto.as_mut() {
2149+
debug!(
2150+
"{:?}: Remove inventory state for Nakamoto {nk:?}",
2151+
&self.local_peer
2152+
);
2153+
inv_state.del_peer(&NeighborAddress::from_neighbor_key(nk.clone(), pubkh));
2154+
}
21552155
}
21562156
}
21572157

0 commit comments

Comments
 (0)