o

�
b�
�@s�dZd
dl
Z
d
dlZd
dlZdd�Zeej�

d
dlmZ
d
dlm	Z	m
Z

d
dlmZm
Z

d
dlmZ
Gd	d
�d
�Zejf
dd�
Zed
krJe�
dSdS)zj
Implementation of C{AMP} worker commands, and main executable entry point for
the workers.

@since: 12.3
�Nc

Cs*d
|vr|d
�t
j�
tjdd�<dSdS)z�
    Override C{sys.path} with what the parent passed in B{TRIAL_PYTHONPATH}.

    @see: twisted.trial._dist.disttrial.DistTrialRunner.launchWorkerProcesses
    �TRIAL_PYTHONPATHN)�split�os�pathsep�sys�path)
�environ�r	�A/usr/lib/python3/dist-packages/twisted/trial/_dist/workertrial.py�
_setupPaths
�r)
�FileWrapper)�startLoggingWithObserver�textFromEventDict)�_WORKER_AMP_STDIN�_WORKER_AMP_STDOUT)
�
WorkerOptionsc@s eZ
dZd
Zdd�Zdd�ZdS)�WorkerLogObserverzF
    A log observer that forward its output to a C{AMP} protocol.
    cCs
|
|_d
S)zg
        @param protocol: a connected C{AMP} protocol instance.
        @type protocol: C{AMP}
        N)
�protocol)�selfrr	r	r
�__init__*s
zWorkerLogObserver.__init__cCs6d
dlm
}
t|
�
}|durdS|jj|j|d�
dS)z'
        Produce a log output.
        r
)
�managercommandsN)
�out)�twisted.trial._distrrr�
callRemote�	TestWrite)r�	eventDictr�textr	r	r
�emit1s



zWorkerLogObserver.emitN)�__name__�
__module__�__qualname__�__doc__rrr	r	r	r
r%s
rc


Cs
t�}
|
�
�
d
dlm}
||
d�
}|td�}|td�}|�t|�
�

t|�
}t	|j
d�
	z|�d�
}WntyQ
}
z|j
d
tjkrLWYd	}~q.�d	}~w
w|d
krWn|�|�

|��
tj��
tj��
q/|
jr�t�d	�

|
j��}	|	jdd|
��jd�
d	Sd	S)z�
    Main function to be run if __name__ == "__main__".

    @param _fdopen: If specified, the function to use in place of C{os.fdopen}.
    @type _fdopen: C{callable}
    r
)
�WorkerProtocolzforce-gc�rb�wbFT�
N�)�show_missing�summary�coverdir)r�parseOptions�twisted.trial._dist.workerr"rr�makeConnectionrrr
r�read�OSError�args�errno�EINTR�dataReceived�flushr�stdout�stderr�tracer�settrace�results�
write_resultsr)r)
�_fdopen�configr"�workerProtocol�
protocolIn�protocolOut�observer�
r�
er8r	r	r
�main=s@










��






�






��rB�__main__)r!r0rrrr�twisted.internet.protocolr�twisted.python.logr
rrrr�twisted.trial._dist.optionsrr�fdopenrBrr	r	r	r
�<module>
s






-

