ó
    Ö›‘h´  ã                   ó–  • S r SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ	r	  SSK
r
SSKJr  SSKJrJrJr  SSKJrJr  SSKJrJr  SSKJr  SS	KJ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K%J&r&  SSK'J(r(J)r)  \" \RT                  5      RW                  5       r,Sr-Sr.\/" \R`                  5      r1\Rd                  Rg                  \Rh                  5      \1S'    SSKJ5r6  \Rn                  " 5       S:w  a  Sr-Sr.\6r5SSK8J9r9  S\;4S jr<S r= " S S\5      r> " S S\5      r? " S S \?5      r@\A" 5       R…                  \@R‡                  5       5         " S! S"\?5      rD\A" 5       R…                  \DR‡                  5       5         " S# S$\)5      rE " S% S&\)5      rF " S' S(\)5      rGS)rHS*rI\= " S+ S,\(5      5       rJg! \: a	    Sr5Sr-Sr. NÂf = f)-z»
Tests for implementations of L{IReactorProcess}.

@var properEnv: A copy of L{os.environ} which has L{bytes} keys/values on POSIX
    platforms and native L{str} keys/values on Windows.
é    N)ÚskipIf)Úutils)ÚDeferredÚinlineCallbacksÚsucceed)ÚProcessDoneÚProcessTerminated)ÚIProcessTransportÚIReactorProcess)ÚProcessProtocol)ÚReactorBuilder)ÚnetworkString)ÚFilePathÚ_asFilesystemBytes)ÚerrÚmsg)Úplatform)ÚAccumulator)ÚSynchronousTestCaseÚTestCaseFÚ Ú
PYTHONPATH©ÚprocessTz$Cannot change UID/GID except as root)Ú_getFileActionsz Cannot change UID/GID on WindowsÚreturnc                  óÀ   • SSK Jn Jn  U" U 5      S   [        R                  " S5      /n[
        R                  " 5       (       a  UR                  S5        [        U5      $ )Nr   )ÚRLIMIT_NOFILEÚ	getrlimitÚSC_OPEN_MAXi (  )	Úresourcer   r   ÚosÚsysconfr   ÚisMacOSXÚappendÚmin)r   r   ÚpotentialLimitss      ÚfC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/test/test_process.pyÚ_getRealMaxOpenFilesr)   :   sL   € ß1á  Ó/°Ñ2´B·J²J¸}Ó4MÐN€OÜ×Ò×Ñð 	×Ñ˜vÔ&ÜˆÓÐó    c                 ó<   • [         R                  S:w  a  SU l        U $ )z„
Only run this test on POSIX platforms.

@param testMethod: A test function, being decorated.

@return: the C{testMethod} argument.
Úposixú%Test only applies to POSIX platforms.)r"   ÚnameÚskip)Ú
testMethods    r(   ÚonlyOnPOSIXr1   K   s   € ô 
‡w�w�'ÓØAˆ
ŒØÐr*   c                   ó*   • \ rS rSrSrS rS rS rSrg)Ú _ShutdownCallbackProcessProtocoléX   zá
An L{IProcessProtocol} which fires a Deferred when the process it is
associated with ends.

@ivar received: A C{dict} mapping file descriptors to lists of bytes
    received from the child process on those file descriptors.
