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 ]

3

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

ddlmZ
ddlmZ
dd
lmZ
dd�Zejeje�
dd�d�D�
Zedek	r�dd�ZxeD]Zejee�
q�WGdd�de�Zfifdd�
Zdd�ZGdd�de�Zdd�Zd d!�ZGd"d#�d#e�ZGd$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+d�d0d1�
Z,Gd2d3�d3e�Z-Gd4d5�d5e�Z.d�d6d7�
Z/Gd8d9�d9e)�Z0Gd:d;�d;e)�Z1Gd<d=�d=e1�Z2Gd>d?�d?e)�Z3Gd@dA�dAe)�Z4GdBdC�dCe)�Z5GdDdE�dEe)�Z6e+dFd��Z7GdZd[�d[e7�Z8e+d\d��Z9d]dei
e9_:e+dfd��Z;e+dgd��Z<dsdsdsdededt�e<_:Gdudg�dge<�Z=Gdvd
�d
e&�Z>e>jdwej?�
e>jdxej?�
e>jdyej@e3�
e>jdzejAe1�
e>jd{ejBe1�
e>jd|ejCe1�
e>jd}ejDe1�
e>jd~ejEe2�
e>jdejFe4�
e>jd�e
jGe=�
e>jd�ee8�
e>jd�eHe9�
e>jd5e.e6�
e>jd7e/e;�
e>jd3e-e5�
e>jdee0d�d��
e>jdsd�d��
dS)��BaseManager�SyncManager�	BaseProxy�Token�N)
�
format_exc�
)
�
connection)�	reduction�get_spawning_popen)
�pool)
�process)
�util)
�get_contextc

Cstj|j
|j�ffS)
N)�array�typecode�tobytes)
�
a�r�=/opt/alt/python36/lib64/python3.6/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�Zd	d
�Zdd�Zd
S)rz4
    Type to uniquely indentify 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!r"r#)	r*�
__module__�__qualname__�__doc__�	__slots__r%r&r(r+rrrrr3s
cCs8|j|
|||f�

|j
�\}}|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




r9cCs\|d
kr|
S|dkr,t|
�
t
ks$t�
t|
�
S|dkrPt|
�
t
ksDt�
td|
�
Std�
SdS)Nz#ERRORz
#TRACEBACKz#UNSERIALIZABLEzUnserializable message: %s
zUnrecognized message type)r�str�AssertionError�RemoteError�
ValueError)r7r8rrrr2Ts







r2c@seZ
dZd
d�ZdS)r<c

Cs&d
ddd
t|j
d�
ddS)N�

�
-�Kr)r:r5)
r$rrr�__str__as
zRemoteError.__str__N)r*r,r-rArrrrr<`s
r<c
Cs6g}
x,t|�
D] }t
||�}t|�
r|
j|�

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





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)rrrrrrwsz"public_methods.<locals>.<listcomp>)
rG)
rrrr�public_methodsssrIc	@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�decrefcCslt|t
�st�
|
|_tj|�
|_t|\}}||d
d�|_|jj	|_	ddffi
|_
i|_i|_t
j�|_dS)N�)r"Zbacklog�
0)�
isinstance�bytesr;�registryr�AuthenticationString�authkey�listener_client�listenerr"�	id_to_obj�id_to_refcount�id_to_local_proxy_obj�	threading�Lock�mutex)r$rXr"rZ�
serializer�Listener�Clientrrrr%�s








zServer.__init__c
Cs�tj
�|_|tj�_zZtj|jd
�
}
d|
_|
j	�
y x|jj
�sN|jjd�

q6WWntt
fk
rj


YnXWdtjtjkr�tjd�

tjt_tjt_tjd�

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$rlrrr�
serve_forever�s 

















zServer.serve_foreverc
CsPxJy|jj
�}
Wntk
r&


wYnXtj|j|
f
d
�}d|_|j�
qWdS)N)rfr5T)r\Zaccept�OSErrorr`rk�handle_requestrmrn)r$r3�
trrrrl�s







