+
    NV-jÔ;  ã                   ó  € ^ RI t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIHt ^ RIt^RI	H
t
 ^RI	Ht . ROt]! ]R4      t]P                  ]P                   3tR tR]RR	 /t]P(                  R
8X  d7    ^ RIt^ RIt]! ]R4      '       d   ]P2                  ]R&   ]P4                  ]R&    ! R R]4      t ! R R]4      t]! 4       t]P@                  t ]PB                  t!]PD                  t"]PF                  t#R t$R t%R#   ] d    ^ RIt L“i ; i)é    N)Údeque)Úspawn)ÚutilÚpthread_sigmaskc                 ó   € \        R 4      h)z-noop should never be registered or cleaned up)ÚRuntimeError©Únames   &Ún/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/multiprocess/resource_tracker.pyÚcleanup_noopr   $   s   € Ü
ÐFÓ
GÐGó    ÚnoopÚdummyc                 ó   € R # ©N© r	   s   &r   Ú<lambda>r   )   s   € ™$r   ÚposixÚ
sem_unlinkÚ	semaphoreÚshared_memoryc                   ó   € ] tR t^=tRtR# )ÚReentrantCallErrorr   N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__static_attributes__r   r   r   r   r   =   s   † Ûr   r   c                   óÎ   a € ] tR t^At o R tR tR tRR lt]P                  ]P                  ]P                  3R ltR tR tR tR	 tR
 tRR ltR tR tR tR tR tRtV tR# )ÚResourceTrackerc                ó�   € \         P                  ! 4       V n        R V n        R V n        R V n        \        4       V n        RV n        R # )NT)	Ú	threadingÚRLockÚ_lockÚ_fdÚ_pidÚ	_exitcoder   Ú_reentrant_messagesÚ_use_simple_format©Úselfs   &r   Ú__init__ÚResourceTracker.__init__C   s9   € Ü—_’_Ó&ˆŒ
ØˆŒØˆŒ	ØˆŒÜ#(£7ˆÔ ð #'ˆÖr   c                ó   € \        R 4      h)z5Reentrant call into the multiprocess resource tracker)r   r*   s   &r   Ú_reentrant_call_errorÚ%ResourceTracker._reentrant_call_errorQ   s   € ô
 !ØCóEð 	Er   c                ó*   € V P                  R R7       R# )F)Úuse_blocking_lockN)Ú_stopr*   s   &r   Ú__del__ÚResourceTracker.__del__Y   s   € ð 	�
‰
 Uˆ
Ö+r   c                óŽ  € V'       d0   V P                   ;_uu_ 4        V P                  4        R R R 4       R # V P                   P                  RR7      p V P                  4        V'       d   V P                   P                  4        R # R #   + '       g   i     R # ; i  T'       d   T P                   P                  4        i i ; i)NF)Úblocking)r$   Ú_stop_lockedÚacquireÚrelease)r+   r2   Úacquireds   && r   r3   ÚResourceTracker._stop_   sˆ   € ßØ——“Ø×!Ñ!Ô#÷ ‘ð —z‘z×)Ñ)°5Ð)Ó9ˆHð)Ø×!Ñ!Ô#çØ—J‘J×&Ñ&Ö(ñ ÷ —�û÷ Ø—J‘J×&Ñ&Õ(ð ús   �BÁB ÂB	Â%Cc                óž  € V P                   P                  4       ^8”  d   V P                  4       hV P                  f   R# V P                  f   R# V! V P                  4       RV n         V! V P                  ^ 4      w  rERT n         T! T4      T n        R#   \
         d    RT n        RT n         R# i ; i  \         d    RT n         R# i ; i©é   N)r$   Ú_recursion_countr/   r%   r&   ÚChildProcessErrorr'   Ú
