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 ]

B

YI~dBz�@sdd
ddgZddl
Z
ddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
mZ
ddl
mZm
Z

dd	lmZ
ejZy$ddlZdd
lmZmZmZmZ
Wn$ek
r�


ejdkr‚dZYnXdZd
Ze��ZdZdg
Zeed�r�dZedg
7Zejdk�
rdZedg
7Zef
dd�
Z dd�Z!dd�Z"dd�Z#dd�Z$Gdd�d�Z%e�
rhGdd�de%�Z&Gdd �d e%�Z'Gd!d
�d
e(�Z)dOd"d�
Z*ejdk�
r�dPd$d�
Z+n
dQd%d�
Z+Gd&d'�d'e(�Z,d(d)�Z-ejdk�
r�Gd*d+�d+e(�Z.d,d-�Z/d.Z0d/Z1d0Z2d1Z3d2d3�Z4d4d5�Z5Gd6d7�d7e(�Z6d8d9�Z7d:d;�Z8Gd<d=�d=e)�Z9d>d?�Z:ejdk�rtd@dA�Z;ej<ej=hZ>dRdBd�
Z?n,ddl@Z@ee@dC��r�e@jAZBne@jCZBdSdDd�
Z?ejdk�r�dEdF�ZDdGdH�ZEe�Fe'eD�
dIdJ�ZGdKdL�ZHe�Fe&eG�
ndMdF�ZDdNdH�ZEe�Fe'eD�
dS)T�Client�Listener�Pipe�wait�N�
)
�util)�AuthenticationError�BufferTooShort)
�	reduction)�
WAIT_OBJECT_0�WAIT_ABANDONED_0�WAIT_TIMEOUT�INFINITE�win32i g4@�AF_INET�AF_UNIX�AF_PIPEc

Cst�
�|S)
N)�time�	monotonic)
�timeout�r�?/opt/alt/python37/lib64/python3.7/multiprocessing/connection.py�
_init_timeout;s
rc

Cst�
�|kS)
N)rr)
�
trrr�_check_timeout>s
rc

CsX|d
krdS|dkr&tj
dt��d�S|dkrLtj
dt��tt�
fdd�Std	�
�
dS)
Nr)Z	localhostrrz	listener-)�prefix�dirrz\\.\pipe\pyc-%d-%d-�zunrecognized family)	�tempfileZmktemprZget_temp_dir�os�getpid�next�
_mmap_counter�
ValueError)
�familyrrr�arbitrary_addressEs





r%c

CsJtj
d
kr|dkrtd|�
�
tj
d
krF|dkrFtt|�sFtd|�
�
dS)NrrzFamily %s is not recognized.r)�sys�platformr#�hasattr�socket)
r$rrr�_validate_familySs



r*c

CsTt|�
t
krd
St|�
tkr*|�d�
r*dSt|�
tks@t�|�
rDdStd|�
�
dS)Nrz\\rrzaddress type of %r unrecognized)�type�tuple�str�
startswithr�is_abstract_socket_namespacer#)
�addressrrr�address_type_s




r1c@s�eZ
dZd
Zd+dd�
Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	e
dd��
Ze
dd��
Ze
dd��
Z
dd�Zdd�Zd,dd�
Zdd�Zd-dd�
Zd.d d!�
Zd"d#�Zd/d%d&�
Zd'd(�Zd)d*�Zd
S)0�_ConnectionBaseNTcCs>|
��}
|
d
krt
d�
�
|s(|s(t
d�
�
|
|_||_||_dS)Nrzinvalid handlez6at least one of `readable` and `writable` must be True)�	__index__r#�_handle�	_readable�	_writable)�self�handle�readable�writablerrr�__init__us








z_ConnectionBase.__init__c

Cs|jdk	r|�
�
dS)
N)r4�_close)
r7rrr�__del__�s


z_ConnectionBase.__del__c

Cs|jdkrt
d
�
�
dS)Nzhandle is closed)r4�OSError)
r7rrr�
_check_closed�s


z_ConnectionBase._check_closedc

Cs|jst
d
�
�
dS)Nzconnection is write-only)r5r>)
r7rrr�_check_readable�s

