$42 GRAYBYTE WORDPRESS FILE MANAGER $81



���] �@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�	threading�Lock�_lock�_preload_modules)
�self�r�//opt/alt/python35/lib64/python3.5/forkserver.py�__init__!s

	
	
	

zForkServer.__init__cCs5td
d�|j
D�
�
s(td�
�
|
|_
dS)Nc
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 strings)�allr�	TypeError)rZ
modules_namesrrrr(s

z!ForkServer.set_forkserver_preloadc


Cs|jS)
N)
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)N�ztoo many fds)r	�len�MAXFDS_TO_SEND�
ValueError�socket�AF_UNIX�connectr�os�piperrZgetfdr�sendfds�close)r�fds�clientZparent_r�child_w�child_rZparent_wZallfdsrrrr6s&





















z!ForkServer.connect_to_new_processc
s�
|j��

t
j�
|jdk	r'dSd
d}
|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
XWdtj|�

X||_||_WdQRXWdQRXdS)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_keysrrr es	
z,ForkServer.ensure_running.<locals>.<genexpr>r(i�
z-c)rrr	rrrZget_preparation_data�dict�itemsr'r(r�arbitrary_address�bindr*�chmod�listenr+�filenoZget_executabler�_args_from_interpreter_flags�spawnv_passfdsr-r)r�cmd�data�listener�address�alive_rZalive_wZfds_to_passZexe�args�pidr)
r7rr	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�dkr�
zPyt|||
|�
Wn2tk
r�



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

XWdQRXWq%
t%k
r1
}

z|
j&t&j'kr�WYdd}
~
Xq%
Xq%
WWdQRXWdQRXdS)
NrTc
Ss+i|]!\}
}tj|
|�|
�qSr)
�signal)r�sig�valrrr�
<dictcomp>�s	
zmain.<locals>.<dictcomp>r>c
Ssg|]\}
}|
j�qSr)
�fileobj)r�key�eventsrrr�
<listcomp>�s	zmain.<locals>.<listcomp>r
r)(r�current_processZ_inheritingrZimport_main_path�
__import__�ImportErrorr�_close_stdinrK�SIGCHLD�SIG_IGN�SIGINT�SIG_DFLr9r'r(�	selectors�DefaultSelector�getsockname�_forkserverr�register�
EVENT_READ�select�
SystemExit�acceptr*�fork�
_serve_one�	Exception�sys�
excepthook�exc_info�stderr�flush�_exit�OSError�errnoZECONNABORTED)Zlistener_fdrEZpreloadr2r3�modname�handlersZold_handlersrC�selectorZrfds�
s�code�
errr�main�sR











	

	


















ruc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*r9rKr�recvfdsr%r^rrrZ_semaphore_trackerZ_fd�write_unsigned�getpidrg�modulesrv�seedr�_main)rrrCrErprLrMr.r1r0Zstfdrvrsrrrre�s










rec
Csqd
}
tj
}xNt|
�
|kr_tj||t|
�
�}|sRtd�
�
|
|7}
qWtj|
�
dS)N�zunexpected EOFr
)�UNSIGNED_STRUCT�sizer$r*�read�EOFError�unpack)�fdrB�lengthrrrrr�
read_unsigned�s

	





r�cCsZtj
|
�
}xD|rUtj||�}|d
krBtd�
�
||d�}qWdS)Nr
zshould not get here)r~�packr*�write�RuntimeError)r��
n�msg�nbytesrrrrx�s

	



rx)rnr*r[rKr'�structrgr�rrrrrr�__all__r%�Structr~�objectrrurer�rxr^r	r
rrrrrr�<module>
s6











	
	
h=!