zServer.accepterc'CsL
d
}}}yTtj
|
|j�
tj|
|j�
|
j�}|\}}}}||jksTtd|�
�
t||�}Wntk
r~


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


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

Wnttk
�
r>
}

zVy|
j
dt	�f�

Wntk
�
r


YnXtjd|	�
tjd|�
tjd|
�
WYd
d
}
~
XnX|
j
�
d
S)z)
        Handle a new connection
        Nz%r unrecognizedz
#TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r)rZdeliver_challengerZZanswer_challenger1�publicr;r�	Exceptionrr0r
�info�close)r$r3�funcnamer8�request�ignorer5r6rF�msg�
errrr|�s4





















zServer.handle_requestcDCs�tj
d
tj�j�
|
j}|
j}|j}�x�|jj	��s�
yBd}}|�}|\}}}	}
y||\}}}Wn^t
k
r�
}

zBy|j|\}}}Wn&t
k
r�
}
z
|
�
WYdd}~XnXWYdd}
~
XnX||kr�td|t
|�
|f�
�
t||�}y||	|
�
}Wn,tk
�
r&
}
zd|f}WYdd}~XnPX|�
o8|j|d�}|�
rn|j|
||�\}}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"


tj
dtj�j�
tjd	�

Yn tk
�r@


dt�f}YnXyDy||�

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

WYdd}~XnXWq(tk
�r�
}
zBtjdtj�j�
tjd|�
tjd
|�
|
j�
tjd�

WYdd}~Xq(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)r
rvr`�current_threadrr1r0r]rhro�KeyErrorr_�AttributeErrorrrr�getrLrr"r�fallback_mapping�EOFErrorrsryr�r�)r$�connr1r0r]r4rr��identr5r6�exposed�	gettypeid�keZ	second_keZfunction�resr�r�r!ZridentZrexposed�tokenZ
fallback_funcr8rrr�serve_client�sx











(



























$






zServer.serve_clientc
Cs|S)
Nr)r$r�r�rrrr�fallback_getvalue&
s
zServer.fallback_getvaluecCst|�
S)
N)
r:)r$r�r�rrrr�fallback_str)
s
zServer.fallback_strcCst|�
S)
N)
�repr)r$r�r�rrrr�
fallback_repr,
s
zServer.fallback_repr)rAr+z	#GETVALUEc
CsdS)
Nr)r$r3rrrrQ5
s
zServer.dummycCs||j�l
g}t
|jj��
}|j�
xD|D]<}|d
kr(|jd||j|t|j|d�
dd�f�

q(Wdj|�
SQRXdS)zO
        Return some info --- useful to spot problems with refcounting
        rUz  %s:       refcount=%s
    %srNr@r>)	rbrr^r�sortrDr:r]�join)r$r3r8rr�rrrrO8
s









$
zServer.debug_infocCs
t|j
�
S)
z*
        Number of shared objects
        )�lenr^)r$r3rrrrPG
szServer.number_of_objectscCsLz:ytj
d
�

|
jd�

Wn


ddl}|j�
YnXWd|jj�
XdS)z'
        Shutdown this process
        z!manager received shutdown message�#RETURNNr)r�N)r
rvr0�	traceback�	print_excrh�set)r$r3r�rrrrKN
s





zServer.shutdowncOs�|j��
|j
|\}}}}|d
krBt|�
dkr4|s8t�
|d}	n
|||�
}	|d
kr\t|	�
}|d
k	r�t|�
tkstt�
t|�
t|�
}dt|	�
}
t	j
d||
�
|	t|�
|f|j|
<|
|j
kr�d|j
|
<Wd
QRX|j|
|
�
|
t|�
fS)z>
        Create a new shared object and return its id
        Nrrz%xz&%r callable returned object with id %r)rbrXr�r;rIr�dictrr#r
rvr�r]r^rR�tuple)r$r3r!r5r6rCr��method_to_typeid�	proxytyperr�rrrrL[
s$











z
Server.createcCst|j
|jd
�
S)zL
        Return the methods of the shared object indicated by token
        r)r�r]r#)r$r3r�rrrrNz
szServer.get_methodscCs"|tj
�_|
jd�

|j|
�

dS)z=
        Spawn a new thread to serve this connection
        �#RETURNN)r�N)r`r�rr0r�)r$r3rrrrrM�
