����JFIF���������
1#@!#!123s
D7net
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
proc
/
self
/
root
/
proc
/
self
/
root
/
lib64
/
python2.7
/
multiprocessing
/
Filename :
managers.pyc
back
Copy
� {fc�����������@���s���d��d�d�d�g�Z��d�d�l�Z�d�d�l�Z�d�d�l�Z�d�d�l�Z�d�d�l�Z�d�d�l�Z�d�d�l�m�Z�d�d�l �m �Z �m�Z�m�Z�m �Z �m�Z�m�Z�d�d�l�m�Z�d�d �l�m�Z�m�Z�m�Z�m�Z�d�d �l�m�Z�m�Z�y�d�d�l�m�Z�Wn!�e�k �rd�d�l�m�Z�n�Xd����Z�e�j�e�j�e���g��d �d�d�f�D]�Z �e!�e"�i��e ��������^�qDZ#�d�e$�f�d�������YZ%�f��i��d���Z&�d����Z'�d�e(�f�d�������YZ)�d����Z*�d����Z+�d�e$�f�d�������YZ,�d�e$�f�d�������YZ-�i�e�j.�e�j/�f�d�6e�j0�e�j1�f�d�6Z2�d��e$�f�d�������YZ3�d�e4�f�d�������YZ5�d�e$�f�d �������YZ6�d!����Z7�i��d"���Z8�e9�e9�e9�e:�d#���Z;�d$�e$�f�d%�������YZ<�d&�e$�f�d'�������YZ=�e:�d(���Z>�d)�e6�f�d*�������YZ?�d+�e6�f�d,�������YZ@�d-�e@�f�d.�������YZA�d/�e6�f�d0�������YZB�d1�e6�f�d2�������YZC�d3�e6�f�d4�������YZD�e8�d5�d6�d7�d8�d9�d:�d;�d<�d=�d>�d?�d@�dA�dB�dC�dD�dE�dF�dG�dH�dI�dJ�dK�f���ZE�dL�eE�f�dM�������YZF�e8�dN�d7�d8�d:�dO�d<�d@�dP�dQ�dR�dS�d �d�dG�dT�dU�dV�d�f���ZG�i�dW�dO�6eG�_H�e8�dX�d<�d:�d@�d;�dA�f���ZI�e8�dY�dZ�d[�d\�d]�d^�d_�d`�da�db�f ���ZJ�i�dc�d[�6dc�da�6dW�d]�6dW�d^�6eJ�_H�d�e3�f�dd�������YZK�eK�j�de�e�j���eK�j�df�e�j���eK�j�dg�e�jL�eB���eK�j�dh�e�jM�e@���eK�j�di�e�jN�e@���eK�j�dj�e�jO�e@���eK�j�dk�e�jP�e@���eK�j�dl�e�jQ�eA���eK�j�dm�e �eJ���eK�j�dn�eR�eF���eK�j�do�eS�eG���eK�j�d&�e=�eD���eK�j�dp�e>�eI���eK�j�d$�e<�eC���eK�j�dW�dq�e?�dr�eT��eK�j�dc�dr�eT��d�S(s���t���BaseManagert���SyncManagert ���BaseProxyt���Tokeni����N(���t ���format_exc(���t���Processt���current_processt���active_childrent���Poolt���utilt ���connection(���t���AuthenticationString(���t���exitt���Popent���assert_spawningt���ForkingPickler(���t���Finalizet���info(���t ���PicklingErrorc���������C���s���t��j��|��j�|��j����f�f�S(���N(���t���arrayt���typecodet���tostring(���t���a(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���reduce_array@���s����t���itemst���keyst���valuesc�����������B���s8���e��Z�d��Z�d�Z�d����Z�d����Z�d����Z�d����Z�RS( ���s4��� Type to uniquely indentify a shared object t���typeidt���addresst���idc���������C���s!���|�|�|�|��_��|��_�|��_�d��S(���N(���R���R���R���(���t���selfR���R���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__init__P���s����c���������C���s���|��j��|��j�|��j�f�S(���N(���R���R���R���(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__getstate__S���s����c���������C���s���|�\�|��_��|��_�|��_�d��S(���N(���R���R���R���(���R���t���state(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__setstate__V���s����c���������C���s���d�|��j��|��j�|��j�f�S(���Ns#���Token(typeid=%r, address=%r, id=%r)(���R���R���R���(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__repr__Y���s����(���R���R���R���(���t���__name__t ���__module__t���__doc__t ���__slots__R���R ���R"���R#���(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR���J���s��� c���������C���sN���|��j��|�|�|�|�f���|��j����\�}�}�|�d�k�r;�|�St�|�|�����d�S(���sL��� Send a message to manager using connection `c` and return response s���#RETURNN(���t���sendt���recvt���convert_to_error(���t���cR���t ���methodnamet���argst���kwdst���kindt���result(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���dispatcha���s ����c���������C���s~���|��d�k�r�|�S|��d�k�r>�t��|���t�k�s4�t���t�|���S|��d�k�rp�t��|���t�k�sb�t���t�d�|���St�d���Sd��S(���Ns���#ERRORs ���#TRACEBACKs���#UNSERIALIZABLEs���Unserializable message: %s s���Unrecognized message type(���t���typet���strt���AssertionErrort���RemoteErrort ���ValueError(���R/���R0���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR*���k���s���� R5���c�����������B���s���e��Z�d�����Z�RS(���c���������C���s)���d�d�d�d�t��|��j�d���d�d�S(���Ns��� t���-iK���i����(���R3���R-���(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__str__x���s����(���R$���R%���R8���(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR5���w���s���c���������C���sO���g��}�xB�t��|����D]4�}�t�|��|���}�t�|�d���r�|�j�|���q�q�W|�S(���s4��� Return a list of names of methods of `obj` t���__call__(���t���dirt���getattrt���hasattrt���append(���t���objt���tempt���namet���func(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���all_methods���s����c���������C���s-���g��t��|����D]�}�|�d�d�k�r �|�^�q �S(���sP��� Return a list of names of methods of `obj` which do not start with '_' i����t���_(���RB���(���R>���R@���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���public_methods����s����t���Serverc�������� ���B���s����e��Z�d��Z�d�d�d�d�d�d�d�d�d �g �Z�d ����Z�d����Z�d����Z�d ����Z�d����Z�d����Z �d����Z �i�e �d�6e �d�6e�d�6Z�d����Z�d����Z �d����Z�d����Z�d����Z�d����Z�d����Z�d����Z�d����Z�RS(���sM��� Server class which runs in a process controlled by a manager object t���shutdownt���createt���accept_connectiont���get_methodst ���debug_infot���number_of_objectst���dummyt���increft���decrefc���������C���s����t��|�t���s�t���|�|��_�t�|���|��_�t�|�\�}�}�|�d�|�d�d���|��_�|��j�j�|��_�i�d��d�f�d�6|��_ �i��|��_�t�j ����|��_�d�|��_�d��S(���NR���t���backlogi���t���0i����(����(���t ���isinstancet���bytesR4���t���registryR���t���authkeyt���listener_clientt���listenerR���t���Nonet ���id_to_objt���id_to_refcountt ���threadingt���RLockt���mutext���stop(���R���RS���R���RT���t ���serializert���Listenert���Client(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s���� c���������C���s����|��t�����_�z��yl�xe�y�|��j�j����}�Wn�t�t�f�k �rD�q�n�Xt�j�d�|��j�d�|�f���}�t �|�_ �|�j����q�WWn�t�t �f�k �r��n�XWd�d�|��_�|��j�j����Xd�S(���s(��� Run the server forever t���targetR-���Ni���(���R���t���_manager_serverRV���t���acceptt���OSErrort���IOErrorRZ���t���Threadt���handle_requestt���Truet���daemont���startt���KeyboardInterruptt ���SystemExitR]���t���close(���R���R+���t���t(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt ���serve_forever����s���� c���������C���s��d�}�}�}�yv�t�j�|�|��j���t�j�|�|��j���|�j����}�|�\�}�}�}�}�|�|��j�k�st�t�d�|�����t�|��|���}�Wn �t �k �r��d�t ����f�} �nF�Xy�|�|�|�|���}�Wn �t �k �r��d�t ����f�} �n �Xd�|�f�} �y�|�j�| ���Wnq�t �k �rp} �y�|�j�d�t ����f���Wn�t �k �r<n�Xt�j �d�| ���t�j �d�|���t�j �d�| ���n�X|�j����d�S(���s)��� Handle a new connection s���%r unrecognizeds ���#TRACEBACKs���#RETURNs���Failure to send message: %rs��� ... request was %rs��� ... exception was %rN(���RW���R ���t���deliver_challengeRT���t���answer_challengeR)���t���publicR4���R;���t ���ExceptionR���R(���R ���R���Rm���(���R���R+���t���funcnameR0���t���requestt���ignoreR-���R.���RA���t���msgt���e(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRg�������s4���� c���������C���s���t��j�d�t�j����j���|�j�}�|�j�}�|��j�}�x�|��j�s�yd�}�}�|����}�|�\�}�}�} �} �|�|�\�}�}�}�|�|�k�r��t �d�|�t�|���|�f�����n��t�|�|���} �y�| �| �| ����}�Wn�t �k �r��}�d�|�f�}�np�X|�o|�j�|�d���}�|�rP|��j�|�|�|���\�}�}�t�|�|��j�|���}�d�|�|�f�f�}�n�d�|�f�}�Wn��t �k �r�|�d�k�r�d�t����f�}�q?y8�|��j�|�}�|�|��|�|�|�| �| ���}�d�|�f�}�Wq?t �k �r�d�t����f�}�q?XnV�t�k �rt��j�d�t�j����j���t�j�d���n �t �k �r>d�t����f�}�n�Xy;�y�|�|���Wn&�t �k �rx}�|�d �t����f���n�XWq7�t �k �r�}�t��j�d �t�j����j���t��j�d�|���t��j�d�|���|�j����t�j�d ���q7�Xq7�Wd�S(���sQ��� Handle requests from the proxies in a particular process/thread s$���starting server thread to service %rs+���method %r of %r object is not in exposed=%rs���#ERRORs���#PROXYs���#RETURNs ���#TRACEBACKs$���got EOF -- exiting thread serving %ri����s���#UNSERIALIZABLEs���exception in thread serving %rs��� ... message was %rs��� ... exception was %ri���N(���R ���t���debugRZ���t���current_threadR@���R)���R(���RX���R]���RW���t���AttributeErrorR2���R;���Rs���t���getRG���R���R���R���t���fallback_mappingt���EOFErrort���sysR���R���Rm���(���R���t���connR)���R(���RX���R,���R>���Ru���t���identR-���R.���t���exposedt ���gettypeidt���functiont���resRx���Rw���R���t���ridentt���rexposedt���tokent ���fallback_funcR0���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���serve_client����sl���� c���������C���s���|�S(���N(����(���R���R����R����R>���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���fallback_getvalue+��s����c���������C���s ���t��|���S(���N(���R3���(���R���R����R����R>���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���fallback_str.��s����c���������C���s ���t��|���S(���N(���t���repr(���R���R����R����R>���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt ���fallback_repr1��s����R8���R#���s ���#GETVALUEc���������C���s���d��S(���N(����(���R���R+���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRL���:��s����c���������C���s����|��j��j����z��g��}�|��j�j����}�|�j����xS�|�D]K�}�|�d�k�r6�|�j�d�|�|��j�|�t�|��j�|�d���d� f���q6�q6�Wd�j�|���SWd�|��j��j ����Xd�S(���sO��� Return some info --- useful to spot problems with refcounting RP���s��� %s: refcount=%s %si����iK���s��� N( ���R\���t���acquireRX���R���t���sortR=���RY���R3���t���joint���release(���R���R+���R0���R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRJ���=��s���� 'c���������C���s���t��|��j���d�S(���s*��� Number of shared objects i���(���t���lenRX���(���R���R+���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRK���O��s����c���������C���s��z��y��t��j�d���|�j�d ���t�j�t�j�k�rZ�t��j�d���t�j�t�_�t�j�t�_�n��t��j �d���x(�t ����D]�}�t��j�d���|�j����qq�Wx(�t ����D]�}�t��j�d���|�j����q��Wt��j ����t��j �d���Wn�d�d�l�}�|�j����n�XWd�t�d���Xd�S( ���s'��� Shutdown this process s!���manager received shutdown messages���#RETURNs���resetting stdout, stderri����s&���terminating a child process of managers���manager exiting with exitcode 0i����N(���s���#RETURNN(���R ���Ry���R(���RW���R���t���stdoutt ���__stdout__t ���__stderr__t���stderrt���_run_finalizersR���t ���terminateR����R���t ���tracebackt ���print_excR���(���R���R+���t���pR����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRF���U��s*���� c���������O���s\��|��j��j����z:|��j�|�\�}�}�}�}�|�d�k�ra�t�|���d�k�rN�|�sT�t���|�d�} �n�|�|�|����} �|�d�k�r��t�| ���}�n��|�d�k �r��t�|���t�k�s��t���t �|���t �|���}�n��d�t �| ���} �t�j�d�|�| ���| �t �|���|�f�|��j�| �<| �|��j�k�r&d�|��j�| �<n��|��j�|�| ���| �t�|���f�SWd�|��j��j����Xd�S(���s>��� Create a new shared object and return its id i���i����s���%xs&���%r callable returned object with id %rN(���R\���R����RS���RW���R����R4���RD���R2���t���dictt���listR���R ���Ry���t���setRX���RY���RM���t���tupleR����(���R���R+���R���R-���R.���t���callableR����t���method_to_typeidt ���proxytypeR>���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRG���u��s(���� c���������C���s���t��|��j�|�j�d���S(���sL��� Return the methods of the shared object indicated by token i���(���R����RX���R���(���R���R+���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRI������s����c���������C���s-���|�t��j����_�|�j�d���|��j�|���d�S(���s=��� Spawn a new thread to serve this connection s���#RETURNN(���s���#RETURNN(���RZ���Rz���R@���R(���RW���R����(���R���R+���R@���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRH������s���� c���������C���s9���|��j��j����z�|��j�|�c�d�7<Wd��|��j��j����Xd��S(���Ni���(���R\���R����RY���R����(���R���R+���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRM������s���� c���������C���s����|��j��j����zj�|��j�|�d�k�s)�t���|��j�|�c�d�8<|��j�|�d�k�rv�|��j�|�=|��j�|�=t�j�d�|���n��Wd��|��j��j����Xd��S(���Ni���i����s���disposing of obj with id %r(���R\���R����RY���R4���RX���R ���Ry���R����(���R���R+���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRN������s���� (���R$���R%���R&���Rr���R���Ro���Rg���R����R����R����R����R}���RL���RJ���RK���RF���RG���RI���RH���RM���RN���(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRE�������s.��� " J & t���Statec�����������B���s#���e��Z�d��g�Z�d�Z�d�Z�d�Z�RS(���t���valuei����i���i���(���R$���R%���R'���t���INITIALt���STARTEDt���SHUTDOWN(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s��� t���picklet ���xmlrpclibc�����������B���s����e��Z�d��Z�i��Z�e�Z�d�d�d�d���Z�d����Z�d����Z �d����Z �d�d�d���Z�e�d�d�d�����Z �d����Z�d�d ���Z�d ����Z�d����Z�d����Z�d ����Z�e�d������Z�e�d������Z�e�d�d�d�d�e�d�����Z�RS(���s!��� Base class for managers R����c���������C���sq���|�d��k�r�t����j�}�n��|�|��_�t�|���|��_�t����|��_�t�j�|��j�_ �|�|��_ �t�|�\�|��_�|��_ �d��S(���N(���RW���R���RT���t���_addressR���t���_authkeyR����t���_stateR����R����t���_serializerRU���t ���_Listenert���_Client(���R���R���RT���R^���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s���� c���������C���s%���t��|����j�|��j�|��j�|��j�f�f�S(���N(���R2���t���from_addressR����R����R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt ���__reduce__���s����c���������C���s:���|��j��j�t�j�k�s�t���t�|��j�|��j�|��j�|��j ���S(���sX��� Return server object with serve_forever() method and address attribute ( ���R����R����R����R����R4���RE���t ���_registryR����R����R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt ���get_server���s����c���������C���sN���t��|��j�\�}�}�|�|��j�d�|��j��}�t�|�d�d���t�j�|��j�_ �d�S(���s>��� Connect manager object to the server process RT���RL���N( ���RU���R����R����R����R1���RW���R����R����R����R����(���R���R_���R`���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���connect���s����c���������C���sg��|��j��j�t�j�k�s�t���|�d�k �rF�t�|�d���rF�t�d�����n��t�j �d�t ���\�}�}�t�d�t�|����j �d�|��j�|��j�|��j�|��j�|�|�|�f���|��_�d�j�d����|��j�j�D����}�t�|����j�d�|�|��j�_�|��j�j����|�j����|�j����|��_�|�j����t�j�|��j��_�t�j�|��t�|����j�d�|��j�|��j�|��j�|��j��|��j�f�d �d ��|��_�d�S(���s@��� Spawn a server process for this manager object R9���s���initializer must be a callablet���duplexRa���R-���t���:c���������s���s���|��]�}�t��|���Vq�d��S(���N(���R3���(���t���.0t���i(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pys ���<genexpr> ��s����R7���t���exitpriorityi����N( ���R����R����R����R����R4���RW���R<���t ���TypeErrorR ���t���Pipet���FalseR���R2���t���_run_serverR����R����R����R����t���_processR����t ���_identityR$���R@���Rj���Rm���R)���R����R ���R���t���_finalize_managerR����RF���(���R���t���initializert���initargst���readert���writerR����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRj������s(���� c��� ������C���sl���|�d�k �r�|�|����n��|��j�|�|�|�|���}�|�j�|�j���|�j����t�j�d�|�j���|�j����d�S(���s@��� Create a server, report its address and run it s���manager serving at %rN(���RW���t���_ServerR(���R���Rm���R ���R���Ro���( ���t���clsRS���R���RT���R^���R����R����R����t���server(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s���� c���������O���s����|��j��j�t�j�k�s!�t�d�����|��j�|��j�d�|��j��}�z)�t�|�d�d�|�f�|�|���\�}�}�Wd�|�j ����Xt�|�|��j�|���|�f�S(���sP��� Create a new shared object; return the token and exposed tuple s���server not yet startedRT���RG���N(���R����R����R����R����R4���R����R����R����R1���RW���Rm���R���(���R���R���R-���R.���R����R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���_create0��s����!)c���������C���s���|��j��j�|���d�S(���sC��� Join the manager process (if it has been spawned) N(���R����R����(���R���t���timeout(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR����<��s����c���������C���sA���|��j��|��j�d�|��j��}�z�t�|�d�d���SWd�|�j����Xd�S(���sS��� Return some info about the servers shared objects and connections RT���RJ���N(���R����R����R����R1���RW���Rm���(���R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���_debug_infoB��s����c���������C���sA���|��j��|��j�d�|��j��}�z�t�|�d�d���SWd�|�j����Xd�S(���s5��� Return the number of shared objects RT���RK���N(���R����R����R����R1���RW���Rm���(���R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���_number_of_objectsL��s����c���������C���s���|��S(���N(����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt ���__enter__V��s����c���������C���s���|��j�����d��S(���N(���RF���(���R���t���exc_typet���exc_valt���exc_tb(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__exit__Y��s����c���������C���s��|��j�����r��t�j�d���y8�|�|�d�|��}�z�t�|�d�d���Wd�|�j����XWn�t�k �rd�n�X|��j�d�d���|��j�����r��t�j�d���t�|��d���r��t�j�d ���|��j ����|��j�d�d ���|��j�����r��t�j�d���q��q��q��n��t �j�|�_�y�t �j�|�=Wn�t�k �rn�Xd�S(���sQ��� Shutdown the manager process; will be registered as a finalizer s#���sending shutdown message to managerRT���RF���NR����g�������?s���manager still aliveR����s'���trying to `terminate()` manager processg�������?s#���manager still alive after terminate(���t���is_aliveR ���R���R1���RW���Rm���Rs���R����R<���R����R����R����R����R���t���_address_to_localt���KeyError(���t���processR���RT���R!���R����R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR����\��s.���� c���������C���s���|��j��S(���N(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���<lambda>|��t����c��� ���������s$��d�|��j��k�r$�|��j�j����|��_�n�����d�k�r9�t����n��|�pN�t����d�d���}�|�pf�t����d�d���}�|�r��xa�|�j����D]P�\�}�}�t�|���t�k�s��t �d�|�����t�|���t�k�s|�t �d�|�����q|�Wn��|�|�|����f�|��j���<|�r �����f�d����} ���| �_ �t�|����| ���n��d�S(���s9��� Register a typeid with the manager type R����t ���_exposed_t���_method_to_typeid_s���%r is not a stringc������ ������s����t��j�d�����|��j���|�|���\�}�}����|�|��j�d�|��d�|��j�d�|��}�|��j�|�j�d�|��j��}�t�|�d��d�|�j �f���|�S(���Ns)���requesting creation of a shared %r objectt���managerRT���R����RN���( ���R ���Ry���R����R����R����R����R���R1���RW���R���(���R���R-���R.���R����t���expt���proxyR����(���R����R���(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR?������s����N(���t���__dict__R����t���copyRW���t ���AutoProxyR;���R���R2���R3���R4���R$���t���setattr( ���R����R���R����R����R����R����t ���create_methodt���keyR����R?���(����(���R����R���s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���register~��s ���� ") N(����(����(���R$���R%���R&���R����RE���R����RW���R���R����R����R����Rj���t���classmethodR����R����R����R����R����R����R����t���staticmethodR����t���propertyR���Rh���R����(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s*��� $ t���ProcessLocalSetc�����������B���s���e��Z�d�����Z�d����Z�RS(���c���������C���s���t��j�|��d������d��S(���Nc���������S���s ���|��j�����S(���N(���t���clear(���R>���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������R����(���R ���t���register_after_fork(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s����c���������C���s���t��|����d�f�S(���N(����(���R2���(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s����(���R$���R%���R���R����(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s��� c�����������B���s����e��Z�d��Z�i��Z�e�j����Z�d�d�d�e�d���Z �d����Z �d �i��d���Z�d����Z�d����Z �e�d������Z�d����Z�d����Z�d ����Z�d ����Z�d����Z�RS(���s.��� A base for proxies of shared objects c���������C���s;��t��j�j����zP�t��j�j�|�j�d����}�|�d��k�r\�t�j����t ����f�}�|�t��j�|�j�<n��Wd��t��j�j ����X|�d�|��_�|�d�|��_�|�|��_ �|��j �j�|��_�|�|��_�|�|��_�t�|�d�|��_�|�d��k �r��t�|���|��_�n0�|��j�d��k �r|��j�j�|��_�n�t����j�|��_�|�r$|��j����n��t�j�|��t��j���d��S(���Ni����i���(���R���t���_mutexR����R����R|���R���RW���R ���t���ForkAwareLocalR����R����t���_tlst���_idsett���_tokenR���t���_idt���_managerR����RU���R����R���R����R���RT���t���_increfR����t���_after_fork(���R���R����R^���R����RT���R����RM���t ���tls_idset(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s,���� c���������C���s����t��j�d���t����j�}�t�j����j�d�k�rH�|�d�t�j����j�7}�n��|��j�|��j�j�d�|��j ��}�t �|�d��d�|�f���|�|��j�_ �d��S(���Ns���making connection to managert ���MainThreadt���|RT���RH���(���R ���Ry���R���R@���RZ���Rz���R����R����R���R����R1���RW���R����R ���(���R���R@���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���_connect���s���� c������ ���C���sD��y�|��j��j�}�Wn@�t�k �rR�t�j�d�t�j����j���|��j����|��j��j�}�n�X|�j �|��j �|�|�|�f���|�j����\�}�}�|�d�k�r��|�S|�d�k�r1|�\�}�}�|��j�j �|�j�d�} �|��j�j�|�_�| �|�|��j�d�|��j�d�|��j�d�|��} �|��j�|�j�d�|��j��}�t�|�d �d�|�j�f���| �St�|�|�����d �S( ���sW��� Try to call a method of the referrent and return a copy of the result s#���thread %r does not own a connections���#RETURNs���#PROXYi����R����RT���R����RN���N(���R����R ���R{���R ���Ry���RZ���Rz���R@���R����R(���R����R)���R����R����R���R����R���R����R����R����R1���RW���R���R*���(���R���R,���R-���R.���R����R/���R0���R����R����R����R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���_callmethod���s,���� c���������C���s ���|��j��d���S(���s9��� Get a copy of the value of the referent s ���#GETVALUE(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt ���_getvalue��s����c������ ���C���s����|��j��|��j�j�d�|��j��}�t�|�d��d�|��j�f���t�j�d�|��j�j ���|��j �j�|��j���|��j�or�|��j�j �}�t�j�|��t�j�d�|��j�|��j�|�|��j�|��j �|��j��f�d�d��|��_�d��S(���NRT���RM���s ���INCREF %rR-���R����i ���(���R����R����R���R����R1���RW���R����R ���Ry���R���R����t���addR����R����R���R���t���_decrefR����t���_close(���R���R����R!���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s����c���������C���s����|�j��|��j���|�d��k�s.�|�j�t�j�k�r��yE�t�j�d�|��j���|�|��j�d�|��}�t �|�d��d�|��j�f���Wq��t �k �r��}�t�j�d�|���q��Xn�t�j�d�|��j���|�r��t�|�d���r��t�j�d�t�j ����j���|�j�j����|�`�n��d��S(���Ns ���DECREF %rRT���RN���s���... decref failed %ss%���DECREF %r -- manager already shutdownR ���s-���thread %r has no more proxies so closing conn(���t���discardR���RW���R����R����R����R ���Ry���R���R1���Rs���R<���RZ���Rz���R@���R ���Rm���(���R����RT���R!���t���tlst���idsetR����R����Rx���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s���� c���������C���sB���d��|��_�y�|��j����Wn$�t�k �r=�}�t�j�d�|���n�Xd��S(���Ns���incref failed: %s(���RW���R����R����Rs���R ���R���(���R���Rx���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR����7��s ���� c���������C���s����i��}�t��j����r"�|��j�|�d�<n��t�|��d�t���r]�|��j�|�d�<t�t�|��j�|��j �|�f�f�St�t �|����|��j�|��j �|�f�f�Sd��S(���NRT���t���_isautoR����(���R ���t���thread_is_spawningR����R;���R����R����t���RebuildProxyR����R����R����R2���(���R���R.���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR����?��s���� c���������C���s ���|��j�����S(���N(���R����(���R���t���memo(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__deepcopy__L��s����c���������C���s*���d�t��|����j�|��j�j�d�t�|����f�S(���Ns���<%s object, typeid %r at %s>s���0x%x(���R2���R$���R����R���R���(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR#���O��s����c���������C���s8���y�|��j��d���SWn �t�k �r3�t�|����d� d�SXd�S(���sV��� Return representation of the referent (or a fall-back if that fails) R#���i����s���; '__str__()' failed>N(���R����Rs���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR8���S��s���� N(����(���R$���R%���R&���R����R ���t���ForkAwareThreadLockR����RW���Rh���R���R����R����R����R����R����R����R����R����R��R#���R8���(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s���% c���������C���s����t��t����d�d���}�|�r?�|�j�|�j�k�r?�|�j�|�j�d�S|�j�d�t���od�t��t����d�t���}�|��|�|�d�|�|��Sd�S(���s���� Function used for unpickling proxy objects. If possible the shared object is returned, or otherwise a proxy for it. Rb���i����RM���t���_inheritingN( ���R;���R���RW���R���RX���R���t���popRh���R����(���RA���R����R^���R.���R����RM���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR��`��s����c���������B���s����e��|���}�y�|�|��|�f�SWn�e�k �r1�n�Xi��}�x �|�D]�}�d�|�|�f�|�Uq?�We�|��e�f�|���}�|�|�_�|�|�|��|�f�<|�S(���sB��� Return a proxy type whose methods are given by `exposed` sL���def %s(self, *args, **kwds): return self._callmethod(%r, args, kwds)(���R����R����R2���R���R����(���R@���R����t���_cachet���dict���metht ���ProxyType(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt ���MakeProxyTypeu��s���� c��� ��� ���C���s����t��|�d�}�|�d�k�r\�|�|��j�d�|��}�z�t�|�d�d�|��f���}�Wd�|�j����Xn��|�d�k�r��|�d�k �r��|�j�}�n��|�d�k�r��t����j�}�n��t�d�|��j �|���}�|�|��|�d�|�d�|�d�|��} �t �| �_�| �S(���s*��� Return an auto-proxy for `token` i���RT���RI���Ns ���AutoProxy[%s]R����RM���(���RU���RW���R���R1���Rm���R����R���RT���R��R���Rh���R����( ���R����R^���R����RT���R����RM���R����R����R ��R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s���� t ���Namespacec�����������B���s���e��Z�d�����Z�d����Z�RS(���c���������K���s���|��j��j�|���d��S(���N(���R����t���update(���R���R.���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s����c���������C���ss���|��j��j����}�g��}�x=�|�D]5�\�}�}�|�j�d���s�|�j�d�|�|�f���q�q�W|�j����d�t�j�d�|���S(���NRC���s���%s=%rs ���Namespace(%s)s���, (���R����R���t ���startswithR=���R����R3���R����(���R���R���R?���R@���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR#������s���� (���R$���R%���R���R#���(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s��� t���Valuec�����������B���s>���e��Z�e�d����Z�d����Z�d����Z�d����Z�e�e�e���Z�RS(���c���������C���s���|�|��_��|�|��_�d��S(���N(���t ���_typecodet���_value(���R���R���R����t���lock(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s���� c���������C���s���|��j��S(���N(���R��(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR|������s����c���������C���s ���|�|��_��d��S(���N(���R��(���R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s����c���������C���s ���d�t��|����j�|��j�|��j�f�S(���Ns ���%s(%r, %r)(���R2���R$���R��R��(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR#������s����( ���R$���R%���Rh���R���R|���R����R#���R����R����(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s ��� c���������C���s���t��j��|��|���S(���N(���R���(���R���t���sequenceR��(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���Array���s����t ���IteratorProxyc�����������B���sD���e��Z�d�Z�d����Z�d����Z�d����Z�d����Z�d ����Z�d ����Z�RS(���t���__next__t���nextR(���t���throwRm���c���������C���s���|��S(���N(����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__iter__���s����c���������G���s���|��j��d�|���S(���NR��(���R����(���R���R-���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s����c���������G���s���|��j��d�|���S(���NR��(���R����(���R���R-���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s����c���������G���s���|��j��d�|���S(���NR(���(���R����(���R���R-���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR(������s����c���������G���s���|��j��d�|���S(���NR��(���R����(���R���R-���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s����c���������G���s���|��j��d�|���S(���NRm���(���R����(���R���R-���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyRm������s����(���R��R��R(���R��Rm���( ���R$���R%���R����R��R��R��R(���R��Rm���(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s��� t ���AcquirerProxyc�����������B���s5���e��Z�d�Z�e�d���Z�d����Z�d����Z�d����Z�RS(���R����R����c���������C���s���|��j��d�|�f���S(���NR����(���R����(���R���t���blocking(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s����c���������C���s ���|��j��d���S(���NR����(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s����c���������C���s ���|��j��d���S(���NR����(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s����c���������C���s ���|��j��d���S(���NR����(���R����(���R���R����R����R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s����(���R����R����(���R$���R%���R����Rh���R����R����R����R����(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s ��� t���ConditionProxyc�����������B���s,���e��Z�d�Z�d �d���Z�d����Z�d����Z�RS( ���R����R����t���waitt���notifyt ���notify_allc���������C���s���|��j��d�|�f���S(���NR��(���R����(���R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s����c���������C���s ���|��j��d���S(���NR��(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s����c���������C���s ���|��j��d���S(���NR��(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s����(���R����R����R��R��R��N(���R$���R%���R����RW���R��R��R��(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s��� t ���EventProxyc�����������B���s5���e��Z�d�Z�d����Z�d����Z�d����Z�d �d���Z�RS( ���t���is_setR����R����R��c���������C���s ���|��j��d���S(���NR!��(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR!�����s����c���������C���s ���|��j��d���S(���NR����(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s����c���������C���s ���|��j��d���S(���NR����(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�������s����c���������C���s���|��j��d�|�f���S(���NR��(���R����(���R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR�����s����(���R!��R����R����R��N(���R$���R%���R����R!��R����R����RW���R��(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR �����s ��� t���NamespaceProxyc�����������B���s)���e��Z�d�Z�d����Z�d����Z�d����Z�RS(���t���__getattribute__t���__setattr__t���__delattr__c���������C���sB���|�d�d�k�r �t��j�|��|���St��j�|��d���}�|�d�|�f���S(���Ni����RC���R����R#��(���t���objectR#��(���R���R����t ���callmethod(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__getattr__���s����c���������C���sH���|�d�d�k�r#�t��j�|��|�|���St��j�|��d���}�|�d�|�|�f���S(���Ni����RC���R����R$��(���R&��R$��R#��(���R���R����R����R'��(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR$�����s����c���������C���sB���|�d�d�k�r �t��j�|��|���St��j�|��d���}�|�d�|�f���S(���Ni����RC���R����R%��(���R&��R%��R#��(���R���R����R'��(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR%����s����(���R#��R$��R%��(���R$���R%���R����R(��R$��R%��(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR"�����s��� t ���ValueProxyc�����������B���s/���e��Z�d�Z�d����Z�d����Z�e�e�e���Z�RS(���R|���R����c���������C���s ���|��j��d���S(���NR|���(���R����(���R���(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR|�����s����c���������C���s���|��j��d�|�f���S(���NR����(���R����(���R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR������s����(���R|���R����(���R$���R%���R����R|���R����R����R����(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR)����s��� t ���BaseListProxyt���__add__t���__contains__t���__delitem__t���__delslice__t���__getitem__t���__getslice__t���__len__t���__mul__t���__reversed__t���__rmul__t���__setitem__t���__setslice__R=���t���countt���extendt���indext���insertR��t���removet���reverseR����t���__imul__t ���ListProxyc�����������B���s���e��Z�d�����Z�d����Z�RS(���c���������C���s���|��j��d�|�f���|��S(���NR8��(���R����(���R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���__iadd__��s����c���������C���s���|��j��d�|�f���|��S(���NR=��(���R����(���R���R����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR=�� ��s����(���R$���R%���R?��R=��(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR>����s��� t ���DictProxyR��R����R����R|���t���has_keyt���popitemt ���setdefaultR ��t���Iteratort ���ArrayProxyt ���PoolProxyt���applyt���apply_asyncRm���t���imapt���imap_unorderedR����t���mapt ���map_asyncR����t���AsyncResultc�����������B���s���e��Z�d��Z�RS(���s(�� 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. (���R$���R%���R&���(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyR���C��s��� t���Queuet ���JoinableQueuet���Eventt���LockR[���t ���Semaphoret���BoundedSemaphoret ���ConditionR���R����R����R��R����R����(U���t���__all__t���osR���t���weakrefRZ���R���RN��R����R���t���multiprocessingR���R���R���R���R ���R ���t���multiprocessing.processR���t���multiprocessing.forkingR���R ���R���R���t���multiprocessing.utilR���R���t���cPickleR���t���ImportErrorR����R���R����R@���R2���R;���t ���view_typesR&��R���R1���R*���Rs���R5���RB���RD���RE���R����R_���R`���t���XmlListenert ���XmlClientRU���R����R����R����R���R��R��RW���Rh���R����R��R��R��R��R��R��R ��R"��R)��R*��R>��R@��R����RE��RF��R���RP��RQ��R[���RR��RS��RT��R����R����R����(����(����(����s0���/usr/lib64/python2.7/multiprocessing/managers.pyt���<module>$���s����." 4 ��, � �