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

� f��@s�dd
ddgZddl
Z
ddlZddlZddlZddlZddlmZ
ddlm	Z	
dd	l
mZmZm
Z

dd
lmZ
ddlmZ
ddlmZ
dd
lmZ
dd�Ze�eje�
dd�dD�
Zedek	r�dd�ZxeD]Ze�ee�
q�WGdd�de�Zdifdd�
Zdd�ZGdd�de�Zdd�Zdd �ZGd!d"�d"e�Z Gd#d$�d$e�Z!e	j"e	j#fe	j$e	j%fd%�Z&Gd&d�de�Z'Gd'd(�d(e(�Z)Gd)d�de�Z*d*d+�Z+if
d,d-�
Z,ddd/d0�
Z-Gd1d2�d2e�Z.Gd3d4�d4e�Z/ded5d6�
Z0Gd7d8�d8e*�Z1Gd9d:�d:e*�Z2Gd;d<�d<e2�Z3Gd=d>�d>e*�Z4Gd?d@�d@e*�Z5GdAdB�dBe*�Z6GdCdD�dDe*�Z7e,dEdF�Z8GdGdH�dHe8�Z9e,dIdJ�Z:dKdLi
e:_;e,dMdN�Z<e,dOdP�Z=dQdQdQdLdLdR�e=_;GdSdO�dOe=�Z>GdTd
�d
e'�Z?e?�dUej@�
e?�dVej@�
e?�dWejAe4�
e?�dXejBe2�
e?�dYejCe2�
e?�dZejDe2�
e?�d[ejEe2�
e?�d\ejFe3�
e?�d]ejGe5�
e?�d^ejHe>�
e?�d_ee9�
e?�d`eIe:�
e?�d4e/e7�
e?�d6e0e<�
e?�d2e.e6�
e?jdLe1dadb�
e?jdQdadc�
dS)f�BaseManager�SyncManager�	BaseProxy�Token�N)
�
format_exc�
)
�
connection)�	reduction�get_spawning_popen�ProcessError)
�pool)
�process)
�util)
�get_contextc

Cstj|j
|��ffS)
N)�array�typecode�tobytes)
�
a�r�=/opt/alt/python37/lib64/python3.7/multiprocessing/managers.py�reduce_array$s
rc
Csg|]}
tt
i|
���
�qSr)�type�getattr)�.0�namerrr�
<listcomp>(sr)�items�keys�valuesc

Cstt|�
f
fS)
N)
�list)
�objrrr�rebuild_as_list*s
r!c@s4eZ
dZd
ZdZdd�Zdd�Zdd�Zd	d
�ZdS)rz3
    Type to uniquely identify a shared object
    )�typeid�address�idcCs|
|||_|_
|_dS)
N)r"r#r$)�selfr"r#r$rrr�__init__9s
zToken.__init__c

Cs|j|j
|jfS)
N)r"r#r$)
r%rrr�__getstate__<s
zToken.__getstate__cCs|
\|_|_
|_dS)
N)r"r#r$)r%�staterrr�__setstate__?s
zToken.__setstate__c

Csd
|jj
|j|j|jfS)Nz %s(typeid=%r, address=%r, id=%r))�	__class__�__name__r"r#r$)
r%rrr�__repr__Bs

zToken.__repr__N)	r+�
__module__�__qualname__�__doc__�	__slots__r&r'r)r,rrrrr3s
rcCs8|�|
|||f�

|�
�\}}|d
kr*|St||��
dS)zL
    Send a message to manager using connection `c` and return response
    z#RETURNN)�send�recv�convert_to_error)�
cr$�
methodname�args�kwds�kind�resultrrr�dispatchJs




r:cCsd|d
kr|
S|dkrRt|
t
�s4td�|
|t|
�
��
�
|dkrHtd|
�
St|
�
Sntd�|�
�
SdS)Nz#ERROR)z
#TRACEBACKz#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strz#UNSERIALIZABLEzUnserializable message: %s
zUnrecognized message type {!r})�
isinstance�str�	TypeError�formatr�RemoteError�
ValueError)r8r9rrrr3Ts










r3c@seZ
dZd
d�ZdS)r?c

Csd
t|j
d�
dS)NzM
---------------------------------------------------------------------------
rzK---------------------------------------------------------------------------)r<r6)
r%rrr�__str__ds
zRemoteError.__str__N)r+r-r.rArrrrr?cs
r?c
Cs6g}
x,t|�
D] }t
||�}t|�
r|
�|�

qW|
S)
z4
    Return a list of names of methods of `obj`
    )�dirr�callable�append)r �tempr�funcrrr�all_methodsks





rGc

Csd
d�t|�
D�
S)zP
    Return a list of names of methods of `obj` which do not start with '_'
    c
Ssg|]}
|
dd
kr|
�qS)r�
_r)rrrrrrzsz"public_methods.<locals>.<listcomp>)
rG)
r rrr�public_methodsvsrIc	@s�eZ
dZd
Zdddddddd	d
g	Zdd�Zd
d�Zdd�Zdd�Zdd�Z	dd�Z
dd�Zdd�Zeee
d�Z
dd�Zdd�Zd d!�Zd"d#�Zd$d%�Zd&d'�Zd(d)�Zd*d+�Zd,d-�Zd.S)/�ServerzM
    Server class which runs in a process controlled by a manager object
    �shutdown�create�accept_connection�get_methods�
debug_info�number_of_objects�dummy�incref�decrefcCsxt|t
�std
�|t|�
��
�
|
|_t�|�
|_t	|\}}||dd�|_
|j
j|_ddi
|_i|_
i|_t��|_dS)Nz&Authkey {0!r} is type {1!s}, not bytes�)r#Zbacklog�
0)Nr)r;�bytesr=r>r�registryr
�AuthenticationString�authkey�listener_client�listenerr#�	id_to_obj�id_to_refcount�id_to_local_proxy_obj�	threading�Lock�mutex)r%rWr#rY�
serializer�Listener�Clientrrrr&�s













zServer.__init__c
	Cs�t�
�|_|t��_zZtj|jd
�
}
d|
_|
�	�
y x|j�
�sN|j�d�

q6WWntt
fk
rj


YnXWdtjtjkr�t�d�

tjt_tjt_t�d�

XdS)z(
        Run the server forever
        )
�targetTrNzresetting stdout, stderrr)r_�Event�
stop_eventr
�current_process�_manager_server�Thread�accepter�daemon�start�is_set�wait�KeyboardInterrupt�
SystemExit�sys�stdout�
__stdout__r�debug�
__stderr__�stderr�exit)r%rkrrr�
serve_forever�s 

















zServer.serve_foreverc
CsPxJy|j�
�}
Wntk
r&


wYnXtj|j|
f
d
�}d|_|��
qWdS)N)rer6T)r[Zaccept�OSErrorr_rj�handle_requestrlrm)r%r4�
trrrrk�s







zServer.acceptercCs4
d
}}}y>t�
|
|j�
t�|
|j�
|
��}|\}}}}t||�}Wntk
rh


dt�f}	Yn>Xy||
f
|�|�
}Wntk
r�


dt�f}	Yn
Xd|f}	y|
�|	�

Wnrtk
�
r&
}

zRy|
�dt�f�

Wntk
r�


YnXt	�
d|	�
t	�
d|�
t	�
d|
�
Wd
d
}
~
XYnX|
��
d
S)z)
        Handle a new connection
        Nz
#TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r)rZdeliver_challengerYZanswer_challenger2r�	Exceptionrr1r�info�close)r%r4�funcnamer9�request�ignorer6r7rF�msg�
errrr{�s2



















zServer.handle_requestc
Cs�t�
d
t��j�
|
j}|
j}|j}�x�|j�	��s�
yBd}}|�}|\}}}	}
y||\}}}Wn^t
k
r�
}

z@y|j|\}}}Wn&t
k
r�
}
z|
�
Wdd}~XYnXWdd}
~
XYnX||kr�td|t
|�
|f�
�
t||�}y||	|
�
}Wn,tk
�
r&
}
zd|f}Wdd}~XYnPX|�
o8|�|d�}|�
rn|�|
||�\}}t||j|�}d||ff}nd|f}Wn�tk
�
r�


|dk�
r�dt�f}nNy,|j|}|||
||f|	�|
�
}d|f}Wn tk
�
r�


dt�f}YnXYnPtk
�r"


t�
dt��j�
t�d	�

Yn tk
�r@


dt�f}YnXyDy||�

Wn2tk
�r�
}
z|d
t�f�

Wdd}~XYnXWq(tk
�r�
}
z@t�dt��j�
t�d|�
t�d
|�
|
��
t�d�

Wdd}~XYq(Xq(WdS)zQ
        Handle requests from the proxies in a particular process/thread
        z$starting server thread to service %rNz+method %r of %r object is not in exposed=%rz#ERRORz#PROXYz#RETURNz
#TRACEBACKz$got EOF -- exiting thread serving %rrz#UNSERIALIZABLEzexception in thread serving %rz ... message was %rz ... exception was %rr)rrur_�current_threadrr2r1r\rgrn�KeyErrorr^�AttributeErrorrrr}�getrLrr#r�fallback_mapping�EOFErrorrrrxr~r)r%�connr2r1r\r5r r��identr6r7�exposed�	gettypeid�keZ	second_keZfunctionZresr�r�r"ZridentZrexposed�tokenZ
fallback_funcr9rrr�serve_client�sx











(



























$






zServer.serve_clientc
Cs|S)
Nr)r%r�r�r rrr�fallback_getvalue,
s
zServer.fallback_getvaluecCst|�
S)
N)
r<)r%r�r�r rrr�fallback_str/
s
zServer.fallback_strcCst|�
S)
N)
�repr)r%r�r�r rrr�
fallback_repr2
s
zServer.fallback_repr)rAr,z	#GETVALUEc
CsdS)
Nr)r%r4rrrrQ;
s
zServer.dummyc
Cs||j�l
g}t
|j���
}|��
xD|D]<}|d
kr(|�d||j|t|j|d�
dd�f�

q(Wd�|�
SQRXdS)zO
        Return some info --- useful to spot problems with refcounting
        rUz  %s:       refcount=%s
    %srN�K�

)	rarr]r�sortrDr<r\�join)r%r4r9rr�rrrrO>
s









$
zServer.debug_infocCs
t|j
�
S)
z*
        Number of shared objects
        )�lenr])r%r4rrrrPN
szServer.number_of_objectscCsLz:yt�
d
�

|
�d�

Wn


ddl}|��
YnXWd|j��
XdS)z'
        Shutdown this process
        z!manager received shutdown message)z#RETURNNrN)rrur1�	traceback�	print_excrg�set)r%r4r�rrrrKU
s





zServer.shutdownc	Os�
t|�
d
kr|^}}}}nz|s(t
d�
�
nld|
krDt
dt|�
d�
�
|
�d�
}t|�
dkrf|^}}}n.d|
kr�t
dt|�
d�
�
|
�d�
}|^
}}t|�
}|j��
|j|\}}}}|dkr�|
s�t|�
dkr�td	�
�
|d
}	n
|||
�
}	|dkr�t|	�
}|dk	�
r4t|t	��
s$t
d�
|t|�
��
�
t|�
t|�
}dt
|	�
}
t�d
||
�
|	t|�
|f|j|
<|
|jk�
rxd
|j|
<WdQRX|�||
�
|
t|�
fS)z>
        Create a new shared object and return its id
        �z8descriptor 'create' of 'Server' object needs an argumentr"z7create expected at least 2 positional arguments, got %dr�r4Nz4Without callable, must have one non-keyword argumentrz,Method_to_typeid {0!r}: type {1!s}, not dictz%xz&%r callable returned object with id %r)r�r=�pop�tuplerarWr@rIr;�dictr>rrr$rrur�r\r]rR)r6r7r%r4r"rCr��method_to_typeid�	proxytyper r�rrrrLb
sN
































z
Server.createcCst|j
|jd
�
S)zL
        Return the methods of the shared object indicated by token
        r)r�r\r$)r%r4r�rrrrN�
szServer.get_methodscCs"|t�
�_|
�d
�

|�|
�

dS)z=
        Spawn a new thread to serve this connection
        )z#RETURNNN)r_r�rr1r�)r%r4rrrrrM�
s



zServer.accept_connectioncCs�|j��
y|j
|d
7<Wnhtk
r�
}
zJ||jkrrd
|j
|<|j||j|<|j|\}}}t�d|�
n|�
Wdd}~XYnXWdQRXdS)Nrz&Server re-enabled tracking & INCREF %r)rar]r�r^r\rru)r%r4r�r�r r�r�rrrrR�
s








z
Server.increfc	Cs�||jkr$||j
kr$t�d
|�
dS|j�Z
|j|dk
rXtd�||j||j|��
�
|j|d8<|j|dkr�|j|=WdQRX||jkr�d|j|<t�d|�
|j�
|j|=WdQRXdS)NzServer DECREF skipping %rrz+Id {0!s} ({1!r}) has refcount {2:n}, not 1+r)NrNzdisposing of obj with id %r)r]r^rrura�AssertionErrorr>r\)r%r4r�rrrrS�
s$



















z
Server.decrefN)r+r-r.r/Zpublicr&ryrkr{r�r�r�r�r�rQrOrPrKrLrNrMrRrSrrrrrJ�s.


"Q


8rJc
@seZ
dZd
g
ZdZdZdZdS)�State�valuerrr�N)r+r-r.r0�INITIAL�STARTED�SHUTDOWNrrrrr��
s



r�)�pickleZ	xmlrpclibc@s�eZ
dZd
ZiZeZd"dd�
Zdd�Zdd	�Z	d#dd�
Z
ed$d
d�
�
Zdd�Z
d%dd�
Zdd�Zdd�Zdd�Zdd�Zedd��
Zedd��
Zed&d d!�
�
ZdS)'r
z!
    Base class for managers
    Nr�cCs\|dkrt�
�j}|
|_t�|�
|_t�|_tj|j_	||_
t|\|_|_
|pTt�|_dS)
N)r
rhrY�_addressrX�_authkeyr��_stater�r��_serializerrZZ	_Listener�_Clientr�_ctx)r%r#rYrbZctxrrrr&�
s









zBaseManager.__init__c

Csf|jj
tjkrP|jj
tjkr&td
�
�
n*|jj
tjkr>td�
�
ntd�|jj
�
�
�
t|j	|j
|j|j�S)zX
        Return server object with serve_forever() method and address attribute
        zAlready started serverzManager has shut downzUnknown state {!r})
r�r�r�r�r�rr�r>rJ�	_registryr�r�r�)
r%rrr�
get_servers









zBaseManager.get_serverc
Cs8t|j
\}
}||j|jd
�}t|dd�
tj|j_dS)z>
        Connect manager object to the server process
        )
rYNrQ)	rZr�r�r�r:r�r�r�r�)r%rcrdr�rrr�connects


zBaseManager.connectrc	Cs4
|jj
tjkrP|jj
tjkr&td
�
�
n*|jj
tjkr>td�
�
ntd�|jj
�
�
�
|
dk	rht|
�
sht	d�
�
t
jdd�
\}}|jj
t|�
j|j|j|j|j||
|fd�|_d	�d
d�|jjD�
�
}t|�
jd||j_|j��
|��
|��|_|��
tj|j_
tj|t|�
j|j|j|j|j|jfd
d�|_ dS)z@
        Spawn a server process for this manager object
        zAlready started serverzManager has shut downzUnknown state {!r}Nzinitializer must be a callableF)
Zduplex)rer6�
:c
ss|]}
t|
�
V
qdS)
N)
r<)r�
irrr�	<genexpr>1sz$BaseManager.start.<locals>.<genexpr>�
-r)r6�exitpriority)!r�r�r�r�r�rr�r>rCr=rZPiper�ZProcessr�_run_serverr�r�r�r��_processr�Z	_identityr+rrmrr2r�Finalize�_finalize_managerr�rK)r%�initializer�initargs�reader�writerr�rrrrms4
























zBaseManager.startc	CsN|d
k	r||�
|�|
|||�}|�
|j�

|��
t�d|j�
|��
d
S)z@
        Create a server, report its address and run it
        Nzmanager serving at %r)�_Serverr1r#rrr~ry)	�clsrWr#rYrbr�r�r��serverrrrr�Cs


zBaseManager._run_servercOs`|^}}}t|�
}|j
|j|jd
�}zt|dd|f
||
�\}}Wd|��
Xt||j|�|fS)zP
        Create a new shared object; return the token and exposed tuple
        )
