+
    NV-j.  ã                   ó(  € ^ RI t ^ RIt^ RIt^RIHt ^RIHt R)t ! R R]4      t ! R R]4      t	 ! R R	]4      t
 ! R
 R]4      t ! R R]4      t ! R R]P                  4      t ! R R]4      t]P"                  R8w  d»    ! R R]P                  4      t ! R R]P                  4      t ! R R]P                  4      t ! R R]4      t ! R R]4      t ! R R]4      tR]! 4       R ]! 4       R!]! 4       /t]P2                  '       d"   ]P"                  R"8w  d   ]! ]R,          4      tMH]! ]R,          4      tM8 ! R# R]P                  4      t ! R$ R]4      tR ]! 4       /t]! ]R ,          4      tR% t]P8                  ! 4       tR& tR' tR( t R# )*é    N)Úprocess)Ú	reductionc                   ó   € ] tR t^tRtR# )ÚProcessError© N©Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__static_attributes__r   ó    Úe/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/multiprocess/context.pyr   r      ó   † Ûr   r   c                   ó   € ] tR t^tRtR# )ÚBufferTooShortr   Nr   r   r   r   r   r      r   r   r   c                   ó   € ] tR t^tRtR# )ÚTimeoutErrorr   Nr   r   r   r   r   r      r   r   r   c                   ó   € ] tR t^tRtR# )ÚAuthenticationErrorr   Nr   r   r   r   r   r      r   r   r   c                   ó¸  a € ] tR t^t o ]t]t]t]t]! ]	P                  4      t
]! ]	P                  4      t]! ]	P                  4      tR tR tR#R ltR tR tR$R ltR%R	 ltR%R
 ltR tR&R ltR'R ltR'R ltR tR(R ltR tR tRR/R ltRR/R ltR tR t R$R lt!R t"R t#R t$R$R lt%R)R lt&R)R lt'](R 4       t)])PT                  R  4       t)R! t+R"t,V t-R# )*ÚBaseContextc                óN   € \         P                  ! 4       pVf   \        R4      hV# )z(Returns the number of CPUs in the systemzcannot determine number of cpus)ÚosÚ	cpu_countÚNotImplementedError)ÚselfÚnums   & r   r   ÚBaseContext.cpu_count)   s#   € ä�lŠl‹nˆØŠ;Ü%Ð&GÓHÐHàˆJr   c                ó`   € ^RI Hp V! V P                  4       R7      pVP                  4        V# )z¥Returns a manager associated with a running server process

The managers methods such as `Lock()`, `Condition()` and `Queue()`
can be used to create shared objects.
)ÚSyncManager©Úctx)Úmanagersr!   Úget_contextÚstart)r   r!   Úms   &  r   ÚManagerÚBaseContext.Manager1   s(   € õ 	*Ù˜D×,Ñ,Ó.Ô/ˆØ	�‰Œ	Øˆr   Tc                ó   € ^RI Hp V! V4      # )z1Returns two connection object connected by a pipe)ÚPipe)Ú
connectionr+   )r   Úduplexr+   s   && r   r+   ÚBaseContext.Pipe<   s   € å$Ù�F‹|Ðr   c                ó<   € ^RI Hp V! V P                  4       R7      # )z#Returns a non-recursive lock object)ÚLockr"   )Úsynchronizer0   r%   )r   r0   s   & r   r0   ÚBaseContext.LockA   s   € å%Ù˜×(Ñ(Ó*Ô+Ð+r   c                ó<   € ^RI Hp V! V P                  4       R7      # )zReturns a recursive lock object)ÚRLockr"   )r1   r4   r%   )r   r4   s   & r   r4   ÚBaseContext.RLockF   ó   € å&Ù˜×)Ñ)Ó+Ô,Ð,r   Nc                ó<   € ^RI Hp V! WP                  4       R7      # )zReturns a condition object)Ú	Conditionr"   )r1   r8   r%   )r   Úlockr8   s   && r   r8   ÚBaseContext.ConditionK   s   € å*Ù˜×#3Ñ#3Ó#5Ô6Ð6r   c                ó<   € ^RI Hp V! WP                  4       R7      # )zReturns a semaphore object)Ú	Semaphorer"   )r1   r<   r%   )r   Úvaluer<   s   && r   r<   ÚBaseContext.SemaphoreP   s   € å*Ù˜×$4Ñ$4Ó$6Ô7Ð7r   c                ó<   € ^RI Hp V! WP                  4       R7      # )z"Returns a bounded semaphore object)ÚBoundedSemaphorer"   )r1   r@   r%   )r   r=   r@   s   && r   r@   ÚBaseContext.BoundedSemaphoreU   s   € å1Ù ×+;Ñ+;Ó+=Ô>Ð>r   c                ó<   € ^RI Hp V! V P                  4       R7      # )zReturns an event object)ÚEventr"   )r1   rC   r%   )r   rC   s   & r   rC   ÚBaseContext.EventZ   r6   r   c                ó>   € ^RI Hp V! WW0P                  4       R7      # )zReturns a barrier object)ÚBarrierr"   )r1   rF   r%   )r   ÚpartiesÚactionÚtimeoutrF   s   &&&& r   rF   ÚBaseContext.Barrier_   s   € å(Ù�w¨×5EÑ5EÓ5GÔHÐHr   c                ó<   € ^RI Hp V! WP                  4       R7      # )úReturns a queue object)ÚQueuer"   )ÚqueuesrM   r%   )r   ÚmaxsizerM   s   && r   rM   ÚBaseContext.Queued   s   € å!Ù�W×"2Ñ"2Ó"4Ô5Ð5r   c                ó<   € ^RI Hp V! WP                  4       R7      # )rL   )ÚJoinableQueuer"   )rN   rR   r%   )r   rO   rR   s   && r   rR   ÚBaseContext.JoinableQueuei   s   € å)Ù˜W×*:Ñ*:Ó*<Ô=Ð=r   c                ó<   € ^RI Hp V! V P                  4       R7      # )rL   )ÚSimpleQueuer"   )rN   rU   r%   )r   rU   s   & r   rU   ÚBaseContext.SimpleQueuen   s   € å'Ù˜t×/Ñ/Ó1Ô2Ð2r   c                ó@   € ^RI Hp V! WW4V P                  4       R7      # )zReturns a process pool object)ÚPool)Úcontext)ÚpoolrX   r%   )r   Ú	processesÚinitializerÚinitargsÚmaxtasksperchildrX   s   &&&&& r   rX   ÚBaseContext.Pools   s$   € õ 	Ù�I¨HØ ×,Ñ,Ó.ô0ð 	0r   c                ó"   € ^RI Hp V! V.VO5!  # )zReturns a shared object)ÚRawValue)Úsharedctypesra   )r   Útypecode_or_typeÚargsra   s   &&* r   ra   ÚBaseContext.RawValuez   s   € å*ÙÐ(Ð0¨4Ó0Ð0r   c                ó   € ^RI Hp V! W4      # )zReturns a shared array)ÚRawArray)rb   rg   )r   rc   Úsize_or_initializerrg   s   &&& r   rg   ÚBaseContext.RawArray   s   € å*ÙÐ(Ó>Ð>r   r9   c               óF   € ^RI Hp V! V.VO5RVRV P                  4       / # )z$Returns a synchronized shared object)ÚValuer9   r#   )rb   rk   r%   )r   rc   r9   rd   rk   s   &&$* r   rk   ÚBaseContext.Value„   s4   € å'ÙÐ%ð -¨ò -°4ð -Ø×)Ñ)Ó+ñ-ð 	-r   c               ó@   € ^RI Hp V! WVV P                  4       R7      # )z#Returns a synchronized shared array)ÚArray)r9   r#   )rb   rn   r%   )r   rc   rh   r9   rn   s   &&&$ r   rn   ÚBaseContext.ArrayŠ   s#   € å'ÙÐ%ÀØ×)Ñ)Ó+ô-ð 	-r   c                ó€   € V P                  4       R8X  d)   \        \        RR4      '       d   ^RIHp V! 4        R# R# R# )z{Check whether this is a fake forked process in a frozen executable.
If so then run code specified by commandline and exit.
ÚspawnÚfrozenF)Úfreeze_supportN)Úget_start_methodÚgetattrÚsysrq   rs   )r   rs   s   & r   rs   ÚBaseContext.freeze_support�   s5   € ð × Ñ Ó" gÔ-´'¼#¸xÈ×2OÒ2OÝ-ÙÖñ 3PÑ-r   c                ó   € ^RI Hp V! 4       # )zJReturn package logger -- if it does not already exist then
it is created.
)Ú
get_logger)Úutilry   )r   ry   s   & r   ry   ÚBaseContext.get_logger˜   s   € õ 	%Ù‹|Ðr   c                ó   € ^RI Hp V! V4      # )z8Turn on logging and add a handler which prints to stderr)Úlog_to_stderr)rz   r}   )r   Úlevelr}   s   && r   r}   ÚBaseContext.log_to_stderrŸ   s   € å'Ù˜UÓ#Ð#r   c                ó   € ^RI Hp R# )zFInstall support for sending connections and sockets
between processes
)r,   N)Ú r,   )r   r,   s   & r   Úallow_connection_picklingÚ%BaseContext.allow_connection_pickling¤   s   € ÷ 	!r   c                ó"   € ^RI Hp V! V4       R# )z´Sets the path to a python.exe or pythonw.exe binary used to run
child processes instead of sys.executable when using the 'spawn'
start method.  Useful for people embedding Python.
)Úset_executableN)rq   r…   )r   Ú
executabler…   s   && r   r…   ÚBaseContext.set_executable¬   s   € õ
 	*Ù�zÖ"r   c                ó"   € ^RI Hp V! V4       R# )z[Set list of module names to try to load in forkserver process.
