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

Class 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)
  _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)
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.
  initThreads(self)
  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.

Class Variable Summary
Implements __implemented__ = <implementedBy twisted.internet.base.R...
_implementsTuple __implements__ = (<MetaInterface twisted.internet.interf...
str __name__ = 'ReactorBase'
ClassProvides __providedBy__ = <zope.interface.declarations.ClassProvi...
ClassProvides __provides__ = <zope.interface.declarations.ClassProvide...
NoneType _lock = None                                                                  
int installed = 0                                                                     
NoneType threadpool = None                                                                  

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)

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>                      

__implements__

Type:
_implementsTuple
Value:
(<MetaInterface twisted.internet.interfaces.IReactorCore>, <MetaInterf\
ace twisted.internet.interfaces.IReactorTime>, <MetaInterface twisted.\
internet.interfaces.IReactorThreads>, <MetaInterface twisted.internet.\
interfaces.IReactorPluggableResolver>)                                 

__name__

Type:
str
Value:
'ReactorBase'                                                          

__providedBy__

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

__provides__

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

_lock

Type:
NoneType
Value:
None                                                                  

installed

Type:
int
Value:
0                                                                     

threadpool

Type:
NoneType
Value:
None                                                                  

Generated by Epydoc 2.1 on Sun Sep 4 00:24:44 2005 http://epydoc.sf.net