s



zServer.accept_connectioncCs�|j��
y|j
|d
7<Wnhtk
r�
}
zL||jkrrd
|j
|<|j||j|<|j|\}}}tjd|�
n|�
WYdd}~XnXWdQRXdS)Nrz&Server re-enabled tracking & INCREF %r)rbr^r�r_r]r
rv)r$r3r�r�rr�r�rrrrR�
s








z
Server.increfcCs�||jkr$||j
kr$tjd
|�
dS|j�@
|j|dks>t�
|j|d8<|j|dkrf|j|=WdQRX||jkr�dfdf|j|<tjd|�
|j�
|j|=WdQRXdS)NzServer DECREF skipping %rrrzdisposing of obj with id %r)r^r_r
rvrbr;r])r$r3r�rrrrS�
s













z
Server.decrefN)r*r,r-r.r~r%rzrlr|r�r�r�r�r�rQrOrPrKrLrNrMrRrSrrrrrJ}s.


"Q


rJc
@seZ
dZd
g
ZdZdZdZdS)�State�valuerr�N)r*r,r-r/�INITIAL�STARTED�SHUTDOWNrrrrr��
s



r�)�pickleZ	xmlrpclibc@s�eZ
dZd
ZiZeZd!dd�
Zdd�Zdd	�Z	dffd
d�
Z
edffdd
�
�
Zdd�Z
d"dd�
Zdd�Zdd�Zdd�Zdd�Zedd��
Zedd��
Zed#dd �
�
ZdS)$r
z!
    Base class for managers
    Nr�cCs\|dkrtj
�j}|
|_tj|�
|_t�|_tj|j_	||_
t|\|_|_
|pTt�|_dS)
N)rrirZ�_addressrY�_authkeyr��_stater�r��_serializerr[Z	_Listener�_Clientr�_ctx)r$r"rZrcZctxrrrr%�
s









zBaseManager.__init__c

Cs(|jj
tjkst�
t|j|j|j|j	�S)
zX
        Return server object with serve_forever() method and address attribute
        )
r�r�r�r�r;rJ�	_registryr�r�r�)
r$rrr�
get_server�
s


zBaseManager.get_serverc
Cs8t|j
\}
}||j|jd
�}t|dd�
tj|j_dS)z>
        Connect manager object to the server process
        )
rZNrQ)	r[r�r�r�r9r�r�r�r�)r$rdrer�rrr�connect�
s


zBaseManager.connectc	Cs�|jj
tjkst�
|
d
k	r,t|
�
r,td�
�
tjdd�
\}}|j	j
t|�
j|j
|j|j|j||
|fd�|_djdd�|jjD�
�
}t|�
jd	||j_|jj�
|j�
|j�|_|j�
tj|j_
tj|t|�
j|j|j|j|j|jfd
d�|_d
S)z@
        Spawn a server process for this manager object
        Nzinitializer must be a callableF)
Zduplex)rfr5�
:c
ss|]}
t|
�
V
qdS)
N)
r:)r�
irrr�	<genexpr>�
sz$BaseManager.start.<locals>.<genexpr>r?r)r5�exitpriority)r�r�r�r�r;rC�	TypeErrorrZPiper�ZProcessr�_run_serverr�r�r�r��_processr�Z	_identityr*rrnr�r1r�r
�Finalize�_finalize_managerr�rK)r$�initializer�initargs�reader�writerr�rrrrn�
s(

















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

|j�
tjd|j�
|j�
d
S)z@
        Create a server, report its address and run it
        Nzmanager serving at %r)�_Serverr0r"r�r
r�rz)	�clsrXr"rZrcr�r�r��serverrrrr�s


zBaseManager._run_servercOsd|jj
tjkstd
�
�
|j|j|jd�}zt|dd|
f
||�\}}Wd|j	�
Xt
|
|j|�|fS)zP
        Create a new shared object; return the token and exposed tuple
        zserver not yet started)
