Class t.i.b.ReactorBase(object):

Part of twisted.internet.base View Source View In Hierarchy

Known subclasses: twisted.internet.default.PosixReactorBase, twisted.internet.iocpreactor.proactor.Proactor

Implements interfaces: twisted.internet.interfaces.IReactorCore, twisted.internet.interfaces.IReactorPluggableResolver, twisted.internet.interfaces.IReactorThreads, twisted.internet.interfaces.IReactorTime
Default base class for Reactors.
Method __init__ Undocumented
Method installWaker Undocumented
Method installResolver Set the internal resolver to use to for name lookups.
Method wakeUp Wake up the event loop.
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 removeAll 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)
overridden in twisted.internet.default.PosixReactorBase, twisted.internet.iocpreactor.proactor.Proactor
Undocumented
def installWaker(self): (source)
overridden in twisted.internet.default.PosixReactorBase, twisted.internet.iocpreactor.proactor.Proactor
Undocumented
def installResolver(self, resolver): (source)
from twisted.internet.interfaces.IReactorPluggableResolver
Set the internal resolver to use to for name lookups.
ParametersresolverThe new resolver to use. (type: An object implementing the IResolverSimple interface )
ReturnsThe previously installed resolver.
def wakeUp(self): (source)
overridden in twisted.internet._threadedselect.ThreadedSelectReactor, twisted.internet.iocpreactor.proactor.Proactor
Wake up the event loop.
def doIteration(self, delay): (source)
overridden in twisted.internet.cfreactor.CFReactor, twisted.internet.gtk2reactor.Gtk2Reactor
Do one iteration over the readers and writers we know about.
def addReader(self, reader): (source)
overridden in twisted.internet._threadedselect.ThreadedSelectReactor, twisted.internet.cfreactor.CFReactor, twisted.internet.default.SelectReactor, twisted.internet.epollreactor.EPollReactor, twisted.internet.gtk2reactor.Gtk2Reactor, twisted.internet.kqreactor.KQueueReactor, twisted.internet.pollreactor.PollReactor, twisted.internet.win32eventreactor.Win32Reactor
Undocumented
def addWriter(self, writer): (source)
overridden in twisted.internet._threadedselect.ThreadedSelectReactor, twisted.internet.cfreactor.CFReactor, twisted.internet.default.SelectReactor, twisted.internet.epollreactor.EPollReactor, twisted.internet.gtk2reactor.Gtk2Reactor, twisted.internet.kqreactor.KQueueReactor, twisted.internet.pollreactor.PollReactor, twisted.internet.win32eventreactor.Win32Reactor
Undocumented
def removeReader(self, reader): (source)
overridden in twisted.internet._threadedselect.ThreadedSelectReactor, twisted.internet.cfreactor.CFReactor, twisted.internet.default.SelectReactor, twisted.internet.epollreactor.EPollReactor, twisted.internet.gtk2reactor.Gtk2Reactor, twisted.internet.kqreactor.KQueueReactor, twisted.internet.pollreactor.PollReactor, twisted.internet.win32eventreactor.Win32Reactor
Undocumented
def removeWriter(self, writer): (source)
overridden in twisted.internet._threadedselect.ThreadedSelectReactor, twisted.internet.cfreactor.CFReactor, twisted.internet.default.SelectReactor, twisted.internet.epollreactor.EPollReactor, twisted.internet.gtk2reactor.Gtk2Reactor, twisted.internet.kqreactor.KQueueReactor, twisted.internet.pollreactor.PollReactor, twisted.internet.win32eventreactor.Win32Reactor
Undocumented
def removeAll(self): (source)
overridden in twisted.internet._threadedselect.ThreadedSelectReactor, twisted.internet.cfreactor.CFReactor, twisted.internet.default.SelectReactor, twisted.internet.epollreactor.EPollReactor, twisted.internet.gtk2reactor.Gtk2Reactor, twisted.internet.iocpreactor.proactor.Proactor, twisted.internet.kqreactor.KQueueReactor, twisted.internet.pollreactor.PollReactor, twisted.internet.win32eventreactor.Win32Reactor
Undocumented
def resolve(self, name, timeout=(1, 3, 11, 45)): (source)
from twisted.internet.interfaces.IReactorCore
Return a Deferred that will resolve a hostname.
def stop(self): (source)
from twisted.internet.interfaces.IReactorCore
overridden in twisted.internet.cfreactor.CFReactor, twisted.internet.wxreactor.WxReactor
See twisted.internet.interfaces.IReactorCore.stop.
def crash(self): (source)
from twisted.internet.interfaces.IReactorCore
overridden in twisted.internet.cfreactor.CFReactor, twisted.internet.gtk2reactor.Gtk2Reactor, twisted.internet.gtk2reactor.PortableGtkReactor
See twisted.internet.interfaces.IReactorCore.crash.
def sigInt(self, *args): (source)
overridden in twisted.internet.cfreactor.CFReactor
Handle a SIGINT interrupt.
def sigBreak(self, *args): (source)
Handle a SIGBREAK interrupt.
def sigTerm(self, *args): (source)
Handle a SIGTERM interrupt.
def disconnectAll(self): (source)
Disconnect every reader, and writer in the system.
def iterate(self, delay=0): (source)
from twisted.internet.interfaces.IReactorCore
overridden in twisted.internet.cfreactor.CFReactor
See twisted.internet.interfaces.IReactorCore.iterate.
def fireSystemEvent(self, eventType): (source)
from twisted.internet.interfaces.IReactorCore
See twisted.internet.interfaces.IReactorCore.fireSystemEvent.
def _cbContinueSystemEvent(self, result, eventType): (source)
Undocumented
def _continueSystemEvent(self, eventType): (source)
Undocumented
def addSystemEventTrigger(self, _phase, _eventType, _f, *args, **kw): (source)
from twisted.internet.interfaces.IReactorCore
See twisted.internet.interfaces.IReactorCore.addSystemEventTrigger.
def removeSystemEventTrigger(self, triggerID): (source)
from twisted.internet.interfaces.IReactorCore
See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger.
def callWhenRunning(self, _callable, *args, **kw): (source)
from twisted.internet.interfaces.IReactorCore
See twisted.internet.interfaces.IReactorCore.callWhenRunning.
def callLater(self, _seconds, _f, *args, **kw): (source)
from twisted.internet.interfaces.IReactorTime
overridden in twisted.internet._threadedselect.ThreadedSelectReactor, twisted.internet.cfreactor.CFReactor
See twisted.internet.interfaces.IReactorTime.callLater.
def _moveCallLaterSooner(self, tple): (source)
Undocumented
def _cancelCallLater(self, tple): (source)
Undocumented
def cancelCallLater(self, callID): (source)
from twisted.internet.interfaces.IReactorTime
See twisted.internet.interfaces.IReactorTime.cancelCallLater.
def getDelayedCalls(self): (source)
from twisted.internet.interfaces.IReactorTime
Return all the outstanding delayed calls in the system. They are returned in no particular order. This method is not efficient -- it is really only meant for test cases.
def _insertNewDelayedCalls(self): (source)
Undocumented
def timeout(self): (source)
Undocumented
def runUntilCurrent(self): (source)
Run all pending timed calls.
def _initThreads(self): (source)
Undocumented
def callFromThread 0(self, f, *args, **kw): (source)
See twisted.internet.interfaces.IReactorThreads.callFromThread.
def _initThreadPool(self): (source)
Undocumented
def callInThread(self, _callable, *args, **kwargs): (source)
from twisted.internet.interfaces.IReactorThreads
See twisted.internet.interfaces.IReactorThreads.callInThread.
def suggestThreadPoolSize(self, size): (source)
from twisted.internet.interfaces.IReactorThreads
See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize.
def callFromThread(self, f, *args, **kw): (source)
from twisted.internet.interfaces.IReactorThreads
Undocumented
API Documentation for twisted, generated by pydoctor.