§
    (¶Õi>  ã                   óf   — g d ¢Z ddlmZ dgZ G d„ de¦  «        Zd„ Zdd„Z G d	„ d
e¦  «        ZdS ))ÚClientÚListenerÚPipeé    )ÚQueueNc                   óD   — e Zd Zd	d„Zd„ Zd„ Zed„ ¦   «         Zd„ Zd„ Z	dS )
r   Né   c                 ó.   — t          |¦  «        | _        d S ©N)r   Ú_backlog_queue)ÚselfÚaddressÚfamilyÚbacklogs       ú7/usr/lib/python3.11/multiprocessing/dummy/connection.pyÚ__init__zListener.__init__   s   € Ý# G™nœnˆÔÐÐó    c                 óB   — t          | j                             ¦   «         Ž S r
   )Ú
Connectionr   Úget©r   s    r   ÚacceptzListener.accept   s   € Ý˜4Ô.×2Ò2Ñ4Ô4Ð5Ð5r   c                 ó   — d | _         d S r
   ©r   r   s    r   ÚclosezListener.close   s   € Ø"ˆÔÐÐr   c                 ó   — | j         S r
   r   r   s    r   r   zListener.address   s   € àÔ"Ð"r   c                 ó   — | S r
   © r   s    r   Ú	__enter__zListener.__enter__!   ó   € Øˆr   c                 ó.   — |                       ¦   «          d S r
   ©r   ©r   Úexc_typeÚ	exc_valueÚexc_tbs       r   Ú__exit__zListener.__exit__$   ó   € Ø�
Š
‰Œˆˆˆr   )NNr   )
Ú__name__Ú
__module__Ú__qualname__r   r   r   Úpropertyr   r   r&   r   r   r   r   r      s   € € € € € ð-ð -ð -ð -ð6ð 6ð 6ð#ð #ð #ð ð#ð #ñ „Xð#ðð ð ðð ð ð ð r   r   c                 óˆ   — t          ¦   «         t          ¦   «         }}|                      ||f¦  «         t          ||¦  «        S r
   )r   Úputr   )r   Ú_inÚ_outs      r   r   r   (   s9   € Ý‘”�™œˆ€CØ‡K‚K��s�ÑÔÐÝ�c˜4Ñ Ô Ð r   Tc                 óz   — t          ¦   «         t          ¦   «         }}t          ||¦  «        t          ||¦  «        fS r
   )r   r   )ÚduplexÚaÚbs      r   r   r   .   s2   € Ý‰7Œ7•E‘G”G€q€AÝ�a˜ÑÔ�Z¨¨1Ñ-Ô-Ð-Ð-r   c                   ó.   — e Zd Zd„ Zdd„Zd„ Zd„ Zd„ ZdS )	r   c                 ón   — || _         || _        |j        x| _        | _        |j        x| _        | _        d S r
   )r/   r.   r-   ÚsendÚ
send_bytesr   ÚrecvÚ
recv_bytes)r   r.   r/   s      r   r   zConnection.__init__5   s4   € ØˆŒ	ØˆŒØ&*¤hÐ.ˆŒ	�D”OØ&)¤gÐ-ˆŒ	�D”O�O�Or   ç        c                 ó  — | j                              ¦   «         dk    rdS |dk    rdS | j         j        5  | j         j                             |¦  «         d d d ¦  «         n# 1 swxY w Y   | j                              ¦   «         dk    S )Nr   Tr:   F)r.   ÚqsizeÚ	not_emptyÚwait)r   Útimeouts     r   ÚpollzConnection.poll;   s¼   € ØŒ8�>Š>ÑÔ˜aÒÐØ�4Ø�cŠ>ˆ>Ø�5ØŒXÔð 	-ð 	-ØŒHÔ×#Ò# GÑ,Ô,Ð,ð	-ð 	-ð 	-ñ 	-ô 	-ð 	-ð 	-ð 	-ð 	-ð 	-ð 	-øøøð 	-ð 	-ð 	-ð 	-àŒx�~Š~ÑÔ !Ò#Ð#s   ´ A Á A$Á'A$c                 ó   — d S r
   r   r   s    r   r   zConnection.closeD   s   € Øˆr   c                 ó   — | S r
   r   r   s    r   r   zConnection.__enter__G   r   r   c                 ó.   — |                       ¦   «          d S r
   r!   r"   s       r   r&   zConnection.__exit__J   r'   r   N)r:   )r(   r)   r*   r   r@   r   r   r&   r   r   r   r   r   3   sd   € € € € € ð.ð .ð .ð$ð $ð $ð $ðð ð ðð ð ðð ð ð ð r   r   )T)	Ú__all__Úqueuer   ÚfamiliesÚobjectr   r   r   r   r   r   r   ú<module>rH      s®   ðð +Ð
*Ð
*€à Ð Ð Ð Ð Ð ð ˆ6€ðð ð ð ð ˆvñ ô ð ð,!ð !ð !ð.ð .ð .ð .ð
ð ð ð ð �ñ ô ð ð ð r   