Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]



��Yf �@sd
dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
lZddlm	Z	
ddlm
Z

ddlmZ
ddlmZ
ddlm
Z

ddlmZ
d	d
ddgZd
Zejd�
ZGdd�de�Zd
d
dd�Zdd�Zdd�Zdd�Ze�ZejZejZejZejZd
S)�N�
)
�
connection)
�process)
�	reduction)
�semaphore_tracker)
�spawn)
�util�ensure_running�get_inherited_fds�connect_to_new_process�set_forkserver_preload�
�
Qc@sLeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�ZdS)�
ForkServerc

Cs:d|_d|_
d|_tj�|_d
g
|_dS)N�__main__)�_forkserver_address�_forkserver_alive_fd�_inherited_fds�	threadingZLock�_lock�_preload_modules)
�self�r�?/opt/alt/python35/lib64/python3.5/multiprocessing/forkserver.py�__init__!s

	
	
	

zForkServer.__init__cCs5td
d�|j
D�
�
s(td�
�
|
|_
dS)z>Set list of module names to try to load in forkserver process.c
ss!|]}
t|
�
t
kV
qdS)
N)�type�str)�.0�modrrr�	<genexpr>*sz4ForkServer.set_forkserver_preload.<locals>.<genexpr>z&module_names must be a list of stringsN)�allr�	TypeError)rZ
modules_namesrrrr(s

z!ForkServer.set_forkserver_preloadc


Cs|jS)
z�Return list of fds inherited from parent process.

        This returns None if the current process was not started by fork
        server.
        )
r)
rrrrr
.szForkServer.get_inherited_fdscCs

|j�
t
|
�
d
tkr,td�
�
tjtj�
��}|j|j�

tj	�\}}tj	�\}}|||j
tj�g}||
7}zJyt
j||�
||fSWn%


tj|�

tj|�

�Yn
XWdtj|�

tj|�

XWdQRXdS)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	�len�MAXFDS_TO_SEND�
ValueError�socket�AF_UNIXZconnectr�os�piperrZgetfdrZsendfds�close)r�fdsZclientZparent_r�child_w�child_rZparent_wZallfdsrrrr6s&





















z!ForkServer.connect_to_new_processc
s�
|j��

t
j�
|jd
k	r'd
Sdd}
|jr}ddh�tjd�
}t�f
dd�|j�D�
�
}ni}t	j	t	j
�
�

}tjd	�
}|j
|�

tj|d
�
|j�
tj�\}}z�yy|j�|g}|
|j�||j|f;}
tj�}|g
tj�}	|	d|
g7}	tj||	|�}
Wn


tj|�

�Yn
XWd
tj|�

X||_||_Wd
QRXWd
QRXd
S)z�Make 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.
        Nz-from multiprocessing.forkserver import main; zmain(%d, %d, %r, **%r)�	main_path�sys_path�ignorec
3s-|]#\}
}|
�kr|
|fV
qdS)
Nr)r�
x�
y)
�desired_keysrrres	
z,ForkServer.ensure_running.<locals>.<genexpr>r'i�
z-c)rrr	rrrZget_preparation_data�dict�itemsr&r'rZarbitrary_addressZbindr(�chmodZlistenr)�filenoZget_executablerZ_args_from_interpreter_flagsZspawnv_passfdsr*r)r�cmd�data�listenerZaddress�alive_rZalive_wZfds_to_passZexe�args�pidr)
r3rr	Ss>





	


(



















	
zForkServer.ensure_runningN)�__name__�
__module__�__qualname__rrr
rr	rrrrrs
rc4CsH|r�d
|krN|dk	rNdtj
�_ztj|�

Wdtj
�`Xx1|D])}yt|�

WqUtk
r}


YqUXqUWtj�
t	j
t	jt	jt	j
i}dd�|j�D�
}tjtjd|�

�f
}tj��P
}	|j�t_|	j|tj�
|	j|
tj�
x
y�x$dd�|	j�D�
}
|
r+
Pq+
W|
|
kra
t�
|j�d	��}d
}tj�d	kr�
zPyt|||
|�
Wn2tk
r�



tj tj!��
tj"j#�
Yn
XWdtj$|�

XWdQRXWq%
t%k
r1
}

z|
j&t&j'kr�WYdd}
~
Xq%
Xq%
WWdQRXWdQRXdS)zRun forkserver.rNTc
Ss+i|]!\}
}tj|
|�|
�qSr)
�signal)r�sig�valrrr�
<dictcomp>�s	
zmain.<locals>.<dictcomp>r7c
Ssg|]\}
}|
j�qSr)
Zfileobj)r�keyZeventsrrr�
<listcomp>�s	zmain.<locals>.<listcomp>r
r)(rZcurrent_processZ_inheritingrZimport_main_path�
__import__�ImportErrorrZ_close_stdinrA�SIGCHLD�SIG_IGN�SIGINT�SIG_DFLr5r&r'�	selectorsZDefaultSelectorZgetsockname�_forkserverr�registerZ
EVENT_READZselect�
SystemExitZacceptr(�fork�
_serve_one�	Exception�sys�
excepthook�exc_info�stderr�flush�_exit�OSError�errnoZECONNABORTED)Zlistener_fdr;Zpreloadr.r/�modname�handlersZold_handlersr:ZselectorZrfds�
s�code�
errr�main�sR











	

	


















racCs�|
j�
t
j|�

x*|j�D]\}}tj||�
q$Wtj|td
�}|j�
|^}}t_}	t_	|	t
j_t
|t
j��
dtjkr�ddl}
|
j�
tj|�
}t
||�
dS)Nr�randomr
)r*r(r5rArZrecvfdsr$rNrrrZ_semaphore_trackerZ_fd�write_unsigned�getpidrT�modulesrbZseedr�_main)r^r:r;r]rBrCr+r-r,Zstfdrbr_rrrrR�s










rRc
Csqd
}
tj
}xNt|
�
|kr_tj||t|
�
�}|sRtd�
�
|
|7}
qWtj|
�
dS)N�zunexpected EOFr
)�UNSIGNED_STRUCT�sizer#r(�read�EOFErrorZunpack)�fdr9Zlengthr^rrr�
read_unsigned�s

	





rmcCsZtj
|
�
}xD|rUtj||�}|d
krBtd�
�
||d�}qWdS)Nr
zshould not get here)rhZpackr(�write�RuntimeError)rl�
n�msg�nbytesrrrrc�s

	



rc)r[r(rMrAr&ZstructrTr�rrrrrr�__all__r$ZStructrh�objectrrarRrmrcrNr	r
rrrrrr�<module>
s6











	
	
h=!