Edit File: util.cpython-36.opt-2.pyc
3 � \n.������������������@���s���d�dl�Z�d�dlZd�dlZd�dlZd�dlZd�dlZd�dlmZ�ddlm Z �ddddd d ddd ddddddgZ d�ZdZdZ dZdZdZdZdadadd��Zdd��Zdd��Zdd��Zdd ��Zd6d d �Zd!d��Zej��Zej��Zd"d#��Zd$d��Z i�Z!ej��Z"G�d%d��de#�Z$d7d&d'�Z%d(d ��Z&da'eee%e j(e j)fd)d*�Z*ej+e*��G�d+d��de#�Z,G�d,d��dej-�Z.ye�j/d-�Z0W�n�e1k �r����d.Z0Y�nX�d/d��Z2d0d1��Z3d2d3��Z4d4d5��Z5dS�)8�����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�rt�jt|�f|����d�S�)N)�_logger�logr���)�msg�args��r����,/usr/lib64/python3.6/multiprocessing/util.pyr���,���s����c�������������G���s���t�rt�jt|�f|����d�S�)N)r���r����DEBUG)r���r���r���r���r���r���0���s����c�������������G���s���t�rt�jt|�f|����d�S�)N)r���r����INFO)r���r���r���r���r���r���4���s����c�������������G���s���t�rt�jt|�f|����d�S�)N)r���r���r���)r���r���r���r���r���r���8���s����c����������� ���C���s|���dd�l�}�|�j���z\tsj|�jt�adt_ttd�rFtjt ��tj t ��n$tjjt f�i�f��tjj t f�i�f��W�d�|�j���X�tS�)Nr���� 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���dd�l�}t��}|jt�}|j��}|j|��|j|��|�rB|j|���dat S�)Nr���T) r!���r ���Z Formatter�DEFAULT_LOGGING_FORMATZ StreamHandlerZsetFormatterZ addHandlerZsetLevel�_log_to_stderrr���)�levelr!���ZloggerZ formatterZhandlerr���r���r���r ���W���s���� c��������������C���sd���t�j��jjd�}�|�d�kr`dd�l}dd�l}|jdd�}�td|���td�|j |�gdd��|�t�j��jd<�|�S�) N�tempdirr���zpymp-)�prefixzcreated temp directory %s�d���)r����exitpriorityi����) r����current_processZ_config�get�shutil�tempfileZmkdtempr���r���Zrmtree)r,���r2���r3���r���r���r���r���m���s���� c��������������C���sj���t�tj���}�|�j���xP|�D�]H\\}}}}y||��W�q�tk r`�}�ztd|��W�Y�d�d�}~X�qX�qW�d�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�tt�t|��|f<�d�S�)N)r5����next�_afterfork_counter�id)r;���r:���r���r���r���r�������s����c���������������@���sH���e�Zd�Zf�ddfdd�Zdeeejfdd�Zdd��Z dd ��Z d d��ZdS�)r���Nc�������������C���sT���|d�k rt�j||��|�_n�||�_||�_|p*i�|�_|tt�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�=�W�n�tk r(���|d��Y�nbX�|�j|��krD|d��d�}n$|d|�j|�j|�j��|�j|�j|�j�}d��|�_�|�_�|�_�|�_|�_�|S�d�S�)Nzfinalizer no longer registeredz+finalizer ignored because different processz/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���sD���yt�|�j=�W�n�tk r ���Y�n X�d��|�_�|�_�|�_�|�_|�_d�S�)N)rL���rH���rQ���rC���rD���rE���rF���)rM���r���r���r����cancel����s ����zFinalize.cancelc�������������C���s ���|�j�tkS�)N)rH���rL���)rM���r���r���r����still_active����s����zFinalize.still_activec�������������C���s����y|�j���}W�n�ttfk r(���d�}Y�nX�|d�kr>d|�jj�S�d|�jjt|�jd|�j�f�}|�jrr|dt|�j��7�}|�j r�|dt|�j ��7�}|�j d�d�k r�|dt|�j d���7�}|d�S�) Nz<%s object, dead>z<%s object, callback=%s�__name__z, args=z , kwargs=r���z, exitprority=�>)rC����AttributeError� TypeError� __class__rW����getattrrD���rE����strrF���rH���)rM���r;����xr���r���r����__repr__����s ���� zFinalize.__repr__)rW���� __module__�__qualname__rP���rL���r���rI���rJ���rT���rU���rV���r_���r���r���r���r���r�������s���c����������������s����t�d�krd�S��d�krdd����n�fdd�����fdd�tt��D��}|jdd��xX|D�]P}t�j|�}|d�k rRtd|��y |���W�qR�tk r����d d�l}|j���Y�qRX�qRW��d�kr�t�j���d�S�) Nc�������������S���s���|�d�d�k S�)Nr���r���)�pr���r���r����<lambda>����s����z!_run_finalizers.<locals>.<lambda>c����������������s���|�d�d�k o|�d���kS�)Nr���r���)rb���)�minpriorityr���r���rc�������s����c����������������s���g�|�]}��|�r|�qS�r���r���)�.0�key)�fr���r���� <listcomp>����s����z#_run_finalizers.<locals>.<listcomp>T)�reversez calling %sr���) rL���r4���r7���r1���r���r8���� traceback� print_exc�clear)rd����keysrf���� finalizerrj���r���)rg���rd���r����_run_finalizers����s$���� ro���c���������������C���s���t�p t�d�kS�)N)�_exitingr���r���r���r���r �����s����c�������������C���s����t�s�da�|�d��|d��|d��|��d�k rzx*|��D�] }|jr2|�d|j��|jj���q2W�x"|��D�]}|�d|j��|j���q^W�|d��|���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)rp���Zdaemon�nameZ_popenZ terminate�join)r���r���ro����active_childrenr0���rb���r���r���r���r%�����s���� r%���c���������������@���s,���e�Zd�Zdd��Zdd��Zdd��Zdd��Zd S�) r���c�������������C���s���|�j����t|�tj���d�S�)N)�_resetr���r���)rM���r���r���r���rP���K��s����zForkAwareThreadLock.__init__c�������������C���s"���t�j��|�_|�jj|�_|�jj|�_d�S�)N)� threadingZLock�_lock�acquire�release)rM���r���r���r���rt���O��s���� zForkAwareThreadLock._resetc�������������C���s ���|�j�j��S�)N)rv���� __enter__)rM���r���r���r���ry���T��s����zForkAwareThreadLock.__enter__c�������������G���s���|�j�j|��S�)N)rv����__exit__)rM���r���r���r���r���rz���W��s����zForkAwareThreadLock.__exit__N)rW���r`���ra���rP���rt���ry���rz���r���r���r���r���r���J��s���c���������������@���s���e�Zd�Zdd��Zdd��ZdS�)r���c�������������C���s���t�|�dd����d�S�)Nc�������������S���s ���|�j�j��S�)N)�__dict__rl���)r;���r���r���r���rc���]��s����z)ForkAwareLocal.__init__.<locals>.<lambda>)r���)rM���r���r���r���rP���\��s����zForkAwareLocal.__init__c�������������C���s���t�|��f�fS�)N)�type)rM���r���r���r���� __reduce__^��s����zForkAwareLocal.__reduce__N)rW���r`���ra���rP���r}���r���r���r���r���r���[��s����SC_OPEN_MAX����c�������������C���sR���t�|��dtg�}�|�j���x4tt|��d��D�] }tj|�|�d�|�|d����q*W�d�S�)Nr������)r4����MAXFDr7����range�lenrI���� closerange)Zfds�ir���r���r���r���j��s����c��������������C���s����t�jd�krd�S�yt�jj���W�n�ttfk r4���Y�nX�y@tjtjtj�}�yt|�dd�t�_W�n���tj|�����Y�nX�W�n�ttfk r����Y�nX�d�S�)NF)�closefd) �sys�stdin�close�OSError� ValueErrorrI����open�devnull�O_RDONLY)�fdr���r���r����_close_stdint��s���� r����c���������������C���sT���yt�jj���W�n�ttfk r&���Y�nX�yt�jj���W�n�ttfk rN���Y�nX�d�S�)N)r�����stdout�flushrY���r�����stderrr���r���r���r����_flush_std_streams���s����r����c�������������C���st���dd�l�}tttt|���}tj��\}}z2|j|tj|��gd|d�d�ddddd d ||ddd��S�tj |��tj |��X�d�S�)Nr���Tr���Fr����r����r����r����r����r����) �_posixsubprocess�tuple�sorted�map�intrI����pipeZ fork_exec�fsencoder����)�pathr���Zpassfdsr����Zerrpipe_readZ errpipe_writer���r���r����spawnv_passfds���s���� r����)N)N)6rI���� itertoolsr����rA���r$���ru���� 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���ro���r ���rp���rs���r0���r%���r&���r���Zlocalr����sysconfr����r8���r���r����r����r����r���r���r���r����<module> ���sf��� S ,(