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
Method __init__ Undocumented
Method startRunning Undocumented
Method run Undocumented
Method mainLoop Undocumented
Method removeAll Undocumented
Method installWaker Undocumented
Method wakeUp Wake up the event loop.
Method listenTCP Connects a given protocol factory to the given numeric TCP/IP port.
Method connectTCP Connect a TCP client.
Method listenUDP Connects a given DatagramProtocol to the given numeric UDP port.
Method listenMulticast Connects a given
Method connectUDPblah Undocumented
Method listenWith Start an instance of the given portType listening.
Method connectWith Start an instance of the given connectorType connecting.
Method spawnProcess Spawn a process.
Method logPrefix Override this method to insert custom logging behavior. Its

Inherited from ReactorBase:

Method installResolver Set the internal resolver to use to for name lookups.
Method doIteration Do one iteration over the readers and writers we know about.
Method addReader Undocumented
Method addWriter Undocumented
Method removeReader Undocumented
Method removeWriter 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 _cbContinueSystemEvent Undocumented
Method _continueSystemEvent Undocumented
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 callLater See twisted.internet.interfaces.IReactorTime.callLater.
Method _moveCallLaterSooner Undocumented
Method _cancelCallLater Undocumented
Method cancelCallLater See twisted.internet.interfaces.IReactorTime.cancelCallLater.
Method getDelayedCalls Return all the outstanding delayed calls in the system.
Method _insertNewDelayedCalls Undocumented
Method timeout Undocumented
Method runUntilCurrent Run all pending timed calls.
Method _initThreads Undocumented
Method callFromThread 0 See twisted.internet.interfaces.IReactorThreads.callFromThread.
Method _initThreadPool Undocumented
Method callInThread See twisted.internet.interfaces.IReactorThreads.callInThread.
Method suggestThreadPoolSize See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize.
Method callFromThread Undocumented
def __init__(self): (source)
overrides twisted.internet.base.ReactorBase.__init__
Undocumented
def startRunning(self): (source)
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.