File: //usr/local/lib/python3.10/asyncio/__pycache__/unix_events.cpython-310.opt-2.pyc
o
�i�� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z ddl m
Z
ddl mZ ddl mZ ddl mZ ddl mZ ddl mZ dd l mZ dd
l mZ dd l mZ dd l mZ dd
lmZ dZe jdkr~ed��dd� Z dd� Z G dd� dej �Z G dd� dej �Z!G dd� dej"ej#�Z$G dd � d ej%�Z&G d d � d �Z'G d d � d e'�Z(G d!d"� d"e'�Z)G d#d$� d$e)�Z*G d%d&� d&e)�Z+G d'd(� d(e'�Z,G d)d*� d*e'�Z-G d+d,� d,ej.�Z/e Z0e/Z1dS )-� N� )� base_events)�base_subprocess)� constants)�
coroutines)�events)�
exceptions)�futures)�selector_events)�tasks)�
transports)�logger)�SelectorEventLoop�AbstractChildWatcher�SafeChildWatcher�FastChildWatcher�PidfdChildWatcher�MultiLoopChildWatcher�ThreadedChildWatcher�DefaultEventLoopPolicy�win32z+Signals are not really supported on Windowsc C s d S �N� )�signum�framer r �0/usr/local/lib/python3.10/asyncio/unix_events.py�_sighandler_noop* s r c C s$ zt �| �W S ty | Y S w r )�os�waitstatus_to_exitcode�
ValueError)�statusr r r r / s
�r c s� e Zd Z d(� fdd� Z� fdd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z d)dd�Z
d)dd�Z d(dd�Z dd� Z
d(ddddd�dd�Z d(ddddd d �d d �Zd d!� Zd"d#� Zd$d%� Zd&d'� Z� ZS )*�_UnixSelectorEventLoopNc s t � �|� i | _d S r )�super�__init__�_signal_handlers)�self�selector�� __class__r r r# ? �
z _UnixSelectorEventLoop.__init__c s` t � �� t�� st| j�D ]}| �|� qd S | jr.tjd| �d�t | d� | j�
� d S d S )NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removal��source) r" �close�sys�
is_finalizing�listr$ �remove_signal_handler�warnings�warn�ResourceWarning�clear�r% �sigr' r r r, C s
���z _UnixSelectorEventLoop.closec C s |D ]
}|sq| � |� qd S r )�_handle_signal)r% �datar r r r �_process_self_dataQ s
�z)_UnixSelectorEventLoop._process_self_datac
G s0 t �|�s t �|�rtd��| �|� | �� z
t�| j� � � W n t
t fy6 } zt t
|���d }~ww t�||| d �}|| j|< zt�|t� t�|d� W d S t y� } z8| j|= | js�zt�d� W n t
t fy� } z t�d|� W Y d }~nd }~ww |jtjkr�t d|� d���� d }~ww )Nz3coroutines cannot be used with add_signal_handler()F���� set_wakeup_fd(-1) failed: %s�sig � cannot be caught)r Z iscoroutineZiscoroutinefunction� TypeError�
_check_signal�
_check_closed�signal�
set_wakeup_fdZ_csock�filenor �OSError� RuntimeError�strr �Handler$ r � siginterruptr
�info�errno�EINVAL)r% r6 �callback�args�exc�handleZnexcr r r �add_signal_handlerX s@
�
��
�� ��z)_UnixSelectorEventLoop.add_signal_handlerc C s< | j �|�}|d u r
d S |jr| �|� d S | �|� d S r )r$ �getZ
_cancelledr0 Z_add_callback_signalsafe)r% r6 rO r r r r7 � s z%_UnixSelectorEventLoop._handle_signalc
C s� | � |� z| j|= W n
ty Y dS w |tjkr tj}ntj}zt�||� W n tyF } z|jtj krAt
d|� d���� d }~ww | jsnzt� d� W dS t tfym } z
t
�d|� W Y d }~dS d }~ww dS )NFr< r= r: r; T)r? r$ �KeyErrorrA �SIGINT�default_int_handler�SIG_DFLrD rJ rK rE rB r r
rI )r% r6 �handlerrN r r r r0 � s8
�
�� ���z,_UnixSelectorEventLoop.remove_signal_handlerc C s8 t |t�s
td|����|t�� vrtd|� ���d S )Nzsig must be an int, not zinvalid signal number )�
isinstance�intr> rA �
valid_signalsr r5 r r r r? � s
�z$_UnixSelectorEventLoop._check_signalc C � t | ||||�S r )�_UnixReadPipeTransport�r% �pipe�protocol�waiter�extrar r r �_make_read_pipe_transport� � z0_UnixSelectorEventLoop._make_read_pipe_transportc C rZ r )�_UnixWritePipeTransportr\ r r r �_make_write_pipe_transport� rb z1_UnixSelectorEventLoop._make_write_pipe_transportc
� s� �t �� �U}
|
�� std��| �� } t| |||||||f| |d�| ��} |
�| �� | j| � z| I d H W n t t
fy? � t yQ | � � | �
� I d H � w W d � | S 1 s]w Y | S )NzRasyncio.get_child_watcher() is not activated, subprocess support is not installed.)r_ r` )r �get_child_watcher� is_activerE �
create_future�_UnixSubprocessTransport�add_child_handlerZget_pid�_child_watcher_callback�
SystemExit�KeyboardInterrupt�
BaseExceptionr, �_wait)
r% r^ rM �shell�stdin�stdout�stderr�bufsizer` �kwargs�watcherr_ �transpr r r �_make_subprocess_transport� s: �
���
� ��
��z1_UnixSelectorEventLoop._make_subprocess_transportc C s | � | j|j|� d S r )�call_soon_threadsafe� call_soonZ_process_exited)r% �pid�
returncoderv r r r rj � s z._UnixSelectorEventLoop._child_watcher_callback)�ssl�sock�server_hostname�ssl_handshake_timeoutc � s �|r |d u r t d��n|d urt d��|d ur t d��|d urO|d ur(t d��t�|�}t�tjtjd�}z|�d� | �||�I d H W n( |�� � |d u rWt d��|j tjksc|j
tjkrjt d|����|�d� | j |||||d �I d H \}}||fS )
Nz/you have to pass server_hostname when using sslz+server_hostname is only meaningful with ssl�1ssl_handshake_timeout is only meaningful with ssl�3path and sock can not be specified at the same timer Fz no path and sock were specified�.A UNIX Domain Stream Socket was expected, got )r ) r r �fspath�socket�AF_UNIX� SOCK_STREAM� setblockingZ sock_connectr, �family�typeZ _create_connection_transport) r% �protocol_factory�pathr| r} r~ r � transportr^ r r r �create_unix_connection� sN �����
�
�z-_UnixSelectorEventLoop.create_unix_connection�d T)r} �backlogr| r �
start_servingc
� s� �t |t�r
td��|d ur|std��|d ur�|d ur td��t�|�}t�tjtj�}|d dvrezt �
t� |�j �rBt� |� W n! t
yL Y n tyd } z
t�d||� W Y d }~nd }~ww z|�|� W nF ty� } z|�� | jtjkr�d|�d�}
ttj|
�d �� d } ~ w |�� � |d u r�td ��|jtjks�|jtjkr�td
|����|�d � t�| |g||||�} |r�| �� t� d�I d H | S ) Nz*ssl argument must be an SSLContext or Noner� r� r )r � z2Unable to check or remove stale UNIX socket %r: %rzAddress z is already in usez-path was not specified, and no sock specifiedr� F) rW �boolr> r r r� r� r� r� �stat�S_ISSOCK�st_mode�remove�FileNotFoundErrorrD r
�error�bindr, rJ Z
EADDRINUSEr� r� r� r ZServerZ_start_servingr �sleep) r% r� r� r} r� r| r r� �errrN �msgZserverr r r �create_unix_server sp �
��
� ��� �� �
�z)_UnixSelectorEventLoop.create_unix_serverc
� s� �zt j W n ty t�d��w z|�� }W n ttjfy- } zt�d��d }~ww zt �|�j }W n t
yB t�d��w |rG|n|}|sMdS | � � } | � | d |||||d� | I d H S )Nz os.sendfile() is not availableznot a regular filer )
r �sendfile�AttributeErrorr �SendfileNotAvailableErrorrC �io�UnsupportedOperation�fstat�st_sizerD rg �_sock_sendfile_native_impl)
r% r} �file�offset�countrC r� �fsize� blocksize�futr r r �_sock_sendfile_nativeU s6 �
��
��
� �
z,_UnixSelectorEventLoop._sock_sendfile_nativec C s* |� � } |d ur
| �|� |�� r| �|||� d S |r2|| }|dkr2| �|||� |�|� d S z
t�| |||�}
W n� ttfya |d u rO| � ||� | �
| | j || ||||||�
Y d S t y� } zK|d ur�| j
t
jkr�t| �tur�tdt
j�} | | _| } |dkr�t�d�}
| �|||� |�|
� n| �|||� |�| � W Y d } ~ d S W Y d } ~ d S d } ~ w ttfy� � ty� } z| �|||� |�| � W Y d } ~ d S d } ~ ww |
dkr�| �|||� |�|� d S ||
7 }||
7 }|d u �r| � ||� | �
| | j || ||||||�
d S )Nr zsocket is not connectedzos.sendfile call failed)rC �
remove_writer� cancelled� _sock_sendfile_update_filepos�
set_resultr r� �BlockingIOError�InterruptedError� _sock_add_cancellation_callbackZ
add_writerr� rD rJ ZENOTCONNr� �ConnectionError� __cause__r r� �
set_exceptionrk rl rm )r% r� Z
registered_fdr} rC r� r� r� �
total_sent�fd�sentrN �new_excr� r r r r� l st
� �� ����
�z1_UnixSelectorEventLoop._sock_sendfile_native_implc C s |dkrt �||t j� d S d S �Nr )r �lseek�SEEK_SET)r% rC r� r� r r r r� � s �z4_UnixSelectorEventLoop._sock_sendfile_update_fileposc s � �fdd�}|� |� d S )Nc s. | � � r��� }|dkr� �|� d S d S d S )Nr: )r� rC r� )r� r� �r% r} r r �cb� s �zB_UnixSelectorEventLoop._sock_add_cancellation_callback.<locals>.cb)�add_done_callback)r% r� r} r� r r� r r� � s z6_UnixSelectorEventLoop._sock_add_cancellation_callbackr �NN)�__name__�
__module__� __qualname__r# r, r9 rP r7 r0 r? ra rd rw rj r� r� r� r� r� r� �
__classcell__r r r' r r! 9 sD -
�
�
� � �.� �CFr! c s� e Zd ZdZd � fdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z e
jfdd�Zd dd�Zdd� Zd d � Z� ZS ) r[ i Nc s� t � �|� || jd< || _|| _|�� | _|| _d| _d| _ t
� | j�j }t
�|�sBt
�|�sBt
�|�sBd | _d | _d | _td��t
�| jd� | j�| jj| � | j�| jj| j| j� |d urm| j�tj|d � d S d S )Nr] Fz)Pipe transport is for pipes/sockets only.)r" r# �_extra�_loop�_piperC �_fileno� _protocol�_closing�_pausedr r� r� r� �S_ISFIFOr� �S_ISCHRr � set_blockingry �connection_made� _add_reader� _read_readyr � _set_result_unless_cancelled)r% �loopr] r^ r_ r` �moder' r r r# � s8
�� �
��z _UnixReadPipeTransport.__init__c C s� | j jg}| jd u r|�d� n| jr|�d� |�d| j� �� t| jdd �}| jd urH|d urHt� || jt
j �}|rB|�d� n|�d� n| jd urS|�d� n|�d� d� d �
|��S )
N�closed�closing�fd=� _selector�polling�idle�open�<{}>� )r( r� r� �appendr� r� �getattrr� r
�_test_selector_event� selectors�
EVENT_READ�format�join)r% rI r& r� r r r �__repr__� s$
�
z _UnixReadPipeTransport.__repr__c
C s� z
t �| j| j�}W n$ ttfy Y d S ty. } z
| �|d� W Y d }~d S d }~ww |r9| j� |� d S | j
� � rDt �
d| � d| _| j
�| j� | j
�| jj� | j
�| jd � d S )Nz"Fatal read error on pipe transport�%r was closed by peerT)r �readr� �max_sizer� r� rD � _fatal_errorr� Z
data_receivedr� � get_debugr
rI r� �_remove_readerry Z eof_received�_call_connection_lost)r% r8 rN r r r r� � s ��
z"_UnixReadPipeTransport._read_readyc C sB | j s| jrd S d| _| j�| j� | j�� r t�d| � d S d S )NTz%r pauses reading)r� r� r� r� r� r� r
�debug�r% r r r �
pause_reading s
�z$_UnixReadPipeTransport.pause_readingc C sF | j s| jsd S d| _| j�| j| j� | j�� r!t�d| � d S d S )NFz%r resumes reading) r� r� r� r� r� r� r� r
r� r� r r r �resume_reading s
�z%_UnixReadPipeTransport.resume_readingc C �
|| _ d S r �r� �r% r^ r r r � set_protocol �
z#_UnixReadPipeTransport.set_protocolc C � | j S r r� r� r r r � get_protocol � z#_UnixReadPipeTransport.get_protocolc C r� r �r� r� r r r �
is_closing r� z!_UnixReadPipeTransport.is_closingc C s | j s
| �d � d S d S r )r� �_closer� r r r r, ! s �z _UnixReadPipeTransport.closec C �0 | j d ur|d| ��t| d� | j �� d S d S �Nzunclosed transport r* �r� r3 r, �r% �_warnr r r �__del__% �
�z _UnixReadPipeTransport.__del__� Fatal error on pipe transportc C sZ t |t�r|jtjkr| j�� rtjd| |dd� n | j�||| | j d�� | �
|� d S �Nz%r: %sT��exc_info)�message� exceptionr� r^ ) rW rD rJ ZEIOr� r� r
r� �call_exception_handlerr� r� �r% rN r r r r r� * s
��z#_UnixReadPipeTransport._fatal_errorc C s( d| _ | j�| j� | j�| j|� d S �NT)r� r� r� r� ry r� �r% rN r r r r� 8 s z _UnixReadPipeTransport._closec C �N z| j �|� W | j�� d | _d | _ d | _d S | j�� d | _d | _ d | _w r �r� Zconnection_lostr� r, r� r
r r r r� = �
�z,_UnixReadPipeTransport._call_connection_lostr� �r )r� r� r� r� r# r� r� r� r� r� r� r� r, r1 r2 r r� r� r� r� r r r' r r[ � s
r[ c s� e Zd Zd%� fdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zejfdd�Zd d � Zd&d d �Zd'd!d"�Zd#d$� Z� ZS )(rc Nc
s t � �||� || jd< || _|�� | _|| _t� | _d| _ d| _
t � | j�j
}t�|�}t�|�}t�|�} |sJ|sJ| sJd | _d | _d | _td��t �| jd� | j�| jj| � | sd|rptj�d�sp| j�| jj| j| j� |d ur| j�t j |d � d S d S )Nr] r Fz?Pipe transport is only for pipes, sockets and character devices�aix) r" r# r� r� rC r� r� � bytearray�_buffer�
_conn_lostr� r r� r� r� r� r� r� r r� r� ry r� r- �platform�
startswithr� r� r r� )
r% r� r] r^ r_ r` r� Zis_char�is_fifo� is_socketr' r r r# J s8
�
��z _UnixWritePipeTransport.__init__c C s� | j jg}| jd u r|�d� n| jr|�d� |�d| j� �� t| jdd �}| jd urT|d urTt� || jt
j �}|rB|�d� n|�d� | � � }|�d|� �� n| jd ur_|�d� n|�d� d �
d
�|��S ) Nr� r� r� r� r� r� zbufsize=r� r� r� )r( r� r� r� r� r� r� r� r
r� r� � EVENT_WRITE�get_write_buffer_sizer� r� )r% rI r& r� rs r r r r� o s(
�
z _UnixWritePipeTransport.__repr__c C s
t | j�S r )�lenr r� r r r r � r� z-_UnixWritePipeTransport.get_write_buffer_sizec C s8 | j �� r t�d| � | jr| �t� � d S | �� d S )Nr� )r� r� r
rI r r� �BrokenPipeErrorr� r r r r� � s
z#_UnixWritePipeTransport._read_readyc
C s& t |t�r t|�}|s
d S | js| jr'| jtjkr t�d� | jd7 _d S | j s�z t
� | j |�}W n5 t
tfy@ d}Y n) ttfyI � tyh } z| jd7 _| �|d� W Y d }~d S d }~ww |t|�krqd S |dkr}t|�|d � }| j�| j | j� | j |7 _ | �� d S )Nz=pipe closed by peer or os.write(pipe, data) raised exception.r r �#Fatal write error on pipe transport)rW r �
memoryviewr r� r Z!LOG_THRESHOLD_FOR_CONNLOST_WRITESr
�warningr r �writer� r� r� rk rl rm r� r r� Z _add_writer� _write_readyZ_maybe_pause_protocol)r% r8 �nrN r r r r! � s:
�� z _UnixWritePipeTransport.writec
C s z
t �| j| j�}W n@ ttfy Y d S ttfy � tyJ } z | j� � | j
d7 _
| j � | j� | �
|d� W Y d }~d S d }~ww |t| j�krs| j� � | j � | j� | �� | jrq| j �| j� | �d � d S |dkr| jd |�= d S d S )Nr r r )r r! r� r r� r� rk rl rm r4 r r� �_remove_writerr� r Z_maybe_resume_protocolr� r� r� )r% r# rN r r r r" � s0
��
�z$_UnixWritePipeTransport._write_readyc C � dS r r r� r r r �
can_write_eof� � z%_UnixWritePipeTransport.can_write_eofc C s< | j rd S d| _ | js | j�| j� | j�| jd � d S d S r )r� r r� r� r� ry r� r� r r r � write_eof� s �z!_UnixWritePipeTransport.write_eofc C r� r r� r� r r r r� � r� z$_UnixWritePipeTransport.set_protocolc C r� r r� r� r r r r� � r� z$_UnixWritePipeTransport.get_protocolc C r� r r� r� r r r r� � r� z"_UnixWritePipeTransport.is_closingc C s$ | j d ur| js| �� d S d S d S r )r� r� r( r� r r r r, � s �z _UnixWritePipeTransport.closec C r� r� r� r r r r r � r z _UnixWritePipeTransport.__del__c C � | � d � d S r )r� r� r r r �abort� � z _UnixWritePipeTransport.abortr c C sN t |t�r| j�� rtjd| |dd� n | j�||| | jd�� | �|� d S r ) rW rD r� r� r
r� r
r� r� r r r r r� � s
��z$_UnixWritePipeTransport._fatal_errorc C sF d| _ | jr
| j�| j� | j�� | j�| j� | j�| j|� d S r ) r� r r� r$ r� r4 r� ry r� r
r r r r� s
z _UnixWritePipeTransport._closec C r r r r
r r r r�
r z-_UnixWritePipeTransport._call_connection_lostr� r r )r� r� r� r# r� r r� r! r" r& r( r� r� r� r, r1 r2 r r* r� r� r� r� r r r' r rc G s$ % #
rc c @ s e Zd Zdd� ZdS )rh c K s� d }|t jkrtj�d�rt�� \}}z7t j|f||||d|d�|��| _|d ur:|� � t
|� � d|d�| j_ d }W |d urI|� � |� � d S d S |d urX|� � |� � w w )Nr F)ro rp rq rr �universal_newlinesrs �wb)� buffering)
�
subprocess�PIPEr- r r r� �
socketpair�Popen�_procr, r� �detachrp ) r% rM ro rp rq rr rs rt Zstdin_wr r r �_start s0 ���� �
�z _UnixSubprocessTransport._startN)r� r� r� r5 r r r r rh s rh c @ sF e Zd Z dd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )r c G � t � �r ��NotImplementedError�r% rz rL rM r r r ri C s z&AbstractChildWatcher.add_child_handlerc C r6 r r7 �r% rz r r r �remove_child_handlerN s z)AbstractChildWatcher.remove_child_handlerc C r6 r r7 �r% r� r r r � attach_loopV s z AbstractChildWatcher.attach_loopc C r6 r r7 r� r r r r, ` s zAbstractChildWatcher.closec C r6 r r7 r� r r r rf g s z AbstractChildWatcher.is_activec C r6 r r7 r� r r r � __enter__p s z AbstractChildWatcher.__enter__c C r6 r r7 �r% �a�b�cr r r �__exit__v s z AbstractChildWatcher.__exit__N)
r� r� r� ri r; r= r, rf r> rC r r r r r , s
r c @ sV e Zd Z dd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dS )r c C � d | _ i | _d S r �r� �
_callbacksr� r r r r# � �
zPidfdChildWatcher.__init__c C � | S r r r� r r r r> � r' zPidfdChildWatcher.__enter__c C � d S r r )r% �exc_type� exc_value�
exc_tracebackr r r rC � r' zPidfdChildWatcher.__exit__c C � | j d uo | j �� S r �r� Z
is_runningr� r r r rf � � zPidfdChildWatcher.is_activec C r) r �r= r� r r r r, � r+ zPidfdChildWatcher.closec C sd | j d ur|d u r| jrt�dt� | j�� D ]\}}}| j �|� t�|� q| j� � || _ d S �NzCA loop is being detached from a child watcher with pending handlers)
r� rF r1 r2 �RuntimeWarning�valuesr� r r, r4 )r% r� �pidfd�_r r r r= � s �
z PidfdChildWatcher.attach_loopc G s\ | j �|�}|d ur|d ||f| j |< d S t�|�}| j�|| j|� |||f| j |< d S r� )rF rQ r Z
pidfd_openr� r� �_do_wait)r% rz rL rM ZexistingrT r r r ri � s
z#PidfdChildWatcher.add_child_handlerc C s~ | j �|�\}}}| j�|� z
t�|d�\}}W n ty* d}t�d|� Y nw t |�}t�
|� |||g|�R � d S )Nr � zJchild process pid %d exit status already read: will report returncode 255) rF �popr� r� r �waitpid�ChildProcessErrorr
r r r, )r% rz rT rL rM rU r r{ r r r rV � s ��
zPidfdChildWatcher._do_waitc C sF z | j �|�\}}}W n
ty Y dS w | j�|� t�|� dS )NFT)rF rX rR r� r� r r, )r% rz rT rU r r r r; � s �
z&PidfdChildWatcher.remove_child_handlerN) r� r� r� r# r> rC rf r, r= ri rV r; r r r r r { s r c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�BaseChildWatcherc C rD r rE r� r r r r# � rG zBaseChildWatcher.__init__c C r) r rP r� r r r r, � r+ zBaseChildWatcher.closec C rM r rN r� r r r rf � rO zBaseChildWatcher.is_activec C � t � �r r7 )r% � expected_pidr r r � _do_waitpid� r� z BaseChildWatcher._do_waitpidc C r\ r r7 r� r r r �_do_waitpid_all� r� z BaseChildWatcher._do_waitpid_allc C sj | j d ur|d u r| jrt�dt� | j d ur | j �tj� || _ |d ur3|�tj| j � | �
� d S d S rQ ) r� rF r1 r2 rR r0 rA �SIGCHLDrP � _sig_chldr_ r< r r r r= � s �
�z BaseChildWatcher.attach_loopc
C sZ z| � � W d S ttfy � ty, } z| j�d|d�� W Y d }~d S d }~ww )N�$Unknown exception in SIGCHLD handler)r r )r_ rk rl rm r� r
r
r r r ra � s ���zBaseChildWatcher._sig_chldN)
r� r� r� r# r, rf r^ r_ r= ra r r r r r[ � s r[ c sN e Zd Z � fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z � Z
S )r c s | j �� t� �� d S r )rF r4 r" r, r� r' r r r, s
zSafeChildWatcher.closec C rH r r r� r r r r>
r' zSafeChildWatcher.__enter__c C rI r r r? r r r rC r' zSafeChildWatcher.__exit__c G s ||f| j |< | �|� d S r )rF r^ r9 r r r ri s z"SafeChildWatcher.add_child_handlerc C �$ z| j |= W dS ty Y dS w �NTF�rF rR r: r r r r; � �z%SafeChildWatcher.remove_child_handlerc C � t | j�D ]}| �|� qd S r �r/ rF r^ r: r r r r_ s �z SafeChildWatcher._do_waitpid_allc C s� z t �|t j�\}}W n ty |}d}t�d|� Y nw |dkr%d S t|�}| j�� r5t� d||� z
| j
� |�\}}W n t yY | j�� rVtjd|dd� Y d S Y d S w |||g|�R � d S )NrW �8Unknown child process pid %d, will report returncode 255r �$process %s exited with returncode %s�'Child watcher got an unexpected pid: %rTr )
r rY �WNOHANGrZ r
r r r� r� r� rF rX rR )r% r] rz r r{ rL rM r r r r^ % s6 ��
�
���z SafeChildWatcher._do_waitpid) r� r� r� r, r> rC ri r; r_ r^ r� r r r' r r � s
r c sR e Zd Z � fdd�Z� fdd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z � Z
S )r c s$ t � �� t�� | _i | _d| _d S r� )r" r# � threading�Lock�_lock�_zombies�_forksr� r' r r r# R s
zFastChildWatcher.__init__c s" | j �� | j�� t� �� d S r )rF r4 rp r" r, r� r' r r r, X s
zFastChildWatcher.closec C s< | j � | jd7 _| W d � S 1 sw Y d S )Nr )ro rq r� r r r r> ] s $�zFastChildWatcher.__enter__c C sv | j �( | jd8 _| js| js W d � d S t| j�}| j�� W d � n1 s.w Y t�d|� d S )Nr z5Caught subprocesses termination from unknown pids: %s)ro rq rp rF r4 r
r )r% r@ rA rB Zcollateral_victimsr r r rC c s �
� �zFastChildWatcher.__exit__c G s| | j �( z| j�|�}W n ty# ||f| j|< Y W d � d S w W d � n1 s.w Y |||g|�R � d S r )ro rp rX rR rF )r% rz rL rM r{ r r r ri q s �� � z"FastChildWatcher.add_child_handlerc C rc rd re r: r r r r; rf z%FastChildWatcher.remove_child_handlerc C s z t �dt j�\}}W n
ty Y d S w |dkr d S t|�}| j�F z
| j�|�\}}W n' tyV | j rR|| j
|< | j � � rJt
�d||� Y W d � q d }Y n
w | j � � rct
�d||� W d � n1 smw Y |d u r~t
�d||� n |||g|�R � q)NTr: r z,unknown process %s exited with returncode %srj z8Caught subprocess termination from unknown pid: %d -> %d)r rY rl rZ r ro rF rX rR rq rp r� r� r
r� r )r% rz r r{ rL rM r r r r_ � sH �
��
�
�� ���z FastChildWatcher._do_waitpid_all) r� r� r� r# r, r> rC ri r; r_ r� r r r' r r H s r c @ sf e Zd Z dd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dS )r c C s i | _ d | _d S r )rF �_saved_sighandlerr� r r r r# � rG z MultiLoopChildWatcher.__init__c C s
| j d uS r )rr r� r r r rf � r� z MultiLoopChildWatcher.is_activec C sT | j �� | jd u r d S t�tj�}|| jkr t�d� nt�tj| j� d | _d S )Nz+SIGCHLD handler was changed by outside code) rF r4 rr rA � getsignalr` ra r
r )r% rV r r r r, � s
zMultiLoopChildWatcher.closec C rH r r r� r r r r> � r' z MultiLoopChildWatcher.__enter__c C rI r r �r% rJ �exc_val�exc_tbr r r rC � r' z MultiLoopChildWatcher.__exit__c G s& t �� }|||f| j|< | �|� d S r )r �get_running_looprF r^ )r% rz rL rM r� r r r ri � s z'MultiLoopChildWatcher.add_child_handlerc C rc rd re r: r r r r; � rf z*MultiLoopChildWatcher.remove_child_handlerc C sN | j d urd S t�tj| j�| _ | j d u r t�d� tj| _ t�tjd� d S )NzaPrevious SIGCHLD handler was set by non-Python code, restore to default handler on watcher close.F)rr rA r` ra r
r rU rH r< r r r r= � s
z!MultiLoopChildWatcher.attach_loopc C rg r rh r: r r r r_ � s �z%MultiLoopChildWatcher._do_waitpid_allc C s� z t �|t j�\}}W n ty |}d}t�d|� d}Y n
w |dkr'd S t|�}d}z | j�|�\}}}W n t yJ tjd|dd� Y d S w |�
� rXt�d||� d S |re|� � ret� d ||� |j
|||g|�R � d S )
NrW ri Fr Trk r �%Loop %r that handles pid %r is closedrj )r rY rl rZ r
r r rF rX rR � is_closedr� r� rx ) r% r] rz r r{ Z debug_logr� rL rM r r r r^ s: ��
�� �z!MultiLoopChildWatcher._do_waitpidc C sD z| � � W d S ttfy � ty! tjddd� Y d S w )Nrb Tr )r_ rk rl rm r
r )r% r r r r r ra % s �z MultiLoopChildWatcher._sig_chldN)r� r� r� r# rf r, r> rC ri r; r= r_ r^ ra r r r r r � s %r c @ sl e Zd Z dd� Zdd� Zdd� Zdd� Zd d
� Zd d � Ze j
fd
d�Z dd� Z dd� Z
dd� Zdd� ZdS )r c C s t �d�| _i | _d S r� )� itertoolsr� � _pid_counter�_threadsr� r r r r# ; r) z ThreadedChildWatcher.__init__c C r% r r r� r r r rf ? r' z ThreadedChildWatcher.is_activec C s | � � d S r )�
_join_threadsr� r r r r, B s zThreadedChildWatcher.closec C s0 dd� t | j�� �D �}|D ]}|�� qd S )Nc S s g | ] }|� � r|js|�qS r )�is_alive�daemon��.0�threadr r r �
<listcomp>G s
�
�z6ThreadedChildWatcher._join_threads.<locals>.<listcomp>)r/ r| rS r� )r% �threadsr� r r r r} E s
�z"ThreadedChildWatcher._join_threadsc C rH r r r� r r r r> L r' z ThreadedChildWatcher.__enter__c C rI r r rt r r r rC O r' z ThreadedChildWatcher.__exit__c C s: dd� t | j�� �D �}|r|| j� d�t| d� d S d S )Nc S s g | ]}|� � r|�qS r )r~ r� r r r r� S s
�z0ThreadedChildWatcher.__del__.<locals>.<listcomp>z0 has registered but not finished child processesr* )r/ r| rS r( r3 )r% r r� r r r r R s
��z ThreadedChildWatcher.__del__c G sF t �� }tj| jdt| j�� �||||fdd�}|| j|< |�� d S )Nzwaitpid-T)�target�namerM r ) r rw rm �Threadr^ �nextr{ r| �start)r% rz rL rM r� r� r r r ri Z s
�
z&ThreadedChildWatcher.add_child_handlerc C r% r r r: r r r r; c s z)ThreadedChildWatcher.remove_child_handlerc C rI r r r< r r r r= i r' z ThreadedChildWatcher.attach_loopc C s� z
t �|d�\}}W n ty |}d}t�d|� Y nw t|�}|�� r-t�d||� |�� r9t�d||� n |j |||g|�R � | j
� |� d S )Nr rW ri rj rx ) r rY rZ r
r r r� r� ry rx r| rX )r% r� r] rL rM rz r r{ r r r r^ l s& �� �z ThreadedChildWatcher._do_waitpidN)r� r� r� r# rf r, r} r> rC r1 r2 r ri r; r= r^ r r r r r . s r c sF e Zd Z eZ� fdd�Zdd� Z� fdd�Zdd� Zd d
� Z � Z
S ) �_UnixDefaultEventLoopPolicyc s t � �� d | _d S r )r" r# �_watcherr� r' r r r# � s
z$_UnixDefaultEventLoopPolicy.__init__c C s~ t j�2 | jd u r%t� | _t�� t�� u r-| j�| jj � W d � d S W d � d S W d � d S 1 s8w Y d S r )
r ro r� r rm �current_thread� main_threadr= �_localr� r� r r r �
_init_watcher� s
��"�z)_UnixDefaultEventLoopPolicy._init_watcherc s@ t � �|� | jd ur t�� t�� u r | j�|� d S d S d S r )r" �set_event_loopr� rm r� r� r= r< r' r r r� � s
�z*_UnixDefaultEventLoopPolicy.set_event_loopc C s | j d u r
| �� | j S r )r� r� r� r r r re � s
z-_UnixDefaultEventLoopPolicy.get_child_watcherc C s | j d ur | j �� || _ d S r )r� r, )r% ru r r r �set_child_watcher� s
z-_UnixDefaultEventLoopPolicy.set_child_watcher) r� r� r� r! Z
_loop_factoryr# r� r� re r� r� r r r' r r� � s
r� )2rJ r� rz r r� rA r� r� r/ r- rm r1 � r r r r r r r r
r r �logr
�__all__r � ImportErrorr r ZBaseSelectorEventLoopr! Z
ReadTransportr[ Z_FlowControlMixinZWriteTransportrc ZBaseSubprocessTransportrh r r r[ r r r r ZBaseDefaultEventLoopPolicyr� r r r r r r �<module> sd
� NON5Ji}Y2