Cuprate/cuprate
Cuprate/cuprate
1
0
Fork 0
mirror of https://github.com/Cuprate/cuprate.git synced 2024-12-22 19:49:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

monero-p2p: tell client message was sent after sending message.

Browse source 
Otherwise, the message might not be sent
This commit is contained in:
Boog900 2024-01-13 15:56:22 +00:00
parent f7149863ae
commit 0cc2acc816
No known key found for this signature in database
GPG key ID: 5401367FB7302004
2 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
net/levin/src/codec.rs
View file

@ -15,7 +15,6 @@
//! A tokio-codec for levin buckets //! A tokio-codec for levin buckets
use std::io::ErrorKind;
use std::marker::PhantomData; use std::marker::PhantomData;
use bytes::{Buf, BufMut, BytesMut}; use bytes::{Buf, BufMut, BytesMut};

13
p2p/monero-p2p/src/client/connection.rs
View file

@ -97,11 +97,18 @@ where
request_id: req.request.id(), request_id: req.request.id(),
tx: req.response_channel, tx: req.response_channel,
}; };
self.send_message_to_peer(req.request.into()).await?;
} else { } else {
// TODO: we should send this after sending the message to the peer. let res = self.send_message_to_peer(req.request.into()).await;
req.response_channel.send(Ok(PeerResponse::NA)); if let Err(e) = res {
let err_str = e.to_string();
let _ = req.response_channel.send(Err(err_str.clone().into()));
Err(e)?
} else {
req.response_channel.send(Ok(PeerResponse::NA));
}
} }
self.send_message_to_peer(req.request.into()).await Ok(())
} }
async fn handle_peer_request(&mut self, req: PeerRequest) -> Result<(), PeerError> { async fn handle_peer_request(&mut self, req: PeerRequest) -> Result<(), PeerError> {