jake/elseware
1
0
Fork 0
Code Issues63 Pull Requests1 Projects Releases Wiki Activity

whitespace

Browse Source
This commit is contained in:
jake 2019-09-13 19:21:01 -07:00
parent ddf7701118
commit dc35c5b82c
1 changed files with 4 additions and 4 deletions

8
src/common/clientpool.rs

@ -28,7 +28,7 @@ fn client_read<S, R>(sender: &Sender<ClientPoolAction<R>>, client: &mut Client<S
println!("client read"); println!("client read");
let pkts = client.read_pkts(); let pkts = client.read_pkts();
println!("pkts: {:?}", pkts); println!("pkts: {:?}", pkts);
for pkt in pkts? { for pkt in pkts? {
sender.send(ClientPoolAction::Packet(client.id, pkt)).unwrap(); sender.send(ClientPoolAction::Packet(client.id, pkt)).unwrap();
} }
@ -89,7 +89,7 @@ impl<S, R> ClientPool<S, R> where
fn new_client(&mut self) { fn new_client(&mut self) {
let (socket, _addr) = self.listener.accept().unwrap(); let (socket, _addr) = self.listener.accept().unwrap();
let client_id = self.client_id_incr; let client_id = self.client_id_incr;
self.client_id_incr += 1; self.client_id_incr += 1;
@ -134,11 +134,11 @@ impl<S, R> ClientPool<S, R> where
} }
} }
} }
} }
} }
pub fn io_loop(mut self) { pub fn io_loop(mut self) {
self.poll.register(&self.listener, Token(0), Ready::readable(), PollOpt::edge()).unwrap(); self.poll.register(&self.listener, Token(0), Ready::readable(), PollOpt::edge()).unwrap();
self.poll.register(&self.receiver, Token(1), Ready::readable(), PollOpt::edge()).unwrap(); self.poll.register(&self.receiver, Token(1), Ready::readable(), PollOpt::edge()).unwrap();