z_ConnectionBase._check_readablec

Cs|jst
d
�
�
dS)Nzconnection is read-only)r6r>)
r7rrr�_check_writable�s

z_ConnectionBase._check_writablec

Cs"|jrd
|_
n|��
td�
�
dS)NFzbad message length)r6r5�closer>)
r7rrr�_bad_message_length�s


z#_ConnectionBase._bad_message_lengthc

Cs
|jdkS)
N)
r4)
r7rrr�closed�sz_ConnectionBase.closedc


Cs|jS)
N)
r5)
r7rrrr9�sz_ConnectionBase.readablec


Cs|jS)
N)
r6)
r7rrrr:�sz_ConnectionBase.writablec

Cs|��
|j
S)
N)r?r4)
r7rrr�fileno�s
z_ConnectionBase.filenoc

Cs$|jdk	r z|�
�
Wdd|_XdS)
N)r4r<)
r7rrrrB�s


z_ConnectionBase.closercCs�|��
|�
�
t|
�
}|jd
kr.tt|�
�
}t|�
}|dkrFtd�
�
||krVtd�
�
|dkrh||}n&|dkrztd�
�
n|||kr�td�
�
|�||||��

dS)Nrrzoffset is negativezbuffer length < offsetzsize is negativezbuffer length < offset + size)r?rA�
memoryview�itemsize�bytes�lenr#�_send_bytes)r7�buf�offset�size�
m�
nrrr�
send_bytes�s"

















z_ConnectionBase.send_bytescCs$|��
|�
�
|�t�|
�
�

dS)
N)r?rArJ�_ForkingPickler�dumps)r7�objrrr�send�s

z_ConnectionBase.sendcCsJ|��
|�
�
|
dk	r(|
d
kr(td�
�
|�|
�
}|dkrB|��
|��S)Nrznegative maxlength)r?r@r#�_recv_bytesrC�getvalue)r7Z	maxlengthrKrrr�
recv_bytes�s







z_ConnectionBase.recv_bytesc	Cs�|��
|�
�
t|
�
��}|j}|t|�
}|d
kr>td�
�
n||krNtd�
�
|��}|��}|||krvt|�	��
�
|�
d
�

|�||||||��

|SQRXdS)Nrznegative offsetzoffset too large)r?r@rFrGrIr#rU�tellr	rV�seek�readinto)r7rKrLrNrGZbytesize�resultrMrrr�recv_bytes_into�s"
















z_ConnectionBase.recv_bytes_intoc
Cs&|��
|�
�
|��}
t�|
���
S)
N)r?r@rUrQ�loads�	getbuffer)r7rKrrr�recv�s


z_ConnectionBase.recv�cCs|��
|�
�
|�|
�
S)
N)r?r@�_poll)r7rrrr�poll�s

z_ConnectionBase.pollc