This is really just a hint.
)Úset_forkserver_preloadN)Ú
forkserverr‰   )r   Úmodule_namesr‰   s   && r   r‰   Ú"BaseContext.set_forkserver_preload´   s   € õ 	7Ù˜|Ö,r   c                ó’   € Vf   V #  \         V,          pTP                  4        T#   \         d    \        RT,          4      R hi ; i)Nzcannot find context for %r)Ú_concrete_contextsÚKeyErrorÚ
ValueErrorÚ_check_available)r   Úmethodr#   s   && r   r%   ÚBaseContext.get_context»   sU   € ØŠ>ØˆKð	NÜ$ VÕ,ˆCð 	×ÑÔØˆ
øô ô 	NÜÐ9¸FÕBÓCÈÐMð	Nús	   ˆ' §Ac                ó   € V P                   # ©N)Ú_name©r   Ú
allow_nones   &&r   rt   ÚBaseContext.get_start_methodÅ   s   € Ø�z‰zÐr   c                ó   € \        R 4      h)z+cannot set start method of concrete context)r�   ©r   r’   Úforces   &&&r   Úset_start_methodÚBaseContext.set_start_methodÈ   s   € ÜÐFÓGÐGr   c                ó4   € \        4       P                  R4      # )zWControls how objects will be reduced to a form that can be
shared with other processes.r   )ÚglobalsÚget©r   s   &r   ÚreducerÚBaseContext.reducerË   s   € ô ‹y�}‰}˜[Ó)Ð)r   c                ó    € V\        4       R &   R# )r   N)r    )r   r   s   &&r   r£   r¤   Ñ   s   € à!*Œ‹	�+Ór   c                ó   € R # r•   r   r¢   s   &r   r‘   ÚBaseContext._check_availableÕ   s   € Ùr   r   )Tr•   )é   )NN)r   )NNr   N©F).r	   r
   r   r   r   r   r   r   Ústaticmethodr   Úcurrent_processÚparent_processÚactive_childrenr   r(   r+   r0   r4   r8   r<   r@   rC   rF   rM   rR   rU   rX   ra   rg   rk   rn   rs   ry   r}   r‚   r…   r‰   r%   rt   r�   Úpropertyr£   Úsetterr‘   r   Ú__classdictcell__©Ú__classdict__s   @r   r   r      s  ø‡ € à€LØ#€NØ€LØ-Ðá" 7×#:Ñ#:Ó;€OÙ! '×"8Ñ"8Ó9€NÙ" 7×#:Ñ#:Ó;€Oòò	ôò
