equal
deleted
inserted
replaced
14 Poll, PollOpt, Ready, Token, |
14 Poll, PollOpt, Ready, Token, |
15 }; |
15 }; |
16 use netbuf; |
16 use netbuf; |
17 use slab::Slab; |
17 use slab::Slab; |
18 |
18 |
19 use super::{core::FileServerIO, core::HWServer, coretypes::ClientId, handlers}; |
19 use super::{core::HWServer, coretypes::ClientId, handlers}; |
20 use crate::{ |
20 use crate::{ |
21 protocol::{messages::*, ProtocolDecoder}, |
21 protocol::{messages::*, ProtocolDecoder}, |
22 utils, |
22 utils, |
23 }; |
23 }; |
24 |
24 |
301 io: IoLayer, |
301 io: IoLayer, |
302 } |
302 } |
303 |
303 |
304 impl NetworkLayer { |
304 impl NetworkLayer { |
305 pub fn new(listener: TcpListener, clients_limit: usize, rooms_limit: usize) -> NetworkLayer { |
305 pub fn new(listener: TcpListener, clients_limit: usize, rooms_limit: usize) -> NetworkLayer { |
306 let server = HWServer::new(clients_limit, rooms_limit, Box::new(FileServerIO::new())); |
306 let server = HWServer::new(clients_limit, rooms_limit); |
307 let clients = Slab::with_capacity(clients_limit); |
307 let clients = Slab::with_capacity(clients_limit); |
308 let pending = HashSet::with_capacity(2 * clients_limit); |
308 let pending = HashSet::with_capacity(2 * clients_limit); |
309 let pending_cache = Vec::with_capacity(2 * clients_limit); |
309 let pending_cache = Vec::with_capacity(2 * clients_limit); |
310 |
310 |
311 NetworkLayer { |
311 NetworkLayer { |