✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

a

�i(%�@sdd
lm
Z

ddlZddlZddlZddlZddlZddlZddlZddl	m
Z

gd�
Zejdkp�e
ed�o�e
ed�o�e
ejd	�ZGd
d�dej�ZejZd8dd
�
Zejdk�r�egd�
7ZddlZd9dd�
dd�Zdd�Zdd�Zdd�ZGdd�de�ZnFegd�
7ZddlZejdkZdd�Zdd �Zd!d�Zd"d�Zd#d$�Zd%d&�ZGd'd(�d(�Z ee!e �j"�
e�
d)d*�Z#ee!e$j%�
e#�
ee!e&j'�
e#�
d+d,�Z(d-d.�Z)eej*e(�
ejdk�
r�d/d0�Z+d1d2�Z,eeje+�
nd3d0�Z+d4d2�Z,eeje+�
Gd5d6�d6e
d7�Z-dS):�)
�ABCMetaN�
)
�context)�send_handle�recv_handle�ForkingPickler�register�dump�win32�CMSG_LEN�
SCM_RIGHTS�sendmsgcsFeZ
dZiZejZ�f
d
d�Zedd��
Z	eddd�
�
Z
ejZ�Z
S)	rc
s*t�j
|
�
|j��|_|j�|j�

dS�
N)�super�__init__�_copyreg_dispatch_table�copy�dispatch_table�update�_extra_reducers��self�args�
�	__class__��1/usr/lib64/python3.9/multiprocessing/reduction.pyr&s


zForkingPickler.__init__cCs||j|
<dSr)
r)�cls�type�reducerrrr+szForkingPickler.registerNcCs t�
�}|||��|
�

|��Sr)�io�BytesIOr	�	getbuffer)r�obj�protocol�bufrrr�dumps0s

zForkingPickler.dumps)
N)�__name__�
__module__�__qualname__r�copyregrrr�classmethodrr&�pickle�loads�
__classcell__rrrrr!s



rcCst|
|��
|�

dSr)rr	)r#�filer$rrrr	:sr	)�	DupHandle�	duplicate�steal_handleF)
�source_processc
Cs6t�
�}|dur|}|
dur |}
t�|||
d
|tj�S)Nr
)�_winapi�GetCurrentProcess�DuplicateHandle�DUPLICATE_SAME_ACCESS)�handleZtarget_process�inheritabler3�current_processrrrr1Gs






�r1c	CsNt�
tjd
|�}z,t�||
t��dd
tjtjB�Wt�|�

St�|�

0dS�NFr
)r4�OpenProcess�PROCESS_DUP_HANDLEr6r5r7�DUPLICATE_CLOSE_SOURCE�CloseHandle)Z
source_pidr8Zsource_process_handlerrrr2Ss
�





�
�r2cCst|
t
j|�}|�|�

dSr)r0r4r7�send)�connr8�destination_pidZdhrrrr_s
rc

Cs|���
�Sr)�recv�detach)
rArrrrdsrc@seZ
dZddd�
Zdd�Zd
S)r0Nc	Csf|durt�
�}t�tjd
|�}z(t�t��|
||d
d�|_Wt�|�

nt�|�

0||_	||_
dSr;)�os�getpidr4r<r=r6r5�_handler?�_access�_pid)rr8�access�pid�procrrrrjs






�

zDupHandle.__init__c
	Csb|jt
��kr|jSt�tjd
|j�}
z*t�|
|jt��|j	d
tj
�Wt�|
�

St�|
�

0dS)NF)rIrErFrGr4r<r=r6r5rHr>r?)rrLrrrrDys

�



�
�zDupHandle.detach)
N)r'r(r)rrDrrrrr0hs
r0)�DupFd�sendfds�recvfds�darwincCsVt�d
|
�}
t
t|
�
dg
�
}|�|g
tjtj|
fg
�
trR|�d�
dkrRt	d�
�
dS)N�
i�
r�
Az%did not receive acknowledgement of fd)
�array�bytes�lenr
�socket�
SOL_SOCKETr�ACKNOWLEDGErC�RuntimeError)�sock�fds�msgrrrrN�s