rYNrL)r�r�r�r�r:rr)r6r7r%r"r�r$r�rrr�_createWs





zBaseManager._createcCs*|jd
k	r&|j�
|
�

|j��s&d
|_d
S)zC
        Join the manager process (if it has been spawned)
        N)r�r��is_alive)r%�timeoutrrrr�fs




zBaseManager.joinc
Cs.|j|j
|jd
�}
zt|
dd�S|
��
XdS)zS
        Return some info about the servers shared objects and connections
        )
rYNrO)r�r�r�r:r)r%r�rrr�_debug_infoos

zBaseManager._debug_infoc
Cs.|j|j
|jd
�}
zt|
dd�S|
��
XdS)z5
        Return the number of shared objects
        )
rYNrP)r�r�r�r:r)r%r�rrr�_number_of_objectsys

zBaseManager._number_of_objectsc

Csj|jj
tjkr|��
|jj
tjkrf|jj
tjkr<td
�
�
n*|jj
tjkrTtd�
�
ntd�|jj
�
�
�
|S)NzUnable to start serverzManager has shut downzUnknown state {!r})	r�r�r�r�rmr�rr�r>)
r%rrr�	__enter__�s










zBaseManager.__enter__cCs|��
dS)
N)
rK)r%�exc_type�exc_val�exc_tbrrr�__exit__�s
zBaseManager.__exit__cCs�|��r�t
�d
�

