ó
    ×›‘hz	  ã                   ó¨   • S r SSKrSSKrSSKrSSKJr  SSKJrJr  SSK	J
r
Jr  SSKJr   " S S5      r\R                  4S	 jr\S
:X  a  \" 5         gg)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                   ó$   • \ rS rSrSrS rS rSrg)ÚWorkerLogObserveré   z>
A log observer that forward its output to a C{AMP} protocol.
c                 ó   • Xl         g)zO
@param protocol: a connected C{AMP} protocol instance.
@type protocol: C{AMP}
N©Úprotocol)Úselfr   s     ÚcC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/trial/_dist/workertrial.pyÚ__init__ÚWorkerLogObserver.__init__   s	   € ð
 !�ó    c                 óv   • SSK Jn  [        U5      nUc  gU R                  R	                  UR
                  US9  g)z
Produce a log output.
r   )ÚmanagercommandsN)Úout)Útwisted.trial._distr   r   r   Ú
callRemoteÚ	TestWrite)r   Ú	eventDictr   Útexts       r   ÚemitÚWorkerLogObserver.emit#   s6   € õ 	8ä  Ó+ˆØ‰<ØØ�‰× Ñ  ×!:Ñ!:ÀÐ ÒEr   r   N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r   r   Ú__static_attributes__© r   r   r
   r
      s   † ñò!õ	Fr   r
   c                 óB  • [        5       nUR                  5         SSKJn  U" US   5      nU " [        S5      nU " [
        S5      nUR                  [        U5      5        [        U5      n[        UR                  S5          UR                  S5      nUS
:X  a  O_UR!                  U5        UR#                  5         [$        R&                  R#                  5         [$        R(                  R#                  5         Mx  UR*                  (       aZ  [$        R,                  " S	5        UR*                  R/                  5       n	U	R1                  SSUR3                  5       R4                  S9  g	g	! [         a.  nUR                  S   [        R                  :X  a   S	nAGM  e S	nAff = f)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Úer<   s
             r   ÚmainrG   /   sN  € ô ‹_€FØ
×ÑÔå9á# F¨:Ñ$6Ó7€NáÔ*¨DÓ1€JÙÔ,¨dÓ3€KØ×!Ñ!¤+¨kÓ":Ô;ä  Ó0€HÜ˜XŸ]™]¨EÔ2à
ð	Ø—‘ Ó"ˆAð �‹8Øà×'Ñ'¨Ô*Ø×ÑÔÜ�J‰J×ÑÔÜ�J‰J×ÑÔñ ð  ‡}‡}Ü�Š�TÔØ—-‘-×'Ñ'Ó)ˆØ×ÑØ u°v·±Ó7H×7MÑ7Mð 	ò 	
ð øô ó 	Ø�v‰v�a‰yœEŸK™KÓ'Þàûð		ús   ÂE& Å&
FÅ0!FÆFÆFÚ__main__)r"   r3   Úosr7   Útwisted.internet.protocolr   Útwisted.python.logr   r   r   r   r   Útwisted.trial._dist.optionsr   r
   ÚfdopenrG   r   r$   r   r   Ú<module>rN      sP   ðñó Û 	Û 
å 1ß Jß EÝ 5÷Fñ Fð0 —‘ô *
ðZ ˆzÓÙ…Fð r   