Class t.i.i.p.Proactor(iocpcore, base.ReactorBase, log.Logger):

Part of twisted.internet.iocpreactor.proactor View Source View In Hierarchy

Implements interfaces: twisted.internet.interfaces.IReactorArbitrary, twisted.internet.interfaces.IReactorMulticast, twisted.internet.interfaces.IReactorProcess, twisted.internet.interfaces.IReactorTCP, twisted.internet.interfaces.IReactorUDP

No class docstring

Split Table into Classes Show Methods in One Table

Line # Kind Name Docs
20 Method __init__ Undocumented
27 Method run Undocumented
31 Method mainLoop Undocumented
49 Method removeAll Undocumented
52 Method installWaker Undocumented
55 Method wakeUp Wake up the event loop.
61 Method listenTCP Connects a given protocol factory to the given numeric TCP/IP port.
66 Method connectTCP Connect a TCP client.
71 Method listenUDP Connects a given DatagramProtocol to the given numeric UDP port.
77 Method listenMulticast Connects a given
82 Method connectUDPblah Undocumented
88 Method listenWith Start an instance of the given portType listening.
93 Method connectWith Start an instance of the given connectorType connecting.
98 Method spawnProcess Spawn a process.
112 Method logPrefix Override this method to insert custom logging behavior. Its

Inherited from ReactorBase:

