diff --git a/ntex-server/src/manager.rs b/ntex-server/src/manager.rs index a19aa801..8e56f285 100644 --- a/ntex-server/src/manager.rs +++ b/ntex-server/src/manager.rs @@ -55,7 +55,7 @@ impl ServerManager { let no_signals = cfg.no_signals; let shared = Arc::new(ServerShared { - paused: AtomicBool::new(true), + paused: AtomicBool::new(false), }); let mgr = ServerManager(Rc::new(Inner { cfg, diff --git a/ntex-server/src/server.rs b/ntex-server/src/server.rs index 5f860b40..dde63a17 100644 --- a/ntex-server/src/server.rs +++ b/ntex-server/src/server.rs @@ -40,6 +40,7 @@ impl Server { /// Send item to worker pool pub fn process(&self, item: T) -> Result<(), T> { if self.shared.paused.load(Ordering::Acquire) { + println!("--------- PAUSED"); Err(item) } else if let Err(e) = self.cmd.try_send(ServerCommand::Item(item)) { match e.into_inner() {