+
    NV-j&  ã                   ó²  € ^ RI H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 . R$Ot]
P                  R8H  ;'       g6    ]! ]	R4      ;'       d%    ]! ]	R4      ;'       d    ]! ]	P                  R4      t ! R	 R]P"                  4      t]P&                  tR%R
 lt]
P                  R8X  d.   ]. R&O,          t^ RItR'RR/R lltR tR tR t ! R R]4      tM]. R(O,          t^ RItR tR tR tR tR tR t  ! R R4      t!]! ]"! ]!! 4       PF                  4      ] 4       R t$]! ]"! ]%PL                  4      ]$4       ]! ]"! ]'PP                  4      ]$4       R t)R t*]! ]PV                  ])4       ]
P                  R8X  d   R t,R t-]! ]	P                  ],4       MR t,R  t-]! ]	P                  ],4        ! R! R"]R#7      t.R#   ] d	    ^ RIt EL¹i ; i))é    )ÚABCMetaN)ÚcontextÚForkingPicklerÚwin32ÚCMSG_LENÚ
SCM_RIGHTSÚsendmsgc                   óŽ   a a€ ] tR t^$t oRt/ t]P                  tV 3R lt	]
R 4       t]
RR l4       t]P                  tRtVtV ;t# )r   z&Pickler subclass used by multiprocess.c                ó°   <€ \         SV `  ! V/ VB  V P                  P                  4       V n        V P                  P                  V P                  4       R # ©N)ÚsuperÚ__init__Ú_copyreg_dispatch_tableÚcopyÚdispatch_tableÚupdateÚ_extra_reducers)ÚselfÚargsÚkwdsÚ	__class__s   &*,€Úg/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/multiprocess/reduction.pyr   ÚForkingPickler.__init__)   sF   ø€ Ü‰Ò˜$Ð' $Ò'Ø"×:Ñ:×?Ñ?ÓAˆÔØ×Ñ×"Ñ" 4×#7Ñ#7Ö8ó    c                ó"   € W P                   V&   R# )z&Register a reduce function for a type.N)r   )ÚclsÚtypeÚreduces   &&&r   ÚregisterÚForkingPickler.register.   s   € ð %+×Ñ˜DÓ!r   c                ó‚   € \         P                  ! 4       pV ! WR.VO5/ VB P                  V4       VP                  4       # r   )ÚioÚBytesIOÚdumpÚ	getbuffer)r   ÚobjÚprotocolr   r   Úbufs   &&&*, r   ÚdumpsÚForkingPickler.dumps3   s6   € ä�jŠj‹lˆÙˆCÐ)˜DÒ) DÑ)×.Ñ.¨sÔ3Ø�}‰}‹Ðr   )r   r   )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r   Úcopyregr   r   r   Úclassmethodr   r)   ÚpickleÚloadsÚ__static_attributes__Ú__classdictcell__Ú__classcell__)r   Ú__classdict__s   @@r   r   r   $   sS   ù‡ € Ù0Ø€OØ%×4Ñ4Ðõ9ð
 ñ+ó ð+ð óó ðð
 �L‰L‡E€Er   c                óB   € \        W.VO5/ VB P                  V 4       R# )z3Replacement for pickle.dump() using ForkingPickler.N)r   r$   )r&   Úfiler'   r   r   s   &&&*,r   r$   r$   =   s   € ä�4Ð1 DÒ1¨DÑ1×6Ñ6°sÖ;r   Ú	DupHandleÚsource_processc               ó”   € \         P                  ! 4       pVf   TpVf   Tp\         P                  ! W0V^ V\         P                  4      # )z<Duplicate a handle.  (target_process is a handle not a pid!))Ú_winapiÚGetCurrentProcessÚDuplicateHandleÚDUPLICATE_SAME_ACCESS)ÚhandleÚtarget_processÚinheritabler;   Úcurrent_processs   &&&$ r   Ú	duplicaterE   J   sM   € ô "×3Ò3Ó5ˆØÒ!Ø,ˆNØÒ!Ø,ˆNÜ×&Ò&Ø NØˆ{œG×9Ñ9ó;ð 	;r   c           	     óR  € \         P                  ! \         P                  RV 4      p \         P                  ! W!\         P                  ! 4       ^ R\         P
                  \         P                  ,          4      \         P                  ! V4       #   \         P                  ! T4       i ; i)z5Steal a handle from process identified by source_pid.F)r=   ÚOpenProcessÚPROCESS_DUP_HANDLEr?   r>   r@   ÚDUPLICATE_CLOSE_SOURCEÚCloseHandle)Ú
