From f81cc0802713e621ea33cfe4bca3f39eb0bdcc72 Mon Sep 17 00:00:00 2001 From: Pierre Krieger Date: Thu, 15 Mar 2018 16:08:49 +0100 Subject: [PATCH] Add logging to tcp-transport (#141) --- libp2p-tcp-transport/Cargo.toml | 1 + libp2p-tcp-transport/src/lib.rs | 6 ++++++ 2 files changed, 7 insertions(+) diff --git a/libp2p-tcp-transport/Cargo.toml b/libp2p-tcp-transport/Cargo.toml index 5a0f50b0..3ab8827c 100644 --- a/libp2p-tcp-transport/Cargo.toml +++ b/libp2p-tcp-transport/Cargo.toml @@ -5,6 +5,7 @@ authors = ["Parity Technologies "] [dependencies] libp2p-swarm = { path = "../libp2p-swarm" } +log = "0.4.1" futures = "0.1" multiaddr = "0.2.0" tokio-core = "0.1" diff --git a/libp2p-tcp-transport/src/lib.rs b/libp2p-tcp-transport/src/lib.rs index 90f88e86..e6343965 100644 --- a/libp2p-tcp-transport/src/lib.rs +++ b/libp2p-tcp-transport/src/lib.rs @@ -51,6 +51,8 @@ extern crate futures; extern crate libp2p_swarm as swarm; +#[macro_use] +extern crate log; extern crate multiaddr; extern crate tokio_core; extern crate tokio_io; @@ -109,12 +111,15 @@ impl Transport for TcpConfig { Err(_) => addr, }; + debug!(target: "libp2p-tcp-transport", "Now listening on {}", new_addr); + let future = future::result(listener) .map(|listener| { // Pull out a stream of sockets for incoming connections listener.incoming().map(|(sock, addr)| { let addr = addr.to_multiaddr() .expect("generating a multiaddr from a socket addr never fails"); + debug!(target: "libp2p-tcp-transport", "Incoming connection from {}", addr); Ok((sock, addr)).into_future() }) }) @@ -130,6 +135,7 @@ impl Transport for TcpConfig { /// or gives back the multiaddress. fn dial(self, addr: Multiaddr) -> Result { if let Ok(socket_addr) = multiaddr_to_socketaddr(&addr) { + debug!(target: "libp2p-tcp-transport", "Dialing {}", addr); let fut = TcpStream::connect(&socket_addr, &self.event_loop).map(|t| (t, addr)); Ok(Box::new(fut) as Box<_>) } else {