Viewing file:  SignalDispatcher.php (1.12 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace Laravel\Octane\Swoole;
class SignalDispatcher
{
public function __construct(protected SwooleExtension $extension)
{
}
/**
* Determine if the given process ID can be communicated with.
*/
public function canCommunicateWith(int $processId): bool
{
return $this->signal($processId, 0);
}
/**
* Send a SIGTERM signal to the given process.
*/
public function terminate(int $processId, int $wait = 0): bool
{
$this->extension->dispatchProcessSignal($processId, SIGTERM);
if ($wait) {
$start = time();
do {
if (! $this->canCommunicateWith($processId)) {
return true;
}
$this->extension->dispatchProcessSignal($processId, SIGTERM);
sleep(1);
} while (time() < $start + $wait);
}
return false;
}
/**
* Send a signal to the given process.
*/
public function signal(int $processId, int $signal): bool
{
return $this->extension->dispatchProcessSignal($processId, $signal);
}
}
|