python (3.11.7)
Browse
Usage
Versions
ek/ & g d Z ddlZddlZddlZddlZddlZddlmZ ej ej
Z n
# e $ r dZ Y nw xY wd Z
d Zd Zd Z G d d e Z G d
d e Z G d d
e Z G d de Zda e a ej d a e a [i Z e ej D ] \ Z!Z"e!dd dk r
de!vr de! e e" < ![![" e Z#dS )) BaseProcesscurrent_processactive_childrenparent_process N)WeakSetc t S N)_current_process K/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/multiprocessing/process.pyr r % s r c H t t t S r )_cleanuplist _childrenr r r
r r + s
JJJ ??r c t S r )_parent_processr r r
r r 3 s r c t t D ]9} | j x}r.| t | :d S r )r r _popenpolldiscard)p child_popens r
r r = sV
)__ ! ! 8 #K !)9)9););)G a ! !r c l e Zd Z d Zddddi fdddZd Zd Zd Zd Zd
Z dd Z
d Z d
Z e
d Zej d Ze
d Zej d Ze
d Zej d Ze
d Ze
d ZeZe
d Zd ZddZed ZdS )r c t r )NotImplementedErrorselfs r
_PopenzBaseProcess._PopenM s !!r Nr )daemonc 6 t t }t j |fz | _ t j | _ t
j | _ t j | _
d | _ d| _ || _
t | | _ t! | | _ |p;t% | j dz d d | j D z | _ ||| _ t. | d S )NF-:c 3 4 K | ]}t | V d S r )str).0is r
<genexpr>z'BaseProcess.__init__.<locals>.<genexpr>^ s( = =c!ff = = = = = =r )next_process_counterr
_identity_configcopyosgetpid _parent_pidname _parent_namer _closed_targettuple_argsdict_kwargstype__name__join_namer _danglingadd)r grouptargetr1 argskwargsr counts r
__init__zBaseProcess.__init__P s %&&)3uh>'/4466 9;; , 1 4[[
F|| >T$ZZ 03 6XX = =dn = = === >
DK
dr c 2 | j rt d d S )Nzprocess object is closed)r3
ValueErrorr s r
_check_closedzBaseProcess._check_closedc s% < 9 788 8 9 9r c H | j r | j | j i | j d S d S r )r4 r6 r8 r s r
runzBaseProcess.rung s> < 6 DL$* 5 5 5 5 5 5 6 6r c | t | | | _ | j j | _ | `| `| `t
| d S r ) rG r r r sentinel _sentinelr4 r6 r8 r r> r s r
startzBaseProcess.startn sl
kk$'' -
L$*dl
dr c b | | j d S r )rG r terminater s r
rO zBaseProcess.terminate s5
r c b | | j d S r )rG r killr s r
rQ zBaseProcess.kill s5
r c | | j | }| t | d S d S r )rG r waitr r )r timeoutress r
r; zBaseProcess.join sX
k w'' ? d # # # # # ?r c | | t u rdS | j dS | j }|dS t | dS )NTF)rG r
r r r r )r
returncodes r
is_alivezBaseProcess.is_alive sr
# # #4 ; 5[%%''
4 d # # #5r c | j d| j t d | j d | _ | `t
| d| _ d S )Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r rF closerL r r r3 r s r
rZ zBaseProcess.close s ; "{ !!) "P Q Q Q K DK d # # # r c | j S r r< r s r
r1 zBaseProcess.name s
zr c || _ d S r r\ )r r1 s r
r1 zBaseProcess.name s
r c : | j dd S )Nr F)r, getr s r
r zBaseProcess.daemon s! | %000r c || j d< d S )Nr r, )r daemonics r
r zBaseProcess.daemon s "* X r c | j d S Nauthkeyra r s r
re zBaseProcess.authkey s |I&&r c 6 t | | j d< d S rd )AuthenticationStringr, )r re s r
re zBaseProcess.authkey s# #7w"?"? Y r c z | | j | j S | j S r )rG r r r s r
exitcodezBaseProcess.exitcode s?
; ; { !!!r c | | t u rt j S | j o | j j S r )rG r
r. r/ r pidr s r
identzBaseProcess.ident sD
# # #9;; ;24;? 2r c x | | j S # t $ r t d d w xY w)Nzprocess not started)rG rL AttributeErrorrF r s r
rK zBaseProcess.sentinel sT
>> ! > > > 233 = >s 9c d }| t u rd}nS| j rd}nI| j t j k rd}n*| j d}n | j }|d}nd}t | j d| j z g}| j "|
d| j j z |
d| j z |
| |3t
|| }|
d |z | j r|
d
d d | z S )
Nstartedclosedunknowninitialstoppedzname=%rzpid=%sz parent=%sz exitcode=%sr z<%s> )r
r3 r0 r. r/ r r r9 r: r< appendrk _exitcode_to_namer_ r r; )r ri statusinfos r
__repr__zBaseProcess.__repr__ sF # # # FF
\ # FF
,
, FF
[
FF{''))H#""T
#Y%;< ; " KK4;?2 3 3 3 K$"22333 F (,,Xx@@H KK
0 1 1 1 ; " KK ! ! !&&r c ddl m}m} | j | | j t j d at a |
t }| a t | j
| j | at j r%t! j | ~n# ~w xY w| d | d}| n# | w xY wn# t0 $ rl}|j d}nXt5 |j t6 r|j }n6t8 j t? |j dz d}Y d }~nKd }~w d}dd l }t8 j d| j! z |" Y nxY wt! j# | d|z |$ nD# t! j# | d|z |$ w xY w|S )N )utilcontextz child process calling self.run()r
z Process %s:
z process exiting with exitcode %d)% r} r~
_start_method_force_start_method itertoolsrC r* setr _close_stdinr
_ParentProcessr2 r0 r threading_HAVE_THREAD_NATIVE_ID main_thread_set_native_id _after_forkry rI _exit_function
SystemExitcode
isinstanceintsysstderrwriter% tracebackr1 print_exc _shutdown_flush_std_streams)r parent_sentinelr} r~ old_processri er s r
_bootstrapzBaseProcess._bootstrap" s| ########( &!-++D,>??? (q 1 1 I *K # ,!4#3_ F FO/
9%''66888
""" KK II8 9 9 9
&
##%%%%##%%%%% v~ AFC((
6
QVt!3444 "H J _ty 8 9 9 9 ! ! ! ! ! ! ! ! II88C D D D # # % % % %
! ! ! II88C D D D # # % % % %sc B,D. 7C
D.
CD. )D ?D. D**D. -H* .
G'8A"F H* AG'%H* *AI+c l ddl m} | j | d S )Nr| r} )r r} _finalizer_registryclear_run_after_forkersr s r
r zBaseProcess._after_forkR sA &&((( !!!!!r r )r:
__module__ __qualname__r rD rG rI rM rO rQ r; rX rZ propertyr1 setterr re ri rl rk rK rz r staticmethodr r r r
r r G s
" " " "$T2 &9 9 96 6 6 $ $ $ $ $ & " X
[ [ 1 1 X1 ]* * ]* ' ' X'
^@ @ ^@ " " X" 3 3 X3 C
> > X >' ' '>. . . .` " " \" " "r r c e Zd Zd ZdS )rg c n ddl m} | t d t t | ffS )Nr| )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r~ r TypeErrorrg bytes)r r s r
__reduce__z AuthenticationString.__reduce__^ sO ////// '2
$eDkk^33r N)r: r r r r r r
rg rg ] s# 4 4 4 4 4r rg c < e Zd Zd Zd Zed ZddZeZdS )r c v d| _ || _ || _ d | _ d | _ d| _ || _ i | _ d S )Nr F)r+ r< _pidr0 r r3 rL r, )r r1 rk rK s r
rD z_ParentProcess.__init__n s?
! r c 6 ddl m} || j gd S Nr )rS )rT multiprocessing.connectionrS rL )r rS s r
rX z_ParentProcess.is_alivex s1 3333334 (!44444r c | j S r )r r s r
rl z_ParentProcess.ident| s
yr Nc : ddl m} || j g| d S r r )r rT rS s r
r; z_ParentProcess.join s; 433333 dn
w//////r r ) r: r r rD rX r rl r; rk r r r
r r l sb 5 5 5 X0 0 0 0 CCCr r c e Zd Zd Zd ZdS ) _MainProcessc d| _ d| _ d | _ d | _ d| _ t t
j d dd| _ d S )Nr MainProcessF z/mp)re semprefix) r+ r< r0 r r3 rg r. urandomr, r s r
rD z_MainProcess.__init__ sN "
#7
2#G#G%*, , r c d S r r r s r
rZ z_MainProcess.close s r N)r: r r rD rZ r r r
r r s2 , , ,$
r r r| SIG_r" )$__all__r. r signalr r _weakrefsetr pathabspathgetcwd ORIGINAL_DIROSErrorr r r r objectr r rg r r r r
rC r* r r rw r __dict__itemsr1 signumr= r r r
<module>r s:
7??929;;//LL LLL ! ! !O" O" O" O" O"& O" O" O"l4 4 4 4 45 4 4 4 [ B
;
0 <>> "9?1%% CEE D ..0011 0 0LD& BQBx3d??%/ZZ6'"&
GII s 'A AA