§
    ÈtºfÌ  ã                   ó  — d Z ddlZddlmZmZ ddlmZmZ  G d„ dej        ¦  «        Z	e
dk    r\ ej        ej        d         ¦  «                             ¦   «          dd	lmZ  ej         e	¦   «         ¦  «          ej        ¦   «          dS dS )
z«
Main program for the child process run by
L{twisted.test.test_stdio.StandardInputOutputTests.test_producer} to test
that process transports implement IProducer properly.
é    N)ÚprotocolÚstdio)ÚlogÚreflectc                   ó.   — e Zd ZdZdZd„ Zd„ Zd„ Zd„ ZdS )ÚProducerChildFó    c                 ól   — t          j        d¦  «         t          j        dt          j        ¦  «         d S )Nz*****OVER*****é   )r   ÚmsgÚreactorÚ	callLaterÚstop)ÚselfÚreasons     ú_/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/test/stdio_test_producer.pyÚconnectionLostzProducerChild.connectionLost   s.   € ÝŒÐ Ñ!Ô!Ð!ÝÔ˜!�Wœ\Ñ*Ô*Ð*Ð*Ð*r	   c                 ó”  — | xj         |z  c_         | j        rMt          j        t          j        ¦  «         t          j        d¦  «         | j                             ¦   «          d S | j         	                    |¦  «         | j          
                    d¦  «        r| j                             ¦   «          d S |                      ¦   «          d S )Nz$dataReceived while transport paused!s   
0
)ÚbufÚ_pausedr   ÚstartLoggingÚsysÚstderrr   Ú	transportÚloseConnectionÚwriteÚendswithÚpause)r   Údatas     r   ÚdataReceivedzProducerChild.dataReceived   s³   € ØˆŒ�DÑˆŒØŒ<ð 		ÝÔ�SœZÑ(Ô(Ð(ÝŒGÐ:Ñ;Ô;Ð;ØŒN×)Ò)Ñ+Ô+Ð+Ð+Ð+àŒN× Ò  Ñ&Ô&Ð&ØŒx× Ò  Ñ*Ô*ð Ø”×-Ò-Ñ/Ô/Ð/Ð/Ð/à—
’
‘”���r	   c                 óz   — d| _         | j                             ¦   «          t          j        d| j        ¦  «         d S )NTg{®Gáz„?)r   r   ÚpauseProducingr   r   Úunpause©r   s    r   r   zProducerChild.pause'   s8   € ØˆŒØŒ×%Ò%Ñ'Ô'Ð'ÝÔ˜$ ¤Ñ-Ô-Ð-Ð-Ð-r	   c                 óF   — d| _         | j                             ¦   «          d S )NF)r   r   ÚresumeProducingr$   s    r   r#   zProducerChild.unpause,   s#   € ØˆŒØŒ×&Ò&Ñ(Ô(Ð(Ð(Ð(r	   N)	Ú__name__Ú
__module__Ú__qualname__r   r   r   r    r   r#   © r	   r   r   r      sZ   € € € € € Ø€GØ
€Cð+ð +ð +ðð ð ð.ð .ð .ð
)ð )ð )ð )ð )r	   r   Ú__main__r   )r   )Ú__doc__r   Útwisted.internetr   r   Útwisted.pythonr   r   ÚProtocolr   r'   ÚnamedAnyÚargvÚinstallr   Ú
StandardIOÚrunr*   r	   r   ú<module>r5      sí   ðð
ð ð €
€
€
à ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,Ø 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'ð)ð )ð )ð )ð )�HÔ%ñ )ô )ð )ð> ˆzÒÐØ€GÔ�S”X˜a”[Ñ!Ô!×)Ò)Ñ+Ô+Ð+Ø(Ð(Ð(Ð(Ð(Ð(à€EÔ�]�]‘_”_Ñ%Ô%Ð%Ø€G„K�M„M€M€M€Mð Ðr	   