rZNrL)r�r�r�r�r;r�r�r�r9r�r)r$r!r5r6r�r#r�rrr�_create%s




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

|jj�s&d
|_d
S)zC
        Join the manager process (if it has been spawned)
        N)r�r��is_alive)r$�timeoutrrrr�1s




zBaseManager.joinc

Cs.|j|j
|jd
�}
zt|
dd�S|
j�
XdS)zS
        Return some info about the servers shared objects and connections
        )
rZNrO)r�r�r�r9r�)r$r�rrr�_debug_info:s

zBaseManager._debug_infoc

Cs.|j|j
|jd
�}
zt|
dd�S|
j�
XdS)z5
        Return the number of shared objects
        )
rZNrP)r�r�r�r9r�)r$r�rrr�_number_of_objectsDs

zBaseManager._number_of_objectsc

Cs,|jj
tjkr|j�
|jj
tjks(t�
|S)
N)r�r�r�r�rnr�r;)
r$rrr�	__enter__Ns



zBaseManager.__enter__c
Cs|j�
dS)
N)
rK)r$�exc_type�exc_val�exc_tbrrr�__exit__Ts
zBaseManager.__exit__cCs�|j�r�t
jd
�

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


YnX|jdd�

|j�r�t
jd�

t|d�r�t
jd	�

|j�
|jd
d�

|j�r�t
jd�

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)
rZNrKg�?)
r�zmanager still alive�	terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r�r
r�r9r�rr��hasattrr�r�r�r�r�_address_to_localr�)rr"rZr'r�r�rrrr�Ws.























zBaseManager._finalize_managerc


Cs|jS)
N)
r�)
r$rrr�<lambda>wszBaseManager.<lambda>Tc
s�d
|jkr|j
j�|_
�dkr"t�|p0t�dd�}|p@t�dd�}|r�xHt|j��
D]8\}}t|�
tkstt	d|�
�
t|�
tksTt	d|�
�
qTW|||�f|j
�
<|rƇ�
fdd�}	�
|	_
t|�
|	�
dS)z9
        Register a typeid with the manager type
        r�N�	_exposed_�_method_to_typeid_z%r is not a stringc
s`tj
d
�
�
|j�
f
|
�|�
\}}�||j||j|d�}|j|j|jd�}t|dd|jf
�
|S)Nz)requesting creation of a shared %r object)�managerrZr�)
rZrS)	r
rvr�r�r�r�r"r9r#)r$r5r6r�Zexp�proxyr�)r�r!rrrE�s






z"BaseManager.register.<locals>.temp)�__dict__r��copy�	AutoProxyrrrrr:r;r*�setattr)
r�r!rCr�r�r��
create_method�keyr�rEr)r�r!r�registerys 









zBaseManager.register)NNr�N)
N)NNNNT)r*r,r-r.r�rJr�r%r�r�rn�classmethodr�r�r�r�r�r�r��staticmethodr��propertyr"r�rrrrr
�
s*



	$
	

 

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

Cstj
|d
d��
dS)Nc


Ss|j�S)
N)
�clear)
rrrrr��sz*ProcessLocalSet.__init__.<locals>.<lambda>)r
�register_after_fork)
r$rrrr%�s
zProcessLocalSet.__init__c

Cst|�
ffS)
N)
r)
r$rrr�
__reduce__�s
zProcessLocalSet.__reduce__N)r*r,r-r%r�rrrrr��s
r�c@s�eZ
dZd
ZiZej�Zddd�
Zdd�Z	fifd	d
�
Z
dd�Zd
d�Ze
dd��
Zdd�Zdd�Zdd�Zdd�Zdd�ZdS)rz.
    A base for proxies of shared objects
    NTFc	
Cs�tj
�8
tjj|
jd�}|dkr:tj�t�f}|tj|
j<WdQRX|d
|_|d|_	|
|_
|j
j|_||_
||_t|d|_||_|dk	r�tj|�
|_n"|j
dk	r�|j
j|_ntj�j|_|r�|j�
tj|tj�
dS)Nrr)r�_mutexr�r�r"r
ZForkAwareLocalr��_tls�_idset�_tokenr#�_id�_managerr�r[r��_owned_by_managerrrYr�rirZ�_increfr��_after_fork)	r$r�rcr�rZr�rR�
manager_ownedZ	tls_idsetrrrr%�s*















zBaseProxy.__init__c
Csdtj
d
�

tj�j}
tj�jdkr4|
dtj�j7}
|j|jj	|j
d�}t|dd|
f
�
||j_
dS)Nzmaking connection to managerZ
MainThread�
|)
rZrM)r
rvrrirr`r�r�r�r"r�r9r�r)r$rr�rrr�_connect�s








