Package twisted :: Package internet :: Module win32eventreactor :: Class Win32Reactor
[frames | no frames]

Class Win32Reactor

 ReactorBase --+    
               |    
PosixReactorBase --+
                   |
                  Win32Reactor


Reactor that uses Win32 event APIs.
Method Summary
  _makeSocketEvent(self, fd, action, why, events)
Make a win32 event object for a socket.
  _runAction(self, action, fd)
  _runWrite(self, fd)
  addEvent(self, event, fd, action, events)
Add a new win32 event to the event loop.
  addReader(self, reader, reads)
Add a socket FileDescriptor for notification of data available to read.
  addWriter(self, writer, writes)
Add a socket FileDescriptor for notification of data available to write.
  doIteration(self, timeout, reads, writes)
  doWaitForMultipleEvents(self, timeout, reads, writes)
  removeAll(self)
Remove all selectables, and return a list of them.
  removeEvent(self, event)
Remove an event.
  removeReader(self, reader)
Remove a Selectable for notification of data available to read.
  removeWriter(self, writer, writes)
Remove a Selectable for notification of data available to write.
  spawnProcess(self, processProtocol, executable, args, env, path, usePTY)
Spawn a process.
    Inherited from PosixReactorBase
  __init__(self)
  _handleSigchld(self, signum, frame)
Reap all processes on SIGCHLD.
  _handleSignals(self)
Install the signal handlers for the Twisted event loop.
  connectMulticast(self, remotehost, remoteport, protocol, localport, interface, maxPacketSize)
Connects a ConnectedDatagramProtocol instance to a UDP port.
  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)
  connectUNIXDatagram(self, address, protocol, maxPacketSize, mode, bindAddress)
Connects a ConnectedDatagramProtocol instance to a path.
  connectWith(self, connectorType, *args, **kw)
  installWaker(self)
Install a `waker' to allow other threads to wake up the IO thread.
  listenMulticast(self, port, protocol, interface, maxPacketSize)
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)
  listenUNIXDatagram(self, address, protocol, maxPacketSize, mode)
Connects a given DatagramProtocol to the given path.
  listenWith(self, portType, *args, **kw)
  mainLoop(self)
  run(self, installSignalHandlers)
  startRunning(self, installSignalHandlers)
    Inherited from ReactorBase
  _cbContinueSystemEvent(self, result, eventType)
  _continueSystemEvent(self, eventType)
  _initThreadPool(self)
  _internalResolve(self, name, timeout)
  _resetCallLater(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.
  clientSSL(self, host, port, protocol, contextFactory, timeout)
Deprecated - use connectSSL instead.
  clientTCP(self, host, port, protocol, timeout)
Deprecated - use connectTCP instead.
  clientUNIX(self, address, protocol, timeout)
Deprecated - use connectUNIX instead.
  crash(self)
See twisted.internet.interfaces.IReactorCore.crash.
  disconnectAll(self)
Disconnect every reader, and writer in the system.
  fireSystemEvent(self, eventType)
See twisted.internet.interfaces.IReactorCore.fireSystemEvent.
  getDelayedCalls(self)
  initThreads(self)
  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.

Class Variable Summary
tuple __implements__ = (((<class twisted.internet.interfaces.I...
NoneType dummyEvent = None                                                                  
    Inherited from ReactorBase
str __name__ = 'ReactorBase'
NoneType _lock = None                                                                  
int installed = 0                                                                     
NoneType threadCallQueue = None                                                                  
NoneType threadpool = None                                                                  

Method Details

_makeSocketEvent(self, fd, action, why, events={})

Make a win32 event object for a socket.

addEvent(self, event, fd, action, events={})

Add a new win32 event to the event loop.

addReader(self, reader, reads={})

Add a socket FileDescriptor for notification of data available to read.
Overrides:
twisted.internet.base.ReactorBase.addReader

addWriter(self, writer, writes={})

Add a socket FileDescriptor for notification of data available to write.
Overrides:
twisted.internet.base.ReactorBase.addWriter

removeAll(self)

Remove all selectables, and return a list of them.
Overrides:
twisted.internet.base.ReactorBase.removeAll

removeEvent(self, event)

Remove an event.

removeReader(self, reader)

Remove a Selectable for notification of data available to read.
Overrides:
twisted.internet.base.ReactorBase.removeReader

removeWriter(self, writer, writes={})

Remove a Selectable for notification of data available to write.
Overrides:
twisted.internet.base.ReactorBase.removeWriter

spawnProcess(self, processProtocol, executable, args=(), env={}, path=None, usePTY=0)

Spawn a process.
Overrides:
twisted.internet.default.PosixReactorBase.spawnProcess

Class Variable Details

__implements__

Type:
tuple
Value:
(((<class twisted.internet.interfaces.IReactorCore at 0x82821fc>,
   <class twisted.internet.interfaces.IReactorTime at 0x825a2e4>,
   <class twisted.internet.interfaces.IReactorThreads at 0x82536a4>,
   <class twisted.internet.interfaces.IReactorPluggableResolver at 0x8\
282134>),
  <class twisted.internet.interfaces.IReactorArbitrary at 0x8252524>,
  <class twisted.internet.interfaces.IReactorTCP at 0x8252554>,
  <class twisted.internet.interfaces.IReactorUDP at 0x82892ec>,
...                                                                    

dummyEvent

Type:
NoneType
Value:
None                                                                  

Generated by Epydoc 2.0 on Wed Feb 25 07:37:56 2004 http://epydoc.sf.net