OwlCyberSecurity - MANAGER
Edit File: util.cpython-38.pyc
U ����e5d~6����������������������@���s���d�dl�Z�d�dlZd�dlZd�dlZd�dlZd�dlZd�dlmZ�ddlm Z �ddddd d ddd ddddddgZ d�ZdZdZ dZdZdZdZdadadd��Zdd��Zdd��Zdd��Zdd ��Zd@d d �Zd!d"��Zd#d$��Ze��Zd%d&��Zd'd��Ze���Z e�!��Z"d(d)��Z#d*d��Z$i�Z%e�!��Z&G�d+d��de'�Z(dAd,d-�Z)d.d ��Z*da+eee)e j,e j-fd/d0�Z.e�/e.��G�d1d��de'�Z0G�d2d��dej1�Z2ze��3d3�Z4W�n�e5k �r����d4Z4Y�nX�d5d��Z6d6d7��Z7d8d9��Z8d:d;��Z9d<d=��Z:d>d?��Z;dS�)B�����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����� ������������multiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc�����������������G���s���t�rt�jt|�f|����d�S��N)�_logger�logr�����msg�args��r����,/usr/lib64/python3.8/multiprocessing/util.pyr���,���s����c�����������������G���s���t�rt�jt|�f|����d�S�r���)r���r����DEBUGr���r���r���r ���r���0���s����c�����������������G���s���t�rt�jt|�f|����d�S�r���)r���r����INFOr���r���r���r ���r���4���s����c�����������������G���s���t�rt�jt|�f|����d�S�r���)r���r���r���r���r���r���r ���r���8���s����c������������������C���s|���ddl�}�|�����z\tsj|��t�adt_ttd�rFt� t ��t�t ��n$tj� t di�f��tj�t di�f��W�5�|�����X�tS�)z0 Returns logger used by multiprocessing r���N� unregisterr���)�loggingZ_acquireLockZ_releaseLockr���Z getLogger�LOGGER_NAMEZ propagate�hasattr�atexitr#����_exit_function�registerZ _exithandlers�remove�append)r$���r���r���r ���r ���<���s���� c�����������������C���sJ���ddl�}t��}|�t�}|���}|�|��|�|��|�rB|�|���dat 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 ���W���s���� c�������������������C���s ���t�jdkrdS�tt�d�rdS�dS�)NZlinuxTZgetandroidapilevelF)�sys�platformr&���r���r���r���r ����#_platform_supports_abstract_socketsl���s ���� r1���c�����������������C���s@���|�sdS�t�|�t�r|�d�dkS�t�|�t�r4|�d�dkS�td��d�S�)NFr�����z(address type of {address!r} unrecognized)� isinstance�bytes�str� TypeError)Zaddressr���r���r ����is_abstract_socket_namespacet���s���� r7���c�����������������C���s&���|�|��t����}|d�k r"d�|jd<�d�S�)N�tempdir)r����current_process�_config)�rmtreer8���r9���r���r���r ����_remove_temp_dir����s����r<���c������������������C���sf���t����j�d�}�|�d�krbdd�l}dd�l}|jdd�}�td|���td�t |j |�fdd��|�t����jd<�|�S�)Nr8���r���zpymp-)�prefixzcreated temp directory %si����)r����exitpriority)r���r9���r:����get�shutil�tempfileZmkdtempr���r���r<���r;���)r8���r@���rA���r���r���r ���r�������s���� �c������������������C���sf���t�t����}�|�����|�D�]H\\}}}}z||��W�q�tk r^�}�ztd|��W�5�d�}~X�Y�qX�qd�S�)Nz after forker raised exception %s)�list�_afterfork_registry�items�sort� Exceptionr���)rD����indexZident�func�obj�er���r���r ����_run_after_forkers����s����rK���c�����������������C���s���|�t�tt�t|��|f<�d�S�r���)rC����next�_afterfork_counter�id)rI���rH���r���r���r ���r�������s����c�������������������@���sF���e�Zd�ZdZddd�Zdeeejfdd�Z dd ��Z d d��Zdd ��ZdS�)r���zA Class which supports object finalization using weakrefs r���Nc�����������������C���s����|d�k r&t�|t�s&td�|t|����|d�k r>t�||��|�_n|d�krNtd��||�_ ||�_ |p`i�|�_|tt �f|�_t���|�_|�t|�j<�d�S�)Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)r3����intr6����format�type�weakref�ref�_weakref� ValueError� _callback�_args�_kwargsrL����_finalizer_counter�_key�os�getpid�_pid�_finalizer_registry)�selfrI����callbackr����kwargsr>���r���r���r ����__init__����s"������� zFinalize.__init__c�����������������C���s����z||�j�=�W�n�tk r(���|d��Y�nbX�|�j|��krD|d��d}n$|d|�j|�j|�j��|�j|�j|�j�}d�|�_�|�_�|�_�|�_|�_�|S�dS�)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)rZ����KeyErrorr]���rV���rW���rX���rT���)r_���Zwrr^���r���r\����resr���r���r ����__call__����s$���������zFinalize.__call__c�����������������C���sD���zt�|�j=�W�n�tk r ���Y�n X�d�|�_�|�_�|�_�|�_|�_dS�)z3 Cancel finalization of the object N)r^���rZ���rc���rT���rV���rW���rX����r_���r���r���r ����cancel����s�������zFinalize.cancelc�����������������C���s ���|�j�tkS�)zS Return whether this finalizer is still waiting to invoke callback )rZ���r^���rf���r���r���r ����still_active����s����zFinalize.still_activec�������������� ���C���s����z|�����}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, exitpriority=�>)rT����AttributeErrorr6���� __class__ri����getattrrV���rW���r5���rX���rZ���)r_���rI����xr���r���r ����__repr__����s"���� �zFinalize.__repr__)r���NN) ri���� __module__�__qualname__�__doc__rb���r^���r���r[���r\���re���rg���rh���ro���r���r���r���r ���r�������s��� �� c�������������� ������s����t�dkrdS��dkrdd����n�fdd�����fdd�tt��D��}|jdd��|D�]P}t��|�}|dk rPtd |��z |���W�qP�tk r����d dl}|����Y�qPX�qP�dkr�t�����dS�)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�k S��Nr���r�����pr���r���r ����<lambda>�������z!_run_finalizers.<locals>.<lambda>c��������������������s���|�d�d�k o|�d���kS�rs���r���rt���)�minpriorityr���r ���rv�����rw���c��������������������s���g�|�]}��|�r|�qS�r���r���)�.0�key)�fr���r ���� <listcomp>#��s������z#_run_finalizers.<locals>.<listcomp>T)�reversez calling %sr���) r^���rB���rE���r?���r���rF���� traceback� print_exc�clear)rx����keysrz���� finalizerr~���r���)r{���rx���r ����_run_finalizers��s$���� r����c�������������������C���s���t�p t�dkS�)z6 Returns true if the process is shutting down N)�_exitingr���r���r���r ���r ���8��s����c�����������������C���s����t�s�da�|�d��|d��|d��|��d�k rr|��D�] }|jr0|�d|j��|j����q0|��D�]}|�d|j��|����qX|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)r����Zdaemon�nameZ_popenZ terminate�join)r���r���r�����active_childrenr9���ru���r���r���r ���r(���@��s���� r(���c�������������������@���s,���e�Zd�Zdd��Zdd��Zdd��Zdd��Zd S�) r���c�����������������C���s���|������t|�tj���d�S�r���)�_resetr���r���rf���r���r���r ���rb���q��s����zForkAwareThreadLock.__init__c�����������������C���s"���t����|�_|�jj|�_|�jj|�_d�S�r���)� threadingZLock�_lock�acquire�releaserf���r���r���r ���r����u��s���� zForkAwareThreadLock._resetc�����������������C���s ���|�j����S�r���)r����� __enter__rf���r���r���r ���r����z��s����zForkAwareThreadLock.__enter__c�����������������G���s���|�j�j|��S�r���)r�����__exit__)r_���r���r���r���r ���r����}��s����zForkAwareThreadLock.__exit__N)ri���rp���rq���rb���r����r����r����r���r���r���r ���r���p��s���c�������������������@���s���e�Zd�Zdd��Zdd��ZdS�)r���c�����������������C���s���t�|�dd����d�S�)Nc�����������������S���s ���|�j����S�r���)�__dict__r����)rI���r���r���r ���rv������rw���z)ForkAwareLocal.__init__.<locals>.<lambda>)r���rf���r���r���r ���rb������s����zForkAwareLocal.__init__c�����������������C���s���t�|��dfS�)Nr���)rQ���rf���r���r���r ���� __reduce__���s����zForkAwareLocal.__reduce__N)ri���rp���rq���rb���r����r���r���r���r ���r������s����SC_OPEN_MAX����c�����������������C���sb���t�|��dtg�}�|�����|�d�tks,td��tt|��d��D�] }t�|�|�d�|�|d����q<d�S�)N���zfd too larger���)rB����MAXFDrE����AssertionError�range�lenr[���� closerange)�fds�ir���r���r ���r������s ����c��������������� ���C���s����t�jd�krd�S�zt�j����W�n�ttfk r4���Y�nX�z@t�tjtj�}�zt|�dd�t�_W�n���t�|�����Y�nX�W�n�ttfk r����Y�nX�d�S�)NF)�closefd) r/����stdin�close�OSErrorrU���r[����open�devnull�O_RDONLY)�fdr���r���r ����_close_stdin���s���� r����c���������������� ���C���sT���zt�j����W�n�ttfk r&���Y�nX�zt�j����W�n�ttfk rN���Y�nX�d�S�r���)r/����stdout�flushrk���rU����stderrr���r���r���r ����_flush_std_streams���s����r����c�����������������C���sx���dd�l�}tttt|���}t���\}}z6|�|t� |��gd|d�d�dddddd||ddd��W��S�t�|��t�|��X�d�S�)Nr���Tr����F) �_posixsubprocess�tuple�sorted�maprO���r[����piper����Z fork_exec�fsencode)�pathr���Zpassfdsr����Zerrpipe_readZ errpipe_writer���r���r ����spawnv_passfds���s2����� �������������� r����c������������������G���s���|�D�]}t��|��qdS�)z/Close each file descriptor given as an argumentN)r[���r����)r����r����r���r���r ���� close_fds���s����r����c������������������C���sZ���ddl�m}��t����ddlm}�|j����ddlm}�|j ����t ���|�����|�����dS�)zKCleanup multiprocessing resources when multiprocessing tests completed.r���)�support)� forkserver)�resource_trackerN) Ztestr����r���Z_cleanupr���r����Z_forkserverZ_stopr����Z_resource_trackerr����Z gc_collectZ reap_children)r����r����r����r���r���r ����_cleanup_tests���s���� r����)N)N)<r[���� itertoolsr/���rR���r'���r����� subprocessr�����r����__all__ZNOTSETr���r!���r"���r���r%���r,���r���r-���r���r���r���r���r ���r ���r1���r7���Zabstract_sockets_supportedr<���r���ZWeakValueDictionaryrC����countrM���rK���r���r^���rY����objectr���r����r ���r����r����r9���r(���r)���r���Zlocalr����sysconfr����rF���r���r����r����r����r����r����r���r���r���r ����<module> ���s���������������� V ,� *