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 ]

U

i�f�{�@sdd
ddgZddl
Z
ddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
mZ
ddl
mZm
Z

dd	lmZ
ejZz$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/python38/lib64/python3.8/multiprocessing/connection.py�
_init_timeout;s
rc

Cst�
�|kSrr)
�
trrr�_check_timeout>s
rc

CsX|d
krdS|dkr&tj
dt��d�S|dkrLtj
dt��tt�
fdd�Std	�
�
d
S)z?
    Return an arbitrary free address for the given family
    r)Z	localhostrrz	listener-)�prefix�dirrz\\.\pipe\pyc-%d-%d-�zunrecognized familyN)	�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)zD
    Checks if the family is valid for the current environment.
    rrzFamily %s is not recognized.rN)�sys�platformr%�hasattr�socketr&rrr�_validate_familySs



r-c

CsTt|�
t
krd
St|�
tkr*|�d�
r*dSt|�
tks@t�|�
rDdStd|�
�
dS)z]
    Return the types of the address

    This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE'
    rz\\rrzaddress type of %r unrecognizedN)�type�tuple�str�
startswithr�is_abstract_socket_namespacer%)
�addressrrr�address_type_s




r4c@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|�
�
dSr�r7�_close�
r:rrr�__del__�s


z_ConnectionBase.__del__c

Cs|jdkrt
d
�
�
dS)Nzhandle is closed)r7�OSErrorrArrr�
_check_closed�s


z_ConnectionBase._check_closedc

Cs|jst
d
�
�
dS)Nzconnection is write-only)r8rCrArrr�_check_readable�s

z_ConnectionBase._check_readablec

Cs|jst
d
�
�
dS)Nzconnection is read-only)r9rCrArrr�_check_writable�s

z_ConnectionBase._check_writablec

Cs"|jrd
|_
n|��
td�
�
dS)NFzbad message length)r9r8�closerCrArrr�_bad_message_length�s


z#_ConnectionBase._bad_message_lengthc

Cs
|jd
kS)z True if the connection is closedN�
r7rArrr�closed�sz_ConnectionBase.closedc


Cs|jS)
z"True if the connection is readable)
r8rArrrr<�sz_ConnectionBase.readablec


Cs|jS)
z"True if the connection is writable)
r9rArrrr=�sz_ConnectionBase.writablec

Cs|��
|j
S)
z+File descriptor or handle of the connection)rDr7rArrr�fileno�s
z_ConnectionBase.filenoc

Cs$|jd
k	r z|�
�
W5d
|_Xd
S)zClose the connectionNr?rArrrrG�s


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

dS)z,Send the bytes data from a bytes-like objectrrzoffset is negativezbuffer length < offsetNzsize is negativezbuffer length < offset + size)rDrF�
memoryview�itemsize�bytes�lenr%�_send_bytes)r:�buf�offset�size�
m�
nrrr�
send_bytes�s"

















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

d
S)zSend a (picklable) objectN)rDrFrP�_ForkingPickler�dumps�r:�objrrr�send�s

z_ConnectionBase.sendcCsJ|��
|�
�
|
d
k	r(|
dkr(td�
�
|�|
�
}|d
krB|��
|��S)z7
        Receive bytes data as a bytes object.
        Nrznegative maxlength)rDrEr%�_recv_bytesrH�getvalue)r:Z	maxlengthrQrrr�
recv_bytes�s







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

|�||||||��

|W5QR�SQRXdS)zq
        Receive bytes data into a writeable bytes-like object.
        Return the number of bytes read.
        rznegative offsetzoffset too largeN)rDrErLrMrOr%r\�tellr	r]�seek�readinto)r:rQrRrTrMZbytesize�resultrSrrr�recv_bytes_into�s$
















�z_ConnectionBase.recv_bytes_intoc
Cs&|��
|�
�
|��}
t�|
���
S)
zReceive a (picklable) object)rDrEr\rW�loads�	getbuffer)r:rQrrr�recv�s


z_ConnectionBase.recv�cCs|��
|�
�
|�|
�
S)
z/Whether there is any input available to be read)rDrE�_poll�r:rrrr�poll�s

z_ConnectionBase.pollc


