B
âÁ ÷S•D‹ã @ 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 d d
d d gZd
Ze d¡ZG dd„ deƒZddd„Zdd„ Zdd„ Zdd„ Zeƒ Zej Z ej Z ej Z ej Z dS )é Né )Ú
connection)Úprocess)Ú reduction)Úsemaphore_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 ú?/opt/alt/python37/lib64/python3.7/multiprocessing/forkserver.pyÚ__init__" s
zForkServer.__init__c C s | j | ¡ W d Q R X d S )N)r Ú_stop_unlocked)r r r r Ú_stop* s zForkServer._stopc C sJ | j d krd S t | j¡ d | _t | j d¡ d | _ t | j¡ d | _d S )Nr )r ÚosÚcloser ÚwaitpidÚunlinkr )r r r r r / s
zForkServer._stop_unlockedc C s& t dd„ | jD ƒƒs tdƒ‚|| _dS )z>Set list of module names to try to load in forkserver process.c s s | ]}t |ƒtkV qd S )N)ÚtypeÚstr)Ú.0Úmodr r r ú ? s z4ForkServer.set_forkserver_preload..z&module_names must be a list of stringsN)Úallr Ú TypeError)r Z
modules_namesr r r r = s z!ForkServer.set_forkserver_preloadc C s | j S )z”Return list of fds inherited from parent process.
This returns None if the current process was not started by fork
server.
)r )r r r r r
C s z ForkServer.get_inherited_fdsc
C sÎ | ¡ t|ƒd tkr tdƒ‚t tj¡˜}| | j¡ t ¡ \}}t ¡ \}}||| j
t ¡ g}||7 }zƒ s z-ForkServer.ensure_running..r. i€ z-c) r r r r r r ÚWNOHANGr r r r r Zget_preparation_dataÚitemsr- r. r Zarbitrary_addressZbindr Z is_abstract_socket_namespaceÚchmodZlistenr/ ÚfilenoZget_executableZ _args_from_interpreter_flagsZspawnv_passfds) r ÚpidZstatusÚcmdÚdataÚlistenerZaddressÚalive_rZalive_wZ fds_to_passZexeÚargsr )r8 r r h sL
zForkServer.ensure_runningN)
Ú__name__Ú
__module__Ú __qualname__r r r r r
r r r r r r r s r c C sî |rhd|kr8|dk r8dt ¡ _zt |¡ W dt ¡ `X x.|D ]&}y t|ƒ W q> tk
rb Y q>X q>W t ¡ t
¡ \}}t |d¡ t |d¡ dd„ }t j
|t jt ji} dd„ | ¡ D ƒ}
t |¡ i } tjtj| d } t ¡ î}
| ¡ t_|
| tj¡ |
|tj¡ |
|tj¡ x°yrx d
d „ |
¡ D ƒ}|r,P q,W ||krZt ‚||krJt |d ¡ xØyt d
t j ¡\}}W n t k
r P Y nX |dkr®P | !|d¡}|dk r6t "|¡rÞt #|¡ }n&t $|¡sút%d &||¡ƒ‚t '|¡}yt(||ƒ W n t)k
r( Y nX t *|¡ nt+ ,d| ¡ qrW | |kr˜| -¡ d 0}t. /|t0d ¡}t1|ƒt0kr”t2d &t1|ƒ¡ƒ‚|^}}}| *¡ t 3¡ }|dkrk
rÎ } z|j?t?j@kr¾‚ W dd}~X Y nX q&W W dQ R X W dQ R X dS )zRun forkserver.r NTFc W s d S )Nr )Z_unusedr r r Úsigchld_handler» s z main..sigchld_handlerc S s i | ]\}}t ||¡|“qS r )Úsignal)r$ ÚsigÚvalr r r r9 Å s zmain..)r= c S s g | ]\}}|j ‘qS r )Zfileobj)r$ ÚkeyZeventsr r r ú
Ù s zmain..i éÿÿÿÿr zChild {0:n} status is {1:n}z.forkserver: waitpid returned unexpected pid %dr z Too many ({0:n}) fds to send)Ar Zcurrent_processZ _inheritingr Zimport_main_pathÚ
__import__Ú ImportErrorr Z _close_stdinr r/ Ú set_blockingrH ÚSIGCHLDÚSIGINTÚSIG_IGNr; Ú
set_wakeup_fdr- r. Ú selectorsZDefaultSelectorZ getsocknameÚ _forkserverr ÚregisterZ
EVENT_READZselectÚ
SystemExitÚreadr r: ÚChildProcessErrorÚpopÚ WIFSIGNALEDÚWTERMSIGÚ WIFEXITEDÚAssertionErrorÚformatÚ WEXITSTATUSÚ write_signedÚBrokenPipeErrorr ÚwarningsÚwarnZacceptr Zrecvfdsr+ r* Ú RuntimeErrorÚforkÚextendÚvaluesÚ
_serve_oneÚ ExceptionÚsysÚ
excepthookÚexc_infoÚstderrÚflushÚ_exitÚOSErrorÚerrnoZ ECONNABORTED)Z listener_fdrB Zpreloadr3 r4 ÚmodnameZsig_rZsig_wrG ÚhandlersZ old_handlersZ pid_to_fdrA ZselectorZrfdsr> Ústsr1 Ú
returncodeÚsr0 r2 ÚcodeÚ
unused_fdsÚfdÚer r r Úmain¦ sÀ
r} c C sd t d¡ x | ¡ D ]\}}t ||¡ qW x|D ]}t |¡ q2W |^t_tj_ t_
t | ¡}|S )NrM )
rH rT r; r r rV r r Z_semaphore_trackerZ_fdr r Ú_main)r2 r0 rz ru rI rJ r{ ry r r r rj 0 s
rj c C sR d}t j}x8t|ƒ|k rBt | |t|ƒ ¡}|s8tdƒ‚||7 }q W t |¡d S )Nó zunexpected EOFr )Ú
SIGNED_STRUCTÚsizer* r rY ÚEOFErrorZunpack)r{ r@ Úlengthrx r r r Ú read_signedF s r„ c C s@ t |¡}x0|r:t | |¡}|dkr,tdƒ‚||d … }q W d S )Nr zshould not get here)r€ Zpackr Úwriterf )r{ ÚnÚmsgÚnbytesr r r rb P s
rb )NN) rs r rU rH r- Zstructrl r rd Ú r r Úcontextr r r r Ú__all__r+ ZStructr€ Úobjectr r} rj r„ rb rV r r
r r r r r r Ú s<