����JFIF���������
1#@!#!123s
D7net
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
alt
/
python34
/
lib64
/
python3.4
/
multiprocessing
/
__pycache__
/
Filename :
util.cpython-34.pyo
back
Copy
� e f{)������������������@���s<��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�d�d�d�d�d �d �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�d�a�d�a�d�d����Z�d�d����Z�d�d����Z�d�d����Z�d�d ����Z�d�d �d ���Z�d!�d����Z�e�j����Z�e�j����Z�d"�d#����Z�d$�d����Z�i��Z �e�j����Z!�Gd%�d����d�e"���Z#�d�d&�d'���Z$�d(�d ����Z%�d�a&�e�e�e$�e�j'�e�j(�d)�d*���Z)�e�j*�e)���Gd+�d����d�e"���Z+�Gd,�d����d�e�j,���Z-�y�e��j.�d-���Z/�Wn�e0�k �rd.�Z/�Yn�Xd/�d����Z1�d0�d1����Z2�d�S)2�����N)�_args_from_interpreter_flags����)�process� sub_debug�debug�info�sub_warning� get_logger� log_to_stderr�get_temp_dir�register_after_fork� is_exiting�Finalize�ForkAwareThreadLock�ForkAwareLocal�close_all_fds_except�SUBDEBUG� SUBWARNING����� �����������Zmultiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc�������������G���s ���t��r�t��j�t�|��|���n��d��S)N)�_logger�logr���)�msg�args��r����9/opt/alt/python34/lib64/python3.4/multiprocessing/util.pyr���+���s����c�������������G���s ���t��r�t��j�t�|��|���n��d��S)N)r���r����DEBUG)r���r���r���r���r���r���/���s����c�������������G���s ���t��r�t��j�t�|��|���n��d��S)N)r���r����INFO)r���r���r���r���r���r���3���s����c�������������G���s ���t��r�t��j�t�|��|���n��d��S)N)r���r���r���)r���r���r���r���r���r���7���s����c����������� ���C���s����d�d�l��}��|��j����z��t�s��|��j�t���a�d�t�_�t�t�d���rc�t�j�t ���t�j �t ���q��t�j�j�t �f��i��f���t�j�j �t �f��i��f���n��Wd�|��j����Xt�S)z0 Returns logger used by multiprocessing r���N� unregister)�loggingZ_acquireLockr���Z getLogger�LOGGER_NAMEZ propagate�hasattr�atexitr ����_exit_function�registerZ _exithandlers�remove�appendZ_releaseLock)r!���r���r���r���r ���;���s���� c�������������C���sj���d�d�l��}�t����}�|�j�t���}�|�j����}�|�j�|���|�j�|���|��r`�|�j�|����n��d�a�t �S)zB Turn on logging and add a handler which prints to stderr r���NT) r!���r ���Z Formatter�DEFAULT_LOGGING_FORMATZ StreamHandlerZsetFormatterZ addHandlerZsetLevel�_log_to_stderrr���)�levelr!���ZloggerZ formatterZhandlerr���r���r���r ���V���s���� c��������������C���s����t��j����j�j�d���}��|��d��k�r��d�d��l�}�d�d��l�}�|�j�d�d���}��t�d�|����t�d��|�j �d�|��g�d�d ��|��t��j����j�d�<n��|��S) N�tempdirr����prefixzpymp-zcreated temp directory %sr����exitpriority�d���i����) r����current_processZ_config�get�shutil�tempfileZmkdtempr���r���Zrmtree)r,���r2���r3���r���r���r���r���l���s���� c��������������C���s����t��t�j������}��|��j����x`�|��D]X�\�\�}�}�}�}�y�|�|���Wq#�t�k �rz�}�z�t�d�|���WYd��d��}�~�Xq#�Xq#�Wd��S)Nz after forker raised exception %s)�list�_afterfork_registry�items�sort� Exceptionr���)r6����indexZident�func�obj�er���r���r����_run_after_forkers~���s���� r=���c�������������C���s#���|��t��t�t���t�|����|�f�<d��S)N)r5����next�_afterfork_counter�id)r;���r:���r���r���r���r�������s����c���������������@���sj���e��Z�d��Z�d�Z�f��d�d�d�d���Z�d�e�e�e�j�d�d���Z �d�d����Z �d �d ����Z�d�d����Z�d�S) r���zA Class which supports object finalization using weakrefs Nc�������������C���sz���|�d��k �r$�t��j�|�|����|��_�n��|�|��_�|�|��_�|�p?�i��|��_�|�t�t���f�|��_�t �j ����|��_�|��t�|��j�<d��S)N) �weakref�ref�_weakref� _callback�_args�_kwargsr>����_finalizer_counter�_key�os�getpid�_pid�_finalizer_registry)�selfr;����callbackr����kwargsr.���r���r���r����__init__����s���� zFinalize.__init__c���������� ���C���s����y�|�|��j��=Wn�t�k �r,�|�d���Yn��X|��j�|����k�rR�|�d���d�}�n4�|�d�|��j�|��j�|��j���|��j�|��j�|��j����}�d�|��_�|��_�|��_�|��_�|��_��|�Sd�S)zQ Run the callback unless it has already been called or cancelled zfinalizer no longer registeredz+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %s)rH����KeyErrorrK���rD���rE���rF���rC���)rM����wrrL���r���rJ����resr���r���r����__call__����s���� %zFinalize.__call__c�������������C���sL���y�t��|��j�=Wn�t�k �r"�Yn&�Xd�|��_�|��_�|��_�|��_�|��_�d�S)z3 Cancel finalization of the object N)rL���rH���rQ���rC���rD���rE���rF���)rM���r���r���r����cancel����s ���� zFinalize.cancelc�������������C���s ���|��j��t�k�S)zS Return whether this finalizer is still waiting to invoke callback )rH���rL���)rM���r���r���r����still_active����s����zFinalize.still_activec���������� ���C���s����y�|��j�����}�Wn�t�t�f�k �r0�d��}�Yn�X|�d��k�rA�d�Sd�t�|��j�d�|��j���}�|��j�r��|�d�t�|��j���7}�n��|��j�r��|�d�t�|��j���7}�n��|��j�d�d��k �r��|�d�t�|��j�d���7}�n��|�d�S) Nz<Finalize object, dead>z<Finalize object, callback=%s�__name__z, args=z , kwargs=r���z, exitprority=�>) rC����AttributeError� TypeError�getattrrD���rE����strrF���rH���)rM���r;����xr���r���r����__repr__����s���� zFinalize.__repr__) rW���� __module__�__qualname__�__doc__rP���rL���r���rI���rJ���rT���rU���rV���r^���r���r���r���r���r�������s���c����������������s����t��d�k�r�d�S��d�k�r+�d�d�������n���f�d�d����������f�d�d����t�t��j������D��}�|�j�d�d���xW�|�D]O�\�}�}�t�d �|���y�|����Wqy�t�k �r��d �d�l�}�|�j����Yqy�Xqy�W��d�k�r��t��j����n��d�S)z� Run all finalizers whose exit priority is not None and at least minpriority Finalizers with highest priority are called first; finalizers with the same priority will be called in reverse order of creation. Nc�������������S���s���|��d�d�d��k �S)Nr���r���)�pr���r���r����<lambda>����s����z!_run_finalizers.<locals>.<lambda>c����������������s&���|��d�d�d��k �o%�|��d�d����k�S)Nr���r���)rb���)�minpriorityr���r���rc�������s����c����������������s"���g��|��]�}����|���r�|���q�Sr���r���)�.0r]���)�fr���r���� <listcomp>����s��� �z#_run_finalizers.<locals>.<listcomp>�reverseTz calling %sr���) rL���r4���r6���r7���r���r8���� traceback� print_exc�clear)rd���r6����keyZ finalizerri���r���)rf���rd���r����_run_finalizers����s ����% rm���c���������������C���s���t��p�t��d�k�S)z6 Returns true if the process is shutting down N)�_exitingr���r���r���r���r �����s����c�������������C���s����t��s��d�a��|��d���|�d���|�d���|����d��k �r��x:�|����D]/�}�|�j�rC�|��d�|�j���|�j�j����qC�qC�Wx.�|����D] �}�|��d�|�j���|�j����q��Wn��|�d���|����n��d��S)NTzprocess shutting downz2running all "atexit" finalizers with priority >= 0r���z!calling terminate() for daemon %szcalling join() for process %sz)running the remaining "atexit" finalizers)rn���Zdaemon�nameZ_popenZ terminate�join)r���r���rm����active_childrenr0���rb���r���r���r���r%�����s���� r%���c���������������@���s(���e��Z�d��Z�d�d����Z�d�d����Z�d�S)r���c�������������C���s���|��j�����t�|��t�j����d��S)N)�_resetr���r���)rM���r���r���r���rP���A��s���� zForkAwareThreadLock.__init__c�������������C���s1���t��j����|��_�|��j�j�|��_�|��j�j�|��_�d��S)N)� threadingZLock�_lock�acquire�release)rM���r���r���r���rr���E��s����zForkAwareThreadLock._resetN)rW���r_���r`���rP���rr���r���r���r���r���r���@��s���c���������������@���s(���e��Z�d��Z�d�d����Z�d�d����Z�d�S)r���c�������������C���s���t��|��d�d������d��S)Nc�������������S���s ���|��j��j����S)N)�__dict__rk���)r;���r���r���r���rc���L��s����z)ForkAwareLocal.__init__.<locals>.<lambda>)r���)rM���r���r���r���rP���K��s����zForkAwareLocal.__init__c�������������C���s���t��|����f��f�S)N)�type)rM���r���r���r���� __reduce__M��s����zForkAwareLocal.__reduce__N)rW���r_���r`���rP���ry���r���r���r���r���r���J��s����SC_OPEN_MAX����c�������������C���se���t��|����d�t�g�}��|��j����x>�t�t�|����d���D]&�}�t�j�|��|�d�|��|�d���q7�Wd��S)Nr������)r4����MAXFDr7����range�lenrI���� closerange)Zfds�ir���r���r���r���Y��s���� c�������������C���s����d�d��l��}�t�|���}�t�j����\�}�}�zM�|�j�|�t�j�|����g�d�|�d��d��d�d�d�d�d �d �|�|�d�d�d����SWd��t�j�|���t�j�|���Xd��S)Nr���Tr���Fr|���r|���r|���r|���r|���r|���)�_posixsubprocess�sortedrI����pipeZ fork_exec�fsencode�close)�pathr���Zpassfdsr����Zerrpipe_readZ errpipe_writer���r���r����spawnv_passfdsd��s���� r����)3rI���� itertoolsrA���r$���rs���� subprocessr�����r����__all__ZNOTSETr���r���r���r���r"���r)���r���r*���r���r���r���r���r ���r ���r����WeakValueDictionaryr5����countr?���r=���r���rL���rG����objectr���rm���r ���rn���rq���r0���r%���r&���r���Zlocalr����sysconfr}���r8���r���r����r���r���r���r����<module> ���s`��� R$ (