fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-05-30 03:01:21 +00:00
Code Issues Projects Releases Wiki Activity

start_providing log

Browse Source
This commit is contained in:
folex 2020-03-28 20:47:51 +03:00
parent b22934be64
commit a644735e6e
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
protocols/kad/src/behaviour.rs
View File

@ -510,6 +510,11 @@ where
)); ));
} else { } else {
let target = kbucket::Key::new(key.clone()); let target = kbucket::Key::new(key.clone());
println!(
"start_providing for key {} ; kademlia key {}",
bs58::encode(target.preimage().as_ref()).into_string(), // peer id
bs58::encode(target.as_ref()).into_string(), // sha256
);
let peers = self.kbuckets.closest_keys(&target); let peers = self.kbuckets.closest_keys(&target);
let context = AddProviderContext::Publish; let context = AddProviderContext::Publish;
let info = QueryInfo::PrepareAddProvider { key, context }; let info = QueryInfo::PrepareAddProvider { key, context };
@ -1261,6 +1266,10 @@ where
KademliaHandlerEvent::GetProvidersReq { key, request_id } => { KademliaHandlerEvent::GetProvidersReq { key, request_id } => {
let provider_peers = self.provider_peers(&key, &source); let provider_peers = self.provider_peers(&key, &source);
println!(
"provider peers: {}",
provider_peers.iter().map(|p| p.node_id.to_base58() + ", ").collect::<String>()
);
let closer_peers = self.find_closest(&kbucket::Key::new(key), &source); let closer_peers = self.find_closest(&kbucket::Key::new(key), &source);
self.queued_events.push_back(NetworkBehaviourAction::NotifyHandler { self.queued_events.push_back(NetworkBehaviourAction::NotifyHandler {
peer_id: source, peer_id: source,