python (3.12.0)
̑ef/ 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 N/BuggyBox/python/3.12.0/bootstrap/lib/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 " ! " " "s '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 L t d |D s t d || _ y)z>Set list of module names to try to load in forkserver process.c 3 > K | ] }t | t u y wr" )typestr).0mods r <genexpr>z4ForkServer.set_forkserver_preload.<locals>.<genexpr>@ s =49#=s z&module_names must be a list of stringsN)all TypeErrorr )r
modules_namess r r
z!ForkServer.set_forkserver_preload> s$ =}== DE E - r c | j S )zReturn list of fds inherited from parent process.
This returns None if the current process was not started by fork
server.
)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 | cddd S # t j | t j | xY w# t j | t j | w xY w# 1 sw Y yxY w)a; Request forkserver to create a child process.
Returns a pair of fds (status_r, data_w). The calling process can read
the child process's pid and (eventually) its returncode from status_r.
The calling process should write to data_w the pickled preparation and
process data.
z too many fdsN)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 A1E2D *E2-E E,E//E22E;c 4 | j 5 t j | j qt j
| j t j \ }}|s
ddd yt 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 |
| | _ | | _ || _ ddd ddd yc c}}w # t j | xY w# t j |
w xY w# 1 sw Y MxY w# 1 sw Y yxY w) zMake sure that a fork server is running.
This can be called from any process. Note that usually a child
process will just reuse the forkserver started by its parent, so
ensure_running() will do nothing.
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 1 + + + -##/ jj)=)=rzz J V1 + 1 + 223+/(,0)'+$,C $$ +Z 8 11(;)- KAl9J1KK v~~.
+($66yA
g&88AHHWe,! $&779 &#+??#4g">KHOO -w8M8M " "C ..0C 54#D#D#FFDT3K'D --c4EC
HHW%+2(,3)'*$3
+11 + 1 +( L,HHW%HHW%-
+
+11 + 1 +si AJ+A.J I&I+)JA9JA=I
*J6JJ
I%%I((I??JJ JJN)
__name__
__module__ __qualname__r r$ r# r
r r r
r r r r s% -"
( . #":8+r r c
|r\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 }|j- t. _ |j3 |t( j4 |j3 |t( j4 |j3 |t( j4 |j7 D cg c] \ }}|j8 }}}|rn0||v r&t j: |d dk( sJ d t< ||v rt j: |d
t j> d t j@ \ }}|d k( rne|
jE |d }|8t jF | } tI || t jL | ntO jP d
|z ||v rK|jS d 5 }tU jV |tX dz }t[ | tX kD r#t] dj_ t[ | |^}}}|jM t j` }|d k( rld} |jM |jM ||||g}|jc |
je tg |||| }t jt | nC tI || ||
|< t jL | |D ] } t jL | ddd \# t j `w xY w# t $ r Y w xY wc c} }
w c c}}w # tB $ r Y w xY w# tJ $ r Y w xY w# th $ rF tk jl tk jn tj jp js Y w xY w# t jt | w xY w# tJ $ r Y
w xY w# 1 sw Y xY w# tv $ r)} | jx tx jz k7 r Y d} ~ d} ~ ww xY w# 1 sw Y nxY wddd y# 1 sw Y yxY w)zRun forkserver.r NTFc y r" rh )_unuseds r sigchld_handlerz main.<locals>.sigchld_handler s r )rS r r z Not at EOF?i r z.forkserver: waitpid returned unexpected pid %dz Too many ({0:n}) fds to send)>r current_process _inheritingr import_main_path
__import__ ImportErrorr _close_stdinr& r> set_blockingsignalSIGCHLDSIGINTSIG_IGNrN
set_wakeup_fdr; r< selectorsDefaultSelector getsockname _forkserverr register
EVENT_READselectfileobjread
SystemExitr( rL ChildProcessErrorpopwaitstatus_to_exitcode write_signedBrokenPipeErrorr' warningswarnacceptr recvfdsr9 r8 RuntimeErrorformatforkextendvalues
_serve_one Exceptionsys
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 Y%:48G # # % 1
:&&y1++-9 G
7# 779LE5OOE5!OOE5!
v~~
H '/nn&68"c sC00 8L 8 I v~~k : Yh " " $Y(0*2*>*>*@ '(I$8$89'9#7#78%!5!56P
=E__=NOMS&CKKODO
d? 777A.#5D}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
oY Y Y Y Ys7 Q Q!<!Q1 U/1A;U-T%Q7
A T%$'Q= /T%; R
AT%BTAR %T< T 6T>T%UQ ! Q.-Q.7T%= R
T% R
T%
RT%RT% A S, (S/+S, ,S//T T T TT TT" T%% U. U UUUU# U//U8c n t j d |j D ] \ }}t j || |D ] }t j | |^t
_ t j _ t
_
t j | }t j | | }|S )Nrm )ru ry 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 B 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 L sH
Q
C
"c" Q; 45 5&'l r )NN) r r& rz ru r; structr r r r r contextr r r r __all__r9 Structr objectr r r r r r} r
r r r
rh r r <module>r s
%
c"
A+ A+NAH.) l ++ 11 $;; $;; r 
Browse
Usage
Versions