twisted.internet.baseView Source (View In Hierarchy)
Known subclasses: twisted.internet.iocpreactor.reactor.IOCPReactor, twisted.internet.posixbase.PosixReactorBase
Implements interfaces: twisted.internet.interfaces.IReactorCore, twisted.internet.interfaces.IReactorPluggableResolver, twisted.internet.interfaces.IReactorThreads, twisted.internet.interfaces.IReactorTime
Default base class for Reactors.
|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 which have been added.|
|Method||resolve||Return a Deferred that will resolve a hostname.|
|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||startRunning||Method called when reactor starts: do some initialization and fire startup events.|
|Method||timeout||Determine the longest time the reactor may sleep (waiting on I/O notification, perhaps) before it must wake up to service a time-related event.|
|Method||runUntilCurrent||Run all pending timed calls.|
|Method||callFromThread||Cause a function to be executed by the reactor thread.|
|Instance Variable||_stopped||A flag which is true between paired calls to
|Instance Variable||_justStopped||A flag which is true between the time
|Instance Variable||_started||A flag which is true from the time
|Instance Variable||_registerAsIOThread||A flag controlling whether the reactor will register the thread it is
running in as the I/O thread when it starts. If
|Method||_reallyStartRunning||Method called to transition to the running state. This should happen in the during startup event trigger phase.|
|Method||_checkProcessArgs||Check for valid arguments and environment to spawnProcess.|
|Method||_initThreadPool||Create the threadpool accessible with callFromThread.|
reactor.stop. This should be replaced with an explicit state machine. (type:
reactor.stopis called and the time the shutdown system event is fired. This is used to determine whether that event should be fired after each iteration through the mainloop. This should be replaced with an explicit state machine. (type:
reactor.runis called until the time
reactor.runreturns. This is used to prevent calls to
reactor.runon a running reactor. This should be replaced with an explicit state machine. (type:
True, registration will be done, otherwise it will not be.
Set the internal resolver to use to for name lookups.
|Parameters||resolver||The new resolver to use. (type: An object implementing the |
|Returns||The previously installed resolver.|
Wake up the event loop.
Do one iteration over the readers and writers which have been added.
Return a Deferred that will resolve a hostname.
Reset reactor state tracking attributes and re-initialize certain
state-transition helpers which were set up in
later destroyed (through use).
Handle a SIGINT interrupt.
Handle a SIGBREAK interrupt.
Handle a SIGTERM interrupt.
Disconnect every reader, and writer in the system.
Method called when reactor starts: do some initialization and fire startup events.
Don't call this directly, call reactor.run() instead: it should take care of calling this.
This method is somewhat misnamed. The reactor will not necessarily be in the running state by the time this method returns. The only guarantee is that it will be on its way to the running state.
Method called to transition to the running state. This should happen in the during startup event trigger phase.
Return all the outstanding delayed calls in the system. They are returned in no particular order. This method is not efficient -- it is really only meant for test cases.
Determine the longest time the reactor may sleep (waiting on I/O notification, perhaps) before it must wake up to service a time-related event.
|Returns||The maximum number of seconds the reactor may sleep. (type: |
Run all pending timed calls.
Check for valid arguments and environment to spawnProcess.
|Returns||A two element tuple giving values to use when creating the process. The
first element of the tuple is a |
Create the threadpool accessible with callFromThread.
Stop the reactor threadpool. This method is only valid if there is
currently a threadpool (created by
It is not intended to be called directly; instead, it will be called by a
shutdown trigger created in
Cause a function to be executed by the reactor thread.
Use this method when you want to run a function in the reactor's thread
from another thread. Calling
should wake up the main thread (where
is executing) and run the given callable in that thread.
If you're writing a multi-threaded application the
may need to be thread safe, but this method doesn't require it as such. If
you want to call a function in the next mainloop iteration, but you're in
the same thread, use
with a delay of 0.