+
    NV-jœ1  ã                   ó  € . ROt ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	H
t
Ht ^RIHt ^RIHt ]P                  P                   t^RIHtHtHtHtHt  ! R R ]4      t]! 4       t ! R	 R]4      t ! R
 R]4      tR# )ÚQueueÚSimpleQueueÚJoinableQueueN)ÚEmptyÚFull)Ú
connection)Úcontext)ÚdebugÚinfoÚFinalizeÚregister_after_forkÚ
is_exitingc                   óú   a € ] tR t^!t o RR ltR tR tR tRR ltRR lt	RR lt
R	 tR
 tR tR tR tR tR tR tR tR t]R 4       t]R 4       t]R 4       t]R 4       t]! ]P8                  4      tRtV tR# )r   c               óò  € V^ 8:  d   ^RI Hp Wn        \        P                  ! RR7      w  V n        V n        VP                  4       V n        \        P                  ! 4       V n        \        P                  R8X  d	   RV n        MVP                  4       V n        VP                  V4      V n        RV n        V P%                  4        \        P                  R8w  d   \'        V \(        P*                  4       R# R# )é    )ÚSEM_VALUE_MAXF©ÚduplexÚwin32N)Úsynchronizer   Ú_maxsizer   ÚPipeÚ_readerÚ_writerÚLockÚ_rlockÚosÚgetpidÚ_opidÚsysÚplatformÚ_wlockÚBoundedSemaphoreÚ_semÚ_ignore_epipeÚ_resetr   r   Ú_after_fork©ÚselfÚmaxsizeÚctxs   &&$Úd/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/multiprocess/queues.pyÚ__init__ÚQueue.__init__#   s¦   € Ø�aŒ<å=ØŒÜ%/§_¢_¸EÔ%BÑ"ˆŒ�d”lØ—h‘h“jˆŒÜ—Y’Y“[ˆŒ
Ü�<‰<˜7Ô"ØˆD�KàŸ(™(›*ˆDŒKØ×(Ñ(¨Ó1ˆŒ	à"ˆÔØ�‰Œä�<‰<˜7Ô"Ü ¤e×&7Ñ&7Ö8ñ #ó    c                óâ   € \         P                  ! V 4       V P                  V P                  V P                  V P
                  V P                  V P                  V P                  V P                  3# ©N)
r   Úassert_spawningr$   r   r   r   r   r!   r#   r   ©r(   s   &r+   Ú__getstate__ÚQueue.__getstate__7   sP   € Ü×Ò Ô%Ø×"Ñ" D§M¡M°4·<±<ÀÇÁØ—‘˜TŸ[™[¨$¯)©)°T·Z±ZðAð 	Ar.   c           	     óŒ   € Vw  V n         V n        V n        V n        V n        V n        V n        V n        V P                  4        R # r0   )	r$   r   r   r   r   r!   r#   r   r%   ©r(   Ústates   &&r+   Ú__setstate__ÚQueue.__setstate__<   s5   € à<Añ	:ˆÔ	˜Tœ]¨D¬L¸$¼,Ø	Œ�d”k 4¤9¨d¬jØ�‰Žr.   c                ó@   € \        R 4       V P                  RR7       R# )zQueue._after_fork()T)Ú
after_forkN)r	   r%   r2   s   &r+   r&   ÚQueue._after_forkA   s   € ÜÐ#Ô$Ø�‰˜tˆÖ$r.   c                óÄ  € V'       d   V P                   P                  4        M.\        P                  ! \        P                  ! 4       4      V n         \
        P                  ! 4       V n        R V n        R V n	        RV n
        RV n        R V n        V P                  P                  V n        V P                   P"                  V n        V P                   P&                  V n        R # )NF)Ú	_notemptyÚ_at_fork_reinitÚ	threadingÚ	Conditionr   ÚcollectionsÚdequeÚ_bufferÚ_threadÚ_jointhreadÚ_joincancelledÚ_closedÚ_closer   Ú
