Viewing file:  EnsureRequestsDontExceedMaxExecutionTime.php (1.4 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace Laravel\Octane\Swoole\Actions;
use Laravel\Octane\Swoole\SwooleExtension;
use Swoole\Http\Response;
use Swoole\Http\Server;
class EnsureRequestsDontExceedMaxExecutionTime
{
public function __construct(
protected SwooleExtension $extension,
protected $timerTable,
protected $maxExecutionTime,
protected ?Server $server = null
) {
}
/**
* Invoke the action.
*
* @return void
*/
public function __invoke()
{
$rows = [];
foreach ($this->timerTable as $workerId => $row) {
if ((time() - $row['time']) > $this->maxExecutionTime) {
$rows[$workerId] = $row;
}
}
foreach ($rows as $workerId => $row) {
if ($this->timerTable->get($workerId, 'fd') !== $row['fd']) {
continue;
}
$this->timerTable->del($workerId);
if ($this->server instanceof Server && ! $this->server->exists($row['fd'])) {
continue;
}
$this->extension->dispatchProcessSignal($row['worker_pid'], SIGKILL);
if ($this->server instanceof Server) {
$response = Response::create($this->server, $row['fd']);
if ($response) {
$response->status(408);
$response->end();
}
}
}
}
}
|