eve.core.linux.loop

Linux Layer 1 event loop built on the selected Layer 0 backend.

This module provides the Linux-specific implementation of EventLoop using timerfd for timers, signalfd for signals, and eventfd for cross-thread wakeups.

struct EventLoop

Types 1

structEventLoop

Single-threaded readiness event loop.

Fields

TimerWheel _timerWheel

long _startTimeMs

SelectedBackend _poller

WatcherSlot[] _slots

NativeEvent[] _events

DnsData[] _dnsSlots

size_t _watcherCount

size_t _totalSendQueueBytes

size_t _activeConnections

size_t _openFds

EventLoopConfig _config

bool _running

bool _stopRequested

uint _freeHead

uint _dnsFreeHead

size_t _phaseDispatchCount

Token[] _phaseBuffer

bool _signalMaskActive

bool _hasSavedSignalMask

sigset_t _savedSignalMask

Methods

EventLoop create(EventLoopConfig config = EventLoopConfig.init) @trustedCreate a new event loop with fixed-capacity watcher and event buffers.

bool isValid() @property const @safe nothrow @nogcCheck whether the loop was created successfully.

Handle backendHandle() @property const @safe nothrow @nogcReturn the native handle for the active Layer 0 poller.

size_t watcherCount() @property const pure @safe nothrow @nogcReport how many watchers are currently registered.

bool isRunning() @property const pure @safe nothrow @nogcReport whether `run` or `runToCompletion` is currently executing.

ResourceUsage usage() const @safe nothrow @nogcGet the current resource usage of the event loop.

const(EventLoopLimits) limits() @property const @safe nothrow @nogcGet the resource limits configured for the event loop.

void updateSendQueueUsage(long delta) @safe nothrow @nogcUpdate the total send queue bytes tracked by the loop.

void updateConnectionCount(long delta) @safe nothrow @nogcUpdate the active connection count tracked by the loop.

int dispose() @trusted nothrowDispose the Layer 0 poller and invalidate all watcher tokens.

Token registerIo(Handle handle, IoInterest interest, IoWatcherCallback callback) @trusted nothrowRegister an I/O watcher with the selected backend.

Token registerTimer(long delayMs, long intervalMs, WatcherCallback callback) @trusted nothrowRegister a one-shot timer watcher.

Token registerSignal(Signal signal, SignalWatcherCallback callback) @trusted nothrowRegister a signal watcher.

Token registerWakeup(WatcherCallback callback) @trusted nothrowRegister an async wakeup watcher.

int notify(Token token) @trusted nothrowTrigger an async wakeup watcher.

void updateDnsResults(Token token, scope const(IpAddress)[] results, DnsError error) @safe nothrowInternal: Update results for a DNS watcher.

const(char) * getDnsHostname(Token token) @safe nothrowInternal: Get the hostname associated with a DNS watcher.

Token registerDns(scope  const(char)[]  host,  DnsWatcherCallback callback,  CancelToken cancel =  CancelToken
         .invalid)

@trusted nothrowRegister an async DNS resolution watcher.

CancelToken getCancelToken(Token token) @safe nothrow @nogcGet the cancellation token associated with a watcher.

Token registerPrepare(WatcherCallback callback) @trusted nothrowRegister a prepare watcher.

Token registerCheck(WatcherCallback callback) @trusted nothrowRegister a check watcher.

Token registerIdle(WatcherCallback callback) @trusted nothrowRegister an idle watcher.

int updateIo(Token token, IoInterest interest) @trusted nothrowUpdate the interest mask for an existing I/O watcher.

int unregister(Token token) @trusted nothrowUnregister an active watcher.

ptrdiff_t runOnce(int timeoutMs) @trusted nothrowRun one iteration of the event loop.

ptrdiff_t run() @trusted nothrowRun the event loop until `stop` is called.

ptrdiff_t runToCompletion() @trusted nothrowRun the event loop until no active watchers remain.

void stop() @safe nothrowRequest the loop to stop after the current iteration.

bool checkLimit(LimitKind kind, size_t current, size_t limit) @safe nothrowInternal: Check if a resource limit is hit.

void rebuildFreeList() @safe nothrow @nogc

void rebuildDnsFreeList() @safe nothrow @nogc

void resetSlot(uint index, ref WatcherSlot slot) @trusted nothrow @nogc

Token allocateToken() @safe nothrow @nogc

WatcherSlot * slotFor(Token token) @safe nothrow @nogc

void cleanupSlotResources(uint index, ref WatcherSlot slot) @trusted nothrow

int detachSlotFromBackend(uint index, ref WatcherSlot slot) @trusted nothrow

int removeSlotNow(uint index, ref WatcherSlot slot) @trusted nothrow

void releaseToken(uint index) @trusted nothrow @nogc

uint allocateDnsSlot() @safe nothrow @nogc

void releaseDnsSlot(uint index) @safe nothrow @nogc

Token registerPhaseWatcher(WatcherKind kind, WatcherCallback callback) @trusted nothrow

int computePollTimeout(int requestedTimeoutMs) const pure @safe nothrow @nogc

bool hasPhaseOnlyWatchers() const @safe nothrow @nogc

ptrdiff_t dispatchPhase(WatcherKind kind) @trusted nothrow

ptrdiff_t countPhaseWatchers(WatcherKind kind) const pure @safe nothrow @nogc

bool dispatchWatcher(Token token) @trusted nothrow

bool dispatchIo(Token token, IoReady ready) @trusted nothrow

bool dispatchSignal(Token token) @trusted nothrow

bool dispatchTimer(Token token) @trusted nothrow

bool dispatchWakeup(Token token) @trusted nothrow

bool dispatchOsEvent(OsEvent osEvent) @trusted nothrow

bool dispatchDns(Token token) @trusted nothrow

Handle createWakeupHandle() @trusted nothrow

Handle createSignalHandle(sigset_t mask) @trusted nothrow

timespec toTimespec(long milliseconds) pure @safe nothrow @nogc

bool hasSignalWatcher(Signal signal) const @safe nothrow @nogc

int blockSignalMask(sigset_t mask) @trusted nothrow

int refreshSignalMask() @trusted nothrow

int restoreSignalMask() @trusted nothrow

bool anySignalWatchers() const @safe nothrow @nogc

Nested Templates

WatcherSlot

DnsData