ValueError)r+   ÚcloseÚwaitpidÚwaitstatus_to_exitcodeÚ_Ústatuss   &&&&  r   r8   ÚResourceTracker._stop_lockedk   sÀ   € ð �:‰:×&Ñ&Ó(¨1Ô,Ø×,Ñ,Ó.Ð.Ø�8‰8ÒáØ�9‰9ÒÙñ 	ˆd�h‰hŒØˆŒð	Ù §	¡	¨1Ó-‰IˆAð ˆŒ	ð	"Ù3°FÓ;ˆDŽNøô !ô 	ØˆDŒIØ!ˆDŒNÚð	ûô ô 	"à!ˆD�Nð	"ús$   Á*B ÂB6 ÂB3Â2B3Â6CÃCc                ó:   € V P                  4        V P                  # r   )Úensure_runningr%   r*   s   &r   ÚgetfdÚResourceTracker.getfdŽ   s   € Ø×ÑÔØ�x‰xˆr   c                ó"   € V P                  4       # )zœMake sure that resource tracker process is running.

This can be run from any process.  Usually a child process will use
the resource created by its parent.)Ú_ensure_running_and_writer*   s   &r   rJ   ÚResourceTracker.ensure_running’   s   € ð
 ×-Ñ-Ó/Ð/r   c                ó  € \         P                  ! V P                  4        V P                  e"   \         P                  ! V P                  ^ 4       R T n        R T n        R T n        \        P                  ! R4       R #   \
         d     L:i ; i)NzUresource_tracker: process died unexpectedly, relaunching.  Some resources might leak.)	ÚosrC   r%   r&   rD   rA   r'   ÚwarningsÚwarnr*   s   &r   Ú_teardown_dead_processÚ&ResourceTracker._teardown_dead_process™   ss   € Ü
�Š�—‘Ôð	ð �y‰yÒ$Ü—
’
˜4Ÿ9™9 aÔ(ð ˆŒØˆŒ	ØˆŒä�Šð Aö 	Bøô !ô 	áð	ús   ¢/A> Á>BÂBc                óH  € . p VP                  \        P                  P                  4       4       \
        P                  ! 4       w  r# VP                  V4       \        P                  ! 4       pV.\        P                  ! 4       OR NRV R2NpRp \        '       d*   \        P                  ! \        P                  \        4      p\        P                   ! WEV4      pVe&   \        P                  ! \        P"                  V4       Y0n        Ypn         \
        P(                  ! T4       R#   \         d     EL	i ; i  Te'   \        P                  ! \        P"                  T4       i i ; i   \
        P(                  ! T4       h ; i  \
        P(                  ! T4       i ; i)z-cz4from multiprocess.resource_tracker import main;main(Ú)N)ÚappendÚsysÚstderrÚfilenoÚ	ExceptionrQ   Úpiper   Úget_executabler   Ú_args_from_interpreter_flagsÚ_HAVE_SIGMASKÚsignalr   Ú	SIG_BLOCKÚ_IGNORED_SIGNALSÚspawnv_passfdsÚSIG_SETMASKr%   r&   rC   )r+   Úfds_to_passÚrÚwÚexeÚargsÚprev_sigmaskÚpids   &       r   Ú_launchÚResourceTracker._launch¬   s[  € Øˆð	Ø×ÑœsŸz™z×0Ñ0Ó2Ô3ô �wŠw‹y‰ˆð	Ø×Ñ˜qÔ!ä×&Ò&Ó(ˆCàðä×2Ò2Ó4ðð ðð GÀqÀcÈÐKð	ˆDð  ˆLðMß “=Ü#)×#9Ò#9¼&×:JÑ:JÔL\Ó#]�LÜ×)Ò)¨#°[ÓA�àÒ+Ü×*Ò*¬6×+=Ñ+=¸|ÔLð
 ŒHØ�Iä�HŠH�QŽKøôE ô 	Úð	ûð2  Ò+Ü×*Ò*¬6×+=Ñ+=¸|ÕLð ,ûð	Ü�HŠH�QŒKØûô
 �HŠH�Q�KúsI   „-D, Á	AE- ÂAD> Ã)E- ÄF	 Ä,D;Ä:D;Ä>,E*Å*E- Å-FÆF	 Æ	F!c                ó�   € V P                   '       d   R# \        P                  ! RRRR/RR
R7      R,           P                  R	4      # )zReturn a probe message.s   PROBE:0:noop
ÚcmdÚPROBEÚrtyper   T©Úensure_asciiÚ
separatorsÚ
Úascii©Ú,Ú:)r)   ÚjsonÚdumpsÚencoder*   s   &r   Ú_make_probe_messageÚ#ResourceTracker._make_probe_messageÔ   sI   € à×"×"Ð"Ù$ä�JŠJØ˜ ¨&Ð1Ø!Ø%ôð
 õ÷ ‰&�‹/ð	r   Nc                óº  € V P                   ;_uu_ 4        V P                   P                  4       ^8”  d:   Vf   V P                  4       hV P                  P	                  V4      uuRRR4       # V P
                  e-   Vf   V P                  4       pMTp V P                  V4       RpMV P                  4        RRR4         V P                  P                  4       pT P                  T4       K/    \         d$    T P                  4        T P                  4         Lwi ; i  + '       g   i     Lp; i  \         d     Mi ; iTe   T P                  T4       R# R# r>   )r$   r@   r/   r(   rX   r%   r~   Ú_writeÚOSErrorrT   rm   ÚpopleftÚ
