+
    € ’eÜ2  ã                   ó¶  € ^ RI t ^ 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R" t]! 4       tM3 ! R# R]P                  4      t ! R$ R]4      tR ]! 4       /tR% t]! 4       tR& t]P:                  ! 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/home/ubuntu/.hermes/tools/python-3.14.9+20261021-linux-x64/lib/python3.14/multiprocessing/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.Manager2   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.LockB   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.RLockG   ó   € å&Ù˜×)Ñ)Ó+Ô,Ð,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.ConditionL   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.SemaphoreQ   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.BoundedSemaphoreV   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.Event[   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.Queuee   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.JoinableQueuej   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.SimpleQueueo   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.Poolt   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.RawValue{   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                ó„   € \        \        RR4      '       d)   V P                  RR7      R9   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.
ÚfrozenFT)Ú
allow_noneN)Úfreeze_support)ÚspawnN)ÚgetattrÚsysÚget_start_methodrt   rs   )r   rs   s   & r   rs   ÚBaseContext.freeze_support‘   s=   € ô ”C˜ 5×)Ò)Ø×)Ñ)°TÐ)Ó:¸oÔMÝ-ÙÖñ Nñ *r   c                ó   € ^RI Hp V! 4       # )zJReturn package logger -- if it does not already exist then
it is created.
)Ú
get_logger)Úutilrz   )r   rz   s   & r   rz   Ú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)r{   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)rt   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   rr   s   &&r   rw   Ú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   rz   r~   rƒ   r†   rŠ   r%   rw   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                   ó‚   a a€ ] tR t^ít o]tRR lt]P                  R 4       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                ó(   € Ve   Wn         R V n        R # r–   )r¶   Ú_actual_context)r   rY   s   &&r   Ú__init__ÚDefaultContext.__init__ð   s   € ØÒØ$+Ô!Ø#ˆÖr   c                ó   € \        4       # r–   )Ú_get_platform_default_contextr¢   s   &r   r¶   ÚDefaultContext._default_contextù   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   rw   Ú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¶   rw   Ú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Ã   Ú	functoolsÚcached_propertyr¶   r%   r�   rw   rÚ   r   r°   Ú__classcell__)rÊ   r²   s   @@r   rÀ   rÀ   í   sB   ù‡ € Ø€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+  rt   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_fork2  ó   € ñ 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# )ÚForkServerProcessi7  r‹   c                ó   € ^RI Hp V! V 4      # rä   )Úpopen_forkserverrå   rç   s   & r   r·   ÚForkServerProcess._Popen9  s   € å/Ù˜Ó%Ð%r   r   Nré   r±   s   @r   rõ   rõ   7  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# )ÚSpawnContextiB  rt   r   N©r	   r
   r   r   r—   rë   r´   r   r   r   r   rü   rü   B  ó   † ØˆØŒr   rü   c                   ó.   a € ] tR tRt o Rt]tR tRtV t	R# )ÚForkServerContextiF  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_availableI  s   € Ü×-×-Ð-Ü Ð!HÓIÐIñ .r   r   N)
r	   r
   r   r   r—   rõ   r´   r’   r   r°   r±   s   @r   r   r   F  s   ø‡ € ØˆØ#ˆ÷	Jð 	Jr   r   râ   rt   r‹   c                  óÄ   € \         P                  '       d?   \        P                  R 8w  d*   ^RIHp  V P                  4       '       d   \        R,          # \        R,          # )Údarwin©r{   r‹   rt   )r   r  rv   Úplatformr‚   r{   Ú_has_writeable_tempdirr�   r  s    r   rÆ   rÆ   S  sE   € ô ×%×%Ð%¬#¯,©,¸(Ô*Bõ
 Ø×*Ñ*×,Ò,Ü)¨,Õ7Ð7Ü! 'Õ*Ð*r   c                   óD   a € ] tR tRt o Rt]R 4       t]R 4       tRtV t	R# )rë   ie  rt   c                ó   € ^RI Hp V! V 4      # rä   )Úpopen_spawn_win32rå   rç   s   & r   r·   rî   g  rï   r   c                 ó   € R # r–   r   r   r   r   r»   rñ   l  rò   r   r   Nr½   r±   s   @r   rë   rë   e  ró   r   c                   ó   € ] tR tRtRt]tRtR# )rü   iq  rt   r   Nrý   r   r   r   rü   rü   q  rþ   r   c                  ó   € \         R ,          # )rt   )r�   r   r   r   rÆ   rÆ   x  s   € Ü! 'Õ*Ð*r   c                 ó2   € \         V ,          \        n        R # r–   )r�   r¶   rÂ   )r“   s   &r   Ú_force_start_methodr  �  s   € Ü'9¸&Õ'AÔÖ$r   c                  ó$   € \        \        R R4      # )Úspawning_popenN)ru   Ú_tlsr   r   r   Úget_spawning_popenr  Š  s   € Ü”4Ð)¨4Ó0Ð0r   c                 ó   € V \         n        R # r–   )r  r  )Úpopens   &r   Úset_spawning_popenr  �  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  �  s4   € ÜÓÒ#Üð#Ü%)¨#£Y×%7Ñ%7õ8óð 	ñ $r   r   )"rÜ   r   rv   Ú	threadingr‚   r   r   Ú__all__Ú	Exceptionr   r   r   r   Úobjectr   ÚBaseProcessr´   rÀ   r  rá   rë   rõ   rú   rü   r   r�   rÆ   r¶   r  Úlocalr  r  r  r  r   r   r   Ú<module>r"     sy  ðÛ Û 	Û 
Û å Ý à
€ô	�9ô 	ô	�\ô 	ô	�<ô 	ô	˜,ô 	ô~�&ô ~ôHDˆg×!Ñ!ô Dô."�[ô ."ðj ‡<�<�7Ôô&�g×)Ñ)ô &ô
�w×*Ñ*ô 
ô&˜G×/Ñ/ô &ô�kô ô�{ô ôJ˜Kô Jð 	‘“Ø‘“ØÑ'Ó)ðÐò+ñ &Ó'Ñô
�w×*Ñ*ô 
ô�{ô ð
 	‘“ðÐò+ñ &Ó'ÐòBð ‡‚Ó€ò1ò ôr   