a
XC?h*� � @ 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 G dd� dej �Z G dd� dej �Z G dd� dej!ej"�Z#G dd� dej$�Z%G dd � d �Z&G d d � d e&�Z'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,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�DefaultEventLoopPolicyZwin32z+Signals are not really supported on Windowsc C s d S �N� )�signum�framer r �8/opt/alt/python39/lib64/python3.9/asyncio/unix_events.py�_sighandler_noop* s r c s� e Zd Zd(� 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�Zd-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 5 s z _UnixSelectorEventLoop.__init__c sZ t � �� t�� s.t| j�D ]}| �|� q n(| jrVtjd| �d�t | d� | j�
� 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& 9 s
�z _UnixSelectorEventLoop.closec C s |D ]}|sq| � |� qd S r )�_handle_signal)r �datar r r r �_process_self_dataG s z)_UnixSelectorEventLoop._process_self_datac
G sR t �|�st �|�r td��| �|� | �� zt�| j� � � W n4 t
t fyv } zt t
|���W Y d }~n
d }~0 0 t�||| d �}|| j|< z t�|t� t�|d� W n� t �yL } z�| j|= | j�szt�d� W n6 t
t f�y } zt�d|� W Y d }~n
d }~0 0 |jtjk�r6t d|� d���n� W Y d }~n
d }~0 0 d S )Nz3coroutines cannot be used with add_signal_handler()F������ set_wakeup_fd(-1) failed: %s�sig � cannot be caught)r Z iscoroutineZiscoroutinefunction� TypeError�
_check_signalZ
_check_closed�signal�
set_wakeup_fdZ_csock�fileno�
ValueError�OSError� RuntimeError�strr ZHandler r � siginterruptr
�info�errno�EINVAL)r r0 �callback�args�exc�handleZnexcr r r �add_signal_handlerN s2
�
"
"z)_UnixSelectorEventLoop.add_signal_handlerc C s8 | j �|�}|d u rd S |jr*| �|� n
| �|� d S r )r �getZ
_cancelledr* Z_add_callback_signalsafe)r r0 rH r r r r1 { s z%_UnixSelectorEventLoop._handle_signalc
C s� | � |� z | j|= W n ty* Y dS 0 |tjkr>tj}ntj}zt�||� W nD ty� } z,|jtj kr�t
d|� d���n� W Y d }~n
d }~0 0 | js�zt� d� W n4 t tfy� } zt
�d|� W Y d }~n
d }~0 0 dS )NFr6 r7 r4 r5 T)r9 r �KeyErrorr: �SIGINT�default_int_handler�SIG_DFLr> rC rD r? r; r= r
rB )r r0 �handlerrG r r r r* � s(
"z,_UnixSelectorEventLoop.remove_signal_handlerc C s6 t |t�std|����|t�� vr2td|� ���d S )Nzsig must be an int, not zinvalid signal number )�
isinstance�intr8 r: �
valid_signalsr= r/ r r r r9 � s
z$_UnixSelectorEventLoop._check_signalc C s t | ||||�S r )�_UnixReadPipeTransport�r �pipe�protocol�waiter�extrar r r �_make_read_pipe_transport� s z0_UnixSelectorEventLoop._make_read_pipe_transportc C s t | ||||�S r )�_UnixWritePipeTransportrT r r r �_make_write_pipe_transport� s z1_UnixSelectorEventLoop._make_write_pipe_transportc
� s� t �� ��}
|
�� std��| �� } t| |||||||f| |d�| ��} |
�| �� | j| � z| I d H W n@ t t
fy� � Y n* t y� | � � | �
� I d H � Y n0 W d � n1 s�0 Y | S )NzRasyncio.get_child_watcher() is not activated, subprocess support is not installed.)rW rX )r �get_child_watcher� is_activer? �
create_future�_UnixSubprocessTransport�add_child_handlerZget_pid�_child_watcher_callback�
SystemExit�KeyboardInterrupt�
BaseExceptionr& Z_wait)
r rV rF �shell�stdin�stdout�stderr�bufsizerX �kwargs�watcherrW �transpr r r �_make_subprocess_transport� s.
���
� &z1_UnixSelectorEventLoop._make_subprocess_transportc C s | � |j|� d S r )�call_soon_threadsafeZ_process_exited)r �pid�
returncoderl r r r ra � s z._UnixSelectorEventLoop._child_watcher_callback)�ssl�sock�server_hostname�ssl_handshake_timeoutc � s
|r|d u r6t d��n |d ur&t d��|d ur6t d��|d ur�|d urNt d��t�|�}t�tjtjd�}z |�d� | �||�I d H W q� |�� � Y q�0 n@|d u r�t d��|j tjks�|j
tjkr�t 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 )rt ) r= �os�fspath�socket�AF_UNIX� SOCK_STREAM� setblockingZ sock_connectr& �family�typeZ _create_connection_transport) r �protocol_factory�pathrq rr rs rt � transportrV r r r �create_unix_connection� sL ���
��
�z-_UnixSelectorEventLoop.create_unix_connection�d T)rr �backlogrq rt �
start_servingc
� s� t |t�rtd��|d ur&|s&td��|d u�rJ|d ur@td��t�|�}t�tjtj�}|d dvr�z t �
t� |�j �r�t� |� W nB t
y� Y n2 ty� } zt�d||� W Y d }~n
d }~0 0 z|�|� W nn t�y2 } z@|�� | jtjk�r d|�d�}
ttj|
�d �n� W Y d } ~ n d } ~ 0 |�� � Y n0 n<|d u �r\td ��|jtjk�sx|jtjk�r�td
|����|�d � t�| |g||||�} |�r�| �� t� d�I d H | S ) Nz*ssl argument must be an SSLContext or Noneru rv r )r � z2Unable to check or remove stale UNIX socket %r: %rzAddress z is already in usez-path was not specified, and no sock specifiedrw F) rP �boolr8 r= rx ry rz r{ r| �stat�S_ISSOCK�st_mode�remove�FileNotFoundErrorr> r
�errorZbindr& rC Z
EADDRINUSEr~ r r} r ZServerZ_start_servingr �sleep) r r� r� rr r� rq rt r� �errrG �msgZserverr r r �create_unix_server sh
�
�
�
�
��
�z)_UnixSelectorEventLoop.create_unix_serverc
� s� z
t j W n ty& t�d��Y n0 z |�� }W n4 ttjfyh } zt�d��W Y d }~n
d }~0 0 zt �|�j }W n t
y� t�d��Y n0 |r�|n|}|s�dS | � � } | � | d |||||d� | I d H S )Nz os.sendfile() is not availableznot a regular filer )
rx �sendfile�AttributeErrorr �SendfileNotAvailableErrorr< �io�UnsupportedOperation�fstat�st_sizer> r^ �_sock_sendfile_native_impl)
r rr �file�offset�countr< r� Zfsize� blocksize�futr r r �_sock_sendfile_nativeJ s,
�
�z,_UnixSelectorEventLoop._sock_sendfile_nativec C s, |� � } |d ur| �|� |�� r4| �|||� d S |rd|| }|dkrd| �|||� |�|� d S zt�| |||�}
W �nD ttfy� |d u r�| � ||� | �
| | j || ||||||�
Y �nd t �yj } z�|d u�r| j
t
jk�rt| �tu�rtdt
j�} | | _| } |dk�r>t�d�}
| �|||� |�|
� n| �|||� |�| � W Y d } ~ n�d } ~ 0 ttf�y� � Y n� t�y� } z$| �|||� |�| � W Y d } ~ nrd } ~ 0 0 |
dk�r�| �|||� |�|� nD||
7 }||
7 }|d u �r
| � ||� | �
| | j || ||||||�
d S )Nr zsocket is not connectedzos.sendfile call failed)r< �
remove_writer� cancelled� _sock_sendfile_update_fileposZ
set_resultrx r� �BlockingIOError�InterruptedError� _sock_add_cancellation_callbackZ
add_writerr� r> rC ZENOTCONNr �ConnectionError� __cause__r r� Z
set_exceptionrb rc rd )r r� Z
registered_fdrr r< r� r� r� �
total_sent�fdZsentrG �new_excr� r r r r� a sp
�
�
��
�
�z1_UnixSelectorEventLoop._sock_sendfile_native_implc C s |dkrt �||t j� d S �Nr )rx �lseek�SEEK_SET)r r< r� r� r r r r� � s z4_UnixSelectorEventLoop._sock_sendfile_update_fileposc s � �fdd�}|� |� d S )Nc s& | � � r"��� }|dkr"� �|� d S )Nr4 )r� r< r� )r� r� �r rr r r �cb� s zB_UnixSelectorEventLoop._sock_add_cancellation_callback..cb)Zadd_done_callback)r r� rr r� r r� r r� � s z6_UnixSelectorEventLoop._sock_add_cancellation_callback)N)NN)NN)N)N)N)�__name__�
__module__� __qualname__r r& r3 rI r1 r* r9 rY r[ rm ra r� r� r� r� r� r� �
__classcell__r r r" r r / s@ -
�
�
�
�� . �� 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 ) rS i Nc s� t � �|� || jd< || _|| _|�� | _|| _d| _d| _ t
� | j�j }t
�|�s�t
�|�s�t
�|�s�d | _d | _d | _td��t
�| jd� | j�| jj| � | j�| jj| j| j� |d ur�| j�tj|d � d S )NrU Fz)Pipe transport is for pipes/sockets only.)r r �_extra�_loop�_piper< �_fileno� _protocol�_closing�_pausedrx r� r� r� �S_ISFIFOr� �S_ISCHRr= � set_blocking� call_soon�connection_made� _add_reader� _read_readyr � _set_result_unless_cancelled)r �looprU rV rW rX �moder" r r r � s6
�� �
�z _UnixReadPipeTransport.__init__c C s� | j jg}| jd u r |�d� n| jr0|�d� |�d| j� �� t| jdd �}| jd ur�|d ur�t� || jt
j �}|r�|�d� q�|�d� n | jd ur�|�d� n
|�d� d� d �
|��S )
N�closed�closing�fd=� _selector�polling�idle�open�<{}>� )r# r� r� �appendr� r� �getattrr� r
�_test_selector_event� selectorsZ
EVENT_READ�format�join)r rB r! r� r r r �__repr__� s$
�
z _UnixReadPipeTransport.__repr__c
C s� zt �| j| j�}W nD ttfy* Y n� tyX } z| �|d� W Y d }~nfd }~0 0 |rl| j� |� nJ| j
� � r�t �
d| � d| _| j
�| j� | j
�| jj� | j
�| jd � d S )Nz"Fatal read error on pipe transport�%r was closed by peerT)rx �readr� �max_sizer� r� r> � _fatal_errorr� Z
data_receivedr� � get_debugr
rB r� �_remove_readerr� Z eof_received�_call_connection_lost)r r2 rG r r r r� � s "
z"_UnixReadPipeTransport._read_readyc C s> | j s | jrd S d| _| j�| j� | j�� r:t�d| � 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 sB | j s | jsd S d| _| j�| j| j� | j�� r>t�d| � 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 s
|| _ d S r �r� �r rV r r r � set_protocol
s z#_UnixReadPipeTransport.set_protocolc C s | j S r r� r� r r r � get_protocol s z#_UnixReadPipeTransport.get_protocolc C s | j S r �r� r� r r r �
is_closing s z!_UnixReadPipeTransport.is_closingc C s | j s| �d � d S r )r� �_closer� r r r r& s z _UnixReadPipeTransport.closec C s, | j d ur(|d| ��t| d� | j �� d S �Nzunclosed transport r$ �r� r- r& �r �_warnr r r �__del__ s
z _UnixReadPipeTransport.__del__� Fatal error on pipe transportc C sZ t |t�r4|jtjkr4| j�� rLtjd| |dd� n| j�||| | j d�� | �
|� d S �Nz%r: %sT��exc_info)�message� exceptionr� rV ) rP r> rC ZEIOr� r� r
r� �call_exception_handlerr� r� �r rG r� r r r r� s
�z#_UnixReadPipeTransport._fatal_errorc C s( d| _ | j�| j� | j�| j|� d S �NT)r� r� r� r� r� r� �r rG r r r r� - s z _UnixReadPipeTransport._closec C sP z,| j �|� W | j�� d | _d | _ d | _n | j�� d | _d | _ d | _0 d S r �r� Zconnection_lostr� r& r� r� r r r r� 2 s
�
z,_UnixReadPipeTransport._call_connection_lost)NN)r� )r� r� r� r� r r� r� r� r� r� r� r� r& r+ r, r� r� r� r� r� r r r" r rS � s
rS 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 )(rZ Nc
s� t � �||� || jd< || _|�� | _|| _t� | _d| _ d| _
t � | j�j
}t�|�}t�|�}t�|�} |s�|s�| s�d | _d | _d | _td��t �| jd� | j�| jj| � | s�|r�tj�d�s�| j�| jj| j| j� |d ur�| j�t j |d � d S )NrU r Fz?Pipe transport is only for pipes, sockets and character devicesZaix) r r r� r� r< r� r� � bytearray�_buffer�
_conn_lostr� rx r� r� r� r� r� r� r= r� r� r� r� r' �platform�
startswithr� r� r r� )
r r� rU rV rW rX r� Zis_charZis_fifoZ is_socketr" r r r ? s6
�
�z _UnixWritePipeTransport.__init__c C s� | j jg}| jd u r |�d� n| jr0|�d� |�d| j� �� t| jdd �}| jd ur�|d ur�t� || jt
j �}|r�|�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� Z EVENT_WRITE�get_write_buffer_sizer� r� )r rB r! r� ri r r r r� d s(
�
z _UnixWritePipeTransport.__repr__c C s
t | j�S r )�lenr� r� r r r r� | s z-_UnixWritePipeTransport.get_write_buffer_sizec C s6 | j �� rt�d| � | jr*| �t� � n| �� d S )Nr� )r� r� r
rB r� r� �BrokenPipeErrorr� r r r r� s
z#_UnixWritePipeTransport._read_readyc
C s. t |t�rt|�}|sd S | js&| jrN| jtjkr| j� � | j
d7 _
| j � | j� | �
|d� W Y d }~nnd }~0 0 |t| j�kr�| j� � | j � | j� | �� | jr�| j �| j� | �d � d S |dkr�| jd |�= d S )Nr r r )rx r r� r� r� r� rb rc rd r. r� r� �_remove_writerr� r� Z_maybe_resume_protocolr� r� r� )r r rG r r r r � s*
"
z$_UnixWritePipeTransport._write_readyc C s dS r� r r� r r r �
can_write_eof� s z%_UnixWritePipeTransport.can_write_eofc C s8 | j r
d S d| _ | js4| j�| j� | j�| jd � d S r� )r� r� r� r� r� r� r� r� r r r � write_eof� s z!_UnixWritePipeTransport.write_eofc C s
|| _ d S r r� r� r r r r� � s z$_UnixWritePipeTransport.set_protocolc C s | j S r r� r� r r r r� � s z$_UnixWritePipeTransport.get_protocolc C s | j S r r� r� r r r r� � s z"_UnixWritePipeTransport.is_closingc C s | j d ur| js| �� d S r )r� r� r r� r r r r& � s z _UnixWritePipeTransport.closec C s, | j d ur(|d| ��t| d� | j �� d S r� r� r� r r r r� � s
z _UnixWritePipeTransport.__del__c C s | � d � d S r )r� r� r r r �abort� s z _UnixWritePipeTransport.abortr� c C sN t |t�r(| j�� r@tjd| |dd� n| j�||| | jd�� | �|� d S r� ) rP r> 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� r. r� r� r� r� r r r r� � s
z _UnixWritePipeTransport._closec C sP z,| j �|� W | j�� d | _d | _ d | _n | j�� d | _d | _ d | _0 d S r r� r� r r r r� � s
�
z-_UnixWritePipeTransport._call_connection_lost)NN)r� )N)r� r� r� r r� r� r� r r r r r� r� r� r& r+ r, r� r r� r� r� r� r r r" r rZ < s" % #
rZ c @ s e Zd Zdd� ZdS )r_ c K s� d }|t jkrt�� \}}zht j|f||||d|d�|��| _|d urh|�� t|�� d|d�| j_ d }W |d ur�|�� |�� n|d ur�|�� |�� 0 d S )NF)re rf rg rh Zuniversal_newlinesri �wb)� buffering)
�
subprocess�PIPErz Z
socketpair�Popen�_procr& r� �detachrf ) r rF re rf rg rh ri rj Zstdin_wr r r �_start s,
���
�z _UnixSubprocessTransport._startN)r� r� r� r r r r r r_ s r_ c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )r c G s
t � �d S r ��NotImplementedError�r ro rE rF r r r r` 9 s z&AbstractChildWatcher.add_child_handlerc C s
t � �d S r r �r ro r r r �remove_child_handlerD s z)AbstractChildWatcher.remove_child_handlerc C s
t � �d S r r �r r� r r r � attach_loopL s z AbstractChildWatcher.attach_loopc C s
t � �d S r r r� r r r r& V s zAbstractChildWatcher.closec C s
t � �d S r r r� r r r r] ] s z AbstractChildWatcher.is_activec C s
t � �d S r r r� r r r � __enter__f s z AbstractChildWatcher.__enter__c C s
t � �d S r r �r �a�b�cr r r �__exit__l s z AbstractChildWatcher.__exit__N)
r� r� r� r` r r r& r] r r r r r r r " s
r c @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dS )r c C s d | _ i | _d S r �r� �
_callbacksr� r r r r } s zPidfdChildWatcher.__init__c C s | S r r r� r r r r � s zPidfdChildWatcher.__enter__c C s d S r r )r �exc_type� exc_value�
exc_tracebackr r r r � s zPidfdChildWatcher.__exit__c C s | j d uo| j �� S r �r� Z
is_runningr� r r r r] � s zPidfdChildWatcher.is_activec C s | � d � d S r �r r� r r r r& � s zPidfdChildWatcher.closec C sd | j d ur$|d u r$| jr$t�dt� | j�� D ] \}}}| j �|� t�|� q.| j� � || _ d S �NzCA loop is being detached from a child watcher with pending handlers)
r� r r+ r, �RuntimeWarning�valuesr� rx r& r. )r r� �pidfd�_r r r r � s �
z PidfdChildWatcher.attach_loopc G sZ | j �|�}|d ur*|d ||f| j |< n,t�|�}| j�|| j|� |||f| j |< d S r� )r rJ rx Z
pidfd_openr� r� �_do_wait)r ro rE rF Zexistingr) r r r r` � s
z#PidfdChildWatcher.add_child_handlerc C s~ | j �|�\}}}| j�|� zt�|d�\}}W n" tyT d}t�d|� Y n
0 t |�}t�
|� |||g|�R � d S )Nr �� zJchild process pid %d exit status already read: will report returncode 255) r �popr� r� rx �waitpid�ChildProcessErrorr
r �_compute_returncoder& )r ro r) rE rF r* �statusrp r r r r+ � s �
zPidfdChildWatcher._do_waitc C sF z| j �|�\}}}W n ty* Y dS 0 | j�|� t�|� dS )NFT)r r- rK r� r� rx r& )r ro r) r* r r r r � s
z&PidfdChildWatcher.remove_child_handlerN) r� r� r� r r r r] r& r r` r+ r r r r r r q s r c C s2 t �| �rt �| � S t �| �r*t �| �S | S d S r )rx � WIFSIGNALED�WTERMSIG� WIFEXITED� WEXITSTATUS)r1 r r r r0 � s
r0 c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�BaseChildWatcherc C s d | _ i | _d S r r r� r r r r � s zBaseChildWatcher.__init__c C s | � d � d S r r% r� r r r r& � s zBaseChildWatcher.closec C s | j d uo| j �� S r r$ r� r r r r] � s zBaseChildWatcher.is_activec C s
t � �d S r r )r � expected_pidr r r � _do_waitpid� s z BaseChildWatcher._do_waitpidc C s
t � �d S r r r� r r r �_do_waitpid_all� s z BaseChildWatcher._do_waitpid_allc C sf | j d ur$|d u r$| jr$t�dt� | j d ur<| j �tj� || _ |d urb|�tj| j � | �
� d S r& ) r� r r+ r, r' r* r: �SIGCHLDrI � _sig_chldr9 r r r r r � s �
z BaseChildWatcher.attach_loopc
C s^ z | � � W nL ttfy$ � Y n6 tyX } z | j�d|d�� W Y d }~n
d }~0 0 d S )N�$Unknown exception in SIGCHLD handler)r� r� )r9 rb rc rd r� r� r� r r r r; � s �zBaseChildWatcher._sig_chldN)
r� r� r� r r& r] r8 r9 r r; r r r r r6 � s r6 c sL e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z � Z
S )r c s | j �� t� �� d S r )r r. r r& r� r" r r r&
s
zSafeChildWatcher.closec C s | S r r r� r r r r s zSafeChildWatcher.__enter__c C s d S r r r r r r r s zSafeChildWatcher.__exit__c G s ||f| j |< | �|� d S r )r r8 r r r r r` s z"SafeChildWatcher.add_child_handlerc C s( z| j |= W dS ty" Y dS 0 d S �NTF�r rK r r r r r s
z%SafeChildWatcher.remove_child_handlerc C s t | j�D ]}| �|� q
d S r �r) r r8 r r r r r9 $ s z SafeChildWatcher._do_waitpid_allc C s� zt �|t j�\}}W n& ty< |}d}t�d|� Y n.0 |dkrJd S t|�}| j�� rjt� d||� z| j
� |�\}}W n, t y� | j�� r�tjd|dd� Y n0 |||g|�R � d S )Nr, �8Unknown child process pid %d, will report returncode 255r �$process %s exited with returncode %s�'Child watcher got an unexpected pid: %rTr� )
rx r. �WNOHANGr/ r
r r0 r� r� r� r r- rK )r r7 ro r1 rp rE rF r r r r8 ) s0 �
�
� z SafeChildWatcher._do_waitpid) r� r� r� r& r r r` r r9 r8 r� r r r" r r s r c sP 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 � threadingZLock�_lock�_zombies�_forksr� r" r r r V s
zFastChildWatcher.__init__c s" | j �� | j�� t� �� d S r )r r. rF r r& r� r" r r r& \ s
zFastChildWatcher.closec C s< | j �" | jd7 _| W d � S 1 s.0 Y d S )Nr )rE rG r� r r r r a s zFastChildWatcher.__enter__c C st | j �N | jd8 _| js"| js2W d � d S t| j�}| j�� W d � n1 sZ0 Y t�d|� d S )Nr z5Caught subprocesses termination from unknown pids: %s)rE rG rF r@ r. r
r )r r r r Zcollateral_victimsr r r r g s
(�zFastChildWatcher.__exit__c G s| | j �P z| j�|�}W n. tyF ||f| j|< Y W d � d S 0 W d � n1 s\0 Y |||g|�R � d S r )rE rF r- rK r )r ro rE rF rp r r r r` u s 2z"FastChildWatcher.add_child_handlerc C s( z| j |= W dS ty" Y dS 0 d S r= r> r r r r r � s
z%FastChildWatcher.remove_child_handlerc C s zt �dt j�\}}W n ty* Y d S 0 |dkr8d S t|�}| j�� z| j�|�\}}W nN ty� | j r�|| j
|< | j � � r�t
�d||� Y W d � q d }Y n0 | j � � r�t
�d||� W d � n1 s�0 Y |d u r�t
�d||� q |||g|�R � q d S )Nr4 r z,unknown process %s exited with returncode %srA z8Caught subprocess termination from unknown pid: %d -> %d)rx r. rC r/ r0 rE r r- rK rG rF r� r� r
r� r )r ro r1 rp rE rF r r r r9 � s:
�
�"�z FastChildWatcher._do_waitpid_all) r� r� r� r r& r r r` r r9 r� r r r" r r L s
r c @ sd e Zd Zdd� 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 )r �_saved_sighandlerr� r r r r � s z MultiLoopChildWatcher.__init__c C s
| j d uS r )rH r� r r r r] � s z MultiLoopChildWatcher.is_activec C sT | j �� | jd u rd S t�tj�}|| jkr:t�d� nt�tj| j� d | _d S )Nz+SIGCHLD handler was changed by outside code) r r. rH r: � getsignalr: r; r
r )r rO r r r r& � s
zMultiLoopChildWatcher.closec C s | S r r r� r r r r � s z MultiLoopChildWatcher.__enter__c C s d S r r �r r! Zexc_valZexc_tbr r r r � s z MultiLoopChildWatcher.__exit__c G s& t �� }|||f| j|< | �|� d S r )r �get_running_loopr r8 )r ro rE rF r� r r r r` � s z'MultiLoopChildWatcher.add_child_handlerc C s( z| j |= W dS ty" Y dS 0 d S r= r> r r r r r � s
z*MultiLoopChildWatcher.remove_child_handlerc C sN | j d urd S t�tj| j�| _ | j d u rK s �z6ThreadedChildWatcher._join_threads..)r) rP r( r� )r �threadsrV r r r rQ I s z"ThreadedChildWatcher._join_threadsc C s | S r r r� r r r r P s z ThreadedChildWatcher.__enter__c C s d S r r rJ r r r r S s z ThreadedChildWatcher.__exit__c C s6 dd� t | j�� �D �}|r2|| j� d�t| d� d S )Nc S s g | ]}|� � r|�qS r )rR rT r r r rW W s �z0ThreadedChildWatcher.__del__..z0 has registered but not finished child processesr$ )r) rP r( r# r- )r r� rX r r r r� V s �z ThreadedChildWatcher.__del__c G sF t �� }tj| jdt| j�� �||||fdd�}|| j|< |�� d S )Nzwaitpid-T)�target�namerF rS ) r rK rD ZThreadr8 �nextrO rP �start)r ro rE rF r� rV r r r r` ^ s
�
z&ThreadedChildWatcher.add_child_handlerc C s dS r� r r r r r r g s z)ThreadedChildWatcher.remove_child_handlerc C s d S r r r r r r r m s z ThreadedChildWatcher.attach_loopc C s� zt �|d�\}}W n& ty: |}d}t�d|� Y n 0 t|�}|�� rZt�d||� |�� rrt�d||� n|j |||g|�R � | j
� |� d S )Nr r, r@ rA rL ) rx r. r/ r
r r0 r� r� rM rn rP r- )r r� r7 rE rF ro r1 rp r r r r8 p s$ �
�z ThreadedChildWatcher._do_waitpidN)r� r� r� r r] r& rQ r r r+ r, r� r` r r r8 r r r r r 2 s
r c sD e Zd ZeZ� 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�B | jd u r:t� | _t�� t�� u r:| j�| jj � W d � n1 sN0 Y d S r )
r rE r^ r rD �current_thread� main_threadr �_localr� r� r r r �
_init_watcher� s
z)_UnixDefaultEventLoopPolicy._init_watcherc s6 t � �|� | jd ur2t�� t�� u r2| j�|� d S r )r �set_event_loopr^ rD r_ r` r r r" r r rc � s
�z*_UnixDefaultEventLoopPolicy.set_event_loopc C s | j d u r| �� | j S r )r^ rb r� r r r r\ � s
z-_UnixDefaultEventLoopPolicy.get_child_watcherc C s | j d ur| j �� || _ d S r )r^ r& )r rk r r r �set_child_watcher� s
z-_UnixDefaultEventLoopPolicy.set_child_watcher) r� r� r� r Z
_loop_factoryr rb rc r\ rd r� r r r" r r] � s
r] )2rC r� rN rx r� r: rz r� r r' rD r+ � r r r r r r r r
r r �logr
�__all__r� � ImportErrorr ZBaseSelectorEventLoopr Z
ReadTransportrS Z_FlowControlMixinZWriteTransportrZ ZBaseSubprocessTransportr_ r r r0 r6 r r r r ZBaseDefaultEventLoopPolicyr] r r r r r r � s`
� NON5Ji}Y2