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

wip

Browse Source
This commit is contained in:
Anatoly Yakovenko
2018-03-25 08:06:33 -07:00
parent 62af09adbe
commit 290960c3b5
2 changed files with 2 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/accountant_skel.rs
View File

@ -99,7 +99,6 @@ impl AccountantSkel {
let timer = Duration::new(1, 0); let timer = Duration::new(1, 0);
let msgs = r_reader.recv_timeout(timer)?; let msgs = r_reader.recv_timeout(timer)?;
let msgs_ = msgs.clone(); let msgs_ = msgs.clone();
let msgs__ = msgs.clone();
let rsps = streamer::allocate(response_recycler); let rsps = streamer::allocate(response_recycler);
let rsps_ = rsps.clone(); let rsps_ = rsps.clone();
{ {
@ -109,7 +108,7 @@ impl AccountantSkel {
let sz = packet.meta.size; let sz = packet.meta.size;
let req = deserialize(&packet.data[0..sz])?; let req = deserialize(&packet.data[0..sz])?;
if let Some(resp) = self.process_request(req) { if let Some(resp) = self.process_request(req) {
if ursps.len() <= num { if ursps.responses.len() <= num {
ursps ursps
.responses .responses
.resize(num * 2, streamer::Response::default()); .resize(num * 2, streamer::Response::default());
@ -123,7 +122,7 @@ impl AccountantSkel {
num += 1; num += 1;
} }
} }
ursps.packets.resize(num, streamer::Packet::default()); ursps.responses.resize(num, streamer::Response::default());
} }
s_responder.send(rsps_)?; s_responder.send(rsps_)?;
streamer::recycle(packet_recycler, msgs_); streamer::recycle(packet_recycler, msgs_);

9
src/streamer.rs
View File

@ -184,15 +184,6 @@ impl Packets {
self.packets.resize(sz, Packet::default()); self.packets.resize(sz, Packet::default());
Ok(()) Ok(())
} }
fn send_to(&self, socket: &UdpSocket, num: &mut usize) -> Result<()> {
for p in &self.packets {
let a = p.meta.get_addr();
socket.send_to(&p.data[..p.meta.size], &a)?;
//TODO(anatoly): wtf do we do about errors?
*num += 1;
}
Ok(())
}
} }
impl Responses { impl Responses {