ACIL FM
Dark
Refresh
Current DIR:
/opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/event-loop/src
/
opt
cpanel
ea-wappspector
vendor
rector
rector
vendor
react
event-loop
src
Upload
Zip Selected
Delete Selected
Pilih semua
Nama
Ukuran
Permission
Aksi
Tick
-
chmod
Open
Rename
Delete
Timer
-
chmod
Open
Rename
Delete
ExtEventLoop.php
7.95 MB
chmod
View
DL
Edit
Rename
Delete
ExtEvLoop.php
5.89 MB
chmod
View
DL
Edit
Rename
Delete
ExtLibeventLoop.php
8.41 MB
chmod
View
DL
Edit
Rename
Delete
ExtLibevLoop.php
5.75 MB
chmod
View
DL
Edit
Rename
Delete
ExtUvLoop.php
8.9 MB
chmod
View
DL
Edit
Rename
Delete
Factory.php
1.81 MB
chmod
View
DL
Edit
Rename
Delete
Loop.php
7.31 MB
chmod
View
DL
Edit
Rename
Delete
LoopInterface.php
18.88 MB
chmod
View
DL
Edit
Rename
Delete
SignalsHandler.php
1.29 MB
chmod
View
DL
Edit
Rename
Delete
StreamSelectLoop.php
11.77 MB
chmod
View
DL
Edit
Rename
Delete
TimerInterface.php
509 B
chmod
View
DL
Edit
Rename
Delete
Edit file: /opt/cpanel/ea-wappspector/vendor/rector/rector/vendor/react/event-loop/src/ExtEvLoop.php
<?php namespace RectorPrefix202411\React\EventLoop; use Ev; use EvIo; use EvLoop; use RectorPrefix202411\React\EventLoop\Tick\FutureTickQueue; use RectorPrefix202411\React\EventLoop\Timer\Timer; use SplObjectStorage; /** * An `ext-ev` based event loop. * * This loop uses the [`ev` PECL extension](https://pecl.php.net/package/ev), * that provides an interface to `libev` library. * `libev` itself supports a number of system-specific backends (epoll, kqueue). * * This loop is known to work with PHP 5.4 through PHP 8+. * * @see http://php.net/manual/en/book.ev.php * @see https://bitbucket.org/osmanov/pecl-ev/overview */ class ExtEvLoop implements LoopInterface { /** * @var EvLoop */ private $loop; /** * @var FutureTickQueue */ private $futureTickQueue; /** * @var SplObjectStorage */ private $timers; /** * @var EvIo[] */ private $readStreams = array(); /** * @var EvIo[] */ private $writeStreams = array(); /** * @var bool */ private $running; /** * @var SignalsHandler */ private $signals; /** * @var \EvSignal[] */ private $signalEvents = array(); public function __construct() { $this->loop = new EvLoop(); $this->futureTickQueue = new FutureTickQueue(); $this->timers = new SplObjectStorage(); $this->signals = new SignalsHandler(); } public function addReadStream($stream, $listener) { $key = (int) $stream; if (isset($this->readStreams[$key])) { return; } $callback = $this->getStreamListenerClosure($stream, $listener); $event = $this->loop->io($stream, Ev::READ, $callback); $this->readStreams[$key] = $event; } /** * @param resource $stream * @param callable $listener * * @return \Closure */ private function getStreamListenerClosure($stream, $listener) { return function () use($stream, $listener) { \call_user_func($listener, $stream); }; } public function addWriteStream($stream, $listener) { $key = (int) $stream; if (isset($this->writeStreams[$key])) { return; } $callback = $this->getStreamListenerClosure($stream, $listener); $event = $this->loop->io($stream, Ev::WRITE, $callback); $this->writeStreams[$key] = $event; } public function removeReadStream($stream) { $key = (int) $stream; if (!isset($this->readStreams[$key])) { return; } $this->readStreams[$key]->stop(); unset($this->readStreams[$key]); } public function removeWriteStream($stream) { $key = (int) $stream; if (!isset($this->writeStreams[$key])) { return; } $this->writeStreams[$key]->stop(); unset($this->writeStreams[$key]); } public function addTimer($interval, $callback) { $timer = new Timer($interval, $callback, \false); $that = $this; $timers = $this->timers; $callback = function () use($timer, $timers, $that) { \call_user_func($timer->getCallback(), $timer); if ($timers->contains($timer)) { $that->cancelTimer($timer); } }; $event = $this->loop->timer($timer->getInterval(), 0.0, $callback); $this->timers->attach($timer, $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 = $this->loop->timer($timer->getInterval(), $timer->getInterval(), $callback); $this->timers->attach($timer, $event); return $timer; } public function cancelTimer(TimerInterface $timer) { if (!isset($this->timers[$timer])) { return; } $event = $this->timers[$timer]; $event->stop(); $this->timers->detach($timer); } public function futureTick($listener) { $this->futureTickQueue->add($listener); } public function run() { $this->running = \true; while ($this->running) { $this->futureTickQueue->tick(); $hasPendingCallbacks = !$this->futureTickQueue->isEmpty(); $wasJustStopped = !$this->running; $nothingLeftToDo = !$this->readStreams && !$this->writeStreams && !$this->timers->count() && $this->signals->isEmpty(); $flags = Ev::RUN_ONCE; if ($wasJustStopped || $hasPendingCallbacks) { $flags |= Ev::RUN_NOWAIT; } elseif ($nothingLeftToDo) { break; } $this->loop->run($flags); } } public function stop() { $this->running = \false; } public function __destruct() { /** @var TimerInterface $timer */ foreach ($this->timers as $timer) { $this->cancelTimer($timer); } foreach ($this->readStreams as $key => $stream) { $this->removeReadStream($key); } foreach ($this->writeStreams as $key => $stream) { $this->removeWriteStream($key); } } public function addSignal($signal, $listener) { $this->signals->add($signal, $listener); if (!isset($this->signalEvents[$signal])) { $this->signalEvents[$signal] = $this->loop->signal($signal, function () use($signal) { $this->signals->call($signal); }); } } public function removeSignal($signal, $listener) { $this->signals->remove($signal, $listener); if (isset($this->signalEvents[$signal])) { $this->signalEvents[$signal]->stop(); unset($this->signalEvents[$signal]); } } }
Simpan
Batal
Isi Zip:
Unzip
Create
Buat Folder
Buat File
Terminal / Execute
Run
Chmod Bulk
All File
All Folder
All File dan Folder
Apply