Selector

Undocumented in source.

abstract

class Selector {

this(TcpListener listener, OnConnected onConnected, OnDisConnected onDisConnected, OnReceive onReceive, OnSendCompleted onSendCompleted, OnSocketError onSocketError, Codec codec, int workerThreadNum);

bool register(int fd, EventType et);

bool reregister(int fd, EventType et);

bool unregister(int fd);

void startLoop();

void dispose();

void removeClient(int fd, int err);

version(Windows)

void iocp_send(int fd, ubyte[] data);

version(Windows)

void iocp_receive(int fd);

Codec codec [@property getter];

version(!Windows)

void accept();

static void beginAccept(Selector selector);

version(Windows)

void read(int fd, ubyte[] data);

version(!Windows)

void read(int fd);

version(!Windows)

void write(int fd);

bool _isDisposed;

TcpListener _listener;

bool _runing;

int _workerThreadNum;

import core.sys.windows.basetsd : HANDLE;;

version(Windows)

HANDLE _eventHandle;

version(Windows)

static void handleEvent(Selector selector);

version(!Windows)

int _eventHandle;

version(!Windows)

void handleEvent();

ThreadPool workerPool;

OnReceive onReceive;

OnSendCompleted onSendCompleted;

}

Constructors

this this(TcpListener listener, OnConnected onConnected, OnDisConnected onDisConnected, OnReceive onReceive, OnSendCompleted onSendCompleted, OnSocketError onSocketError, Codec codec, int workerThreadNum): Undocumented in source.

Destructor

~this ~this(): Undocumented in source.

Members

Functions

accept void accept(): Undocumented in source. Be warned that the author may not have intended to support it.
dispose void dispose(): Undocumented in source. Be warned that the author may not have intended to support it.
handleEvent void handleEvent(): Undocumented in source.
iocp_receive void iocp_receive(int fd): Undocumented in source.
iocp_send void iocp_send(int fd, ubyte[] data): Undocumented in source.
read void read(int fd, ubyte[] data): Undocumented in source. Be warned that the author may not have intended to support it.
read void read(int fd): Undocumented in source. Be warned that the author may not have intended to support it.
register bool register(int fd, EventType et): Undocumented in source.
removeClient void removeClient(int fd, int err): Undocumented in source. Be warned that the author may not have intended to support it.
reregister bool reregister(int fd, EventType et): Undocumented in source.
startLoop void startLoop(): Undocumented in source. Be warned that the author may not have intended to support it.
stop void stop(): Undocumented in source. Be warned that the author may not have intended to support it.
unregister bool unregister(int fd): Undocumented in source.
write void write(int fd): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

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

Static functions

beginAccept void beginAccept(Selector selector): Undocumented in source. Be warned that the author may not have intended to support it.
handleEvent void handleEvent(Selector selector): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

_eventHandle HANDLE _eventHandle;: Undocumented in source.
_eventHandle int _eventHandle;: Undocumented in source.
_isDisposed bool _isDisposed;: Undocumented in source.
_listener TcpListener _listener;: Undocumented in source.
_runing bool _runing;: Undocumented in source.
_workerThreadNum int _workerThreadNum;: Undocumented in source.
onReceive OnReceive onReceive;: Undocumented in source.
onSendCompleted OnSendCompleted onSendCompleted;: Undocumented in source.
workerPool ThreadPool workerPool;: Undocumented in source.

Meta

Source

See Implementation

async event selector aliases

classes

Selector

enums

EventType