Part of twisted.internet.default View Source View In Hierarchy
Known subclasses: twisted.internet.gtk2reactor.PortableGtkReactor, twisted.internet.gtkreactor.PortableGtkReactor
Implements interfaces: twisted.internet.interfaces.IReactorFDSet
Instance Variables | _reads | A dictionary mapping FileDescriptor
instances to arbitrary values (this is essentially a set). Keys in this
dictionary will be checked for read events.
|
_writes | A dictionary mapping FileDescriptor
instances to arbitrary values (this is essentially a set). Keys in this
dictionary will be checked for writability.
|
Method | __init__ | Initialize file descriptor tracking dictionaries and the base class. |
Method | doSelect | Run one iteration of the I/O monitor loop. |
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 readers and writers. |
Method | getReaders | Return the list of file descriptors currently monitored for input events by the reactor. |
Method | getWriters | Return the list file descriptors currently monitored for output events by the reactor. |
Method | _preenDescriptors | 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 installed if asked. |
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 startup events. |
Method | callLater | See twisted.internet.interfaces.IReactorTime.callLater. |
Method | cancelCallLater | See twisted.internet.interfaces.IReactorTime.cancelCallLater. |
Method | getDelayedCalls | No summary |
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. |
Run one iteration of the I/O monitor loop.
This will run all selectables who had input or output readiness waiting for them.Remove all readers and writers.
Should not remove reactor internal reactor connections (like a waker).Returns | A list of IReadDescriptor
and IWriteDescriptor
providers which were removed.
|
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
) |