Cs|SrrrArrr�	__enter__
s
z_ConnectionBase.__enter__cCs|��
dSr�
rG�r:�exc_type�	exc_valueZexc_tbrrr�__exit__
s
z_ConnectionBase.__exit__)TT)rN)
N)
r)
rg)�__name__�
__module__�__qualname__r7r>rBrDrErFrH�propertyrJr<r=rKrGrVr[r^rcrfrjrkrprrrrr5rs.












r5c@sDeZ
dZd
ZdZejf
dd�
Zdd�Zddd	�
Z	d
d�Z
dd
�ZdS)�PipeConnectionz�
        Connection class based on a Windows named pipe.
        Overlapped I/O is used, so the handles must have been created
        with FILE_FLAG_OVERLAPPED.
        FcCs|
|j�

dSrrI)r:Z_CloseHandlerrrr@
s
zPipeConnection._closec	Cs�tj
|j|
d
d�\}}zHz,|tjkrBt�|jg
dt�}|tksBt	�
Wn


|�
�
�YnXW5|�d
�
\}}X|dks|t	�
|t|
�
ks�t	�
dS)NT�
�
overlappedFr)�_winapiZ	WriteFiler7�GetOverlappedResult�ERROR_IO_PENDING�WaitForMultipleObjects�eventrr�AssertionError�cancelrO)r:rQ�ov�errZnwritten�waitresrrrrP
s





�




zPipeConnection._send_bytesNc	Cs2
|jrd
|_t
��S|
dkr dnt|
d�}z�tj|j|dd�\}}dzHz,|tjkrpt�
|jg
d
t�}|tkspt�
Wn


|��
�YnXW5|�d�
\}}|dkr�t
��}|�|�	��

|�

WS|tj
kr�|�||
��

WSX
Wn:tk
�
r$
}
z|jtjk�
rt�
n�W5d}~XYnXtd�
�
dS)NF�Trvrz.shouldn't get here; expected KeyboardInterrupt)�_got_empty_message�io�BytesIO�minrx�ReadFiler7ry�writereZERROR_MORE_DATA�_get_more_datarzr{r|rrr}r~rC�winerror�ERROR_BROKEN_PIPE�EOFError�RuntimeError)	r:�maxsizeZbsizerr�Znread�
fr��
errrr\&
s>






�




�













zPipeConnection._recv_bytescCs.|jst
�|j�
d
d
krdStt|g
|
��
S)NrT)r�rx�
PeekNamedPiper7�boolrrirrrrhF
s


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

t�|j�
d
}|dks6t�
|dk	rVt|�
||krV|�	�
tj
|j|dd�\}
}|
�d�
\}}|dks�t�
||ks�t�
|�|
���

|S)NrrTrv)rer�r�r�rxr�r7r}rOrHr�ry)r:rr�rQr��leftr�Zrbytesrrrr�L
s













zPipeConnection._get_more_data)
N)rqrrrs�__doc__r�rx�CloseHandler@rPr\rhr�rrrrru
s

 ruc@s|eZ
dZd
Zer,ejf
dd�
ZejZ	ej
Znej
f
dd�
ZejZ	ejZe	f
dd�
Zef
dd�
Zd	d
�Zddd
�
Zdd�ZdS)�
Connectionzo
    Connection class based on an arbitrary file descriptor (Unix only), or
    a socket handle (Windows).
    cCs|
|j�

dSrrI�r:r@rrrr@c
s
zConnection._closecCs|
|j�

dSrrIr�rrrr@h
s
cCs8t|
�
}||j
|
�}||8}|d
kr&q4|
|d�}
qdS�Nr)rOr7)r:rQr��	remainingrUrrr�_sendm
s




zConnection._sendcCsbt�
�}|j}|
}|d
kr^|||�}t|�
}|d
krJ||
krBt�
ntd�
�
|�|�

||8}q|S)Nrzgot end of file during message)r�r�r7rOr�rCr�)r:rS�readrQr;r��chunkrUrrr�_recvv
s














zConnection._recvcCs�t|
�
}|d
krHt
�dd�}t
�d|�}|�|�

|�|�

|�|
�

n8t
�d|�}|dkrr|�|�

|�|
�

n|�||
�

dS)Ni����!i����!Qi@)rO�structZpackr�)r:rQrUZ
pre_header�headerrrrrP�
s











