Kqueue

Undocumented in source.

version(Kqueue)

package

struct Kqueue {

public import mecca.reactor.subsystems.poller : FdContext;;

import core.time : Duration, msecs;;

import mecca.containers.pools : FixedPool;;

import mecca.lib.exception : ASSERT, DBG_ASSERT, enforceNGC, errnoEnforceNGC;;

import mecca.lib.io : FD;;

import mecca.lib.reflection : setToInit;;

import mecca.lib.time : Timeout;;

import mecca.log : INFO, notrace;;

import mecca.platform.os : OSSignal;;

import mecca.reactor : theReactor;;

import mecca.reactor.platform : EVFILT_READ, EVFILT_WRITE, EVFILT_SIGNAL, kevent64, kevent64_s;;

import mecca.reactor.subsystems.poller : Direction;;

alias SignalHandler = void delegate(OSSignal) @(system);

void close();

bool isOpen [@property getter];

FdContext* registerFD(FD fd, bool alreadyNonBlocking);

void deregisterFd(FD fd, FdContext* ctx, bool fdIsClosing);

void waitForEvent(FdContext* ctx, int fd, Direction dir, Timeout timeout);

void registerFdCallback(FdContext* ctx, Direction dir, void delegate(void*) callback, void* opaq, bool oneShot);

void unregisterFdCallback(FdContext* ctx, Direction dir);

FdContext* registerSignalHandler(OSSignal signal, SignalHandler handler);

void unregisterSignalHandler(FdContext* ctx);

bool reactorIdle(Duration timeout);

}

Public Imports

mecca.reactor.subsystems.poller public import mecca.reactor.subsystems.poller : FdContext;

Members

Aliases

SignalHandler alias SignalHandler = void delegate(OSSignal) @(system): Undocumented in source.

Functions

close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
deregisterFd void deregisterFd(FD fd, FdContext* ctx, bool fdIsClosing): Undocumented in source. Be warned that the author may not have intended to support it.
open void open(): Undocumented in source. Be warned that the author may not have intended to support it.
poll void poll(): Export of the poller function
reactorIdle bool reactorIdle(Duration timeout): Undocumented in source. Be warned that the author may not have intended to support it.
registerFD FdContext* registerFD(FD fd, bool alreadyNonBlocking): Undocumented in source. Be warned that the author may not have intended to support it.
registerFdCallback void registerFdCallback(FdContext* ctx, Direction dir, void delegate(void*) callback, void* opaq, bool oneShot): Undocumented in source. Be warned that the author may not have intended to support it.
registerSignalHandler FdContext* registerSignalHandler(OSSignal signal, SignalHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
unregisterFdCallback void unregisterFdCallback(FdContext* ctx, Direction dir): Undocumented in source. Be warned that the author may not have intended to support it.
unregisterSignalHandler void unregisterSignalHandler(FdContext* ctx): Undocumented in source. Be warned that the author may not have intended to support it.
waitForEvent void waitForEvent(FdContext* ctx, int fd, Direction dir, Timeout timeout): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

isOpen bool isOpen [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

mecca reactor platform kqueue aliases

Poller

functions

structs

Kqueue