twisted.internet.base.ReactorBase

Package twisted :: Package internet :: Module base :: Class ReactorBase

[show private | hide private]

Type ReactorBase

object --+
         |
        ReactorBase

Known Subclasses:: PosixReactorBase

Default base class for Reactors.

Method Summary
	`__init__(self)`
	`_cancelCallLater(self, tple)`
	`_cbContinueSystemEvent(self, result, eventType)`
	`_continueSystemEvent(self, eventType)`
	`_initThreadPool(self)`
	`_initThreads(self)`
	`_insertNewDelayedCalls(self)`
	`_moveCallLaterSooner(self, tple)`
	`addReader(self, reader)`
	`addSystemEventTrigger(self, _phase, _eventType, _f, args, *kw)` See twisted.internet.interfaces.IReactorCore.addSystemEventTrigger.
	`addWriter(self, writer)`
	`callFromThread(self, f, args, *kw)` See twisted.internet.interfaces.IReactorThreads.callFromThread.
	`callInThread(self, _callable, args, *kwargs)` See twisted.internet.interfaces.IReactorThreads.callInThread.
	`callLater(self, _seconds, _f, args, *kw)` See twisted.internet.interfaces.IReactorTime.callLater.
	`callWhenRunning(self, _callable, args, *kw)` See twisted.internet.interfaces.IReactorCore.callWhenRunning.
	`cancelCallLater(self, callID)` See twisted.internet.interfaces.IReactorTime.cancelCallLater.
	`crash(self)` See twisted.internet.interfaces.IReactorCore.crash.
	`disconnectAll(self)` Disconnect every reader, and writer in the system.
	`doIteration(self, delay)` Do one iteration over the readers and writers we know about.
	`fireSystemEvent(self, eventType)` See twisted.internet.interfaces.IReactorCore.fireSystemEvent.
	`getDelayedCalls(self)` Return all the outstanding delayed calls in the system.
	`installResolver(self, resolver)`
	`installWaker(self)`
	`iterate(self, delay)` See twisted.internet.interfaces.IReactorCore.iterate.
	`removeAll(self)`
	`removeReader(self, reader)`
	`removeSystemEventTrigger(self, triggerID)` See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger.
	`removeWriter(self, writer)`
	`resolve(self, name, timeout)` Return a Deferred that will resolve a hostname.
	`runUntilCurrent(self)` Run all pending timed calls.
	`sigBreak(self, *args)` Handle a SIGBREAK interrupt.
	`sigInt(self, *args)` Handle a SIGINT interrupt.
	`sigTerm(self, *args)` Handle a SIGTERM interrupt.
	`stop(self)` See twisted.internet.interfaces.IReactorCore.stop.
	`suggestThreadPoolSize(self, size)` See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize.
	`timeout(self)`
	`wakeUp(self)` Wake up the event loop.
Inherited from object
	`__delattr__(...)` x.__delattr__('name') <==> del x.name
	`__getattribute__(...)` x.__getattribute__('name') <==> x.name
	`__hash__(x)` x.__hash__() <==> hash(x)
	`__new__(T, S, ...)` T.__new__(S, ...) -> a new object with type S, a subtype of T
	`__reduce__(...)` helper for pickle
	`__reduce_ex__(...)` helper for pickle
	`__repr__(x)` x.__repr__() <==> repr(x)
	`__setattr__(...)` x.__setattr__('name', value) <==> x.name = value
	`__str__(x)` x.__str__() <==> str(x)

Class Variable Summary
`Implements`	`__implemented__` = `<implementedBy twisted.internet.base.R...`
`str`	`__name__` = `'ReactorBase'`
`ClassProvides`	`__providedBy__` = `<zope.interface.declarations.ClassProvi...`
`ClassProvides`	`__provides__` = `<zope.interface.declarations.ClassProvide...`
`NoneType`	`_lock` = None
`int`	`installed` = 0
`BlockingResolver`	`resolver` = `<twisted.internet.base.BlockingResolver insta...`
`NoneType`	`threadpool` = None
`int`	`usingThreads` = 0

Method Details

addSystemEventTrigger(self, _phase, _eventType, _f, *args, **kw)

See twisted.internet.interfaces.IReactorCore.addSystemEventTrigger.

callFromThread(self, f, *args, **kw)

See twisted.internet.interfaces.IReactorThreads.callFromThread.

callInThread(self, _callable, *args, **kwargs)

See twisted.internet.interfaces.IReactorThreads.callInThread.

callLater(self, _seconds, _f, *args, **kw)

See twisted.internet.interfaces.IReactorTime.callLater.

callWhenRunning(self, _callable, *args, **kw)

See twisted.internet.interfaces.IReactorCore.callWhenRunning.

cancelCallLater(self, callID)

See twisted.internet.interfaces.IReactorTime.cancelCallLater.

crash(self)

See twisted.internet.interfaces.IReactorCore.crash.

disconnectAll(self)

Disconnect every reader, and writer in the system.

doIteration(self, delay)

Do one iteration over the readers and writers we know about.

fireSystemEvent(self, eventType)

See twisted.internet.interfaces.IReactorCore.fireSystemEvent.

getDelayedCalls(self)

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.

iterate(self, delay=0)

See twisted.internet.interfaces.IReactorCore.iterate.

removeSystemEventTrigger(self, triggerID)

See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger.

resolve(self, name, timeout=(1, 3, 11, 45))

Return a Deferred that will resolve a hostname.

runUntilCurrent(self)

Run all pending timed calls.

sigBreak(self, *args)

Handle a SIGBREAK interrupt.

sigInt(self, *args)

Handle a SIGINT interrupt.

sigTerm(self, *args)

Handle a SIGTERM interrupt.

stop(self)

See twisted.internet.interfaces.IReactorCore.stop.

suggestThreadPoolSize(self, size)

See twisted.internet.interfaces.IReactorThreads.suggestThreadPoolSize.

wakeUp(self)

Wake up the event loop.

Class Variable Details

implemented

Type:: Implements
Value:: <implementedBy twisted.internet.base.ReactorBase>

name

Type:: str
Value:: 'ReactorBase'

providedBy

Type:: ClassProvides
Value:: <zope.interface.declarations.ClassProvides object at 0x2b88c5042850>

provides

Type:: ClassProvides
Value:: <zope.interface.declarations.ClassProvides object at 0x2b88c5042850>

_lock

Type:: NoneType
Value:: None

installed

Type:: int
Value:: 0

resolver

Type:: BlockingResolver
Value:: <twisted.internet.base.BlockingResolver instance at 0x2b88c5040ab8>

threadpool

Type:: NoneType
Value:: None

usingThreads

Type:: int
Value:: 0

Generated by Epydoc 2.1 on Fri Feb 2 11:29:21 2007

http://epydoc.sf.net