modify plugin name
This commit is contained in:
@@ -90,14 +90,15 @@ abstract class BaseProcess implements OnProcessInterface
|
|||||||
public function onSigterm(): static
|
public function onSigterm(): static
|
||||||
{
|
{
|
||||||
if (!Context::inCoroutine()) {
|
if (!Context::inCoroutine()) {
|
||||||
Process::signal(SIGTERM, fn($data) => $this->onShutdown($data));
|
Process::signal(SIGTERM | SIGINT, fn($data) => $this->onShutdown($data));
|
||||||
} else {
|
} else {
|
||||||
Coroutine::create(function () {
|
$listen = function () {
|
||||||
$data = Coroutine::waitSignal(SIGTERM, -1);
|
$data = Coroutine::waitSignal(SIGTERM | SIGINT, -1);
|
||||||
if ($data) {
|
if ($data) {
|
||||||
$this->onShutdown($data);
|
$this->onShutdown($data);
|
||||||
}
|
}
|
||||||
});
|
};
|
||||||
|
Coroutine::create($listen);
|
||||||
}
|
}
|
||||||
return $this;
|
return $this;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user