diff options
| -rw-r--r-- | Cargo.lock | 10 | ||||
| -rw-r--r-- | p2p/src/discovery/lookup.rs | 8 | ||||
| -rw-r--r-- | p2p/src/peer/mod.rs | 2 |
3 files changed, 10 insertions, 10 deletions
@@ -1231,7 +1231,7 @@ dependencies = [ [[package]] name = "karyon_core" -version = "0.1.0" +version = "0.1.1" dependencies = [ "async-channel 2.3.1", "async-process", @@ -1251,7 +1251,7 @@ dependencies = [ [[package]] name = "karyon_jsonrpc" -version = "0.1.0" +version = "0.1.1" dependencies = [ "async-channel 2.3.1", "async-trait", @@ -1275,7 +1275,7 @@ dependencies = [ [[package]] name = "karyon_jsonrpc_macro" -version = "0.1.0" +version = "0.1.1" dependencies = [ "proc-macro2", "quote", @@ -1285,7 +1285,7 @@ dependencies = [ [[package]] name = "karyon_net" -version = "0.1.0" +version = "0.1.1" dependencies = [ "async-channel 2.3.1", "async-trait", @@ -1307,7 +1307,7 @@ dependencies = [ [[package]] name = "karyon_p2p" -version = "0.1.0" +version = "0.1.1" dependencies = [ "async-channel 2.3.1", "async-std", 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 |