modify
This commit is contained in:
@@ -61,6 +61,7 @@ class OnWorkerStart extends Callback
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $server
|
* @param $server
|
||||||
* @param $worker_id
|
* @param $worker_id
|
||||||
@@ -70,7 +71,7 @@ class OnWorkerStart extends Callback
|
|||||||
Coroutine\go(function (Server $server, $worker_id) {
|
Coroutine\go(function (Server $server, $worker_id) {
|
||||||
$sigkill = Coroutine::waitSignal(SIGTERM | SIGKILL | SIGUSR2 | SIGUSR1);
|
$sigkill = Coroutine::waitSignal(SIGTERM | SIGKILL | SIGUSR2 | SIGUSR1);
|
||||||
if ($sigkill !== false) {
|
if ($sigkill !== false) {
|
||||||
return Process::kill($server->worker_pid);
|
return Process::kill($server->worker_pid,0);
|
||||||
}
|
}
|
||||||
do {
|
do {
|
||||||
$number = Coroutine::stats()['coroutine_num'];
|
$number = Coroutine::stats()['coroutine_num'];
|
||||||
|
|||||||
Reference in New Issue
Block a user