| Server IP : 127.0.0.1 / Your IP : 216.73.216.109 Web Server : Apache/2.4.54 (Win64) OpenSSL/1.1.1q PHP/8.1.10 System : Windows NT DESKTOP-E5T4RUN 10.0 build 19045 (Windows 10) AMD64 User : SERVERWEB ( 0) PHP Version : 8.1.10 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/cygwin64/lib/python3.7/multiprocessing/__pycache__/ |
Upload File : |
B
T-�al5 � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ddlm Z ddddd d
d d d
ddddddgZ
d Z dZ dZ
dZdZdZdZdadadd� Zd d� Zd d� Zd d� Zd d � Zd>d d
�Zd!d"� Zd#d$� 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� de'�Z(d?d,d-�Z)d.d
� Z*da+eee)e j,e j-fd/d0�Z.e�/e.� G d1d� de'�Z0G d2d� dej1�Z2ye �3d3�Z4W n e5k
�r� d4Z4Y nX d5d� Z6d6d7� Z7d8d9� Z8d:d;� Z9d<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 s t rt jt| f|�� d S )N)�_logger�logr )�msg�args� r �*/usr/lib/python3.7/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 } | �� z\tsj| �t�adt_ttd�rFt�t � t�
t � n$tj � t di f� tj �
t di f� W d | �� X tS )Nr �
unregisterr )�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� }|�t�}|�� }|�|� |�|� | rB|�| � dat S )Nr T)
r" r Z Formatter�DEFAULT_LOGGING_FORMATZ
StreamHandlerZ setFormatterZ
addHandlerZsetLevel�_log_to_stderrr )�levelr" Zlogger� formatterZhandlerr r r r
W s
c C s t jdkrdS tt d�r dS dS )NZlinuxTZgetandroidapilevelF)�sys�platformr$ r r r r �#_platform_supports_abstract_socketsl s
r0 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
r6 c C s& | |� t �� }|d k r"d |jd< d S )N�tempdir)r �current_process�_config)�rmtreer7 r8 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 )Nr7 r zpymp-)�prefixzcreated temp directory %si����)r � exitpriority) r r8 r9 �get�shutil�tempfileZmkdtempr r r; r: )r7 r? r@ r r r r � s
c C sj t t�� �} | �� xP| D ]H\\}}}}y ||� W q tk
r` } ztd|� W d d }~X Y qX qW d S )Nz after forker raised exception %s)�list�_afterfork_registry�items�sort� Exceptionr )rC �indexZident�func�obj�er r r �_run_after_forkers� s rJ c C s | t tt�t| �|f< d S )N)rB �next�_afterfork_counter�id)rH rG r r r r � s c @ sB e Zd Zd
dd�Zdeeejfdd�Zdd� Z d d
� Z
d d � Z dS )r r Nc C s� |d k r&t |t�s&td�|t|����|d k r>t�|| �| _n|d krNtd��|| _ || _
|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)r2 �intr5 �format�type�weakref�ref�_weakref�
ValueError� _callback�_args�_kwargsrK �_finalizer_counter�_key�os�getpid�_pid�_finalizer_registry)�selfrH �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 )Nz finalizer no longer registeredz+finalizer ignored because different processz/finalizer calling %s with args %s and kwargs %s)rY �KeyErrorr\ rU rV rW rS )r^ Zwrr] r r[ Zresr r r �__call__� s zFinalize.__call__c C sD y t | j= W n tk
r Y n X d | _ | _ | _ | _| _d S )N)r] rY rb rS rU rV rW )r^ r r r �cancel� s
zFinalize.cancelc C s
| j tkS )N)rY r] )r^ r r r � still_active� s zFinalize.still_activec C s� y | � � }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=�>) rS �AttributeErrorr5 � __class__rf �getattrrU rV r4 rW rY )r^ rH �xr r r �__repr__� s
zFinalize.__repr__)r NN) rf �
__module__� __qualname__ra r] r rZ r[ rc rd re rl r r r r r � s
c s� t d kr d S �d kr dd� � n �fdd�� � fdd�tt �D �}|jdd� xX|D ]P}t �|�}|d k rRtd|� y
|� W qR tk
r� d d l}|�� Y qRX qRW �d kr�t �� d S )
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 )Nr r )ro )� minpriorityr r rp rq c s g | ]}� |�r|�qS r r )�.0�key)�fr r �
<listcomp># s z#_run_finalizers.<locals>.<listcomp>T)�reversez
calling %sr ) r] rA rD r> r rE � traceback� print_exc�clear)rr �keysrt � finalizerrx r )ru rr r �_run_finalizers s$
r} c C s t p
t d kS )N)�_exitingr r r r r
8 s c C s� t s�da | d� |d� |d� |� d k rzx*|� D ] }|jr2| d|j� |j�� q2W x"|� D ]}| d|j� |�� q^W |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)r~ Zdaemon�nameZ_popenZ terminate�join)r r r} �active_childrenr8 ro r r r r& @ s
r& c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
r c C s | � � t| tj � d S )N)�_resetr r )r^ r r r ra q s z ForkAwareThreadLock.__init__c C s" t �� | _| jj| _| jj| _d S )N)� threadingZLock�_lock�acquire�release)r^ r r r r� u s
zForkAwareThreadLock._resetc C s
| j �� S )N)r� � __enter__)r^ r r r r� z s z ForkAwareThreadLock.__enter__c G s | j j|� S )N)r� �__exit__)r^ r r r r r� } s z ForkAwareThreadLock.__exit__N)rf rm rn ra 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 )N)�__dict__rz )rH r r r rp � rq z)ForkAwareLocal.__init__.<locals>.<lambda>)r )r^ r r r ra � s zForkAwareLocal.__init__c C s t | �dfS )Nr )rP )r^ r r r �
__reduce__� s zForkAwareLocal.__reduce__N)rf rm rn ra r� r r r r r � s � SC_OPEN_MAX� c C sR t | �dtg } | �� x4tt| �d �D ] }t�| | d | |d � q*W d S )N���r )rA �MAXFDrD �range�lenrZ �
closerange)Zfds�ir r r r � s c C s� t jd krd S yt j�� W n ttfk
r4 Y nX y@t�tjtj�} yt| dd�t _W n t�| � � Y nX W n ttfk
r� Y nX d S )NF)�closefd) r. �stdin�close�OSErrorrT rZ �open�devnull�O_RDONLY)�fdr r r � _close_stdin� s
r� c C sT yt j�� W n ttfk
r& Y nX yt j�� W n ttfk
rN Y nX d S )N)r. �stdout�flushrh rT �stderrr r r r �_flush_std_streams� s r� c C st dd l }tttt|���}t�� \}}z2|�|t�| �gd|d d dddddd||ddd �S t� |� t� |� X d S )Nr Tr� F)
�_posixsubprocess�tuple�sorted�maprN rZ �pipeZ fork_exec�fsencoder� )�pathr Zpassfdsr� Z errpipe_readZ
errpipe_writer r r �spawnv_passfds� s
r� c C sD ddl m} t�� ddlm} |j�� t� | � � | �
� d S )Nr )�support)�
forkserver) Ztestr� r Z_cleanupr r� Z _forkserverZ_stopr} Z
gc_collectZ
reap_children)r� r� r r r �_cleanup_tests� s
r� )N)N);rZ � itertoolsr. rQ r% r� �
subprocessr � r �__all__ZNOTSETr r r r r# r* r r+ r r r r r r
r0 r6 Zabstract_sockets_supportedr; r ZWeakValueDictionaryrB �countrL rJ r r] rX �objectr r} r
r~ r� r8 r& r' r Zlocalr �sysconfr� rE r r� r� r� r� r r r r �<module>
sp
V
,(