Package twisted :: Package internet :: Module base :: Class ReactorBase
[show private | hide private]
[frames | no frames]

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