OwlCyberSecurity - MANAGER
Edit File: managers.cpython-310.opt-2.pyc
o ����S�g������������������������@���sP��g�d��Z�ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z �ddl mZ�ddlm Z �ddlmZmZmZ�ddlmZ�dd lmZ�dd lmZ�ddlmZ�zddlmZ�W�n�eyk���d ZY�nw�dZe��d��dd��Ze�eje��dd��dD��Zed�eur�dd��ZeD�]Ze�ee��q�G�dd��de �Z!di�fdd�Z"dd��Z#G�dd��de$�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,e0�Z1G�d-d.��d.e �Z2d/d0��Z3i�fd1d2�Z4 dmd3d4�Z5G�d5d6��d6e �Z6G�d7d8��d8e �Z7dnd9d:�Z8G�d;d<��d<e2�Z9G�d=d>��d>e2�Z:G�d?d@��d@e:�Z;G�dAdB��dBe2�Z<G�dCdD��dDe2�Z=G�dEdF��dFe2�Z>G�dGdH��dHe2�Z?e4dIdJ�Z@G�dKdL��dLe@�ZAe4dMdN�ZBdOdPieB_Ce4dQdR�ZDe4dSdT�ZEdUdUdUdPdPdV�eE_CG�dWdS��dSeE�ZFG�dXdY��dYe/�ZGeG�dZejH��eG�d[ejH��eG�d\ejIe<��eG�d]ejJe:��eG�d^ejKe:��eG�d_ejLe:��eG�d`ejMe:��eG�daejNe;��eG�dbejOe=��eG�dcejPeF��eG�ddeeA��eG�deeQeB��eG�d8e7e?��eG�d:e8eD��eG�d6e6e>��eGjdPe9d df��eGjdUd dg��e�r&G�dhdi��di�ZRG�djdk��dke(�ZSG�dld��de/�ZTdS�dS�)o)�BaseManager�SyncManager� BaseProxy�Token�����N)�getpid)� format_exc����)� connection)� reduction�get_spawning_popen�ProcessError)�pool)�process)�util)�get_context)� shared_memoryFT�SharedMemoryManagerc�����������������C���s���t�j�|�j|����ffS��N)�array�typecode�tobytes)�a��r����?/opt/alt/python310/lib64/python3.10/multiprocessing/managers.py�reduce_array/�������r���c�����������������C���s���g�|�] }t�ti�|�����qS�r���)�type�getattr��.0�namer���r���r���� <listcomp>3��������r!���)�items�keys�valuesc�����������������C���s���t�t�|��ffS�r���)�list��objr���r���r����rebuild_as_list5�������r)���c�������������������@���s2���e�Zd�Z �dZdd��Zdd��Zdd��Zdd ��Zd S�)r�����typeid�address�idc�����������������C���s���||||�_�|�_|�_d�S�r���r+���)�selfr,���r-���r.���r���r���r����__init__D���s���zToken.__init__c�����������������C���s���|�j�|�j|�jfS�r���r+����r/���r���r���r����__getstate__G�������zToken.__getstate__c�����������������C���s���|\|�_�|�_|�_d�S�r���r+����r/����stater���r���r����__setstate__J���r���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.���r1���r���r���r����__repr__M���s����zToken.__repr__N)r8���� __module__�__qualname__� __slots__r0���r2���r6���r9���r���r���r���r���r���>���s����r���r���c�����������������C���s6��� �|���||||f��|����\}}|dkr|S�t||��)N�#RETURN)�send�recv�convert_to_error)�cr.���� methodname�args�kwds�kind�resultr���r���r����dispatchU���s��� rG���c�����������������C���s^���|�dkr|S�|�dv�r(t�|t�std�||�t|����|�dkr$td|��S�t|�S�td�|���S�)N�#ERROR)� #TRACEBACK�#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strrJ���zUnserializable message: %s zUnrecognized message type {!r})� isinstance�str� TypeError�formatr����RemoteError� ValueError)rE���rF���r���r���r���r@���_���s��� ��r@���c�������������������@���s���e�Zd�Zdd��ZdS�)rO���c�����������������C���s���dt�|�jd���d�S�)NzM --------------------------------------------------------------------------- r���zK---------------------------------------------------------------------------)rL���rC���r1���r���r���r����__str__o���s���zRemoteError.__str__N)r8���r:���r;���rQ���r���r���r���r���rO���n���s����rO���c�����������������C���s4��� �g�}t�|��D�]}t|�|�}t|�r|�|��q|S�r���)�dirr����callable�append)r(����tempr ����funcr���r���r����all_methodsv���s��� �rW���c�����������������C���s��� �dd��t�|��D��S�)Nc�����������������S���s���g�|�] }|d��dkr|�qS�)r����_r���r���r���r���r���r!�������r"���z"public_methods.<locals>.<listcomp>)rW���r'���r���r���r����public_methods����s���rY���c�������������������@���s����e�Zd�Z �g�d�Zdd��Zdd��Zdd��Zdd ��Zd d��Zdd ��Z dd��Z dd��Zdd��Zeee d�Z dd��Zdd��Zdd��Zdd��Zdd��Zdd ��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�std�|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���)rK����bytesrM���rN���r����registryr����AuthenticationString�authkey�listener_client�listenerr-���� id_to_obj�id_to_refcount�id_to_local_proxy_obj� threading�Lock�mutex)r/���rh���r-���rj���� serializer�Listener�Clientr���r���r���r0�������s��� �� zServer.__init__c�������������� ���C���s���� �t����|�_|�t���_zGt�j|�jd�}d|_|� ���z|�j� ��s+|�j�d��|�j� ��r W�n�tt fy7���Y�nw�W�tjtjkrLt�d��tjt_tjt_t�d��d�S�tjtjkrft�d��tjt_tjt_t�d��w�)N)�targetTr���zresetting stdout, stderrr���)rp����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/���r|���r���r���r���� serve_forever����s4��� ���� � zServer.serve_foreverc�����������������C���sF��� �z|�j����}W�n �ty���Y�q�w�tj|�j|fd�}d|_|����q)NT�rv���rC���)rl���Zaccept�OSErrorrp���r{����handle_requestr}���r~���)r/���rA����tr���r���r���r|�������s�����zServer.accepterc�����������������C���s$��d�}zt��||�j��t��||�j��|���}|\}}}}t|�|�}W�n�ty/���dt��f}Y�n!w�z ||g|�R�i�|��} W�n�tyK���dt��f}Y�nw�d| f}z|�|��W�d�S��ty��} �z-z |�dt��f��W�n �tys���Y�nw�t � d|��t � d|��t � d| ��W�Y�d�} ~ d�S�d�} ~ ww�)NrI���r=���zFailure to send message: %rz ... request was %r� ... exception was %r)r ���Zdeliver_challengerj���Zanswer_challenger?���r���� Exceptionr���r>���r����info)r/���rA����request�ignore�funcnamerC���rD���rV����msgrF����er���r���r����_handle_request����s:��������zServer._handle_requestc�����������������C���sL��� �zz|���|��W�n �ty���Y�nw�W�|����d�S�W�|����d�S�|����w�r���)r����r�����close�r/����connr���r���r���r��������s������zServer.handle_requestc�����������������C���s��� �t��dt���j��|j}|j}|�j}|�j� ���sez�d��}}|��}|\}}} } z ||�\}}}W�n&�t yV�} �zz |�j|�\}}}W�n �t yK���| �w�W�Y�d�} ~ nd�} ~ ww�||vrftd|t |�|f���t||�}z || i�| ��}W�n�ty��}�z d|f}W�Y�d�}~n*d�}~ww�|o�|�|d��}|r�|��|||�\}}t||�j|�}d||ff}nd|f}W�n`�ty����|d�u�r�dt��f}n(z|�j|�}||�|||g| �R�i�| ��}d|f}W�n�ty����dt��f}Y�nw�Y�n&�t�y���t��dt���j��t�d��Y�n�t�y���dt��f}Y�nw�zz||��W�n�t�y*���|d t��f��Y�nw�W�n1�t�y]�}�z$t��d t���j��t��d|��t��d|��|����t�d ��W�Y�d�}~nd�}~ww�|�j� ��rd�S�d�S�)Nz$starting server thread to service %rz+method %r of %r object is not in exposed=%rrH����#PROXYr=���rI���z$got EOF -- exiting thread serving %rr���rJ���zexception in thread serving %rz ... message was %rr����r���)r���r����rp����current_threadr ���r?���r>���rm���rx���r����KeyErrorro����AttributeErrorr���r���r�����getr\���r���r-���r����fallback_mapping�EOFErrorr����r����r����r����)r/���r����r?���r>���rm���rB���r(���r�����identrC���rD����exposed� gettypeid�keZfunction�resr����r����r,���ZridentZrexposed�tokenZ fallback_funcrF���r���r���r����serve_client����s������������ ��� �������������zServer.serve_clientc�����������������C���s���|S�r���r����r/���r����r����r(���r���r���r����fallback_getvalue?������zServer.fallback_getvaluec�����������������C�������t�|�S�r����rL���r����r���r���r����fallback_strB������zServer.fallback_strc�����������������C���r����r���)�reprr����r���r���r���� fallback_reprE��r����zServer.fallback_repr)rQ���r9���� #GETVALUEc�����������������C���s���d�S�r���r����r/���rA���r���r���r���ra���N��r����zServer.dummyc�������������� ���C���s���� �|�j��;�g�}t|�j����}|����|D�]}|dkr2|�d||�j|�t|�j|�d��d�d��f���qd�|�W��d�����S�1�sBw���Y��d�S�)Nre���z %s: refcount=%s %sr����K���� ) rr���r&���rn���r$����sortrT���rL���rm����join)r/���rA���rF���r$���r����r���r���r���r_���Q��s��� ���$�zServer.debug_infoc�����������������C���s��� �t�|�j�S�r���)�lenrn���r����r���r���r���r`���a��s��� zServer.number_of_objectsc�����������������C���sb��� �z)zt��d��|�d��W�n���dd�l}|����Y�W�|�j����d�S�W�|�j����d�S�|�j����w�)Nz!manager received shutdown message�r=���Nr���)r���r����r>���� traceback� print_excrx����set)r/���rA���r����r���r���r���r[���h��s��� �zServer.shutdownc����������������O���s�� �|�j��q�|�j|�\}}}}|d�u�r#|st|�dkrtd��|d�} n||i�|��} |d�u�r2t| �}|d�urMt|t�sEtd�|t |����t |�t |��}dt| ��} t� d|| ��| t|�|f|�j| <�| |�jvrnd|�j| <�W�d�����n1�sxw���Y��|��|| ��| t|�fS�)Nr���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)rr���rh���r����rP���rY���rK����dictrM���rN���r���r&���r.���r���r����r����rm���rn���rb����tuple)r/���rA���r,���rC���rD���rS���r�����method_to_typeid� proxytyper(���r����r���r���r���r\���u��s<��� �� �� ��z Server.createc�����������������C���s��� �t�|�j|j�d��S�)Nr���)r����rm���r.���)r/���rA���r����r���r���r���r^������s���zServer.get_methodsc�����������������C���s$��� �|t����_|�d��|��|��d�S�)Nr����)rp���r����r ���r>���r����)r/���rA���r ���r���r���r���r]������s��� zServer.accept_connectionc�����������������C���s����|�j��R�z|�j|��d7��<�W�n5�tyD�}�z)||�jv�r8d|�j|<�|�j|�|�j|<�|�j|�\}}}t�d|��n|�W�Y�d�}~n d�}~ww�W�d�����d�S�W�d�����d�S�1�sXw���Y��d�S�)Nr���z&Server re-enabled tracking & INCREF %r)rr���rn���r����ro���rm���r���r����)r/���rA���r����r����r(���r����r����r���r���r���rb������s$��� ������ "�z Server.increfc�����������������C���s����||�j�vr||�jv�rt�d|��d�S�|�j�2�|�j�|�dkr,td�||�j|�|�j�|����|�j�|��d8��<�|�j�|�dkr@|�j�|=�W�d�����n1�sJw���Y��||�j�vryd|�j|<�t�d|��|�j� �|�j|=�W�d�����d�S�1�srw���Y��d�S�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)rn���ro���r���r����rr����AssertionErrorrN���rm���)r/���rA���r����r���r���r���rc������s0��� ���� "��z Server.decrefN)r8���r:���r;����publicr0���r����r|���r����r����r����r����r����r����r����ra���r_���r`���r[���r\���r^���r]���rb���rc���r���r���r���r���rZ�������s2���� Q� $rZ���c�������������������@���s���e�Zd�ZdgZdZdZdZdS�)�State�valuer���r�������N)r8���r:���r;���r<����INITIAL�STARTED�SHUTDOWNr���r���r���r���r�������s ����r����)�pickleZ xmlrpclibc�������������������@���s����e�Zd�Z �i�ZeZ d!dd�Zdd��Zdd��Zd"d d�Z e d"dd ��Zdd��Zd#dd�Z dd��Zdd��Zdd��Zdd��Zedd���Zedd���Ze d$dd ��ZdS�)%r���Nr����c�����������������C���s\���|d�u�r t����j}||�_t��|�|�_t��|�_tj|�j_ ||�_ t|�\|�_|�_ |p*t��|�_d�S�r���)r���ry���rj����_addressri����_authkeyr�����_stater����r�����_serializerrk���Z _Listener�_Clientr����_ctx)r/���r-���rj���rs����ctxr���r���r���r0������s��� zBaseManager.__init__c�����������������C���sd��� �|�j�jtjkr'|�j�jtjkrtd��|�j�jtjkrtd��td�|�j�j���t|�j |�j |�j|�j�S�)N�Already started server�Manager has shut down�Unknown state {!r}) r����r����r����r����r����r���r����rN���rZ���� _registryr����r����r����r1���r���r���r���� get_server���s���� �zBaseManager.get_serverc�����������������C���s:��� �t�|�j�\}}||�j|�jd�}t|d�d��tj|�j_d�S�)N�rj���ra���) rk���r����r����r����rG���r����r����r����r����)r/���rt���ru���r����r���r���r����connect��s ���zBaseManager.connectr���c�������������� ���C���s2�� �|�j�jtjkr'|�j�jtjkrtd��|�j�jtjkrtd��td�|�j�j���|d�ur3t|�s3t d��t jdd�\}}|�jj t|��j|�j|�j|�j|�j|||fd�|�_d�d d ��|�jjD���}t|��jd�|�|�j_|�j����|����|���|�_|����tj|�j�_tj|�t|��j|�j|�j|�j|�j�|�jfdd �|�_ d�S�)Nr����r����r����zinitializer must be a callableF)Zduplexr�����:c�����������������s���s�����|�]}t�|�V��qd�S�r���r����)r����ir���r���r���� <genexpr>0��s�����z$BaseManager.start.<locals>.<genexpr>�-r����rC���Zexitpriority)!r����r����r����r����r����r���r����rN���rS���rM���r ���ZPiper����ZProcessr����_run_serverr����r����r����r�����_processr����Z _identityr8���r ���r~���r����r?���r����Finalize�_finalize_managerr����r[���)r/����initializer�initargs�reader�writerr����r���r���r���r~�����s@���� �� ��zBaseManager.startc����������� ������C���s`��� �t���t�jt�j��|d�ur||���|��||||�}|�|j��|����t�d|j��|� ���d�S�)Nzmanager serving at %r) �signal�SIGINT�SIG_IGN�_Serverr>���r-���r����r���r����r����) �clsrh���r-���rj���rs���r����r����r�����serverr���r���r���r����B��s���zBaseManager._run_serverc����������������O���sX��� �|�j�|�j|�jd�}zt|d�d|f|�|�\}}W�|����n|����w�t||�j|�|fS�)Nr����r\���)r����r����r����rG���r����r���)r/���r,���rC���rD���r����r.���r����r���r���r����_createY��s���zBaseManager._createc�����������������C���s4��� �|�j�d�ur|�j��|��|�j����sd�|�_�d�S�d�S�d�S�r���)r����r�����is_alive�r/����timeoutr���r���r���r����e��s��� �zBaseManager.joinc�����������������C����6��� �|�j�|�j|�jd�}zt|d�d�W�|����S�|����w�)Nr����r_����r����r����r����rG���r����r����r���r���r����_debug_infon��� ���zBaseManager._debug_infoc�����������������C���r����)Nr����r`���r����r����r���r���r����_number_of_objectsx��r����zBaseManager._number_of_objectsc�����������������C���sf���|�j�jtjkr|�����|�j�jtjkr1|�j�jtjkrtd��|�j�jtjkr(td��td�|�j�j���|�S�)NzUnable to start serverr����r����) r����r����r����r����r~���r����r���r����rN���r1���r���r���r���� __enter__���s����zBaseManager.__enter__c�����������������C�������|������d�S�r���)r[����r/����exc_typeZexc_valZexc_tbr���r���r����__exit__�������zBaseManager.__exit__c�����������������C���s���� �|�����rZt�d��z|||d�}zt|d�d��W�|����n|����w�W�n �ty-���Y�nw�|�jdd��|�����rZt�d��t|�d�rZt�d��|�����|�jdd��|�����rZt�d ��t j |_ztj |=�W�d�S��tyo���Y�d�S�w�) Nz#sending shutdown message to managerr����r[���g�������?)r����zmanager still alive� terminatez'trying to `terminate()` manager processz#manager still alive after terminate)r����r���r����rG���r����r����r�����hasattrr����r����r����r����r����_address_to_localr����)r���r-���rj���r5���r����r����r���r���r���r�������s4��� � �zBaseManager._finalize_managerc�����������������C�������|�j�S�r���)r����r1���r���r���r���r-������s���zBaseManager.addressTc����������� ���������s���� �d|�j�vr|�j���|�_��d�u�rt��|pt��dd��}|p!t��dd��}|r/t|����D�]\}}q*|||��f|�j�<�|rL���fdd�} �| _t|��| ��d�S�d�S�)Nr����� _exposed_�_method_to_typeid_c�������������������sf���t��d���|�j�g|�R�i�|��\}}��||�j|�|�j|d�}|�j|j|�jd�}t|d�d|jf��|S�)Nz)requesting creation of a shared %r object��managerrj���r����r����rc���) r���r����r����r����r����r����r-���rG���r.���)r/���rC���rD���r����Zexp�proxyr�����r����r,���r���r���rU������s����z"BaseManager.register.<locals>.temp) �__dict__r�����copy� AutoProxyr���r&���r#���r8����setattr) r����r,���rS���r����r����r����� create_method�keyr����rU���r���r��r����register���s$��� � � �zBaseManager.register)NNr����Nrf���r���)NNNNT)r8���r:���r;���r����rZ���r����r0���r����r����r~����classmethodr����r����r����r����r����r����r�����staticmethodr�����propertyr-���r ��r���r���r���r���r������s6���� � +� �r���c�������������������@�������e�Zd�Zdd��Zdd��ZdS�)�ProcessLocalSetc�����������������C���s���t��|�dd����d�S�)Nc�����������������S�������|�����S�r���)�clearr'���r���r���r����<lambda>���s����z*ProcessLocalSet.__init__.<locals>.<lambda>)r����register_after_forkr1���r���r���r���r0������r���zProcessLocalSet.__init__c�����������������C���s���t�|��dfS�rf���)r���r1���r���r���r���� __reduce__���r����zProcessLocalSet.__reduce__N)r8���r:���r;���r0���r��r���r���r���r���r����������r��c�������������������@���s����e�Zd�Z �i�Ze���Z ddd�Zdd��Zdi�fd d �Z dd��Z d d��Zedd���Z dd��Zdd��Zdd��Zdd��Zdd��ZdS�)r���NTFc����������� ������C���s����t�j�!�t�j�|jd��}|d�u�rt���t��f}|t�j|j<�W�d�����n1�s'w���Y��|d�|�_|d�|�_ ||�_ |�j j|�_||�_ ||�_t|�d�|�_||�_|d�urYt�|�|�_n|�j d�urd|�j j|�_nt���j|�_|rp|�����t�|�t�j��d�S�)Nr���r���)r����_mutexr����r����r-���r���ZForkAwareLocalr���_tls�_idset�_tokenr.����_id�_managerr����rk���r�����_owned_by_managerr���ri���r����ry���rj����_increfr���_after_fork) r/���r����rs���r��rj���r����rb���� manager_ownedZ tls_idsetr���r���r���r0������s.����� zBaseProxy.__init__c�����������������C���sd���t��d��t���j}t���jdkr|dt���j�7�}|�j|�jj |�j d�}t|d�d|f��||�j_ d�S�)Nzmaking connection to managerZ MainThread�|r����r]���)r���r����r���ry���r ���rp���r����r����r��r-���r����rG���r��r ���)r/���r ���r����r���r���r����_connect��s��� zBaseProxy._connectr���c�����������������C���s���� �z|�j�j}W�n�ty!���t�dt���j��|�����|�j�j}Y�nw�|� |�j |||f��|���\}}|dkr8|S�|dkrn|\}}|�jj |j�d�} |�jj|_| ||�j|�j|�j|d�} |�j|j|�jd�}t|d�d|jf��| S�t||��)Nz#thread %r does not own a connectionr=���r�������r���r����rc���)r��r ���r����r���r����rp���r����r ���r!��r>���r��r?���r��r����r,���r��r-���r����r����r����rG���r.���r@���)r/���rB���rC���rD���r����rE���rF���r����r����r����r��r���r���r����_callmethod%��s4����� � zBaseProxy._callmethodc�����������������C���s��� �|���d�S�)Nr�����r#��r1���r���r���r���� _getvalueC��s��� zBaseProxy._getvaluec�������������� ���C���s����|�j�r t�d|�jj��d�S�|�j|�jj|�jd�}t|d�d|�j f��t�d|�jj��|�j �|�j ��|�jo5|�jj }tj|�tj|�j|�j||�j|�j |�jfdd�|�_d�S�)Nz%owned_by_manager skipped INCREF of %rr����rb���z INCREF %r� ���r����)r��r���r����r��r.���r����r-���r����rG���r��r���addr��r����r����r����_decrefr��Z_close)r/���r����r5���r���r���r���r��I��s��� ��zBaseProxy._increfc�������������� ���C���s����|��|�j��|d�u�s|jtjkrBzt�d|�j��||�j|d�}t|d�d|�jf��W�n�t yA�}�zt�d|��W�Y�d�}~nd�}~ww�t�d|�j��|sbt |d�rdt�dt���j ��|j����|`d�S�d�S�d�S�)Nz DECREF %rr����rc���z... decref failed %sz%DECREF %r -- manager already shutdownr ���z-thread %r has no more proxies so closing conn)�discardr.���r����r����r����r���r����r-���rG���r����r����rp���r����r ���r ���r����)r����rj���r5���ZtlsZidsetr����r����r����r���r���r���r(��]��s$������ �zBaseProxy._decrefc�������������� ���C���sJ���d�|�_�z|�����W�d�S��ty$�}�zt�d|���W�Y�d�}~d�S�d�}~ww�)Nzincref failed: %s)r��r��r����r���r����)r/���r����r���r���r���r��v��s�����zBaseProxy._after_forkc�����������������C���sZ���i�}t���d�ur|�j|d<�t|�dd�r!|�j|d<�tt|�j|�j|ffS�tt|��|�j|�j|ffS�)Nrj����_isautoFr����) r���r����r���r�����RebuildProxyr��r��r����r����r/���rD���r���r���r���r��~��s��� ��zBaseProxy.__reduce__c�����������������C���r��r���)r%��)r/���Zmemor���r���r����__deepcopy__���r����zBaseProxy.__deepcopy__c�����������������C���s���dt�|��j|�jjt|��f�S�)Nz<%s object, typeid %r at %#x>)r���r8���r��r,���r.���r1���r���r���r���r9������s����zBaseProxy.__repr__c�����������������C���s6��� �z|���d�W�S��ty���t|��d�d��d��Y�S�w�)Nr9���r"��z; '__str__()' failed>)r#��r����r����r1���r���r���r���rQ������s����zBaseProxy.__str__�NNNTF)r8���r:���r;���r����r���ZForkAwareThreadLockr��r0���r!��r#��r%��r��r��r(��r��r��r-��r9���rQ���r���r���r���r���r������s$���� �) r���c�����������������C���s���� �t�t���dd��}|r+|j|jkr+t�d|��d|d<�|j|jvr+|j|j�|j|j<�|� dd�o9t�t���dd��}|�||fd|i|��S�)Nrz���z*Rebuild a proxy owned by manager, token=%rTr��rb���Z_inheritingF) r���r���ry���r-���r���r����r.���ro���rm����pop)rV���r����rs���rD���r����rb���r���r���r���r+�����s��� ��r+��c�����������������C���sp��� �t�|�}z||�|f�W�S��ty���Y�nw�i�}|D�]}td||f�|��qt|�tf|�}||_|||�|f<�|S�)NzOdef %s(self, /, *args, **kwds): return self._callmethod(%r, args, kwds))r����r�����execr���r���r����)r ���r�����_cacheZdicZmeth� ProxyTyper���r���r���� MakeProxyType���s$������r3��c�����������������C���s���� �t�|�d�}|d�u�r&||�j|d�}zt|d�d|�f�}W�|����n|����w�|d�u�r1|d�ur1|j}|d�u�r:t���j}td|�j �|�} | |�|||||d�} d| _ | S�)Nr���r����r^���z AutoProxy[%s])r��rj���rb���r��T)rk���r-���rG���r����r����r���ry���rj���r3��r,���r*��)r����rs���r��rj���r����rb���r��r����r����r2��r��r���r���r���r�����s"��� �r��c�������������������@���r��)� Namespacec����������������K���s���|�j��|��d�S�r���)r���updater,��r���r���r���r0������r3���zNamespace.__init__c�����������������C���sZ���t�|�j����}g�}|D�]\}}|�d�s|�d||f���q|����d|�jjd�|�f�S�)NrX���z%s=%rz%s(%s)z, ) r&���r��r#���� startswithrT���r����r7���r8���r����)r/���r#���rU���r ���r����r���r���r���r9������s��� �zNamespace.__repr__N)r8���r:���r;���r0���r9���r���r���r���r���r4�����r��r4��c�������������������@���s8���e�Zd�Zddd�Zdd��Zdd��Zdd ��Zeee�Zd S�)�ValueTc�����������������C�������||�_�||�_d�S�r���)� _typecode�_value)r/���r���r�����lockr���r���r���r0���������� zValue.__init__c�����������������C���r����r����r:��r1���r���r���r���r�������s���z Value.getc�����������������C���s ���||�_�d�S�r���r=���r/���r����r���r���r���r����������� z Value.setc�����������������C���s���dt�|��j|�j|�jf�S�)Nz %s(%r, %r))r���r8���r9��r:��r1���r���r���r���r9������s���zValue.__repr__N�T) r8���r:���r;���r0���r����r����r9���r ��r����r���r���r���r���r7�����s���� r7��c�����������������C���s���t���|�|�S�r���)r���)r����sequencer;��r���r���r����Array���r����rB��c�������������������@���s8���e�Zd�ZdZdd��Zdd��Zdd��Zdd ��Zd d��ZdS�) � IteratorProxy)�__next__r>����throwr����c�����������������C�������|�S�r���r���r1���r���r���r����__iter__��r����zIteratorProxy.__iter__c�����������������G�������|���d|�S�)NrD��r$���r/���rC���r���r���r���rD�� ��r����zIteratorProxy.__next__c�����������������G���rH��)Nr>���r$��rI��r���r���r���r>�����r����zIteratorProxy.sendc�����������������G���rH��)NrE��r$��rI��r���r���r���rE����r����zIteratorProxy.throwc�����������������G���rH��)Nr����r$��rI��r���r���r���r������r����zIteratorProxy.closeN) r8���r:���r;���r����rG��rD��r>���rE��r����r���r���r���r���rC����s����rC��c�������������������@���s2���e�Zd�ZdZddd�Zdd��Zdd ��Zd d��ZdS�) � AcquirerProxy)�acquire�releaseTNc�����������������C���s"���|d�u�r|fn||f}|���d|�S��NrK��r$��)r/���Zblockingr����rC���r���r���r���rK����s���zAcquirerProxy.acquirec�����������������C���� ���|���d�S��NrL��r$��r1���r���r���r���rL����r?��zAcquirerProxy.releasec�����������������C���rN��rM��r$��r1���r���r���r���r������r?��zAcquirerProxy.__enter__c�����������������C���rN��rO��r$��r����r���r���r���r������r?��zAcquirerProxy.__exit__)TN)r8���r:���r;���r����rK��rL��r����r����r���r���r���r���rJ����s���� rJ��c�������������������@���s6���e�Zd�ZdZddd�Zd dd�Zdd ��Zdd d�ZdS�)�ConditionProxy)rK��rL��r�����notify� notify_allNc�����������������C�������|���d|f�S��Nr����r$��r����r���r���r���r����#��r*���zConditionProxy.waitr���c�����������������C���rS��)NrQ��r$��)r/����nr���r���r���rQ��%��r*���zConditionProxy.notifyc�����������������C���rN��)NrR��r$��r1���r���r���r���rR��'��r?��zConditionProxy.notify_allc�����������������C���sj���|��}|r|S�|d�urt����|�}nd�}d�}|s3|d�ur)|t�����}|dkr) �|S�|��|��|��}|r|S�)Nr���)�time� monotonicr����)r/���Z predicater����rF���ZendtimeZwaittimer���r���r����wait_for)��s"��� ��zConditionProxy.wait_forr���)r���)r8���r:���r;���r����r����rQ��rR��rX��r���r���r���r���rP��!��s���� rP��c�������������������@���s2���e�Zd�ZdZdd��Zdd��Zdd��Zdd d �ZdS�)� EventProxy)r���r����r��r����c�����������������C���rN��)Nr���r$��r1���r���r���r���r���>��r?��zEventProxy.is_setc�����������������C���rN���Nr����r$��r1���r���r���r���r����@��r?��zEventProxy.setc�����������������C���rN��)Nr��r$��r1���r���r���r���r��B��r?��zEventProxy.clearNc�����������������C���rS��rT��r$��r����r���r���r���r����D��r*���zEventProxy.waitr���)r8���r:���r;���r����r���r����r��r����r���r���r���r���rY��<��s����rY��c�������������������@���sN���e�Zd�ZdZddd�Zdd��Zdd��Zed d ���Zedd���Z ed d���Z dS�)�BarrierProxy)�__getattribute__r�����abort�resetNc�����������������C���rS��rT��r$��r����r���r���r���r����J��r*���zBarrierProxy.waitc�����������������C���rN��)Nr]��r$��r1���r���r���r���r]��L��r?��zBarrierProxy.abortc�����������������C���rN��)Nr^��r$��r1���r���r���r���r^��N��r?��zBarrierProxy.resetc�����������������C�������|���dd�S�)Nr\��)�partiesr$��r1���r���r���r���r`��P������zBarrierProxy.partiesc�����������������C���r_��)Nr\��)� n_waitingr$��r1���r���r���r���rb��S��ra��zBarrierProxy.n_waitingc�����������������C���r_��)Nr\��)�brokenr$��r1���r���r���r���rc��V��ra��zBarrierProxy.brokenr���)r8���r:���r;���r����r����r]��r^��r ��r`��rb��rc��r���r���r���r���r[��H��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���rX���r#��r\��)�objectr\���r/���r ��� callmethodr���r���r����__getattr__]������zNamespaceProxy.__getattr__c�����������������C���s4���|d�dkr t��|�||�S�t��|�d�}|d||f�S�)Nr���rX���r#��re��)rg��re��r\��)r/���r ��r����ri��r���r���r���re��b��s���zNamespaceProxy.__setattr__c�����������������C���s0���|d�dkrt��|�|�S�t��|�d�}|d|f�S�)Nr���rX���r#��rf��)rg��rf��r\��rh��r���r���r���rf��g��rk��zNamespaceProxy.__delattr__N)r8���r:���r;���r����rj��re��rf��r���r���r���r���rd��[��s ����rd��c�������������������@���s4���e�Zd�ZdZdd��Zdd��Zeee�Zee j �ZdS�)� ValueProxy)r����r����c�����������������C���rN��)Nr����r$��r1���r���r���r���r����p��r?��zValueProxy.getc�����������������C���rS��rZ��r$��r>��r���r���r���r����r��r*���zValueProxy.setN)r8���r:���r;���r����r����r����r ��r����r���types�GenericAlias�__class_getitem__r���r���r���r���rl��n��s���� rl��� BaseListProxy)�__add__�__contains__�__delitem__�__getitem__�__len__�__mul__�__reversed__�__rmul__�__setitem__rT����count�extend�index�insertr/���remove�reverser�����__imul__c�������������������@���r��)� ListProxyc�����������������C�������|���d|f��|�S�)Nr{��r$��r>��r���r���r����__iadd__�������zListProxy.__iadd__c�����������������C���r���)Nr���r$��r>��r���r���r���r������r���zListProxy.__imul__N)r8���r:���r;���r���r���r���r���r���r���r�����s����r���� DictProxy)rr��rs��rt��rG��ru��ry��r��r��r����r#���r$���r/���popitem� setdefaultr5��r%���rG���Iterator� ArrayProxy)ru��rt��ry��� PoolProxy)Zapply�apply_asyncr�����imap�imap_unorderedr�����map� map_async�starmap� starmap_asyncr����ZAsyncResult)r���r���r���r���r���c�������������������@���r��)r���c�����������������C���rF��r���r���r1���r���r���r���r�������r����zPoolProxy.__enter__c�����������������C���r����r���)r����r����r���r���r���r�������r����zPoolProxy.__exit__N)r8���r:���r;���r����r����r���r���r���r���r������r��c�������������������@���s���e�Zd�ZdS�)r���N)r8���r:���r;���r���r���r���r���r������s����r����QueueZ JoinableQueuerw���rq����RLock� Semaphore�BoundedSemaphore� Condition�Barrier�Poolr&���r����)r����r��)r��c�������������������@���sJ���e�Zd�Z �g�fdd�Zdd��Zdd��Zdd��Zd d ��Zdd��Zd d��Z dS�)�_SharedMemoryTrackerc�����������������C���r8��r����Zshared_memory_context_name� segment_names)r/���r ���r���r���r���r���r0������r<��z_SharedMemoryTracker.__init__c�����������������C���s*��� �t��d|�dt�������|�j�|��d�S�)NzRegister segment � in pid )r���r����r���r���rT����r/����segment_namer���r���r����register_segment���s���z%_SharedMemoryTracker.register_segmentc�����������������C���sD��� �t��d|�dt�������|�j�|��t�|�}|����|����d�S�)NzDestroy segment r���) r���r����r���r���r~��r����SharedMemoryr�����unlink)r/���r���Zsegmentr���r���r����destroy_segment���s��� z$_SharedMemoryTracker.destroy_segmentc�����������������C���s$��� �|�j�d�d���D�]}|��|��qd�S�r���)r���r���r���r���r���r���r������s����z_SharedMemoryTracker.unlinkc�����������������C���s(���t��d|�jj��dt�������|�����d�S�)NzCall z.__del__ in )r���r����r7���r8���r���r���r1���r���r���r����__del__���s���z_SharedMemoryTracker.__del__c�����������������C���s���|�j�|�jfS�r���r���r1���r���r���r���r2������r����z!_SharedMemoryTracker.__getstate__c�����������������C���s���|�j�|���d�S�r���)r0���r4���r���r���r���r6������r*���z!_SharedMemoryTracker.__setstate__N) r8���r:���r;���r0���r���r���r���r���r2���r6���r���r���r���r���r������s���� r���c�������������������@���sJ���e�Zd�Zejg�d��Zdd��Zdd��Zdd��Zdd ��Zd d��Z dd ��Z dS�)�SharedMemoryServer)� track_segment�release_segment� list_segmentsc�����������������O���s`���t�j|�g|�R�i�|���|�j}t|t�rt�|�}td|��dt������|�_ t �dt�������d�S�)NZshm_rX���z"SharedMemoryServer started by pid )rZ���r0���r-���rK���rg����os�fsdecoder���r����shared_memory_contextr���r����)r/���rC����kwargsr-���r���r���r���r0������s��� �zSharedMemoryServer.__init__c����������������O���s<��� �t�|�j|�d�d�r|�j|d<�tj|�||g|�R�i�|��S�)Nr"��Z_shared_memory_proxyr���)r����rh���r���rZ���r\���)r/���rA���r,���rC���r���r���r���r���r\�����s��� zSharedMemoryServer.createc�����������������C���s��� �|�j�����t�|�|�S�r���)r���r���rZ���r[���r����r���r���r���r[�����s��� zSharedMemoryServer.shutdownc�����������������C������� �|�j��|��d�S�r���)r���r����r/���rA���r���r���r���r���r�����s���z SharedMemoryServer.track_segmentc�����������������C���r���r���)r���r���r���r���r���r���r�����s���z"SharedMemoryServer.release_segmentc�����������������C���s ��� �|�j�jS�r���)r���r���r����r���r���r���r�����s���z SharedMemoryServer.list_segmentsN)r8���r:���r;���rZ���r����r0���r\���r[���r���r���r���r���r���r���r���r������s����� r���c�������������������@���s:���e�Zd�Z �eZdd��Zdd��Zdd��Zdd��Zd d ��Z dS�)r���c�����������������O���sT���t�jdkrddlm}�|����tj|�g|�R�i�|���t�|�j j ��dt�������d�S�)N�posixr���)�resource_trackerz created by pid )r���r �����r���Zensure_runningr���r0���r���r����r7���r8���r���)r/���rC���r���r���r���r���r���r0���/��s ��� zSharedMemoryManager.__init__c�����������������C���s���t��|�jj��dt�������d�S�)Nz.__del__ by pid )r���r����r7���r8���r���r1���r���r���r���r���;��s���zSharedMemoryManager.__del__c�����������������C���sf��� �|�j�jtjkr'|�j�jtjkrtd��|�j�jtjkrtd��td�|�j�j���|��|�j |�j |�j|�j�S�)Nz"Already started SharedMemoryServerz!SharedMemoryManager has shut downr����) r����r����r����r����r����r���r����rN���r����r����r����r����r����r1���r���r���r���r����?��s�����zSharedMemoryManager.get_serverc�����������������C���s���� �|�j�|�j|�jd��/}tjd�d|d�}zt|d�d|jf��W�n�ty0�}�z|����|�d�}~ww�W�d�����|S�1�s<w���Y��|S�)Nr����T)r\����sizer���) r����r����r����r���r���rG���r ���� BaseExceptionr���)r/���r���r����Zsmsr����r���r���r���r���L��s������ ��z SharedMemoryManager.SharedMemoryc�����������������C���s���� �|�j�|�j|�jd��.}t�|�}zt|d�d|jjf��W�n�ty/�}�z|j� ���|�d�}~ww�W�d�����|S�1�s;w���Y��|S�)Nr����r���) r����r����r����r���� ShareableListrG���Zshmr ���r���r���)r/���rA��r����Zslr����r���r���r���r���X��s��� ��� ��z!SharedMemoryManager.ShareableListN) r8���r:���r;���r���r����r0���r���r����r���r���r���r���r���r���r���#��s���� r.��r@��)U�__all__r����rp���r����r����queuerV��rm��r���r���r����r���r���r ����contextr ���r���r���r ���r���r���r���r����ImportErrorZ HAS_SHMEMrT���r���r ��Z view_typesr&���r)���Z view_typerg��r���rG���r@���r����rO���rW���rY���rZ���r����rt���ru���ZXmlListenerZ XmlClientrk���r���r����r��r���r+��r3��r��r4��r7��rB��rC��rJ��rP��rY��r[��rd��rl��rp��r���r���r����r���Z BasePoolProxyr���r���r���rw���rq���r���r���r���r���r���r���r����r���r���r���r���r���r���r����<module>���s���� � ��P � �w �4 � � � �%-