SelectorLoop

Undocumented in source.

Constructors

this
this()
Undocumented in source.

Destructor

~this
~this()
Undocumented in source.

Members

Functions

acceptConnections
void acceptConnections(ConnectionWatcher connection)

Accept incoming connections.

feed
bool feed(StreamTransport transport, SocketException exception)

If the transport couldn't send the data, the further sending should be handled by the event loop.

kill
void kill(StreamTransport transport, SocketException exception)

Kills the watcher and closes the connection.

reify
bool reify(SocketWatcher watcher, EventMask oldEvents, EventMask events)

Should be called if the backend configuration changes.

start
void start(ConnectionWatcher watcher)

Start watching.

Variables

connections
Array!SocketWatcher connections;

Pending connections.

Inherited Members

From Loop

done
bool done;
Undocumented in source.
pendings
DList!Watcher pendings;

Pending watchers.

maxEvents
uint maxEvents [@property getter]
~this
~this()

Frees loop internals.

run
void run()

Starts the loop.

unloop
void unloop()

Break out of the loop.

start
void start(ConnectionWatcher watcher)

Start watching.

stop
void stop(ConnectionWatcher watcher)

Stop watching.

reify
bool reify(SocketWatcher watcher, EventMask oldEvents, EventMask events)

Should be called if the backend configuration changes.

blockTime
inout(Duration) blockTime [@property getter]
blockTime
Duration blockTime [@property setter]

Sets the blocking time for IO watchers.

poll
void poll()

Does the actual polling.

blockTime_
Duration blockTime_;

Maximal block time.

Meta