Package flumotion :: Package twisted :: Module gtk2reactor :: Class Gtk2Reactor
[show private | hide private]
[frames | no frames]

Type Gtk2Reactor

  object --+        
           |        
 ReactorBase --+    
               |    
PosixReactorBase --+
                   |
                  Gtk2Reactor


GTK+-2 event loop reactor.
Method Summary
  __init__(self, useGtk)
  _doReadOrWrite(self, source, condition, faildict)
  addReader(self, reader)
  addWriter(self, writer)
  callback(self, source, condition)
  crash(self)
See twisted.internet.interfaces.IReactorCore.crash.
  doIteration(self, delay)
Do one iteration over the readers and writers we know about.
  doIterationTimeout(self, *args)
  input_add(self, source, condition, callback)
  removeAll(self)
  removeReader(self, reader)
  removeWriter(self, writer)
  run(self, installSignalHandlers)
  simulate(self)
Run simulation loops and reschedule callbacks.
    Inherited from PosixReactorBase
  connectSSL(self, host, port, factory, contextFactory, timeout, bindAddress)
  connectTCP(self, host, port, factory, timeout, bindAddress)
  connectUDP(self, remotehost, remoteport, protocol, localport, interface, maxPacketSize)
Connects a ConnectedDatagramProtocol instance to a UDP port.
  connectUNIX(self, address, factory, timeout, checkPID)
  connectUNIXDatagram(self, remotehost, remoteport, protocol, localport, interface, maxPacketSize)
Connects a ConnectedDatagramProtocol instance to a UDP port.
  connectWith(self, connectorType, *args, **kw)
  installWaker(self)
Install a `waker' to allow threads and signals to wake up the IO thread.
  listenMulticast(self, port, protocol, interface, maxPacketSize, listenMultiple)
Connects a given DatagramProtocol to the given numeric UDP port.
  listenSSL(self, port, factory, contextFactory, backlog, interface)
  listenTCP(self, port, factory, backlog, interface)
  listenUDP(self, port, protocol, interface, maxPacketSize)
Connects a given DatagramProtocol to the given numeric UDP port.
  listenUNIX(self, address, factory, backlog, mode, wantPID)
  listenUNIXDatagram(self, port, protocol, interface, maxPacketSize)
Connects a given DatagramProtocol to the given numeric UDP port.
  listenWith(self, portType, *args, **kw)
  mainLoop(self)
  spawnProcess(self, processProtocol, executable, args, env, path, uid, gid, usePTY, childFDs)
  startRunning(self, installSignalHandlers)
  _checkProcessArgs(self, args, env)
Check for valid arguments and environment to spawnProcess.
  _disconnectSelectable(self, selectable, why, isRead, faildict)
Utility function for disconnecting a selectable.
  _handleSigchld(self, signum, frame, _threadSupport)
Reap all processes on SIGCHLD.
  _handleSignals(self)
Install the signal handlers for the Twisted event loop.
  _removeAll(self, readers, writers)
Remove all readers and writers, and return list of Selectables.
    Inherited from ReactorBase
  _cancelCallLater(self, tple)
  _cbContinueSystemEvent(self, result, eventType)
  _continueSystemEvent(self, eventType)
  _initThreadPool(self)
  _initThreads(self)
  _insertNewDelayedCalls(self)
  _moveCallLaterSooner(self, tple)
  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.
  disconnectAll(self)
Disconnect every reader, and writer in the system.
  fireSystemEvent(self, eventType)
See twisted.internet.interfaces.IReactorCore.fireSystemEvent.
  getDelayedCalls(self)
Return all the outstanding delayed calls in the system.
  installResolver(self, resolver)
  iterate(self, delay)
See twisted.internet.interfaces.IReactorCore.iterate.
  removeSystemEventTrigger(self, triggerID)
See twisted.internet.interfaces.IReactorCore.removeSystemEventTrigger.
  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 flumotion.twisted.gtk2r...
ClassProvides __provides__ = <zope.interface.declarations.ClassProvide...
NoneType doIterationTimer = None                                                                  
    Inherited from ReactorBase
str __name__ = 'ReactorBase'
ClassProvides __providedBy__ = <zope.interface.declarations.ClassProvi...
NoneType _lock = None                                                                  
int installed = 0                                                                     
BlockingResolver resolver = <twisted.internet.base.BlockingResolver insta...
NoneType threadpool = None                                                                  
int usingThreads = 0                                                                     

Method Details

crash(self)

See twisted.internet.interfaces.IReactorCore.crash.
Overrides:
twisted.internet.base.ReactorBase.crash (inherited documentation)

doIteration(self, delay)

Do one iteration over the readers and writers we know about.
Overrides:
twisted.internet.base.ReactorBase.doIteration (inherited documentation)

simulate(self)

Run simulation loops and reschedule callbacks.

Class Variable Details

__implemented__

Type:
Implements
Value:
<implementedBy flumotion.twisted.gtk2reactor.Gtk2Reactor>              

__provides__

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

doIterationTimer

Type:
NoneType
Value:
None                                                                  

Generated by Epydoc 2.1 on Fri Feb 2 11:44:39 2007 http://epydoc.sf.net