zBaseProxy._connectcCs�y|jj
}Wn6tk
rB


tjd
tj�j�
|j�
|jj
}YnX|j	|j
|
||f�

|j�\}}|dkrp|S|dkr�|\}}|jj
|jd	}	|jj|_|	||j|j|j|d�}
|j|j|jd�}t|dd|jf
�
|
St||��
dS)
zW
        Try to call a method of the referrent and return a copy of the result
        z#thread %r does not own a connectionz#RETURNz#PROXYr)r�rZr�)
rZNrS���)r�rr�r
rvr`r�rr�r0r�r1r�r�r!r�r"r�r�r�r9r#r2)r$r4r5r6r�r7r8r�r�r�r�rrr�_callmethod�s,



















zBaseProxy._callmethodc

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

|joj|jj
}t
j|tj|j|j||j|j
|jfdd�|_dS)Nz%owned_by_manager skipped INCREF of %r)
rZrRz	INCREF %r�
)r5r�)r�r
rvr�r#r�r"r�r9r�r��addr�r�r�r�_decrefr�Z_close)r$r�r'rrrr�s









zBaseProxy._increfcCs�|j|j
�

|dks |jtjkr�y2tjd
|j
�
||j|
d�}t|dd|j
f
�
Wq�t	k
r�
}
ztjd|�
WYdd}~Xq�Xntjd|j
�
|r�t
|d�r�tjdtj�j
�
|jj�
|`dS)Nz	DECREF %r)
rZrSz... decref failed %sz%DECREF %r -- manager already shutdownrz-thread %r has no more proxies so closing conn)�discardr#r�r�r�r
rvr"r9rr�r`r�rrr�)r�rZr'ZtlsZidsetr�r�r�rrrr� s




 




zBaseProxy._decrefc
CsHd|_y|j
�
Wn0tk
rB
}

ztjd
|
�

WYdd}
~
XnXdS)Nzincref failed: %s)r�r�rr
r�)r$r�rrrr�9s




zBaseProxy._after_forkc
Cs^i}
t�dk	r|j
|
d
<t|dd�rB|j|
d<tt|j|j|
ffStt|�
|j|j|
ffSdS)NrZ�_isautoFr�)	r
r�rr��RebuildProxyr�r�r�r)r$r6rrrr�As









zBaseProxy.__reduce__c
Cs|j�S)
N)
r�)r$�memorrr�__deepcopy__Ns
zBaseProxy.__deepcopy__c

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

zBaseProxy.__repr__c

Cs4y
|jd
�
St
k
r.


t|�
dd�dSXdS)zV
        Return representation of the referent (or a fall-back if that fails)
        r+Nrz; '__str__()' failed>r�)r�rr�)
r$rrrrAUs



zBaseProxy.__str__)NNNTF)r*r,r-r.r�r
ZForkAwareThreadLockr�r%r�r�r�r�r�r�r�r�r�r+rArrrrr�s



(	
cCs�tt
j�d
d�}|rT|j|
jkrTtjd|
�
d|d<|
j|jkrT|j|
j|j|
j<|j	dd�optt
j�dd�}||
|fd|i
|��
S)	z5
    Function used for unpickling proxy objects.
    rjNz*Rebuild a proxy owned by manager, token=%rTr�rRZ_inheritingF)