c                 ó   • Xl         0 U l        g ©N)ÚwhenFinishedÚreceived)Úselfr7   s     r(   Ú__init__Ú)_ShutdownCallbackProcessProtocol.__init__a   s   € Ø(ÔØˆ�r*   c                 óZ   • U R                   R                  U/ 5      R                  U5        g r6   )r8   Ú
setdefaultr%   )r9   ÚfdÚbytess      r(   ÚchildDataReceivedÚ2_ShutdownCallbackProcessProtocol.childDataReceivede   s!   € Ø�‰× Ñ   RÓ(×/Ñ/°Õ6r*   c                 ó:   • U R                   R                  S 5        g r6   )r7   Úcallback©r9   Úreasons     r(   ÚprocessEndedÚ-_ShutdownCallbackProcessProtocol.processEndedh   s   € Ø×Ñ×"Ñ" 4Õ(r*   )r8   r7   N)	Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r:   r@   rF   Ú__static_attributes__© r*   r(   r3   r3   X   s   † ñòò7õ)r*   r3   c                   ó&  • \ rS rSr% Sr\/r\\S'   S r	S r
S rS rS rS	 r\" \" \S
S5      SL S5      S 5       rS rS r\" \R,                  " 5       S5      S 5       r\S 5       rS rS r\" \\5      S 5       r\" \\5      S 5       rS r Sr!g)ÚProcessTestsBuilderBaseél   zÒ
Base class for L{IReactorProcess} tests which defines some tests which
can be applied to PTY or non-PTY uses of C{spawnProcess}.

Subclasses are expected to set the C{usePTY} attribute to C{True} or
C{False}.
ÚusePTYc                 ó4  ^• [        5       n[        U5      nU R                  5       mTR                  U[        [        SS/U R
                  S9nU R                  [        R                  " U5      5        UR                  U4S j5        U R                  T5        g)zx
L{IReactorProcess.spawnProcess} connects the protocol passed to it
to a transport which provides L{IProcessTransport}.
ó   -cr*   ©rR   c                 ó$   >• TR                  5       $ r6   ©Ústop©ÚignoredÚreactors    €r(   Ú<lambda>ÚHProcessTestsBuilderBase.test_processTransportInterface.<locals>.<lambda>�   ó   ø€ ¨'¯,©,¬.r*   N)r   r3   ÚbuildReactorÚspawnProcessÚpyExerR   Ú
assertTruer
   Ú
providedByÚaddCallbackÚ
runReactor)r9   ÚendedÚprotocolÚ	transportr[   s       @r(   Útest_processTransportInterfaceÚ6ProcessTestsBuilderBase.test_processTransportInterfacex   s„   ø€ ô
 “
ˆÜ3°EÓ:ˆà×#Ñ#Ó%ˆØ×(Ñ(Ø”eœe U¨CÐ0¸¿¹ð )ð 
ˆ	ð 	�‰Ô)×4Ò4°YÓ?Ô@ð 	×ÑÔ8Ô9Ø�‰˜Õ r*   c                 ór  ^^^^^• U R                  5       m[        5       n[        U5      mS[        [        R
                  5      -   mSmUUUUU4S jnTR                  U5        UR                  U4S j5        U R                  T5        U R                  TSR                  TR                  S   5      5        g)a€  
Helper for testing L{IProcessTransport} write functionality.  This
method spawns a child process and gives C{write} a chance to write some
bytes to it.  It then verifies that the bytes were actually written to
it (by relying on the child process to echo them back).

@param write: A two-argument callable.  This is invoked with a process
    transport and some bytes to write to it.
s   hello, worlds2   import sys
sys.stdout.write(sys.stdin.readline())
c                  ó°   >• TR                  T[        [        ST/5      n  T" U T5        g ! [         a     [        S S5        U R	                  S5         g f = f)NrT   z!Unhandled exception while writingÚKILL)r`   ra   ÚBaseExceptionr   ÚsignalProcess)rh   ÚbytesToSendÚprogramrg   r[   Úwrites    €€€€€r(   ÚstartupÚ3ProcessTestsBuilderBase._writeTest.<locals>.startup¤   sU   ø€ Ø×,Ñ,¨X´u¼uÀeÈWÐ>UÓVˆIð0Ù�i Õ-øÜ ó 0Ü�DÐ=Ô>Ø×'Ñ'¨Ö/ð0ús   ¡	+ «'AÁAc                 ó$   >• TR                  5       $ r6   rW   rY   s    €r(   r\   Ú4ProcessTestsBuilderBase._writeTest.<locals>.<lambda>®   r^   r*   r*   é   N)r_   r   r3   r   r"   ÚlinesepÚcallWhenRunningrd   re   ÚassertEqualÚjoinr8   )r9   rr   rf   rs   rp   rq   rg   r[   s    `  @@@@r(   Ú
_writeTestÚ"ProcessTestsBuilderBase._writeTest’   s•   ü€ ð ×#Ñ#Ó%ˆä“
ˆÜ3°EÓ:ˆà%¬´b·j±jÓ(AÑAˆØMˆ÷	0ñ 	0ð 	×Ñ Ô(à×ÑÔ8Ô9à�‰˜Ô Ø×Ñ˜ c§h¡h¨x×/@Ñ/@ÀÑ/CÓ&DÕEr*   c                 ó,   • S nU R                  U5        g)zf
L{IProcessTransport.write} writes the specified C{bytes} to the standard
input of the child process.
c                 ó&   • U R                  U5        g r6   ©rr   ©rh   rp   s     r(   rr   Ú1ProcessTestsBuilderBase.test_write.<locals>.write¹   s   € Ø�O‰O˜KÕ(r*   N©r|   ©r9   rr   s     r(   Ú
test_writeÚ"ProcessTestsBuilderBase.test_write³   s   € ò	)ð 	�‰˜Õr*   c                 ó,   • S nU R                  U5        g)zy
L{IProcessTransport.writeSequence} writes the specified C{list} of
C{bytes} to the standard input of the child process.
c                 ó(   • U R                  U/5        g r6   )ÚwriteSequencer�   s     r(   rr   Ú9ProcessTestsBuilderBase.test_writeSequence.<locals>.writeÄ   s   € Ø×#Ñ# [ MÕ2r*   Nrƒ   r„   s     r(   Útest_writeSequenceÚ*ProcessTestsBuilderBase.test_writeSequence¾   ó   € ò	3ð 	�‰˜Õr*   c                 ó,   • S nU R                  U5        g)zx
L{IProcessTransport.writeToChild} writes the specified C{bytes} to the
specified file descriptor of the child process.
c                 ó(   • U R                  SU5        g )Nr   )ÚwriteToChildr�   s     r(   rr   Ú8ProcessTestsBuilderBase.test_writeToChild.<locals>.writeÏ   s   € Ø×"Ñ" 1 kÕ2r*   Nrƒ   r„   s     r(   Útest_writeToChildÚ)ProcessTestsBuilderBase.test_writeToChildÉ   r�   r*   c                 ó4   ^ • U 4S jnT R                  U5        g)zŽ
L{IProcessTransport.writeToChild} raises L{KeyError} if passed a file
descriptor which is was not set up by L{IReactorProcess.spawnProcess}.
c                 óš   >•  TR                  [        U R                  SU5        U R                  U5        g ! U R                  U5        f = f)Né   )ÚassertRaisesÚKeyErrorr�   rr   )rh   rp   r9   s     €r(   rr   ÚIProcessTestsBuilderBase.test_writeToChildBadFileDescriptor.<locals>.writeÚ   s=   ø€ ð-Ø×!Ñ!¤(¨I×,BÑ,BÀBÈÔTð —‘ Õ,ø�	—‘ Õ,ús	   ƒ"7 ·A
Nrƒ   r„   s   ` r(   Ú"test_writeToChildBadFileDescriptorÚ:ProcessTestsBuilderBase.test_writeToChildBadFileDescriptorÔ   s   ø€ õ	-ð 	�‰˜Õr*   ÚSIGCHLDNz;Platform lacks SIGCHLD, early-spawnProcess test can't work.c                 óp  ^^• U R                  5       mU R                  (       a  SnO0 n[        R                  " 5       mU4S jn[        R                  " [        R
                  U5        [        5       nTR                  [        U5      [        [        SS/U R                  US9  TR                  S5        TR                  5       (       d  U R                  S5        / nUR                  UR                  5        U(       a  gUR                  U4S j5        U R                  T5        U R!                  U5        g)	zº
If, before the reactor is started with L{IReactorCore.run}, a
process is started with L{IReactorProcess.spawnProcess} and
terminates, the process is reaped once the reactor is started.
Nc                  ó&   >• TR                  5         g r6   )Úset)ÚargsÚsignaleds    €r(   ÚhandlerÚGProcessTestsBuilderBase.test_spawnProcessEarlyIsReaped.<locals>.handlerû   s   ø€ Ø�L‰L�Nr*   rT   r*   )rR   ÚchildFDséx   z,Timed out waiting for child process to exit.c                 ó$   >• TR                  5       $ r6   rW   rY   s    €r(   r\   ÚHProcessTestsBuilderBase.test_spawnProcessEarlyIsReaped.<locals>.<lambda>  r^   r*   )r_   rR   Ú	threadingÚEventÚsignalrœ   r   r`   r3   ra   ÚwaitÚisSetÚfailrd   r%   re   rb   )r9   r¤   r¢   rf   Úresultr[   r¡   s        @@r(   Útest_spawnProcessEarlyIsReapedÚ6ProcessTestsBuilderBase.test_spawnProcessEarlyIsReapedã   sü   ù€ ð ×#Ñ#Ó%ˆð �;�;Ø‰HàˆHô —?’?Ó$ˆõ	ô 	�Š”f—n‘n gÔ.ô “
ˆØ×ÑÜ,¨UÓ3ÜÜ�E˜3ÐØ—;‘;Øð 	ñ 	
ð 	�‰�cÔØ�~‰~×ÑØ�I‰IÐDÔEð ˆØ×Ñ˜&Ÿ-™-Ô(æð ð 	×ÑÔ8Ô9Ø�‰˜Ô ð 	�‰˜Õr*   c                 óª  ^ ^^^^• Sm[        [        ST-   5      m[        5       mSn " UU4S jS[        5      nT R	                  5       mTR                  TR                  U" 5       [        [        SU/T R                  S9  U U4S jnTR                  U5        TR                  [        5        TR                  U4S	 j5        T R                  T5        g
)z‘
The C{reason} argument passed to L{IProcessProtocol.processExited} is a
L{ProcessTerminated} instance if the child process exits with a signal.
ÚTERMÚSIGsE   import sys
sys.stdout.write('x')
sys.stdout.flush()
sys.stdin.read()
c                   ó:   >• \ rS rSrU4S jrS rU 4S jrS rSrg)ÚDProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiteri7  c                 óZ   >• [        SX4-  5        U R                  R                  T5        g ©NzchildDataReceived(%d, %r))r   rh   ro   )r9   r>   ÚdataÚsigNames      €r(   r@   ÚVProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.childDataReceived8  s%   ø€ ÜÐ/°2°*Ñ<Ô=Ø—‘×,Ñ,¨WÕ5r*   c                 ó"   • [        SU4-  5        g ©NúchildConnectionLost(%d)©r   )r9   r>   s     r(   ÚchildConnectionLostÚXProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.childConnectionLost<  s   € ÜÐ-°°Ñ5Õ6r*   c                 óJ   >• [        SU< S35        TR                  U/5        g ©NzprocessExited(Ú)©r   rC   ©r9   rE   Úexiteds     €r(   ÚprocessExitedÚRProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.processExited?  s$   ø€ Ü�n V¡J¨aÐ0Ô1ð —‘  Õ)r*   c                 ó$   • [        SU< S35        g ©NzprocessEnded(rÃ   r¾   rD   s     r(   rF   ÚQProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.Exiter.processEndedH  s   € Ü�m F¡:¨QÐ/Õ0r*   rN   N©	rH   rI   rJ   rK   r@   r¿   rÇ   rF   rM   )rÆ   r¹   s   €€r(   ÚExiterrµ   7  s   ø† õ6ò7õ*õ1r*   rÍ   rT   rU   c                 ób  >• U u  nUR                  [        5        UR                  n[        R                  " 5       (       a8  TR                  UR                  5        TR                  UR                  S5        g TR                  UR                  T5        TR                  UR                  5        g )Nrw   )	Útrapr	   Úvaluer   Ú	isWindowsÚassertIsNonerª   rz   ÚexitCode)r    Úfailurer   r9   ÚsigNums      €€r(   ÚcbExitedÚFProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.cbExitedT  s   ø€ Ø‰JˆWð �L‰LÔ*Ô+Ø—-‘-ˆCÜ×!Ò!×#Ñ#ð ×!Ñ! #§*¡*Ô-Ø× Ñ  §¡¨qÕ1à× Ñ  §¡¨VÔ4Ø×!Ñ! #§,¡,Õ/r*   c                 ó$   >• TR                  5       $ r6   rW   ©Úignr[   s    €r(   r\   ÚFProcessTestsBuilderBase.test_processExitedWithSignal.<locals>.<lambda>i  ó   ø€  w§|¡|¤~r*   N)Úgetattrrª   r   r   r_   ry   r`   ra   rR   rd   Ú
addErrbackr   re   )r9   ÚsourcerÍ   rÖ   rÆ   r[   r¹   rÕ   s   `   @@@@r(   Útest_processExitedWithSignalÚ4ProcessTestsBuilderBase.test_processExitedWithSignal#  s¿   ü€ ð
 ˆÜœ ¨¡Ó1ˆÜ“ˆð"ð 	÷	1ð 	1”_ô 	1ð( ×#Ñ#Ó%ˆØ×ÑØ× Ñ Ù‹HÜÜ�E˜6Ð"Ø—;‘;ð 	 ñ 	
ö	0ð& 	×Ñ˜8Ô$Ø×Ñœ#ÔØ×ÑÔ5Ô6à�‰˜Õ r*   c                 óä   ^^• U R                  5       m/ mUU4S jnTR                  U5        U R                  T5        U R                  TS[        R
                  R                  S5      -   /5        g)a�  
If a child process exits while a system call is in progress, the system
call should not be interfered with.  In particular, it should not fail
with EINTR.

Older versions of Twisted installed a SIGCHLD handler on POSIX without
using the feature exposed by the SA_RESTART flag to sigaction(2).  The
most noticeable problem this caused was for blocking reads and writes to
sometimes fail with EINTR.
c                  ó¾  >•  [         R                  [        R                  " 5       5      n [        R
                  " U SS/5        [        R
                  " U SS/[        R                  S9nUR                     TR                  UR                  R                  5       5        S S S 5        TR                  5         g ! , (       d  f       N= f! TR                  5         f = f)Nú-czimport time; time.sleep(0.1)z)import time; time.sleep(0.5);print('Foo'))Ústdout)ra   ÚdecodeÚsysÚgetfilesystemencodingÚ
subprocessÚPopenÚPIPErå   r%   ÚreadrX   )ÚexeÚf2r[   r®   s     €€r(   ÚfÚJProcessTestsBuilderBase.test_systemCallUninterruptedByChildExit.<locals>.f{  s›   ø€ ðÜ—l‘l¤3×#<Ò#<Ó#>Ó?�ä× Ò  # tÐ-KÐ!LÔMÜ×%Ò%Ø˜$Ð!OÐQÜ%Ÿ?™?ñ�ð —Y“YØ—M‘M "§)¡)§.¡.Ó"2Ô3÷ ð —‘•÷ •Yûð —‘•ús$   ƒA3C
 Á6*B9Â C
 Â9
CÃC
 Ã
Cs   FooÚasciiN)r_   ry   re   rz   r"   rx   Úencode)r9   rï   r[   r®   s     @@r(   Ú'test_systemCallUninterruptedByChildExitÚ?ProcessTestsBuilderBase.test_systemCallUninterruptedByChildExitm  s`   ù€ ð ×#Ñ#Ó%ˆØˆö	ð" 	×Ñ Ô"Ø�‰˜Ô Ø×Ñ˜ &¬2¯:©:×+<Ñ+<¸WÓ+EÑ"EÐ!FÕGr*   r-   c           	      ó  ^
^• [        S5      n[        R                  " 5       u  p#U R                  [        R                  U5        U R                  [        R                  U5        Sn[        5       nXT-
  n[        R                  " X65        U R                  [        R                  U5        [        R                  " 5       m
 " U
U4S jS[        5      nU R                  5       mTR                  TR                  U" 5       [        [        SSU/[        U R                  S9  U R!                  T5        [#        [%        T
R'                  5       5      5      n/ SQn	U R)                  UR+                  [#        X–/-   5      5      [#        U	5      5        g	)
zŒ
Processes spawned with spawnProcess() close all extraneous file
descriptors in the parent.  They do have a stdin, stdout, and stderr
open.
zr
import sys
from twisted.internet import process
sys.stdout.write(repr(process._listOpenFDs()))
sys.stdout.flush()é   c                   ó<   >• \ rS rSr Y R                  rU4S jrSrg)ÚKProcessTestsBuilderBase.test_openFileDescriptors.<locals>.GatheringProtocoliÃ  c                 ó&   >• TR                  5         g r6   rW   ©r9   rE   r[   s     €r(   rF   ÚXProcessTestsBuilderBase.test_openFileDescriptors.<locals>.GatheringProtocol.processEndedÆ  s   ø€ Ø—‘•r*   rN   N)rH   rI   rJ   rK   rr   ÚoutReceivedrF   rM   )Úoutputr[   s   €€r(   ÚGatheringProtocolrø   Ã  s   ø† Ù Ÿ,™,ˆK÷ð r*   rþ   s   -WignorerT   ©ÚenvrR   ©r   rw   é   N)r   r"   ÚpipeÚ
addCleanupÚcloser)   Údup2ÚioÚBytesIOr   r_   ry   r`   ra   Ú	properEnvrR   re   rŸ   ÚevalÚgetvaluerz   Úintersection)r9   rß   ÚrÚwÚfudgeFactorÚhardResourceLimitÚ
unlikelyFDrþ   ÚreportedChildFDsÚstdFDsrý   r[   s             @@r(   Útest_openFileDescriptorsÚ0ProcessTestsBuilderBase.test_openFileDescriptors�  s<  ù€ ô ðó
ˆô �wŠw‹y‰ˆØ�‰œŸ™ !Ô$Ø�‰œŸ™ !Ô$ð* ˆÜ0Ó2ÐØ&Ñ4ˆ
ä
�Š�ÔØ�‰œŸ™ *Ô-ä—’“ˆ÷	ð 	¤ô 	ð ×#Ñ#Ó%ˆà×ÑØ× Ñ ÙÓÜÜ�K ¨Ð/ÜØ—;‘;ð 	 ñ 	
ð 	�‰˜Ô Üœt F§O¡OÓ$5Ó6Ó7Ðâˆð
 	×ÑØ×)Ñ)¬#¨f°|Ñ.CÓ*DÓEÄsÈ6Ã{õ	
r*   c                 óž  ^ ^^^• S nT R                  [        SU5        T R                  [        SS 5        T R                  5       mSTl        [
        R                  " 5       mT R                  (       a  SOSmTR                  UUUU 4S j5       nT R                  TS	S
9  T R                  SR                  5       TR                  5       5        g)z†
When L{os.execvpe} raises an exception, it will format that exception
on stderr as UTF-8, regardless of system encoding information.
c                  ó„   • Sn[        U[        5      (       d  UR                  S5      n[        SUS5      n[	        U5        g )Nu   <â˜ƒ>úutf-8z1/0Úsingle)Ú
isinstanceÚstrrò   Úcompiler
  )r    ÚkwÚfilenameÚcodeobjs       r(   ÚexecvpeÚ=ProcessTestsBuilderBase.test_errorDuringExec.<locals>.execvpeç  s9   € ð 'ˆHÜ˜h¬×,Ñ,Ø#Ÿ?™?¨7Ó3�Ü˜e X¨xÓ8ˆGÜ��Mr*   r   rè   c                  ó   • g)Nrñ   rN   rN   r*   r(   r\   Ú>ProcessTestsBuilderBase.test_errorDuringExec.<locals>.<lambda>ñ  s   € ¸r*   Trw   r  c                  ó†   >•  " UUU4S jS[         5      n TR                  U " 5       [        [        SS/TR                  S9  g )Nc                   ó0   >• \ rS rSrU U4S jrU4S jrSrg)Ú[ProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunning.<locals>.TracebackCatcheriÿ  c                 ó6   >• UT:X  a  TR                  U5        g g r6   r€   )r9   Úchildr¸   Ú
expectedFDrý   s      €€r(   r@   ÚmProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunning.<locals>.TracebackCatcher.childDataReceived   s   ø€ Ø 
Ó*ØŸ™ TÕ*ð +r*   c                 ó&   >• TR                  5         g r6   rW   rú   s     €r(   rF   ÚhProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunning.<locals>.TracebackCatcher.processEnded  s   ø€ Ø—L‘L•Nr*   rN   N)rH   rI   rJ   rK   r@   rF   rM   )r)  rý   r[   s   €€€r(   ÚTracebackCatcherr&  ÿ  s   ø† ö+÷#ð #r*   r-  rT   r*   rU   )r   r`   ra   rR   )r-  r)  rý   r[   r9   s    €€€€r(   ÚwhenRunningÚAProcessTestsBuilderBase.test_errorDuringExec.<locals>.whenRunningý  s@   ø€ ÷#ñ #¤?ô #ð × Ñ Ù Ó"¤E¬E°5¸#Ð+>ÀtÇ{Á{ð !ò r*   é   ©Útimeoutu   â˜ƒN)Úpatchr"   rç   r_   Ú_neverUseSpawnr  r  rR   ry   re   ÚassertInrò   r  )r9   r   r.  r)  rý   r[   s   `  @@@r(   Útest_errorDuringExecÚ,ProcessTestsBuilderBase.test_errorDuringExecà  s¥   û€ ò	ð 	�
‰
”2�y 'Ô*Ø�
‰
”3Ð/±ÔAà×#Ñ#Ó%ˆð "&ˆÔÜ—’“ˆð Ÿ+Ÿ+‘Q¨1ˆ
à	×	 Ñ	 ÷	ó 
!ð	ð 	�‰˜¨ˆÑ,Ø�‰�m×*Ñ*Ó,¨f¯o©oÓ.?Õ@r*   c                 ó  ^ ^• T R                  5       m " UU 4S jS[        5      nU" 5       nTR                  TR                  U[        [        SS/T R
                  S9  T R                  TSS9  T R                  UR                  5        g)	zQ
If a spawned process exits, C{processExited} will be called in a
timely manner.
c                   ó(   >• \ rS rSrSrU U4S jrSrg)ÚIProcessTestsBuilderBase.test_timelyProcessExited.<locals>.ExitingProtocoli  Fc                 ó€   >• SU l         TR                  5         TR                  UR                  R                  S5        g )NTr   )rÆ   rX   rz   rÐ   rÓ   )Ú	protoSelfrE   r[   r9   s     €€r(   rÇ   ÚWProcessTestsBuilderBase.test_timelyProcessExited.<locals>.ExitingProtocol.processExited  s.   ø€ Ø#'�	Ô Ø—‘”Ø× Ñ  §¡×!6Ñ!6¸Õ:r*   rN   N)rH   rI   rJ   rK   rÆ   rÇ   rM   )r[   r9   s   €€r(   ÚExitingProtocolr:    s   ø† ØˆF÷;ñ ;r*   r>  rT   s   raise SystemExit(0)rU   r0  r1  N)	r_   r   ry   r`   ra   rR   re   rb   rÆ   )r9   r>  rg   r[   s   `  @r(   Útest_timelyProcessExitedÚ0ProcessTestsBuilderBase.test_timelyProcessExited  s„   ù€ ð
 ×#Ñ#Ó%ˆ÷	;ð 	;œoô 	;ñ #Ó$ˆØ×ÑØ× Ñ ØÜÜ�EÐ1Ð2Ø—;‘;ð 	 ñ 	
ð 	�‰˜¨ˆÑ,Ø�‰˜Ÿ™Õ(r*   c           
      ó\  ^^• SSU S3/n/ m " UU4S jS[         5      nU R                  5       mU" 5       nTR                  " TR                  U[        [        SSR                  U5      /40 US0D6  U R                  T5        U R                  S	TS	   R                  R                  5        g
)a$  
Launch a child process, using either the C{uid} or C{gid} argument to
L{IReactorProcess.spawnProcess} to change either its UID or GID to a
different value.  If the child process reports this hasn't happened,
raise an exception to fail the test.

@param which: Either C{b"uid"} or C{b"gid"}.
z	import oszraise SystemExit(os.getz() != 1)c                   ó$   >• \ rS rSrU U4S jrSrg)Ú@ProcessTestsBuilderBase._changeIDTest.<locals>.CaptureExitStatusi7  c                 óH   >• TR                  U5        TR                  5         g r6   )r%   rX   )r9   rE   Ú	containerr[   s     €€r(   rF   ÚMProcessTestsBuilderBase._changeIDTest.<locals>.CaptureExitStatus.processEnded8  s   ø€ Ø× Ñ  Ô(Ø—‘•r*   rN   N)rH   rI   rJ   rK   rF   rM   )rE  r[   s   €€r(   ÚCaptureExitStatusrC  7  s   ø† ÷ñ r*   rG  rä   Ú
rw   r   N)
r   r_   ry   r`   ra   r{   re   rz   rÐ   rÓ   )r9   Úwhichrq   rG  rg   rE  r[   s        @@r(   Ú_changeIDTestÚ%ProcessTestsBuilderBase._changeIDTest*  s³   ù€ ð Ð"9¸%¸ÀÐ IÐJˆàˆ	÷	ð 	¤ô 	ð
 ×#Ñ#Ó%ˆÙ$Ó&ˆØ×ÒØ× Ñ ØÜÜ�D˜$Ÿ)™) GÓ,Ð-ñ		
ð
 �aˆjò	
ð 	�‰˜Ô à×Ñ˜˜I a™L×.Ñ.×7Ñ7Õ8r*   c                 ó&   • U R                  S5        g)zl
If a value is passed for L{IReactorProcess.spawnProcess}'s C{uid}, the
child process is run with that UID.
ÚuidN©rJ  ©r9   s    r(   Útest_changeUIDÚ&ProcessTestsBuilderBase.test_changeUIDJ  ó   € ð 	×Ñ˜5Õ!r*   c                 ó&   • U R                  S5        g)zl
If a value is passed for L{IReactorProcess.spawnProcess}'s C{gid}, the
child process is run with that GID.
ÚgidNrN  rO  s    r(   Útest_changeGIDÚ&ProcessTestsBuilderBase.test_changeGIDR  rR  r*   c                 ó  ^^• U R                  5       m " S S[        5      m " UU4S jS[        5      nU" 5       nTR                  U[        [        SS/U R
                  S9nU R                  T5        [        b\  [        [        R                  R                  5       5       H1  u  pEXSLa  M  [        R                  XE5        U R                  S	5        M3     U R                  S
[        U R                  T5      5      5        g)zI
If L{IProcessProtocol.processExited} raises an exception, it is logged.
c                   ó   • \ rS rSrSrg)ÚGProcessTestsBuilderBase.test_processExitedRaises.<locals>.TestExceptionib  rN   N)rH   rI   rJ   rK   rM   rN   r*   r(   ÚTestExceptionrY  b  s   † Úr*   rZ  c                   ó$   >• \ rS rSrU U4S jrSrg)ÚBProcessTestsBuilderBase.test_processExitedRaises.<locals>.Protocolie  c                 ó4   >• TR                  5         T" S5      e)NzprocessedExited raisedrW   )r9   rE   rZ  r[   s     €€r(   rÇ   ÚPProcessTestsBuilderBase.test_processExitedRaises.<locals>.Protocol.processExitedf  s   ø€ Ø—‘”Ù#Ð$<Ó=Ð=r*   rN   N)rH   rI   rJ   rK   rÇ   rM   )rZ  r[   s   €€r(   ÚProtocolr\  e  s   ø† ÷>ñ >r*   r_  rT   r*   rU   NzEAfter processExited raised, transport was left in reapProcessHandlersrw   )r_   Ú	Exceptionr   r`   ra   rR   re   r   ÚlistÚreapProcessHandlersÚitemsÚunregisterReapProcessHandlerr­   rz   ÚlenÚflushLoggedErrors)r9   r_  rg   rh   Úpidr¢   rZ  r[   s         @@r(   Útest_processExitedRaisesÚ0ProcessTestsBuilderBase.test_processExitedRaisesZ  sã   ù€ ð ×#Ñ#Ó%ˆô	œIô 	÷	>ð 	>”ô 	>ñ
 “:ˆØ×(Ñ(Ø”eœe U¨CÐ0¸¿¹ð )ð 
ˆ	ð 	�‰˜Ô ô
 ÑÜ $¤W×%@Ñ%@×%FÑ%FÓ%HÖ I‘�ØÒ+ÙÜ×4Ñ4°SÔBØ—	‘	ð+öñ	 !Jð 	×Ñ˜œC × 6Ñ 6°}Ó EÓFÕGr*   rN   )"rH   rI   rJ   rK   rL   r   ÚrequiredInterfacesÚboolÚ__annotations__ri   r|   r…   r‹   r’   rš   r   rÝ   rª   r¯   rà   ró   r   rÑ   r  r1   r6  r?  rJ  Ú_uidgidSkipÚ_uidgidSkipReasonrP  rU  rh  rM   rN   r*   r(   rP   rP   l   sü   ‡ ñð *Ð*ÐØƒLò!ò4FòB	ò	ò	òñ Ù�˜	 4Ó(¨DÐ0ØEóñ: ó	ð: òxH!òT!HñF ˆH×ÒÓ Ð"IÓJñM
ó KðM
ð^ ñ+Aó ð+AòZ)ò89ñ@ ˆKÐ*Ó+ñ"ó ,ð"ñ ˆKÐ*Ó+ñ"ó ,ð"õ#Hr*   rP   c                   ó  • \ rS rSrSrSrSr\R                  " 5       (       a  Sr	OSr	S r
S rS	 rS
 rS rS rS r\S 5       rS rS rS r\S 5       r\S 5       r\S 5       r\S 5       r\S 5       r\S 5       rSrg)ÚProcessTestsBuilderi€  zd
Builder defining tests relating to L{IReactorProcess} for child processes
which do not have a PTY.
Fs$   twisted.internet.test.process_helpers   windowsr*   c           	      ó  ^^^	• [        5       m[        5       [        5       [        5       S.m " UU4S jS[        5      nSnU R                  5       m	T	R                  T	R                  U" 5       [
        [
        SU/[        U R                  S9  U4S jnTR                  U5        U4S jnTR                  U5        S	 nTR                  U5        TR                  [        5        U	4S
 jnTR                  U5        U R                  T	5        g)zz
L{IProcessProtocol.childConnectionLost} is called each time a file
descriptor associated with a child process is closed.
r  c                   ó.   >• \ rS rSrU 4S jrU4S jrSrg)Ú<ProcessTestsBuilder.test_childConnectionLost.<locals>.Closeri™  c                 ó(   >• TR                  U5        g r6   ©rC   )r9   rh   Ú	connecteds     €r(   ÚmakeConnectionÚKProcessTestsBuilder.test_childConnectionLost.<locals>.Closer.makeConnectionš  s   ø€ Ø×"Ñ" 9Õ-r*   c                 ó.   >• TU   R                  S 5        g r6   ru  ©r9   ÚchildFDÚlosts     €r(   r¿   ÚPProcessTestsBuilder.test_childConnectionLost.<locals>.Closer.childConnectionLost�  s   ø€ Ø�W‘×&Ñ& tÕ,r*   rN   N)rH   rI   rJ   rK   rw  r¿   rM   )rv  r|  s   €€r(   ÚCloserrs  ™  s   ø† õ.÷-ð -r*   r~  s,   twisted.internet.test.process_loseconnectionó   -mrÿ   c                 óX   >^ • T R                  S5        TS   R                  U 4S j5      $ )Ns   2
r  c                 ó   >• T$ r6   rN   ©rÚ   rh   s    €r(   r\   ÚSProcessTestsBuilder.test_childConnectionLost.<locals>.cbConnected.<locals>.<lambda>®  ó   ø€ ±9r*   ©rr   rd   ©rh   r|  s   `€r(   ÚcbConnectedÚAProcessTestsBuilder.test_childConnectionLost.<locals>.cbConnected¬  ó%   ù€ Ø�O‰O˜FÔ#Ø˜‘7×&Ñ&Ô'<Ó=Ð=r*   c                 óX   >^ • T R                  S5        TS   R                  U 4S j5      $ )Ns   1
rw   c                 ó   >• T$ r6   rN   r‚  s    €r(   r\   ÚRProcessTestsBuilder.test_childConnectionLost.<locals>.lostSecond.<locals>.<lambda>´  r„  r*   r…  r†  s   `€r(   Ú
lostSecondÚ@ProcessTestsBuilder.test_childConnectionLost.<locals>.lostSecond²  r‰  r*   c                 ó&   • U R                  S5        g )Nó   
r€   )rh   s    r(   Ú	lostFirstÚ?ProcessTestsBuilder.test_childConnectionLost.<locals>.lostFirst¸  s   € Ø�O‰O˜EÕ"r*   c                 ó&   >• TR                  5         g r6   rW   rY   s    €r(   ÚcbEndedÚ=ProcessTestsBuilder.test_childConnectionLost.<locals>.cbEnded¾  ó   ø€ Ø�L‰L�Nr*   N)r   r   r_   ry   r`   ra   r	  rR   rd   rÞ   r   re   )
r9   r~  Útargetr‡  r�  r‘  r”  rv  r|  r[   s
          @@@r(   Útest_childConnectionLostÚ,ProcessTestsBuilder.test_childConnectionLost‘  së   ú€ ô
 “Jˆ	Ü“:¤(£*´³Ñ<ˆ÷	-ð 	-”_ô 	-ð Aˆà×#Ñ#Ó%ˆØ×ÑØ× Ñ Ù‹HÜÜ�E˜6Ð"ÜØ—;‘;ð 	 ñ 	
õ	>ð 	×Ñ˜kÔ*õ	>ð 	×Ñ˜jÔ)ò	#ð 	×Ñ˜iÔ(Ø×ÑœSÔ!õ	ð 	×Ñ˜gÔ&à�‰˜Õ r*   c           
      ó´  ^ ^^^• [        5       m/ m " UU4S jS[        5      nT R                  5       mTR                  TR                  U" 5       [
        [
        ST R                  ST R                  /[        T R                  S9  UU 4S jnTR                  U5        TR                  [        5        TR                  U4S j5        T R                  T5        g)	z¢
L{IProcessProtocol.processEnded} is called after the child process
exits and L{IProcessProtocol.childConnectionLost} is called for each of
its file descriptors.
c                   ó:   >• \ rS rSrS rU4S jrS rU 4S jrSrg)Ú4ProcessTestsBuilder.test_processEnded.<locals>.EnderiÏ  c                 óV   • [        SX4-  5        U R                  R                  5         g r·   )r   rh   ÚloseConnection©r9   r>   r¸   s      r(   r@   ÚFProcessTestsBuilder.test_processEnded.<locals>.Ender.childDataReceivedÐ  s"   € ÜÐ/°2°*Ñ<Ô=Ø—‘×-Ñ-Õ/r*   c                 óF   >• [        SU4-  5        TR                  U5        g r¼   )r   r%   rz  s     €r(   r¿   ÚHProcessTestsBuilder.test_processEnded.<locals>.Ender.childConnectionLostÔ  s   ø€ ÜÐ-°°
Ñ:Ô;Ø—‘˜GÕ$r*   c                 ó$   • [        SU< S35        g rÂ   r¾   rD   s     r(   rÇ   ÚBProcessTestsBuilder.test_processEnded.<locals>.Ender.processExitedØ  s   € Ü�n V¡J¨aÐ0Õ1r*   c                 óJ   >• [        SU< S35        TR                  U/5        g rÊ   rÄ   )r9   rE   rf   s     €r(   rF   ÚAProcessTestsBuilder.test_processEnded.<locals>.Ender.processEndedÛ  s"   ø€ Ü�m F¡:¨QÐ/Ô0Ø—‘ ˜xÕ(r*   rN   NrÌ   )rf   r|  s   €€r(   ÚEnderrœ  Ï  s   ø† ò0õ%ò2÷)ð )r*   r§  r  ó   childrÿ   c                 ór   >• U u  nUR                  [        5        TR                  [        T5      1 Sk5        g ©N>   r   rw   r  )rÏ   r   rz   rŸ   )r    rÔ   r|  r9   s     €€r(   r”  Ú6ProcessTestsBuilder.test_processEnded.<locals>.cbEndedé  s*   ø€ Ø‰JˆWØ�L‰LœÔ%Ø×ÑœS ›Yª	Õ2r*   c                 ó$   >• TR                  5       $ r6   rW   rÙ   s    €r(   r\   Ú7ProcessTestsBuilder.test_processEnded.<locals>.<lambda>ñ  s   ø€  g§l¡l¤nr*   N©r   r   r_   ry   r`   ra   ÚkeepStdioOpenProgramÚkeepStdioOpenArgr	  rR   rd   rÞ   r   re   )r9   r§  r”  rf   r|  r[   s   `  @@@r(   Útest_processEndedÚ%ProcessTestsBuilder.test_processEndedÆ  s¸   û€ ô “
ˆØˆ÷	)ð 	)”Oô 	)ð  ×#Ñ#Ó%ˆØ×ÑØ× Ñ Ù‹GÜÜ�E˜4×4Ñ4°hÀ×@UÑ@UÐVÜØ—;‘;ð 	 ñ 	
ö	3ð
 	×Ñ˜'Ô"à×ÑœÔØ×ÑÔ4Ô5à�‰˜Õ r*   c                 ó   ^ ^^^^• [        5       m[        5       m/ m " UUU4S jS[        5      nT R                  5       mTR                  TR                  U" 5       [
        [
        SST R                  ST R                  /[        T R                  S9  UUU 4S jnTR                  U5        UU 4S jnTR                  U5        TR                  [        5        TR                  U4S	 j5        T R                  T5        g
)zŽ
L{IProcessProtocol.processExited} is called when the child process
exits, even if file descriptors associated with the child are still
open.
c                   ó6   >• \ rS rSrS rU U4S jrU4S jrSrg)Ú6ProcessTestsBuilder.test_processExited.<locals>.Waiteri  c                 ó"   • [        SX4-  5        g r·   r¾   rŸ  s      r(   r@   ÚHProcessTestsBuilder.test_processExited.<locals>.Waiter.childDataReceived  s   € ÜÐ/°2°*Ñ<Õ=r*   c                 óˆ   >• [        SU4-  5        TR                  U5        [        T5      S:X  a  TR                  S 5        g g )Nr½   é   )r   r%   re  rC   )r9   r{  ÚallLostr|  s     €€r(   r¿   ÚJProcessTestsBuilder.test_processExited.<locals>.Waiter.childConnectionLost  s=   ø€ ÜÐ-°°
Ñ:Ô;Ø—‘˜GÔ$Ü�t“9 “>Ø×$Ñ$ TÕ*ð "r*   c                 ó~   >• [        SU< S35        TR                  U/5        U R                  R                  5         g rÂ   )r   rC   rh   rž  rÅ   s     €r(   rÇ   ÚDProcessTestsBuilder.test_processExited.<locals>.Waiter.processExited  s2   ø€ Ü�n V¡J¨aÐ0Ô1à—‘  Ô)Ø—‘×-Ñ-Õ/r*   rN   N)rH   rI   rJ   rK   r@   r¿   rÇ   rM   )rº  rÆ   r|  s   €€€r(   ÚWaiterrµ    s   ø† ò>ö+÷0ð 0r*   r¾  s   -ur  r¨  rÿ   c                 óz   >• U u  nUR                  [        5        [        ST 35        TR                  T/ 5        T$ )NzcbExited; lost = )rÏ   r   r   rz   )r    rÔ   rº  r|  r9   s     €€€r(   rÖ   Ú8ProcessTestsBuilder.test_processExited.<locals>.cbExited#  s;   ø€ Ø‰JˆWØ�L‰LœÔ%ÜÐ# D 6Ð*Ô+Ø×Ñ˜T 2Ô&ØˆNr*   c                 ó@   >• TR                  [        T5      1 Sk5        g rª  )rz   rŸ   )rZ   r|  r9   s    €€r(   Ú	cbAllLostÚ9ProcessTestsBuilder.test_processExited.<locals>.cbAllLost,  s   ø€ Ø×ÑœS ›Yª	Õ2r*   c                 ó$   >• TR                  5       $ r6   rW   rÙ   s    €r(   r\   Ú8ProcessTestsBuilder.test_processExited.<locals>.<lambda>2  rÜ   r*   Nr®  )r9   r¾  rÖ   rÂ  rº  rÆ   r|  r[   s   `   @@@@r(   Útest_processExitedÚ&ProcessTestsBuilder.test_processExitedø  sß   ü€ ô “ˆÜ“*ˆØˆ÷	0ñ 	0”_ô 	0ð  ×#Ñ#Ó%ˆØ×ÑØ× Ñ Ù‹HÜäØØØ×)Ñ)ØØ×%Ñ%ðô Ø—;‘;ð 	 ñ 	
÷ 	ð 	×Ñ˜8Ô$ö	3ð 	×Ñ˜9Ô%à×Ñœ#ÔØ×ÑÔ5Ô6à�‰˜Õ r*   c                 ó<  • [        U R                  5       5      n[        US5       nUR                  [        R
                  R                  U5      [        R
                  -   5        SSS5        [        R                  R                  U5      $ ! , (       d  f       N-= f)zR
Write the given list of lines to a text file and return the absolute
path to it.
ÚwtN)	r   ÚmktempÚopenrr   r"   rx   r{   ÚpathÚabspath)r9   ÚsourceLinesÚscriptÚ
scriptFiles       r(   ÚmakeSourceFileÚ"ProcessTestsBuilder.makeSourceFile6  se   € ô
 $ D§K¡K£MÓ2ˆÜ�&˜$Ô :Ø×ÑœRŸZ™ZŸ_™_¨[Ó9¼B¿J¹JÑFÔG÷  ä�w‰w�‰˜vÓ&Ð&÷  Õús   ¦A BÂ
Bc           	      óž  ^ ^^^^^• Sm[        [        S[        R                  S5      5      nT R	                  SR                  U5      SSR                  TR                  S5      5      S/5      m[        R                  " TS5        T R                  5       mU U4S	 jmU4S
 jmUUUU4S jnTR                  U5        T R                  T5        g)z™
Spawning a process with an executable which is a script starting
with an interpreter definition line (#!) uses that interpreter to
evaluate the script.
s   this is the shebang outputÚ_base_executablerñ   z#!{}z
import syszsys.stdout.write('{}')zsys.stdout.flush()iÀ  c                 óœ   >• U u  pn[        SXU4-  5        TR                  UT5        TR                  US5        TR                  US5        g )NzcbProcessExited((%r, %r, %d))r*   r   )r   rz   )r    Úoutr   Úcoder9   ÚshebangOutputs       €€r(   ÚcbProcessExitedÚ9ProcessTestsBuilder.test_shebang.<locals>.cbProcessExitedW  sO   ø€ Ø!‰NˆC�dÜÐ/°3¸TÐ2BÑBÔCØ×Ñ˜S -Ô0Ø×Ñ˜S #Ô&Ø×Ñ˜T 1Õ%r*   c                 ó(   >• TR                  5         U $ r6   rW   )Úpassthroughr[   s    €r(   ÚshutdownÚ2ProcessTestsBuilder.test_shebang.<locals>.shutdown^  s   ø€ Ø�L‰LŒNØÐr*   c                  óž   >• [         R                  " TTS9n U R                  T5        U R                  T5        U R	                  [
        5        g )N)r[   )r   ÚgetProcessOutputAndValueÚaddBothrd   rÞ   r   )ÚdrÙ  r[   rÐ  rÝ  s    €€€€r(   ÚstartÚ/ProcessTestsBuilder.test_shebang.<locals>.startb  s9   ø€ Ü×.Ò.¨zÀ7ÑKˆAØ�I‰I�hÔØ�M‰M˜/Ô*Ø�L‰LœÕr*   N)rÝ   rç   ra   ræ   rÑ  Úformatr"   Úchmodr_   ry   re   )r9   Ú
executablerã  rÙ  r[   rÐ  rØ  rÝ  s   `  @@@@@r(   Útest_shebangÚ ProcessTestsBuilder.test_shebang@  s²   ý€ ð 6ˆô œSÐ"4´e·l±lÀ7Ó6KÓLˆ
Ø×(Ñ(à—‘˜jÓ)ØØ(×/Ñ/°×0DÑ0DÀWÓ0MÓNØ$ð	ó
ˆ
ô 	�Š�˜UÔ#à×#Ñ#Ó%ˆö	&õ	÷	ð 	ð 	×Ñ Ô&Ø�‰˜Õ r*   c                 óv   ^ • U 4S jnT R                  5       nUR                  X5        T R                  U5        g)z,
Pause producing and then resume producing.
c                 óô   >•  [        5       nU R                  U[        [        SS/TR                  S9nUR	                  5         UR                  5         U R                  5         g ! U R                  5         f = f)NrT   r*   rU   )r   r`   ra   rR   ÚpauseProducingÚresumeProducingrX   )r[   rg   rh   r9   s      €r(   ÚpauseAndResumeÚHProcessTestsBuilder.test_pauseAndResumeProducing.<locals>.pauseAndResumep  sf   ø€ ðÜ*Ó,�Ø#×0Ñ0Øœe¤e¨U°CÐ%8ÀÇÁð 1ð �	ð ×(Ñ(Ô*Ø×)Ñ)Ô+à—‘•ø�—‘•ús   ƒAA% Á%A7N)r_   ry   re   )r9   rî  r[   s   `  r(   Útest_pauseAndResumeProducingÚ0ProcessTestsBuilder.test_pauseAndResumeProducingk  s2   ø€ õ
		ð ×#Ñ#Ó%ˆØ×Ñ Ô8Ø�‰˜Õ r*   c           	      óL  ^ ^^^^^• Sm/ SQmSR                  [        [        [        SS5      5      5      n[	        U[
        5      (       a  UR                  S5        T R                  5       mUU 4S jmU4S jmUUUUU4S	 jnTR                  U5        T R                  T5        g
)zY
Arguments given to spawnProcess are passed to the child process as
originally intended.
s!   twisted.internet.test.process_cli)s   helloó   "s    	|<>^&s   "\\"hello\\"s   "foo\ bar baz\""r   rw   éÿ   r  c                 óv   >• U u  pnUR                  S5      nUR                  5         TR                  TU5        g )Nó    )ÚsplitÚpoprz   )ÚfinishedArgsrý   r   r×  r    r9   s       €€r(   ÚprocessFinishedÚMProcessTestsBuilder.test_processCommandLineArguments.<locals>.processFinishedŽ  s4   ø€ Ø ,ÑˆF˜Ø—\‘\ %Ó(ˆFà�J‰JŒLØ×Ñ˜T 6Õ*r*   c                 ó(   >• TR                  5         U $ r6   rW   )r®   r[   s    €r(   rÝ  ÚFProcessTestsBuilder.test_processCommandLineArguments.<locals>.shutdown•  s   ø€ Ø�L‰LŒNØˆMr*   c                  óŽ   >• [        S 5      n U R                  UUU4S j5        U R                  T5        U R                  T5        g )Nc                 óL   >• [         R                  " [        ST/T-   [        TS9$ )Nr  )r   r[   )r   rà  ra   r	  )Údummyr    r[   Úuss    €€€r(   r\   ÚZProcessTestsBuilder.test_processCommandLineArguments.<locals>.spawnChild.<locals>.<lambda>œ  s"   ø€ œe×<Ò<Ü˜E 2˜;¨Ñ-´9Àgòr*   )r   rd   rá  )râ  r    rú  r[   rÝ  r  s    €€€€€r(   Ú
spawnChildÚHProcessTestsBuilder.test_processCommandLineArguments.<locals>.spawnChild™  s7   ø€ Ü˜“ˆAØ�M‰Möôð
 �M‰M˜/Ô*Ø�I‰I�hÕr*   N)
r{   ÚmapÚchrÚranger  r  rò   r_   ry   re   )r9   ÚallCharsr  r    rú  r[   rÝ  r  s   `  @@@@@r(   Ú test_processCommandLineArgumentsÚ4ProcessTestsBuilder.test_processCommandLineArguments  s�   ý€ ð
 2ˆâTˆà—7‘7œ3œs¤E¨!¨S£MÓ2Ó3ˆÜ�h¤×$Ñ$Ø�O‰O˜GÔ$à×#Ñ#Ó%ˆö	+õ	÷	 ñ 	 ð 	×Ñ 
Ô+Ø�‰˜Õ r*   c                 ó  ^^• / m " U4S jS[         5      m[        UU4S j5       nU R                  5       nUR                  X5        U R	                  U5        [
        R                  " T[
        R                  " S/5      5        g)zi
Process is removed from reapProcessHandler dict before running
ProcessProtocol.processEnded() callback.
c                   ó,   >• \ rS rSrSrS rU 4S jrSrg)ÚiProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callback.<locals>.TestProcessProtocoli®  zï
Process protocol captures own presence in
process.reapProcessHandlers at time of .processEnded() callback.

@ivar deferred: A deferred fired when the .processEnded() callback
    has completed.
@type deferred: L{Deferred<defer.Deferred>}
c                 ó"   • [        5       U l        g r6   )r   ÚdeferredrO  s    r(   r:   ÚrProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callback.<locals>.TestProcessProtocol.__init__¸  s   € Ü (£
�•r*   c                 óæ   >• SSK Jn  UR                  nUR                  5       nU R                  U;   a  TR                  S5        OTR                  S5        U R                  R                  S5        g)zo
Capture whether the process has already been removed
from process.reapProcessHandlers.

@param status: unused
r   r   z!process present but should not beú"process already removed as desiredN)Útwisted.internetr   rb  Úvaluesrh   r%   r  rC   )r9   Ústatusr   ÚhandlersÚ	processesÚresultss        €r(   rF   ÚvProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callback.<locals>.TestProcessProtocol.processEnded»  sW   ø€ õ 5à"×6Ñ6�Ø$ŸO™OÓ-�	à—>‘> YÓ.Ø—N‘NÐ#FÕGà—N‘NÐ#GÔHà—‘×&Ñ& tÕ,r*   )r  N)rH   rI   rJ   rK   rL   r:   rF   rM   )r  s   €r(   ÚTestProcessProtocolr  ®  s   ø† ñò+÷-ð -r*   r  c              3   ó  >#   •  T" 5       nU R                  U[        [        S/5        UR                  v •  U R                  5         g! [         a  nTR	                  U5         SnAN1SnAff = f! U R                  5         f = f7f)a—  
Launch and wait for a subprocess and allow the TestProcessProtocol
to capture the order of the .processEnded() callback vs. removal
from process.reapProcessHandlers.

@param reactor: Reactor used to spawn the test process and to be
    stopped when checks are complete.
@type reactor: object providing
    L{twisted.internet.interfaces.IReactorProcess} and
    L{twisted.internet.interfaces.IReactorCore}.
z	--versionN)r`   ra   r  r`  r%   rX   )r[   ÚtestProcessProtocolÚer  r  s      €€r(   ÚlaunchProcessAndWaitÚjProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callback.<locals>.launchProcessAndWaitÎ  su   øé € ðÙ&9Ó&;Ð#Ø×$Ñ$Ø'ÜÜ˜KÐ(ôð
 *×2Ñ2Ò2ð —‘•øô ó "Ø—‘˜q×!Ñ!ûð"ûð —‘•üs9   ƒB…2A ·BÁ
A-ÁA(Á#A0 Á(A-Á-A0 Á0BÂBr  N)r   r   r_   ry   re   ÚhamcrestÚassert_thatÚequal_to)r9   r  r[   r  r  s      @@r(   Ú8test_process_unregistered_before_protocol_ended_callbackÚLProcessTestsBuilder.test_process_unregistered_before_protocol_ended_callback¦  sy   ù€ ð ˆ÷	-¤/ô 	-ô@ 
õ	ó 
ð	ð2 ×#Ñ#Ó%ˆØ×ÑÐ 4Ô>Ø�‰˜Ô ä×ÒØÜ×ÒÐCÐDÓEõ	
r*   c           
      ó   ^• [        5       n[        5       =oTl        U R                  5       mU(       + Tl        TR
                  " TR                  U[        [        S[        S5      /4SU R                  0UD6  U4S jnUR                  U5        U R                  T5        1 SknU H  nUR                  US5        M     [        R                  " U R                  (       a  UR                  R!                  5       OUR"                  R!                  5       5      R%                  5       n	U R'                  X’R%                  5       5        X’R%                  5       -
   V
s1 s H  oªS   iM	     nn
U R'                  X{5        gs  sn
f )zå
Shared code for testing the environment variables
present in the spawned process.

The spawned process serializes its environ to stderr or stdout (depending on usePTY)
which is checked against os.environ of the calling process.
rT   zOimport os, sys, json; env = dict(os.environ); sys.stderr.write(json.dumps(env))rR   c                 ó&   >• TR                  5         g r6   rW   rÙ   s    €r(   rÝ  ÚBProcessTestsBuilder.checkSpawnProcessEnvironment.<locals>.shutdown  r–  r*   >   ÚLINESÚCOLUMNSÚLC_CTYPEÚ__CF_USER_TEXT_ENCODINGNr   )r   r   ÚendedDeferredr_   r4  ry   r`   ra   r   rR   rá  re   rø  ÚjsonÚloadsÚoutFr  ÚerrFrc  ÚassertGreaterEqual)r9   ÚspawnKwargsÚexpectedEnvÚusePosixSpawnpÚprâ  rÝ  ÚexpectedExcessÚvarÚ	resultEnvÚpairÚresultExcessr[   s               @r(   ÚcheckSpawnProcessEnvironmentÚ0ProcessTestsBuilder.checkSpawnProcessEnvironmentñ  sI  ø€ ô ‹MˆÜ&›jÐ(ˆŒOà×#Ñ#Ó%ˆØ%3Ô!3ˆÔà×ÒØ× Ñ ØÜäØÜð8óðñ		
ð —;‘;ð	
ð ò	
õ"	ð 	
�	‰	�(Ôà�‰˜Ô ò
 UˆÛ!ˆCØ�O‰O˜C Ö&ñ "ô —J’JØ!%§§ˆA�F‰F�O‰OÔ°!·&±&·/±/Ó2Có
ç
‰%‹'ð 	ð 	×Ñ 	×+<Ñ+<Ó+>Ô?Ø,5×8IÑ8IÓ8KÒ,KÓLÒ,K D˜QœÑ,KˆÐLØ×Ñ Õ=ùò Ms   ÅE;c                 ó"   • U R                  XSS9$ )NT©r4  ©r;  ©r9   r2  r3  s      r(   Ú+checkSpawnProcessEnvironmentWithPosixSpawnpÚ?ProcessTestsBuilder.checkSpawnProcessEnvironmentWithPosixSpawnp%  s   € Ø×0Ñ0Ø°Tð 1ð 
ð 	
r*   c                 ó"   • U R                  XSS9$ )NFr>  r?  r@  s      r(   Ú$checkSpawnProcessEnvironmentWithForkÚ8ProcessTestsBuilder.checkSpawnProcessEnvironmentWithFork*  s   € Ø×0Ñ0Ø°Uð 1ð 
ð 	
r*   c                 ó&   • U R                  0 0 5      $ )zé
An empty environment is passed to the spawned process, when the default value of the C{env}
is used. That is, when the C{env} argument is not explicitly set.

In this case posix_spawnp is used as the backend for spawning processes.
©rA  rO  s    r(   Ú$test_environmentPosixSpawnpEnvNotSetÚ8ProcessTestsBuilder.test_environmentPosixSpawnpEnvNotSet/  s   € ð ×?Ñ?ÀÀBÓGÐGr*   c                 ó&   • U R                  0 0 5      $ )zé
An empty environment is passed to the spawned process, when the default value of the C{env}
is used. That is, when the C{env} argument is not explicitly set.

In this case fork+execvpe is used as the backend for spawning processes.
©rD  rO  s    r(   Útest_environmentForkEnvNotSetÚ1ProcessTestsBuilder.test_environmentForkEnvNotSet9  s   € ð ×8Ñ8¸¸RÓ@Ð@r*   c                 óF   • U R                  SS0[        R                  5      $ )z«
The parent process environment is passed to the spawned process, when C{env} is set to
C{None}.

In this case posix_spawnp is used as the backend for spawning processes.
r   N)rA  r"   ÚenvironrO  s    r(   Ú"test_environmentPosixSpawnpEnvNoneÚ6ProcessTestsBuilder.test_environmentPosixSpawnpEnvNoneC  s$   € ð ×?Ñ?Ø�DˆMœ2Ÿ:™:ó
ð 	
r*   c                 óF   • U R                  SS0[        R                  5      $ )z«
The parent process environment is passed to the spawned process, when C{env} is set to
C{None}.

In this case fork+execvpe is used as the backend for spawning processes.
r   N)rD  r"   rO  rO  s    r(   Útest_environmentForkEnvNoneÚ/ProcessTestsBuilder.test_environmentForkEnvNoneO  s   € ð ×8Ñ8¸%À¸ÌÏ
É
ÓSÐSr*   c                 ó2   • U R                  SSS00SS05      $ )zÜ
The user-specified environment without extra variables from parent process is passed to the
spawned process, when C{env} is set to a dictionary.

In this case posix_spawnp is used as the backend for spawning processes.
r   ÚMYENV1Úmyvalue1rG  rO  s    r(   Ú$test_environmentPosixSpawnpEnvCustomÚ8ProcessTestsBuilder.test_environmentPosixSpawnpEnvCustomY  s,   € ð ×?Ñ?Ø�X˜zÐ*Ð+Ø�zÐ"ó
ð 	
r*   c                 ó2   • U R                  SSS00SS05      $ )zÜ
The user-specified environment without extra variables from parent process is passed to the
spawned process, when C{env} is set to a dictionary.

In this case fork+execvpe is used as the backend for spawning processes.
r   rV  rW  rK  rO  s    r(   Útest_environmentForkEnvCustomÚ1ProcessTestsBuilder.test_environmentForkEnvCustomf  s,   € ð ×8Ñ8Ø�X˜zÐ*Ð+Ø�zÐ"ó
ð 	
r*   rN   N)rH   rI   rJ   rK   rL   rR   r¯  r   rÑ   r°  r˜  r±  rÆ  rÑ  rè  rð  r	  r1   r#  r;  rA  rD  rH  rL  rP  rS  rX  r[  rM   rN   r*   r(   rp  rp  €  sþ   † ñð
 €FàBÐØ×Ò×ÑØ%Ñð Ðò2!òj-!òd<!ò|'ò)!òV!ò(%!ðN ñH
ó ðH
òT2>òh
ò

ð
 ñHó ðHð ñAó ðAð ñ	
ó ð	
ð ñTó ðTð ñ

ó ð

ð ñ

ó ó

r*   rp  c                   ó�   • \ rS rSrSrSr\R                  " 5       (       a  SrSrg	\R                  " 5       (       a	  SrSS0r
Srg	Srg	)
ÚPTYProcessTestsBuilderiw  z]
Builder defining tests relating to L{IReactorProcess} for child processes
which have a PTY.
Tz"PTYs are not supported on Windows.z,PTYs are flaky from a Darwin bug. See #8840.z(twisted.internet.pollreactor.PollReactorz$macOS's poll() does not support PTYsrN   N)rH   rI   rJ   rK   rL   rR   r   rÑ   r/   r$   ÚskippedReactorsrM   rN   r*   r(   r^  r^  w  sJ   † ñð
 €Fà×Ò×ÑØ3‹Ø	×	Ò	×	Ñ	Ø=ˆð 7Ð8^ð
‹ò 
r*   r^  c                   ó   • \ rS rSrSrS rSrg)ÚPotentialZombieWarningTestsiŒ  z=
Tests for L{twisted.internet.error.PotentialZombieWarning}.
c                 óþ   • SSK Jn  UR                    U R                  U R                  /5      nU R                  US   S   [        5        U R                  US   S   S5        U R                  [        U5      S5        g)zž
Accessing L{PotentialZombieWarning} via the
I{PotentialZombieWarning} attribute of L{twisted.internet.error}
results in a deprecation warning being emitted.
r   )ÚerrorÚcategoryÚmessagez„twisted.internet.error.PotentialZombieWarning was deprecated in Twisted 10.0.0: There is no longer any potential for zombie process.rw   N)r  rc  ÚPotentialZombieWarningÚflushWarningsÚtest_deprecatedrz   ÚDeprecationWarningre  )r9   rc  Úwarningss      r(   rh  Ú+PotentialZombieWarningTests.test_deprecated‘  sx   € õ 	+à×$Ò$à×%Ñ% t×';Ñ';Ð&<Ó=ˆØ×Ñ˜ !™ ZÑ0Ô2DÔEØ×ÑØ�Q‰K˜	Ñ"ðô	
ð 	×Ñœ˜X›¨Õ*r*   rN   N)rH   rI   rJ   rK   rL   rh  rM   rN   r*   r(   ra  ra  Œ  s   † ñõ+r*   ra  c                   ó^   • \ rS rSrSr\" \R                  " 5       (       + S5      S 5       rSr	g)Ú/ProcessIsUnimportableOnUnsupportedPlatormsTestsi¦  zx
Tests to ensure that L{twisted.internet.process} is unimportable on
platforms where it does not work (namely Windows).
zOnly relevant on Windows.c                 ó–   • U R                  [        5         SSKnUR                  R                    SSS5        g! , (       d  f       g= f)z9
L{twisted.internet.process} is unimportable on Windows.
r   N)r—   ÚImportErrorÚtwisted.internet.processÚinternetr   )r9   Útwisteds     r(   Útest_unimportableOnWindowsÚJProcessIsUnimportableOnUnsupportedPlatormsTests.test_unimportableOnWindows¬  s0   € ð
 ×Ñœ{Õ+Û+à×Ñ×$Ò$÷ ,×+Ö+ús	   –:º
ArN   N)
rH   rI   rJ   rK   rL   r   r   rÑ   rs  rM   rN   r*   r(   rm  rm  ¦  s0   † ññ
 �×"Ò"Ó$Ô$Ð&AÓBñ%ó Có%r*   rm  c                   ó¢   • \ rS rSr \R
                  " SS5        \S 5       r\S 5       rSrg! \ a  r\" \5      r	\
" \5      r SrCN.SrCff = f)ÚReapingNonePidsLogsProperlyi·  Nc                 ó  • [         R                  S S 5        U R                  5       u  nU R                  [	        UR
                  5      U R                  S5        U R                  [        UR
                  5      U R                  S5        g ©NzWrong error type loggedzWrong error message logged)	r   ÚregisterReapProcessHandlerrf  rz   ÚtyperÐ   Úexpected_typer  Úexpected_message)r9   rc  s     r(   Útest_registerReapProcessHandlerÚ;ReapingNonePidsLogsProperly.test_registerReapProcessHandlerÀ  sp   € ä×*Ñ*¨4°Ô6à×(Ñ(Ó*‰ˆØ×ÑÜ�—‘ÓØ×ÑØ%ô	
ð
 	×ÑÜ�—‘ÓØ×!Ñ!Ø(õ	
r*   c                 ó2  • [         R                  S 5      nUR                  5         U R                  5       u  nU R	                  [        UR                  5      U R                  S5        U R	                  [        UR                  5      U R                  S5        g rx  )
r   Ú_BaseProcessÚreapProcessrf  rz   rz  rÐ   r{  r  r|  )r9   Ú_baseProcessrc  s      r(   Útest__BaseProcess_reapProcessÚ9ReapingNonePidsLogsProperly.test__BaseProcess_reapProcessÐ  s|   € ä×+Ñ+¨DÓ1ˆØ× Ñ Ô"à×(Ñ(Ó*‰ˆØ×ÑÜ�—‘ÓØ×ÑØ%ô	
ð
 	×ÑÜ�—‘ÓØ×!Ñ!Ø(õ	
r*   rN   )rH   rI   rJ   rK   r"   Úwaitpidr`  r  r  r|  rz  r{  r1   r}  rƒ  rM   rN   r*   r(   rv  rv  ·  sd   † ð ð 	�
Š
�4˜Ôð
 ñ
ó ð
ð ñ
ó ó
øð+ ó  Ù˜q›6ÐÙ˜Q›�ûð ús   ˆ. ®A´A	Á	Arv  i'  iu'  c                   óh   • \ rS rSrSrSS jrSS jrSS jrSS jrSS jr	SS	 jr
SS
 jrSS jrSrg)ÚGetFileActionsTestsiæ  zP
Tests to make sure that the file actions computed for posix_spawn are
correct.
Nc                 óP   • U R                  [        / 0 [        [        5      / 5        g)zM
If there are no open FDs and no requested child FDs, there's nothing to
do.
N©rz   r   ÚCLOSEÚDUP2rO  s    r(   Útest_nothingÚ GetFileActionsTests.test_nothingí  s   € ð
 	×Ñœ¨¨R´¼Ó=¸rÕBr*   c                 ó`   • U R                  [        S/0 [        [        5      [        S4/5        g)zY
If a file descriptor is not requested but it is not close-on-exec, it
should be closed.
©r   Fr   Nr‰  rO  s    r(   Útest_closeNoCloexecÚ'GetFileActionsTests.test_closeNoCloexecô  s(   € ð
 	×Ñœ¨*¨°r¼5Ä$ÓGÌ5ÐRSÈ*ÈÕVr*   c                 óR   • U R                  [        S/0 [        [        5      / 5        g)z[
If a file descriptor is close-on-exec and it is not requested, no
action should be taken.
©r   TNr‰  rO  s    r(   Útest_closeWithCloexecÚ)GetFileActionsTests.test_closeWithCloexecû  s!   € ð
 	×Ñœ¨)¨°b¼%ÄÓFÈÕKr*   c                 óf   • U R                  [        S/SS0[        [        5      [        SS4/5        g)zb
If a file descriptor is close-on-exec and it is moved, then there should be a dup2 but no close.
r“  r¹  r   Nr‰  rO  s    r(   Útest_moveWithCloexecÚ(GetFileActionsTests.test_moveWithCloexec  s0   € ð 	×ÑÜ˜Y˜K¨!¨Q¨´¼Ó=ÄÀqÈ!À¸~õ	
r*   c                 ót   • U R                  [        S/SS0[        [        5      [        SS4[        S4/5        g)zm
If a file descriptor is not close-on-exec and it is moved, then there
should be a dup2 followed by a close.
r�  r¹  r   Nr‰  rO  s    r(   Útest_moveNoCloexecÚ&GetFileActionsTests.test_moveNoCloexec
  s8   € ð
 	×ÑÜ˜Z˜L¨1¨a¨&´%¼Ó>Ü�A�qˆ\œE 1˜:Ð&õ	
r*   c                 óV   • U R                  [        S/SS0[        [        5      / 5        g)zs
If a file descriptor is not close-on-exec and it's left in the same
place, then there should be no actions taken.
r�  r   Nr‰  rO  s    r(   Útest_stayPutÚ GetFileActionsTests.test_stayPut  s%   € ð
 	×Ñœ¨*¨¸¸1°v¼uÄdÓKÈRÕPr*   c                 ó„   • U R                  [        S/SS0[        [        5      [        SS4[        SS4[        S4/5        g)zé
If a file descriptor is close-on-exec and it's left in the same place,
then we need to DUP2 it elsewhere, close the original, then DUP2 it
back so it doesn't get closed by the implicit exec at the end of
posix_spawn's file actions.
r“  r   rw   Nr‰  rO  s    r(   Útest_cloexecStayPutÚ'GetFileActionsTests.test_cloexecStayPut  s@   € ð 	×ÑÜ˜Y˜K¨!¨Q¨´¼Ó=Ü�A�qˆ\œD ! Q˜<¬%°¨Ð4õ	
r*   c                 ó˜   • U R                  [        SS/SSS.[        [        5      [        SS4[        SS4[        SS4[        S4/5        g)zŒ
If our file descriptor mapping requests that file descriptors change
places, we must DUP2 them to a new location before DUP2ing them back.
r�  )rw   Frw   r   )r   rw   r  Nr‰  rO  s    r(   Útest_inheritableConflictÚ,GetFileActionsTests.test_inheritableConflict'  s^   € ð
 	×ÑÜØ˜ZÐ(àØñô Üóô �q˜!�ä�q˜!�Ü�q˜!�Ü˜�
ðõ	
r*   rN   )r   N)rH   rI   rJ   rK   rL   rŒ  r�  r”  r—  rš  r�  r   r£  rM   rN   r*   r(   r‡  r‡  æ  s3   † ñô
CôWôLô
ô
ôQô

÷
r*   r‡  )KrL   r  r-  r"   rª   ré   rç   r¨   Úunittestr   r   r  r   Útwisted.internet.deferr   r   r   Útwisted.internet.errorr   r	   Útwisted.internet.interfacesr
   r   Útwisted.internet.protocolr   Ú#twisted.internet.test.reactormixinsr   Útwisted.python.compatr   Útwisted.python.filepathr   r   Útwisted.python.logr   r   Útwisted.python.runtimer   Útwisted.test.test_processr   Útwisted.trial.unittestr   r   rç  Ú_asBytesPathra   rm  rn  ÚdictrO  r	  Úpathsepr{   rÌ  r   Ú_processÚgetuidrp  r   ro  Úintr)   r1   r3   rP   rp  ÚglobalsÚupdateÚmakeTestCaseClassesr^  ra  rm  rv  rŠ  r‹  r‡  rN   r*   r(   Ú<module>rº     s»  ðñó 
Û Û 	Û Û Û 
Û Ý ã å "ß EÑ Eß Aß JÝ 5Ý >Ý /ß @ß 'Ý +Ý 1ß @ñ 	�—‘Ó ×-Ñ-Ó/€à€ØÐ Ù�—‘Ó€	ØŸ*™*Ÿ/™/¨#¯(©(Ó3€	ˆ,Ñ ð9Ý4à	‡y‚yƒ{�aÓØˆØBÐð €GÝ8ð ˜cô  ò"
ô) ô )ô(QH˜nô QHôhq
Ð1ô q
ñh ƒ	× Ñ Ð$×8Ñ8Ó:Ô ;ô
Ð4ô 
ñ$ ƒ	× Ñ Ð'×;Ñ;Ó=Ô >ô+ (ô +ô4%°hô %ô"(
 (ô (
ðV 	€Ø€ð ôV
Ð-ó V
ó ñV
øðm% ó ;Ø€GØ€KØ:Òð;ús   ÃF9 Æ9GÇG