eve.core.windows.loop

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

This module provides the Windows-specific implementation of EventLoop using performance counters for timers, SetConsoleCtrlHandler for signals, and Windows Event objects for cross-thread wakeups.

var _errno

struct EventLoop

fn errno

Types 1

structEventLoop

Single-threaded readiness event loop for Windows.

Fields

SelectedBackend _poller

WatcherSlot[] _slots

NativeEvent[] _events

ResourceAccounting _resources

DnsManager _dns

PhaseWatchers _phases

TimerWheel _timerWheel

TimerState _timer

SignalState _signals

size_t _watcherCount

WindowsSocketBackend _windowsSocketBackend

bool _running

bool _stopRequested

uint _freeHead

PostState _post

ulong _registrationSeq

void delegate(Token, Exception) @safe nothrow _onCallbackError

Methods

EventLoop create(EventLoopConfig config = EventLoopConfig.init) static @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.

int registerCompletion(void * context, CompletionCallback callback) @trusted nothrowRegister a completion handler for IOCP completions.

void unregisterCompletion(void * context) @trusted nothrowUnregister a completion handler.

BackendId backendId() @property const @safe nothrow @nogcReturn the identifier of the active Layer 0 backend.

BackendCapabilities backendCapabilities() @property const @safe nothrow @nogcReturn the capability flags for the active Layer 0 backend.

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.

WindowsSocketBackend windowsSocketBackend() @property const pure @safe nothrow @nogcGet the configured Windows socket backend.

bool usingIocp() @property const pure @safe nothrow @nogcReport whether the loop is using IOCP overlapped I/O mode.

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

ResourceUsage diagnostics() const @safe nothrow @nogcGet a snapshot of current diagnostics.

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.

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

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() @trusted nothrowRequest the loop to stop after the current iteration.

void defer(scope void delegate() @safe nothrow callback) @safe nothrowDefer a callback to the next loop iteration.

void post(scope void delegate() @safe nothrow callback) @trusted nothrowPost a callback from any thread for execution on the loop thread.

void reportCallbackError(Token token, Exception error) @trusted nothrow

ptrdiff_t countPhaseWatchers(WatcherKind kind) const pure @safe nothrow @nogcCount enabled phase watchers of the given kind.

void ensurePostWakeup() @trusted nothrow

void drainDeferQueue() @trusted nothrow

void rebuildFreeList() @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

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

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

long currentTimeMs() @trusted nothrow @nogc

ptrdiff_t fireExpiredTimers() @trusted nothrow

bool dispatchTimer(Token token) @trusted nothrow

bool dispatchWatcherLocal(Token token) @trusted nothrow

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

bool dispatchOsEventLocal(OsEvent osEvent) @trusted nothrow

void checkDnsEvents() @trusted nothrow

void checkWakeupEvents() @trusted nothrow

void checkSignalEvents() @trusted nothrow

void installConsoleHandler() @trusted nothrow

bool consoleHandlerInstalled() @property const @safe nothrow @nogc

Nested Templates

WatcherSlot

Functions 1

private fnint errno() ref @trusted nothrow @nogc

Variables 1

private varint _errno

Thread-local errno for Windows compatibility.