aboutsummaryrefslogtreecommitdiff
path: root/p2p/src
diff options
context:
space:
mode:
Diffstat (limited to 'p2p/src')
-rw-r--r--p2p/src/discovery/lookup.rs8
-rw-r--r--p2p/src/peer/mod.rs2
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