y,||
|d�}zt|dd�
Wd|��
XWntk
rR


YnX|jdd�

|��r�t
�d�

t|d�r�t
�d	�

|��
|jd
d�

|��r�t
�d�

t	j
|_ytj
|
=Wntk
r�


YnXdS)zQ
        Shutdown the manager process; will be registered as a finalizer
        z#sending shutdown message to manager)
rYNrKg�?)
r�zmanager still alive�	terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r�rr~r:rr}r��hasattrr�r�r�r�r�_address_to_localr�)r
r#rYr(r�r�rrrr��s.























zBaseManager._finalize_managerc


Cs|jS)
N)
r�)
r%rrrr#�szBaseManager.addressTc
s�d
|jkr|j
��|_
�dkr"t�|p0t�dd�}|p@t�dd�}|r`xt|���
D]\}}qTW|||�f|j
�
<|r���
fdd�}	�
|	_t|�
|	�
dS)z9
        Register a typeid with the manager type
        r�N�	_exposed_�_method_to_typeid_c
s`t�
d
�
�
|j�
f
|
�|�
\}}�||j||j|d�}|j|j|jd�}t|dd|jf
�
|S)Nz)requesting creation of a shared %r object)�managerrYr�)
rYrS)	rrur�r�r�r�r#r:r$)r%r6r7r�Zexp�proxyr�)r�r"rrrE�s






z"BaseManager.register.<locals>.temp)	�__dict__r��copy�	AutoProxyrrrr+�setattr)
r�r"rCr�r�r��
create_method�keyr�rEr)r�r"r�register�s







zBaseManager.register)NNr�N)Nr)Nr)
N)NNNNT)r+r-r.r/r�rJr�r&r�r�rm�classmethodr�r�r�r�r�r�r��staticmethodr��propertyr#r�rrrrr
�
s*



	
+
	


 

c@seZ
dZd
d�Zdd�ZdS)�ProcessLocalSetc

Cst�
|d
d��
dS)Nc

Ss|��S)
N)
�clear)
r rrr�<lambda>��z*ProcessLocalSet.__init__.<locals>.<lambda>)r�register_after_fork)
r%rrrr&�s
zProcessLocalSet.__init__c

Cst|�
d
fS)Nr)
r)
r%rrr�
__reduce__�s
zProcessLocalSet.__reduce__N)r+r-r.r&r�rrrrr��s
r�c@s�eZ
dZd
ZiZe��Zddd�
Zdd�Z	d	ifd
d�
Z
dd
�Zdd�Ze
dd��
Zdd�Zdd�Zdd�Zdd�Zdd�ZdS)rz.
    A base for proxies of shared objects
    NTFc		Cs�tj
�8
tj�|
jd�}|dkr:t��t�f}|tj|
j<WdQRX|d
|_|d|_	|
|_
|j
j|_||_
||_t|d|_||_|dk	r�t�|�
|_n"|j
dk	r�|j
j|_nt��j|_|r�|��
t�|tj�
dS)Nrr)r�_mutexr�r�r#rZForkAwareLocalr��_tls�_idset�_tokenr$�_id�_managerr�rZr��_owned_by_managerr
rXr�rhrY�_increfr��_after_fork)	r%r�rbr�rYr�rR�
manager_ownedZ	tls_idsetrrrr&�s*















zBaseProxy.__init__c
Csdt�
d
�

t��j}
t��jdkr4|
dt��j7}
|j|jj	|j
d�}t|dd|
f
�
||j_
dS)Nzmaking connection to managerZ
MainThread�
|)
rYrM)rrur
rhrr_r�r�r�r#r�r:r�r)r%rr�rrr�_connects








zBaseProxy._connectrcCs�y|jj
}Wn6tk
rB


t�d
t��j�
|��
|jj
}YnX|�	|j
|
||f�

|��\}}|dkrp|S|dkr�|\}}|jj
|jd}	|jj|_|	||j|j|j|d�}
|j|j|jd�}t|dd|jf
�
|
St||��
dS)	zV
        Try to call a method of the referent and return a copy of the result
        z#thread %r does not own a connectionz#RETURNz#PROXY���)r�rYr�)
rYNrS)r�rr�rrur_r�rr�r1r�r2r�r�r"r�r#r�r�r�r:r$r3)r%r5r6r7r�r8r9r�r�r�r�rrr�_callmethod&s,



















zBaseProxy._callmethodc

Cs
|�d
�
S)z9
        Get a copy of the value of the referent
        z	#GETVALUE)
r�)
r%rrr�	_getvalueDszBaseProxy._getvaluec
	Cs�|jrt
�d
|jj�
dS|j|jj|jd�}
t|
dd|j	f
�
t
�d|jj�
|j
�|j	�

|joj|jj
}t
j|tj|j|j||j|j
|jfdd�|_dS)Nz%owned_by_manager skipped INCREF of %r)
rYrRz	INCREF %r�
)r6r�)r�rrur�r$r�r#r�r:r�r��addr�r�r�r�_decrefr�Z_close)r%r�r(rrrr�Js









zBaseProxy._increfc
Cs�|�|j
�

|dks |jtjkr�y2t�d
|j
�
||j|
d�}t|dd|j
f
�
Wq�t	k
r�
}
zt�d|�
Wdd}~XYq�Xnt�d|j
�
|s�t
|d�r�t�dt��j
�
|j��
|`dS)Nz	DECREF %r)
rYrSz... decref failed %sz%DECREF %r -- manager already shutdownrz-thread %r has no more proxies so closing conn)�discardr$r�r�r�rrur#r:r}r�r_r�rrr)r�rYr(ZtlsZidsetr�r�r�rrrr�^s




 




