From 36eae63e84f22c9973edee699d3388ee2674874e Mon Sep 17 00:00:00 2001 From: hozan23 Date: Sat, 1 Jun 2024 21:30:23 +0200 Subject: p2p: fix cargo clippy warnings --- p2p/src/discovery/lookup.rs | 8 ++++---- p2p/src/peer/mod.rs | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) (limited to 'p2p') 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) -> 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 = 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) -> 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 -- cgit v1.2.3