Trees | Index | Help |
---|
Package twisted :: Package internet :: Module posixbase :: Class PosixReactorBase |
|
object
--+ |ReactorBase
--+ | PosixReactorBase
Gtk2Reactor
Method Summary | |
---|---|
__init__(self)
| |
| |
| |
Connects a ConnectedDatagramProtocol instance to a UDP port. | |
| |
Connects a ConnectedDatagramProtocol instance to a UDP port. | |
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 numeric UDP port. | |
listenWith(self,
portType,
*args,
**kw)
| |
mainLoop(self)
| |
run(self,
installSignalHandlers)
| |
spawnProcess(self,
processProtocol,
executable,
args,
env,
path,
uid,
gid,
usePTY,
childFDs)
| |
startRunning(self,
installSignalHandlers)
| |
Check for valid arguments and environment to spawnProcess. | |
Utility function for disconnecting a selectable. | |
Reap all processes on SIGCHLD. | |
Install the signal handlers for the Twisted event loop. | |
Remove all readers and writers, and return list of Selectables. | |
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. | |
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. | |
Return all the outstanding delayed calls in the system. | |
| |
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. | |
Inherited from object | |
x.__delattr__('name') <==> del x.name | |
x.__getattribute__('name') <==> x.name | |
x.__hash__() <==> hash(x) | |
T.__new__(S, ...) -> a new object with type S, a subtype of T | |
helper for pickle | |
helper for pickle | |
x.__repr__() <==> repr(x) | |
x.__setattr__('name', value) <==> x.name = value | |
x.__str__() <==> str(x) |
Class Variable Summary | |
---|---|
Implements |
__implemented__ = <implementedBy twisted.internet.posixb...
|
ClassProvides |
__provides__ = <zope.interface.declarations.ClassProvide...
|
Inherited from ReactorBase | |
str |
__name__ = 'ReactorBase'
|
ClassProvides |
__providedBy__ = <zope.interface.declarations.ClassProvi...
|
NoneType |
_lock = None |
int |
installed = 0 |
BlockingResolver |
resolver = <twisted.internet.base.BlockingResolver insta...
|
NoneType |
threadpool = None |
int |
usingThreads = 0 |
Method Details |
---|
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)Connects a ConnectedDatagramProtocol instance to a UDP port. EXPERIMENTAL. |
connectUNIX(self, address, factory, timeout=30, checkPID=0)
|
connectUNIXDatagram(self, remotehost, remoteport, protocol, localport=0, interface='', maxPacketSize=8192)Connects a ConnectedDatagramProtocol instance to a UDP port. EXPERIMENTAL. |
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, listenMultiple=False)Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL.
|
listenSSL(self, port, factory, contextFactory, backlog=50, interface='')
|
listenTCP(self, port, factory, backlog=50, interface='')
|
listenUDP(self, port, protocol, interface='', maxPacketSize=8192)Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL.
|
listenUNIX(self, address, factory, backlog=50, mode=438, wantPID=0)
|
listenUNIXDatagram(self, port, protocol, interface='', maxPacketSize=8192)Connects a given DatagramProtocol to the given numeric UDP port. EXPERIMENTAL.
|
_checkProcessArgs(self, args, env)Check for valid arguments and environment to spawnProcess.
|
_disconnectSelectable(self, selectable, why, isRead, faildict={<class 'twisted.internet.error.ConnectionLost'>: <twiste...)Utility function for disconnecting a selectable. Supports half-close notification, isRead should be boolean indicating whether error resulted from doRead(). |
_handleSigchld(self, signum, frame, _threadSupport=True)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. |
_handleSignals(self)Install the signal handlers for the Twisted event loop. |
_removeAll(self, readers, writers)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.
|
Class Variable Details |
---|
__implemented__
|
__provides__
|
Trees | Index | Help |
---|
Generated by Epydoc 2.1 on Fri Feb 2 11:44:37 2007 | http://epydoc.sf.net |