source_pidrA   Úsource_process_handles   && r   Ústeal_handlerM   V   s|   € ä '× 3Ò 3Ü×&Ñ&¨¨zó!;Ðð	7Ü×*Ò*Ø%Ü×)Ò)Ó+¨Q°Ü×-Ñ-´×0NÑ0NÕNóPô
 ×ÒÐ 5Õ6øŒG×ÒÐ 5Õ6ús   ¨AB ÂB&c                ó^   € \        V\        P                  V4      pV P                  V4       R# ©z&Send a handle over a local connection.N)r:   r=   r@   Úsend)ÚconnrA   Údestination_pidÚdhs   &&& r   Úsend_handlerT   b   s!   € ä�vœw×<Ñ<¸oÓNˆØ�	‰	�"Žr   c                ó>   € V P                  4       P                  4       # )ú)Receive a handle over a local connection.)ÚrecvÚdetach)rQ   s   &r   Úrecv_handlerY   g   s   € à�y‰y‹{×!Ñ!Ó#Ð#r   c                   ó4   a € ] tR t^kt o RtRR ltR tRtV tR# )r:   zPicklable wrapper for a handle.Nc                ód  € Vf   \         P                  ! 4       p\        P                  ! \        P                  RV4      p \        P
                  ! \        P                  ! 4       WVR^ 4      V n        \        P                  ! V4       W n	        W0n
        R #   \        P                  ! T4       i ; i©NF)ÚosÚgetpidr=   rG   rH   r?   r>   Ú_handlerJ   Ú_accessÚ_pid)r   rA   ÚaccessÚpidÚprocs   &&&& r   r   ÚDupHandle.__init__m   s†   € ØŠ{ô —i’i“k�Ü×&Ò&¤w×'AÑ'AÀ5È#ÓNˆDð*Ü&×6Ò6Ü×-Ò-Ó/Ø &¨%°ó 4�”ô ×#Ò# DÔ)Ø!ŒLØŽIøô ×#Ò# DÕ)ús   Á2B ÂB/c                óÄ  € V P                   \        P                  ! 4       8X  d   V P                  # \        P
                  ! \        P                  RV P                   4      p \        P                  ! WP                  \        P                  ! 4       V P                  R\        P                  4      \        P                  ! V4       #   \        P                  ! T4       i ; i)z1Get the handle.  This should only be called once.F)ra   r]   r^   r_   r=   rG   rH   r?   r>   r`   rI   rJ   )r   rd   s   & r   rX   ÚDupHandle.detach|   s—   € ð �y‰yœBŸIšI›KÔ'à—|‘|Ð#ä×&Ò&¤w×'AÑ'AÀ5Ø'+§y¡yó2ˆDð*Ü×.Ò.ØŸ,™,¬×(AÒ(AÓ(CØ—L‘L %¬×)GÑ)GóIô ×#Ò# DÕ)ø”×#Ò# DÕ)ús   Á"AC ÃC)r`   r_   ra   r   )	r+   r,   r-   r.   r/   r   rX   r4   r5   ©r7   s   @r   r:   r:   k   s   ø‡ € Ù-ô	÷	*ð 	*r   c                ó  € \         P                   ! RV4      p\        \        V4      R,          .4      pV P                  V.\        P
                  \        P                  V3.4       V P                  ^4      R8w  d   \        R4      hR# )z,Send an array of fds over an AF_UNIX socket.Úié   ó   Az%did not receive acknowledgement of fdN)	ÚarrayÚbytesÚlenr	   ÚsocketÚ
SOL_SOCKETr   rW   ÚRuntimeError)ÚsockÚfdsÚmsgs   && r   Úsendfdsrv   ‘   sn   € ä�kŠk˜#˜sÓ#ˆÜ”S˜“X •^Ð$Ó%ˆØ�‰�c�Uœf×/Ñ/´×1BÑ1BÀCÐHÐIÔJØ�9‰9�Q‹<˜4ÔÜÐFÓGÐGñ  r   c                ó  € \         P                   ! R4      pVP                  V,          pV P                  ^\        P                  ! V4      4      w  rErgV'       g   V'       g   \
        h V P                  R4       \        V4      ^8w  d   \        R\        V4      ,          4      hV^ ,          w  r‰p