,ò
-ô
7ô
8ô
?ò
-ô
Iô
6ô
>ò
3ô
0ò1ò
?ð
-°$ô -ð-À4ô -òòô$ò
!ò#ò-ôôôHð ñ*ó ð*ð
 ‡^�^ñ+ó ð+÷ð r   r   c                   óD   a € ] tR t^Üt o Rt]R 4       t]R 4       tRtV t	R# )ÚProcessNc                ó\   € \         P                  4       P                  P                  V 4      # r•   )Ú_default_contextr%   r´   Ú_Popen)Úprocess_objs   &r   r·   ÚProcess._PopenÞ   s"   € ä×+Ñ+Ó-×5Ñ5×<Ñ<¸[ÓIÐIr   c                 óZ   € \         P                  4       P                  P                  4       # r•   )r¶   r%   r´   Ú_after_forkr   r   r   r»   ÚProcess._after_forkâ   s    € ä×+Ñ+Ó-×5Ñ5×AÑAÓCÐCr   r   ©
r	   r
   r   r   Ú_start_methodrª   r·   r»   r   r°   r±   s   @r   r´   r´   Ü   s4   ø‡ € Ø€MØñJó ðJð ñDó öDr   r´   c                   óZ   a a€ ] tR t^æt o]tR tRV 3R lltRR ltRR ltR t	Rt
