equal
deleted
inserted
replaced
29 PollOpt::edge()) |
29 PollOpt::edge()) |
30 } |
30 } |
31 |
31 |
32 pub fn accept(&mut self, poll: &Poll) -> io::Result<()> { |
32 pub fn accept(&mut self, poll: &Poll) -> io::Result<()> { |
33 let (sock, addr) = self.listener.accept()?; |
33 let (sock, addr) = self.listener.accept()?; |
34 println!("Connected: {}", addr); |
34 info!("Connected: {}", addr); |
35 |
35 |
36 let client = HWClient::new(sock); |
36 let client = HWClient::new(sock); |
37 let token = self.clients.insert(client) |
37 let token = self.clients.insert(client) |
38 .ok().expect("could not add connection to slab"); |
38 .ok().expect("could not add connection to slab"); |
39 |
39 |
49 |
49 |
50 pub fn client_writable(&mut self, poll: &Poll, |
50 pub fn client_writable(&mut self, poll: &Poll, |
51 token: Token) -> io::Result<()> { |
51 token: Token) -> io::Result<()> { |
52 self.clients[token].writable(poll) |
52 self.clients[token].writable(poll) |
53 } |
53 } |
|
54 |
|
55 pub fn client_error(&mut self, poll: &Poll, |
|
56 token: Token) -> io::Result<()> { |
|
57 self.clients[token].error(poll) |
|
58 } |
54 } |
59 } |
55 |
60 |
56 |
61 |
57 struct HWRoom { |
62 struct HWRoom { |
58 name: String |
63 name: String |