zBaseProxy._decrefc

CsHd|_y|�
�
Wn0tk
rB
}

zt�d
|
�

Wdd}
~
XYnXdS)Nzincref failed: %s)r�r�r}rr~)r%r�rrrr�ws




zBaseProxy._after_forkc
Cs^i}
t�dk	r|j
|
d
<t|dd�rB|j|
d<tt|j|j|
ffStt|�
|j|j|
ffSdS)NrY�_isautoFr�)	r
r�rr��RebuildProxyr�r�r�r)r%r7rrrr�s









zBaseProxy.__reduce__cCs|��S)
N)
r�)r%Zmemorrr�__deepcopy__�s
zBaseProxy.__deepcopy__c

Csd
t|�
j
|jjt|�
fS)Nz<%s object, typeid %r at %#x>)rr+r�r"r$)
r%rrrr,�s

zBaseProxy.__repr__c

Cs4y
|�d
�
St
k
r.


t|�
dd�dSXdS)zV
        Return representation of the referent (or a fall-back if that fails)
        r,Nr�z; '__str__()' failed>)r�r}r�)
r%rrrrA�s



zBaseProxy.__str__)NNNTF)r+r-r.r/r�rZForkAwareThreadLockr�r&r�r�r�r�r�r�r�r�r�r,rArrrrr�s