send_bytesÚ_send_bytesr   Ú
recv_bytesÚ_recv_bytesÚpollÚ_poll)r(   r;   s   &&r+   r%   ÚQueue._resetE   s˜   € ßØ�N‰N×*Ñ*Õ,ä&×0Ò0´·²Ó1AÓBˆDŒNÜ"×(Ò(Ó*ˆŒØˆŒØˆÔØ#ˆÔØˆŒØˆŒØŸ<™<×2Ñ2ˆÔØŸ<™<×2Ñ2ˆÔØ—\‘\×&Ñ&ˆŽ
r.   Nc                ó   € V P                   '       d   \        R V : R24      hV P                  P                  W#4      '       g   \        hV P
                  ;_uu_ 4        V P                  f   V P                  4        V P                  P                  V4       V P
                  P                  4        RRR4       R#   + '       g   i     R# ; i©úQueue ú
 is closedN)rH   Ú
ValueErrorr#   Úacquirer   r>   rE   Ú_start_threadrD   ÚappendÚnotify©r(   ÚobjÚblockÚtimeouts   &&&&r+   ÚputÚ	Queue.putT   s†   € Ø�<�<ˆ<Ü˜v d¡X¨ZÐ8Ó9Ð9Ø�y‰y× Ñ  ×0Ò0ÜˆJà�^�^‹^Ø�|‰|Ò#Ø×"Ñ"Ô$Ø�L‰L×Ñ Ô$Ø�N‰N×!Ñ!Ô#÷	 �^�^Š^ús   ÁAB<Â<C	c                ó˜  € V P                   '       d   \        R V : R24      hV'       dN   VfJ   V P                  ;_uu_ 4        V P                  4       pRRR4       V P                  P                  4        EMV'       d,   \        \        R\        P                  4      ! 4       V,           pV P                  P                  W4      '       g   \        h V'       dJ   X\        \        R\        P                  4      ! 4       ,
          pV P                  V4      '       g   \        hMV P                  4       '       g   \        hV P                  4       pV P                  P                  4        V P                  P                  4        \        P                  X4      #   + '       g   i     ELN; i  T P                  P                  4        i ; i)rS   rT   NÚ	monotonic)rH   rU   r   rM   r#   ÚreleaseÚgetattrÚtimerV   r   rO   Ú_ForkingPicklerÚloads)r(   r\   r]   ÚresÚdeadlines   &&&  r+   ÚgetÚ	Queue.get`   s0  € Ø�<�<ˆ<Ü˜v d¡X¨ZÐ8Ó9Ð9ß�W’_Ø——“Ø×&Ñ&Ó(�÷ à�I‰I×ÑÖçÜ"¤4¨´D·I±IÔ>Ó@À7ÕJ�Ø—;‘;×&Ñ& u×6Ò6Ü�ð
&ßØ&¬´°kÄ$Ç)Á)Ô)LÓ)NÕN�GØŸ:™: g×.Ò.Ü#˜ð /àŸ™ŸšÜ�KØ×&Ñ&Ó(�Ø—	‘	×!Ñ!Ô#à—‘×#Ñ#Ô%ä×$Ñ$ SÓ)Ð)÷) —�ûð$ —‘×#Ñ#Õ%ús%   ÁFÃF- ÃAF- Ä:0F- ÆF*	Æ-G	c                óX   € V P                   V P                  P                  4       ,
          # r0   )r   r#   Ú	get_valuer2   s   &r+   ÚqsizeÚQueue.qsizez   s   € à�}‰}˜tŸy™y×2Ñ2Ó4Õ4Ð4r.   c                ó,   € V P                  4       '       * # r0   ©rO   r2   s   &r+   ÚemptyÚQueue.empty~   ó   € Ø—:‘:“<ÔÐr.   c                óJ   € V P                   P                  P                  4       # r0   )r#   Ú_semlockÚ_is_zeror2   s   &r+   ÚfullÚ
