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(*args, **kwargs)¶
Bases:
circuits.core.components.BaseComponent
initializes x; see x.__class__.__doc__ for signature
- channel = None¶
- resume()¶
- addReader(source, fd)¶
- addWriter(source, fd)¶
- removeReader(fd)¶
- removeWriter(fd)¶
- isReading(fd)¶
- isWriting(fd)¶
- discard(fd)¶
- getTarget(fd)¶
- circuits.core.pollers.Poller¶
alias of
circuits.core.pollers.Select
- 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.
initializes x; see x.__class__.__doc__ for signature
- 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.
initializes x; see x.__class__.__doc__ for signature
- 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.
initializes x; see x.__class__.__doc__ for signature
- 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.
initializes x; see x.__class__.__doc__ for signature
- channel = 'kqueue'¶
- addReader(source, sock)¶
- addWriter(source, sock)¶
- removeReader(sock)¶
- removeWriter(sock)¶
- discard(sock)¶