Mirrored_Repos/veloren
1
0
Fork 0
mirror of https://gitlab.com/veloren/veloren.git synced 2024-08-30 18:12:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Avoid clone in Stream::send

Browse Source
This commit is contained in:
Isse 2022-05-09 14:48:13 +00:00 committed by Marcel
parent 6b69fbe9c5
commit 06f0239130
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
network/src/api.rs
View File

@ -842,7 +842,7 @@ impl Stream {
/// [`Serialized`]: Serialize
#[inline]
pub fn send<M: Serialize>(&mut self, msg: M) -> Result<(), StreamError> {
self.send_raw(&Message::serialize(&msg, self.params()))
self.send_raw_move(Message::serialize(&msg, self.params()))
}
/// This methods give the option to skip multiple calls of [`bincode`] and
@ -892,13 +892,22 @@ impl Stream {
/// [`Participants`]: crate::api::Participant
/// [`compress`]: lz_fear::raw::compress2
/// [`Message::serialize`]: crate::message::Message::serialize
#[inline]
pub fn send_raw(&mut self, message: &Message) -> Result<(), StreamError> {
self.send_raw_move(Message {
data: message.data.clone(),
#[cfg(feature = "compression")]
compressed: message.compressed,
})
}
fn send_raw_move(&mut self, message: Message) -> Result<(), StreamError> {
if self.send_closed.load(Ordering::Relaxed) {
return Err(StreamError::StreamClosed);
}
#[cfg(debug_assertions)]
message.verify(self.params());
self.a2b_msg_s.send((self.sid, message.data.clone()))?;
self.a2b_msg_s.send((self.sid, message.data))?;
Ok(())
}