Queue.full�   s   € Ø�y‰y×!Ñ!×*Ñ*Ó,Ð,r.   c                ó$   € V P                  R 4      # ©F)ri   r2   s   &r+   Ú
get_nowaitÚQueue.get_nowait„   s   € Ø�x‰x˜‹Ðr.   c                ó&   € V P                  VR 4      # rz   )r^   ©r(   r[   s   &&r+   Ú
put_nowaitÚQueue.put_nowait‡   s   € Ø�x‰x˜˜UÓ#Ð#r.   c                ó\   € R V n         V P                  pV'       d   RV n        V! 4        R# R# ©TN)rH   rI   )r(   Úcloses   & r+   rƒ   ÚQueue.closeŠ   s&   € ØˆŒØ—‘ˆßØˆDŒKÙŽGñ r.   c                ó´   € \        R 4       V P                  '       g   Q RP                  V 4      4       hV P                  '       d   V P                  4        R# R# )zQueue.join_thread()zQueue {0!r} not closedN)r	   rH   ÚformatrF   r2   s   &r+   Újoin_threadÚQueue.join_thread‘   sG   € ÜÐ#Ô$Ø�|�|ˆ|ÐBÐ5×<Ñ<¸TÓBÓBˆ|Ø××ÐØ×ÑÖñ r.   c                ó„   € \        R 4       RV n         V P                  P                  4        R#   \         d     R# i ; i)zQueue.cancel_join_thread()TN)r	   rG   rF   ÚcancelÚAttributeErrorr2   s   &r+   Úcancel_join_threadÚQueue.cancel_join_thread—   s<   € ÜÐ*Ô+Ø"ˆÔð	Ø×Ñ×#Ñ#Ö%øÜô 	Úð	ús   ”0 °?¾?c                óØ   € V P                   P                  4        \        P                  R 8X  d   V P                  P                  4        V P                  4        V P                  4        R# )r   N)r   rƒ   r   r    r   r‡   r2   s   &r+   Ú_terminate_brokenÚQueue._terminate_brokenŸ   sG   € ð 	�‰×ÑÔô �<‰<˜7Ô"Ø�L‰L×ÑÔ à�
‰
ŒØ×ÑÖr.   c                ó>  € \        R 4       V P                  P                  4        \        P                  ! \
        P                  V P                  V P                  V P                  V P                  V P                  P                  V P                  P                  V P                  V P                  V P                  3	RRR7      V n         \        R4       V P                   P#                  4        \        R4       T P$                  '       gL   \'        T P                   \
        P(                  \*        P,                  ! T P                   4      .RR7      T n        \'        T \
        P0                  T P                  T P                  .^
R7      T n        R#    RT n        h ; i)	zQueue._start_thread()ÚQueueFeederThreadT)ÚtargetÚargsÚnameÚdaemonzdoing self._thread.start()z... done self._thread.start()N)Úexitpriorityéûÿÿÿ)r	   rD   Úclearr@   ÚThreadr   Ú_feedr>   rK   r!   r   rƒ   r   r$   Ú_on_queue_feeder_errorr#   rE   ÚstartrG   r   Ú_finalize_joinÚweakrefÚrefrF   Ú_finalize_closerI   r2   s   &r+   rW   ÚQueue._start_thread­   s5  € ÜÐ%Ô&ð 	�‰×ÑÔÜ ×'Ò'Ü—;‘;Ø—,‘, §¡°×0@Ñ0@Ø—+‘+˜tŸ|™|×1Ñ1°4·<±<×3EÑ3EØ×$Ñ$ d×&AÑ&AØ—)‘)ðð %Øô
ˆŒð	ÜÐ.Ô/Ø�L‰L×ÑÔ ÜÐ1Ô2ð ×"×"Ð"Ü'Ø—‘œe×2Ñ2Ü—’˜TŸ\™\Ó*Ð+Øô ˆDÔô Ø”%×'Ñ'Ø�\‰\˜4Ÿ>™>Ð*ØôˆŽøð	ð  ˆDŒLØús   Ã0F Æ
Fc                ó‚   € \        R 4       V ! 4       pVe   VP                  4        \        R4       R# \        R4       R# )zjoining queue threadNz... queue thread joinedz... queue thread already dead)r	   Újoin)ÚtwrÚthreads   & r+   rž   ÚQueue._finalize_joinÔ   s3   € äÐ$Ô%Ù“ˆØÒØ�K‰KŒMÜÐ+Ö,äÐ1Ö2r.   c                ó´   € \        R 4       V;_uu_ 4        V P                  \        4       VP                  4        RRR4       R#   + '       g   i     R# ; i)ztelling queue thread to quitN)r	   rX   Ú	_sentinelrY   )ÚbufferÚnotemptys   &&r+   r¡   ÚQueue._finalize_closeÞ   s2   € äÐ,Ô-ßŠXØ�M‰Mœ)Ô$Ø�O‰OÔ÷ �X�XŠXús   –&AÁA	c	                óJ  € \        R 4       VP                  p	VP                  p
VP                  pV P                  p\
        p\        P                  R8w  d   VP                  pVP                  pMRp  V	! 4         V '       g   V! 4        V
! 4          V! 4       pVVJ d   \        R4       V! 4        V! 4        R# \        P                  V4      pVf   V! V4       KL  V! 4         V! V4       X! 4        Ke    T
! 4        i ; i  X! 4        i ; i  \         d     K¬  i ; i  \         dv   pT'       d'   \        TR^ 4      \        P                  8X  d    Rp?R# \        4       '       d   \!        RT4        Rp?R# TP                  4        T! TX4        Rp?EK+  Rp?ii ; i)z$starting thread to feed data to piper   Nz%feeder thread got sentinel -- exitingÚerrnozerror in queue thread: %s)r	   rV   rb   ÚwaitÚpopleftr©   r   r    re   ÚdumpsÚ
IndexErrorÚ	Exceptionrc   r®   ÚEPIPEr   r
   )rª   r«   rJ   Ú	writelockÚreader_closeÚwriter_closeÚignore_epipeÚonerrorÚ	queue_semÚnacquireÚnreleaseÚnwaitÚbpopleftÚsentinelÚwacquireÚwreleaser[   Úes   &&&&&&&&&         r+   r›   ÚQueue._feedå   s\  € ô 	Ð4Ô5Ø×#Ñ#ˆØ×#Ñ#ˆØ—‘ˆØ—>‘>ˆÜˆÜ�<‰<˜7Ô"Ø ×(Ñ(ˆHØ ×(Ñ(‰HàˆHàð-$Ù”
ðß!Ùœá”JðØÙ&›j˜Ø (›?Ü!Ð"IÔJÙ(œNÙ(œNÙ"ô .×3Ñ3°CÓ8˜Ø#Ò+Ù& sžOá$œJð+Ù *¨3¤á (¦
øñ' •Jûñ& !)¥
ûÜ!ô Úðûäô $ß¤G¨A¨w¸Ó$:¼e¿k¹kÔ$IÝô
 —<’<ÜÐ4°aÔ8Ýð ×%Ñ%Ô'Ù˜A˜s—O“Oûð#$ús~   Á4D" Á<C8 ÂC8 ÂD" Â'D Â<*D Ã'D Ã/	D Ã8	DÄD" Ä	DÄD ÄDÄD" ÄDÄD" Ä"F"Ä-(FÅFÅ=FÆF"c                ó.   € ^ RI pVP                  4        R# )z€
Private API hook called when feeding data in the background thread
raises an exception.  For overriding by concurrent.futures.
N)Ú	tracebackÚ	print_exc)rÂ   r[   rÅ   s   && r+   rœ   ÚQueue._on_queue_feeder_error$  s   € ó 	Ø×ÑÖr.   )rD   rI   rH   r$   rG   rF   r   r>   r   rO   r   rM   r   r#   rK   rE   r!   r   ©r   rz   r‚   ) Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r,   r3   r8   r&   r%   r^   ri   rm   rq   rw   r{   r   rƒ   r‡   rŒ   r�   rW   Ústaticmethodrž   r¡   r›   rœ   ÚclassmethodÚtypesÚGenericAliasÚ__class_getitem__Ú__static_attributes__Ú__classdictcell__©Ú__classdict__s   @r+   r   r   !   sÀ   ø‡ € ô9ò(Aò
ò
%ô'ô
$ô*ò45ò ò-òò$òòòòò%ðN ñ3ó ð3ð ñó ðð ñ<$ó ð<$ð| ñó ðñ $ E×$6Ñ$6Ó7Ör.   c                   óL   a € ] tR tRt o R
R ltR tR tRR ltR tR t	R	t
V tR# )r   i:  c               óŠ   € \         P                  WVR 7       VP                  ^ 4      V n        VP	                  4       V n        R# ))r*   N)r   r,   Ú	SemaphoreÚ_unfinished_tasksrA   Ú_condr'   s   &&$r+   r,   ÚJoinableQueue.__init__<  s0   € Ü�‰�t¨#ˆÔ.Ø!$§¡¨qÓ!1ˆÔØ—]‘]“_ˆŽ
r.   c                óf   € \         P                  V 4      V P                  V P                  3,           # r0   )r   r3   rÚ   rÙ   r2   s   &r+   r3   ÚJoinableQueue.__getstate__A  s'   € Ü×!Ñ! $Ó'¨4¯:©:°t×7MÑ7MÐ*NÕNÐNr.   c                óZ   € \         P                  WR R 4       VRR  w  V n        V n        R # )Néþÿÿÿ)r   r8   rÚ   rÙ   r6   s   &&r+   r8   ÚJoinableQueue.__setstate__D  s+   € Ü×Ñ˜4 s¨ Ô,Ø-2°2°3¨ZÑ*ˆŒ
�DÖ*r.   Nc           	     ó4  € V P                   '       d   \        R V : R24      hV P                  P                  W#4      '       g   \        hV P
                  ;_uu_ 4        V P                  ;_uu_ 4        V P                  f   V P                  4        V P                  P                  V4       V P                  P                  4        V P
                  P                  4        RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; irR   )rH   rU   r#   rV   r   r>   rÚ   rE   rW   rD   rX   rÙ   rb   rY   rZ   s   &&&&r+   r^   ÚJoinableQueue.putH  s©   € Ø�<�<ˆ<Ü˜v d¡X¨ZÐ8Ó9Ð9Ø�y‰y× Ñ  ×0Ò0ÜˆJà�^�^‹^˜TŸZŸZ›ZØ�|‰|Ò#Ø×"Ñ"Ô$Ø�L‰L×Ñ Ô$Ø×"Ñ"×*Ñ*Ô,Ø�N‰N×!Ñ!Ô#÷ (�^‰^ŸZŸZú�^�^ˆ^ús%   ÁDÁ3A.C3	Ã!DÃ3DÃ>DÄD	c                óH  € V P                   ;_uu_ 4        V P                  P                  R 4      '       g   \        R4      hV P                  P                  P                  4       '       d   V P                   P                  4        RRR4       R#   + '       g   i     R# ; i)Fz!task_done() called too many timesN)rÚ   rÙ   rV   rU   ru   rv   Ú
