twisted.trial._dist.worker.LocalWorker

class documentation

class LocalWorker(ProcessProtocol): (source)

View In Hierarchy

Local process worker protocol. This worker runs as a local process and communicates via stdin/out.
Method __init__ Undocumented
Method child​Data​Received Handle data received on the specific pipe for the _ampProtocol.
Method connection​Lost On connection lost, close the log files that we're managing for stdin and stdout.
Method connection​Made When connection is made, create the AMP protocol instance.
Method err​Received Write error data to log.
Method out​Received Send data received from stdout to log.
Method process​Ended When the process closes, call connectionLost for cleanup purposes and forward the information to the _ampProtocol.
Instance Variable end​Deferred Undocumented
Instance Variable _amp​Protocol The AMP protocol instance used to communicate with the worker.
Instance Variable _err​Log Undocumented
Instance Variable _log​Directory The directory where logs will reside.
Instance Variable _log​File The name of the main log file for tests output.
Instance Variable _out​Log Undocumented
Instance Variable _test​Log Undocumented

Inherited from ProcessProtocol:

Method child​Connection​Lost Called when a file descriptor associated with the child process is closed.
Method err​Connection​Lost This will be called when stderr is closed.
Method in​Connection​Lost This will be called when stdin is closed.
Method out​Connection​Lost This will be called when stdout is closed.
Method process​Exited This will be called when the subprocess exits.

Inherited from BaseProtocol (via ProcessProtocol):

Method make​Connection Make a connection to a transport and a server.
Instance Variable connected Undocumented
Instance Variable transport Undocumented
def __init__(self, ampProtocol, logDirectory, logFile): (source)

Undocumented

def childDataReceived(self, childFD, data): (source)
from twisted.internet.interfaces.IProcessProtocol
overrides twisted.internet.protocol.ProcessProtocol.childDataReceived
Handle data received on the specific pipe for the _ampProtocol.
def connectionLost(self, reason): (source)
On connection lost, close the log files that we're managing for stdin and stdout.
def connectionMade(self): (source)
overrides twisted.internet.protocol.BaseProtocol.connectionMade
When connection is made, create the AMP protocol instance.
def errReceived(self, data): (source)
overrides twisted.internet.protocol.ProcessProtocol.errReceived
Write error data to log.
def outReceived(self, data): (source)
overrides twisted.internet.protocol.ProcessProtocol.outReceived
Send data received from stdout to log.
def processEnded(self, reason): (source)
from twisted.internet.interfaces.IProcessProtocol
overrides twisted.internet.protocol.ProcessProtocol.processEnded
When the process closes, call connectionLost for cleanup purposes and forward the information to the _ampProtocol.
endDeferred = (source)

Undocumented

_ampProtocol = (source)
The AMP protocol instance used to communicate with the worker.
_errLog = (source)

Undocumented

_logDirectory = (source)
The directory where logs will reside.
_logFile = (source)
The name of the main log file for tests output.
_outLog = (source)

Undocumented

_testLog = (source)

Undocumented