diff --git a/ntex-server/src/net/accept.rs b/ntex-server/src/net/accept.rs index fd900f12..ce99303a 100644 --- a/ntex-server/src/net/accept.rs +++ b/ntex-server/src/net/accept.rs @@ -193,6 +193,7 @@ impl Accept { let mut events = Events::with_capacity(NonZeroUsize::new(512).unwrap()); loop { + println!("------- ACCEPT LOOP"); if let Err(e) = self.poller.wait(&mut events, None) { if e.kind() == io::ErrorKind::Interrupted { continue; @@ -202,6 +203,7 @@ impl Accept { } for event in events.iter() { + println!("------- ACCEPTED {:?}", event); let readd = self.accept(event.key); if readd { self.add_source(event.key); @@ -378,6 +380,7 @@ impl Accept { } fn accept(&mut self, token: usize) -> bool { + println!("------- ACCEPTING 1 {:?}", token); loop { if let Some(info) = self.sockets.get_mut(token) { let item = info.sock.accept(); diff --git a/ntex-server/src/wrk.rs b/ntex-server/src/wrk.rs index 7aa008ae..66b8a116 100644 --- a/ntex-server/src/wrk.rs +++ b/ntex-server/src/wrk.rs @@ -260,7 +260,7 @@ where T: Send + 'static, F: ServiceFactory + 'static, { - //println!("------- start worker {:?}", wrk.id); + println!("------- start worker {:?}", wrk.id); loop { //println!("------- run worker {:?}", wrk.id);