twisted.internet.iocpreactor.reactor.IOCPReactor(base._SignalReactorMixin, base.ReactorBase, _ThreadedWin32EventsMixin) class documentation

Part of twisted.internet.iocpreactor.reactor View Source (View In Hierarchy)

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

No class docstring
Method __init__ Undocumented
Method addActiveHandle Undocumented
Method removeActiveHandle Undocumented
Method doIteration Poll the IO completion port for new events.
Method installWaker Undocumented
Method wakeUp Wake up the event loop.
Method registerHandle Undocumented
Method createSocket Undocumented
Method listenTCP
Method connectTCP
Method listenSSL 0
Method connectSSL 0
Method listenSSL Non-implementation of IReactorSSL.listenSSL. Some dependency is not satisfied. This implementation always raises NotImplementedError.
Method connectSSL Non-implementation of IReactorSSL.connectSSL. Some dependency is not satisfied. This implementation always raises NotImplementedError.
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 spawnProcess Spawn a process.
Method removeAll Undocumented
Method _callEventCallback Undocumented

Inherited from _ThreadedWin32EventsMixin:

Method addEvent
Method removeEvent
Instance Variable _reactor The Win32Reactor running in the other thread. This is None until it is actually needed.
Instance Variable _reactorThread The threading.Thread which is running the Win32Reactor. This is None until it is actually needed.
Method _unmakeHelperReactor Stop and discard the reactor started by _makeHelperReactor.
Method _makeHelperReactor Create and (in a new thread) start a Win32Reactor instance to use for the implementation of IReactorWin32Events.

Inherited from _ThreadedWin32EventsMixin:

Method addEvent
Method removeEvent
Instance Variable _reactor The Win32Reactor running in the other thread. This is None until it is actually needed.
Instance Variable _reactorThread The threading.Thread which is running the Win32Reactor. This is None until it is actually needed.
Method _unmakeHelperReactor Stop and discard the reactor started by _makeHelperReactor.
Method _makeHelperReactor Create and (in a new thread) start a Win32Reactor instance to use for the implementation of IReactorWin32Events.

Inherited from _ThreadedWin32EventsMixin:

Method addEvent
Method removeEvent
Instance Variable _reactor The Win32Reactor running in the other thread. This is None until it is actually needed.
Instance Variable _reactorThread The threading.Thread which is running the Win32Reactor. This is None until it is actually needed.
Method _unmakeHelperReactor Stop and discard the reactor started by _makeHelperReactor.
Method _makeHelperReactor Create and (in a new thread) start a Win32Reactor instance to use for the implementation of IReactorWin32Events.

Inherited from _ThreadedWin32EventsMixin:

Method addEvent
Method removeEvent
Instance Variable _reactor The Win32Reactor running in the other thread. This is None until it is actually needed.
Instance Variable _reactorThread The threading.Thread which is running the Win32Reactor. This is None until it is actually needed.
Method _unmakeHelperReactor Stop and discard the reactor started by _makeHelperReactor.
Method _makeHelperReactor Create and (in a new thread) start a Win32Reactor instance to use for the implementation of IReactorWin32Events.
def __init__(self): (source)
overrides twisted.internet.base.ReactorBase.__init__
Undocumented
def addActiveHandle(self, handle): (source)
Undocumented
def removeActiveHandle(self, handle): (source)
Undocumented
def doIteration(self, timeout): (source)
overrides twisted.internet.base.ReactorBase.doIteration

Poll the IO completion port for new events.

def _callEventCallback(self, rc, numBytes, evt): (source)
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 registerHandle(self, handle): (source)
Undocumented
def createSocket(self, af, stype): (source)
Undocumented
def listenTCP(self, port, factory, backlog=50, interface=''): (source)
from twisted.internet.interfaces.IReactorTCP
See Alsotwisted.internet.interfaces.IReactorTCP.listenTCP
def connectTCP(self, host, port, factory, timeout=30, bindAddress=None): (source)
from twisted.internet.interfaces.IReactorTCP
See Alsotwisted.internet.interfaces.IReactorTCP.connectTCP
def listenSSL 0(self, port, factory, contextFactory, backlog=50, interface=''): (source)
See Alsotwisted.internet.interfaces.IReactorSSL.listenSSL
def connectSSL 0(self, host, port, factory, contextFactory, timeout=30, bindAddress=None): (source)
See Alsotwisted.internet.interfaces.IReactorSSL.connectSSL
def listenSSL(self, port, factory, contextFactory, backlog=50, interface=''): (source)

Non-implementation of IReactorSSL.listenSSL. Some dependency is not satisfied. This implementation always raises NotImplementedError.

def connectSSL(self, host, port, factory, contextFactory, timeout=30, bindAddress=None): (source)

Non-implementation of IReactorSSL.connectSSL. Some dependency is not satisfied. This implementation always raises NotImplementedError.

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 conforming to 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.

EXPERIMENTAL.

Returnsobject conforming to IListeningPort.
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 removeAll(self): (source)
overrides twisted.internet.base.ReactorBase.removeAll
Undocumented
API Documentation for Twisted, generated by pydoctor at 2019-08-06 12:10:50.