a
Z��^�6 c @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ddlm Z g d�Z
d Z dZ dZ
dZd Zd
Zd Zdad ad
d� Zdd� Zdd� Zdd� Zdd� Zd?dd�Zdd� Zdd � Ze� Z d d � Z d d � Z e� � 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*d a+eee)e j,e j-fd+d,�Z.e�/e.� G d-d.� d.e'�Z0G d/d0� d0ej1�Z2ze �3d1�Z4W n e5�y� d2Z4Y n0 d3d4� Z6d5d6� Z7d7d8� Z8d9d:� Z9d;d<� Z:d=d>� Z;dS )A� 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�
SUBWARNINGi i
i i �multiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc G � t rt jt| g|�R � d S �N)�_logger�logr �Zmsg�args� r �,/usr/lib64/python3.9/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 } | �� zdtsj| �t�adt_ttd�rFt�t � t�
t � n$tj � t di f� tj �
t di f� W | �� n
| �� 0 tS )z0
Returns logger used by multiprocessing
r N�
unregisterr )�loggingZ _acquireLockr Z getLogger� LOGGER_NAMEZ propagate�hasattr�atexitr �_exit_function�registerZ
_exithandlersZremoveZappendZ _releaseLock)r r r r r < s
r 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
StreamHandlerZ setFormatterZ
addHandlerZsetLevel�_log_to_stderrr )Zlevelr ZloggerZ formatterZhandlerr r r r W s
r c C s t jdkrdS tt d�r dS dS )NZlinuxTZgetandroidapilevelF)�sysZplatformr" r r r r �#_platform_supports_abstract_socketsl s
r) c C s@ | sdS t | t�r | d dkS t | t�r4| d dkS td��d S )NFr z z(address type of {address!r} unrecognized)�
isinstanceZbytes�str� TypeError)Zaddressr r r � is_abstract_socket_namespacet s
r- c C s& | |� t �� }|d ur"d |jd< d S )N�tempdir)r �current_process�_config)�rmtreer. r/ r r r �_remove_temp_dir� s r2 c C sf t �� j�d�} | d u rbdd l}dd l}|jdd�} td| � td t |j
| fdd� | t �� jd< | S )Nr. r zpymp-)Zprefixzcreated temp directory %si����)r � exitpriority) r r/ r0 �get�shutil�tempfileZmkdtempr r
r2 r1 )r. r5 r6 r r r r
� s
�r
c C sh t t�� �} | �� | D ]J\\}}}}z ||� W q ty` } ztd|� W Y d }~qd }~0 0 qd S )Nz after forker raised exception %s)�list�_afterfork_registry�items�sort� Exceptionr )r9 ZindexZident�func�objZer r r �_run_after_forkers� s r> c C s | t tt�t| �|f< d S r )r8 �next�_afterfork_counterZid)r= r< r r r r � � r c @ sF e Zd ZdZddd�Zdeeejfdd�Z dd � Z
d
d � Z d d
� Z dS )r
zA
Class which supports object finalization using weakrefs
r Nc C s� |d ur&t |t�s&td�|t|����|d ur>t�|| �| _n|d u rNtd��|| _ || _
|p`i | _ |t t
�f| _t�� | _| t| j< d S )Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)r* �intr, Zformat�type�weakrefZref�_weakref�
ValueError� _callback�_args�_kwargsr? �_finalizer_counter�_key�os�getpid�_pid�_finalizer_registry)�selfr= Zcallbackr Zkwargsr3 r r r �__init__� s ��
zFinalize.__init__c C s� z || j = W n ty& |d� Y nf0 | j|� krB|d� d}n(|d| j| j| j� | j| ji | j��}d | _ | _ | _ | _| _ |S dS )zQ
Run the callback unless it has already been called or cancelled
z finalizer no longer registeredz+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %s)rK �KeyErrorrN rG rH rI rE )rP ZwrrO r rM Zresr r r �__call__� s ��zFinalize.__call__c C sB z t | j= W n ty Y n 0 d | _ | _ | _ | _| _dS )z3
Cancel finalization of the object
N)rO rK rR rE rG rH rI �rP r r r �cancel� s ��zFinalize.cancelc C s
| j tv S )zS
Return whether this finalizer is still waiting to invoke callback
)rK rO rT r r r � still_active� � zFinalize.still_activec C s� z | � � }W n ttfy& d }Y n0 |d u r<d| jj S d| jjt| jd| j�f }| jrp|dt| j� 7 }| j r�|dt| j � 7 }| j
d d ur�|dt| j
d � 7 }|d S ) Nz<%s object, dead>z<%s object, callback=%s�__name__z, args=z , kwargs=r z, exitpriority=z>) rE �AttributeErrorr, Z __class__rX ZgetattrrG rH r+ rI rK )rP r= Zxr r r �__repr__� s"
�zFinalize.__repr__)r NN)
rX �
__module__� __qualname__Z__doc__rQ rO r rL rM rS rU rV rZ r r r r r
� s
�
r
c s� t du r dS �du r dd� � n �fdd�� � fdd�tt �D �}|jdd� |D ]N}t �|�}|durPtd |� z
|� W qP ty� d
dl}|�� Y qP0 qP�du r�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 uS �Nr r ��pr r r �<lambda> � z!_run_finalizers.<locals>.<lambda>c s | d d uo| d � kS r] r r^ )� minpriorityr r r` ra c s g | ]}� |�r|�qS r r )Z.0�key)�fr r Z
<listcomp># ra z#_run_finalizers.<locals>.<listcomp>T)Zreversez
calling %sr ) rO r7 r: r4 r r; � tracebackZ print_exc�clear)rb Zkeysrc Z finalizerre r )rd rb r �_run_finalizers s$
rg c C s t p
t du S )z6
Returns true if the process is shutting down
N)�_exitingr r r r r 8 rW r c C s� t s�da | d� |d� |d� |� d urr|� 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 %sz calling join() for process %sz)running the remaining "atexit" finalizers)rh ZdaemonZnameZ_popenZ terminateZjoin)r r rg �active_childrenr/ r_ 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�_lockZacquireZreleaser r �_at_fork_reinitrT r r r rQ q s
z ForkAwareThreadLock.__init__c C s | j �� d S r )rk rl rT r r r rl w rA z#ForkAwareThreadLock._at_fork_reinitc C �
| j �� S r )rk � __enter__rT r r r rn z rA z ForkAwareThreadLock.__enter__c G s | j j|� S r )rk �__exit__)rP r r r r ro } rA z ForkAwareThreadLock.__exit__N)rX r[ r\ rQ rl rn ro 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 rm r )Z__dict__rf )r= r r r r` � ra z)ForkAwareLocal.__init__.<locals>.<lambda>)r rT r r r rQ � rA zForkAwareLocal.__init__c C s t | �dfS )Nr )rC rT r r r �
__reduce__� rA zForkAwareLocal.__reduce__N)rX r[ r\ rQ rp r r r r r � s r Z SC_OPEN_MAXi c C sN t | �dtg } | �� tt| �d �D ] }t�| | d | |d � q(d S )N�����r )r7 �MAXFDr: ZrangeZlenrL Z
closerange)�fdsZir r r r � s r c C s� t jd u rd S zt j�� W n ttfy2 Y n0 z@t�tjtj�} zt| dd�t _W n t�| � � Y n0 W n ttfy� Y n0 d S )NF)Zclosefd) r( Zstdin�closeZOSErrorrF rL ZopenZdevnullZO_RDONLY)�fdr r r � _close_stdin� s
rv c C sP zt j�� W n ttfy$ Y n0 zt j�� W n ttfyJ Y n0 d S r )r( ZstdoutZflushrY rF Zstderrr r r r �_flush_std_streams� s rw c C s� dd l }tttt|���}t�� \}}zP|�|t�| �gd|d d dddddd||ddd d d dd �W t� |� t� |� S t� |� t� |� 0 d S )Nr Trq F)
�_posixsubprocessZtupleZsortedZmaprB rL ZpipeZ fork_execZfsencodert )Zpathr Zpassfdsrx Z errpipe_readZ
errpipe_writer r r �spawnv_passfds� s �
� �
ry c G s | D ]}t �|� qdS )z/Close each file descriptor given as an argumentN)rL rt )rs ru r r r � close_fds� s rz 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_trackerrg Z
gc_collectZ
reap_children)r{ r| r} r r r �_cleanup_tests� s
r~ r r )<rL Z itertoolsr( rD r# rj Z
subprocessr Z r Z__all__ZNOTSETr r r r r! r& r r' r r r r r r r) r- Zabstract_sockets_supportedr2 r
ZWeakValueDictionaryr8 Zcountr@ r> r rO rJ Zobjectr
rg r rh ri r/ r$ r% r Zlocalr Zsysconfrr r; r rv rw ry rz r~ r r r r Z<module>
sn
V
,�
*