diff options
Diffstat (limited to 'p2p')
| -rw-r--r-- | p2p/src/discovery/lookup.rs | 8 | ||||
| -rw-r--r-- | p2p/src/peer/mod.rs | 2 |
2 files changed, 5 insertions, 5 deletions
diff --git a/p2p/src/discovery/lookup.rs b/p2p/src/discovery/lookup.rs index 3beea7e..677bad7 100644 --- a/p2p/src/discovery/lookup.rs +++ b/p2p/src/discovery/lookup.rs @@ -345,7 +345,7 @@ impl LookupService { /// Sends a Pong msg async fn send_pong_msg(&self, nonce: [u8; 32], conn: &Conn<NetMsg>) -> Result<()> { trace!("Send Pong msg"); - conn.send(NetMsg::new(NetMsgCmd::Pong, &PongMsg(nonce))?) + conn.send(NetMsg::new(NetMsgCmd::Pong, PongMsg(nonce))?) .await?; Ok(()) } @@ -355,7 +355,7 @@ impl LookupService { trace!("Send FindPeer msg"); conn.send(NetMsg::new( NetMsgCmd::FindPeer, - &FindPeerMsg(peer_id.clone()), + FindPeerMsg(peer_id.clone()), )?) .await?; @@ -376,7 +376,7 @@ impl LookupService { .closest_entries(&peer_id.0, MAX_PEERS_IN_PEERSMSG); let peers: Vec<PeerMsg> = entries.into_iter().map(|e| e.into()).collect(); - conn.send(NetMsg::new(NetMsgCmd::Peers, &PeersMsg(peers))?) + conn.send(NetMsg::new(NetMsgCmd::Peers, PeersMsg(peers))?) .await?; Ok(()) } @@ -397,7 +397,7 @@ impl LookupService { /// Sends a Shutdown msg. async fn send_shutdown_msg(&self, conn: &Conn<NetMsg>) -> Result<()> { trace!("Send Shutdown msg"); - conn.send(NetMsg::new(NetMsgCmd::Shutdown, &ShutdownMsg(0))?) + conn.send(NetMsg::new(NetMsgCmd::Shutdown, ShutdownMsg(0))?) .await?; Ok(()) } diff --git a/p2p/src/peer/mod.rs b/p2p/src/peer/mod.rs index b4cfd3a..0d42da3 100644 --- a/p2p/src/peer/mod.rs +++ b/p2p/src/peer/mod.rs @@ -124,7 +124,7 @@ impl Peer { // No need to handle the error here let shutdown_msg = - NetMsg::new(NetMsgCmd::Shutdown, &ShutdownMsg(0)).expect("pack shutdown message"); + NetMsg::new(NetMsgCmd::Shutdown, ShutdownMsg(0)).expect("pack shutdown message"); let _ = self.conn.send(shutdown_msg).await; // Force shutting down |