📁
ＳＫＹＳＨＥＬＬ ＭＡＮＡＧＥＲ
PHP v8.2.30
Create
Create
Path:
root
/
home
/
qooetu
/
costes.qooetu.com
/
Name
Size
Perm
Actions
📁
.well-known
-
0755
🗑️
🏷️
🔒
📁
6b114
-
0755
🗑️
🏷️
🔒
📁
Modules
-
0755
🗑️
🏷️
🔒
📁
app
-
0755
🗑️
🏷️
🔒
📁
assets
-
0755
🗑️
🏷️
🔒
📁
bootstrap
-
0755
🗑️
🏷️
🔒
📁
cgi-bin
-
0755
🗑️
🏷️
🔒
📁
config
-
0755
🗑️
🏷️
🔒
📁
css
-
0755
🗑️
🏷️
🔒
📁
database
-
0755
🗑️
🏷️
🔒
📁
images
-
0755
🗑️
🏷️
🔒
📁
js
-
0755
🗑️
🏷️
🔒
📁
nbproject
-
0755
🗑️
🏷️
🔒
📁
public
-
0755
🗑️
🏷️
🔒
📁
resources
-
0755
🗑️
🏷️
🔒
📁
routes
-
0755
🗑️
🏷️
🔒
📁
storage
-
0755
🗑️
🏷️
🔒
📁
tests
-
0755
🗑️
🏷️
🔒
📁
uploads
-
0755
🗑️
🏷️
🔒
📁
vendor
-
0755
🗑️
🏷️
🔒
📁
wp-admin
-
0755
🗑️
🏷️
🔒
📁
wp-content
-
0755
🗑️
🏷️
🔒
📁
wp-includes
-
0755
🗑️
🏷️
🔒
📄
.htaccess
0.23 KB
0444
🗑️
🏷️
⬇️
✏️
🔒
📄
COOKIE.txt
0.2 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
X7ROOT.txt
0.27 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
defaults.php
1.29 KB
0444
🗑️
🏷️
⬇️
✏️
🔒
📄
engine.php
0 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
error_log
813.08 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
features.php
11.28 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
googlecfb82e09419fc0f6.html
0.05 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
index.php0
1.56 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
inputs.php
0.12 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
kurd.html
1.07 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
library.php
0 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
min.php
6.83 KB
0444
🗑️
🏷️
⬇️
✏️
🔒
📄
p.php
2.75 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
php.ini
0.04 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
product.php
1.78 KB
0444
🗑️
🏷️
⬇️
✏️
🔒
📄
qpmwztts.php
0.74 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
robots.txt
0.38 KB
0444
🗑️
🏷️
⬇️
✏️
🔒
📄
tovmbkwh.php
0.74 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
tyyffovi.php
0.74 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
📄
veoxv.html
1.23 KB
0644
🗑️
🏷️
⬇️
✏️
🔒
Edit: managers.cpython-37.opt-2.pyc
B YI~d� � @ s� d dddgZ ddlZddlZddlZddlZddlZddlmZ ddlm Z dd l m Z m Z m Z dd lmZ dd lmZ dd lmZ dd lmZ dd� Ze �eje� dd� dD �Zed ek r�dd� ZxeD ]Ze �ee� q�W G dd� de�Zdi fdd�Zdd� ZG dd � 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,ddd/d0�Z-G d1d2� d2e�Z.G d3d4� d4e�Z/ded5d6�Z0G d7d8� d8e*�Z1G d9d:� d:e*�Z2G d;d<� d<e2�Z3G d=d>� d>e*�Z4G d?d@� d@e*�Z5G dAdB� dBe*�Z6G dCdD� dDe*�Z7e,dEdF�Z8G dGdH� dHe8�Z9e,dIdJ�Z:dKdLie:_;e,dMdN�Z<e,dOdP�Z=dQdQdQdLdLdR�e=_;G dSdO� dOe=�Z>G dTd� de'�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 C s t j | j| �� ffS )N)�array�typecode�tobytes)�a� r �=/opt/alt/python37/lib64/python3.7/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 @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) r )�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+ � __module__� __qualname__� __slots__r& r' r) r, r r r r r 3 s r c C s8 | � ||||f� | �� \}}|dkr*|S t||��d S )Nz#RETURN)�send�recv�convert_to_error)�cr$ � methodname�args�kwds�kind�resultr r r �dispatchJ s r9 c C sd | dkr |S | dkrRt |t�s4td�|| t|����| dkrHtd| �S t|�S ntd�| ��S d S )Nz#ERROR)z #TRACEBACKz#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strz#UNSERIALIZABLEzUnserializable message: %s z Unrecognized message type {!r})� isinstance�str� TypeError�formatr � RemoteError� ValueError)r7 r8 r r r r2 T s r2 c @ s e Zd Zdd� ZdS )r> c C s dt | jd � d S )NzM --------------------------------------------------------------------------- r zK---------------------------------------------------------------------------)r; r5 )r% r r r �__str__d s zRemoteError.__str__N)r+ r- r. r@ r r r r r> c s r> c C s6 g }x,t | �D ] }t| |�}t|�r|�|� qW |S )N)�dirr �callable�append)r �tempr �funcr r r � all_methodsk s rF c C s dd� t | �D �S )Nc S s g | ]}|d dkr|�qS )r �_r )r r r r r r z s z"public_methods.<locals>.<listcomp>)rF )r r r r �public_methodsv s rH c @ s� e Zd Zddddddddd g Zd d � Zd d � Zdd� Zdd� Zdd� Zdd� Z dd� Z dd� Z e e e d�Z dd � Z d d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-S ).�Server�shutdown�create�accept_connection� get_methods� debug_info�number_of_objects�dummy�incref�decrefc C sx t |t�s td�|t|����|| _t�|�| _t | \}}||dd�| _ | j j | _ ddi| _ i | _ i | _t�� | _d S )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% rV r# rX � serializer�Listener�Clientr r r r& � s zServer.__init__c C s� t �� | _| t�� _zZt j| jd�}d|_|� � y x| j� � sN| j� d� q6W W n t t fk rj Y nX W d tjtjkr�t�d� tjt_tjt_t�d� X d S )N)�targetTr zresetting 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% rj r r r � serve_forever� s zServer.serve_foreverc C sP xJy| j �� }W n tk r& wY nX tj| j|fd�}d|_|�� qW d S )N)rd r5 T)rZ Zaccept�OSErrorr^ ri �handle_requestrk rl )r% r3 �tr r r rj � s zServer.accepterc C s4 d } }}y>t �|| j� t �|| 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|�| � W nr tk �r& } zRy|�dt� f� W n tk r� Y nX t � d| � t � d|� t � d| � W d d } ~ X Y nX |� � d S )Nz #TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r) r Zdeliver_challengerX Zanswer_challenger1 r � Exceptionr r0 r �info�close) r% r3 �funcnamer8 �request�ignorer5 r6 rE �msg�er r r rz � s2 zServer.handle_requestc C s� t �dt�� j� |j}|j}| j}�x�| j� � �s�yBd }}|� }|\}}} } y|| \}} } W n^ t k r� } z@y| j | \}} } W n& t k r� } z| �W d d }~X Y nX W d d } ~ X Y nX || kr�t d|t |�| f ��t||�}y|| | �}W n, tk �r& } z d|f}W d d }~X Y nPX | �o8| �|d �}|�rn| �|||�\}}t|| j|�}d||ff}nd|f}W n� t k �r� |d k�r�dt� f}nNy,| j| }|| |||f| �| �}d|f}W n tk �r� dt� f}Y nX Y nP tk �r" t �dt�� j� t�d� Y n tk �r@ dt� f}Y nX yDy ||� W n2 tk �r� } z|d t� f� W d d }~X Y nX W q( tk �r� } z@t �d t�� j� t �d |� t �d |� |�� t�d � W d d }~X Y q(X q(W d S )Nz$starting server thread to service %rz+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 rt r^ �current_threadr r1 r0 r[ rf rm �KeyErrorr] �AttributeErrorr r r| �getrK r r# r �fallback_mapping�EOFErrorrq rw r} r~ )r% �connr1 r0 r[ r4 r r� �identr5 r6 �exposed� gettypeid�keZ second_keZfunctionZresr� 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_repr2 s zServer.fallback_repr)r@ r, z #GETVALUEc C s d S )Nr )r% r3 r r r rP ; s z Server.dummyc C s| | j �l g }t| j�� �}|�� xD|D ]<}|dkr(|�d|| j| t| j| d �d d� f � q(W d�|�S Q R X d S )NrT z %s: refcount=%s %sr �K � ) r` r r\ r �sortrC r; r[ �join)r% r3 r8 r r� r r r rN > s $zServer.debug_infoc C s t | j�S )N)�lenr\ )r% r3 r r r rO N s zServer.number_of_objectsc C sL z:yt �d� |�d� W n dd l}|�� Y nX W d | j�� X d S )Nz!manager received shutdown message)z#RETURNNr )r rt r0 � traceback� print_excrf �set)r% r3 r� r r r rJ U s zServer.shutdownc O s� t | �dkr| ^}}}} nz| s(td��nld|krDtdt | �d ��|�d�}t | �dkrf| ^}}} n.d|kr�tdt | �d ��|�d�}| ^}} t| �} |j�� |j| \}}}}|d kr�|s�t | �dkr�td��| d } n || |�} |d kr�t| �}|d k �r4t|t ��s$td � |t |����t |�t |� }d t | � } t�d || � | t|�|f|j| < | |jk�rxd |j| < W d Q R X |�|| � | t|�fS ) N� z8descriptor 'create' of 'Server' object needs an argumentr" z7create expected at least 2 positional arguments, got %dr � r3 z4Without callable, must have one non-keyword argumentr z,Method_to_typeid {0!r}: type {1!s}, not dictz%xz&%r callable returned object with id %r)r� r< �pop�tupler` rV r? rH r: �dictr= r r r$ r rt r� r[ r\ rQ ) r5 r6 r% r3 r" rB r� �method_to_typeid� proxytyper r� r r r rK b sN z Server.createc C s t | j|j d �S )Nr )r� r[ r$ )r% r3 r� r r r rM � s zServer.get_methodsc C s" |t �� _|�d� | �|� d S )N)z#RETURNN)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� } zJ|| jkrrd| j|< | j| | j|< | j| \}}}t�d|� n|�W d d }~X Y nX W d Q R X d S )Nr z&Server re-enabled tracking & INCREF %r)r` r\ r� r] r[ r rt )r% r3 r� r� r r� r� r r r rQ � s z Server.increfc C s� || j kr$|| jkr$t�d|� d S | j�Z | j | dkrXtd�|| j| | j | ���| j | d8 < | j | dkr�| j |= W d Q R X || j kr�d| j|< t�d|� | j� | j|= W d Q R X d S )NzServer DECREF skipping %rr z+Id {0!s} ({1!r}) has refcount {2:n}, not 1+r )Nr Nzdisposing of obj with id %r)r\ r] r rt r` �AssertionErrorr= r[ )r% r3 r� r r r rR � s$ z Server.decrefN)r+ r- r. Zpublicr& rx rj rz r� r� r� r� r� rP rN rO rJ rK rM rL rQ rR r r r r rI � s, "Q 8rI c @ s e Zd ZdgZdZdZdZdS )�State�valuer r r� N)r+ r- r. r/ �INITIAL�STARTED�SHUTDOWNr r r r r� � s r� )�pickleZ xmlrpclibc @ s� e Zd Zi ZeZd!dd�Zdd� Zdd� Zd"d d �Z e d#d d ��Z dd� Z d$dd�Z dd� Zdd� Zdd� Zdd� Zedd� �Zed d � �Ze d%d d ��ZdS )&r Nr� c C s\ |d krt �� j}|| _t �|�| _t� | _tj| j_ || _ t | \| _ | _ |pTt� | _d S )N)r rg rX �_addressrW �_authkeyr� �_stater� r� � _serializerrY Z _Listener�_Clientr �_ctx)r% r# rX ra Zctxr r r r& � s zBaseManager.__init__c C sf | j jtjkrP| j jtjkr&td��n*| j jtjkr>td��ntd�| j j���t| j | j | j | j �S )NzAlready started serverzManager has shut downzUnknown state {!r}) r� r� r� r� r� r r� r= rI � _registryr� r� r� )r% r r r � get_server s zBaseManager.get_serverc C s8 t | j \}}|| j| jd�}t|d d� tj| j_d S )N)rX rP ) rY r� r� r� r9 r� r� r� r� )r% rb rc r� r r r �connect s zBaseManager.connectr c C s4 | j jtjkrP| j jtjkr&td��n*| j jtjkr>td��ntd�| j j���|d k rht|�sht d��t j dd�\}}| j j t| �j| j| j| j| j|||fd�| _d�d d � | jjD ��}t| �jd | | j_| j�� |�� |�� | _|�� tj| j _t j | t| �j | j| j| j| j | j fd d �| _ d S )NzAlready started serverzManager has shut downzUnknown state {!r}z initializer must be a callableF)Zduplex)rd r5 �:c s s | ]}t |�V qd S )N)r; )r �ir r r � <genexpr>1 s z$BaseManager.start.<locals>.<genexpr>�-r )r5 � exitpriority)!r� r� r� r� r� r r� r= rB r< r ZPiper� ZProcessr � _run_serverr� r� r� r� �_processr� Z _identityr+ r rl r~ r1 r �Finalize�_finalize_managerr� rJ )r% � initializer�initargs�reader�writerr� r r r rl s4 zBaseManager.startc C sN |d k r||� | � ||||�}|�|j� |�� t�d|j� |�� d S )Nzmanager serving at %r)�_Serverr0 r# r~ r r} rx ) �clsrV r# rX ra r� r� r� �serverr r r r� C s zBaseManager._run_serverc O s` | ^}}} t | �} |j|j|jd�}z t|d d|f| |�\}}W d |�� X t||j|�|fS )N)rX rK )r� r� r� r� r9 r~ r )r5 r6 r% r" r� r$ r� r r r �_createW s zBaseManager._createc C s* | j d k r&| j �|� | j �� s&d | _ d S )N)r� r� �is_alive)r% �timeoutr r r r� f s zBaseManager.joinc C s. | j | j| jd�}z t|d d�S |�� X d S )N)rX rN )r� r� r� r9 r~ )r% r� r r r � _debug_infoo s zBaseManager._debug_infoc C s. | j | j| jd�}z t|d d�S |�� X d S )N)rX rO )r� r� r� r9 r~ )r% r� r r r �_number_of_objectsy s z BaseManager._number_of_objectsc C sj | j jtjkr| �� | j jtjkrf| j jtjkr<td��n*| j jtjkrTtd��ntd�| j j���| S )NzUnable to start serverzManager has shut downzUnknown state {!r}) r� r� r� r� rl r� r r� r= )r% r r r � __enter__� s zBaseManager.__enter__c C s | � � d S )N)rJ )r% �exc_type�exc_val�exc_tbr r r �__exit__� s zBaseManager.__exit__c C s� | � � r�t�d� y,|||d�}zt|d d� W d |�� X W n tk rR Y nX | jdd� | � � r�t�d� t| d�r�t�d� | �� | jd d� | � � r�t�d � t j |_ y t j |= W n tk r� Y nX d S ) Nz#sending shutdown message to manager)rX rJ 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# rX r( r� r� r r r r� � s. z BaseManager._finalize_managerc C s | j S )N)r� )r% r r r r# � s zBaseManager.addressTc s� d| j kr| j�� | _� d kr"t� |p0t� dd �}|p@t� dd �}|r`xt|�� �D ]\}}qTW |||� f| j�< |r�� �fdd�} �| _t| �| � d S )Nr� � _exposed_�_method_to_typeid_c s` t �d�� | j�f|�|�\}}� || j| | j|d�}| j|j| jd�}t|d d|jf� |S )Nz)requesting creation of a shared %r object)�managerrX r� )rX rR ) r rt 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 �register� s zBaseManager.register)NNr� N)Nr )Nr )N)NNNNT)r+ r- r. r� rI r� r& r� r� rl � 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 �| dd� � d S )Nc S s | � � S )N)�clear)r r r r �<lambda>� � z*ProcessLocalSet.__init__.<locals>.<lambda>)r �register_after_fork)r% r r r r& � s zProcessLocalSet.__init__c C s t | �dfS )Nr )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 Zi Ze�� Zddd�Zdd� Zdi fd d �Z d d � Z d d� Z e dd� �Z dd� Zdd� Zdd� Zdd� Zdd� ZdS ) r NTFc C s� t j�8 t j�|jd �}|d kr:t�� t� f}|t j|j< W d Q R X |d | _|d | _ || _ | j j | _ || _ || _t| d | _|| _|d k r�t�|�| _n"| j d k r�| j j| _n t�� j| _|r�| �� t�| t j� d S )Nr r )r �_mutexr� r� r# r ZForkAwareLocalr� �_tls�_idset�_tokenr$ �_id�_managerr� rY r� �_owned_by_managerr rW r� rg rX �_increfr� � _after_fork) r% r� ra r� rX r� rQ � manager_ownedZ tls_idsetr r r r& � s* zBaseProxy.__init__c C sd t �d� t�� j}t�� jdkr4|dt�� j 7 }| j| jj | j d�}t |d d|f� || j _ d S )Nz making connection to managerZ MainThread�|)rX rL )r rt r rg r r^ r� r� r� r# r� r9 r� r )r% r r� r r r �_connect s zBaseProxy._connectr c C s� y | j j}W n6 tk rB t�dt�� j� | �� | j j}Y nX |� | j |||f� |� � \}}|dkrp|S |dkr�|\}}| j j |j d } | jj|_| || j| j | j|d�} | j|j| jd�}t|d d|jf� | S t||��d S )Nz#thread %r does not own a connectionz#RETURNz#PROXY���)r� rX r� )rX rR )r� r r� r rt 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 | � d�S )Nz #GETVALUE)r� )r% r r r � _getvalueD s zBaseProxy._getvaluec C s� | j rt�d| jj� d S | j| jj| jd�}t|d d| j f� t�d| jj� | j � | j � | j oj| j j }tj| tj| j| j|| j| j | jfdd�| _d S )Nz%owned_by_manager skipped INCREF of %r)rX rQ z INCREF %r� )r5 r� )r� r rt r� r$ r� r# r� r9 r� r� �addr� r� r� r �_decrefr� Z_close)r% r� r( r r r r� J s zBaseProxy._increfc C s� |� | j� |d ks |jtjkr�y2t�d| j� || j|d�}t|d d| jf� W q� t k r� } zt�d|� W d d }~X Y q�X nt�d| j� |s�t |d�r�t�dt � � j � |j�� |`d S )Nz DECREF %r)rX 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 rt r# r9 r| r� r^ r� r r r~ )r� rX r( ZtlsZidsetr� r� r� r r r r� ^ s zBaseProxy._decrefc C sH d | _ y | �� W n0 tk rB } zt�d| � W d d }~X Y nX d S )Nzincref failed: %s)r� r� r| r r} )r% r� r r r r� w 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 )NrX �_isautoFr� ) r r� r r� � RebuildProxyr� r� r� r )r% r6 r r r r� s zBaseProxy.__reduce__c C s | � � S )N)r� )r% Zmemor r r � __deepcopy__� 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, � s zBaseProxy.__repr__c C s4 y | � d�S tk r. t| �d d� d S X d S )Nr, r� z; '__str__()' failed>)r� r| r� )r% r r r r@ � s zBaseProxy.__str__)NNNTF)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 t�� dd �}|rT|j|jkrTt�d|� d|d< |j|jkrT|j|j |j|j< |� dd�opt t�� dd� }| ||fd|i|��S )Nrh z*Rebuild a proxy owned by manager, token=%rTr� rQ Z _inheritingF) r r rg r# r rt r$ r] r[ r� )rE r� ra r6 r� rQ r r r r� � s r� c C sr t |�}y || |f S tk r( Y nX i }x |D ]}td||f |� q4W t| tf|�}||_||| |f< |S )NzLdef %s(self, *args, **kwds): return self._callmethod(%r, args, kwds))r� r� �execr r r� )r r� �_cacheZdicZmeth� ProxyTyper r r � MakeProxyType� s r� Tc C s� t | d }|d krB|| j|d�}zt|d d| f�}W d |�� X |d krX|d k rX|j}|d krjt�� j}td| j |�}|| ||||d�} d| _ | S )Nr )rX rM z AutoProxy[%s])r� rX rQ T) rY r# r9 r~ r� r rg rX r� r" r� ) r� ra r� rX r� rQ r� r� r� r� r r r r� � s r� c @ s e Zd Zdd� Zdd� ZdS )� Namespacec K s | j �|� d S )N)r� �update)r% r6 r r r r& � s zNamespace.__init__c C s^ t | j�� �}g }x,|D ]$\}}|�d�s|�d||f � qW |�� d| jjd�|�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 � | |�S )N)r )r Zsequencer r r r �Array s r c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) � IteratorProxy)�__next__r0 �throwr~ c C s | S )Nr )r% r r r �__iter__ s zIteratorProxy.__iter__c G s | � d|�S )Nr )r� )r% r5 r r r r s zIteratorProxy.__next__c G s | � d|�S )Nr0 )r� )r% r5 r r r r0 s zIteratorProxy.sendc G s | � d|�S )Nr )r� )r% r5 r r r r s zIteratorProxy.throwc G s | � d|�S )Nr~ )r� )r% r5 r r r r~ s zIteratorProxy.closeN) r+ r- r. r� r r r0 r r~ r r r r r s r c @ s2 e Zd ZdZd dd�Zdd� Zdd � Zd d � ZdS ) � AcquirerProxy)�acquire�releaseTNc C s" |d kr|fn||f}| � d|�S )Nr )r� )r% Zblockingr� r5 r r r r s zAcquirerProxy.acquirec C s | � d�S )Nr )r� )r% r r r r s zAcquirerProxy.releasec C s | � d�S )Nr )r� )r% r r r r� s zAcquirerProxy.__enter__c C s | � d�S )Nr )r� )r% r� r� r� r r r r� s zAcquirerProxy.__exit__)TN)r+ r- r. r� r r r� r� r r r r r s r c @ s6 e Zd ZdZd dd�Zd dd�Zdd � Zdd d �ZdS )�ConditionProxy)r r rn �notify� notify_allNc C s | � d|f�S )Nrn )r� )r% r� r r r rn $ s zConditionProxy.waitr c C s | � d|f�S )Nr )r� )r% �nr r r r & s zConditionProxy.notifyc C s | � d�S )Nr )r� )r% r r r r ( s zConditionProxy.notify_allc C sh |� }|r|S |d k r$t �� | }nd }d }x6|sb|d k rP|t �� }|dkrPP | �|� |� }q.W |S )Nr )�timeZ monotonicrn )r% Z predicater� r8 ZendtimeZwaittimer r r �wait_for* s zConditionProxy.wait_for)N)r )N)r+ r- r. r� rn r r r r r r r r " s r c @ s2 e Zd ZdZdd� Zdd� Zdd� Zd d d �ZdS ) � EventProxy)rm r� r� rn c C s | � d�S )Nrm )r� )r% r r r rm ? s zEventProxy.is_setc C s | � d�S )Nr� )r� )r% r r r r� A s zEventProxy.setc C s | � d�S )Nr� )r� )r% r r r r� C s zEventProxy.clearNc C s | � d|f�S )Nrn )r� )r% r� r r r rn E s zEventProxy.wait)N)r+ r- r. r� rm r� r� rn r r r r r = s r c @ sN e Zd ZdZddd�Zdd� Zdd� Zed d � �Zed d � �Z ed d� �Z dS )� BarrierProxy)�__getattribute__rn �abort�resetNc C s | � d|f�S )Nrn )r� )r% r� r r r rn K s zBarrierProxy.waitc C s | � d�S )Nr )r� )r% r r r r M s zBarrierProxy.abortc C s | � d�S )Nr )r� )r% r r r r O s zBarrierProxy.resetc C s | � dd�S )Nr )�parties)r� )r% r r r r Q s zBarrierProxy.partiesc C s | � dd�S )Nr )� n_waiting)r� )r% r r r r T s zBarrierProxy.n_waitingc C s | � dd�S )Nr )�broken)r� )r% r r r r W s zBarrierProxy.broken)N) r+ r- r. r� rn r r r� r r r r r r r r I s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �NamespaceProxy)r � __setattr__� __delattr__c C s0 |d dkrt �| |�S t �| d�}|d|f�S )Nr rG r� r )�objectr )r% r� � callmethodr r r � __getattr__^ s zNamespaceProxy.__getattr__c C s4 |d dkrt �| ||�S t �| d�}|d||f�S )Nr rG r� r )r r r )r% r� r� r r r r r c s zNamespaceProxy.__setattr__c C s0 |d dkrt �| |�S t �| d�}|d|f�S )Nr rG r� r )r r r )r% r� r r r r r h s zNamespaceProxy.__delattr__N)r+ r- r. r� r! r r r r r r r \ s r c @ s* e Zd ZdZdd� Zdd� Zeee�ZdS )� ValueProxy)r� r� c C s | � d�S )Nr� )r� )r% r r r r� q s zValueProxy.getc C s | � d|f�S )Nr� )r� )r% r� r r r r� s s zValueProxy.setN)r+ r- r. r� r� r� r� r� r r r r r" o 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 | � d|f� | S )Nr. )r� )r% r� r r r �__iadd__ s zListProxy.__iadd__c C s | � d|f� | S )Nr3 )r� )r% r� r r r r3 � s zListProxy.__imul__N)r+ r- r. r5 r3 r r r r r4 ~ s r4 � DictProxy)r% r& r' r r( r, r� r� r� r r r� �popitem� setdefaultr r r �Iterator� ArrayProxy)r( r' r, � PoolProxy) Zapply� apply_asyncr~ �imap�imap_unorderedr� �map� map_async�starmap� starmap_asyncr� Z AsyncResult)r< r@ rB r= r> c @ s e Zd Zdd� Zdd� ZdS )r; c C s | S )Nr )r% r r r r� � s zPoolProxy.__enter__c C s | � � d S )N)r� )r% r� r� r� r r r r� � s zPoolProxy.__exit__N)r+ r- r. r� r� r r r r r; � s c @ s e Zd ZdS )r N)r+ r- r. r r r r r � s �QueueZ JoinableQueuere r_ �RLock� Semaphore�BoundedSemaphore� Condition�Barrier�Poolr r� F)r� r� )r� )NNNT)T)J�__all__rq r^ r Zqueuer r� r � r �contextr r r r r r r r r� Z view_typesr r! Z view_typer r r9 r2 r| r> rF rH rI r� rb rc Z XmlListenerZ XmlClientrY r r� r� r r� r� r� r� r r r r r r r r r" r# r4 r6 r� r: Z BasePoolProxyr; r rC re r_ rD rE rF rG rH rI r� r r r r �<module> s� \ w 4
Save