OwlCyberSecurity - MANAGER
Edit File: managers.cpython-36.opt-2.pyc
3 � \�������������������@���s���d�dddgZ�ddlZddlZddlZddlZddlZddlmZ�ddlm Z �dd l mZmZ�dd lm Z �ddlmZ�ddlmZ�dd lmZ�dd��Zejeje��dd��d�D��Zed�ek r�dd��ZxeD�]Zejee��q�W�G�dd��de�Zf�i�fdd�Zdd��ZG�dd��de�Zdd��Zd d!��ZG�d"d#��d#e�ZG�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���������������@���s0���e�Zd�Zd Zdd��Zdd��Zdd ��Zd d��ZdS�)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!���r"���r#���)r*���� __module__�__qualname__� __slots__r%���r&���r(���r+���r���r���r���r���r���3���s ���c�������������C���s8���|�j�||||f��|�j��\}}|dkr*|S�t||��d�S�)Nz#RETURN)�send�recv�convert_to_error)�cr#���� methodname�args�kwds�kind�resultr���r���r����dispatchJ���s ����r8���c�������������C���s<���|�dkr|S�|�dkrt�|�S�|�dkr0t�d|��S�td�S�d�S�)Nz#ERRORz #TRACEBACKz#UNSERIALIZABLEzUnserializable message: %s zUnrecognized message type)�RemoteError� ValueError)r6���r7���r���r���r���r1���T���s����r1���c���������������@���s���e�Zd�Zdd��ZdS�)r9���c�������������C���s&���ddd��d�t�|�jd���dd��S�)N� �-�K���r���)�strr4���)r$���r���r���r����__str__a���s����zRemoteError.__str__N)r*���r,���r-���r?���r���r���r���r���r9���`���s���r9���c�������������C���s6���g�}x,t�|��D�] }t|�|�}t|�r|j|��qW�|S�)N)�dirr����callable�append)r����tempr����funcr���r���r����all_methodsh���s���� rE���c�������������C���s���dd��t�|��D��S�)Nc�������������S���s���g�|�]}|d��dkr|�qS�)r����_r���)r���r���r���r���r���r���w���s����z"public_methods.<locals>.<listcomp>)rE���)r���r���r���r����public_methodss���s����rG���c������������ ���@���s����e�Zd�Zddddddddd g Zd d��Zdd ��Zdd��Zdd��Zdd��Zdd��Z dd��Z dd��Ze ee d�Zdd��Z dd��Zdd ��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���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$���rT���r"���rV���� serializer�Listener�Clientr���r���r���r%�������s���� zServer.__init__c�������������C���s����t�j��|�_|�tj��_zZt�j|�jd�}d|_|j ���y x|�jj ��sN|�jjd��q6W�W�n�tt fk rj���Y�nX�W�d�tjtjkr�tjd��tjt_tjt_tjd��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$���rh���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)rb���r4���T)rX���Zaccept�OSErrorr\���rg����handle_requestri���rj���)r$���r2����tr���r���r���rh�������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�d�d�} ~ X�nX�|j���d�S�)Nz #TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r)r���Zdeliver_challengerV���Zanswer_challenger0���r���� Exceptionr���r/���r ����info�close)r$���r2����funcnamer7����request�ignorer4���r5���rD����msg�er���r���r���rx�������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�d�d�}~X�nX�W�Y�d�d�} ~ X�nX�||kr�td|t |�|f���t||�}y|| | �}W�n,�tk �r&�}�zd|f}W�Y�d�d�}~X�nPX�|�o8|j|d��}|�rn|�j|||�\}}t||�j|�}d||ff}nd|f}W�n��tk �r����|d�k�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�d�d�}~X�nX�W�q(�tk �r��}�zBt�jd tj��j��t�jd|��t�jd|��|j���tjd ��W�Y�d�d�}~X�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#UNSERIALIZABLEzexception in thread serving %rz ... message was %rz ... exception was %rr���)r ���rr���r\����current_threadr���r0���r/���rY���rd���rk����KeyErrorr[����AttributeErrorr���r���rz����getrJ���r���r"���r����fallback_mapping�EOFErrorro���ru���r{���r|���)r$����connr0���r/���rY���r3���r���r~����identr4���r5����exposed� gettypeid�keZ second_keZfunction�resr����r����r!���ZridentZrexposed�tokenZ fallback_funcr7���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$���r2���r���r���r���rO���5��s����zServer.dummyc�������������C���s|���|�j��l�g�}t|�jj���}|j���xD|D�]<}|dkr(|jd||�j|�t|�j|�d��d�d��f���q(W�dj|�S�Q�R�X�d�S�)NrS���z %s: refcount=%s %sr���r=���r;���) r^���r���rZ���r����sortrB���r>���rY����join)r$���r2���r7���r���r����r���r���r���rM���8��s���� $zServer.debug_infoc�������������C���s ���t�|�j�S�)N)�lenrZ���)r$���r2���r���r���r���rN���G��s����zServer.number_of_objectsc�������������C���sL���z:yt�jd��|jd��W�n���dd�l}|j���Y�nX�W�d�|�jj���X�d�S�)Nz!manager received shutdown message�#RETURNr���)r����N)r ���rr���r/���� traceback� print_excrd����set)r$���r2���r����r���r���r���rI���N��s���� zServer.shutdownc�������������O���s����|�j����|�j|�\}}}}|d�kr,|d�} n |||�} |d�krFt| �}|d�k r^t|�t|��}dt| ��} tjd|| ��| t|�|f|�j| <�| |�j kr�d|�j | <�W�d�Q�R�X�|�j || ��| t|�fS�)Nr���z%xz&%r callable returned object with id %r)r^���rT���rG���r���r#���r ���rr���r����rY���rZ���rP����tuple)r$���r2���r!���r4���r5���rA���r�����method_to_typeid� proxytyper���r����r���r���r���rJ���[��s ���� z Server.createc�������������C���s���t�|�j|j�d��S�)Nr���)r����rY���r#���)r$���r2���r����r���r���r���rL���z��s����zServer.get_methodsc�������������C���s"���|t�j��_|jd��|�j|��d�S�)N�#RETURN)r����N)r\���r����r���r/���r����)r$���r2���r���r���r���r���rK������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^���rZ���r����r[���rY���r ���rr���)r$���r2���r����r����r���r����r����r���r���r���rP������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)rZ���r[���r ���rr���r^���rY���)r$���r2���r����r���r���r���rQ������s���� z Server.decrefN)r*���r,���r-���Zpublicr%���rv���rh���rx���r����r����r����r����r����rO���rM���rN���rI���rJ���rL���rK���rP���rQ���r���r���r���r���rH���}���s,��� "Q rH���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�Zi�ZeZd dd�Zdd��Zdd��Zdf�fd d �Z e df�fdd��Zd d��Zd!dd�Z dd��Zdd��Zdd��Zdd��Zedd���Zedd���Ze d"dd��ZdS�)#r���Nr����c�������������C���s\���|d�krt�j��j}||�_t�j|�|�_t��|�_tj|�j_ ||�_ t|�\|�_|�_ |pTt��|�_d�S�)N)r���re���rV����_addressrU����_authkeyr�����_stater����r�����_serializerrW���Z _Listener�_Clientr����_ctx)r$���r"���rV���r_���Zctxr���r���r���r%������s���� zBaseManager.__init__c�������������C���s���t�|�j|�j|�j|�j�S�)N)rH���� _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)rV���rO���) rW���r����r����r����r8���r����r����r����r����)r$���r`���ra���r����r���r���r����connect���s����zBaseManager.connectc���������� ���C���s����|d�k rt�|��rtd��tjdd�\}}|�jjt|��j|�j|�j |�j |�j|||fd�|�_dj dd��|�jjD���}t|��jd�|�|�j_|�jj���|j���|j��|�_ |j���tj|�j_tj|�t|��j|�j|�j |�j |�j|�jfd d �|�_d�S�)Nzinitializer must be a callableF)Zduplex)rb���r4����:c�������������s���s���|�]}t�|�V��qd�S�)N)r>���)r����ir���r���r���� <genexpr>���s����z$BaseManager.start.<locals>.<genexpr>r<���r���)r4����exitpriority)rA���� TypeErrorr���ZPiper����ZProcessr����_run_serverr����r����r����r�����_processr����Z _identityr*���r���rj���r|���r0���r����r����r����r����r ����Finalize�_finalize_managerr����rI���)r$����initializer�initargs�reader�writerr����r���r���r���rj������s&���� zBaseManager.startc������� ������C���sN���|d�k r||���|�j�||||�}|j|j��|j���tjd|j��|j���d�S�)Nzmanager serving at %r)�_Serverr/���r"���r|���r ���r{���rv���) �clsrT���r"���rV���r_���r����r����r�����serverr���r���r���r������s����zBaseManager._run_serverc�������������O���sN���|�j�|�j|�jd�}zt|d�d|f|�|�\}}W�d�|j���X�t||�j|�|fS�)N)rV���rJ���)r����r����r����r8���r|���r���)r$���r!���r4���r5���r����r#���r����r���r���r����_create%��s ���� zBaseManager._createc�������������C���s*���|�j�d�k r&|�j�j|��|�j�j��s&d�|�_�d�S�)N)r����r�����is_alive)r$����timeoutr���r���r���r����1��s���� zBaseManager.joinc���������� ���C���s.���|�j�|�j|�jd�}zt|d�d�S�|j���X�d�S�)N)rV���rM���)r����r����r����r8���r|���)r$���r����r���r���r����_debug_info:��s����zBaseManager._debug_infoc���������� ���C���s.���|�j�|�j|�jd�}zt|d�d�S�|j���X�d�S�)N)rV���rN���)r����r����r����r8���r|���)r$���r����r���r���r����_number_of_objectsD��s����zBaseManager._number_of_objectsc�������������C���s���|�j�jtjkr|�j���|�S�)N)r����r����r����r����rj���)r$���r���r���r���� __enter__N��s����zBaseManager.__enter__c�������������C���s���|�j����d�S�)N)rI���)r$����exc_type�exc_val�exc_tbr���r���r����__exit__T��s����zBaseManager.__exit__c�������������C���s����|�j���r�tjd��y,|||d�}zt|d�d��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 |_ytj |=�W�n�tk r����Y�nX�d�S�)Nz#sending shutdown message to manager)rV���rI���g�������?)r����zmanager still alive� terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r����r ���r{���r8���r|���rz���r�����hasattrr����r����r����r����r����_address_to_localr����)r���r"���rV���r'���r����r����r���r���r���r����W��s.���� zBaseManager._finalize_managerc�������������C���s���|�j�S�)N)r����)r$���r���r���r����<lambda>w��s����zBaseManager.<lambda>Tc������� ���������s����d|�j�kr|�jj��|�_��d�kr"t��|p0t��dd��}|p@t��dd��}|r`xt|j���D�]\}}qTW�|||��f|�j�<�|r����fdd�} �| _t|��| ��d�S�)Nr����� _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)�managerrV���r����)rV���rQ���) r ���rr���r����r����r����r����r"���r8���r#���)r$���r4���r5���r����Zexp�proxyr����)r����r!���r���r���rC������s����z"BaseManager.register.<locals>.temp) �__dict__r�����copy� AutoProxyr���r���r���r*����setattr) r����r!���rA���r����r����r����� create_method�keyr����rC���r���)r����r!���r����registery��s���� zBaseManager.register)NNr����N)N)NNNNT)r*���r,���r-���r����rH���r����r%���r����r����rj����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�Zi�Zej��Zddd�Zdd��Zf�i�fdd �Z d d��Z dd ��Zedd���Z dd��Zdd��Zdd��Zdd��Zdd��ZdS�)r���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|�_ntj��j|�_|r�|�j���tj|�t�j��d�S�)Nr���r���)r����_mutexr����r����r"���r ���ZForkAwareLocalr�����_tls�_idset�_tokenr#����_id�_managerr����rW���r�����_owned_by_managerr���rU���r����re���rV����_increfr�����_after_fork) r$���r����r_���r����rV���r����rP���� 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�)Nzmaking connection to managerZ MainThread�|)rV���rK���)r ���rr���r���re���r���r\���r����r����r����r"���r����r8���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�|\}}|�jj |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#PROXYr���)r����rV���r����)rV���rQ������)r����r���r����r ���rr���r\���r����r���r����r/���r����r0���r����r����r!���r����r"���r����r����r����r8���r#���r1���)r$���r3���r4���r5���r����r6���r7���r����r����r����r����r���r���r����_callmethod���s,���� zBaseProxy._callmethodc�������������C���s ���|�j�d�S�)Nz #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 ��|�joj|�jj }tj|�tj|�j|�j||�j|�j |�jfdd�|�_d�S�)Nz%owned_by_manager skipped INCREF of %r)rV���rP���z INCREF %r� ���)r4���r����)r����r ���rr���r����r#���r����r"���r����r8���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�tjdtj��j ��|jj���|`d�S�)Nz DECREF %r)rV���rQ���z... decref failed %sz%DECREF %r -- manager already shutdownr���z-thread %r has no more proxies so closing conn)�discardr#���r����r����r����r ���rr���r"���r8���rz���r����r\���r����r���r���r|���)r����rV���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����rz���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�)NrV����_isautoFr����) r ���r����r���r�����RebuildProxyr����r����r����r���)r$���r5���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|��d�d��d�S�X�d�S�)Nr+���r���z; '__str__()' failed>r����)r����rz���r����)r$���r���r���r���r?���U��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�tj��dd��}|rT|j|jkrTtjd|��d|d<�|j|jkrT|j|j�|j|j<�|j dd�opt�tj��dd��}|�||fd|i|��S�)Nrf���z*Rebuild a proxy owned by manager, token=%rTr����rP���Z_inheritingF) r���r���re���r"���r ���rr���r#���r[���rY����pop)rD���r����r_���r5���r����rP���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�)NzLdef %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�}|d�krB||�j|d�}zt|d�d|�f�}W�d�|j���X�|d�krX|d�k rX|j}|d�krjtj��j}td|�j �|�}||�||||d�} d| _ | S�)Nr���)rV���rL���z AutoProxy[%s])r����rV���rP���T)rW���r"���r8���r|���r����r���re���rV���r����r!���r����) r����r_���r����rV���r����rP���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$���r5���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�)NrF���z%s=%rz%s(%s)z, ) r���r����r���� startswithrB���r����r)���r*���r����)r$���r���rC���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�Zddd�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 ��Zdd��Zd d��ZdS�)� IteratorProxy�__next__r/����throwr|���c�������������C���s���|�S�)Nr���)r$���r���r���r����__iter__���s����zIteratorProxy.__iter__c�������������G���s���|�j�d|�S�)Nr��)r����)r$���r4���r���r���r���r�����s����zIteratorProxy.__next__c�������������G���s���|�j�d|�S�)Nr/���)r����)r$���r4���r���r���r���r/������s����zIteratorProxy.sendc�������������G���s���|�j�d|�S�)Nr��)r����)r$���r4���r���r���r���r�����s����zIteratorProxy.throwc�������������G���s���|�j�d|�S�)Nr|���)r����)r$���r4���r���r���r���r|������s����zIteratorProxy.closeN)r��r/���r��r|���) r*���r,���r-���r����r��r��r/���r��r|���r���r���r���r���r�����s���r��c���������������@���s2���e�Zd�Zd Zddd�Zdd��Zd d ��Zdd��ZdS�)� AcquirerProxy�acquire�releaseTNc�������������C���s"���|d�kr|fn||f}|�j�d|�S�)Nr ��)r����)r$���Zblockingr����r4���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 ��Zdd��Zdd d�ZdS�)�ConditionProxyr ��r ��rl����notify� notify_allNc�������������C���s���|�j�d|f�S�)Nrl���)r����)r$���r����r���r���r���rl������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 monotonicrl���)r$���Z predicater����r7���ZendtimeZwaittimer���r���r����wait_for���s���� zConditionProxy.wait_for)r ��r ��rl���r��r ��)N)N)r*���r,���r-���r����rl���r��r ��r��r���r���r���r���r�����s ��� r��c���������������@���s2���e�Zd�ZdZdd��Zdd��Zd d ��Zddd �ZdS�)� EventProxyrk���r����r����rl���c�������������C���s ���|�j�d�S�)Nrk���)r����)r$���r���r���r���rk�����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�)Nrl���)r����)r$���r����r���r���r���rl�����s����zEventProxy.wait)rk���r����r����rl���)N)r*���r,���r-���r����rk���r����r����rl���r���r���r���r���r�����s ���r��c���������������@���sN���e�Zd�ZdZddd�Zdd ��Zd d��Zedd ���Zedd���Z edd���Z dS�)�BarrierProxy�__getattribute__rl����abort�resetNc�������������C���s���|�j�d|f�S�)Nrl���)r����)r$���r����r���r���r���rl��� ��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��rl���r��r��)N)r*���r,���r-���r����rl���r��r��r����r��r��r��r���r���r���r���r����s��� r��c���������������@���s(���e�Zd�ZdZdd��Zdd��Zdd ��Zd S�)�NamespaceProxyr���__setattr__�__delattr__c�������������C���s0���|d�dkrt�j|�|�S�t�j|�d�}|d|f�S�)Nr���rF���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���rF���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���rF���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__rB����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�)Nr/��)r����)r$���r����r���r���r���r/��D��s����zListProxy.__imul__N)r*���r,���r-���r1��r/��r���r���r���r���r0��@��s���r0��� 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:��r>��r@��r;��r<��c���������������@���s���e�Zd�Zdd��Zdd��ZdS�)r8��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���r8��c��s���c���������������@���s���e�Zd�ZdS�)r���N)r*���r,���r-���r���r���r���r���r���m��s��� �QueueZ JoinableQueuerc���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(��rB���r)��r*��r+��r,��r����r-��r.��r����r/��)r!��r"��r#��r��r$��r(��r����r����r����r3��r���r���r����r4��r5��r����r���)r$��r#��r(��)r9��r:��r|���r;��r<��r����r=��r>��r?��r@��r����)I�__all__ro���r\���r���Zqueuer��r����r�����r����contextr ���r ���r���r���r ���r���r���r����Z view_typesr���r ���Z view_typer��r���r8���r1���rz���r9���rE���rG���rH���r����r`���ra���ZXmlListenerZ XmlClientrW���r���r����r����r���r����r����r����r����r����r��r��r��r��r��r��r��r��r��r0��r2��r����r7��Z BasePoolProxyr8��r���rA��rc���r]���rB��rC��rD��rE��rF��rG��rH��r���r���r���r����<module>���s���� ��; �] �4� ��� �� �