ó
    F\h>  ã                   óZ   • / S Qr SSKJr  S/r " S S\5      rS rS
S jr " S S	\5      rg))ÚClientÚListenerÚPipeé    )ÚQueueNc                   óF   • \ rS rSrS
S jrS rS r\S 5       rS r	S r
S	rg)r   é   Nc                 ó$   • [        U5      U l        g ©N)r   Ú_backlog_queue)ÚselfÚaddressÚfamilyÚbacklogs       Ú7/usr/lib/python3.13/multiprocessing/dummy/connection.pyÚ__init__ÚListener.__init__   s   € Ü# G›nˆÕó    c                 óB   • [        U R                  R                  5       6 $ r
   )Ú
Connectionr   Úget©r   s    r   ÚacceptÚListener.accept   s   € Ü˜4×.Ñ.×2Ñ2Ó4Ð5Ð5r   c                 ó   • S U l         g r
   ©r   r   s    r   ÚcloseÚListener.close   s
   € Ø"ˆÕr   c                 ó   • U R                   $ r
   r   r   s    r   r   ÚListener.address   s   € à×"Ñ"Ð"r   c                 ó   • U $ r
   © r   s    r   Ú	__enter__ÚListener.__enter__!   ó   € Øˆr   c                 ó$   • U R                  5         g r
   ©r   ©r   Úexc_typeÚ	exc_valueÚexc_tbs       r   Ú__exit__ÚListener.__exit__$   ó   € Ø�
‰
�r   r   )NNé   )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r   r   Úpropertyr   r"   r+   Ú__static_attributes__r!   r   r   r   r      s/   † ô-ò6ò#ð ñ#ó ð#òõr   r   c                 ób   • [        5       [        5       p!U R                  X!45        [        X5      $ r
   )r   Úputr   )r   Ú_inÚ_outs      r   r   r   (   s&   € Ü“œ›ˆØ‡K�K��ÔÜ�cÓ Ð r   c                 óT   • [        5       [        5       p![        X5      [        X!5      4$ r
   )r   r   )ÚduplexÚaÚbs      r   r   r   .   s"   € Ü‹7”E“G€qÜ�aÓœZ¨Ó-Ð-Ð-r   c                   ó6   • \ rS rSrS rS	S jrS rS rS rSr	g)
r   é3   c                 ó|   • X l         Xl        UR                  =U l        U l        UR
                  =U l        U l        g r
   )r8   r7   r6   ÚsendÚ
send_bytesr   ÚrecvÚ
recv_bytes)r   r7   r8   s      r   r   ÚConnection.__init__5   s0   € ØŒ	ØŒØ&*§h¡hÐ.ˆŒ	�D”OØ&)§g¡gÐ-ˆŒ	�D•Or   c                 ó2  • U R                   R                  5       S:”  a  gUS::  a  gU R                   R                     U R                   R                  R                  U5        S S S 5        U R                   R                  5       S:„  $ ! , (       d  f       N+= f)Nr   Tç        F)r7   ÚqsizeÚ	not_emptyÚwait)r   Útimeouts     r   ÚpollÚConnection.poll;   sk   € Ø�8‰8�>‰>Ó˜aÓØØ�c‹>ØØ�X‰X×ÓØ�H‰H×Ñ×#Ñ# GÔ,÷  à�x‰x�~‰~Ó !Ñ#Ð#÷  Õús   ½&BÂ
Bc                 ó   • g r
   r!   r   s    r   r   ÚConnection.closeD   s   € Ør   c                 ó   • U $ r
   r!   r   s    r   r"   ÚConnection.__enter__G   r$   r   c                 ó$   • U R                  5         g r
   r&   r'   s       r   r+   ÚConnection.__exit__J   r-   r   )r7   r8   rB   rC   r@   rA   N)rF   )
r/   r0   r1   r2   r   rK   r   r"   r+   r4   r!   r   r   r   r   3   s   † ò.ô$òòõr   r   )T)	Ú__all__Úqueuer   ÚfamiliesÚobjectr   r   r   r   r!   r   r   Ú<module>rW      s:   ðò +€å ð ˆ6€ôˆvô ò,!ô.ô
�õ r   