diff --git a/substrate/network-libp2p/src/service.rs b/substrate/network-libp2p/src/service.rs index 2c82d608d15e2..435958756e114 100644 --- a/substrate/network-libp2p/src/service.rs +++ b/substrate/network-libp2p/src/service.rs @@ -495,8 +495,13 @@ fn init_thread( trace!(target: "sub-libp2p", "Dialing bootnode {:?}", peer_id); for proto in shared.protocols.read().0.clone().into_iter() { - open_peer_custom_proto(shared.clone(), transport.clone(), - proto, peer_id.clone(), &swarm_controller) + open_peer_custom_proto( + shared.clone(), + transport.clone(), + proto, + peer_id.clone(), + &swarm_controller + ) } } @@ -843,8 +848,7 @@ fn start_kademlia_discovery(shared: Arc, transport: T, .for_each({ let shared = shared.clone(); move |_| { - connect_to_nodes(shared.clone(), transport.clone(), - &swarm_controller); + connect_to_nodes(shared.clone(), transport.clone(), &swarm_controller); Ok(()) } }); @@ -940,8 +944,13 @@ fn connect_to_nodes( // should automatically open multiple substreams. trace!(target: "sub-libp2p", "Ensuring connection to {:?}", peer); for proto in shared.protocols.read().0.clone().into_iter() { - open_peer_custom_proto(shared.clone(), base_transport.clone(), - proto, peer.clone(), swarm_controller) + open_peer_custom_proto( + shared.clone(), + base_transport.clone(), + proto, + peer.clone(), + swarm_controller + ) } } } diff --git a/substrate/network-libp2p/src/transport.rs b/substrate/network-libp2p/src/transport.rs index 0b9497c2f0405..594137f49795f 100644 --- a/substrate/network-libp2p/src/transport.rs +++ b/substrate/network-libp2p/src/transport.rs @@ -57,8 +57,7 @@ pub fn build_transport( TransportTimeout::new(base, Duration::from_secs(20)) .map_err(|err| { - debug!(target: "sub-libp2p", "Error in base transport \ - layer: {:?}", err); + debug!(target: "sub-libp2p", "Error in base transport layer: {:?}", err); err }) }