Colocate packet dependencies

This commit is contained in:
Greg Fitzgerald 2018-03-29 12:55:41 -06:00
parent 1fbb34620c
commit 232e1bb8a3
1 changed files with 2 additions and 1 deletions

View File

@ -101,6 +101,7 @@ impl<W: Write + Send + 'static> AccountantSkel<W> {
let mut num = 0;
let mut ursps = rsps.write().unwrap();
for packet in &msgs.read().unwrap().packets {
let rsp_addr = packet.meta.get_addr();
let sz = packet.meta.size;
let req = deserialize(&packet.data[0..sz])?;
if let Some(resp) = obj.lock().unwrap().process_request(req) {
@ -114,7 +115,7 @@ impl<W: Write + Send + 'static> AccountantSkel<W> {
let len = v.len();
rsp.data[..len].copy_from_slice(&v);
rsp.meta.size = len;
rsp.meta.set_addr(&packet.meta.get_addr());
rsp.meta.set_addr(&rsp_addr);
num += 1;
}
}