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 N t d |D s t d || _ y )Nc 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 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 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
*J7JJI&&I))J 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 rt: ||v rt j< |d t j> dt j@ \ }}|dk( rne|
jE |d }|8t jF | } tI || t jL | ntO jP d |z ||v rK|jS d 5 }tU jV |tX d
z }t[ | tX kD r#t] d j_ t[ | |^}}}|jM t j` }|dk( rld
} |jM |jM ||||g}|jc |
je tg |||| }t jt | nC tI || ||
|< t jL | |D ] } t jL | d d d <# 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 wd d d y # 1 sw Y y xY w) Nr TFc y r" rh )_unuseds r sigchld_handlerz main.<locals>.sigchld_handler s r )rS i r z.forkserver: waitpid returned unexpected pid %dr z 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_READselectfileobj
SystemExitreadr( 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? %$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 Ys6 P) Q=!Q U2A;T;.TQ
,T'Q ,/T Q.(AT/BS:3AQ>S: S*)6S: T'T;)P? QQT Q+'T*Q++T. Q;7T:Q;;T>A S
S S
SS' 'S:* S7 3S:6S7 7S::T ?T T8 T3-T;3T88T;;U UUc 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