
    Yf                        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     R/var/www/html/env/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< 		SZ(((G:;;;N))+++++N  &&&x  ** --/////

r	   c                 z    d| _         | j                                         t          j        d| j                   d S )NTg{Gz?)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SXa[!!))+++((((((E]]__%%%GKMMMMM r	   