Viewing file:  ServerProcessInspector.php (1.93 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace Laravel\Octane\RoadRunner;
use Laravel\Octane\Contracts\ServerProcessInspector as ServerProcessInspectorContract;
use Laravel\Octane\PosixExtension;
use Laravel\Octane\RoadRunner\Concerns\FindsRoadRunnerBinary;
use Laravel\Octane\SymfonyProcessFactory;
use RuntimeException;
use Symfony\Component\Process\Process;
class ServerProcessInspector implements ServerProcessInspectorContract
{
use FindsRoadRunnerBinary;
public function __construct(
protected ServerStateFile $serverStateFile,
protected SymfonyProcessFactory $processFactory,
protected PosixExtension $posix
) {
}
/**
* Determine if the RoadRunner server process is running.
*/
public function serverIsRunning(): bool
{
[
'masterProcessId' => $masterProcessId,
] = $this->serverStateFile->read();
return $masterProcessId && $this->posix->kill($masterProcessId, 0);
}
/**
* Reload the RoadRunner workers.
*/
public function reloadServer(): void
{
[
'state' => [
'host' => $host,
'rpcPort' => $rpcPort,
],
] = $this->serverStateFile->read();
tap($this->processFactory->createProcess([
$this->findRoadRunnerBinary(),
'reset',
'-o', 'version=3',
'-o', "rpc.listen=tcp://$host:$rpcPort",
'-s',
], base_path()))->start()->waitUntil(function ($type, $buffer) {
if ($type === Process::ERR) {
throw new RuntimeException('Cannot reload RoadRunner: '.$buffer);
}
return true;
});
}
/**
* Stop the RoadRunner server.
*/
public function stopServer(): bool
{
[
'masterProcessId' => $masterProcessId,
] = $this->serverStateFile->read();
return (bool) $this->posix->kill($masterProcessId, SIGTERM);
}
}
|