aboutsummaryrefslogtreecommitdiff
path: root/src/peering/basalt.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/peering/basalt.rs')
-rw-r--r--src/peering/basalt.rs9
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);
}
}