✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

�

�֦i���dd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlmZ
ddlm	Z	
dg
Z
ejdk(re
dg
z
Z
Gd	�de�Z
ne
d
g
z
Z
Gd�d
e�ZGd�d
e�Ze�Zej"Zy
)�N�
)
�process)
�	reduction)
�util�stop�win32�	DupSocketc
��eZ
dZ	d
�Zd�Zy)r	c�z��|
j
���f
d
�}tj|�j�|_y)Nc�J�
��j
|
�
}|j|�

y�
N)�share�
send_bytes)�conn�pidr�new_socks   ��8/usr/lib64/python3.12/multiprocessing/resource_sharer.py�sendz DupSocket.__init__.<locals>.sends��� ���s�+������&�)�dup�_resource_sharer�register�close�_id)�self�sockrrs   @r�__init__zDupSocket.__init__s-����x�x�z�H�
'�(�0�0��x�~�~�F�D�Hrc
��	tj|j�
5}
|
j�}t	j
|�
cddd�
S#1s
w
Y

yxYw
r
)r�get_connectionr�
recv_bytes�socket�	fromshare)rrrs   r�detachzDupSocket.detach$s?��C�!�0�0����:�d����)���'�'��.�;�:�:�s�%A�AN��__name__�
__module__�__qualname__rr#�rrr	r	s��-�	G
�	/r�DupFdc
��eZ
dZ	d
�Zd�Zy)r)c�z��t
j|
�
��f
d
�}�f
d�}tj||�|_y)Nc�4�
�t
j|�|
�
yr
)r�send_handle)rr�new_fds  �rrzDupFd.__init__.<locals>.send1s����%�%�d�F�C�8rc�0�
�t
j��

yr
)�osr)
r.s
�rrzDupFd.__init__.<locals>.close3s������� r)r0rrrr)r�fdrrr.s    @rrzDupFd.__init__/s.����V�V�B�Z�F�

9�

!�'�0�0��u�=�D�Hrc
��	tj|j�
5}
tj|
�
cddd�
S#1s
w
Y

yxYw
r
)rrrr�recv_handle)rrs  rr#zDupFd.detach7s3��?�!�0�0����:�d� �,�,�T�2�;�:�:�s�A�A	Nr$r(rrr)r)-s��;�	>�	3rc�D�eZ
dZ	d
�Zd�Zed��Zd	d�
Zd�Zd�Z	d�Z
y)
�_ResourceSharerc
���d
|_i|_
tj�|_d|_d|_d|_tj|tj�
y)Nr)�_key�_cache�	threading�Lock�_lock�	_listener�_address�_threadr�register_after_forkr5�
_afterfork)
rs
 rrz_ResourceSharer.__init__?sI����	�����^�^�%��
������
����� � ���'A�'A�Brc�
�	|j5
|j�|j�
|x
jd
z
c_|
|f|j|j<|j|jfcddd�
S#1s
w
Y

yxYw
)Nr)r;r=�_startr7r8)rrrs   rrz_ResourceSharer.registerHs\��9�
�Z�Z��}�}�$����
��I�I��N�I�&*�E�]�D�K�K��	�	�"��M�M�4�9�9�-��Z�Z�s�A$A<�<Bc
��	d
dlm
}

|\}}|
|tj�j��}|j|t
j�f�

|S)Nr�
�Client�
�authkey)�
connectionrEr�current_processrGrr0�getpid)�identrE�address�key�
cs     rrz_ResourceSharer.get_connectionQsH��J�&������7�G�$;�$;�$=�$E�$E�F�
�	����R�Y�Y�[�!�"��rNc��	d
dlm
}
|j5
|j�
�||jt	j
�j��}|jd�

|j�
|jj|
�

|jj�rtjd�

|jj�
d|_	d|_d|_|jj!�D]\}\}}|�
�|jj#�
ddd�
y#1s
w
Y

yxYw
)NrrDrFz._ResourceSharer thread did not stop when asked)rHrEr;r=rrIrGrrr>�join�is_aliver�sub_warningr<r8�items�clear)r�timeoutrErNrMrrs       rrz_ResourceSharer.stopZs���H�&�
�Z�Z��}�}�(��4�=�=�#*�#:�#:�#<�#D�#D�
F
�
����t�����	����!�!�'�*��<�<�(�(�*��$�$�
&;�
<����$�$�&�#��� $��
�!%���*.�+�+�*;�*;�*=�&�C��$���G�+>����!�!�#�!�Z�Z�s�DD;�;Ec
�:
�|jj�D]\}
\}}|�
�|jj�
|jj	�
|j
�|j
j
�
d|_d|_d|_yr
)	r8rSrTr;�_at_fork_reinitr<rr=r>)rrMrrs    rr@z_ResourceSharer._afterforkosv��"&�+�+�"3�"3�"5��C��$���G�#6��������
�
�"�"�$��>�>�%��N�N� � �"������
���rc
�B
�d
dlm
}

tjd�

|
t	j
�jd��|_|jj|_	tj|j��
}d|_
|j�
||_y)Nr)
�Listenerz0starting listener and thread for sending handles�)rG�backlog)
�targetT)rHrYr�debugrrIrGr<rLr=r9�Thread�_serve�daemon�startr>)rrY�
ts   rrBz_ResourceSharer._startzsl��(��
�
�E�F�!�'�*A�*A�*C�*K�*K�UX�Y������.�.��
����D�K�K�0�
��
��	���	���rc
�*�t
td
�r6tjtjtj��
		|j
j
�5}
|
j�}|�
	ddd�
y|\}}|jj|�
\}}	||
|�
|�
	ddd�
�v#|�
wxYw
#1s
w
Y

�xYw
#
tj�s$tjtj��
Y�UxYw
)N�pthread_sigmask)�hasattr�signalrd�	SIG_BLOCK�
valid_signalsr<�accept�recvr8�popr�
is_exiting�sys�
excepthook�exc_info)rr�msgrM�destination_pidrrs       rr_z_ResourceSharer._serve�s����6�,�-��"�"�6�#3�#3�V�5I�5I�5K�L��

4��^�^�*�*�,���)�)�+�C��{��-�,�,/�(�C��"&�+�+�/�/�#�"6�K�D�%� ��T�?�3���-������-�,��
4����(��N�N�C�L�L�N�3�sH�	C�#C
�7C�#C
�$	B>�-C
�5C�>	C�C
�
C�C�:Dr
)r%r&r'rr�staticmethodrrr@rBr_r(rrr5r5=s8��8�C
�.�����$�*	�	�4rr5)r0rfr!rmr9�r�contextrr�__all__�platform�objectr	r)r5rrr(rr�<module>rx
s��


�

�
�
�
������(���<�<�7����}��G�
/�F�
/� ��y��G�
3��
3� Y

4�f�Y

4�x#�$�����r