zConnection._send_bytesNcCs^|�d
�
}t
�d|���\
}|dkr@|�d�
}t
�d|���\
}|
dk	rT||
krTdS|�|�
S)N�r�r��r�)r�r�Zunpackr])r:r�rQrSrrrr\�
s









zConnection._recv_bytescCst|g
|
�}t
|�
Sr)rr�)r:r�
rrrrrh�
s

zConnection._poll)
N)rqrrrsr�rx�_multiprocessingZclosesocketr@r[Z_writerfZ_readr!rGr�r�r�r�rPr\rhrrrrr�\
s



	

r�c@sReZ
dZd
Zddd�
Zdd�Zdd	�Zed
d��
Zedd
��
Z	dd�Z
dd�ZdS)rz�
    Returns a listener object.

    This is a wrapper for a bound socket which is 'listening' for
    connections, or for a Windows named pipe.
    NrcCsp|p|
rt|
�
pt
}|
pt|�
}
t|�

|d
kr>t|
|�|_nt|
||�|_|dk	rft|t�sft	d�
�
||_
dS)Nr�authkey should be a byte string)r4�default_familyr(r-�PipeListener�	_listener�SocketListener�
isinstancerN�	TypeError�_authkey)r:r3r'�backlog�authkeyrrrr>�
s

�


zListener.__init__c
Cs>|jd
krt
d�
�
|j��}
|jr:t|
|j�
t|
|j�
|
S)zz
        Accept a connection on the bound socket or named pipe of `self`.

        Returns a `Connection` object.
        Nzlistener is closed)r�rC�acceptr��deliver_challenge�answer_challenge)r:�
crrrr��
s







zListener.acceptc
Cs |j}
|
d
k	rd
|_|
�
�
d
S)zA
        Close the bound socket or named pipe of `self`.
        N)r�rG)r:ZlistenerrrrrG�
s


zListener.closec


Cs|jj
Sr)r��_addressrArrrr3�
szListener.addressc


Cs|jj
Sr)r��_last_acceptedrArrr�
last_accepted�
szListener.last_acceptedc


Cs|SrrrArrrrk�
s
zListener.__enter__cCs|��
dSrrlrmrrrrp�
s
zListener.__exit__)NNrN)rqrrrsr�r>r�rGrtr3r�rkrprrrrr�
s

	



cCsh|
p
t|�
}
t
|
�

|
d
kr&t|�
}nt|�
}|dk	rHt|t�sHtd�
�
|dk	rdt||�
t||�
|S)z=
    Returns a connection to the address of a `Listener`
    rNr�)	r4r-�
PipeClient�SocketClientr�rNr�r�r�)r3r'r�r�rrrr
�
s








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

|�d
�

t|
���
}t|���
}n$t��\}}t|dd�}t|dd�}||fS)�L
        Returns pair of connection objects at either end of a pipe
        TF�
r=�
r<)r,Z
socketpair�setblockingr��detachr!�pipe)�duplex�s1�s2�c1�c2Zfd1Zfd2rrrrs








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�
\}	}
|
dks�t�
t||d�}t||d�}||fS)	r�rrrNTrvr�r�)r(rx�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�ConnectNamedPiperyr}ru)
r�r3Zopenmode�accessZobsizeZibsizeZh1Zh2rw�
_r�r�r�rrrrsV








�

��	

�
�


c@s*eZ
dZd
Zd
dd�
Zdd�Zdd�Zd	S)r�zO
    Representation of a socket which is bound to an address and listening
    rcCs�t�t
t|��
|_zRtjd
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��argsZexitpriority)r,�getattr�_socketr!�nameZ
setsockoptZ
SOL_SOCKETZSO_REUSEADDRr�ZbindZlistenZgetsocknamer�rCrGZ_familyr�rr2�Finalize�unlink�_unlink)r:r3r'r�rrrr>Gs0





�









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

