Home | Trees | Index | Help |
|
---|
Package twisted :: Package internet :: Module default :: Class PosixReactorBase |
|
ReactorBase
--+
|
PosixReactorBase
CFReactor
,
Gtk2Reactor
,
GtkReactor
,
PollReactor
,
SelectReactor
,
Win32Reactor
Method Summary | |
---|---|
__init__(self)
| |
Reap all processes on SIGCHLD. | |
Install the signal handlers for the Twisted event loop. | |
Connects a ConnectedDatagramProtocol instance to a UDP port. | |
| |
| |
DEPRECATED. | |
| |
Connects a ConnectedDatagramProtocol instance to a
path. | |
connectWith(self,
connectorType,
*args,
**kw)
| |
Install a `waker' to allow threads and signals to wake up the IO thread. | |
Connects a given DatagramProtocol to the given numeric UDP port. | |
| |
| |
Connects a given DatagramProtocol to the given numeric
UDP port. | |
| |
Connects a given DatagramProtocol to the given path. | |
listenWith(self,
portType,
*args,
**kw)
| |
mainLoop(self)
| |
run(self,
installSignalHandlers)
| |
spawnProcess(self,
processProtocol,
executable,
args,
env,
path,
uid,
gid,
usePTY,
childFDs)
| |
startRunning(self,
installSignalHandlers)
| |
Inherited from ReactorBase | |
| |
| |
| |
| |
| |
| |
See twisted.internet.interfaces.IReactorCore.addSystemEventTrigger. | |
| |
See twisted.internet.interfaces.IReactorThreads.callFromThread. | |
See twisted.internet.interfaces.IReactorThreads.callInThread. | |
See twisted.internet.interfaces.IReactorTime.callLater. | |
See twisted.internet.interfaces.IReactorCore.callWhenRunning. | |
See twisted.internet.interfaces.IReactorTime.cancelCallLater. | |
Deprecated - use connectSSL instead. | |
Deprecated - use connectTCP instead. | |
Deprecated - use connectUNIX instead. | |
See twisted.internet.interfaces.IReactorCore.crash. | |
Disconnect every reader, and writer in the system. | |
Do one iteration over the readers and writers we know about. | |
See twisted.internet.interfaces.IReactorCore.fireSystemEvent. | |
| |
| |
| |
See twisted.internet.interfaces.IReactorCore.iterate. | |
| |
| |
See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger. | |
| |
Return a Deferred that will resolve a hostname. | |
Run all pending timed calls. | |
Handle a SIGBREAK interrupt. | |
Handle a SIGINT interrupt. | |
Handle a SIGTERM interrupt. | |
See twisted.internet.interfaces.IReactorCore.stop. | |
See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize. | |
| |
Wake up the event loop. |
Class Variable Summary | |
---|---|
tuple |
__implements__ = ((<class twisted.internet.interfaces.IR...
|
Inherited from ReactorBase | |
str |
__name__ = 'ReactorBase'
|
NoneType |
_lock = None |
int |
installed = 0 |
NoneType |
threadCallQueue = None |
NoneType |
threadpool = None |
Method Details |
---|
_handleSigchld(self, signum, frame)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. Note that a Reactor must be able to accept callLater calls at any time, even interleaved inside it's own methods; it must block SIGCHLD if it is unable to guarantee this. |
_handleSignals(self)Install the signal handlers for the Twisted event loop. |
connectMulticast(self, remotehost, remoteport, protocol, localport=0, interface='', maxPacketSize=8192)Connects a ConnectedDatagramProtocol instance to a UDP port. EXPERIMENTAL. |
connectSSL(self, host, port, factory, contextFactory, timeout=30, bindAddress=None)
|
connectTCP(self, host, port, factory, timeout=30, bindAddress=None)
|
connectUDP(self, remotehost, remoteport, protocol, localport=0, interface='', maxPacketSize=8192)DEPRECATED. Connects aConnectedDatagramProtocol instance to a UDP
port.
|
connectUNIX(self, address, factory, timeout=30, checkPID=0)
|
connectUNIXDatagram(self, address, protocol, maxPacketSize=8192, mode=438, bindAddress=None)Connects a |
installWaker(self)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. |
listenMulticast(self, port, protocol, interface='', maxPacketSize=8192)Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL.
|
listenSSL(self, port, factory, contextFactory, backlog=5, interface='')
|
listenTCP(self, port, factory, backlog=5, interface='')
|
listenUDP(self, port, protocol, interface='', maxPacketSize=8192)Connects a given
|
listenUNIX(self, address, factory, backlog=5, mode=438, wantPID=0)
|
listenUNIXDatagram(self, address, protocol, maxPacketSize=8192, mode=438)Connects a given
|
Class Variable Details |
---|
Home | Trees | Index | Help |
|
---|
Generated by Epydoc 2.0 on Sat May 15 20:08:46 2004 | http://epydoc.sf.net |