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 ]

o

�=?h�@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlmZ
ddlm	Z	
dg
Z
ejdkr<e
dg
7Z
Gd	d�de�Z
n
e
d
g
7Z
Gdd
�d
e�ZGdd
�d
e�Ze�ZejZd
S)�N�
)
�process)
�	reduction)
�util�stopZwin32�	DupSocketc@� eZ
dZd
Zdd�Zdd�ZdS)rzPicklable wrapper for a socket.cs(|
����f
d
d�}t
�|�j�|_dS)Ncs��|
�
}|�
|�

dS�
N)�shareZ
send_bytes)�conn�pidr
�
Znew_sock��F/opt/alt/python310/lib64/python3.10/multiprocessing/resource_sharer.py�sends


z DupSocket.__init__.<locals>.send)�dup�_resource_sharer�register�close�_id)�selfZsockrrr
r�__init__s

zDupSocket.__init__c
CsBt�
|j�
�}
|
��}t�|�
Wd
�
S1sw



Y
d
S)z1Get the socket.  This should only be called once.N)r�get_connectionrZ
recv_bytes�socketZ	fromshare)rrr
rrr�detach$s

$�zDupSocket.detachN��__name__�
__module__�__qualname__�__doc__rrrrrrrs

�DupFdc@r)r z-Wrapper for fd which can be used at any time.cs4t�
|
�
��f
d
d�}�f
dd�}t�||�|_dS)Ncst�
|�|
�
dSr	)rZsend_handle)rr�
Znew_fdrrr1s
zDupFd.__init__.<locals>.sendcst�
��

dSr	)�osrrr!rrr3s
zDupFd.__init__.<locals>.close)r"rrrr)r�fdrrrr!rr/s


zDupFd.__init__c
Cs:t�
|j�
�
}
t�|
�
Wd
�
S1sw



Y
d
S)z-Get the fd.  This should only be called once.N)rrrrZrecv_handle)rrrrrr7s
$�zDupFd.detachNrrrrrr -s

c@sNeZ
dZd
Zdd�Zdd�Zedd��
Zdd	d
�
Zdd�Z	d
d�Z
dd�ZdS)�_ResourceSharerz.Manager for resources using background thread.c

Cs:d
|_i|_
t��|_d|_d|_d|_t�	|t
j�
dS)Nr
)�_key�_cache�	threadingZLock�_lock�	_listener�_address�_threadrZregister_after_forkr$�
_afterfork)
rrrrr?s







z_ResourceSharer.__init__cCsf|j�&
|j
d
ur
|��
|jd7_|
|f|j|j<|j
|jfWd
�
S1s,w



Y
d
S)z+Register resource, returning an identifier.Nr)r(r*�_startr%r&)rrrrrrrHs






$�z_ResourceSharer.registerc
Cs<d
dlm
}

|\}}|
|t��jd�}|�|t��f�

|S)z<Return connection from which to receive identified resource.r�
�Client�
�authkey)�
connectionr/r�current_processr1rr"�getpid)Zidentr/�address�key�
crrrrQs




z_ResourceSharer.get_connectionNcCs�d
dlm
}
|j�[
|jdu
r\||jt��jd�}|�d�

|��
|j	�
|
�

|j	��r2t�
d�

|j��
d|_	d|_d|_|j��D]	\}\}}|�
qE|j��
Wd�
dSWd�
dS1sgw



Y
dS)z:Stop the background thread and clear registered resources.rr.Nr0z._ResourceSharer thread did not stop when asked)r2r/r(r*rr3r1rrr+�joinZis_aliverZsub_warningr)r&�items�clear)rZtimeoutr/r7r6rrrrrrZs*




�













�
"�z_ResourceSharer.stopc
Cs\|j�
�D]	\}
\}}|�
q|j��
|j��
|jdu
r#|j��
d|_d|_d|_dSr	)	r&r9r:r(�_at_fork_reinitr)rr*r+)rr6rrrrrr,os













z_ResourceSharer._afterforkc
Csjd
dlm
}

|jdusJd�
�
t�d�

|
t��jd�
|_|jj|_	t
j|jd�
}d|_
|��
||_dS)Nr)
�ListenerzAlready have Listenerz0starting listener and thread for sending handlesr0)
�targetT)r2r<r)r�debugrr3r1r5r*r'ZThread�_serveZdaemon�startr+)rr<�
trrrr-zs











z_ResourceSharer._startc
Cs�tt
d
�rt
�t
jt
���
	zD|j���5}
|
��}|dur(	Wd�
WdS|\}}|j�	|�
\}}z
||
|�
W|�
n|�
wWd�
n1sMw



Y
Wn


t
��sbtj
t���
Yq)N�pthread_sigmask)�hasattr�signalrB�	SIG_BLOCK�
valid_signalsr)ZacceptZrecvr&�poprZ
is_exiting�sys�
excepthook�exc_info)rr�msgr6Zdestination_pidrrrrrr?�s*








�


��


��z_ResourceSharer._server	)rrrrrr�staticmethodrrr,r-r?rrrrr$=s

		


r$)r"rDrrHr'�r�contextrr�__all__�platform�objectrr r$rrrrrr�<module>
s"










\