diff --git a/radicle-node/Cargo.toml b/radicle-node/Cargo.toml index 0a59b871..bb33bdbd 100644 --- a/radicle-node/Cargo.toml +++ b/radicle-node/Cargo.toml @@ -24,7 +24,7 @@ log = { version = "0.4.17", features = ["std"] } nakamoto-net = { version = "0.3.0" } netservices = { version = "0", features = ["io-reactor", "socket2", "log"] } nonempty = { version = "0.8.1", features = ["serialize"] } -io-reactor = { version = "0", features = ["popol", "socket2", "log"] } +io-reactor = { version = "0", features = ["popol", "socket2"] } qcheck = { version = "1", default-features = false, optional = true } sqlite = { version = "0.30.3" } sqlite3-src = { version = "0.4.0", features = ["bundled"] } # Ensures static linking diff --git a/radicle-node/src/service/reactor.rs b/radicle-node/src/service/reactor.rs index 5d64fece..f6f768bc 100644 --- a/radicle-node/src/service/reactor.rs +++ b/radicle-node/src/service/reactor.rs @@ -80,9 +80,14 @@ impl Reactor { pub fn write_all(&mut self, remote: NodeId, msgs: impl IntoIterator) { let msgs = msgs.into_iter().collect::>(); - let len = msgs.len(); - for (no, msg) in msgs.iter().enumerate() { - debug!("Write {no}/{len} {:?} message to {}", msg, remote); + for (ix, msg) in msgs.iter().enumerate() { + debug!( + "Write {:?} message to {} ({}/{})", + msg, + remote, + ix + 1, + msgs.len() + ); } self.io.push_back(Io::Write(remote, msgs)); } diff --git a/radicle-node/src/wire/protocol.rs b/radicle-node/src/wire/protocol.rs index 4a79a571..2c6e06f7 100644 --- a/radicle-node/src/wire/protocol.rs +++ b/radicle-node/src/wire/protocol.rs @@ -31,8 +31,11 @@ use crate::worker::{WorkerReq, WorkerResp}; use crate::Link; use crate::{address, service}; +/// Peer session type. pub type WireSession = CypherSession; +/// Peer session type (read-only). pub type WireReader = CypherReader; +/// Peer session type (write-only). pub type WireWriter = CypherWriter; /// Reactor action. @@ -572,8 +575,8 @@ where while let Some(ev) = self.service.next() { match ev { Io::Write(node_id, msgs) => { - log::debug!( - target: "transport", "Sending {} message(s) to {}", msgs.len(), node_id + log::trace!( + target: "transport", "Writing {} message(s) to {}", msgs.len(), node_id ); let fd = self.connected_fd_by_id(&node_id); let mut data = Vec::new();