Class: cogen.core.pollers.EpollPoller
Methods
__init__ (self, scheduler, default_size=1024)
__len__ (self)
Returns number of waiting operations registered in the poller.
add (self, op, coro)
handle_errored (self, desc)
Handles descriptors that have errors.
remove (self, op, coro)
run (self, timeout=0)
Run a poller loop and return new socket events. Timeout is a timedelta
object, 0 if active coros or None.
epoll timeout param is a integer number of miliseconds (seconds/1000).
epoll timeout param is a integer number of miliseconds (seconds/1000).
run_once (self, fdesc, waiting_ops)
Run a operation, remove it from the poller and return the result.
Called from the main poller loop.
run_operation (self, op)
Run the socket op and return result or exception.
run_or_add (self, op, coro)
Perform operation or add the operation in the poller if socket isn't
ready. Called from the scheduller.
waiting_op (self, testcoro)
Returns the registered operation for some specified coroutine.