notify_allr2   s   &r+   Ú	task_doneÚJoinableQueue.task_doneU  se   € Ø�Z�Z‹ZØ×)Ñ)×1Ñ1°%×8Ò8Ü Ð!DÓEÐEØ×%Ñ%×.Ñ.×7Ñ7×9Ò9Ø—
‘
×%Ñ%Ô'÷	 �Z�ZŠZús   •ABÁ,BÂB!	c                óð   € V P                   ;_uu_ 4        V P                  P                  P                  4       '       g   V P                   P	                  4        R R R 4       R #   + '       g   i     R # ; ir0   )rÚ   rÙ   ru   rv   r¯   r2   s   &r+   r¤   ÚJoinableQueue.join\  s@   € Ø�Z�Z‹ZØ×)Ñ)×2Ñ2×;Ñ;×=Ò=Ø—
‘
—‘Ô!÷ �Z�ZŠZús   •AA$Á$A5	)rÚ   rÙ   rÈ   r‚   )rÉ   rÊ   rË   rÌ   r,   r3   r8   r^   rå   r¤   rÒ   rÓ   rÔ   s   @r+   r   r   :  s)   ø‡ € ô%ò
Oò8ô$ò(÷"ð "r.   c                   ón   a € ] tR tRt o R tR tR tR tR tR t	R t
]! ]P                  4      tR	tV tR
# )r   ie  c               ó  € \         P                  ! R R7      w  V n        V n        VP	                  4       V n        V P                  P                  V n        \        P                  R8X  d
   RV n
        R# VP	                  4       V n
        R# )Fr   r   N)r   r   r   r   r   r   rN   rO   r   r    r!   )r(   r*   s   &$r+   r,   ÚSimpleQueue.__init__g  sW   € Ü%/§_¢_¸EÔ%BÑ"ˆŒ�d”lØ—h‘h“jˆŒØ—\‘\×&Ñ&ˆŒ
