Package Products :: Package ZenUtils :: Module ProcessQueue :: Class _ProcessQueueProtocolDecorator

[frames] | no frames]

Class _ProcessQueueProtocolDecorator

twisted.internet.protocol.BaseProtocol --+        
                                         |        
 twisted.internet.protocol.ProcessProtocol --+    
                                             |    
                         _ProcessQueueProtocol --+
                                                 |
                                                _ProcessQueueProtocolDecorator

For interal use by ProcessQueue Wraps an existing ProcessProtocol so that it can be run in a ProcessQueue

Instance Methods

__init__(self, protocol, executable, args=(), env={}, path=None, uid=None, gid=None, usePTY=0, childFDs=None, timeout=60, timeout_callback=None)

source code

outReceived(self, data)
Some data was received from stdout.

source code

errReceived(self, data)
Some data was received from stderr.

source code

inConnectionLost(self)
This will be called when stdin is closed.

source code

outConnectionLost(self)
This will be called when stdout is closed.

source code

errConnectionLost(self)
This will be called when stderr is closed.

source code

processEnded(self, reason)
This will be called when the subprocess is finished.

source code

Inherited from _ProcessQueueProtocol: __str__, start

Inherited from _ProcessQueueProtocol (private): _timedOut

Inherited from twisted.internet.protocol.ProcessProtocol: childConnectionLost, childDataReceived, processExited

Inherited from twisted.internet.protocol.BaseProtocol: connectionMade, makeConnection

Class Variables

Inherited from twisted.internet.protocol.BaseProtocol: connected, transport

Method Details

init(self, protocol, executable, args=(), env={}, path=None, uid=None, gid=None, usePTY=0, childFDs=None, timeout=60, timeout_callback=None)
(Constructor)

Overrides: _ProcessQueueProtocol.__init__

outReceived(self, data)

Some data was received from stdout.

Overrides: twisted.internet.protocol.ProcessProtocol.outReceived

errReceived(self, data)

Some data was received from stderr.

Overrides: twisted.internet.protocol.ProcessProtocol.errReceived

inConnectionLost(self)

This will be called when stdin is closed.

Overrides: twisted.internet.protocol.ProcessProtocol.inConnectionLost

outConnectionLost(self)

This will be called when stdout is closed.

Overrides: twisted.internet.protocol.ProcessProtocol.outConnectionLost

errConnectionLost(self)

This will be called when stderr is closed.

Overrides: twisted.internet.protocol.ProcessProtocol.errConnectionLost

processEnded(self, reason)

This will be called when the subprocess is finished.

Parameters:

reason (twisted.python.failure.Failure)

Overrides: twisted.internet.protocol.ProcessProtocol.processEnded