Cs|S)
Nr)
r7rrr�	__enter__
s
z_ConnectionBase.__enter__cCs|��
dS)
N)
rB)r7�exc_type�	exc_value�exc_tbrrr�__exit__
s
z_ConnectionBase.__exit__)TT)rN)
N)
r)
r`)�__name__�
__module__�__qualname__r4r;r=r?r@rArC�propertyrDr9r:rErBrPrTrWr\r_rbrcrgrrrrr2rs(






r2c@s@eZ
dZd
Zejf
dd�
Zdd�Zd
dd�
Zd	d
�Z	dd�Z
dS)�PipeConnectionFcCs|
|j�

dS)
N)
r4)r7Z_CloseHandlerrrr<
s
zPipeConnection._closec	Cshtj
|j|
d
d�\}}z<y |tjkr6t�|jg
dt�}Wn


|��
�YnXWd|�d
�
\}}XdS)NT)
�
overlappedF)	�_winapiZ	WriteFiler4�ERROR_IO_PENDING�WaitForMultipleObjects�eventr�cancel�GetOverlappedResult)r7rK�ov�err�waitresZnwrittenrrrrJ
s









zPipeConnection._send_bytesNc	
Cs
|jrd
|_t
��S|
dkr dnt|
d�}y�tj|j|dd�\}}z<y |tjkrbt�|j	g
d
t
�}Wn


|��
�YnXWd|�d�
\}}|dkr�t
��}|�
|���

|S|tjkr�|�||
�SXWn8tk
�
r
}
z|jtjkr�t�
n�Wdd}~XYnXtd�
�
dS)NF�T)
rmrz.shouldn't get here; expected KeyboardInterrupt)�_got_empty_message�io�BytesIO�minrn�ReadFiler4rorprqrrrrs�writer^ZERROR_MORE_DATA�_get_more_datar>�winerror�ERROR_BROKEN_PIPE�EOFError�RuntimeError)	r7�maxsizeZbsizertrurvZnread�
f�
errrrU&
s6


























zPipeConnection._recv_bytescCs.|jst
�|j�
d
d
krdStt|g
|
��
S)NrT)rxrn�
PeekNamedPiper4�boolr)r7rrrrraF
s



zPipeConnection._pollcCs�|
��}t
��}|�|�

t�|j�
d
}|dk	rJt|�
||krJ|��
tj	|j|dd�\}
}|
�
d�
\}}|�|
���

|S)NrT)
rm)r^ryrzr}rnr�r4rIrCr|rs)r7rtr�rKr��leftruZrbytesrrrr~L
s








zPipeConnection._get_more_data)
N)rhrirjrxrn�CloseHandler<rJrUrar~rrrrrl
s
 rlc@sxeZ
dZer(ejf
d
d�
ZejZej	Z
nejf
dd�
Zej
ZejZ
ef
dd�
Ze
f
dd�
Zdd	�Zddd�
Zd
d�Zd
S)�
ConnectioncCs|
|j�

dS)
N)
r4)r7r<rrrr<c
s
zConnection._closecCs|
|j�

dS)
N)
r4)r7r<rrrr<h
s
cCs<t|
�
}x.||j
|
�}||8}|d
kr(P|
|d�}
q
WdS)Nr)rIr4)r7rKr}�	remainingrOrrr�_sendm
s






zConnection._sendcCsft�
�}|j}|
}xN|d
kr`|||�}t|�
}|d
krL||
krDt�
ntd�
�
|�|�

||8}qW|S)Nrzgot end of file during message)ryrzr4rIr�r>r})r7rM�readrKr8r��chunkrOrrr�_recvv
s














zConnection._recvcCsDt|
�
}t
�d
|�}|dkr2|�|�

|�|
�

n|�||
�

dS)Nz!ii@)rI�struct�packr�)r7rKrO�headerrrrrJ�
s



zConnection._send_bytesNcCs:|�d
�
}t
�d|���\
}|
dk	r0||
kr0dS|�|�
S)N�z!i)r�r��unpackrV)r7r�rKrMrrrrU�
s






zConnection._recv_bytescCst|g
|
�}t
|�
S)
N)rr�)r7r�
rrrrra�
s

zConnection._poll)
N)rhrirjrn�_multiprocessingZclosesocketr<rTZ_writer_Z_readrrBr}r�r�r�rJrUrarrrrr�\
s


	
r�c@sNeZ
dZddd�
Zdd�Zdd�Zed	d
��
Zedd��
Zd
d�Z	dd�Z
d
S)rNrcCsp|p|
rt|
�
pt
}|
pt|�
}
t|�

|d
kr>t|
|�|_nt|
||�|_|dk	rft|t�sft	d�
�
||_
dS)Nrzauthkey should be a byte string)r1�default_familyr%r*�PipeListener�	_listener�SocketListener�
isinstancerH�	TypeError�_authkey)r7r0r$�backlog�authkeyrrrr;�
s





zListener.__init__c
Cs>|jdkrt
d
�
�
|j��}
|jr:t|
|j�
t|
|j�
|
S)Nzlistener is closed)r�r>�acceptr��deliver_challenge�answer_challenge)r7�
crrrr��
s







zListener.acceptc
Cs |j}
|
dk	rd|_|
�
�
dS)
N)r�rB)r7ZlistenerrrrrB�
s


zListener.closec