VtV ;t# )	ÚDefaultContextc                ó    € Wn         R V n        R # r•   )r¶   Ú_actual_context)r   rY   s   &&r   Ú__init__ÚDefaultContext.__init__é   s   € Ø 'ÔØ#ˆÖr   c                ó€   <€ Vf,   V P                   f   V P                  V n         V P                   # \        SV `  V4      # r•   )rÂ   r¶   Úsuperr%   )r   r’   Ú	__class__s   &&€r   r%   ÚDefaultContext.get_contextí   s>   ø€ ØŠ>Ø×#Ñ#Ò+Ø'+×'<Ñ'<�Ô$Ø×'Ñ'Ð'ä‘7Ñ& vÓ.Ð.r   c                óž   € V P                   e   V'       g   \        R4      hVf   V'       d
   R V n         R # V P                  V4      V n         R # )Nzcontext has already been set)rÂ   ÚRuntimeErrorr%   r›   s   &&&r   r�   ÚDefaultContext.set_start_methodõ   sA   € Ø×ÑÒ+·EÜÐ=Ó>Ð>ØŠ>ŸeØ#'ˆDÔ ÙØ#×/Ñ/°Ó7ˆÖr   c                ó€   € V P                   f   V'       d   R # V P                  V n         V P                   P                  # r•   )rÂ   r¶   r–   r—   s   &&r   rt   ÚDefaultContext.get_start_methodý   s4   € Ø×ÑÒ'ßÙØ#'×#8Ñ#8ˆDÔ Ø×#Ñ#×)Ñ)Ð)r   c                ó€   a€ V P                   P                  4       oS.pVP                  V3R l\         4       4       V# )z=Returns a list of the supported start methods, default first.c              3   ó8   <"  € T F  qS8w  g   K  Vx € K  	  R # 5ir•   r   )Ú.0ÚnameÚdefaults   & €r   Ú	<genexpr>Ú7DefaultContext.get_all_start_methods.<locals>.<genexpr>  s   øé € ð "
Ù/�T¸7±?�DŠDÓ/ùs   ƒ�
)r¶   rt   ÚextendrŽ   )r   Ústart_method_namesrÒ   s   & @r   Úget_all_start_methodsÚ$DefaultContext.get_all_start_methods  sB   ø€ à×'Ñ'×8Ñ8Ó:ˆØ%˜YÐØ×!Ñ!ô "
Ý/ó"
ô 	
ð "Ð!r   )rÂ   r¶   r•   r©   )r	   r
   r   r   r´   rÃ   r%   r�   rt   r×   r   r°   Ú__classcell__)rÇ   r²   s   @@r   rÀ   rÀ   æ   s(   ù‡ € Ø€Gò$÷/ô8ô*÷"ò "r   rÀ   Úwin32c                   ó4   a € ] tR tRt o Rt]R 4       tRtV tR# )ÚForkProcessi  Úforkc                ó   € ^RI Hp V! V 4      # ©r¨   )ÚPopen)Ú
popen_forkrà   ©r¸   rà   s   & r   r·   ÚForkProcess._Popen  s   € å)Ù˜Ó%Ð%r   r   N©	r	   r
   r   r   r¾   rª   r·   r   r°   r±   s   @r   rÜ   rÜ     s   ø‡ € ØˆØ	ñ	&ó 