t|
���
S)NT)r�r�r�r�r�r��r:�
srrrr�`s



zSocketListener.acceptc
Cs0z|j
��
W5|j}
|
dk	r*d|_|
�
XdSr)r�r�rG)r:r�rrrrGes




zSocketListener.closeN)
r)rqrrrsr�r>r�rGrrrrr�Cs

r�c

CsPt|�
}
t
�
tt
|
��
�.}|�d
�

|�|�

t|���
W5QR�SQRXdS)zO
    Return a connection object connected to the socket given by `address`
    TN)r4r,r�r�Zconnectr�r�)r3r'r�rrrr�os






r�c@s8eZ
dZd
Zddd�
Zd
dd�
Zdd	�Zed
d��
ZdS)r�z0
        Representation of a named pipe
        NcCsL|
|_|j
d
d�
g
|_d|_t�d|j�
tj|tj|j|jfdd�|_	dS)NT)
�firstz listener created with address=%rrr�)
r��_new_handle�
_handle_queuer�r�	sub_debugr�r��_finalize_pipe_listenerrG)r:r3r�rrrr>�s






�zPipeListener.__init__Fc
CsHtj
tjB}|
r|tjO}t�|j|tjtjBtjBtj	t
t
tjtj�Sr)
rxr�r�r�r�r�r�r�r�ZPIPE_UNLIMITED_INSTANCESr�r�r�)r:r��flagsrrrr��s








�
�zPipeListener._new_handlec

Cs�|j�
|���

|j�d
�
}
ztj|
dd�}Wn0tk
r^
}
z|jtjkrN�W5d}~XYn\Xz<zt�|jg
dt
�}Wn 


|��
t�|
�

�YnXW5|�	d�
\}}|d
ks�t
�
Xt|
�
S)NrTrvF)r��appendr��poprxr�rCr�Z
ERROR_NO_DATAryr}r{r|rr~r�ru)r:r;rr�r�r��resrrrr��s(








�





zPipeListener.acceptcCs$t�
d
|
�
|D]}t�|�

qdS)Nz closing listener with address=%r)rr�rxr�)Zqueuer3r;rrrr��s

z$PipeListener._finalize_pipe_listener)
N)
F)	rqrrrsr�r>r�r��staticmethodr�rrrrr�s



r�c

Cs�t�}
z6t
�|d
�
t
�|t
jt
jBdt
jt
jt
jt
j�}Wq�t	k
rz
}
z |j
t
jt
jfksht
|
�
rj�W5d}~XYqXq�q�t
�|t
jdd�
t|�
S)zU
        Return a connection object connected to the pipe given by `address`
        ��rN)rrxZ
WaitNamedPiper�r�r�r�r�r�rCr�ZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYrr�r�ru)r3r�
hr�rrrr��s8





�

�
�
�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)Nr� Authkey must be bytes, not {0!s}�md5�
zdigest received was wrong)�hmacr�rNr%�formatr.r!�urandom�MESSAGE_LENGTHrV�	CHALLENGE�new�digestr^�WELCOME�FAILUREr�Z
connectionr�r��messager�Zresponserrrr��s




�








r�cCs�d
dl}t
|
t�s$td�t|
�
�
�
�
|�d�
}|dtt�
�tksNt	d|�
�
|tt�
d�}|�
|
|d���}|�|�

|�d�
}|t
kr�td�
�
dS)Nrr�r�zmessage = %rr�zdigest sent was rejected)r�r�rNr%r�r.r^rOr�r}r�r�rVr�rr�rrrr��s




�

 







r�c@s$eZ
dZd
d�Zdd�Zdd�ZdS)�ConnectionWrappercCs6|
|_||_
||_d
D]}t|
|�}t|||�
qdS)N)rKrGrjr^rV)�_conn�_dumps�_loadsr��setattr)r:�connrXrd�attrrZrrrr>�s






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

dSr)r�r�rV)r:rZr�rrrr[s


zConnectionWrapper.sendc
Cs|j�
�}
|�|
�
Sr)r�r^r
r�rrrrfs


zConnectionWrapper.recvN)rqrrrsr>r[rfrrrrr��s
r�c

Cst�
|f
dddd
��d�
S)Nr�utf-8)�	xmlrpclibrX�encode)
rZrrr�
_xml_dumpss
r
c
Cst�
|�d
�
�
\\
}
}|
S)Nr
)r
rd�decode)r�rZ�methodrrr�
_xml_loadss

r

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

rYrrrr�s


zXmlListener.acceptN)rqrrrsr�rrrrr
s
r
cOsd
dlm
a
tt||
�
tt�Sr�)r
r

r
r�r
r
r

)r��kwdsrrr�	XmlClients
r
cCs�t|�
}g}|r�t
�|d
|
�}|tkr*q�n\t|k
rFtt|�
krTn
n
|t8}n2t|k
rptt|�
kr~n
n
|t8}ntd�
�
|�||�

||dd�}d}
q|S)NFzShould not get hererr)	�listrxr{r
rrOrr�r�)Zhandlesr�
L�readyr�rrr�_exhaustive_wait%s





 


 





r
c
s^|
d
krt}
n|
dkrd}
nt
|
dd�
}
t|�
}i�
g}t��t�}�
z@|D�
]&}zt|d�}	Wn tk
r�


|�
|��<YqPXzt	�|	�dd�\}}Wn8tk
r�
}
zd
|j}}|tkrƂW5d
}~XYnX|t	jkr�|�|�

|�
|j<qP|�
rjt��d
d�d	k�
rjz|�d
�
\}}Wn*tk
�
rP
}
z
|j}W5d
}~XYnX|�
sjt
|d��
rjd|_��|�

d}
qPt�
��|
�}W5|D]}|��
�
q�|D]�}z|�d�
\}}Wn6tk
�
r�
}
z|j}|tk�
r�W5d
}~XYnX|t	j
k�
r��
|j}��|�

|dk�
r�t
|d��
r�d|_�
q�X���
f
dd�|D�
�

�f
d
d�|D�
S)��
        Wait till an object in object_list is ready/readable.

        Returns list of those objects in object_list which are ready/readable.
        Nrr�g�?Tr�rK�)�r
Fc
3s|]}
�|
V
qdSrr)�.0r�)
�waithandle_to_objrr�	<genexpr>�szwait.<locals>.<genexpr>c
sg|]}
|
�kr|
�qSrr)r
�
o)
�
ready_objectsrr�
<listcomp>�s�wait.<locals>.<listcomp>)r�intr
�setr~ryrCr��
_ready_errorsrxZERROR_OPERATION_ABORTEDr|�addr+r�r��AttributeErrorr6r�rzr�r)Zgetwindowsversionr
�keys�update)
�object_listrZov_listZ
ready_handlesrr�r�r�r
rKr)r
r
rr;sh















































�PollSelectorc
Cs�t���}|D]}|�
|tj�
q|
d
k	r4t��|
}|�|
�
}|r\dd�|D�
W5QR�S|
d
k	r4|t��}
|
dkr4|W5QR�Sq4W5QRXd
S)r
Nc
Ssg|]\}
}|
j�qSr)
Zfileobj)r
�keyZeventsrrrr
�sr
r)�
_WaitSelector�register�	selectorsZ
EVENT_READrrZselect)r%
rZselectorrZZdeadliner
rrrr�s








c

CsZ|��}
t
�|
t
jt
j��6}d
dlm}
|�|�
}t||j	|j
ffW5QR�SQRXdS)Nr)
�resource_sharer)rKr,ZfromfdrZSOCK_STREAMrr+
Z	DupSocket�rebuild_connectionr<r=)r
r;r�r+
�dsrrr�reduce_connection�s






r.
cCs|��}t
|��|
|�Sr�r�r�)r-
r<r=Zsockrrrr,
�s

r,
c
CsB|jrt
jnd
|jrt
jnd
B}
t�|��|
�}t||j|jffSr�)	r<rxZFILE_GENERIC_READr=ZFILE_GENERIC_WRITEr
Z	DupHandlerK�rebuild_pipe_connection)r
r��dhrrr�reduce_pipe_connection�s


�
r2
cCs|��}t
||
|�Sr)r�ru)r1
r<r=r;rrrr0
�s

r0
c
Cs t�
|���
}
t|
|j|jffSr)r
ZDupFdrKr,
r<r=)r
�dfrrrr.
�s

cCs|��}t
||
|�Srr/
)r3
r<r=�fdrrrr,
�s

)NN)
T)
T)
N)
N)I�__all__r�r!r)r,r�rr �	itertoolsr�rrrr	�contextr
ZForkingPicklerrWrxrrr
r�ImportErrorr*r�ZCONNECTION_TIMEOUT�countr$r�Zfamiliesr+rrr(r-r4r5rur��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)
r2
r0
rrrr�<module>
s�
























PT=

,,8

	P