Part of twisted.internet.pollreactor View Source View In Hierarchy
Implements interfaces: twisted.internet.interfaces.IReactorFDSet
Instance Variables | _poller | A poll which will be used to check for I/O readiness.
|
_selectables | A dictionary mapping integer file descriptors to instances of FileDescriptor
which have been registered with the reactor. All
FileDescriptors which are currently receiving read or write
readiness notifications will be present as values in this dictionary.
| |
_reads | A dictionary mapping integer file descriptors to arbitrary values
(this is essentially a set). Keys in this dictionary will be registered
with _poller for read readiness notifications which will be
dispatched to the corresponding FileDescriptor
instances in _selectables .
| |
_writes | A dictionary mapping integer file descriptors to arbitrary values
(this is essentially a set). Keys in this dictionary will be registered
with _poller for write readiness notifications which will be
dispatched to the corresponding FileDescriptor
instances in _selectables .
|
Method | __init__ | Initialize polling object, file descriptor tracking dictionaries, and |
Method | addReader | Add a FileDescriptor for notification of data available to read. |
Method | addWriter | Add a FileDescriptor for notification of data available to write. |
Method | removeReader | Remove a Selectable for notification of data available to read. |
Method | removeWriter | Remove a Selectable for notification of data available to write. |
Method | removeAll | Remove all selectables, and return a list of them. |
Method | doPoll | Poll the poller for new events. |
Method | getReaders | Return the list of file descriptors currently monitored for input |
Method | getWriters | Return the list file descriptors currently monitored for output events |
Method | _updateRegistration | Register/unregister an fd with the poller. |
Method | _dictRemove | Undocumented |
Method | _doReadOrWrite | Undocumented |
Inherited from PosixReactorBase:
Method | installWaker | Install a `waker' to allow threads and signals to wake up the IO thread. |
Method | spawnProcess | Spawn a process, with a process protocol. |
Method | listenUDP | Connects a given DatagramProtocol
to the given numeric UDP port.
|
Method | connectUDP | DEPRECATED. |
Method | listenMulticast | Connects a given DatagramProtocol to the given numeric UDP port. |
Method | connectUNIX | |
Method | listenUNIX | |
Method | listenUNIXDatagram | Connects a given DatagramProtocol
to the given path.
|
Method | connectUNIXDatagram | Connects a ConnectedDatagramProtocol
instance to a path.
|
Method | listenTCP | |
Method | connectTCP | |
Method | connectSSL | |
Method | listenSSL | |
Method | listenWith | Start an instance of the given portType listening.
|
Method | connectWith | Start an instance of the given connectorType
connecting.
|
Method | _disconnectSelectable | Utility function for disconnecting a selectable. |
Method | _removeAll | Remove all readers and writers, and return list of Selectables. |
Inherited from _SignalReactorMixin (via PosixReactorBase):
Method | startRunning | Forward call to ReactorBase, arrange for signal handlers to be |
Method | run | Undocumented |
Method | mainLoop | Undocumented |
Method | _handleSignals | Install the signal handlers for the Twisted event loop. |
Method | _handleSigchld | Reap all processes on SIGCHLD. |
Inherited from ReactorBase (via PosixReactorBase):
Method | installResolver | Set the internal resolver to use to for name lookups. |
Method | wakeUp | Wake up the event loop. |
Method | doIteration | Do one iteration over the readers and writers we know about. |
Method | resolve | Return a Deferred that will resolve a hostname. |
Method | stop | See twisted.internet.interfaces.IReactorCore.stop. |
Method | crash | See twisted.internet.interfaces.IReactorCore.crash. |
Method | sigInt | Handle a SIGINT interrupt. |
Method | sigBreak | Handle a SIGBREAK interrupt. |
Method | sigTerm | Handle a SIGTERM interrupt. |
Method | disconnectAll | Disconnect every reader, and writer in the system. |
Method | iterate | See twisted.internet.interfaces.IReactorCore.iterate. |
Method | fireSystemEvent | See twisted.internet.interfaces.IReactorCore.fireSystemEvent. |
Method | addSystemEventTrigger | See twisted.internet.interfaces.IReactorCore.addSystemEventTrigger. |
Method | removeSystemEventTrigger | See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger. |
Method | callWhenRunning | See twisted.internet.interfaces.IReactorCore.callWhenRunning. |
Method | startRunning | Method called when reactor starts: do some initialization and fire |
Method | callLater | See twisted.internet.interfaces.IReactorTime.callLater. |
Method | cancelCallLater | See twisted.internet.interfaces.IReactorTime.cancelCallLater. |
Method | getDelayedCalls | Return all the outstanding delayed calls in the system. |
Method | timeout | Undocumented |
Method | runUntilCurrent | Run all pending timed calls. |
Method | callFromThread 0 | See twisted.internet.interfaces.IReactorThreads.callFromThread .
|
Method | callInThread | See twisted.internet.interfaces.IReactorThreads.callInThread .
|
Method | suggestThreadPoolSize | See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize .
|
Method | callFromThread | Cause a function to be executed by the reactor thread. |
Method | _moveCallLaterSooner | Undocumented |
Method | _cancelCallLater | Undocumented |
Method | _insertNewDelayedCalls | Undocumented |
Method | _checkProcessArgs | Check for valid arguments and environment to spawnProcess. |
Method | _initThreads | Undocumented |
Method | _initThreadPool | Create the threadpool accessible with callFromThread. |
Method | _stopThreadPool | Stop the reactor threadpool. |
Returns | the list of file descriptors monitored for input events.
(type: list of IReadDescriptor
) |
Returns | the list of file descriptors monitored for output events.
(type: list of IWriteDescriptor
) |