interface Driver
The driver MUST run in its own fiber and execute callbacks in a separate fiber. If fibers are reused, the driver needs to call {
Hierarchy
- interface \Revolt\EventLoop\Driver
Expanded class hierarchy of Driver
All classes that implement Driver
See also
FiberLocal::clear()} after running the callback.
3 files declare their use of Driver
- AbstractDriver.php in vendor/
revolt/ event-loop/ src/ EventLoop/ Internal/ AbstractDriver.php - EventLoop.php in vendor/
revolt/ event-loop/ src/ EventLoop.php - TracingDriver.php in vendor/
revolt/ event-loop/ src/ EventLoop/ Driver/ TracingDriver.php
7 string references to 'Driver'
- BuildInformation::setRuntimeInformation in vendor/
phpunit/ php-code-coverage/ src/ Report/ Xml/ BuildInformation.php - CredentialForm::validateForm in core/
modules/ migrate_drupal_ui/ src/ Form/ CredentialForm.php - Form validation handler.
- DatabaseDriver::getPath in core/
lib/ Drupal/ Core/ Extension/ DatabaseDriver.php - Returns the relative path of the extension.
- DatabaseDriverList::doList in core/
lib/ Drupal/ Core/ Extension/ DatabaseDriverList.php - Builds the list of extensions.
- SiteSettingsForm::buildForm in core/
lib/ Drupal/ Core/ Installer/ Form/ SiteSettingsForm.php - Form constructor.
File
-
vendor/
revolt/ event-loop/ src/ EventLoop/ Driver.php, line 11
Namespace
Revolt\EventLoopView source
interface Driver {
/**
* Run the event loop.
*
* One iteration of the loop is called one "tick". A tick covers the following steps:
*
* 1. Activate callbacks created / enabled in the last tick / before `run()`.
* 2. Execute all enabled deferred callbacks.
* 3. Execute all due timer, pending signal and actionable stream callbacks, each only once per tick.
*
* The loop MUST continue to run until it is either stopped explicitly, no referenced callbacks exist anymore, or an
* exception is thrown that cannot be handled. Exceptions that cannot be handled are exceptions thrown from an
* error handler or exceptions that would be passed to an error handler but none exists to handle them.
*
* @throws \Error Thrown if the event loop is already running.
*/
public function run() : void;
/**
* Stop the event loop.
*
* When an event loop is stopped, it continues with its current tick and exits the loop afterwards. Multiple calls
* to stop MUST be ignored and MUST NOT raise an exception.
*/
public function stop() : void;
/**
* Returns an object used to suspend and resume execution of the current fiber or {main}.
*
* Calls from the same fiber will return the same suspension object.
*
* @return Suspension
*/
public function getSuspension() : Suspension;
/**
* @return bool True if the event loop is running, false if it is stopped.
*/
public function isRunning() : bool;
/**
* Queue a microtask.
*
* The queued callback MUST be executed immediately once the event loop gains control. Order of queueing MUST be
* preserved when executing the callbacks. Recursive scheduling can thus result in infinite loops, use with care.
*
* Does NOT create an event callback, thus CAN NOT be marked as disabled or unreferenced.
* Use {@see EventLoop::defer()} if you need these features.
*
* @param \Closure(...):void $closure The callback to queue.
* @param mixed ...$args The callback arguments.
*/
public function queue(\Closure $closure, mixed ...$args) : void;
/**
* Defer the execution of a callback.
*
* The deferred callback MUST be executed before any other type of callback in a tick. Order of enabling MUST be
* preserved when executing the callbacks.
*
* The created callback MUST immediately be marked as enabled, but only be activated (i.e. callback can be called)
* right before the next tick. Callbacks MUST NOT be called in the tick they were enabled.
*
* @param \Closure(string):void $closure The callback to defer. The `$callbackId` will be invalidated before the
* callback invocation.
*
* @return string A unique identifier that can be used to cancel, enable or disable the callback.
*/
public function defer(\Closure $closure) : string;
/**
* Delay the execution of a callback.
*
* The delay is a minimum and approximate, accuracy is not guaranteed. Order of calls MUST be determined by which
* timers expire first, but timers with the same expiration time MAY be executed in any order.
*
* The created callback MUST immediately be marked as enabled, but only be activated (i.e. callback can be called)
* right before the next tick. Callbacks MUST NOT be called in the tick they were enabled.
*
* @param float $delay The amount of time, in seconds, to delay the execution for.
* @param \Closure(string):void $closure The callback to delay. The `$callbackId` will be invalidated before the
* callback invocation.
*
* @return string A unique identifier that can be used to cancel, enable or disable the callback.
*/
public function delay(float $delay, \Closure $closure) : string;
/**
* Repeatedly execute a callback.
*
* The interval between executions is a minimum and approximate, accuracy is not guaranteed. Order of calls MUST be
* determined by which timers expire first, but timers with the same expiration time MAY be executed in any order.
* The first execution is scheduled after the first interval period.
*
* The created callback MUST immediately be marked as enabled, but only be activated (i.e. callback can be called)
* right before the next tick. Callbacks MUST NOT be called in the tick they were enabled.
*
* @param float $interval The time interval, in seconds, to wait between executions.
* @param \Closure(string):void $closure The callback to repeat.
*
* @return string A unique identifier that can be used to cancel, enable or disable the callback.
*/
public function repeat(float $interval, \Closure $closure) : string;
/**
* Execute a callback when a stream resource becomes readable or is closed for reading.
*
* Warning: Closing resources locally, e.g. with `fclose`, might not invoke the callback. Be sure to `cancel` the
* callback when closing the resource locally. Drivers MAY choose to notify the user if there are callbacks on
* invalid resources, but are not required to, due to the high performance impact. Callbacks on closed resources are
* therefore undefined behavior.
*
* Multiple callbacks on the same stream MAY be executed in any order.
*
* The created callback MUST immediately be marked as enabled, but only be activated (i.e. callback can be called)
* right before the next tick. Callbacks MUST NOT be called in the tick they were enabled.
*
* @param resource $stream The stream to monitor.
* @param \Closure(string, resource):void $closure The callback to execute.
*
* @return string A unique identifier that can be used to cancel, enable or disable the callback.
*/
public function onReadable(mixed $stream, \Closure $closure) : string;
/**
* Execute a callback when a stream resource becomes writable or is closed for writing.
*
* Warning: Closing resources locally, e.g. with `fclose`, might not invoke the callback. Be sure to `cancel` the
* callback when closing the resource locally. Drivers MAY choose to notify the user if there are callbacks on
* invalid resources, but are not required to, due to the high performance impact. Callbacks on closed resources are
* therefore undefined behavior.
*
* Multiple callbacks on the same stream MAY be executed in any order.
*
* The created callback MUST immediately be marked as enabled, but only be activated (i.e. callback can be called)
* right before the next tick. Callbacks MUST NOT be called in the tick they were enabled.
*
* @param resource $stream The stream to monitor.
* @param \Closure(string, resource):void $closure The callback to execute.
*
* @return string A unique identifier that can be used to cancel, enable or disable the callback.
*/
public function onWritable(mixed $stream, \Closure $closure) : string;
/**
* Execute a callback when a signal is received.
*
* Warning: Installing the same signal on different instances of this interface is deemed undefined behavior.
* Implementations MAY try to detect this, if possible, but are not required to. This is due to technical
* limitations of the signals being registered globally per process.
*
* Multiple callbacks on the same signal MAY be executed in any order.
*
* The created callback MUST immediately be marked as enabled, but only be activated (i.e. callback can be called)
* right before the next tick. Callbacks MUST NOT be called in the tick they were enabled.
*
* @param int $signal The signal number to monitor.
* @param \Closure(string, int):void $closure The callback to execute.
*
* @return string A unique identifier that can be used to cancel, enable or disable the callback.
*
* @throws UnsupportedFeatureException If signal handling is not supported.
*/
public function onSignal(int $signal, \Closure $closure) : string;
/**
* Enable a callback to be active starting in the next tick.
*
* Callbacks MUST immediately be marked as enabled, but only be activated (i.e. callbacks can be called) right
* before the next tick. Callbacks MUST NOT be called in the tick they were enabled.
*
* @param string $callbackId The callback identifier.
*
* @return string The callback identifier.
*
* @throws InvalidCallbackError If the callback identifier is invalid.
*/
public function enable(string $callbackId) : string;
/**
* Cancel a callback.
*
* This will detach the event loop from all resources that are associated to the callback. After this operation the
* callback is permanently invalid. Calling this function MUST NOT fail, even if passed an invalid identifier.
*
* @param string $callbackId The callback identifier.
*/
public function cancel(string $callbackId) : void;
/**
* Disable a callback immediately.
*
* A callback MUST be disabled immediately, e.g. if a deferred callback disables a later deferred callback,
* the second deferred callback isn't executed in this tick.
*
* Disabling a callback MUST NOT invalidate the callback. Calling this function MUST NOT fail, even if passed an
* invalid callback identifier.
*
* @param string $callbackId The callback identifier.
*
* @return string The callback identifier.
*/
public function disable(string $callbackId) : string;
/**
* Reference a callback.
*
* This will keep the event loop alive whilst the callback is still being monitored. Callbacks have this state by
* default.
*
* @param string $callbackId The callback identifier.
*
* @return string The callback identifier.
*
* @throws InvalidCallbackError If the callback identifier is invalid.
*/
public function reference(string $callbackId) : string;
/**
* Unreference a callback.
*
* The event loop should exit the run method when only unreferenced callbacks are still being monitored. Callbacks
* are all referenced by default.
*
* @param string $callbackId The callback identifier.
*
* @return string The callback identifier.
*/
public function unreference(string $callbackId) : string;
/**
* Set a callback to be executed when an error occurs.
*
* The callback receives the error as the first and only parameter. The return value of the callback gets ignored.
* If it can't handle the error, it MUST throw the error. Errors thrown by the callback or during its invocation
* MUST be thrown into the `run` loop and stop the driver.
*
* Subsequent calls to this method will overwrite the previous handler.
*
* @param null|\Closure(\Throwable):void $errorHandler The callback to execute. `null` will clear the current
* handler.
*/
public function setErrorHandler(?\Closure $errorHandler) : void;
/**
* Gets the error handler closure or {@code null} if none is set.
*
* @return null|\Closure(\Throwable):void The previous handler, `null` if there was none.
*/
public function getErrorHandler() : ?\Closure;
/**
* Get the underlying loop handle.
*
* Example: the `uv_loop` resource for `libuv` or the `EvLoop` object for `libev` or `null` for a stream_select
* driver.
*
* Note: This function is *not* exposed in the `Loop` class. Users shall access it directly on the respective loop
* instance.
*
* @return null|object|resource The loop handle the event loop operates on. `null` if there is none.
*/
public function getHandle() : mixed;
/**
* Returns all registered non-cancelled callback identifiers.
*
* @return string[] Callback identifiers.
*/
public function getIdentifiers() : array;
/**
* Returns the type of the callback identified by the given callback identifier.
*
* @param string $callbackId The callback identifier.
*
* @return CallbackType The callback type.
*/
public function getType(string $callbackId) : CallbackType;
/**
* Returns whether the callback identified by the given callback identifier is currently enabled.
*
* @param string $callbackId The callback identifier.
*
* @return bool `true` if the callback is currently enabled, otherwise `false`.
*/
public function isEnabled(string $callbackId) : bool;
/**
* Returns whether the callback identified by the given callback identifier is currently referenced.
*
* @param string $callbackId The callback identifier.
*
* @return bool `true` if the callback is currently referenced, otherwise `false`.
*/
public function isReferenced(string $callbackId) : bool;
/**
* Returns some useful information about the event loop.
*
* If this method isn't implemented, dumping the event loop in a busy application, even indirectly, is a pain.
*
* @return array
*/
public function __debugInfo() : array;
}
Members
Title Sort descending | Modifiers | Object type | Summary | Overrides |
---|---|---|---|---|
Driver::cancel | public | function | Cancel a callback. | 2 |
Driver::defer | public | function | Defer the execution of a callback. | 2 |
Driver::delay | public | function | Delay the execution of a callback. | 2 |
Driver::disable | public | function | Disable a callback immediately. | 2 |
Driver::enable | public | function | Enable a callback to be active starting in the next tick. | 2 |
Driver::getErrorHandler | public | function | Gets the error handler closure or {@code null} if none is set. | 2 |
Driver::getHandle | public | function | Get the underlying loop handle. | 5 |
Driver::getIdentifiers | public | function | Returns all registered non-cancelled callback identifiers. | 2 |
Driver::getSuspension | public | function | Returns an object used to suspend and resume execution of the current fiber or {main}. | 2 |
Driver::getType | public | function | Returns the type of the callback identified by the given callback identifier. | 2 |
Driver::isEnabled | public | function | Returns whether the callback identified by the given callback identifier is currently enabled. | 2 |
Driver::isReferenced | public | function | Returns whether the callback identified by the given callback identifier is currently referenced. | 2 |
Driver::isRunning | public | function | 2 | |
Driver::onReadable | public | function | Execute a callback when a stream resource becomes readable or is closed for reading. | 2 |
Driver::onSignal | public | function | Execute a callback when a signal is received. | 2 |
Driver::onWritable | public | function | Execute a callback when a stream resource becomes writable or is closed for writing. | 2 |
Driver::queue | public | function | Queue a microtask. | 2 |
Driver::reference | public | function | Reference a callback. | 2 |
Driver::repeat | public | function | Repeatedly execute a callback. | 2 |
Driver::run | public | function | Run the event loop. | 2 |
Driver::setErrorHandler | public | function | Set a callback to be executed when an error occurs. | 2 |
Driver::stop | public | function | Stop the event loop. | 2 |
Driver::unreference | public | function | Unreference a callback. | 2 |
Driver::__debugInfo | public | function | Returns some useful information about the event loop. | 2 |