V\        P                  8X  d¢   V	\        P                  8X  d�   \        V
4      VP                  ,          ^ 8w  d   \        hVP                  V
4       \        V4      R,          V^ ,          8w  d,   \        RP                  \        V4      V^ ,          4      4      h\        V4      # \        R4      h  \        \         3 d     Li ; i)z/Receive an array of fds over an AF_UNIX socket.rj   rl   zreceived %d items of ancdatark   z Len is {0:n} but msg[0] is {1!r}zInvalid data received)rm   ÚitemsizeÚrecvmsgrp   Ú
CMSG_SPACEÚEOFErrorrP   ro   rr   rq   r   Ú
ValueErrorÚ	frombytesÚAssertionErrorÚformatÚlistÚ
IndexError)rs   ÚsizeÚaÚ
bytes_sizeru   ÚancdataÚflagsÚaddrÚ
cmsg_levelÚ	cmsg_typeÚ	cmsg_datas   &&         r   Úrecvfdsr‹   ™   sA  € ä�KŠK˜ÓˆØ—Z‘Z $Õ&ˆ
Ø$(§L¡L°´F×4EÒ4EÀjÓ4QÓ$RÑ!ˆ�eßŸ7ÜˆNð	ð
 �I‰I�dŒOÜ�7‹|˜qÔ Ü"Ð#AÜ#& w£<õ$0ó 1ð 1à/6°q­zÑ,ˆJ 9Øœf×/Ñ/Ô/ØœV×.Ñ.Ô.Ü�y“> A§J¡JÕ.°!Ô3Ü$Ð$Ø—‘˜IÔ&Ü�q“6˜C•< 3 q¥6Ô)Ü(Ø:×AÑAÜ ›F C¨¥Fó,ó-ð -ô ˜A“w�ô Ð2Ó3Ð3øô œJÐ'ô 	Ùð	ús   Á*C=E3 Å3FÆFc                óì   € \         P                  ! V P                  4       \         P                  \         P                  4      ;_uu_ 4       p\        W1.4       RRR4       R#   + '       g   i     R# ; irO   )rp   ÚfromfdÚfilenoÚAF_UNIXÚSOCK_STREAMrv   )rQ   rA   rR   Úss   &&& r   rT   rT   ¸   sB   € ä�]Š]˜4Ÿ;™;›=¬&¯.©.¼&×:LÑ:L×MÔMÐQRÜ�A�xÔ ÷ N×M×MÒMús   ÁA"Á"A3	c                óú   € \         P                  ! V P                  4       \         P                  \         P                  4      ;_uu_ 4       p\        V^4      ^ ,          uuRRR4       #   + '       g   i     R# ; i)rV   N)rp   r�   rŽ   r�   r�   r‹   )rQ   r‘   s   & r   rY   rY   ½   sF   € ä�]Š]˜4Ÿ;™;›=¬&¯.©.¼&×:LÑ:L×MÔMÐQRÜ˜1˜a“= Õ#÷ N×M×MÓMús   ÁA)Á)A:	c                óÐ   € \         P                  ! 4       pVe!   VP                  VP                  V 4      4      # \        '       d   ^RIHp VP                  V 4      # \        R4      h)zReturn a wrapper for an fd.)Úresource_sharerz&SCM_RIGHTS appears not to be available)r   Úget_spawning_popenÚDupFdÚduplicate_for_childÚHAVE_SEND_HANDLEÚ r”   r|   )ÚfdÚ	popen_objr”   s   &  r   r–   r–   Â   sV   € ä×.Ò.Ó0ˆ	ØÒ Ø—?‘? 9×#@Ñ#@ÀÓ#DÓEÐEßÓÝ)Ø"×(Ñ(¨Ó,Ð,äÐEÓFÐFr   c                 ó¾   € V P                   f)   \        V P                  V P                  P                  33# \        V P                   V P                  P                  33# r   )Ú__self__Úgetattrr   Ú__func__r+   ©Úms   &r   Ú_reduce_methodr¢   Ñ   sH   € Ø‡z�zÒÜ˜Ÿ™ a§j¡j×&9Ñ&9Ð:Ð:Ð:ä˜Ÿ™ Q§Z¡Z×%8Ñ%8Ð9Ð9Ð9r   c                   ó&   a € ] tR t^Öt o R tRtV tR# )Ú_Cc                ó   € R # r   © )r   s   &r   ÚfÚ_C.f×   s   € Ùr   r¦   N)r+   r,   r-   r.   r§   r4   r5   rh   s   @r   r¤   r¤   Ö   s   ø‡ € ÷ð r   r¤   c                 ó>   € \         V P                  V P                  33# r   )rž   Ú__objclass__r+   r    s   &r   Ú_reduce_method_descriptorr«   Ü   s   € Ü�Q—^‘^ Q§Z¡ZÐ0Ð0Ð0r   c                 óh   € \         V P                  V P                  V P                  ;'       g    / 33# r   )Ú_rebuild_partialÚfuncr   Úkeywords)Úps   &r   Ú_reduce_partialr±   â   s(   € Ü˜aŸf™f a§f¡f¨a¯j©j×.>Ð.>¸BÐ?Ð?Ð?r   c                 ó6   € \         P                  ! V .VO5/ VB # r   )Ú	functoolsÚpartial)r®   r   r¯   s   &&&r   r­   r­   ä   s   € Ü×Ò˜TÐ5 DÒ5¨HÑ5Ð5r   c                 ó,   € ^RI Hp \        V! V 4      33# )é   )Ú	DupSocket)r”   r·   Ú_rebuild_socket)r‘   r·   s   & r   Ú_reduce_socketr¹   í   s   € Ý.Ü¡¨1£ Ð/Ð/r   c                 ó"   € V P                  4       # r   )rX   )Údss   &r   r¸   r¸   ð   s   € Ø�y‰y‹{Ðr   c                 ó†   € \        V P                  4       4      p\        WP                  V P                  V P
                  33# r   )r–   rŽ   r¸   Úfamilyr   Úproto)r‘   Údfs   & r   r¹   r¹   õ   s0   € Ü�1—8‘8“:ÓˆÜ §X¡X¨q¯v©v°q·w±wÐ ?Ð?Ð?r   c                 óR   € V P                  4       p\        P                  ! WW4R 7      # ))rŽ   )rX   rp   )r¿   r½   r   r¾   rš   s   &&&& r   r¸   r¸   ø   s   € Ø�Y‰Y‹[ˆÜ�}Š}˜V¨5Ô<Ð<r   c                   óŽ   a € ] tR t^þt o Rt]t]t]t]t]	t	]
P                  R8X  d   ]t]t]tM]t]t]t]t]t]t]t]tR tRtV tR# )ÚAbstractReducerz’Abstract base class for use in implementing a Reduction class
suitable for use in replacing the standard reduction mechanism
used in multiprocess.r   c                óp  € \        \        \        4       P                  4      \        4       \        \        \
        P                  4      \        4       \        \        \        P                  4      \        4       \        \        P                  \        4       \        \        P                  \        4       R # r   )r   r   r¤   r§   r¢   r€   Úappendr«   ÚintÚ__add__r³   r´   r±   rp   r¹   )r   r   s   &*r   r   ÚAbstractReducer.__init__  s\   € Ü””b“d—f‘f“œ~Ô.Ü””d—k‘kÓ"Ô$=Ô>Ü””c—k‘kÓ"Ô$=Ô>Ü”×"Ñ"¤OÔ4Ü”—‘¤Ö/r   r¦   N)r+   r,   r-   r.   r/   r   r   r$   rT   rY   ÚsysÚplatformrM   rE   r:   rv   r‹   r–   r¢   r«   r­   r¹   r¸   r   r4   r5   rh   s   @r   rÂ   rÂ   þ   st   ø‡ € ñð $€NØ€HØ€DØ€KØ€Kà
