File: //usr/lib/python3/dist-packages/twisted/trial/_dist/__pycache__/workertrial.cpython-38.pyc
U
W[+ � @ s� d Z ddlZddlZddlZdd� Zeej� ddlmZ ddlm Z m
Z
ddl m Z ddl
mZmZ G d d
� d
e�Zejfd d �Zed
kr�e� dS )zj
Implementation of C{AMP} worker commands, and main executable entry point for
the workers.
@since: 12.3
� Nc C s& d| kr"| d � tj�tjdd�< dS )z�
Override C{sys.path} with what the parent passed in B{TRIAL_PYTHONPATH}.
@see: twisted.trial._dist.disttrial.DistTrialRunner.launchWorkerProcesses
ZTRIAL_PYTHONPATHN)�split�os�pathsep�sys�path)�environ� r �A/usr/lib/python3/dist-packages/twisted/trial/_dist/workertrial.py�
_setupPath s r
)� FileWrapper)�startLoggingWithObserver�textFromEventDict)�
WorkerOptions)�_WORKER_AMP_STDIN�_WORKER_AMP_STDOUTc @ s e Zd ZdZdd� Zdd� ZdS )�WorkerLogObserverzF
A log observer that forward its output to a C{AMP} protocol.
c C s
|| _ dS )zg
@param protocol: a connected C{AMP} protocol instance.
@type protocol: C{AMP}
N)�protocol)�selfr r r r �__init__, s zWorkerLogObserver.__init__c C s6 ddl m} t|�}|dkr dS | jj|j|d� dS )z'
Produce a log output.
r )�managercommandsN)�out)�twisted.trial._distr r
r Z
callRemoteZ TestWrite)r Z eventDictr �textr r r �emit4 s
zWorkerLogObserver.emitN)�__name__�
__module__� __qualname__�__doc__r r r r r r r ' s r c
C s& t � }|�� ddlm} ||d �}| td�}| td�}|�t|�� t|�}t |j
d� z|� d�}W nP t k
r� } z2|j
d tjkr�tjdk r�t�� W Y �
q\n� W 5 d }~X Y nX |d
kr�q�q\|�|� |�� tj�� tj�� q\|j�r"t�d � |j�� } | jd d|�� j d � d S )
z�
Main function to be run if __name__ == "__main__".
@param _fdopen: If specified, the function to use in place of C{os.fdopen}.
@param _fdopen: C{callable}
r )�WorkerProtocolzforce-gc�rb�wbF� )� r N� T)Z show_missingZsummary�coverdir) r Z parseOptionsZtwisted.trial._dist.workerr r r ZmakeConnectionr r r r �read�IOError�args�errnoZEINTRr � version_infoZ exc_clearZ dataReceived�flush�stdout�stderrZtracer�settrace�resultsZ
write_resultsr$ r )
Z_fdopenZconfigr ZworkerProtocolZ
protocolInZ protocolOutZobserver�r�er. r r r �main@ s:
�r1 �__main__)r r r r( r
r Ztwisted.internet.protocolr Ztwisted.python.logr r
Ztwisted.trial._dist.optionsr r r r �objectr �fdopenr1 r r r r r �<module> s
.