ö	&r   rÜ   c                   óD   a € ] tR tRt o Rt]R 4       t]R 4       tRtV t	R# )ÚSpawnProcessi  rq   c                ó   € ^RI Hp V! V 4      # rß   )Úpopen_spawn_posixrà   râ   s   & r   r·   ÚSpawnProcess._Popen  ó   € å0Ù˜Ó%Ð%r   c                 ó   € R # r•   r   r   r   r   r»   ÚSpawnProcess._after_fork"  ó   € ñ r   r   Nr½   r±   s   @r   ræ   ræ     ó0   ø‡ € ØˆØ	ñ	&ó 
ð	&ð 
ñ	ó 
ö	r   ræ   c                   ó4   a € ] tR tRt o Rt]R 4       tRtV tR# )ÚForkServerProcessi'  rŠ   c                ó   € ^RI Hp V! V 4      # rß   )Úpopen_forkserverrà   râ   s   & r   r·   ÚForkServerProcess._Popen)  s   € å/Ù˜Ó%Ð%r   r   Nrä   r±   s   @r   rð   rð   '  s   ø‡ € Ø$ˆØ	ñ	&ó 
ö	&r   rð   c                   ó   € ] tR tRtRt]tRtR# )ÚForkContexti.  rÝ   r   N)r	   r
   r   r   r–   rÜ   r´   r   r   r   r   rõ   rõ   .  s   † ØˆØŒr   rõ   c                   ó   € ] tR tRtRt]tRtR# )ÚSpawnContexti2  rq   r   N©r	   r
   r   r   r–   ræ   r´   r   r   r   r   r÷   r÷   2  ó   † ØˆØŒr   r÷   c                   ó.   a € ] tR tRt o Rt]tR tRtV t	R# )ÚForkServerContexti6  rŠ   c                óH   € \         P                  '       g   \        R 4      hR# )z%forkserver start method not availableN)r   ÚHAVE_SEND_HANDLEr�   r¢   s   &r   r‘   Ú"ForkServerContext._check_available9  s   € Ü×-×-Ð-Ü Ð!HÓIÐIñ .r   r   N)
r	   r
   r   r   r–   rð   r´   r‘   r   r°   r±   s   @r   rû   rû   6  s   ø‡ € ØˆØ#ˆ÷	Jð 	Jr   rû   rÝ   rq   rŠ   Údarwinc                   óD   a € ] tR tRt o Rt]R 4       t]R 4       tRtV t	R# )ræ   iL  rq   c                ó   € ^RI Hp V! V 4      # rß   )Úpopen_spawn_win32rà   râ   s   & r   r·   ré   N  rê   r   c                 ó   € R # r•   r   r   r   r   r»   rì   S  rí   r   r   Nr½   r±   s   @r   ræ   ræ   L  rî   r   c                   ó   € ] tR tRtRt]tRtR# )r÷   iX  rq   r   Nrø   r   r   r   r÷   r÷   X  rù   r   c                 ó2   € \         V ,          \        n        R # r•   )rŽ   r¶   rÂ   )r’   s   &r   Ú_force_start_methodr  e  s   € Ü'9¸&Õ'AÔÖ$r   c                  ó$   € \        \        R R4      # )Úspawning_popenN)ru   Ú_tlsr   r   r   Úget_spawning_popenr
  n  s   € Ü”4Ð)¨4Ó0Ð0r   c                 ó   € V \         n        R # r•   )r	  r  )Úpopens   &r   Úset_spawning_popenr  q  s
   € Ø„DÖr   c                 óh   € \        4       f&   \        R\        V 4      P                  ,          4      hR # )NzF%s objects should only be shared between processes through inheritance)r
  rÊ   Útyper	   )Úobjs   &r   Úassert_spawningr  t  s4   € ÜÓÒ#Üð#Ü%)¨#£Y×%7Ñ%7õ8óð 	ñ $r   r   )!r   rv   Ú	threadingr�   r   r   Ú__all__Ú	Exceptionr   r   r   r   Úobjectr   ÚBaseProcessr´   rÀ   ÚplatformrÜ   ræ   rð   rõ   r÷   rû   rŽ   rý   r¶   r  Úlocalr	  r
  r  r  r   r   r   Ú<module>r     s¤  ðÛ 	Û 
Û å Ý à
€ô	�9ô 	ô	�\ô 	ô	�<ô 	ô	˜,ô 	ôx�&ô xô|Dˆg×!Ñ!ô Dô%"�[ô %"ðX ‡<�<�7Ôô&�g×)Ñ)ô &ô
�w×*Ñ*ô 
ô&˜G×/Ñ/ô &ô�kô ô�{ô ôJ˜Kô Jð 	‘“Ø‘“ØÑ'Ó)ðÐð ×!×!Ð! c§l¡l°hÔ&>Ù)Ð*<¸VÕ*DÓEÑá)Ð*<¸VÕ*DÓEÑô
�w×*Ñ*ô 
ô�{ô ð
 	‘“ðÐñ &Ð&8¸Õ&AÓBÐòBð ‡‚Ó€ò1ò ôr   