‡|�|�wÔØ#ˆØˆ	Ø‰	àˆØˆØˆà#€NØ 9ÐØ'ÐØ#€NØ%€O÷0ð 0r   rÂ   )Ú	metaclass)rT   rY   r   r   r$   r   )r:   rE   rM   r\   )r–   rv   r‹   )/Úabcr   r0   r³   r"   r]   Údillr2   ÚImportErrorrp   rÈ   r™   r   Ú__all__rÉ   Úhasattrr˜   ÚPicklerr   r   r$   r=   rE   rM   rT   rY   Úobjectr:   rm   rv   r‹   r–   r¢   r¤   r   r§   r«   r€   rÄ   rÅ   rÆ   r±   r­   r´   r¹   r¸   rÂ   r¦   r   r   Ú<module>rÒ      sâ  ðõ Û Û Û 	Û 	ðÛó Û 
å â
N€ð —L‘L GÑ+÷ 8ð 8Ù˜V ZÓ0÷ 7ð 7Ù˜V \Ó2÷7ð 7á˜VŸ]™]¨IÓ6ð ô�V—^‘^ô ð. ×"Ñ"€ô<ð ‡<�<�7ÔàÒ9Õ9€GÛñ
;Ø$(õ
;ò
7òò
$ô*�Fõ *ðF Ò.Õ.€GÛòHò4ò>!ò
$ò
	Gò:÷
ñ ñ 	‰‰b‹d�f‰f‹�~Ô &ò1á ‰ˆd�k‰kÓ	Ð5Ô 6Ù ‰ˆc�k‰kÓ	Ð5Ô 6ò@ò6á ˆ×	Ñ	˜OÔ ,ð ‡<�<�7Ôò0òáˆV�]‰]˜NÕ+ò@ò=ñ ˆV�]‰]˜NÔ+ô0 ÷ 0øð[ ô Þðús   ˜G ÇGÇG