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 ]

�
e f��@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlmZ
ddlmZ
dg
Z	ej
dkr�e	dg
7Z	Gd	d�de�Zn#e	d
g
7Z	Gdd
�d
e�Z
Gdd
�d
e�Ze�ZejZd
S)�N�
)
�process)
�	reduction)
�util�stop�win32�	DupSocketc@s.eZ
dZd
Zdd�Zdd�ZdS)rzPicklable wrapper for a socket.cs:|
j���f
d
d�}t
j|�j�|_dS)Ncs �j|
�
}|j
|�

dS)
N)�shareZ
send_bytes)�conn�pidr	)
�new_sock��D/opt/alt/python34/lib64/python3.4/multiprocessing/resource_sharer.py�sends

z DupSocket.__init__.<locals>.send)�dup�_resource_sharer�register�close�_id)�selfZsockrr
)
rr�__init__s

zDupSocket.__init__c
	Cs8tj
|j�
� }
|
j�}tj|�
SWd
QXd
S)z1Get the socket.  This should only be called once.N)r�get_connectionrZ
recv_bytes�socketZ	fromshare)rr
r	r
r
r�detach$s

zDupSocket.detachN)�__name__�
__module__�__qualname__�__doc__rrr
r
r
rrs

�DupFdc@s.eZ
dZd
Zdd�Zdd�ZdS)rz-Wrapper for fd which can be used at any time.csLtj
|
�
��f
d
d�}�f
dd�}tj||�|_dS)Ncstj
|�|
�
dS)
N)rZsend_handle)r
r)
�new_fdr
rr1s
zDupFd.__init__.<locals>.sendcstj
��

dS)
N)�osrr
)
rr
rr3s
zDupFd.__init__.<locals>.close)r rrrr)r�fdrrr
)
rrr/s

zDupFd.__init__c
	Cs,tj
|j�
�}
tj|
�
SWd
QXd
S)z-Get the fd.  This should only be called once.N)rrrrZrecv_handle)rr
r
r
rr7s
zDupFd.detachN)rrrrrrr
r
r
rr-s

c@sseZ
dZd
Zdd�Zdd�Zedd��
Zdd	d
�
Zdd�Z	d
d�Z
dd�ZdS)�_ResourceSharerz-Manager for resouces using background thread.c

Cs\d
|_i|_
g|_tj�|_d|_d|_d|_t	j
|tj�
dS)Nr
)
�_key�_cache�
_old_locks�	threading�Lock�_lock�	_listener�_address�_threadrZregister_after_forkr"�
_afterfork)
rr
r
rr?s
	
	
	

	
	
	
z_ResourceSharer.__init__c
Cse|j�V
|j
d
kr&|j�
n|jd7_|
|f|j|j<|j
|jfSWd
QXd
S)z+Register resource, returning an identifier.Nr)r(r*�_startr#r$)rrrr
r
rrIs






z_ResourceSharer.registerc
CsTd
dlm
}

|\}}|
|dtj�j�

}|j|tj�f�

|S)z<Return connection from which to receive identified resource.r)
�Client�authkey)�
connectionr.r�current_processr/rr �getpid)Zidentr.�address�key�
cr
r
rrRs




z_ResourceSharer.get_connectionNcCs�d
dlm
}
|j��
|jdk	r�||jdtj�j�

}|jd�

|j�
|j	j
|
�

|j	j�r�tj
d�

n|jj�
d|_	d|_d|_x*|jj�D]\}\}}|�
q�W|jj�
nWdQXdS)z:Stop the background thread and clear registered resources.r)
r.Nr/z._ResourceSharer thread did not stop when asked)r0r.r(r*rr1r/rrr+�joinZis_aliverZsub_warningr)r$�items�clear)rZtimeoutr.r5r4rrr
r
rr[s"













	
	
	
"

z_ResourceSharer.stopc
Cs�x*|jj
�D]\}
\}}|�
qW|jj�
|jj|j�

tj�|_|jdk	r{|jj	�
nd|_d|_
d|_dS)
N)r$r7r8r%�appendr(r&r'r)rr*r+)rr4rrr
r
rr,ps
"






	
	
z_ResourceSharer._afterforkc
Cs|d
dlm
}

tjd�

|
dtj�j�
|_|jj|_	t
jd|j�
}d|_
|j�
||_dS)Nr)
�Listenerz0starting listener and thread for sending handlesr/�targetT)r0r:r�debugrr1r/r)r3r*r&ZThread�_serveZdaemon�startr+)rr:�
tr
r
rr-~s





	


z_ResourceSharer._startc
Cs�tt
d
�r1t
jt
jtdt
j��
nx�yx|jj��c}
|
j�}|dkrePn|\}}|j	j
|�
\}}z||
|�
Wd|�
XWdQXWq4


tj�s�t
jt
j��
nYq4Xq4WdS)N�pthread_sigmaskr)�hasattr�signalr@�	SIG_BLOCK�range�NSIGr)ZacceptZrecvr$�poprZ
is_exiting�sys�
excepthook�exc_info)rr
�msgr4Zdestination_pidrrr
r
rr=�s 

"












z_ResourceSharer._serve)rrrrrr�staticmethodrrr,r-r=r
r
r
rr"=s


		r")r rBrrGr&�rrr�__all__�platform�objectrrr"rrr
r
r
r�<module>s 





	


`