IndexError)r+   ÚmsgÚto_sendÚreentrant_msgs   &&  r   rN   Ú)ResourceTracker._ensure_running_and_writeá   s  € Ø�Z�Z‹ZØ�z‰z×*Ñ*Ó,¨qÔ0à’;Ø×4Ñ4Ó6Ð6Ø×/Ñ/×6Ñ6°sÓ;÷ ŠZð �x‰xÒ#à’;Ø"×6Ñ6Ó8‘Gà!�Gð#Ø—K‘K Ô(ð
 ‘à—‘”÷+ ð. ðØ $× 8Ñ 8× @Ñ @Ó B�ð �K‰K˜Ö&øô ô #Ø×/Ñ/Ô1Ø—L‘L–Nð#ú÷ �Zûô4 ô Ùðúð Š?Ø�K‰K˜Öñ sH   •AD Á.%D ÂC/Â%D ÃD3 Ã/+DÄD ÄDÄD Ä D0	Ä3EÅ Ec                óŠ   €  \         P                  ! V P                  V P                  4       4       R#   \         d     R# i ; i)z;Check that the pipe has not been closed by sending a probe.TF)rQ   Úwriter%   r~   r‚   r*   s   &r   Ú_check_aliveÚResourceTracker._check_alive  s=   € ð	ô �HŠH�T—X‘X˜t×7Ñ7Ó9Ô:ñ øô ô 	Úð	ús   ‚/3 ³AÁAc                ó*   € V P                  RW4       R# )z0Register name of resource with resource tracker.ÚREGISTERN©Ú_send©r+   r
   rr   s   &&&r   ÚregisterÚResourceTracker.register  s   € à�
‰
�:˜tÖ+r   c                ó*   € V P                  RW4       R# )z2Unregister name of resource with resource tracker.Ú
UNREGISTERNr�   r‘   s   &&&r   Ú
unregisterÚResourceTracker.unregister  s   € à�
‰
�< Ö-r   c                ó˜   € \         P                  ! V P                  V4      pV\        V4      8X  g   Q R V: R\        V4      : 24       hR# )znbytes=z != len(msg)=N)rQ   rŠ   r%   Úlen)r+   r…   Únbytess   && r   r�   ÚResourceTracker._write  s>   € Ü—’˜$Ÿ(™( CÓ(ˆØœ˜S›Ô!Ð> g f¡Y¨n´3°s³8±+Ð#>Ó>Ò!r   c                óv  € V P                   '       dP   R V9  dI   V RV RV R 2P                  R4      p\        V4      R8”  d   \        R4      hV P	                  V4       R# VP                  RR4      p\        V4      ^ÿ8”  d   \        R4      h\
        P                  ! V4      P                  R4      pR	VR
