tsarevvv/rust-ipfs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: tweak some kademlia log levels

Browse Source 
Signed-off-by: ljedrz <ljedrz@gmail.com>
This commit is contained in:
ljedrz 2020-07-31 17:04:57 +02:00
parent 6b6ddcdce2
commit ed20a189e7
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/p2p/behaviour.rs
View File

@ -84,7 +84,7 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
} }
GetClosestPeers(Ok(GetClosestPeersOk { key: _, peers })) => { GetClosestPeers(Ok(GetClosestPeersOk { key: _, peers })) => {
for peer in peers { for peer in peers {
info!("kad: peer {} is close", peer); debug!("kad: peer {} is close", peer);
} }
} }
GetClosestPeers(Err(GetClosestPeersError::Timeout { key: _, peers })) => { GetClosestPeers(Err(GetClosestPeersError::Timeout { key: _, peers })) => {
@ -92,7 +92,7 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
"kad: timed out trying to find all closest peers; got the following:" "kad: timed out trying to find all closest peers; got the following:"
); );
for peer in peers { for peer in peers {
info!("kad: peer {} is close", peer); debug!("kad: peer {} is close", peer);
} }
} }
GetProviders(Ok(GetProvidersOk { GetProviders(Ok(GetProvidersOk {
@ -105,7 +105,7 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
warn!("kad: could not find a provider for {}", key); warn!("kad: could not find a provider for {}", key);
} else { } else {
for peer in closest_peers.into_iter().chain(providers.into_iter()) { for peer in closest_peers.into_iter().chain(providers.into_iter()) {
info!("kad: {} is provided by {}", key, peer); debug!("kad: {} is provided by {}", key, peer);
self.bitswap.connect(peer); self.bitswap.connect(peer);
} }
} }
@ -116,7 +116,7 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
} }
StartProviding(Ok(AddProviderOk { key })) => { StartProviding(Ok(AddProviderOk { key })) => {
let key = multibase::encode(Base::Base32Lower, key); let key = multibase::encode(Base::Base32Lower, key);
info!("kad: providing {}", key); debug!("kad: providing {}", key);
} }
StartProviding(Err(AddProviderError::Timeout { key })) => { StartProviding(Err(AddProviderError::Timeout { key })) => {
let key = multibase::encode(Base::Base32Lower, key); let key = multibase::encode(Base::Base32Lower, key);
@ -124,7 +124,7 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
} }
RepublishProvider(Ok(AddProviderOk { key })) => { RepublishProvider(Ok(AddProviderOk { key })) => {
let key = multibase::encode(Base::Base32Lower, key); let key = multibase::encode(Base::Base32Lower, key);
info!("kad: republished provider {}", key); debug!("kad: republished provider {}", key);
} }
RepublishProvider(Err(AddProviderError::Timeout { key })) => { RepublishProvider(Err(AddProviderError::Timeout { key })) => {
let key = multibase::encode(Base::Base32Lower, key); let key = multibase::encode(Base::Base32Lower, key);
@ -133,7 +133,7 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
GetRecord(Ok(GetRecordOk { records })) => { GetRecord(Ok(GetRecordOk { records })) => {
for record in records { for record in records {
let key = multibase::encode(Base::Base32Lower, record.record.key); let key = multibase::encode(Base::Base32Lower, record.record.key);
info!("kad: got record {}:{:?}", key, record.record.value); debug!("kad: got record {}:{:?}", key, record.record.value);
} }
} }
GetRecord(Err(GetRecordError::NotFound { GetRecord(Err(GetRecordError::NotFound {
@ -156,7 +156,7 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
); );
for record in records { for record in records {
let key = multibase::encode(Base::Base32Lower, record.record.key); let key = multibase::encode(Base::Base32Lower, record.record.key);
info!("kad: got record {}:{:?}", key, record.record.value); debug!("kad: got record {}:{:?}", key, record.record.value);
} }
} }
GetRecord(Err(GetRecordError::Timeout { GetRecord(Err(GetRecordError::Timeout {
@ -172,13 +172,13 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
); );
for record in records { for record in records {
let key = multibase::encode(Base::Base32Lower, record.record.key); let key = multibase::encode(Base::Base32Lower, record.record.key);
info!("kad: got record {}:{:?}", key, record.record.value); debug!("kad: got record {}:{:?}", key, record.record.value);
} }
} }
PutRecord(Ok(PutRecordOk { key })) PutRecord(Ok(PutRecordOk { key }))
| RepublishRecord(Ok(PutRecordOk { key })) => { | RepublishRecord(Ok(PutRecordOk { key })) => {
let key = multibase::encode(Base::Base32Lower, key); let key = multibase::encode(Base::Base32Lower, key);
info!("kad: successfully put record {}", key); debug!("kad: successfully put record {}", key);
} }
PutRecord(Err(PutRecordError::QuorumFailed { PutRecord(Err(PutRecordError::QuorumFailed {
key, key,
@ -191,7 +191,7 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
quorum, quorum,
})) => { })) => {
let key = multibase::encode(Base::Base32Lower, key); let key = multibase::encode(Base::Base32Lower, key);
info!( warn!(
"kad: quorum failed ({}) trying to put record {}", "kad: quorum failed ({}) trying to put record {}",
quorum, key quorum, key
); );
@ -207,7 +207,7 @@ impl<Types: IpfsTypes> NetworkBehaviourEventProcess<KademliaEvent> for Behaviour
quorum: _, quorum: _,
})) => { })) => {
let key = multibase::encode(Base::Base32Lower, key); let key = multibase::encode(Base::Base32Lower, key);
info!("kad: timed out trying to put record {}", key); warn!("kad: timed out trying to put record {}", key);
} }
} }
} }