+
    NV-j>  ã                   ó\   € . R	Ot ^ RIHt R.t ! R R]4      tR tR
R lt ! R R]4      tR# )ÚClientÚListener)ÚQueueNc                   óR   a € ] tR t^t o R	R ltR tR t]R 4       tR t	R t
RtV tR# )
r   Nc                ó&   € \        V4      V n        R # ©N)r   Ú_backlog_queue)ÚselfÚaddressÚfamilyÚbacklogs   &&&&Ún/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/multiprocess/dummy/connection.pyÚ__init__ÚListener.__init__   s   € Ü# G›nˆÖó    c                óD   € \        V P                  P                  4       !  # r   )Ú
Connectionr   Úget©r	   s   &r   ÚacceptÚListener.accept   s   € Ü˜4×.Ñ.×2Ñ2Ó4Ñ5Ð5r   c                ó   € R V n         R # r   ©r   r   s   &r   ÚcloseÚListener.close   s
   € Ø"ˆÖr   c                ó   € V P                   # r   r   r   s   &r   r
   ÚListener.address   s   € à×"Ñ"Ð"r   c                ó   € V # r   © r   s   &r   Ú	__enter__ÚListener.__enter__!   ó   € Øˆr   c                ó&   € V P                  4        R # 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__Ú__classdictcell__©Ú__classdict__s   @r   r   r      s7   ø‡ € ô-ò6ò#ð ñ#ó ð#ò÷ð r   c                 ób   € \        4       \        4       r!V P                  W!34       \        W4      # r   )r   Úputr   )r
   Ú_inÚ_outs   &  r   r   r   (   s&   € Ü“œ›ˆØ‡K�K��ÔÜ�cÓ Ð r   c                 óT   € \        4       \        4       r!\        W4      \        W!4      3# r   )r   r   )ÚduplexÚaÚbs   &  r   ÚPiper=   .   s"   € Ü‹7”E“G€qÜ�aÓœZ¨Ó-Ð-Ð-r   c                   óB   a € ] tR t^3t o R tRR ltR tR tR tRt	V t
R# )	r   c                ó~   € W n         Wn        VP                  ;V n        V n        VP
                  ;V n        V n        R # 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                óN  € V P                   P                  4       ^ 8”  d   R# VR8:  d   R# V P                   P                  ;_uu_ 4        V P                   P                  P                  V4       RRR4       V P                   P                  4       ^ 8„  #   + '       g   i     L-; i)é    Tç        FN)r7   ÚqsizeÚ	not_emptyÚwait)r	   Útimeouts   &&r   ÚpollÚConnection.poll;   sn   € Ø�8‰8�>‰>Ó˜aÔÙØ�cŒ>ÙØ�X‰X××ÓØ�H‰H×Ñ×#Ñ# GÔ,÷  à�x‰x�~‰~Ó !Ñ#Ð#÷  ×ús   Á	&BÂB$	c                ó   € R # r   r   r   s   &r   r   ÚConnection.closeD   s   € Ùr   c                ó   € V # r   r   r   s   &r   r   ÚConnection.__enter__G   r!   r   c                ó&   € V P                  4        R # r   r#   r$   s   &&&&r   r(   ÚConnection.__exit__J   r*   r   )r7   r8   rB   rC   r@   rA   N)rG   )r,   r-   r.   r/   r   rL   r   r   r(   r1   r2   r3   s   @r   r   r   3   s#   ø‡ € ò.ô$òò÷ð r   r   )r   r   r=   )T)	Ú__all__Úqueuer   ÚfamiliesÚobjectr   r   r=   r   r   r   r   Ú<module>rX      s:   ðò +€å ð ˆ6€ôˆvô ò,!ô.ô
�ö r   