Linux server.ldran.com 4.18.0-513.18.1.el8_9.x86_64 #1 SMP Thu Feb 22 03:02:37 EST 2024 x86_64
Apache
: 178.128.81.129 | : 172.70.92.203
254 Domain
8.1.29
materijurusanac
www.github.com/MadExploits
Terminal
AUTO ROOT
Adminer
Backdoor Destroyer
Linux Exploit
Lock Shell
Lock File
Create User
CREATE RDP
PHP Mailer
BACKCONNECT
UNLOCK SHELL
HASH IDENTIFIER
CPANEL RESET
CREATE WP USER
BLACK DEFEND!
README
+ Create Folder
+ Create File
/
usr /
lib64 /
python3.6 /
multiprocessing /
__pycache__ /
[ HOME SHELL ]
Name
Size
Permission
Action
__init__.cpython-36.opt-1.pyc
507
B
-rw-r--r--
__init__.cpython-36.opt-2.pyc
507
B
-rw-r--r--
__init__.cpython-36.pyc
507
B
-rw-r--r--
connection.cpython-36.opt-1.py...
23.97
KB
-rw-r--r--
connection.cpython-36.opt-2.py...
21.79
KB
-rw-r--r--
connection.cpython-36.pyc
24.26
KB
-rw-r--r--
context.cpython-36.opt-1.pyc
12.79
KB
-rw-r--r--
context.cpython-36.opt-2.pyc
11.33
KB
-rw-r--r--
context.cpython-36.pyc
12.79
KB
-rw-r--r--
forkserver.cpython-36.opt-1.py...
6.58
KB
-rw-r--r--
forkserver.cpython-36.opt-2.py...
5.81
KB
-rw-r--r--
forkserver.cpython-36.pyc
6.68
KB
-rw-r--r--
heap.cpython-36.opt-1.pyc
5.75
KB
-rw-r--r--
heap.cpython-36.opt-2.pyc
5.75
KB
-rw-r--r--
heap.cpython-36.pyc
5.94
KB
-rw-r--r--
managers.cpython-36.opt-1.pyc
32.04
KB
-rw-r--r--
managers.cpython-36.opt-2.pyc
29.66
KB
-rw-r--r--
managers.cpython-36.pyc
32.54
KB
-rw-r--r--
pool.cpython-36.opt-1.pyc
20.08
KB
-rw-r--r--
pool.cpython-36.opt-2.pyc
18.53
KB
-rw-r--r--
pool.cpython-36.pyc
20.33
KB
-rw-r--r--
popen_fork.cpython-36.opt-1.py...
2.04
KB
-rw-r--r--
popen_fork.cpython-36.opt-2.py...
2.04
KB
-rw-r--r--
popen_fork.cpython-36.pyc
2.08
KB
-rw-r--r--
popen_forkserver.cpython-36.op...
2.27
KB
-rw-r--r--
popen_forkserver.cpython-36.op...
2.27
KB
-rw-r--r--
popen_forkserver.cpython-36.py...
2.27
KB
-rw-r--r--
popen_spawn_posix.cpython-36.o...
2.06
KB
-rw-r--r--
popen_spawn_posix.cpython-36.o...
2.06
KB
-rw-r--r--
popen_spawn_posix.cpython-36.p...
2.06
KB
-rw-r--r--
popen_spawn_win32.cpython-36.o...
2.66
KB
-rw-r--r--
popen_spawn_win32.cpython-36.o...
2.58
KB
-rw-r--r--
popen_spawn_win32.cpython-36.p...
2.7
KB
-rw-r--r--
process.cpython-36.opt-1.pyc
7.32
KB
-rw-r--r--
process.cpython-36.opt-2.pyc
6.29
KB
-rw-r--r--
process.cpython-36.pyc
7.95
KB
-rw-r--r--
queues.cpython-36.opt-1.pyc
8.66
KB
-rw-r--r--
queues.cpython-36.opt-2.pyc
8.66
KB
-rw-r--r--
queues.cpython-36.pyc
8.74
KB
-rw-r--r--
reduction.cpython-36.opt-1.pyc
7.73
KB
-rw-r--r--
reduction.cpython-36.opt-2.pyc
6.92
KB
-rw-r--r--
reduction.cpython-36.pyc
7.77
KB
-rw-r--r--
resource_sharer.cpython-36.opt...
5
KB
-rw-r--r--
resource_sharer.cpython-36.opt...
4.59
KB
-rw-r--r--
resource_sharer.cpython-36.pyc
5.04
KB
-rw-r--r--
semaphore_tracker.cpython-36.o...
3.55
KB
-rw-r--r--
semaphore_tracker.cpython-36.o...
3.25
KB
-rw-r--r--
semaphore_tracker.cpython-36.p...
3.58
KB
-rw-r--r--
sharedctypes.cpython-36.opt-1....
6.65
KB
-rw-r--r--
sharedctypes.cpython-36.opt-2....
6.41
KB
-rw-r--r--
sharedctypes.cpython-36.pyc
6.71
KB
-rw-r--r--
spawn.cpython-36.opt-1.pyc
6.25
KB
-rw-r--r--
spawn.cpython-36.opt-2.pyc
5.78
KB
-rw-r--r--
spawn.cpython-36.pyc
6.29
KB
-rw-r--r--
synchronize.cpython-36.opt-1.p...
11.03
KB
-rw-r--r--
synchronize.cpython-36.opt-2.p...
11.03
KB
-rw-r--r--
synchronize.cpython-36.pyc
11.3
KB
-rw-r--r--
util.cpython-36.opt-1.pyc
9.46
KB
-rw-r--r--
util.cpython-36.opt-2.pyc
8.78
KB
-rw-r--r--
util.cpython-36.pyc
9.57
KB
-rw-r--r--
Delete
Unzip
Zip
${this.title}
Close
Code Editor : managers.cpython-36.opt-1.pyc
3 \� � @ s� d dddgZ ddlZddlZddlZddlZddlZddlmZ ddlm Z dd l m Z m Z dd lm Z dd lmZ dd lmZ dd lmZ dd� Ze jeje� dd� d�D �Zed ek r�dd� ZxeD ]Ze jee� q�W G dd� de�Zf i fdd�Zdd� ZG d d � d e�Z d d � Z d d!� Z G d"d#� d#e�Z G d$d%� d%e�Z e j!e j"fe j#e j$fd&�Z%G d'd � d e�Z&G d(d)� d)e'�Z(G d*d� de�Z)d+d,� Z*i fd-d.�Z+d�d0d1�Z,G d2d3� d3e�Z-G d4d5� d5e�Z.d�d6d7�Z/G d8d9� d9e)�Z0G d:d;� d;e)�Z1G d<d=� d=e1�Z2G d>d?� d?e)�Z3G d@dA� dAe)�Z4G dBdC� dCe)�Z5G dDdE� dEe)�Z6e+dFd��Z7G dZd[� d[e7�Z8e+d\d��Z9d]deie9_:e+dfd��Z;e+dgd��Z<dsdsdsdededt�e<_:G dudg� dge<�Z=G dvd� de&�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 C s t j | j| j� ffS )N)�array�typecode�tobytes)�a� r �0/usr/lib64/python3.6/multiprocessing/managers.py� reduce_array$ s r c C s g | ]}t ti |�� ��qS r )�type�getattr)�.0�namer r r � <listcomp>( s r �items�keys�valuesc C s t t | �ffS )N)�list)�objr r r �rebuild_as_list* s r c @ s4 e Zd ZdZdZdd� Zdd� Zd d � Zd d � Zd S )r z4 Type to uniquely indentify a shared object �typeid�address�idc C s ||| | _ | _| _d S )N)r! r" r# )�selfr! r" r# r r r �__init__9 s zToken.__init__c C s | j | j| jfS )N)r! r" r# )r$ r r r � __getstate__< s zToken.__getstate__c C s |\| _ | _| _d S )N)r! r" r# )r$ �stater r r � __setstate__? s zToken.__setstate__c C s d| j j| j| j| jf S )Nz %s(typeid=%r, address=%r, id=%r))� __class__�__name__r! r" r# )r$ r r r �__repr__B s zToken.__repr__N)r! r" r# ) r* � __module__� __qualname__�__doc__� __slots__r% r& r( r+ r r r r r 3 s c C s8 | j ||||f� | j� \}}|dkr*|S t||��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�resultr r r �dispatchJ s r9 c C s< | dkr |S | dkr t |�S | dkr0t d| �S td�S d S )Nz#ERRORz #TRACEBACKz#UNSERIALIZABLEzUnserializable message: %s zUnrecognized message type)� RemoteError� ValueError)r7 r8 r r r r2 T s r2 c @ s e Zd Zdd� ZdS )r: c C s& ddd d t | jd � dd S )N� �-�K r )�strr5 )r$ r r r �__str__a s zRemoteError.__str__N)r* r, r- r@ r r r r r: ` s r: c C s6 g }x,t | �D ] }t| |�}t|�r|j|� qW |S )z4 Return a list of names of methods of `obj` )�dirr �callable�append)r �tempr �funcr r r � all_methodsh s rF c C s dd� t | �D �S )zP Return a list of names of methods of `obj` which do not start with '_' c S s g | ]}|d dkr|�qS )r �_r )r r r r r r w s z"public_methods.<locals>.<listcomp>)rF )r r r r �public_methodss s rH c @ s� e Zd ZdZdddddddd d g Zd d � Zd d� Zdd� Zdd� Zdd� Z dd� Z dd� Z dd� Z e e e d�Z d d � Zd d � 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�decrefc C s^ || _ tj|�| _t| \}}||dd�| _| jj| _dd f fi| _i | _i | _ t j � | _ d S )N� )r" Zbacklog�0) �registryr �AuthenticationString�authkey�listener_client�listenerr" � id_to_obj�id_to_refcount�id_to_local_proxy_obj� threading�Lock�mutex)r$ rU r" rW � serializer�Listener�Clientr r r r% � s zServer.__init__c C s� t j� | _| tj� _zZt j| jd�}d|_|j � y x| jj � sN| jj d� q6W W n t t fk rj Y nX W dtjtjkr�tjd� tjt_tjt_tjd� X dS )z( Run the server forever )�targetTr Nzresetting 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$ ri r r r � serve_forever� s zServer.serve_foreverc C sP xJy| j j� }W n tk r& wY nX tj| j|fd�}d|_|j� qW d S )N)rc r5 T)rY Zaccept�OSErrorr] rh �handle_requestrj rk )r$ r3 �tr r r ri � s zServer.accepterc ' C s4 d } }}y>t j|| j� t j|| j� |j� }|\}}}}t| |�}W n tk rh dt� f} Y n>X y||f|�|�}W n tk r� dt� f} Y n X d|f} y|j| � W nr tk �r& } zTy|jdt� f� W n tk r� Y nX t j d| � t j d|� t j d| � W Y dd} ~ X nX |j � dS )z) Handle a new connection Nz #TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r) r Zdeliver_challengerW Zanswer_challenger1 r � Exceptionr r0 r �info�close) r$ r3 �funcnamer8 �request�ignorer5 r6 rE �msg�er r r ry � s2 zServer.handle_requestc D C s� t jdtj� j� |j}|j}| j}�x�| jj � �s�yBd }}|� }|\}}} } y|| \}} } W n^ t k r� } zBy| j | \}} } W n& t k r� } z | �W Y dd}~X nX W Y dd} ~ X nX || kr�t d|t |�| f ��t||�}y|| | �}W n, tk �r& } zd|f}W Y dd}~X nPX | �o8| j|d�}|�rn| j|||�\}}t|| j|�}d||ff}nd|f}W n� t k �r� |dk�r�dt� f}nNy,| j| }|| |||f| �| �}d|f}W n tk �r� dt� f}Y nX Y nP tk �r" t jdtj� j� tjd � Y n tk �r@ dt� f}Y nX yDy ||� W n2 tk �r� } z|d t� f� W Y dd}~X nX W q( tk �r� } zBt jd tj� j� t jd |� t jd |� |j� tjd� W Y dd}~X q(X q(W dS )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 %rr z#UNSERIALIZABLEz exception in thread serving %rz ... message was %rz ... exception was %rr )r rs r] �current_threadr r1 r0 rZ re rl �KeyErrorr\ �AttributeErrorr r r{ �getrK r r" r �fallback_mapping�EOFErrorrp rv r| r} )r$ �connr1 r0 rZ r4 r r �identr5 r6 �exposed� gettypeid�keZ second_keZfunction�resr� r� r! ZridentZrexposed�tokenZ fallback_funcr8 r r r � serve_client� sx ( $ zServer.serve_clientc C s |S )Nr )r$ r� r� r r r r �fallback_getvalue& s zServer.fallback_getvaluec C s t |�S )N)r? )r$ r� r� r r r r � fallback_str) s zServer.fallback_strc C s t |�S )N)�repr)r$ r� r� r r r r � fallback_repr, s zServer.fallback_repr)r@ r+ z #GETVALUEc C s d S )Nr )r$ r3 r r r rP 5 s z Server.dummyc C s| | j �l g }t| jj� �}|j� xD|D ]<}|dkr(|jd|| j| t| j| d �dd� f � q(W dj|�S Q R X dS )zO Return some info --- useful to spot problems with refcounting rT z %s: refcount=%s %sr Nr> r< ) r_ r r[ r �sortrC r? rZ �join)r$ r3 r8 r r� r r r rN 8 s $zServer.debug_infoc C s t | j�S )z* Number of shared objects )�lenr[ )r$ r3 r r r rO G s zServer.number_of_objectsc C sL z:yt jd� |jd� W n ddl}|j� Y nX W d| jj� X dS )z' Shutdown this process z!manager received shutdown message�#RETURNNr )r� N)r rs r0 � traceback� print_excre �set)r$ r3 r� r r r rJ N s zServer.shutdownc O s� | j �� | j| \}}}}|dkr,|d } n |||�} |dkrFt| �}|dk r^t|�t|� }dt| � } tjd|| � | t|�|f| j| < | | j kr�d| j | < W dQ R X | j || � | t |�fS )z> Create a new shared object and return its id Nr z%xz&%r callable returned object with id %r) r_ rU rH r r# r rs r� rZ r[ rQ �tuple) r$ r3 r! r5 r6 rB r� �method_to_typeid� proxytyper r� r r r rK [ s z Server.createc C s t | j|j d �S )zL Return the methods of the shared object indicated by token r )r� rZ r# )r$ r3 r� r r r rM z s zServer.get_methodsc C s" |t j� _|jd� | j|� dS )z= Spawn a new thread to serve this connection �#RETURNN)r� N)r] r� r r0 r� )r$ r3 r r r r rL � s zServer.accept_connectionc C s� | j �� y| j| d7 < W nh tk r� } zL|| jkrrd| j|< | j| | j|< | j| \}}}tjd|� n|�W Y d d }~X nX W d Q R X d S )Nr z&Server re-enabled tracking & INCREF %r)r_ r[ r� r\ rZ r rs )r$ r3 r� r� r r� r� r r r rQ � s z Server.increfc C s� || j kr$|| jkr$tjd|� d S | j�. | j | d8 < | j | dkrT| j |= W d Q R X || j kr�d f d f| j|< tjd|� | j� | j|= W d Q R X d S )NzServer DECREF skipping %rr r zdisposing of obj with id %r)r[ r\ r rs r_ rZ )r$ r3 r� r r r rR � s z Server.decrefN)r* r, r- r. Zpublicr% rw ri ry r� r� r� r� r� rP rN rO rJ rK rM rL rQ rR r r r r rI } s. "Q rI c @ s e Zd ZdgZdZdZdZdS )�State�valuer r � N)r* r, r- r/ �INITIAL�STARTED�SHUTDOWNr r r r r� � s r� )�pickleZ xmlrpclibc @ s� e Zd ZdZi ZeZd!dd�Zdd� Zdd � Z df fd d �Z e df fd d ��Z dd� Z d"dd�Zdd� Zdd� Zdd� Zdd� Zedd� �Zed d � �Ze d#d d ��ZdS )$r z! Base class for managers Nr� c C s\ |d krt j� j}|| _t j|�| _t� | _tj| j_ || _ t | \| _ | _ |pTt� | _d S )N)r rf rW �_addressrV �_authkeyr� �_stater� r� � _serializerrX Z _Listener�_Clientr �_ctx)r$ r" rW r` Zctxr r r r% � s zBaseManager.__init__c C s t | j| j| j| j�S )zX Return server object with serve_forever() method and address attribute )rI � _registryr� r� r� )r$ r r r � get_server� s zBaseManager.get_serverc C s8 t | j \}}|| j| jd�}t|dd� tj| j_dS )z> Connect manager object to the server process )rW NrP ) rX r� r� r� r9 r� r� r� r� )r$ ra rb r� r r r �connect� s zBaseManager.connectc C s� |dk rt |� rtd��tjdd�\}}| jjt| �j| j| j | j | j |||fd�| _ dj dd� | j jD ��}t| �jd | | j _| j j� |j� |j� | _ |j� tj| j_tj| t| �j| j | j | j | j| jfd d �| _ dS ) z@ Spawn a server process for this manager object Nz initializer must be a callableF)Zduplex)rc r5 �:c s s | ]}t |�V qd S )N)r? )r �ir r r � <genexpr>� s z$BaseManager.start.<locals>.<genexpr>r= r )r5 � exitpriority) rB � TypeErrorr ZPiper� ZProcessr � _run_serverr� r� r� r� �_processr� Z _identityr* r rk r} r1 r� r� r� r� r �Finalize�_finalize_managerr� rJ )r$ � initializer�initargs�reader�writerr� r r r rk � s& zBaseManager.startc C sN |dk r||� | j ||||�}|j|j� |j� tjd|j� |j� dS )z@ Create a server, report its address and run it Nzmanager serving at %r)�_Serverr0 r" r} r r| rw ) �clsrU r" rW r` r� r� r� �serverr r r r� s zBaseManager._run_serverc O sN | j | j| jd�}z t|dd|f| |�\}}W d|j� X t|| j|�|fS )zP Create a new shared object; return the token and exposed tuple )rW NrK )r� r� r� r9 r} r )r$ r! r5 r6 r� r# r� r r r �_create% s zBaseManager._createc C s* | j dk r&| j j|� | j j� s&d| _ dS )zC Join the manager process (if it has been spawned) N)r� r� �is_alive)r$ �timeoutr r r r� 1 s zBaseManager.joinc C s. | j | j| jd�}z t|dd�S |j� X dS )zS Return some info about the servers shared objects and connections )rW NrN )r� r� r� r9 r} )r$ r� r r r � _debug_info: s zBaseManager._debug_infoc C s. | j | j| jd�}z t|dd�S |j� X dS )z5 Return the number of shared objects )rW NrO )r� r� r� r9 r} )r$ r� r r r �_number_of_objectsD s z BaseManager._number_of_objectsc C s | j jtjkr| j� | S )N)r� r� r� r� rk )r$ r r r � __enter__N s zBaseManager.__enter__c C s | j � d S )N)rJ )r$ �exc_type�exc_val�exc_tbr r r �__exit__T s zBaseManager.__exit__c C s� | j � r�tjd� y,|||d�}zt|dd� W d|j� X W n tk rR Y nX | jdd� | j � r�tjd� t| d�r�tjd � | j� | jd d� | j � r�tjd � t j |_ y t j |= W n tk r� Y nX dS ) zQ Shutdown the manager process; will be registered as a finalizer z#sending shutdown message to manager)rW NrJ g �?)r� zmanager still alive� terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r� r r| r9 r} r{ r� �hasattrr� r� r� r� r �_address_to_localr� )r r" rW r' r� r� r r r r� W s. z BaseManager._finalize_managerc C s | j S )N)r� )r$ r r r �<lambda>w s zBaseManager.<lambda>Tc s� d| j kr| jj� | _� dkr"t� |p0t� dd�}|p@t� dd�}|r`xt|j� �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 jd�� | j�f|�|�\}}� || j| | j|d�}| j|j| jd�}t|d d|jf� |S )Nz)requesting creation of a shared %r object)�managerrW r� )rW rR ) r rs r� r� r� r� r" r9 r# )r$ r5 r6 r� Zexp�proxyr� )r� r! r r rD � s z"BaseManager.register.<locals>.temp) �__dict__r� �copy� AutoProxyr r r r* �setattr) r� r! rB r� r� r� � create_method�keyr� rD r )r� r! r �registery s zBaseManager.register)NNr� N)N)NNNNT)r* r, r- r. r� rI r� r% r� r� rk � classmethodr� r� r� r� r� r� r� � staticmethodr� �propertyr" r� r r r r r � s* $ c @ s e Zd Zdd� Zdd� ZdS )�ProcessLocalSetc C s t j| dd� � d S )Nc S s | j � S )N)�clear)r r r r r� � s z*ProcessLocalSet.__init__.<locals>.<lambda>)r �register_after_fork)r$ r r r r% � s zProcessLocalSet.__init__c C s t | �f fS )N)r )r$ r r r � __reduce__� s zProcessLocalSet.__reduce__N)r* r, r- r% r� r r r r r� � s r� c @ s� e Zd ZdZi Zej� Zddd�Zdd� Z f i fd d �Z d d � Z d d� Z e dd� �Zdd� Zdd� Zdd� Zdd� Zdd� ZdS ) r z. A base for proxies of shared objects NTFc C s� t j�8 t jj|jd �}|d kr:tj� t� f}|t j|j< W d Q R X |d | _|d | _ || _ | j j | _ || _ || _t| d | _|| _|d k r�tj|�| _n"| j d k r�| j j| _n tj� j| _|r�| j� tj| t j� d S )Nr r )r �_mutexr� r� r" r ZForkAwareLocalr� �_tls�_idset�_tokenr# �_id�_managerr� rX r� �_owned_by_managerr rV r� rf rW �_increfr� � _after_fork) r$ r� r` r� rW r� rQ � manager_ownedZ tls_idsetr r r r% � s* zBaseProxy.__init__c C sd t jd� tj� j}tj� jdkr4|dtj� j 7 }| j| jj | j d�}t |d d|f� || j _ d S )Nz making connection to managerZ MainThread�|)rW rL )r rs r rf r r] r� r� r� r" r� r9 r� r )r$ r r� r r r �_connect� s zBaseProxy._connectc C s� y | j j}W n6 tk rB tjdtj� j� | j� | j j}Y nX |j | j |||f� |j � \}}|dkrp|S |dkr�|\}}| j j |j d } | jj|_| || j| j | j|d�} | j|j| jd�}t|dd|jf� | S t||��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� rW r� )rW NrR ���)r� r r� r rs r] r� r r� r0 r� r1 r� r� r! r� r" r� r� r� r9 r# r2 ) r$ r4 r5 r6 r� r7 r8 r� r� r� r� r r r � _callmethod� s, zBaseProxy._callmethodc C s | j d�S )z9 Get a copy of the value of the referent z #GETVALUE)r� )r$ r r r � _getvalue s zBaseProxy._getvaluec C s� | j rtjd| jj� d S | j| jj| jd�}t|d d| j f� tjd| jj� | j j | j � | j oj| j j }tj| tj| j| j|| j| j | jfdd�| _d S )Nz%owned_by_manager skipped INCREF of %r)rW rQ z INCREF %r� )r5 r� )r� r rs r� r# r� r" r� r9 r� r� �addr� r� r� r �_decrefr� Z_close)r$ r� r' r r r r� s zBaseProxy._increfc C s� |j | j� |d ks |jtjkr�y2tjd| j� || j|d�}t|d d| jf� W q� t k r� } ztjd|� W Y d d }~X q�X ntjd| j� | r�t |d�r�tjdt j � j � |jj� |`d S )Nz DECREF %r)rW rR z... decref failed %sz%DECREF %r -- manager already shutdownr z-thread %r has no more proxies so closing conn)�discardr# r� r� r� r rs r" r9 r{ r� r] r� r r r} )r� rW r' ZtlsZidsetr� r� r� r r r r� s zBaseProxy._decrefc C sH d | _ y | j� W n0 tk rB } ztjd| � W Y d d }~X nX d S )Nzincref failed: %s)r� r� r{ r r| )r$ r� r r r r� 9 s zBaseProxy._after_forkc C s^ i }t � d k r| j|d< t| dd�rB| j|d< tt| j| j|ffS tt| �| j| j|ffS d S )NrW �_isautoFr� ) r r� r r� � RebuildProxyr� r� r� r )r$ r6 r r r r� A s zBaseProxy.__reduce__c C s | j � S )N)r� )r$ �memor r r � __deepcopy__N s zBaseProxy.__deepcopy__c C s dt | �j| jjt| �f S )Nz <%s object, typeid %r at %#x>)r r* r� r! r# )r$ r r r r+ Q s zBaseProxy.__repr__c C s4 y | j d�S tk r. t| �dd� d S X dS )zV Return representation of the referent (or a fall-back if that fails) r+ Nr z; '__str__()' failed>r� )r� r{ r� )r$ r r r r@ U s zBaseProxy.__str__)NNNTF)r* r, r- r. r� r ZForkAwareThreadLockr� r% r� r� r� r� r� r� r� r� r� r+ r@ r r r r r � s ( c C s� t tj� dd�}|rT|j|jkrTtjd|� d|d< |j|jkrT|j|j |j|j< |j dd�opt tj� dd� }| ||fd|i|��S ) z5 Function used for unpickling proxy objects. rg Nz*Rebuild a proxy owned by manager, token=%rTr� rQ Z _inheritingF) r r rf r" r rs r# r\ rZ �pop)rE r� r` r6 r� rQ r r r r� b s r� c C sr t |�}y || |f S tk r( Y nX i }x |D ]}td||f |� q4W t| 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� �execr r r� )r r� �_cacheZdic�meth� ProxyTyper r r � MakeProxyTypew s r� Tc C s� t | d }|dkrB|| j|d�}zt|dd| f�}W d|j� X |dkrX|dk rX|j}|dkrjtj� j}td| j |�}|| ||||d�} d| _ | S )z* Return an auto-proxy for `token` r N)rW rM z AutoProxy[%s])r� rW rQ T) rX r" r9 r} r� r rf rW r� r! r� ) r� r` r� rW r� rQ r� r� r� r� r r r r� � s r� c @ s e Zd Zdd� Zdd� ZdS )� Namespacec K s | j j|� d S )N)r� �update)r$ r6 r r r r% � s zNamespace.__init__c C s^ t | jj� �}g }x,|D ]$\}}|jd�s|jd||f � qW |j� d| jjdj|�f S )NrG z%s=%rz%s(%s)z, ) r r� r � startswithrC r� r) r* r� )r$ r rD r r� r r r r+ � s zNamespace.__repr__N)r* r, r- r% r+ r r r r r� � s r� c @ s8 e Zd Zd dd�Zdd� Zdd� Zdd � Zeee�Zd S ) �ValueTc C s || _ || _d S )N)� _typecode�_value)r$ r r� �lockr r r r% � s zValue.__init__c C s | j S )N)r )r$ r r r r� � s z Value.getc C s || _ d S )N)r )r$ r� r r r r� � s z Value.setc C s dt | �j| j| jf S )Nz %s(%r, %r))r r* r r )r$ r r r r+ � s zValue.__repr__N)T) r* r, r- r% r� r� r+ r� r� r r r r r � s r c C s t j | |�S )N)r )r Zsequencer r r r �Array� s r c @ s8 e Zd ZdZdd� Zdd� Zd d � Zd d � Zd d� ZdS )� IteratorProxy�__next__r0 �throwr} c C s | S )Nr )r$ r r r �__iter__� s zIteratorProxy.__iter__c G s | j d|�S )Nr )r� )r$ r5 r r r r � s zIteratorProxy.__next__c G s | j d|�S )Nr0 )r� )r$ r5 r r r r0 � s zIteratorProxy.sendc G s | j d|�S )Nr )r� )r$ r5 r r r r � s zIteratorProxy.throwc G s | j d|�S )Nr} )r� )r$ r5 r r r r} � s zIteratorProxy.closeN)r r0 r r} ) r* r, r- r� r r r0 r r} r r r r r � s r c @ s2 e Zd Zd Zddd�Zdd� Zd d � Zd d � ZdS )� AcquirerProxy�acquire�releaseTNc C s" |d kr|fn||f}| j d|�S )Nr )r� )r$ Zblockingr� r5 r r r r � s zAcquirerProxy.acquirec C s | j d�S )Nr )r� )r$ r r r r � s zAcquirerProxy.releasec C s | j d�S )Nr )r� )r$ r r r r� � s zAcquirerProxy.__enter__c C s | j d�S )Nr )r� )r$ r� r� r� r r r r� � s zAcquirerProxy.__exit__)r r )TN)r* r, r- r� r r r� r� r r r r r � s r c @ s4 e Zd ZdZddd�Zd d � Zd d � Zdd d�ZdS )�ConditionProxyr r rm �notify� notify_allNc C s | j d|f�S )Nrm )r� )r$ r� r r r rm � s zConditionProxy.waitc C s | j d�S )Nr )r� )r$ r r r r � s zConditionProxy.notifyc C s | j d�S )Nr )r� )r$ r r r r � s zConditionProxy.notify_allc C sh |� }|r|S |d k r$t j� | }nd }d }x6|sb|d k rP|t j� }|dkrPP | j|� |� }q.W |S )Nr )�timeZ monotonicrm )r$ Z predicater� r8 ZendtimeZwaittimer r r �wait_for� s zConditionProxy.wait_for)r r rm r r )N)N)r* r, r- r� rm r r r r r r r r � s r c @ s2 e Zd ZdZdd� Zdd� Zd d � Zdd d �Zd S )� EventProxyrl r� r� rm c C s | j d�S )Nrl )r� )r$ r r r rl s zEventProxy.is_setc C s | j d�S )Nr� )r� )r$ r r r r� s zEventProxy.setc C s | j d�S )Nr� )r� )r$ r r r r� s zEventProxy.clearNc C s | j d|f�S )Nrm )r� )r$ r� r r r rm s zEventProxy.wait)rl r� r� rm )N)r* r, r- r� rl r� r� rm r r r r r � s r c @ sN e Zd ZdZddd�Zdd � Zd d � Zed d � �Zedd� �Z edd� �Z dS )� BarrierProxy�__getattribute__rm �abort�resetNc C s | j d|f�S )Nrm )r� )r$ r� r r r rm s zBarrierProxy.waitc C s | j d�S )Nr )r� )r$ r r r r s zBarrierProxy.abortc C s | j d�S )Nr )r� )r$ r r r r s zBarrierProxy.resetc C s | j dd�S )Nr �parties)r )r� )r$ r r r r s zBarrierProxy.partiesc C s | j dd�S )Nr � n_waiting)r )r� )r$ r r r r s zBarrierProxy.n_waitingc C s | j dd�S )Nr �broken)r )r� )r$ r r r r s zBarrierProxy.broken)r rm r r )N) r* r, r- r� rm r r r� r r r r r r r r s r c @ s( e Zd Zd Zdd� Zdd� Zdd � Zd S ) �NamespaceProxyr � __setattr__� __delattr__c C s0 |d dkrt j| |�S t j| d�}|d|f�S )Nr rG r� r )�objectr )r$ r� � callmethodr r r � __getattr__ s zNamespaceProxy.__getattr__c C s4 |d dkrt j| ||�S t j| d�}|d||f�S )Nr rG r� r )r r r )r$ r� r� r r r r r % s zNamespaceProxy.__setattr__c C s0 |d dkrt j| |�S t j| d�}|d|f�S )Nr rG r� r )r r r )r$ r� r r r r r * s zNamespaceProxy.__delattr__N)r r r )r* r, r- r� r r r r r r r r s r c @ s* e Zd ZdZdd� Zdd� Zeee�ZdS ) � ValueProxyr� r� c C s | j d�S )Nr� )r� )r$ r r r r� 3 s zValueProxy.getc C s | j d|f�S )Nr� )r� )r$ r� r r r r� 5 s zValueProxy.setN)r� r� )r* r, r- r� r� r� r� r� r r r r r 1 s r � BaseListProxy�__add__� __contains__� __delitem__� __getitem__�__len__�__mul__� __reversed__�__rmul__� __setitem__rC �count�extend�index�insertr� �remove�reverser� �__imul__c @ s e Zd Zdd� Zdd� ZdS )� ListProxyc C s | j d|f� | S )Nr+ )r� )r$ r� r r r �__iadd__A s zListProxy.__iadd__c C s | j d|f� | S )Nr0 )r� )r$ r� r r r r0 D s zListProxy.__imul__N)r* r, r- r2 r0 r r r r r1 @ s r1 � DictProxyr r� r� r� �has_key�popitem� setdefaultr� �Iterator� ArrayProxy� PoolProxy�apply� apply_asyncr} �imap�imap_unorderedr� �map� map_async�starmap� starmap_asyncr� Z AsyncResult)r; r? rA r< r= c @ s e Zd Zdd� Zdd� ZdS )r9 c C s | S )Nr )r$ r r r r� d s zPoolProxy.__enter__c C s | j � d S )N)r� )r$ r� r� r� r r r r� f s zPoolProxy.__exit__N)r* r, r- r� r� r r r r r9 c s c @ s e Zd ZdZdS )r a( 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. r r r r r m s �QueueZ JoinableQueuerd r^ �RLock� Semaphore�BoundedSemaphore� Condition�Barrier�Poolr �dictF)r� r� )r� )r r r )NNNT)T)r! r" r# r$ r% r& r' r( r) rC r* r+ r, r- r� r. r/ r� r0 )r" r# r$ r r% r) r� r� r� r4 r r r� r5 r6 r� r )r% r$ r) ) r: r; r} r< r= r� r> r? r@ rA r� )I�__all__rp r] r Zqueuer r� r � r �contextr r r r r r r r� Z view_typesr r Z view_typer r r9 r2 r{ r: rF rH rI r� ra rb Z XmlListenerZ XmlClientrX r r� r� r r� r� r� r� r r r r r r r r r r r1 r3 r� r8 Z BasePoolProxyr9 r rB rd r^ rC rD rE rF rG rH rI r r r r �<module> s� ; ] 4
Close