VRV/p\        P                  ! VRRR7      R ,           P                  R4      p\        V4      R8:  g   Q R\        V4       R24       hVP                  R4      '       g   Q hV P	                  V4       R# )rv   rz   rw   i   zmsg too longNúutf-8Úsurrogateescapez+shared memory name too long (max 255 bytes)rp   rr   Úbase64_nameTrs   z"internal error: message too long (z bytes)ó   {rx   )r)   r}   r™   rB   rN   Úbase64Úurlsafe_b64encodeÚdecoder{   r|   Ú
startswith)r+   rp   r
   rr   r…   ÚbÚb64Úpayloads   &&&&    r   r�   ÚResourceTracker._send  s#  € Ø×"×"Ð" t°4Ô'7Ø�E˜˜4˜&  % ¨Ð+×2Ñ2°7Ó;ˆCÜ�3‹x˜#Œ~ô ! Ó0Ð0Ø×*Ñ*¨3Ô/Ùð �K‰K˜Ð!2Ó3ˆÜˆq‹6�CŒ<ÜÐJÓKÐKÜ×&Ò& qÓ)×0Ñ0°Ó9ˆà˜#˜w¨¨}¸cÐBˆÜ�zŠz˜'°ÀÔLÈtÕS×[Ñ[Ð\cÓdˆô �3‹x˜3ŒÐVÐ"DÄSÈÃXÀJÈgÐ VÓVˆØ�~‰~˜d×#Ò#Ð#Ð#à×&Ñ& sÖ+r   )r'   r%   r$   r&   r(   r)   )Tr   )r   r   r   r   r,   r/   r4   r3   rQ   rC   rD   rE   r8   rK   rJ   rT   rm   r~   rN   r‹   r’   r–   r�   r�   r   Ú__classdictcell__)Ú__classdict__s   @r   r    r    A   sx   ø‡ € ò'òEò,ô
)ð �h‰hØ—
‘
Ø!×8Ñ8ô	!"òFò0òBò&&òPôòB	ò,ò.ò?÷,ð ,r   r    c                 óØ  € V P                  R 4      '       dÄ    \        P                  ! V P                  R4      4      pTR,          pTR,          pTP                  RR4      p\        T\        4      '       d-   \        T\        4      '       d   \        T\        4      '       g   \        RT: 24      h \        P                  ! T4      P                  R	R
4      pMGV P                  4       P                  R4      P                  R^R7      w  r7VP                  R^R7      w  rdW4V3#   \         d   p\        RT : 24      ThRp?ii ; i  \
         d   p\        RT: 24      ThRp?ii ; i)r    rw   z$malformed resource_tracker message: Nrp   rr   rŸ   Ú z#malformed resource_tracker fields: r�   rž   z(malformed resource_tracker base64_name: rz   )Úmaxsplit)r¤   r{   Úloadsr£   r\   rB   ÚgetÚ
isinstanceÚstrr¡   Úurlsafe_b64decodeÚstripÚsplitÚrsplit)ÚlineÚobjÚerp   rr   r¦   r
   Úrests   &       r   Ú_decode_messagerº   A  s=  € Ø‡��t×Òð	XÜ—*’*˜TŸ[™[¨Ó1Ó2ˆCð �%�jˆØ�G•ˆØ�w‰w�} bÓ)ˆä˜#œs×#Ò#¬:°e¼S×+AÒ+AÌÐTWÔY\×I]ÒI]ÝÊÐMÓNÐNð	[Ü×+Ò+¨CÓ0×7Ñ7¸ÐARÓS‰Dð —J‘J“L×'Ñ'¨Ó0×6Ñ6°sÀQÐ6ÓG‰	ˆØ—k‘k #°�kÓ2‰ˆØ�tÐÐøô# ô 	XÝÊÐOÓPÐVWÐWûð	Xûô ô 	[ÝÊSÐRÓSÐYZÐZûð	[ús/   ™%D& Â4&E	 Ä&EÄ1EÅEÅ	E)ÅE$Å$E)c                óÆ  € \         P                   ! \         P                  \         P                  4       \         P                   ! \         P                  \         P                  4       \        '       d*   \         P
                  ! \         P                  \        4       \        P                  \        P                  3 F  p VP                  4        K  	  \        P                  4        Uu/ uF  q"\        4       bK  	  pp^ p \!        V R4      ;_uu_ 4       pV F–  p \#        V4      w  rbp\        P%                  VR4      pVf   \'        RV RV 24      hVR8X  d   W2,          P)                  V4       K]  VR8X  d   W2,          P+                  V4       K}  VR8X  d   K†  \-        RV,          4      h	  RRR4       VP3                  4        F_  w  r)V	'       d5    ^pVR	8X  d   M)\4        P6                  ! R
\9        V	4       RV RV	 24        V	 F  p  \        V,          ! V4       K  	  Ka  	  \        P:                  ! V4       R#   \         d     EK™  i ; iu upi   \         d:    ^p \        P.                  ! \        P0                  ! 4       !    EK~       EK…  ; ii ; i  + '       g   i     Lú; i  \         d     L¹i ; i  \         d+   p
^p\4        P6                  ! RT: RT
: 24        Rp
?
LÓRp
?
ii ; i  i ; i  TP3                  4        F®  w  r)T	'       dF    ^pTR	8X  d   M:\4        P6                  ! R
\9        T	4       RT RT	 24       M  \         d     Mi ; iT	 FV  p  \        T,          ! T4       M8  \         d+   p
^p\4        P6                  ! RT: RT
: 24        Rp
?
MRp
?
ii ; iKS    i ; i	  K°  	  \        P:                  ! T4       i ; i)zRun resource tracker.ÚrbNzCannot register z. for automatic cleanup: unknown resource type rŽ   r•   rq   zunrecognized command %rr   z%resource_tracker: There appear to be z leaked z" objects to clean up at shutdown: zresource_tracker: z: )ra   ÚSIGINTÚSIG_IGNÚSIGTERMr`   r   ÚSIG_UNBLOCKrc   rY   ÚstdinÚstdoutrC   r\   Ú_CLEANUP_FUNCSÚkeysÚsetÚopenrº   r¯   rB   ÚaddÚremover   Ú
excepthookÚexc_infoÚitemsrR   rS   r™   Úexit)ÚfdÚfrr   ÚcacheÚ	exit_coder¶   rp   r
   Úcleanup_funcÚrtype_cacher¸   s   &          r   ÚmainrÓ   Y  sf  € ô ‡M‚M”&—-‘-¤§¡Ô0Ü