rrrir"r
rvr#r_r]�pop)rFr�rcr6r�rRrrrr�bs




r�c
Csrt|
�
}
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��_cacheZdic�meth�	ProxyTyperrr�
MakeProxyTypews









r

Tc
Cs�t|
d
}|dkrB||j
|d�}zt|dd|f
�}Wd|j�
X|dkrX|dk	rX|j}|dkrjtj�j}td|j	|�}|||
|||d�}	d|	_
|	S)z*
    Return an auto-proxy for `token`
    rN)
rZrNz
AutoProxy[%s])r�rZrRT)r[r"r9r�r�rrirZr

r!r�)
r�rcr�rZr�rRr�r�r
r�rrrr��s












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

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

qW|j�
d|jjdj|�
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tj||
�S)
N)
r)rZsequencer
rrr�Array�s
r	
c@s8eZ
dZdZdd�Zdd�Zd	d
�Zdd�Zd
d�ZdS)�
IteratorProxy�__next__r0�throwr�c


Cs|S)
Nr)
r$rrr�__iter__�s
zIteratorProxy.__iter__c
Gs|jd
|
�S)Nr
)
r�)r$r5rrrr
�s
zIteratorProxy.__next__c
Gs|jd
|
�S)Nr0)
r�)r$r5rrrr0�s
zIteratorProxy.sendc
Gs|jd
|
�S)Nr
)
r�)r$r5rrrr
�s
zIteratorProxy.throwc
Gs|jd
|
�S)Nr�)
r�)r$r5rrrr��s
zIteratorProxy.closeN)r
r0r
r�)	r*r,r-r�r

r
r0r
r�rrrrr

�s

r

c@s2eZ
dZd
Zddd�
Zdd�Zd	d
�Zdd�ZdS)�
AcquirerProxy�acquire�releaseTNcCs"|dkr|
f
n|
|f}|jd
|�S)Nr
)
r�)r$Zblockingr�r5rrrr
�s

zAcquirerProxy.acquirec

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
�s
zAcquirerProxy.releasec

Cs
|jd
�
S)Nr
)
r�)
r$rrrr��s
zAcquirerProxy.__enter__cCs
|jd
�
S)Nr
)
r�)r$r�r�r�rrrr��s
zAcquirerProxy.__exit__)r
r
)TN)r*r,r-r�r
r
r�r�rrrrr
�s



r
c@s4eZ
dZdZddd�
Zd	d
�Zdd�Zdd
d�
ZdS)�ConditionProxyr
r
rp�notify�
notify_allNcCs|jd
|
f
�S)Nrp)
r�)r$r�rrrrp�s
zConditionProxy.waitc

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
�s
zConditionProxy.notifyc

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
�s
zConditionProxy.notify_allcCsh|
�}|r|S|dk	r$tj
�|}nd}d}x6|sb|dk	rP|tj
�}|d
k
rPP|j|�

|
�}q.W|S)Nr)�timeZ	monotonicrp)r$Z	predicater�r8ZendtimeZwaittimerrr�wait_for�s















zConditionProxy.wait_for)r
r
rpr
r
)
N)
N)r*r,r-r�rpr
r
r
rrrrr
�s



r
c@s2eZ
dZdZdd�Zdd�Zd	d
�Zddd
�
ZdS)�
EventProxyror�r�rpc

Cs
|jd
�
S)Nro)
r�)
r$rrrro
s
zEventProxy.is_setc

Cs
|jd
�
S)Nr�)
r�)
r$rrrr�s
zEventProxy.setc

Cs
|jd
�
S)Nr�)
r�)
r$rrrr�s
zEventProxy.clearNcCs|jd
|
f
�S)Nrp)
r�)r$r�rrrrps
zEventProxy.wait)ror�r�rp)
N)r*r,r-r�ror�r�rprrrrr
�s


r
c@sNeZ
dZdZddd�
Zdd	�Zd
d�Zedd
��
Zedd��
Z	edd��
Z
dS)�BarrierProxy�__getattribute__rp�abort�resetNcCs|jd
|
f
�S)Nrp)
r�)r$r�rrrrp
s
zBarrierProxy.waitc

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
s
zBarrierProxy.abortc