Cs|jj
S)
N)r��_address)
r7rrrr0�
szListener.addressc


Cs|jj
S)
N)r��_last_accepted)
r7rrr�
last_accepted�
szListener.last_acceptedc


Cs|S)
Nr)
r7rrrrc�
s
zListener.__enter__cCs|��
dS)
N)
rB)r7rdrerfrrrrg�
s
zListener.__exit__)NNrN)rhrirjr;r�rBrkr0r�rcrgrrrrr�
s
	cCsh|
p
t|�
}
t
|
�

|
d
kr&t|�
}nt|�
}|dk	rHt|t�sHtd�
�
|dk	rdt||�
t||�
|S)Nrzauthkey should be a byte string)	r1r*�
PipeClient�SocketClientr�rHr�r�r�)r0r$r�r�rrrr
�
s








Tc
Csj|r>t�
�\}
}|
�d
�

|�d
�

t|
���
}t|���
}n$t��\}}t|dd�}t|dd�}||fS)NTF)
r:)
r9)r)Z
socketpair�setblockingr��detachr�pipe)�duplex�s1�s2�c1�c2Zfd1Zfd2rrrr�
s








c


Cs�td
�
}
|r*t
j}t
jt
jB}tt}}nt
j}t
j}dt}}t
�|
|t
jBt
j	Bt
j
t
jBt
jBd||t
j
t
j�}t
�|
|dt
jt
jt
jt
j�}t
�|t
jdd�
t
j|dd�}|�d�
\}	}
t||d�}t||d�}||fS)NrrrT)
rm)
r:)
r9)r%rn�PIPE_ACCESS_DUPLEX�GENERIC_READ�
GENERIC_WRITE�BUFSIZEZPIPE_ACCESS_INBOUND�CreateNamedPipe�FILE_FLAG_OVERLAPPED�FILE_FLAG_FIRST_PIPE_INSTANCE�PIPE_TYPE_MESSAGE�PIPE_READMODE_MESSAGE�	PIPE_WAIT�NMPWAIT_WAIT_FOREVER�NULL�
CreateFile�
OPEN_EXISTING�SetNamedPipeHandleState�ConnectNamedPipersrl)
r�r0Zopenmode�accessZobsizeZibsizeZh1Zh2rm�
_rur�r�rrrr
s2



















c@s&eZ
dZd	dd�
Zdd�Zdd�ZdS)
r�rcCs�t�t
t|��
|_yRtjd
kr2|j�tjtjd�
|j�d�

|j�	|
�

|j�
|�

|j��|_Wn t
k
r�


|j��
�YnX||_d|_|dkr�t�|
�
s�tj|tj|
f
dd�|_nd|_dS)N�posixrTrr)�args�exitpriority)r)�getattr�_socketr�nameZ
setsockoptZ
SOL_SOCKETZSO_REUSEADDRr�ZbindZlistenZgetsocknamer�r>rBZ_familyr�rr/�Finalize�unlink�_unlink)r7r0r$r�rrrr;=s$

















zSocketListener.__init__c
Cs&|j�
�\}
|_|
�d
�

t|
���
S)NT)r�r�r�r�r�r�)r7�
srrrr�Vs



zSocketListener.acceptc
Cs0z|j�
�
Wd|j}
|
dk	r*d|_|
�
XdS)
N)r�rBr�)r7r�rrrrB[s




zSocketListener.closeN)
r)rhrirjr;r�rBrrrrr�9s
r�c
	CsDt|�
}
t
�
tt
|
��
�"}|�d
�

|�|�

t|���
SQRXdS)NT)r1r)r�r�Zconnectr�r�)r0r$r�rrrr�es






r�c@s4eZ
dZddd�
Zddd�
Zdd�Zed	d
��
Zd
S)
r�NcCsL|
|_|j
d
d�
g
|_d|_t�d|j�
tj|tj|j|jfdd�|_	dS)NT)
�firstz listener created with address=%rr)r�r�)
r��_new_handle�
_handle_queuer�r�	sub_debugr�r��_finalize_pipe_listenerrB)r7r0r�rrrr;ys





