Part of twisted.internet.posixbase View Source View In Hierarchy
Known subclasses: twisted.internet._glibbase.GlibReactorBase, twisted.internet._threadedselect.ThreadedSelectReactor, twisted.internet.cfreactor.CFReactor, twisted.internet.epollreactor.EPollReactor, twisted.internet.gtkreactor.GtkReactor, twisted.internet.kqreactor.KQueueReactor, twisted.internet.pollreactor.PollReactor, twisted.internet.selectreactor.SelectReactor, twisted.internet.win32eventreactor.Win32Reactor
Implements interfaces: twisted.internet.interfaces.IReactorProcess, twisted.internet.interfaces.IReactorSocket, twisted.internet.interfaces.IReactorSSL, twisted.internet.interfaces.IReactorUNIX, twisted.internet.interfaces.IReactorUNIXDatagram
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 | listenMulticast | Connects a given DatagramProtocol to the given numeric UDP port. |
Method | connectUNIX | Connect a client protocol to a UNIX socket. |
Method | listenUNIX | Listen on a UNIX socket. |
Method | listenUNIXDatagram | Connects a given DatagramProtocol
to the given path. |
Method | connectUNIXDatagram | Connects a ConnectedDatagramProtocol
instance to a path. |
Method | adoptStreamPort | Create a new IListeningPort
from an already-initialized socket. |
Method | adoptStreamConnection | |
Method | adoptDatagramPort | Add an existing listening SOCK_DGRAM socket to the reactor to monitor for read and write readiness. |
Method | listenTCP | Undocumented |
Method | connectTCP | Undocumented |
Method | connectSSL | Connect a client Protocol to a remote SSL socket. |
Method | listenSSL | Connects a given protocol factory to the given numeric TCP/IP port. The connection is a SSL one, using contexts created by the context factory. |
Instance Variable | _childWaker | None or a reference to the _SIGCHLDWaker
which is used to properly notice child process termination. |
Method | _handleSignals | Extend the basic signal handling logic to also support handling SIGCHLD to know when to try to reap child processes. |
Method | _uninstallHandler | If a child waker was created and installed, uninstall it now. |
Method | _removeAll | Remove all readers and writers, and list of removed IReadDescriptor s
and IWriteDescriptor s. |
Inherited from _SignalReactorMixin:
Method | startRunning | Extend the base implementation in order to remember whether signal handlers should be installed later. |
Method | run | Undocumented |
Method | mainLoop | Undocumented |
Instance Variable | _installSignalHandlers | A flag which indicates whether any signal handlers will be installed during
startup. This includes handlers for SIGCHLD to monitor child processes,
and SIGINT, SIGTERM, and SIGBREAK to stop the reactor. (type: bool ) |
Method | _reallyStartRunning | Extend the base implementation by also installing signal handlers, if
self._installSignalHandlers is true. |
Inherited from _DisconnectSelectableMixin:
Method | _disconnectSelectable | Utility function for disconnecting a selectable. |
Inherited from ReactorBase:
Instance Variable | running | See IReactorCore.running |
Method | __init__ | Undocumented |
Method | installResolver | Undocumented |
Method | wakeUp | Wake up the event loop. |
Method | doIteration | Do one iteration over the readers and writers which have been added. |
Method | addReader | Undocumented |
Method | addWriter | Undocumented |
Method | removeReader | Undocumented |
Method | removeWriter | Undocumented |
Method | removeAll | Undocumented |
Method | getReaders | Undocumented |
Method | getWriters | 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 | 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 | getDelayedCalls | No summary |
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 0 | See twisted.internet.interfaces.IReactorThreads.callFromThread . |
Method | getThreadPool | See twisted.internet.interfaces.IReactorThreads.getThreadPool . |
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. |
Instance Variable | _stopped | A flag which is true between paired calls to reactor.run and
reactor.stop . This should be replaced with an explicit state
machine. (type: bool ) |
Instance Variable | _justStopped | A flag which is true between the time reactor.stop is 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: bool ) |
Instance Variable | _started | A flag which is true from the time reactor.run is called until
the time reactor.run returns. This is used to prevent calls
to reactor.run on a running reactor. This should be replaced
with an explicit state machine. (type: bool ) |
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 True ,
registration will be done, otherwise it will not be. |
Method | _reallyStartRunning | Method called to transition to the running state. This should happen in the during startup event trigger phase. |
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 | No summary |
None
or a reference to the _SIGCHLDWaker
which is used to properly notice child process termination.
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.
Since this disables reactor functionality and is only called when the reactor is stopping, it doesn't provide any directly useful functionality, but the cleanup of reactor-related process-global state that it does helps in unit tests involving multiple reactors and is generally just a nice thing.
Parameters | processProtocol | An object which will be notified of all events related to the created
process. (type: IProcessProtocol
provider) |
executable | the file name to spawn - the full path should be used. | |
args | the command line arguments to pass to the process; a sequence of strings. The first string should be the executable's name. | |
env | the environment variables to pass to the child process. The resulting
behavior varies between platforms. If
dict mapping str to str , or
None .) | |
path | the path to run the subprocess in - defaults to the current directory. | |
uid | user ID to run the subprocess as. (Only available on POSIX systems.) | |
gid | group ID to run the subprocess as. (Only available on POSIX systems.) | |
usePTY | if true, run this process in a pseudo-terminal. optionally a tuple of
(masterfd, slavefd, ttyname) , in which case use those file
descriptors. (Not available on all systems.) | |
childFDs | A dictionary mapping file descriptors in the new child process to an
integer or to the string 'r' or 'w'.
If the value is an integer, it specifies a file descriptor in the parent process which will be mapped to a file descriptor (specified by the key) in the child process. This is useful for things like inetd and shell-like file redirection. If it is the string 'r', a pipe will be created and attached to the
child at that file descriptor: the child will be able to write to that file
descriptor and the parent will receive read notification via the If it is the string 'w', similar setup to the previous case will occur,
with the pipe being readable by the child instead of writeable. The parent
process can write to that file descriptor using If childFDs is not passed, the default behaviour is to use a mapping that opens the usual stdin/stdout/stderr pipes. | |
Returns | An object which provides IProcessTransport . | |
Raises | OSError | Raised with errno EAGAIN or ENOMEM if there are
insufficient system resources to create a new process. |
See Also | twisted.internet.protocol.ProcessProtocol |
DatagramProtocol
to the given numeric UDP port.Returns | object conforming to IListeningPort . |
EXPERIMENTAL.
Returns | object conforming to IListeningPort. |
Parameters | address | a path to a unix socket on the filesystem. |
factory | a twisted.internet.protocol.ClientFactory
instance | |
timeout | number of seconds to wait before assuming the connection has failed. | |
checkPID | if True, check for a pid file to verify that a server is listening. If
address is a Linux abstract namespace path, this must be
False . | |
Returns | An object which provides IConnector . |
Parameters | address | a path to a unix socket on the filesystem. |
factory | a twisted.internet.protocol.Factory
instance. | |
backlog | number of connections to allow in backlog. | |
mode | The mode (not umask) to set on the unix socket. See platform
specific documentation for information about how this might affect
connection attempts. (type: int ) | |
wantPID | if True, create a pidfile for the socket. If address is a
Linux abstract namespace path, this must be False . | |
Returns | An object which provides IListeningPort . |
DatagramProtocol
to the given path.
EXPERIMENTAL.
Returns | object conforming to IListeningPort . |
IListeningPort
from an already-initialized socket.
This just dispatches to a suitable port implementation (eg from IReactorTCP
,
etc) based on the specified addressFamily
.
See Also | twisted.internet.interfaces.IReactorSocket.adoptStreamPort |
Add an existing listening I{SOCK_DGRAM} socket to the reactor to monitor for read and write readiness. @param fileDescriptor: A file descriptor associated with a socket which is already bound to an address and marked as listening. The socket must be set non-blocking. Any additional flags (for example, close-on-exec) must also be set by application code. Application code is responsible for closing the file descriptor, which may be done as soon as C{adoptDatagramPort} returns. @type fileDescriptor: C{int} @param addressFamily: The address family (or I{domain}) of the socket. For example, L{socket.AF_INET6}. @type addressFamily: C{int} @param protocol: A L{DatagramProtocol} instance to connect to a UDP transport. @type protocol: L{DatagramProtocol} @param maxPacketSize: The maximum packet size to accept. @type maxPacketSize: C{int} @return: An object providing L{IListeningPort}. @raise L{UnsupportedAddressFamily}: If the given address family is not supported by this reactor, or not supported with the given socket type. @raise UnsupportedSocketType: If the given socket type is not supported by this reactor, or not supported with the given socket type.
Parameters | host | a host name |
port | a port number | |
factory | a twisted.internet.protocol.ClientFactory
instance | |
contextFactory | a twisted.internet.ssl.ClientContextFactory
object. | |
timeout | number of seconds to wait before assuming the connection has failed. | |
bindAddress | a (host, port) tuple of local address to bind to, or None . | |
Returns | An object which provides IConnector . |
Parameters | port | a port number on which to listen |
factory | a twisted.internet.protocol.ServerFactory
instance | |
contextFactory | a twisted.internet.ssl.ContextFactory
instance | |
backlog | size of the listen queue | |
interface | the hostname to bind to, defaults to '' (all) |
IReadDescriptor
s
and IWriteDescriptor
s.
Meant for calling from subclasses, to implement removeAll, like:
def removeAll(self): return self._removeAll(self._reads, self._writes)
where self._reads
and self._writes
are
iterables.