§
    Ètºfz	  ã                   ó¬   — d Z ddlZddlZddlZddlmZ ddlmZmZ ddl	m
Z
mZ ddlmZ  G d„ d¦  «        Zej        fd	„Zed
k    r e¦   «          dS dS )zj
Implementation of C{AMP} worker commands, and main executable entry point for
the workers.

@since: 12.3
é    N)ÚFileWrapper)ÚstartLoggingWithObserverÚtextFromEventDict)Ú_WORKER_AMP_STDINÚ_WORKER_AMP_STDOUT)ÚWorkerOptionsc                   ó   — e Zd ZdZd„ Zd„ ZdS )ÚWorkerLogObserverzF
    A log observer that forward its output to a C{AMP} protocol.
    c                 ó   — || _         dS )zg
        @param protocol: a connected C{AMP} protocol instance.
        @type protocol: C{AMP}
        N)Úprotocol)Úselfr   s     ú^/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/trial/_dist/workertrial.pyÚ__init__zWorkerLogObserver.__init__   s   € ð
 !ˆŒˆˆó    c                 óz   — ddl m} t          |¦  «        }|€dS | j                             |j        |¬¦  «         dS )z'
        Produce a log output.
        r   )ÚmanagercommandsN)Úout)Útwisted.trial._distr   r   r   Ú
callRemoteÚ	TestWrite)r   Ú	eventDictr   Útexts       r   ÚemitzWorkerLogObserver.emit#   sQ   € ð 	8Ð7Ð7Ð7Ð7Ð7å  Ñ+Ô+ˆØˆ<ØˆFØŒ× Ò  Ô!:ÀÐ ÑEÔEÐEÐEÐEr   N)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   © r   r   r
   r
      sA   € € € € € ðð ð!ð !ð !ð	Fð 	Fð 	Fð 	Fð 	Fr   r
   c                 ó‚  — t          ¦   «         }|                     ¦   «          ddlm}  ||d         ¦  «        } | t          d¦  «        } | t
          d¦  «        }|                     t          |¦  «        ¦  «         t          |¦  «        }t          |j
        d¦  «         	 	 |                     d¦  «        }n3# t          $ r&}|j        d         t          j        k    rY d	}~ŒB‚ d	}~ww xY w|d
k    rnf|                     |¦  «         |                     ¦   «          t$          j                             ¦   «          t$          j                             ¦   «          Œ·|j        r^t%          j        d	¦  «         |j                             ¦   «         }	|	                     dd|                     ¦   «         j        ¬¦  «         d	S 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}.
    @type _fdopen: C{callable}
    r   )ÚWorkerProtocolzforce-gcÚrbÚwbFTé   Nr   )Úshow_missingÚsummaryÚcoverdir)r   ÚparseOptionsÚtwisted.trial._dist.workerr    r   r   ÚmakeConnectionr   r
   r   r   ÚreadÚOSErrorÚargsÚerrnoÚEINTRÚdataReceivedÚflushÚsysÚstdoutÚstderrÚtracerÚsettraceÚresultsÚwrite_resultsr&   Úpath)
Ú_fdopenÚconfigr    ÚworkerProtocolÚ
protocolInÚprotocolOutÚobserverÚrÚer6   s
             r   ÚmainrA   /   sÖ  € õ ‰_Œ_€FØ
×ÒÑÔÐà9Ð9Ð9Ð9Ð9Ð9à#�^ F¨:Ô$6Ñ7Ô7€Nà�Õ*¨DÑ1Ô1€JØ�'Õ,¨dÑ3Ô3€KØ×!Ò!¥+¨kÑ":Ô":Ñ;Ô;Ð;å  Ñ0Ô0€HÝ˜Xœ]¨EÑ2Ô2Ð2ðð	Ø—’ Ñ"Ô"ˆAˆAøÝð 	ð 	ð 	ØŒv�aŒy�EœKÒ'Ð'Ø����àøøøøð		øøøð
 �Š8ˆ8Øà×'Ò'¨Ñ*Ô*Ð*Ø×ÒÑÔÐÝŒJ×ÒÑÔÐÝŒJ×ÒÑÔÐðð  „}ð 
ÝŒ�TÑÔÐØ”-×'Ò'Ñ)Ô)ˆØ×ÒØ u°v·²Ñ7HÔ7HÔ7Mð 	ñ 	
ô 	
ð 	
ð 	
ð 	
ð
ð 
s   Â$B: Â:
C*ÃC%Ã$C%Ã%C*Ú__main__)r   r-   Úosr1   Útwisted.internet.protocolr   Útwisted.python.logr   r   r   r   r   Útwisted.trial._dist.optionsr   r
   ÚfdopenrA   r   r   r   r   ú<module>rH      sð   ððð ð €€€Ø 	€	€	€	Ø 
€
€
€
à 1Ð 1Ð 1Ð 1Ð 1Ð 1Ø JÐ JÐ JÐ JÐ JÐ JÐ JÐ JØ EÐ EÐ EÐ EÐ EÐ EÐ EÐ EØ 5Ð 5Ð 5Ð 5Ð 5Ð 5ðFð Fð Fð Fð Fñ Fô Fð Fð0 ”ð *
ð *
ð *
ð *
ðZ ˆzÒÐØ€D�F„F€F€F€Fð Ðr   