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(...) → new Select Poller Component

Bases: circuits.core.pollers.BasePoller

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(...) → new Poll Poller Component

Bases: circuits.core.pollers.BasePoller

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(...) → new EPoll Poller Component

Bases: circuits.core.pollers.BasePoller

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(...) → new KQueue Poller Component

Bases: circuits.core.pollers.BasePoller

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 circuits.core.pollers.Select