cj/ b d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
ddl m Z ddl m
Z
ddl mZ ddl mZ ddl mZ g d Zd
Z ej& d Z G d d
e ZddZd Zd Zd Z e Zej8 Z ej: Z ej< Z ej> Z y) N )
connection)process) reduction)resource_tracker)spawn)util)ensure_runningget_inherited_fdsconnect_to_new_processset_forkserver_preload qc 6 e Zd Zd Zd Zd Zd Zd Zd Zd Z y)
ForkServerc ~ d | _ d | _ d | _ d | _ t j
| _ dg| _ y )N__main__)_forkserver_address_forkserver_alive_fd_forkserver_pid_inherited_fds threadingLock_lock_preload_modulesselfs 3/usr/lib64/python3.12/multiprocessing/forkserver.py__init__zForkServer.__init__" s: #' $(! # " ^^%
!+ c f | j 5 | j d d d y # 1 sw Y y xY wN)r _stop_unlockedr s r _stopzForkServer._stop* s
ZZ ! ZZs '0c B | j y t j | j d | _ t j | j d d | _ t j | j s t j | j d | _ y )Nr ) r oscloser waitpidr is_abstract_socket_namespacer unlinkr s r r# zForkServer._stop_unlocked/ sw ' **+$(!
4''+ # 001I1IJ IId.. /#' r c N t d |D s t d || _ y )Nc 3 > K | ] }t | t u y wr" )typestr).0mods r z4ForkServer.set_forkserver_preload..@ s =}49#}s z&module_names must be a list of strings)all TypeErrorr )r
modules_namess r r
z!ForkServer.set_forkserver_preload> s' L=}== DE E - r c | j S r" )r r s r r z ForkServer.get_inherited_fdsD s
"""r c | j t | dz t k\ r t d t j t j
5 }|j
| j t j \ }}t j \ }}||| j t j g}||z
} t j || ||ft j | t j | cd d d S # t j | t j | xY w# t j | t j | w xY w# 1 sw Y y xY w)N z too many fds)r
lenMAXFDS_TO_SEND
ValueErrorsocketAF_UNIXconnectr r& piper r getfdr sendfdsr' )r fdsclientparent_rchild_wchild_rparent_wallfdss r r z!ForkServer.connect_to_new_processL s
s8a<> ) ^, ,
]]6>>
*f NN433 4 " Hg " GX w(A(A&,,.0F cMF
"!!&&1 ) !!! +
*
""!!! +
*s1 A1E3D *E3-EE,E00E33E<c 6 | j 5 t j | j qt j
| j t j \ }}|s
d d d y t j | j d | _ d | _ d | _ d}| j rBddh}t j d }|j D ci c]
\ }}||v s || }}}ni }t j t j 5 }t! j" d } |j% | t' j( | st j* | d |j- t j. \ }
} |j1 |
g} ||j1 |
| j |fz }t j2 }
|
gt' j4 z }|d|gz
}t' j6 |
|| } t j |
| | _ | | _ || _ d d d d d d y c c}}w # t j | xY w# t j |
w xY w# 1 sw Y MxY w# 1 sw Y y xY w)NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r) main_pathsys_pathignorer< i z-c) r r r
r r& r( WNOHANGr' r r r r get_preparation_dataitemsr; r< r arbitrary_addressbindr r) chmodlistenr> filenoget_executable _args_from_interpreter_flagsspawnv_passfds)r pidstatuscmd desired_keysdataxylisteneraddressalive_ralive_w fds_to_passexeargss r r
zForkServer.ensure_runningi s+ ZZ + + -##/ jj)=)=rzz J V Z 223+/(,0)'+$,C $$ +Z 8 11(;)- K Al9J1 K v~~.($66yA
g&88AHHWe,! $&779 &#+??#4g">KHOO -w8M8M " "C ..0C 54#D#D#FFDT3K'D --c4EC
HHW%+2(,3)'*$3 /1 Z( L,HHW%HHW%- /.1 Zsi AJ,A.J I'I,)JA9JA=I
*J7JJI&&I))J JJ JJN)
__name__
__module__ __qualname__r r$ r# r
r r r
r r r r s% -"
( . #":8+r r c
|rq||t j d d d|v rE|Cdt j _ t j | t j `|D ] } t | t j t j \ }}t j |d t j |d d }t j |t j t j" i} | j% D
ci c] \ }
} |
t j |
| } }
} t j& | i }
t) j( t( j* | 5 }t- j. 5 }|j1 t2 _ |j7 |t, j8 |j7 |t, j8 |j7 |t, j8 |j; D cg c] \ }}|j< }}}|rn0||v rt> ||v rt j@ |d t jB dt jD \ }}|dk( rne|
jI |d }|8t jJ | } tM || t jP | ntS jT d |z ||v rK|jW d 5 }tY jZ |t\ d
z }t_ | t\ kD r#ta d jc t_ | |^}}}|jQ t jd }|dk( rld
} |jQ |jQ ||||g}|jg |
ji tk |||| }t jv | nC tM || ||
|< t jP | |D ] } t jP | d d d <# t j `w xY w# t $ r Y w xY wc c} }
w c c}}w # tF $ r Y w xY w# tN $ r Y w xY w# tl $ rF t jn t jp t jr ju Y w xY w# t jv | w xY w# tN $ r Y
w xY w# 1 sw Y xY w# tx $ r)} | jz tz j| k7 r Y d } ~ d } ~ ww xY w# 1 sw Y nxY w d d d y # 1 sw Y y xY w) Nr TFc y r" rh )_unuseds r sigchld_handlerz main..sigchld_handler s r )rS i r z.forkserver: waitpid returned unexpected pid %dr z Too many ({0:n}) fds to send)?syspathr current_process _inheritingr import_main_path
__import__ ImportErrorr _close_stdinr& r> set_blockingsignalSIGCHLDSIGINTSIG_IGNrN
set_wakeup_fdr; r< selectorsDefaultSelector getsockname _forkserverr register
EVENT_READselectfileobj
SystemExitreadr( rL ChildProcessErrorpopwaitstatus_to_exitcode write_signedBrokenPipeErrorr' warningswarnacceptr recvfdsr9 r8 RuntimeErrorformatforkextendvalues
_serve_one Exception
excepthookexc_infostderrflush_exitOSErrorerrno ECONNABORTED) listener_fdr` preloadrI rJ modnamesig_rsig_wrl handlerssigval old_handlers pid_to_fdr^ selectorkeyeventsrfdsrW stsrD
returncodesrA rE code
unused_fdsfdes r mainr s "CHHQK Y%:48G # # % 1
:&&y1++-9 G
7# 779LE5OOE5!OOE5!
v~~
H '/nn&68&6
c sC00&6 8 I v~~k :h " " $*2*>*>*@ '(I$8$89'9#7#78%!5!56P
=E__=NO=NMS&CKK=NDO
d? %$D=GGE5) "')zz"bjj'AHC !8 !"+--T":".)+)B)B3)GJ % ,Wj A HHW - %MM +>@C+D E+ 0 t#! *1- ' / />A3E F s8n4". > E E$'H!.#/ / 25.3 ggi !8#$D / ( 0 ( 0.5wu-M
* 1 1)2B2B2D E'1'32<2>(@ !# % ,Wc : .5IcN HHW -&) " '*G .S Q ++-9
&8( P 1 " !" $3 % $ %@ $- 3 # ? #
0 0 2 3 !#
$3 % $ %= .-L
77e 0 00 1
m
% $ $
; : :s6 P> ( Q!Q'2U&A;UTQ-
-,T'Q3/T1 R=ATBTART2 S?>6T4T<U>Q Q$#Q$-T3 R <T?R T R TRTA S" S%!S" "S%%S< <T? T T T TT T U
$ UUU
UU U&&U/c n t j d |j D ] \ }}t j || |D ] }t j | |^t
_ t j _ t
_
t j | }t j | | }|S )Nrm )rw r{ rN r& r' r r r _resource_tracker_fdr dupr _main) rE rA r r r r r parent_sentinelr s r r r - s
NN$S
c3 %
%("[%''+ ffWoO ;;w 0D Kr c d}t j }t | |k rCt j | |t | z
}|s t d ||z
}t | |k rCt j
| d S )Nr zunexpected EOFr )
SIGNED_STRUCTsizer8 r& r EOFErrorunpack)r r[ lengthr s r read_signedr D su D
F
d)f
GGBT* ++, , d)f
%a ((r c t j | }|r/t j | | }|dk( r t d ||d }|r.y y )Nr zshould not get here)r packr& writer )r nmsgnbytess r r r N sH
Q
C
"c" Q; 45 5&'l r )NN) r r& r| rw r; structrn r r r r contextr r r r __all__r9 Structr objectr r r r r r r
r r r
rh r r r s
%
c"
A+ A+NCL.) l ++ 11 $;; $;; r