OwlCyberSecurity - MANAGER
Edit File: util.cpython-310.opt-1.pyc
o ����S�g�6����������������������@���s���d�dl�Z�d�dlZd�dlZd�dlZd�dlZd�dlZd�dlmZ�ddlm Z �g�d�Z d�ZdZdZ dZd Zd ZdZdadad d��Zdd��Zdd��Zdd��Zdd��Zd?dd�Zdd��Zdd��Ze��Zdd��Zdd ��Ze���Z e�!��Z"d!d"��Z#d#d$��Z$i�Z%e�!��Z&G�d%d&��d&e'�Z(d?d'd(�Z)d)d*��Z*da+eee)e j,e j-fd+d,�Z.e�/e.��G�d-d.��d.e'�Z0G�d/d0��d0ej1�Z2ze��3d1�Z4W�n�e5y����d2Z4Y�nw�d3d4��Z6d5d6��Z7d7d8��Z8d9d:��Z9d;d<��Z:d=d>��Z;dS�)@�����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���� ���t�rt�jt|�g|�R����d�S�d�S��N)�_logger�logr�����msg�args��r ����;/opt/alt/python310/lib64/python3.10/multiprocessing/util.pyr���,��������r���c�����������������G���r���r���)r���r����DEBUGr���r ���r ���r!���r���0���r"���r���c�����������������G���r���r���)r���r����INFOr���r ���r ���r!���r���4���r"���r���c�����������������G���r���r���)r���r���r���r���r ���r ���r!���r���8���r"���r���c������������������C���s����ddl�}�|�����zAts<|��t�adt_ttd�r#t�t ��t� t ��n tj�t di�f��tj� t di�f��W�|�����tS�W�|�����tS�W�|�����tS�|�����w�)z0 Returns logger used by multiprocessing r���N� unregisterr ���)�loggingZ_acquireLockr���Z getLogger�LOGGER_NAMEZ propagate�hasattr�atexitr%����_exit_function�registerZ _exithandlers�remove�appendZ_releaseLock)r&���r ���r ���r!���r ���<���s(��� �� �r ���c�����������������C���sJ���ddl�}t��}|�t�}|���}|�|��|�|��|�r!|�|���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��� r ���c�������������������C���s ���t�jdkrdS�tt�d�rdS�dS�)NZlinuxTZgetandroidapilevelF)�sys�platformr(���r ���r ���r ���r!����#_platform_supports_abstract_socketsl���s ��� r3���c�����������������C���sD���|�sdS�t�|�t�r|�d�dkS�t�|�t�r|�d�dkS�td|��d���)NFr�����zaddress type of z unrecognized)� isinstance�bytes�str� TypeError)Zaddressr ���r ���r!����is_abstract_socket_namespacet���s��� r9���c�����������������C���s*���|�|��t����}|d�urd�|jd<�d�S�d�S�)N�tempdir)r����current_process�_config)�rmtreer:���r;���r ���r ���r!����_remove_temp_dir����s ����r>���c������������������C���sf���t����j�d�}�|�d�u�r1dd�l}dd�l}|jdd�}�td|���td�t |j |�fdd��|�t����jd<�|�S�)Nr:���r���zpymp-)�prefixzcreated temp directory %si����)r����exitpriority)r���r;���r<����get�shutil�tempfileZmkdtempr���r���r>���r=���)r:���rB���rC���r ���r ���r!���r�������s��� �r���c������������������C���sf���t�t����}�|�����|�D�]$\\}}}}z||��W�q�ty0�}�ztd|��W�Y�d�}~qd�}~ww�d�S�)Nz after forker raised exception %s)�list�_afterfork_registry�items�sort� Exceptionr���)rF����indexZident�func�obj�er ���r ���r!����_run_after_forkers����s������rM���c�����������������C���s���|�t�tt�t|��|f<�d�S�r���)rE����next�_afterfork_counter�id)rK���rJ���r ���r ���r!���r�������s���r���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�urt�|t�std�|t|����|d�urt�||��|�_n|d�u�r'td��||�_ ||�_ |p0i�|�_|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)r5����intr8����format�type�weakref�ref�_weakref� ValueError� _callback�_args�_kwargsrN����_finalizer_counter�_key�os�getpid�_pid�_finalizer_registry)�selfrK����callbackr����kwargsr@���r ���r ���r!����__init__����s ����� zFinalize.__init__c�����������������C���s����z||�j�=�W�n�ty���|d��Y�dS�w�|�j|��kr"|d��d}n|d|�j|�j|�j��|�j|�ji�|�j��}d�|�_�|�_�|�_�|�_|�_�|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)r\����KeyErrorr_���rX���rY���rZ���rV���)ra���Zwrr`���r���r^����resr ���r ���r!����__call__����s ������zFinalize.__call__c�����������������C���sD���zt�|�j=�W�n �ty���Y�dS�w�d�|�_�|�_�|�_�|�_|�_dS�)z3 Cancel finalization of the object N)r`���r\���re���rV���rX���rY���rZ����ra���r ���r ���r!����cancel����s�����zFinalize.cancelc�����������������C���s ���|�j�tv�S�)zS Return whether this finalizer is still waiting to invoke callback )r\���r`���rh���r ���r ���r!����still_active����s��� zFinalize.still_activec�������������� ���C���s����z|�����}W�n �ttfy���d�}Y�nw�|d�u�rd|�jj�S�d|�jjt|�jd|�j�f�}|�jr8|dt|�j��7�}|�j rD|dt|�j ��7�}|�j d�d�urV|dt|�j d���7�}|d�S�) Nz<%s object, dead>z<%s object, callback=%s�__name__z, args=z , kwargs=r���z, exitpriority=�>)rV����AttributeErrorr8���� __class__rk����getattrrX���rY���r7���rZ���r\���)ra���rK����xr ���r ���r!����__repr__����s$�����zFinalize.__repr__)r ���NN) rk���� __module__�__qualname__�__doc__rd���r`���r���r]���r^���rg���ri���rj���rq���r ���r ���r ���r!���r�������s���� �r���c�������������� ������s����t�du�rdS��du�rdd����n�fdd�����fdd�tt��D��}|jdd��|D�]'}t��|�}|durOtd |��z|���W�q(�tyN���d dl}|����Y�q(w�q(�du�rZt�����dS�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�uS��Nr���r �����pr ���r ���r!����<lambda>��s����z!_run_finalizers.<locals>.<lambda>c��������������������s���|�d�d�uo|�d���kS�ru���r ���rv���)�minpriorityr ���r!���rx����������c��������������������s���g�|�]}��|�r|�qS�r ���r ���)�.0�key)�fr ���r!���� <listcomp>#��rz���z#_run_finalizers.<locals>.<listcomp>T)�reversez calling %sr���) r`���rD���rG���rA���r���rH���� traceback� print_exc�clear)ry����keysr|���� finalizerr����r ���)r}���ry���r!����_run_finalizers��s*��� ���r����c�������������������C���s���t�pt�du�S�)z6 Returns true if the process is shutting down N)�_exitingr ���r ���r ���r!���r ���8��s���r ���c�����������������C���s����t�sBda�|�d��|d��|d��|��d�ur9|��D�]}|jr(|�d|j��|j����q|��D�]}|�d|j��|����q,|d��|���d�S�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_childrenr;���rw���r ���r ���r!���r*���@��s"��� � �r*���c�������������������@���s,���e�Zd�Zdd��Zdd��Zdd��Zdd��Zd S�) r���c�����������������C���s.���t����|�_|�jj|�_|�jj|�_t|�tj��d�S�r���)� threadingZLock�_lock�acquire�releaser���r����_at_fork_reinitrh���r ���r ���r!���rd���q��s��� zForkAwareThreadLock.__init__c�����������������C���s���|�j�����d�S�r���)r����r����rh���r ���r ���r!���r����w��s���z#ForkAwareThreadLock._at_fork_reinitc�����������������C���� ���|�j����S�r���)r����� __enter__rh���r ���r ���r!���r����z��s��� zForkAwareThreadLock.__enter__c�����������������G���s���|�j�j|��S�r���)r�����__exit__)ra���r���r ���r ���r!���r����}������zForkAwareThreadLock.__exit__N)rk���rr���rs���rd���r����r����r����r ���r ���r ���r!���r���p��s ����r���c�������������������@���s���e�Zd�Zdd��Zdd��ZdS�)r���c�����������������C���s���t�|�dd����d�S�)Nc�����������������S���r����r���)�__dict__r����)rK���r ���r ���r!���rx������s��� �z)ForkAwareLocal.__init__.<locals>.<lambda>)r���rh���r ���r ���r!���rd������s���zForkAwareLocal.__init__c�����������������C���s���t�|��dfS�)Nr ���)rS���rh���r ���r ���r!���� __reduce__���r����zForkAwareLocal.__reduce__N)rk���rr���rs���rd���r����r ���r ���r ���r!���r������s����r����SC_OPEN_MAX����c�����������������C���sN���t�|��dtg�}�|�����tt|��d��D�]}t�|�|�d�|�|d����qd�S�)N���r���)rD����MAXFDrG����range�lenr]���� closerange)�fds�ir ���r ���r!���r������s ����r���c��������������� ���C���s����t�jd�u�rd�S�zt�j����W�n�ttfy���Y�nw�zt�tjtj�}�zt|�ddd�t�_W�W�d�S����t�|������ttfyD���Y�d�S�w�)Nzutf-8F)�encoding�closefd) r1����stdin�close�OSErrorrW���r]����open�devnull�O_RDONLY)�fdr ���r ���r!����_close_stdin���s"��� � �r����c���������������� ���C���sP���zt�j����W�n�ttfy���Y�nw�zt�j����W�d�S��ttfy'���Y�d�S�w�r���)r1����stdout�flushrm���rW����stderrr ���r ���r ���r!����_flush_std_streams���s�����r����c�����������������C���s����dd�l�}tttt|���}t���\}}z(|�|t�|��gd|d�d�dddddd||ddd�d�d�dd��W�t� |��t� |��S�t� |��t� |��w�)Nr���Tr����F) �_posixsubprocess�tuple�sorted�maprQ���r]����pipeZ fork_exec�fsencoder����)�pathr���Zpassfdsr����Zerrpipe_readZ errpipe_writer ���r ���r!����spawnv_passfds���s���� �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) �testr����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����r���)<r]���� itertoolsr1���rT���r)���r����� subprocessr�����r����__all__ZNOTSETr���r#���r$���r���r'���r.���r���r/���r���r���r���r���r ���r ���r3���r9���Zabstract_sockets_supportedr>���r���ZWeakValueDictionaryrE����countrO���rM���r���r`���r[����objectr���r����r ���r����r����r;���r*���r+���r���Zlocalr����sysconfr����rH���r���r����r����r����r����r����r ���r ���r ���r!����<module>���sr��� V, � * �