(	
cCs�tt
��d
d�}|rT|j|
jkrTt�d|
�
d|d<|
j|jkrT|j|
j|j|
j<|�	dd�optt
��dd�}||
|fd|i
|��
S)	z5
    Function used for unpickling proxy objects.
    riNz*Rebuild a proxy owned by manager, token=%rTr�rRZ_inheritingF)
rr
rhr#rrur$r^r\r�)rFr�rbr7r�rRrrrr��s




r�cCsrt|
�
}
y|||
fSt
k
r(


YnXi}x|
D]}td
||f|�
q4Wt|tf
|�}|
|_||||
f<|S)zB
    Return a proxy type whose methods are given by `exposed`
    zLdef %s(self, *args, **kwds):
        return self._callmethod(%r, args, kwds))r�r��execrrr�)rr��_cacheZdicZmeth�	ProxyTyperrr�
MakeProxyType�s









r�Tc
Cs�t|
d
}|dkrB||j
|d�}zt|dd|f
�}Wd|��
X|dkrX|dk	rX|j}|dkrjt��j}td|j	|�}|||
|||d�}	d|	_
|	S)z*
    Return an auto-proxy for `token`
    rN)
rYrNz
AutoProxy[%s])r�rYrRT)rZr#r:rr�r
rhrYr�r"r�)
r�rbr�rYr�rRr�r�r�r�rrrr��s












