Package twisted :: Package internet :: Module posixbase :: Class PosixReactorBase
[show private | hide private]
[frames | no frames]

Class PosixReactorBase

ReactorBase --+
              |
             PosixReactorBase


A basis for reactors that use file descriptors.
Method Summary
  __init__(self)
  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)
  run(self, installSignalHandlers)
  spawnProcess(self, processProtocol, executable, args, env, path, uid, gid, usePTY, childFDs)
  startRunning(self, installSignalHandlers)

Class Variable Summary
Implements __implemented__ = <implementedBy twisted.internet.posixb...
_implementsTuple __implements__ = (<MetaInterface twisted.internet.interf...
ClassProvides __provides__ = <zope.interface.declarations.ClassProvide...

Method Details

connectSSL(self, host, port, factory, contextFactory, timeout=30, bindAddress=None)

See Also: twisted.internet.interfaces.IReactorSSL.connectSSL

connectTCP(self, host, port, factory, timeout=30, bindAddress=None)

See Also: twisted.internet.interfaces.IReactorTCP.connectTCP

connectUDP(self, remotehost, remoteport, protocol, localport=0, interface='', maxPacketSize=8192)

Connects a ConnectedDatagramProtocol instance to a UDP port.

EXPERIMENTAL.

connectUNIX(self, address, factory, timeout=30, checkPID=0)

See Also: twisted.internet.interfaces.IReactorUNIX.connectUNIX

connectUNIXDatagram(self, remotehost, remoteport, protocol, localport=0, interface='', maxPacketSize=8192)

Connects a ConnectedDatagramProtocol instance to a UDP port.

EXPERIMENTAL.

installWaker(self)

Install a `waker' to allow threads and signals to wake up the IO thread.

We use the self-pipe trick (http://cr.yp.to/docs/selfpipe.html) to wake the reactor. On Windows we use a pair of sockets.
Overrides:
twisted.internet.base.ReactorBase.installWaker

listenMulticast(self, port, protocol, interface='', maxPacketSize=8192, listenMultiple=False)

Connects a given DatagramProtocol to the given numeric UDP port.

EXPERIMENTAL.
Returns:
object conforming to IListeningPort.

listenSSL(self, port, factory, contextFactory, backlog=5, interface='')

See Also: twisted.internet.interfaces.IReactorSSL.listenSSL

listenTCP(self, port, factory, backlog=50, interface='')

See Also: twisted.internet.interfaces.IReactorTCP.listenTCP

listenUDP(self, port, protocol, interface='', maxPacketSize=8192)

Connects a given DatagramProtocol to the given numeric UDP port.

EXPERIMENTAL.
Returns:
object conforming to IListeningPort.

listenUNIX(self, address, factory, backlog=5, mode=438, wantPID=0)

See Also: twisted.internet.interfaces.IReactorUNIX.listenUNIX

listenUNIXDatagram(self, port, protocol, interface='', maxPacketSize=8192)

Connects a given DatagramProtocol to the given numeric UDP port.

EXPERIMENTAL.
Returns:
object conforming to IListeningPort.

Class Variable Details

__implemented__

Type:
Implements
Value:
<implementedBy twisted.internet.posixbase.PosixReactorBase>            

__implements__

Type:
_implementsTuple
Value:
(<MetaInterface twisted.internet.interfaces.IReactorArbitrary>, <MetaI\
nterface twisted.internet.interfaces.IReactorTCP>, <MetaInterface twis\
ted.internet.interfaces.IReactorUDP>, <MetaInterface twisted.internet.\
interfaces.IReactorMulticast>, <MetaInterface twisted.internet.interfa\
ces.IReactorSSL>, <MetaInterface twisted.internet.interfaces.IReactorU\
NIX>, <MetaInterface twisted.internet.interfaces.IReactorUNIXDatagram>\
, <MetaInterface twisted.internet.interfaces.IReactorProcess>, <MetaIn\
terface twisted.internet.interfaces.IReactorCore>, <MetaInterface twis\
...                                                                    

__provides__

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

Generated by Epydoc 2.1 on Tue Aug 2 15:16:41 2005 http://epydoc.sf.net