rNc	Cs
t�d
�
}|j
|
}|�dt�|�
�\}}}}|s:|s:t�
z�trJ|�d�

t|�
dkrft	dt|�
�
�
|d\}}	}
|tj
kr�|	tjkr�t|
�
|j
dkr�t�
|�
|
�

t|�
d|dkr�td�t|�
|d��
�
t|�
WSWnttfy�


Yn0t	d�
�
dS)	NrQrrSzreceived %d items of ancdatar
rRz Len is {0:n} but msg[0] is {1!r}zInvalid data received)rT�itemsize�recvmsgrW�
CMSG_SPACE�EOFErrorrYr@rVrZrXr�
ValueError�	frombytes�AssertionError�format�list�
IndexError)r[�size�
a�
bytes_sizer]�ancdata�flags�addr�
cmsg_level�	cmsg_type�	cmsg_datarrrrO�s:












�


�






��


rOcCsFt�
|��tjtj��}t||
g
�
Wd�
n1s80


Y
dSr)rW�fromfd�fileno�AF_UNIX�SOCK_STREAMrN)rAr8rB�
srrrr�s
c
CsHt�
|��tjtj��}
t|
d
�dWd�
S1s:0


Y
dS)Nrr
)rWrqrrrsrtrO)rArurrrr�s
c
CsFt�
�}
|
du
r |
�|
�|�
�
Str:d
dlm}
|�|�
Std�
�
dS)Nr)
�resource_sharerz&SCM_RIGHTS appears not to be available)r�get_spawning_popenrM�duplicate_for_child�HAVE_SEND_HANDLE�rvrb)�fd�	popen_objrvrrrrM�s





rMc

Cs2|jdurt
|j|jjffSt
|j|jjffSdSr)�__self__�getattrr�__func__r'�
�
mrrr�_reduce_method�s


r�c@seZ
dZd
d�ZdS)�_Cc


CsdSrr)
rrrr�
f�s
z_C.fN)r'r(r)r�rrrrr��s
r�c

Cst|j
|jffSr)r~�__objclass__r'r�rrr�_reduce_method_descriptor�s
r�c

Cst|j
|j|jpiffSr)�_rebuild_partial�funcr�keywords)
�
prrr�_reduce_partial�s
r�cCstj
|g
|
�
Ri|�
�
Sr)�	functools�partial)r�rr�rrrr��s
r�c
Csd
dlm
}

t|
|�
f
fS)Nr)
�	DupSocket)rvr��_rebuild_socket)rur�rrr�_reduce_socket�s

r�c

Cs|��Sr)
rD)
Zdsrrrr��s
r�c
Cs"t|�
��
}
t|
|j|j|jffSr)rMrrr��familyr�proto)ru�dfrrrr��s

cCs|��}t
j
|
|||d
�S)N)
rr)rDrW)r�r�rr�r{rrrr��s

c@s`eZ
dZeZeZeZeZeZej	d
kr4e
Z
eZeZne
Z
eZeZeZeZeZeZeZdd�ZdS)�AbstractReducerr
c
GsNtt
t�j�
t�
tt
tj�
t�
tt
tj	�
t�
tt
jt�
tt
j
t�
dSr)rrr�r�r�rf�appendr��int�__add__r�r�r�rWr�rrrrr
s





zAbstractReducer.__init__N)r'r(r)rrr	rr�sys�platformr2r1r0rNrOrMr�r�r�r�r�rrrrrr��s$













r�)
�	metaclass)
N)NF).�abcrr*r�r rEr,rWr�rzr�__all__r��hasattrry�Picklerrrr	r4r1r2rr�objectr0rTrYrNrOrMr�r�rr�r�rfr�r�r�r�r�r�r�r�r�rrrr�<module>
sj










�
�	


�#