Ü�<‰<˜7Ô"ØˆDŽKàŸ(™(›*ˆDŽKr.   c                ón   € V P                   P                  4        V P                  P                  4        R # r0   )r   rƒ   r   r2   s   &r+   rƒ   ÚSimpleQueue.closep  s"   € Ø�‰×ÑÔØ�‰×ÑÖr.   c                ó,   € V P                  4       '       * # r0   rp   r2   s   &r+   rq   ÚSimpleQueue.emptyt  rs   r.   c                óŠ   € \         P                  ! V 4       V P                  V P                  V P                  V P
                  3# r0   )r   r1   r   r   r   r!   r2   s   &r+   r3   ÚSimpleQueue.__getstate__w  s/   € Ü×Ò Ô%Ø—‘˜dŸl™l¨D¯K©K¸¿¹ÐEÐEr.   c                ór   € Vw  V n         V n        V n        V n        V P                   P                  V n        R # r0   )r   r   r   r!   rN   rO   r6   s   &&r+   r8   ÚSimpleQueue.__setstate__{  s)   € ØAFÑ>ˆŒ�t”| T¤[°$´+Ø—\‘\×&Ñ&ˆŽ
r.   c                óÀ   € V P                   ;_uu_ 4        V P                  P                  4       pR R R 4       \        P	                  X4      #   + '       g   i     L%; ir0   )r   r   rL   re   rf   )r(   rg   s   & r+   ri   ÚSimpleQueue.get  s=   € Ø�[�[‹[Ø—,‘,×)Ñ)Ó+ˆC÷ ô ×$Ñ$ SÓ)Ð)÷ �[ús   •AÁA	c                ó  € \         P                  V4      pV P                  f   V P                  P	                  V4       R # V P                  ;_uu_ 4        V P                  P	                  V4       R R R 4       R #   + '       g   i     R # ; ir0   )re   r±   r!   r   rJ   r~   s   &&r+   r^   ÚSimpleQueue.put…  sU   € ä×#Ñ# CÓ(ˆØ�;‰;Òà�L‰L×#Ñ# CÖ(à——“Ø—‘×'Ñ'¨Ô,÷ ——’ús   ÁA;Á;B	)rO   r   r   r!   r   N)rÉ   rÊ   rË   rÌ   r,   rƒ   rq   r3   r8   ri   r^   rÎ   rÏ   rÐ   rÑ   rÒ   rÓ   rÔ   s   @r+   r   r   e  s<   ø‡ € ò%òò òFò'ò*ò-ñ $ E×$6Ñ$6Ó7Ör.   )r   r   r   )Ú__all__r   r   r@   rB   rd   rÏ   rŸ   r®   Úqueuer   r   Ú r   r   Ú	reductionÚForkingPicklerre   Úutilr	   r
   r   r   r   Úobjectr   r©   r   r   © r.   r+   Ú<module>r      su   ðò 4€ã 
Û 	Û Û Û Û Û Û ç å Ý Ø×#Ñ#×2Ñ2€ç HÕ HôL8ˆFô L8ñ^ ‹H€	ô%"�Eô %"ôV*8�&ö *8r.   