Package Products :: Package ZenUtils :: Module ProcessQueue :: Class _ProcessQueueProtocolDecorator |
[hide private]
[frames] | no frames]

# Class _ProcessQueueProtocolDecorator

source code

    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 | [hide private]
__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` Inherited from `twisted.internet.protocol.BaseProtocol`: `connectionMade`, `makeConnection`

Class Variables | [hide private]
Inherited from `twisted.internet.protocol.BaseProtocol`: `connected`, `transport`

Method Details | [hide private]

### __init__(self, protocol, executable, args=(), env={}, path=None, uid=None, gid=None, usePTY=0, childFDs=None, timeout=60, timeout_callback=None) (Constructor) | source code
Overrides: _ProcessQueueProtocol.__init__

### outReceived(self, data) | source code
Some data was received from stdout. Overrides: twisted.internet.protocol.ProcessProtocol.outReceived

### errReceived(self, data) | source code
Some data was received from stderr. Overrides: twisted.internet.protocol.ProcessProtocol.errReceived

### inConnectionLost(self) | source code
This will be called when stdin is closed. Overrides: twisted.internet.protocol.ProcessProtocol.inConnectionLost

### outConnectionLost(self) | source code
This will be called when stdout is closed. Overrides: twisted.internet.protocol.ProcessProtocol.outConnectionLost

### errConnectionLost(self) | source code
This will be called when stderr is closed. Overrides: twisted.internet.protocol.ProcessProtocol.errConnectionLost

### processEnded(self, reason) | source code
This will be called when the subprocess is finished. Parameters: `reason` (`twisted.python.failure.Failure`) Overrides: twisted.internet.protocol.ProcessProtocol.processEnded