Cs
|jd
�
S)Nr
)
r�)
r$rrrr
s
zBarrierProxy.resetc

Cs|jd
d�S)Nr
�parties)
r
)
r�)
r$rrrr
szBarrierProxy.partiesc

Cs|jd
d�S)Nr
�	n_waiting)
r
)
r�)
r$rrrr
szBarrierProxy.n_waitingc

Cs|jd
d�S)Nr
�broken)
r
)
r�)
r$rrrr
szBarrierProxy.broken)r
rpr
r
)
N)r*r,r-r�rpr
r
r�r
r
r
rrrrr
s


r
c@s(eZ
dZdZdd�Zdd�Zdd	�Zd
S)�NamespaceProxyr
�__setattr__�__delattr__cCs0|
d
dkrtj
||
�Stj
|d�}|d|
f
�S)NrrHr�r
)�objectr
)r$r��
callmethodrrr�__getattr__ s



zNamespaceProxy.__getattr__cCs4|
d
dkrtj
||
|�Stj|d�}|d|
|f�S)NrrHr�r
)r!
r
r
)r$r�r�r"
rrrr
%s



zNamespaceProxy.__setattr__cCs0|
d
dkrtj
||
�Stj|d�}|d|
f
�S)NrrHr�r 
)r!
r 
r
)r$r�r"
rrrr 
*s



zNamespaceProxy.__delattr__N)r
r
r 
)r*r,r-r�r#
r
r 
rrrrr
s

r
c@s*eZ
dZdZdd�Zdd�Zeee�ZdS)	�
ValueProxyr�r�c

Cs
|jd
�
S)Nr�)
r�)
r$rrrr�3s
zValueProxy.getcCs|jd
|
f
�S)Nr�)
r�)r$r�rrrr�5s
zValueProxy.setN)r�r�)r*r,r-r�r�r�r�r�rrrrr$
1s

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|jd
|
f
�
|S)Nr0
)
r�)r$r�rrr�__iadd__As

zListProxy.__iadd__cCs|jd
|
f
�
|S)Nr5
)
r�)r$r�rrrr5
Ds

zListProxy.__imul__N)r*r,r-r7
r5
rrrrr6
@s
r6
�	DictProxyr

r�r�r��has_key�popitem�
setdefaultr
�Iterator�
ArrayProxy�	PoolProxy�apply�apply_asyncr��imap�imap_unorderedr��map�	map_async�starmap�
starmap_asyncr�ZAsyncResult)r@
rD
rF
rA
rB
c@seZ
dZd
d�Zdd�ZdS)r>
c


Cs|S)
Nr)
r$rrrr�ds
zPoolProxy.__enter__c
Cs|j�
dS)
N)
r�)r$r�r�r�rrrr�fs
zPoolProxy.__exit__N)r*r,r-r�r�rrrrr>
cs
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.rrrrrms	�QueueZ
JoinableQueuergra�RLock�	Semaphore�BoundedSemaphore�	Condition�Barrier�Poolrr�F)r�r�)
r�)rrr)NNNT)
T)r&
r'
r(
r)
r*
r+
r,
r-
r.
rDr/
r0
r1
r2
r�r3
r4
r�r5
)r'
r(
r)
r

r*
r.
r�r�r�r9
rrr�r:
r;
r
r)r*
r)
r.
)r?
r@
r�rA
rB
r�rC
rD
rE
rF
r�)I�__all__rsr`rZqueuer
r�r�r�contextr	r
rrr
rrr�Z
view_typesrr Z	view_typer!
rr9r2rr<rGrIrJr�rdreZXmlListenerZ	XmlClientr[r
r�r�rr�r

r�r
r
r	
r

r
r
r
r
r
r$
r%
r6
r8
r�r=
Z
BasePoolProxyr>
rrG
rgrarH
rI
rJ
rK
rL
rM
r�rrrr�<module>s�














;

]
4