r�c@seZ
dZd
d�Zdd�ZdS)�	Namespacec
Ks|j�
|
�

dS)
N)r��update)r%r7rrrr&�s
zNamespace.__init__c
Cs^t|j
���
}
g}x,|
D]$\}}|�d
�
s|�d||f�

qW|��
d|jjd�|�
fS)NrHz%s=%rz%s(%s)z, )	rr�r�
startswithrDr�r*r+r�)r%rrErr�rrrr,�s







zNamespace.__repr__N)r+r-r.r&r,rrrrr
�s
r
c@s8eZ
dZddd�
Zdd�Zdd�Zdd	�Zeee�Zd
S)�ValueTcCs|
|_||_
dS)
N)�	_typecode�_value)r%rr��lockrrrr&�s

zValue.__init__c


Cs|jS)
N)
r
)
r%rrrr��s
z	Value.getcCs
|
|_dS)
N)
r
)r%r�rrrr��s
z	Value.setc

Csd
t|�
j
|j|jfS)Nz
%s(%r, %r))rr+r
r
)
r%rrrr,�s
zValue.__repr__N)
T)	r+r-r.r&r�r�r,r�r�rrrrr
�s


r
cCst�||
�S)
N)
r)rZsequencer
rrr�Arrays
r
c@s8eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�ZdS)
�
IteratorProxy)�__next__r1�throwrc


