diff options
Diffstat (limited to 'src/peering')
| -rw-r--r-- | src/peering/basalt.rs | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/src/peering/basalt.rs b/src/peering/basalt.rs index 5da65e0..00cfd60 100644 --- a/src/peering/basalt.rs +++ b/src/peering/basalt.rs @@ -3,7 +3,7 @@ use std::net::SocketAddr; use std::sync::{Arc, RwLock}; use std::time::Duration; -use log::{debug, warn}; +use log::{debug, info, warn}; use lru::LruCache; use rand::{thread_rng, Rng}; use serde::{Deserialize, Serialize}; @@ -302,7 +302,10 @@ impl Basalt { .unwrap() .sample(count) .iter() - .map(|p| p.id) + .map(|p| { + info!("KYEV S {}", hex::encode(p.id)); + p.id + }) .collect::<Vec<_>>() } @@ -421,6 +424,7 @@ impl Basalt { if is_incoming { self.handle_peer_list(&[Peer { id: pk, addr }][..]); } else { + info!("KYEV C {}", hex::encode(pk)); let peer = Peer { id: pk, addr }; let mut backlog = self.backlog.write().unwrap(); @@ -443,6 +447,7 @@ impl Basalt { fn on_disconnected(&self, pk: ed25519::PublicKey, is_incoming: bool) { if !is_incoming { + info!("KYEV D {}", hex::encode(pk)); self.view.write().unwrap().disconnected(pk); } } |