danog/amp
1
0
Fork 0
mirror of https://github.com/danog/amp.git synced 2024-11-26 20:15:00 +01:00
Code Issues Projects Releases Wiki Activity

Automatically enable async signal handling when possible

Browse Source
This commit is contained in:
Daniil Gentili 2019-06-07 18:12:30 +02:00
parent f824f0df1d
commit d35ac1bb1c
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib/Loop/NativeDriver.php
View File

@ -43,10 +43,14 @@ class NativeDriver extends Driver
/** @var bool */
private $signalHandling;
/** @var bool */
private $manualSignalHandling;
public function __construct()
{
$this->timerQueue = new Internal\TimerQueue;
$this->signalHandling = \extension_loaded("pcntl");
$this->manualSignalHandling = !(\PHP_MAJOR_VERSION >= 7 && \PHP_MINOR_VERSION >= 1);
$this->nowOffset = getCurrentTime();
$this->now = \random_int(0, $this->nowOffset);
$this->nowOffset -= $this->now;
@ -63,6 +67,10 @@ class NativeDriver extends Driver
throw new UnsupportedFeatureException("Signal handling requires the pcntl extension");
}
if (!$this->manualSignalHandling && !pcntl_async_signals()) {
pcntl_async_signals(true);
}
return parent::onSignal($signo, $callback, $data);
}
@ -143,7 +151,7 @@ class NativeDriver extends Driver
}
}
if ($this->signalHandling) {
if ($this->signalHandling && $this->manualSignalHandling) {
\pcntl_signal_dispatch();
}
}