circuits.core.pollers module

Poller Components for asynchronous file and socket I/O.

This module contains Poller components that enable polling of file or socket descriptors for read/write events. Pollers: - Select - Poll - EPoll

class circuits.core.pollers.BasePoller(channel=None)

Bases: circuits.core.components.BaseComponent

channel = None

resume()

addReader(source, fd)

addWriter(source, fd)

removeReader(fd)

removeWriter(fd)

isReading(fd)

isWriting(fd)

discard(fd)

getTarget(fd)

class circuits.core.pollers.Select(channel='select')

Bases: circuits.core.pollers.BasePoller

Select(...) -> new Select Poller Component

Creates a new Select Poller Component that uses the select poller implementation. This poller is not recommended but is available for legacy reasons as most systems implement select-based polling for backwards compatibility.

channel = 'select'

class circuits.core.pollers.Poll(channel='poll')

Bases: circuits.core.pollers.BasePoller

Poll(...) -> new Poll Poller Component

Creates a new Poll Poller Component that uses the poll poller implementation.

channel = 'poll'

addReader(source, fd)

addWriter(source, fd)

removeReader(fd)

removeWriter(fd)

discard(fd)

class circuits.core.pollers.EPoll(channel='epoll')

Bases: circuits.core.pollers.BasePoller

EPoll(...) -> new EPoll Poller Component

Creates a new EPoll Poller Component that uses the epoll poller implementation.

channel = 'epoll'

addReader(source, fd)

addWriter(source, fd)

removeReader(fd)

removeWriter(fd)

discard(fd)

class circuits.core.pollers.KQueue(channel='kqueue')

Bases: circuits.core.pollers.BasePoller

KQueue(...) -> new KQueue Poller Component

Creates a new KQueue Poller Component that uses the kqueue poller implementation.

channel = 'kqueue'

addReader(source, sock)

addWriter(source, sock)

removeReader(sock)

removeWriter(sock)

discard(sock)

circuits.core.pollers.Poller

alias of Select