Cs|S)
Nr)
r%rrr�__iter__	s
zIteratorProxy.__iter__c
Gs|�d
|
�S)Nr	
)
r�)r%r6rrrr	
s
zIteratorProxy.__next__c
Gs|�d
|
�S)Nr1)
r�)r%r6rrrr1
s
zIteratorProxy.sendc
Gs|�d
|
�S)Nr

)
r�)r%r6rrrr

s
zIteratorProxy.throwc
Gs|�d
|
�S)Nr)
r�)r%r6rrrrs
zIteratorProxy.closeN)	r+r-r.r�r
r	
r1r

rrrrrr
s

r
c@s2eZ
dZd
Zddd�
Zdd�Zdd	�Zd
d�ZdS)
�
AcquirerProxy)�acquire�releaseTNcCs"|dkr|
f
n|
|f}|�d
|�S)Nr

)
r�)r%Zblockingr�r6rrrr

s

zAcquirerProxy.acquirec

Cs
|�d
�
S)Nr
)
r�)
r%rrrr
s
zAcquirerProxy.releasec

Cs
|�d
�
S)Nr

)
r�)
r%rrrr�s
zAcquirerProxy.__enter__cCs
|�d
�
S)Nr
)
r�)r%r�r�r�rrrr�s
zAcquirerProxy.__exit__)TN)r+r-r.r�r

r
r�r�rrrrr
s



r
c@s6eZ
dZd
Zddd�
Zd
dd�
Zdd	�Zdd
d�
ZdS)�ConditionProxy)r

r
ro�notify�
notify_allNcCs|�d
|
f
�S)Nro)
r�)r%r�rrrro$s
zConditionProxy.waitrcCs|�d
|
f
�S)Nr
)
r�)r%�
nrrrr
&s
zConditionProxy.notifyc

Cs
|�d
�
S)Nr
)
r�)
r%rrrr
(s
zConditionProxy.notify_allcCsh|
�}|r|S|dk	r$t�
�|}nd}d}x6|sb|dk	rP|t�
�}|d
k
rPP|�|�

|
�}q.W|S)Nr)�timeZ	monotonicro)r%Z	predicater�r9ZendtimeZwaittimerrr�wait_for*s















zConditionProxy.wait_for)
N)
r)
N)r+r-r.r�ror
r
r
rrrrr
"s




r
c@s2eZ
dZd
Zdd�Zdd�Zdd�Zdd	d
�
ZdS)�
EventProxy)rnr�r�roc

Cs
|�d
�
S)Nrn)
r�)
r%rrrrn?s
zEventProxy.is_setc

Cs
|�d
�
S)Nr�)
r�)
r%rrrr�As
zEventProxy.setc

Cs
|�d
�
S)Nr�)
r�)
r%rrrr�Cs
zEventProxy.clearNcCs|�d
|
f
�S)Nro)
r�)r%r�rrrroEs
zEventProxy.wait)
N)r+r-r.r�rnr�r�rorrrrr
=s


