smeb_y/0g-storage-node
1
0
Fork 0
mirror of https://github.com/0glabs/0g-storage-node.git synced 2024-12-28 17:25:18 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Notify peer connected to sync layer after status message exchanged

Browse Source
This commit is contained in:
boqiu 2024-11-22 15:17:29 +08:00
parent 85a7810cc3
commit 2be910cd39
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
node/router/src/libp2p_event_handler.rs
View File

@ -194,7 +194,6 @@ impl Libp2pEventHandler {
if outgoing {
self.send_status(peer_id);
self.send_to_sync(SyncMessage::PeerConnected { peer_id });
metrics::LIBP2P_HANDLE_PEER_CONNECTED_OUTGOING.mark(1);
} else {
metrics::LIBP2P_HANDLE_PEER_CONNECTED_INCOMING.mark(1);
@ -263,6 +262,8 @@ impl Libp2pEventHandler {
return;
}
self.send_to_sync(SyncMessage::PeerConnected { peer_id });
let status_message = StatusMessage {
data: network_id,
num_shard: shard_config.num_shard,
@ -280,7 +281,9 @@ impl Libp2pEventHandler {
fn on_status_response(&self, peer_id: PeerId, status: StatusMessage) {
let network_id = self.network_globals.network_id();
let shard_config = self.store.get_store().get_shard_config();
self.verify_status_message(peer_id, status, network_id, &shard_config);
if self.verify_status_message(peer_id, status, network_id, &shard_config) {
self.send_to_sync(SyncMessage::PeerConnected { peer_id });
}
}
pub async fn on_rpc_response(