改名
This commit is contained in:
@@ -22,11 +22,6 @@ use Swoole\Server;
|
|||||||
class OnWorkerStart extends Callback
|
class OnWorkerStart extends Callback
|
||||||
{
|
{
|
||||||
|
|
||||||
/** @var int 重启信号 */
|
|
||||||
private int $signal = SIGUSR1 | SIGKILL | SIGKILL;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param Server $server
|
* @param Server $server
|
||||||
* @param int $worker_id
|
* @param int $worker_id
|
||||||
@@ -46,7 +41,6 @@ class OnWorkerStart extends Callback
|
|||||||
}
|
}
|
||||||
|
|
||||||
$this->debug(sprintf('%s #%d Pid:%d start.', ucfirst(env('environmental')), $worker_id, $server->worker_pid));
|
$this->debug(sprintf('%s #%d Pid:%d start.', ucfirst(env('environmental')), $worker_id, $server->worker_pid));
|
||||||
Coroutine\go([$this, 'onSignal'], $server, $worker_id);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@@ -85,21 +79,6 @@ class OnWorkerStart extends Callback
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @param $server
|
|
||||||
* @param $worker_id
|
|
||||||
* @return void
|
|
||||||
*/
|
|
||||||
public function onSignal(Server $server, $worker_id): mixed
|
|
||||||
{
|
|
||||||
$ret = Coroutine::waitSignal($this->signal, -1);
|
|
||||||
if ($ret === true) {
|
|
||||||
$this->ticker();
|
|
||||||
}
|
|
||||||
return $server->stop();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return void
|
* @return void
|
||||||
*/
|
*/
|
||||||
|
|||||||
Reference in New Issue
Block a user