zPipeListener.__init__Fc
CsHtj
tjB}|
r|tjO}t�|j|tjtjBtjBtj	t
t
tjtj�S)
N)
rnr�r�r�r�r�r�r�r�ZPIPE_UNLIMITED_INSTANCESr�r�r�)r7r��flagsrrrr��s










zPipeListener._new_handlec

Cs�|j�
|���

|j�d
�
}
ytj|
dd�}Wn0tk
r^
}
z|jtjkrN�Wdd}~XYnPXz<yt�	|j
g
dt�}Wn 


|��
t�
|
�

�YnXWd|�d�
\}}Xt|
�
S)NrT)
rmF)r��appendr��poprnr�r>rZ
ERROR_NO_DATArprqrrrr�rsrl)r7r8rtr��resr�rurrrr��s"















zPipeListener.acceptcCs(t�
d
|
�
x|D]}t�|�

qWdS)Nz closing listener with address=%r)rr�rnr�)Zqueuer0r8rrrr��s


z$PipeListener._finalize_pipe_listener)
N)
F)rhrirjr;r�r��staticmethodr�rrrrr�us

r�c

Cs�t�}
x~y6t
�|d
�
t
�|t
jt
jBdt
jt
jt
jt
j�}Wn>t	k
r|
}
z |j
t
jt
jfksjt
|
�
rl�Wdd}~XYqXPqW�t
�|t
jdd�
t|�
S)Ni�r)rrnZ
WaitNamedPiper�r�r�r�r�r�r>rZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYrr�r�rl)r0r�
hr�rrrr��s"











r��s#CHALLENGE#s	#WELCOME#s	#FAILURE#cCs�d
dl}t
|
t�s$td�t|
�
�
�
�
t�t�
}|�	t
|�

|�|
|d���}|�
d�
}||krl|�	t�

n|�	t�

td�
�
dS)Nrz Authkey must be bytes, not {0!s}�md5�
zdigest received was wrong)�hmacr�rHr#�formatr+r�urandom�MESSAGE_LENGTHrP�	CHALLENGE�new�digestrW�WELCOME�FAILUREr)�
connectionr�r��messager��responserrrr��s














r�cCsxd
dl}t
|
t�s$td�t|
�
�
�
�
|�d�
}|tt�
d�}|�	|
|d��
�}|�|�

|�d�
}|tkrtt
d�
�
dS)Nrz Authkey must be bytes, not {0!s}r�r�zdigest sent was rejected)r�r�rHr#r�r+rWrIr�r�r�rPr�r)r�r�r�r�r�r�rrrr��s













r�c@s$eZ
dZd
d�Zdd�Zdd�ZdS)�ConnectionWrappercCs:|
|_||_
||_x"d
D]}t|
|�}t|||�
qWdS)N)rErBrbrWrP)�_conn�_dumps�_loadsr��setattr)r7�connrRr]�attrrSrrrr;�s







zConnectionWrapper.__init__cCs|�|
�
}|j
�|�

dS)
N)r�r�rP)r7rSr�rrrrT�s


zConnectionWrapper.sendc
Cs|j�
�}
|�|
�
S)
N)r�rWr�)r7r�rrrr_�s


zConnectionWrapper.recvN)rhrirjr;rTr_rrrrr��s
r�c

Cst�
|f
dddd
��d�
S)Nrzutf-8)�	xmlrpclibrR�encode)
rSrrr�
_xml_dumpss
r�c
Cst�
|�d
�
�
\\
}
}|
S)Nzutf-8)r�r]�decode)r�rS�methodrrr�
_xml_loadss

r�c@seZ
dZd
d�ZdS)�XmlListenerc
Cs"d
dlm
a
t�|�
}
t|
tt�S)Nr)�
xmlrpc.client�clientr�rr�r�r�r�)r7rSrrrr�
s


zXmlListener.acceptN)rhrirjr�rrrrr�	s
r�cOsd
dlm
a
tt||
�
tt�S)Nr)r�r�r�r�r
r�r�)r��kwdsrrr�	XmlClients
r�cCs�t|�
}g}x�|r�t
�|d
|
�}|tkr,Pn\t|k
rHtt|�
krVn
n
|t8}n2t|k
rrtt|�
kr�n
n
|t8}ntd�
�
|�||�

||dd�}d}
qW|S)NFzShould not get hererr)	�listrnrpr
rrIrr�r�)Zhandlesr�
L�readyr�rrr�_exhaustive_waits





 


 





r�c
sl|
dkrt}
n|
d
krd
}
nt
|
dd�
}
t|�
}i�
g}t��t�}�
zF�
x0|D�
]&}yt|d�}Wn tk
r�


|�
|��<YqTXyt�|�d
d�\}}Wn8t	k
r�
}
zd|j
}}|tkrʂWdd}~XYnX|tjkr�|�
|�

|�
|j<qT|�
rnt��dd�dk�
rny|�d�
\}	}Wn*t	k
�
rT
}
z
|j
}Wdd}~XYnX|�
snt|d	��
rnd|_��|�

d
}
qTWt�
��|
�}Wdx|D]}|��
�
q�Wx�|D]�}y|�d�
\}	}Wn6t	k
�
r�
}
z|j
}|tk�
r�Wdd}~XYnX|tjk�
r��
|j}��|�

|d
k�
r�t|d	��
r�d|_�
q�WX���
f
d
d�|D�
�

�f
dd
�|D�
S)Nri�g�?rET�)�r�Frxc
3s|]}
�|
V
qdS)
Nr)�.0r�)
�waithandle_to_objrr�	<genexpr>|szwait.<locals>.<genexpr>c
sg|]}
|
�kr|
�qSrr)r��
o)
�
ready_objectsrr�
<listcomp>}szwait.<locals>.<listcomp>)r�intr��setr��AttributeErrorr3rnr|r>r�
_ready_errorsror�rqr&Zgetwindowsversionrsr(rx�addr��keysrrZERROR_OPERATION_ABORTED�update)
�object_listrZov_listZ
ready_handlesr
rErtrur�r�r)r
r
rr1sh
















































�PollSelectorc	Cs�t��x}x|D]}|�
|tj�
qW|
dk	r8t��|
}x@|�|
�
}|rVd
d�|D�
S|
dk	r:|t��}
|
dkr:|Sq:WWdQRXdS)Nc
Ssg|]\}
}|
j�qSr)
Zfileobj)r��keyZeventsrrrr
�szwait.<locals>.<listcomp>r)�
_WaitSelector�register�	selectorsZ
EVENT_READrrZselect)r
rZselectorrSZdeadliner�rrrr�s










c
	CsN|��}
t
�|
t
jt
j��*}d
dlm}
|�|�
}t||j	|j
ffSQRXdS)Nr)
�resource_sharer)rEr)ZfromfdrZSOCK_STREAMrr
Z	DupSocket�rebuild_connectionr9r:)r�r8r�r
�dsrrr�reduce_connection�s






r
cCs|��}t
|��|
|�S)
N)r�r�)r
r9r:Zsockrrrr
�s

r
c
CsB|jrt
jnd
|jrt
jnd
B}
t�|��|
�}t||j|jffS)Nr)	r9rnZFILE_GENERIC_READr:ZFILE_GENERIC_WRITEr
Z	DupHandlerE�rebuild_pipe_connection)r�r��dhrrr�reduce_pipe_connection�s



r
cCs|��}t
||
|�S)
N)r�rl)r
r9r:r8rrrr
�s

r
c
Cs t�
|���
}
t|
|j|jffS)
N)r
ZDupFdrEr
r9r:)r��dfrrrr
�s

cCs|��}t
||
|�S)
N)r�r�)r
r9r:�fdrrrr
�s

)NN)
T)
T)
N)
N)I�__all__ryrr&r)r�rr�	itertoolsr�rrrr	�contextr
ZForkingPicklerrQrnrrr
r�ImportErrorr'r�ZCONNECTION_TIMEOUT�countr"r�Zfamiliesr(rrr%r*r1r2rlr��objectrr
rr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�ZERROR_NETNAME_DELETEDr
rr
r

r
ZSelectSelectorr
r
r
r
r
rrrr�<module>
s�
























PJ=

,,8

	P