‡M‚M”&—.‘.¤&§.¡.Ô1ßƒ}Ü×Òœv×1Ñ1Ô3CÔDä�i‰iœŸ™Ó$ˆð	Ø�G‰GŽIñ %ô (6×':Ñ':Ô'<Ó=Ñ'<˜e”C“EŠ\Ñ'<€EÐ=Ø€Ið9ä�"�d�^Œ^˜qÛ�ðÜ'6°tÓ'<Ñ$�C Ü#1×#5Ñ#5°e¸TÓ#B�LØ#Ò+Ü(Ø.¨t¨fð 55Ø5:°Gð=ó>ð >ð ˜jÔ(Ø�×(Ñ(¨Ö.Ø Ô,Ø�×+Ñ+¨DÖ1Ø œÙä*Ð+DÀsÕ+JÓKÐKñ! ÷ ð4 #(§+¡+¦-ÑˆEßðØ !�IØ Ô'ð ä ŸšØCÜ" ;Ó/Ð0°¸¸ð @5Ø5@°MðCõó $�ððNÜ& uÖ-¨dÔ3ñ
 ó $ñ! #0ô: 	�Š�Öøô ô 	Ûð	üò >øô. !ô Ø !�IðÜŸš¬¯ª«Ö7øðÜúðú÷% �^ûôP !ô Ùðûô %ô NØ$%˜	Ü Ÿ›ÃDÊ!Ð&L×MÑMûðNûð ûð7 #(§+¡+¦-ÑˆEßðØ !�IØ Ô'ð ä ŸšØCÜ" ;Ó/Ð0°¸¸ð @5Ø5@°MðCõøô
 !ô Ùðúã#�ððNÜ& uÖ-¨dÕ3øÜ$ô NØ$%˜	Ü Ÿ›ÃDÊ!Ð&L×MÑMûðNúñ ø�Dúó $ñ! #0ô: 	�Š�ÕúsK  Ã IÃ*IÄL ÄJ%ÄAIÅ4J%Å6IÆJ%ÆIÆJ%ÆIÆ1J%Æ3L Ç	J8Ç#(J8ÈK	ÉIÉIÉJ"	É,'JÊJ%ÊJÊJ"	ÊJ%ÊJ"	Ê"J%Ê%J5	Ê0L Ê8KËKË	K>Ë K9Ë4LË9K>Ë>LÌLÌO Ì%	MÌ.O Ì/(MÍO ÍM&	Í#O Í%M&	Í&O Í0NÎN>ÎN9Î N4Î/N>Î4N9Î9N>Î<O Î>O Ï  O )rJ   r’   r–   )&r¡   rQ   ra   rY   r"   rR   Úcollectionsr   r{   r¬   r   r   Ú__all__Úhasattrr`   r½   r¿   rc   r   rÃ   r
   Ú_multiprocessÚ_multiprocessingÚImportErrorÚ_posixshmemr   Ú
shm_unlinkr   r   Úobjectr    Ú_resource_trackerrJ   r’   r–   rK   rº   rÓ   r   r   r   Ú<module>rÞ      s!  ðó$ Û 	Û Û 
Û Û Ý ã å Ý â
6€á˜Ð 1Ó2€Ø—M‘M 6§>¡>Ð2Ð òHð ˆLØÑð€ð
 ‡7�7ˆgÔð Û0ó ñ Ð ×.Ò.Ø&6×&AÑ&Aˆ�{Ñ#Ø&1×&<Ñ&<€N�?Ñ#ô	˜ô 	ôw,�fô w,ñr $Ó%Ð Ø"×1Ñ1€Ø×%Ñ%€Ø×)Ñ)€
Ø×Ñ€òô0JøðU	 ô  Ýð ús   Á0C: Ã:DÄD