r
c@sNeZ
dZd
Zddd�
Zdd�Zdd�Zed	d
��
Zedd��
Z	ed
d��
Z
dS)�BarrierProxy)�__getattribute__ro�abort�resetNcCs|�d
|
f
�S)Nro)
r�)r%r�rrrroKs
zBarrierProxy.waitc

Cs
|�d
�
S)Nr
)
r�)
r%rrrr
Ms
zBarrierProxy.abortc

Cs
|�d
�
S)Nr
)
r�)
r%rrrr
Os
zBarrierProxy.resetc

Cs|�d
d�S)Nr
)
�parties)
r�)
r%rrrr
QszBarrierProxy.partiesc

Cs|�d
d�S)Nr
)
�	n_waiting)
r�)
r%rrrr
TszBarrierProxy.n_waitingc

Cs|�d
d�S)Nr
)
�broken)
r�)
r%rrrr
WszBarrierProxy.broken)
N)r+r-r.r�ror
r
r�r
r
r
rrrrr
Is


r
c@s(eZ
dZd
Zdd�Zdd�Zdd�ZdS)	�NamespaceProxy)r
�__setattr__�__delattr__cCs0|
d
dkrt�
||
�St�
|d�}|d|
f
�S)NrrHr�r
)�objectr
)r%r��
callmethodrrr�__getattr__^s



zNamespaceProxy.__getattr__cCs4|
d
dkrt�
||
|�St�|d�}|d|
|f�S)NrrHr�r
)r 
r
r
)r%r�r�r!
rrrr
cs



zNamespaceProxy.__setattr__cCs0|
d
dkrt�
||
�St�|d�}|d|
f
�S)NrrHr�r
)r 
r
r
)r%r�r!
rrrr
hs



zNamespaceProxy.__delattr__N)r+r-r.r�r"
r
r
rrrrr
\s

r
c@s*eZ
dZd
Zdd�Zdd�Zeee�ZdS)�
ValueProxy)r�r�c

Cs
|�d
�
S)Nr�)
r�)
r%rrrr�qs
zValueProxy.getcCs|�d
|
f
�S)Nr�)
r�)r%r�rrrr�ss
zValueProxy.setN)r+r-r.r�r�r�r�r�rrrrr#
os

r#
�
BaseListProxy)�__add__�__contains__�__delitem__�__getitem__�__len__�__mul__�__reversed__�__rmul__�__setitem__rD�count�extend�index�insertr��remove�reverser��__imul__c@seZ
dZd
d�Zdd�ZdS)�	ListProxycCs|�d
|
f
�
|S)Nr/
)
r�)r%r�rrr�__iadd__s

zListProxy.__iadd__cCs|�d
|
f
�
|S)Nr4
)
r�)r%r�rrrr4
�s

zListProxy.__imul__N)r+r-r.r6
r4
rrrrr5
~s
r5
�	DictProxy)r&
r'
r(
r
r)
r-
r�r�r�rrr��popitem�
setdefaultr

rr
�Iterator�
ArrayProxy)r)
r(
r-
�	PoolProxy)Zapply�apply_asyncr�imap�imap_unorderedr��map�	map_async�starmap�
starmap_asyncr�ZAsyncResult)r=
rA
rC
r>
r?
c@seZ
dZd
d�Zdd�ZdS)r<
c


Cs|S)
Nr)
r%rrrr��s
zPoolProxy.__enter__cCs|��
dS)
N)
r�)r%r�r�r�rrrr��s
zPoolProxy.__exit__N)r+r-r.r�r�rrrrr<
�s
c
@seZ
dZd
ZdS)ra(

    Subclass of `BaseManager` which supports a number of shared object types.

    The types registered are those intended for the synchronization
    of threads, plus `dict`, `list` and `Namespace`.

    The `multiprocessing.Manager()` function creates started instances of
    this class.
    N)r+r-r.r/rrrrr�s	�QueueZ
JoinableQueuerfr`�RLock�	Semaphore�BoundedSemaphore�	Condition�Barrier�Poolrr�F)r�r�)
r�)NNNT)
T)J�__all__rrr_rZqueuer
r�r�r�contextr	r
rrr
rrrr�Z
view_typesrr!Z	view_typer 
rr:r3r}r?rGrIrJr�rcrdZXmlListenerZ	XmlClientrZr
r�r�rr�r�r�r
r
r
r
r
r
r
r
r
r#
r$
r5
r7
r�r;
Z
BasePoolProxyr<
rrD
rfr`rE
rF
rG
rH
rI
rJ
r�rrrr�<module>s�














\

w
4