Part of twisted.internet.default View Source View In Hierarchy
Known subclasses: twisted.internet._threadedselect.ThreadedSelectReactor, twisted.internet.cfreactor.CFReactor, twisted.internet.default.SelectReactor, twisted.internet.epollreactor.EPollReactor, twisted.internet.gtk2reactor.Gtk2Reactor, twisted.internet.kqreactor.KQueueReactor, twisted.internet.pollreactor.PollReactor, twisted.internet.win32eventreactor.Win32Reactor
Implements interfaces: twisted.internet.interfaces.IReactorArbitrary, twisted.internet.interfaces.IReactorMulticast, twisted.internet.interfaces.IReactorProcess, twisted.internet.interfaces.IReactorSSL, twisted.internet.interfaces.IReactorTCP, twisted.internet.interfaces.IReactorUDP, twisted.internet.interfaces.IReactorUNIX, twisted.internet.interfaces.IReactorUNIXDatagramMethod | __init__ | Undocumented |
Method | _handleSignals | Install the signal handlers for the Twisted event loop. |
Method | _handleSigchld | Reap all processes on SIGCHLD. |
Method | startRunning | Undocumented |
Method | run | Undocumented |
Method | mainLoop | Undocumented |
Method | _disconnectSelectable | Utility function for disconnecting a selectable. |
Method | installWaker | Install a `waker' to allow threads and signals to wake up the IO thread. |
Method | _checkProcessArgs | Check for valid arguments and environment to spawnProcess. |
Method | spawnProcess | Undocumented |
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 | _removeAll | Remove all readers and writers, and return list of Selectables. |
Inherited from ReactorBase:
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 | addReader | Undocumented |
Method | addWriter | Undocumented |
Method | removeReader | Undocumented |
Method | removeWriter | Undocumented |
Method | removeAll | Undocumented |
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 | _cbContinueSystemEvent | Undocumented |
Method | _continueSystemEvent | Undocumented |
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 | callLater | See twisted.internet.interfaces.IReactorTime.callLater. |
Method | _moveCallLaterSooner | Undocumented |
Method | _cancelCallLater | Undocumented |
Method | cancelCallLater | See twisted.internet.interfaces.IReactorTime.cancelCallLater. |
Method | getDelayedCalls | Return all the outstanding delayed calls in the system. |
Method | _insertNewDelayedCalls | Undocumented |
Method | timeout | Undocumented |
Method | runUntilCurrent | Run all pending timed calls. |
Method | _initThreads | Undocumented |
Method | callFromThread 0 | See twisted.internet.interfaces.IReactorThreads.callFromThread. |
Method | _initThreadPool | Undocumented |
Method | callInThread | See twisted.internet.interfaces.IReactorThreads.callInThread. |
Method | suggestThreadPoolSize | See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize. |
Method | callFromThread | Undocumented |
Reap all processes on SIGCHLD.
This gets called on SIGCHLD. We do no processing inside a signal handler, as the calls we make here could occur between any two python bytecode instructions. Deferring processing to the next eventloop round prevents us from violating the state constraints of arbitrary classes.Utility function for disconnecting a selectable.
Supports half-close notification, isRead should be boolean indicating whether error resulted from doRead().Install a `waker' to allow threads and signals to wake up the IO thread.
We use the self-pipe trick (http://cr.yp.to/docs/selfpipe.html) to wake the reactor. On Windows we use a pair of sockets.Returns | A two element tuple giving values to use when creating the process.
The first element of the tuple is a list of str
giving the values for argv of the child process. The second element of
the tuple is either None if env was
None or a dict mapping str
environment keys to str environment values.
|
DatagramProtocol
to the given numeric UDP port.
Returns | object conforming to IListeningPort .
|
Connects a given DatagramProtocol to the given numeric UDP port.
EXPERIMENTAL.Returns | object conforming to IListeningPort. |
See Also | twisted.internet.interfaces.IReactorUNIX.connectUNIX |
See Also | twisted.internet.interfaces.IReactorUNIX.listenUNIX |
Connects a given DatagramProtocol
to the given path.
Returns | object conforming to IListeningPort .
|
Connects a ConnectedDatagramProtocol
instance to a path.
See Also | twisted.internet.interfaces.IReactorTCP.listenTCP |
See Also | twisted.internet.interfaces.IReactorTCP.connectTCP |
See Also | twisted.internet.interfaces.IReactorSSL.connectSSL |
See Also | twisted.internet.interfaces.IReactorSSL.listenSSL |
portType
listening.
Parameters | portType | The object given by portType(*args, **kw) will be started
listening.
(type: type which implements IListeningPort
) |
Returns | an object which provides IListeningPort .
|
connectorType
connecting.
Parameters | connectorType | The object given by connectorType(*args, **kw) will be
started connecting.
(type: type which implements IConnector
) |
Returns | An object which provides IConnector .
|
Remove all readers and writers, and return list of Selectables.
Meant for calling from subclasses, to implement removeAll, like:def removeAll(self): return self._removeAll(reads, writes)where
reads
and writes
are iterables.