mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-03 21:07:39 +03:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Nikolay Kim 2024-09-24 13:30:13 +05:00
parent 95a0134c7b
commit 8573ed5dd1
1 changed files with 7 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

16
ntex-server/src/manager.rs
View file

@ -3,7 +3,8 @@ use std::{cell::Cell, cell::RefCell, collections::VecDeque, rc::Rc, sync::Arc};
use async_channel::{unbounded, Receiver, Sender};
use ntex_rt::System;
use ntex_util::{future::join_all, time::sleep, time::Millis};
use ntex_util::future::join_all;
use ntex_util::time::{sleep, timeout, Millis};
use crate::server::ServerShared;
use crate::signals::Signal;
@ -238,16 +239,13 @@ impl<F: ServerConfiguration> HandleCmdState<F> {
// stop workers
if !self.workers.is_empty() {
let timeout = self.mgr.0.cfg.shutdown_timeout;
let to = self.mgr.0.cfg.shutdown_timeout;
if graceful && !timeout.is_zero() {
let futs: Vec<_> = self
.workers
.iter()
.map(|worker| worker.stop(timeout))
.collect();
if graceful && !to.is_zero() {
let futs: Vec<_> =
self.workers.iter().map(|worker| worker.stop(to)).collect();
let _ = join_all(futs).await;
let _ = timeout(to, join_all(futs)).await;
} else {
self.workers.iter().for_each(|worker| {
let _ = worker.stop(Millis::ZERO);