gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Why is msgs cloned here?

Browse Source
This commit is contained in:
Greg Fitzgerald
2018-04-06 15:58:11 -06:00
parent 6869089111
commit 912a5f951e
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/accountant_skel.rs
View File

@ -159,7 +159,6 @@ impl<W: Write + Send + 'static> AccountantSkel<W> {
let timer = Duration::new(1, 0); let timer = Duration::new(1, 0);
let (mms, vvs) = verified_receiver.recv_timeout(timer)?; let (mms, vvs) = verified_receiver.recv_timeout(timer)?;
for (msgs, vers) in mms.into_iter().zip(vvs.into_iter()) { for (msgs, vers) in mms.into_iter().zip(vvs.into_iter()) {
let msgs_ = msgs.clone();
let mut rsps = VecDeque::new(); let mut rsps = VecDeque::new();
{ {
let reqs = Self::deserialize_packets(&((*msgs).read().unwrap())); let reqs = Self::deserialize_packets(&((*msgs).read().unwrap()));
@ -187,7 +186,7 @@ impl<W: Write + Send + 'static> AccountantSkel<W> {
//don't wake up the other side if there is nothing //don't wake up the other side if there is nothing
blob_sender.send(rsps)?; blob_sender.send(rsps)?;
} }
packet_recycler.recycle(msgs_); packet_recycler.recycle(msgs);
} }
Ok(()) Ok(())
} }