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 ]

�

5[Yh���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
dZd
Zd�Zd�Zy)r	zPicklable wrapper for a socket.c�z��|
j
���f
d
�}tj|�j�|_y)Nc�J�
��j
|
�
}|j|�

y�
N)�share�
send_bytes)�conn�pidr�new_socks   ��F/opt/alt/python312/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
|�
cd
d
d
�
S#1s
w
Y

y
xYw
)z1Get the socket.  This should only be called once.N)r�get_connectionr�
recv_bytes�socket�	fromshare)rrrs   r�detachzDupSocket.detach$s<��!�0�0����:�d����)���'�'��.�;�:�:�s�%A�AN��__name__�
__module__�__qualname__�__doc__rr#�rrr	r	s��-�	G
�	/r�DupFdc
��eZ
dZd
Zd�Zd�Zy)r*z-Wrapper for fd which can be used at any time.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)r1rrrr)r�fdrrr/s    @rrzDupFd.__init__/s.����V�V�B�Z�F�

9�

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

y
xYw
)z-Get the fd.  This should only be called once.N)rrrr�recv_handle)rrs  rr#zDupFd.detach7s0��!�0�0����:�d� �,�,�T�2�;�:�:�s	�?�ANr$r)rrr*r*-s��;�	>�	3rc�F�eZ
dZd
Zd�Zd�Zed��Zd
d�
Zd�Z	d�Z
d	�Zy)�_ResourceSharerz.Manager for resources using background thread.c
���d
|_i|_
tj�|_d|_d|_d|_tj|tj�
y)Nr)�_key�_cache�	threading�Lock�_lock�	_listener�_address�_threadr�register_after_forkr6�
_afterfork)
rs
 rrz_ResourceSharer.__init__?sI����	�����^�^�%��
������
����� � ���'A�'A�Brc�
�|j5
|j�|j�
|x
jdz
c_|
|f|j|j<|j|jfcd
d
d
�
S#1s
w
Y

y
xYw
)z+Register resource, returning an identifier.Nr)r<r>�_startr8r9)rrrs   rrz_ResourceSharer.registerHsY��
�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)z<Return connection from which to receive identified resource.r�
�Client�
�authkey)�
connectionrFr�current_processrHrr1�getpid)�identrF�address�key�
cs     rrz_ResourceSharer.get_connectionQsG��	'������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
)z:Stop the background thread and clear registered resources.rrENrGz._ResourceSharer thread did not stop when asked)rIrFr<r>rrJrHrrr?�join�is_aliver�sub_warningr=r9�items�clear)r�timeoutrFrOrNrrs       rrz_ResourceSharer.stopZs���&�
�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
)	r9rTrUr<�_at_fork_reinitr=rr>r?)rrNrrs    rrAz_ResourceSharer._afterforkosv��"&�+�+�"3�"3�"5��C��$���G�#6��������
�
�"�"�$��>�>�%��N�N� � �"������
���rc
�h
�d
dlm
}

|j�Jd��
tjd�

|
tj�jd��|_|jj|_	tj|j��
}d|_
|j�
||_y)	Nr)
�ListenerzAlready have Listenerz0starting listener and thread for sending handles�)rH�backlog)
�targetT)rIrZr=r�debugrrJrHrMr>r:�Thread�_serve�daemon�startr?)rrZ�
ts   rrCz_ResourceSharer._startzs���(��~�~�%�>�'>�>�%��
�
�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�signalre�	SIG_BLOCK�
valid_signalsr=�accept�recvr9�popr�
is_exiting�sys�
excepthook�exc_info)rr�msgrN�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'r(rr�staticmethodrrrArCr`r)rrr6r6=s8��8�C
�.�����$�*	�	�4rr6)r1rgr!rnr:�r�contextrr�__all__�platform�objectr	r*r6rrr)rr�<module>ry
s��


�

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

4�f�Y

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