o
0¦in/ ã @ sú 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
Ze d ¡ZG d d
„ d
eƒZddd„Zdd„ Zdd„ Zdd„ Zeƒ Zej Z ej Z ej Z ej Z dS )é Né )Ú
connection)Úprocess)Ú reduction)Úresource_tracker)Úspawn)Úutil)Úensure_runningÚget_inherited_fdsÚconnect_to_new_processÚset_forkserver_preloadé Úqc @ sD e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dS )Ú
ForkServerc C s. d | _ d | _d | _d | _t ¡ | _dg| _d S )NÚ__main__)Ú_forkserver_addressÚ_forkserver_alive_fdÚ_forkserver_pidÚ_inherited_fdsÚ threadingZLockÚ_lockÚ_preload_modules©Úself© r úA/opt/alt/python310/lib64/python3.10/multiprocessing/forkserver.pyÚ__init__" s
zForkServer.__init__c C s4 | j
| ¡ W d ƒ d S 1 sw Y d S ©N)r Ú_stop_unlockedr r r r Ú_stop* s
"ÿzForkServer._stopc C sV | j d u rd S t | j¡ d | _t | j d¡ d | _ t | j¡s&t | j¡ d | _d S )Nr ) r ÚosÚcloser Úwaitpidr Ú is_abstract_socket_namespacer Úunlinkr r r r r / s
zForkServer._stop_unlockedc C s( t dd„ | jD ƒƒstdƒ‚|| _d S )Nc s s | ] }t |ƒtu V qd S r )ÚtypeÚstr)Ú.0Úmodr r r Ú @ s € z4ForkServer.set_forkserver_preload..z&module_names must be a list of strings)Úallr Ú TypeError)r Z
modules_namesr r r r > s
z!ForkServer.set_forkserver_preloadc C s | j S r )r r r r r r
D s z ForkServer.get_inherited_fdsc
C sò | ¡ t|ƒd tkrtdƒ‚t tj¡X}| | j¡ t ¡ \}}t ¡ \}}||| j
t ¡ g}||7 }z,z t
||¡ ||fW W t |¡ t |¡ W d ƒ S t |¡ t |¡ ‚ t |¡ t |¡ w 1 srw Y d S )Né z too many fds)r ÚlenÚMAXFDS_TO_SENDÚ
ValueErrorÚsocketÚAF_UNIXZconnectr r Úpiper r Zgetfdr Zsendfdsr! )r ÚfdsZclientZparent_rÚchild_wÚchild_rZparent_wZallfdsr r r r L s2 ÿ
ð
ðz!ForkServer.connect_to_new_processc sÒ | j Û t ¡ | jd ur2t | jtj¡\}}|s# W d ƒ d S t | j¡ d | _ d | _d | _d}| j
rLddh‰ t d¡}‡ fdd„|
¡ D ƒ}ni }t tj¡s}t d¡}| |¡ t |¡sjt |d¡ | ¡ t ¡ \}}z„ s z-ForkServer.ensure_running..r1 i€ z-c) r r r r r r" ÚWNOHANGr! r r r r Zget_preparation_dataÚitemsr0 r1 r Zarbitrary_addressZbindr r# ÚchmodZlistenr2 ÚfilenoZget_executableZ _args_from_interpreter_flagsZspawnv_passfds) r ÚpidZstatusÚcmdÚdataÚlistenerZaddressÚalive_rZalive_wZ fds_to_passZexeÚargsr r; r r i s\
ù
ÿ
ý çè"èzForkServer.ensure_runningN)
Ú__name__Ú
__module__Ú __qualname__r r r r r
r r r r r r r s r c C sÎ |r5d|v r!|d ur!dt ¡ _z t |¡ W t ¡ `nt ¡ `w |D ]}zt|ƒ W q# ty4 Y q#w t ¡ t
¡ \}}t |d¡ t |d¡ dd„ }t j
|t jt ji} dd„ | ¡ D ƒ}
t |¡ i } tjtj| dk} t ¡ T}
| ¡ t_|
| tj¡ |
|tj¡ |
|tj¡ z d d
„ |
¡ D ƒ}|r¢nq–||v r©t ‚||v rüt |d ¡ z t d t j ¡\}}W n t yÈ Y n4w |d
krÎn.| !|d ¡}|d urôt "|¡}zt#||ƒ W n t$yí Y nw t %|¡ nt& 'd| ¡ q´| |v r| (¡ d
}t) *|t+d ¡}t,|ƒt+kr t-d .t,|ƒ¡ƒ‚|^}}}| %¡ t /¡ }|d
krwd}z.sigchld_handlerc S s i | ] \}}|t ||¡“qS r )Úsignal)r' ÚsigÚvalr r r r< Æ s ÿzmain..)r@ c S s g | ]\}}|j ‘qS r )Zfileobj)r' ÚkeyZeventsr r r Ú
Ú s zmain..i éÿÿÿÿr z.forkserver: waitpid returned unexpected pid %dr z Too many ({0:n}) fds to send)=r Zcurrent_processZ _inheritingr Zimport_main_pathÚ
__import__Ú ImportErrorr Z _close_stdinr r2 Ú set_blockingrK ÚSIGCHLDÚSIGINTÚSIG_IGNr> Ú
set_wakeup_fdr0 r1 Ú selectorsZDefaultSelectorZ getsocknameÚ _forkserverr ÚregisterZ
EVENT_READZselectÚ
SystemExitÚreadr" r= ÚChildProcessErrorÚpopÚwaitstatus_to_exitcodeÚ write_signedÚBrokenPipeErrorr! ÚwarningsÚwarnZacceptr Zrecvfdsr. r- Ú RuntimeErrorÚformatÚforkÚextendÚvaluesÚ
_serve_oneÚ ExceptionÚsysÚ
excepthookÚexc_infoÚstderrÚflushÚ_exitÚOSErrorÚerrnoZ ECONNABORTED)Z listener_fdrE Zpreloadr6 r7 ÚmodnameZsig_rZsig_wrJ ÚhandlersZ old_handlersZ pid_to_fdrD ZselectorZrfdsrA Ústsr4 Ú
returncodeÚsr3 r5 ÚcodeÚ
unused_fdsÚfdÚer r r Úmain§ sæ
ÿ üÿ
ÿ
ý ÿ
þ ÿë
ÿÿ
þþ€þ
€ Ü€& ÿ€ÿ±8ør| c C sh t d¡ | ¡ D ]
\}}t ||¡ q |D ]}t |¡ q|^t_tj_ t_
t | ¡}t
| |¡}|S )NrP )rK rW r> r r! rY r r Z_resource_trackerZ_fdr Údupr Z_main) r5 r3 ry rt rL rM rz Zparent_sentinelrx r r r ri + s
þ
ri c C sX d}t j}t|ƒ|k r%t | |t|ƒ ¡}|stdƒ‚||7 }t|ƒ|k s t |¡d S )Nó zunexpected EOFr )Ú
SIGNED_STRUCTÚsizer- r r\ ÚEOFErrorZunpack)rz rC Zlengthrw r r r Ú read_signedB s ür‚ c C sB t |¡}|r t | |¡}|dkrtdƒ‚||d … }|sd S d S )Nr zshould not get here)r Zpackr Úwriterd )rz ÚnÚmsgÚnbytesr r r r` L s
ür` )NN) rr r rX rK r0 Zstructrk r rb Ú r r Úcontextr r r r Ú__all__r. ZStructr Úobjectr r| ri r‚ r` rY r r
r r r r r r Ú s<