danog/amp
1
0
Fork 0
mirror of https://github.com/danog/amp.git synced 2024-11-30 04:29:08 +01:00
Code Issues Projects Releases Wiki Activity

Remove old forkable references

Browse Source
This commit is contained in:
Daniel Lowrey 2014-02-23 16:24:07 -05:00
parent 5402715d70
commit a6ae4cc4cf
1 changed files with 0 additions and 45 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
src/Alert/LibeventReactor.php
View File

@ -19,14 +19,6 @@ class LibeventReactor implements Reactor {
function __construct() {
$this->lastWatcherId = PHP_INT_MAX * -1;
$this->initialize();
}
/**
* Normally this would go into the __construct() function but it's split out into its own
* method because we also have to initialize() when calling afterFork().
*/
private function initialize() {
$this->base = event_base_new();
$this->gcEvent = event_new();
event_timer_set($this->gcEvent, [$this, 'collectGarbage']);
@ -262,41 +254,4 @@ class LibeventReactor implements Reactor {
event_del($this->gcEvent);
}
function beforeFork() {
$this->collectGarbage();
}
function afterFork() {
$this->initialize();
foreach ($this->watchers as $watcherId => $watcher) {
$eventResource = event_new();
$watcher->eventResource = $eventResource;
switch ($watcher->type) {
case self::$TYPE_STREAM:
$wrapper = $this->wrapStreamCallback($watcher);
event_set($eventResource, $watcher->stream, $watcher->streamFlags, $wrapper);
break;
case self::$TYPE_ONCE:
$wrapper = $this->wrapOnceCallback($watcher);
event_timer_set($eventResource, $wrapper);
break;
case self::$TYPE_REPEATING:
$wrapper = $this->wrapRepeatingCallback($watcher);
event_timer_set($eventResource, $wrapper);
break;
}
$watcher->wrapper = $wrapper;
event_base_set($eventResource, $this->base);
if ($watcher->isEnabled) {
event_add($eventResource, $watcher->interval);
}
}
}
}