Line # Kind Name Docs
430 Method installResolver Set the internal resolver to use to for name lookups.
444 Method doIteration Do one iteration over the readers and writers we know about.
448 Method addReader Undocumented
451 Method addWriter Undocumented
454 Method removeReader Undocumented
457 Method removeWriter Undocumented
463 Method resolve Return a Deferred that will resolve a hostname.
477 Method stop See twisted.internet.interfaces.IReactorCore.stop.
486 Method crash See twisted.internet.interfaces.IReactorCore.crash.
492 Method sigInt Handle a SIGINT interrupt.
498 Method sigBreak Handle a SIGBREAK interrupt.
504 Method sigTerm Handle a SIGTERM interrupt.
510 Method disconnectAll Disconnect every reader, and writer in the system.
520 Method iterate See twisted.internet.interfaces.IReactorCore.iterate.
527 Method fireSystemEvent See twisted.internet.interfaces.IReactorCore.fireSystemEvent.
535 Method addSystemEventTrigger See twisted.internet.interfaces.IReactorCore.addSystemEventTrigger.
545 Method removeSystemEventTrigger See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger.
552 Method callWhenRunning See twisted.internet.interfaces.IReactorCore.callWhenRunning.
561 Method startRunning Method called when reactor starts: do some initialization and fire
582 Method callLater See twisted.internet.interfaces.IReactorTime.callLater.
595 Method _moveCallLaterSooner Undocumented
615 Method _cancelCallLater Undocumented
618 Method cancelCallLater See twisted.internet.interfaces.IReactorTime.cancelCallLater.
626 Method getDelayedCalls Return all the outstanding delayed calls in the system.
633 Method _insertNewDelayedCalls Undocumented
642 Method timeout Undocumented
651 Method runUntilCurrent Run all pending timed calls.
716 Method _initThreads Undocumented
721 Method callFromThread 0 See twisted.internet.interfaces.IReactorThreads.callFromThread.
732 Method _initThreadPool Create the threadpool accessible with callFromThread.
742 Method _stopThreadPool Stop the reactor threadpool.
750 Method callInThread See twisted.internet.interfaces.IReactorThreads.callInThread.
758 Method suggestThreadPoolSize See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize.
769 Method callFromThread Cause a function to be executed by the reactor thread.
Line # Kind Name Docs
20 Method __init__ Undocumented
615 Method _cancelCallLater Undocumented
732 Method _initThreadPool Create the threadpool accessible with callFromThread.
716 Method _initThreads Undocumented
633 Method _insertNewDelayedCalls Undocumented
595 Method _moveCallLaterSooner Undocumented
742 Method _stopThreadPool Stop the reactor threadpool.
448 Method addReader Undocumented
535 Method addSystemEventTrigger See twisted.internet.interfaces.IReactorCore.addSystemEventTrigger.
451 Method addWriter Undocumented
769 Method callFromThread Cause a function to be executed by the reactor thread.
721 Method callFromThread 0 See twisted.internet.interfaces.IReactorThreads.callFromThread.
750 Method callInThread See twisted.internet.interfaces.IReactorThreads.callInThread.
582 Method callLater See twisted.internet.interfaces.IReactorTime.callLater.
552 Method callWhenRunning See twisted.internet.interfaces.IReactorCore.callWhenRunning.
618 Method cancelCallLater See twisted.internet.interfaces.IReactorTime.cancelCallLater.
66 Method connectTCP Connect a TCP client.
82 Method connectUDPblah Undocumented
93 Method connectWith Start an instance of the given connectorType connecting.
486 Method crash See twisted.internet.interfaces.IReactorCore.crash.
510 Method disconnectAll Disconnect every reader, and writer in the system.
444 Method doIteration Do one iteration over the readers and writers we know about.
527 Method fireSystemEvent See twisted.internet.interfaces.IReactorCore.fireSystemEvent.
626 Method getDelayedCalls Return all the outstanding delayed calls in the system.
430 Method installResolver Set the internal resolver to use to for name lookups.
52 Method installWaker Undocumented
520 Method iterate See twisted.internet.interfaces.IReactorCore.iterate.
77 Method listenMulticast Connects a given
61 Method listenTCP Connects a given protocol factory to the given numeric TCP/IP port.
71 Method listenUDP Connects a given DatagramProtocol to the given numeric UDP port.
88 Method listenWith Start an instance of the given portType listening.
112 Method logPrefix Override this method to insert custom logging behavior. Its
31 Method mainLoop Undocumented
49 Method removeAll Undocumented
454 Method removeReader Undocumented
545 Method removeSystemEventTrigger See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger.
457 Method removeWriter Undocumented
463 Method resolve Return a Deferred that will resolve a hostname.
27 Method run Undocumented
651 Method runUntilCurrent Run all pending timed calls.
498 Method sigBreak Handle a SIGBREAK interrupt.
492 Method sigInt Handle a SIGINT interrupt.
504 Method sigTerm Handle a SIGTERM interrupt.
98 Method spawnProcess Spawn a process.
561 Method startRunning Method called when reactor starts: do some initialization and fire
477 Method stop See twisted.internet.interfaces.IReactorCore.stop.
758 Method suggestThreadPoolSize See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize.
642 Method timeout Undocumented
55 Method wakeUp Wake up the event loop.
def __init__(self): (source)
overrides twisted.internet.base.ReactorBase.__init__
Undocumented
def run(self): (source)
Undocumented
def mainLoop(self): (source)
Undocumented
def removeAll(self): (source)
overrides twisted.internet.base.ReactorBase.removeAll
Undocumented
def installWaker(self): (source)
overrides twisted.internet.base.ReactorBase.installWaker
Undocumented
def wakeUp(self): (source)
overrides twisted.internet.base.ReactorBase.wakeUp
Wake up the event loop.
def listenTCP(self, port, factory, backlog=50, interface=''): (source)
from twisted.internet.interfaces.IReactorTCP
Connects a given protocol factory to the given numeric TCP/IP port.
Parametersporta port number on which to listen
factorya twisted.internet.protocol.ServerFactory instance
backlogsize of the listen queue
interfacethe hostname to bind to, defaults to '' (all)
Returnsan object that provides IListeningPort.
RaisesCannotListenErroras defined here twisted.internet.error.CannotListenError, if it cannot listen on this port (e.g., it cannot bind to the required port number)
def connectTCP(self, host, port, factory, timeout=30, bindAddress=None): (source)
from twisted.internet.interfaces.IReactorTCP
Connect a TCP client.
Parametershosta host name
porta port number
factorya twisted.internet.protocol.ClientFactory instance
timeoutnumber of seconds to wait before assuming the connection has failed.
bindAddressa (host, port) tuple of local address to bind to, or None.
ReturnsAn object which provides IConnector. This connector will call various callbacks on the factory when a connection is made, failed, or lost - see ClientFactory docs for details.
def listenUDP(self, port, protocol, interface='', maxPacketSize=8192): (source)
from twisted.internet.interfaces.IReactorUDP
Connects a given DatagramProtocol to the given numeric UDP port.
Returnsobject which provides IListeningPort.
def listenMulticast(self, port, protocol, interface='', maxPacketSize=8192, listenMultiple=False): (source)
from twisted.internet.interfaces.IReactorMulticast
Connects a given DatagramProtocol to the given numeric UDP port.
ParameterslistenMultipleboolean indicating whether multiple sockets can bind to same UDP port.
ReturnsAn object which provides IListeningPort.
def connectUDPblah(self, remotehost, remoteport, protocol, localport=0, interface='', maxPacketSize=8192): (source)
Undocumented
def listenWith(self, portType, *args, **kw): (source)
from twisted.internet.interfaces.IReactorArbitrary
Start an instance of the given portType listening.
ParametersportTypeThe object given by portType(*args, **kw) will be started listening. (type: type which implements IListeningPort )
Returnsan object which provides IListeningPort.
def connectWith(self, connectorType, *args, **kw): (source)
from twisted.internet.interfaces.IReactorArbitrary
Start an instance of the given connectorType connecting.
ParametersconnectorTypeThe object given by connectorType(*args, **kw) will be started connecting. (type: type which implements IConnector )
ReturnsAn object which provides IConnector.
def spawnProcess(self, processProtocol, executable, args=(), env={}, path=None, uid=None, gid=None, usePTY=0, childFDs=None): (source)
from twisted.internet.interfaces.IReactorProcess
Spawn a process.
def logPrefix(self): (source)
overrides twisted.python.log.Logger.logPrefix
Override this method to insert custom logging behavior. Its return value will be inserted in front of every line. It may be called more times than the number of output lines.
API Documentation for Twisted, generated by pydoctor at 2008-02-28 08:53:09.