U
e5dۿ � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
mZ ddl
mZ ddl
mZ ddl
mZ ddl
mZ dd l
mZ dd
l
mZ dd l
mZ dd l
mZ dd
l
mZ ddlmZ dZe
jdkr�e d��dd� Z G dd� dej �Z G dd� dej �Z!G dd� dej"ej#�Z$G dd� dej%�Z&G d d � d �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 ),z2Selector event loop for Unix with signal handling.� N� )� base_events)�base_subprocess)� constants)�
coroutines)�events)�
exceptions)�futures)�selector_events)�tasks)�
transports)�logger)�SelectorEventLoop�AbstractChildWatcher�SafeChildWatcher�FastChildWatcher�MultiLoopChildWatcher�ThreadedChildWatcher�DefaultEventLoopPolicyZwin32z+Signals are not really supported on Windowsc C s dS )zDummy signal handler.N� )�signum�framer r �+/usr/lib64/python3.8/asyncio/unix_events.py�_sighandler_noop* s r c s� e Zd ZdZd)� fdd� Z� fdd�Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
d*dd�Z d+dd�Z d,dd�Z
dd� Zd-ddddd�dd�Zd.dd ddd d �d d �Zd!d"� Zd#d$� Zd%d&� Zd'd(� Z� ZS )/�_UnixSelectorEventLoopzdUnix event loop.
Adds signal handling and UNIX Domain Socket support to SelectorEventLoop.
Nc s t � �|� i | _d S �N)�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 sL t �|�st �|�r td��| �|� | �� zt�| j� � � W n2 t
t fk
rt } zt t
|���W 5 d}~X Y nX t�||| d�}|| j|< z t�|t� t�|d� W n� t k
�rF } zz| j|= | j�szt�d� W n4 t
t fk
�r } zt�d|� W 5 d}~X Y nX |jtjk�r4t d|� d���n� W 5 d}~X Y nX dS )z�Add a handler for a signal. UNIX only.
Raise ValueError if the signal number is invalid or uncatchable.
Raise RuntimeError if there is a problem setting up the handler.
z3coroutines cannot be used with add_signal_handler()NF������ 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 r/ �callback�args�exc�handleZnexcr r r �add_signal_handlerN s2
�
z)_UnixSelectorEventLoop.add_signal_handlerc C s8 | j �|�}|dkrdS |jr*| �|� n
| �|� dS )z2Internal helper that is the actual signal handler.N)r �getZ
_cancelledr) Z_add_callback_signalsafe)r r/ rG r r r r0 { s z%_UnixSelectorEventLoop._handle_signalc
C s� | � |� z | j|= W n tk
r, Y dS X |tjkr@tj}ntj}zt�||� W nB tk
r� } z$|jtj kr�t
d|� d���n� W 5 d}~X Y nX | js�zt� d� W n2 t tfk
r� } zt
�d|� W 5 d}~X Y nX dS )zwRemove a handler for a signal. UNIX only.
Return True if a signal handler was removed, False if not.
Fr5 r6 Nr3 r4 T)r8 r �KeyErrorr9 �SIGINT�default_int_handler�SIG_DFLr= rB rC r> r: r< r
rA )r r/ �handlerrF r r r r) � s(
z,_UnixSelectorEventLoop.remove_signal_handlerc C s6 t |t�std|����|t�� kr2td|� ���dS )z�Internal helper to validate a signal.
Raise ValueError if the signal number is invalid or uncatchable.
Raise RuntimeError if there is a problem setting up the handler.
zsig must be an int, not zinvalid signal number N)�
isinstance�intr7 r9 �
valid_signalsr< r. r r r r8 � 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 )�_UnixWritePipeTransportrS 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 nD t t
fk
r� � Y n, t k
r� | � � | �
� I d H � Y nX W 5 Q R X | S )NzRasyncio.get_child_watcher() is not activated, subprocess support is not installed.)rV rW )r �get_child_watcher� is_activer> �
create_future�_UnixSubprocessTransport�add_child_handlerZget_pid�_child_watcher_callback�
SystemExit�KeyboardInterrupt�
BaseExceptionr% Z_wait)
r rU rE �shell�stdin�stdout�stderr�bufsizerW �kwargs�watcherrV �transpr r r �_make_subprocess_transport� s8
� ��
�z1_UnixSelectorEventLoop._make_subprocess_transportc C s | � |j|� d S r )�call_soon_threadsafeZ_process_exited)r �pid�
returncoderk r r r r` � s z._UnixSelectorEventLoop._child_watcher_callback)�ssl�sock�server_hostname�ssl_handshake_timeoutc � s |d kst |t�st�|r,|d krLtd��n |d k r.cb)Zadd_done_callback)r r� rq r� r r� r r� � s z6_UnixSelectorEventLoop._sock_add_cancellation_callback)N)NN)NN)N)N)N)�__name__�
__module__� __qualname__�__doc__r r% r2 rH r0 r) r8 rX rZ rl r` r� r� r� r� r� r� �
__classcell__r r r! r r / sH -
�
�
�
� � . � � 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 ) rR 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 k r�| j�tj|d � d S )NrT 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 r� rT rU rV rW �moder! r r r � s:
�� �
�z _UnixReadPipeTransport.__init__c C s� | j jg}| jd kr |�d� n| jr0|�d� |�d| j� �� t| jdd �}| jd k r�|d k r�t� || jt
j �}|r�|�d� q�|�d� n | jd k r�|�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 rA r r� r r r �__repr__� s(
�
z _UnixReadPipeTransport.__repr__c
C s� zt �| j| j�}W nD ttfk
r, Y n� tk
rX } z| �|d� W 5 d }~X Y n^X |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
rA r� �_remove_readerr� Z eof_received�_call_connection_lost)r r1 rF 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 rU 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 k r(|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� rU ) rO r= rB ZEIOr� r� r
r� �call_exception_handlerr� r� �r rF 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 rF r r r r� - s z _UnixReadPipeTransport._closec C s4 z| j�|� W 5 | j �� d | _ d | _d | _X d S r �r� r% r� r� Zconnection_lostr� 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 rR � s
rR 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 )(rY 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 k r�| j�t j |d � d S )NrT 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� rT rU rV rW r� Zis_charZis_fifoZ is_socketr! r r r ? s:
�
�z _UnixWritePipeTransport.__init__c C s� | j jg}| jd kr |�d� n| jr0|�d� |�d| j� �� t| jdd �}| jd k r�|d k r�t� || jt
j �}|r�|�d� n
|�d� | � � }|�d|� �� n | jd k r�|�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 rA r r� rh 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
rA r� r� �BrokenPipeErrorr� r r r r� s
z#_UnixWritePipeTransport._read_readyc
C sR t |tttf�s tt|���t |t�r.t|�}|s6d S | jsB| jrj| jtj krXt
� d� | jd7 _d S | j �s8zt
�| j|�}W nt ttfk
r� d}Y nZ ttfk
r� � Y nB tk
r� } z$| jd7 _| �|d� W Y �d S d }~X Y nX |t|�k�r d S |dk�r&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)rO �bytesr� �
memoryviewrw �reprr� r� r Z!LOG_THRESHOLD_FOR_CONNLOST_WRITESr
�warningr� rx �writer� r� r� ra rb rc r� r� r� Z _add_writer� _write_readyZ_maybe_pause_protocol)r r1 �nrF r r r r � s8
z _UnixWritePipeTransport.writec
C s | j std��zt�| j| j �}W n� ttfk
r: Y n� ttfk
rR � Y n� t k
r� } z6| j �
� | j d7 _ | j �
| j� | �|d� W 5 d }~X Y nhX |t| j �kr�| j �
� | j �
| j� | �� | jr�| j �| j� | �d � d S |dk�r | j d |�= d S )NzData should not be emptyr r r )r� rw rx r r� r� r� ra rb rc r- r� r� �_remove_writerr� r� Z_maybe_resume_protocolr� r� r� )r r rF 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 sB | j r
d S | jst�d| _ | js>| j�| j� | j�| jd � d S r� ) r� r� rw 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 k r| js| �� d S r )r� r� r r� r r r r% � s z _UnixWritePipeTransport.closec C s, | j d k r(|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� ) rO 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 s4 z| j�|� W 5 | j �� d | _ d | _d | _X 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 rY < s" % #
rY c @ s e Zd Zdd� ZdS )r^ c K s� d }|t jkrt�� \}}zPt j|f||||d|d�|��| _|d k rh|�� t|�� d|d�| j_ d }W 5 |d k r�|�� |�� X d S )NF)rd re rf rg Zuniversal_newlinesrh �wb)� buffering)
�
subprocess�PIPErz Z
socketpairr% �Popen�_procr� �detachre ) r rE rd re rf rg rh ri Zstdin_wr r r �_start s.
� ��z _UnixSubprocessTransport._startN)r� r� r� r r r r r r^ s r^ c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dS )r aH Abstract base class for monitoring child processes.
Objects derived from this class monitor a collection of subprocesses and
report their termination or interruption by a signal.
New callbacks are registered with .add_child_handler(). Starting a new
process must be done within a 'with' block to allow the watcher to suspend
its activity until the new process if fully registered (this is needed to
prevent a race condition in some implementations).
Example:
with watcher:
proc = subprocess.Popen("sleep 1")
watcher.add_child_handler(proc.pid, callback)
Notes:
Implementations of this class must be thread-safe.
Since child watcher objects may catch the SIGCHLD signal and call
waitpid(-1), there should be only one active object per process.
c G s
t � �dS )a Register a new child handler.
Arrange for callback(pid, returncode, *args) to be called when
process 'pid' terminates. Specifying another callback for the same
process replaces the previous handler.
Note: callback() must be thread-safe.
N��NotImplementedError�r rn rD rE r r r r_ 9 s z&AbstractChildWatcher.add_child_handlerc C s
t � �dS )z�Removes the handler for process 'pid'.
The function returns True if the handler was successfully removed,
False if there was nothing to remove.Nr �r rn r r r �remove_child_handlerD s z)AbstractChildWatcher.remove_child_handlerc C s
t � �dS )z�Attach the watcher to an event loop.
If the watcher was previously attached to an event loop, then it is
first detached before attaching to the new loop.
Note: loop may be None.
Nr �r r� r r r � attach_loopL s z AbstractChildWatcher.attach_loopc C s
t � �dS )zlClose the watcher.
This must be called to make sure that any underlying resource is freed.
Nr r� r r r r% V s zAbstractChildWatcher.closec C s
t � �dS )z�Return ``True`` if the watcher is active and is used by the event loop.
Return True if the watcher is installed and ready to handle process exit
notifications.
Nr r� r r r r\ ] s z AbstractChildWatcher.is_activec C s
t � �dS )zdEnter the watcher's context and allow starting new processes
This function must return selfNr r� r r r � __enter__f s z AbstractChildWatcher.__enter__c C s
t � �dS )zExit the watcher's contextNr �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 r " s
r c C s2 t �| �rt �| � S t �| �r*t �| �S | S d S r )rx � WIFSIGNALED�WTERMSIG� WIFEXITED� WEXITSTATUS)�statusr r r �_compute_returncodeq s
r' 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� �
_callbacksr� 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 k o| j �� S r )r� Z
is_runningr� 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 s~ |d kst |tj�st�| jd k r<|d kr<| jr r r% r� r! r r r% s
zFastChildWatcher.closec
C s0 | j � | jd7 _| W 5 Q R � S Q R X d S )Nr )r= r? r� r r r r s zFastChildWatcher.__enter__c C s^ | j �B | jd8 _| js"| js0W 5 Q R � d S t| j�}| j�� W 5 Q R X t�d|� d S )Nr z5Caught subprocesses termination from unknown pids: %s)r= r? r> r? r- r
r )r r r r Zcollateral_victimsr r r r! s
�zFastChildWatcher.__exit__c G st | j std��| j�F z| j�|�}W n. tk
rT ||f| j|< Y W 5 Q R � d S X W 5 Q R X |||f|�� d S )Nz Must use the context manager)r? rw r= r> r; rJ r) )r rn rD rE ro r r r r_ ' s z"FastChildWatcher.add_child_handlerc C s* z| j |= W dS tk
r$ Y dS X d S r1 r2 r r r r r 5 s
z%FastChildWatcher.remove_child_handlerc C s� zt �dt j�\}}W n tk
r, Y d S X |dkr:d S t|�}| j�� z| j�|�\}}W nN tk
r� | j r�|| j
|< | j � � r�t
�d||� Y W 5 Q R � q d }Y nX | j � � r�t
�d||� W 5 Q R X |d kr�t
�d||� q |||f|�� q d S )Nr3 r z,unknown process %s exited with returncode %sr6 z8Caught subprocess termination from unknown pid: %d -> %d)rx r8 r9 r: r' r= r) r; rJ r? r> r� r� r
r� r )r rn r& ro rD rE r r r r, < s@
�
� �z FastChildWatcher._do_waitpid_all) r� r� r� r� r r% r r! r_ r r, r� r r r! r r � s r c @ sh e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� ZdS )r a~ A watcher that doesn't require running loop in the main thread.
This implementation registers a SIGCHLD signal handler on
instantiation (which may conflict with other code that
install own handler for this signal).
The solution is safe but it has a significant overhead when
handling a big number of processes (*O(n)* each time a
SIGCHLD is received).
c C s i | _ d | _d S r )r) �_saved_sighandlerr� r r r r z s z MultiLoopChildWatcher.__init__c C s
| j d k S r )r@ r� r r r r\ ~ s z MultiLoopChildWatcher.is_activec C sT | j �� | jd krd S t�tj�}|| jkr:t�d� nt�tj| j� d | _d S )Nz+SIGCHLD handler was changed by outside code) r) r- r@ r9 � getsignalr. r/ r
r )r rN 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 �exc_typeZexc_valZexc_tbr r r r! � s z MultiLoopChildWatcher.__exit__c G s& t �� }|||f| j|< | �|� d S r )r �get_running_loopr) r+ )r rn rD rE r� r r r r_ � s z'MultiLoopChildWatcher.add_child_handlerc C s* z| j |= W dS tk
r$ Y dS X d S r1 r2 r r r r r � s
z*MultiLoopChildWatcher.remove_child_handlerc C sN | j d k rd S t�tj| j�| _ | j d kr� s �z6ThreadedChildWatcher._join_threads..N)r( rI �valuesr� )r �threadsrO r r r rJ � s z"ThreadedChildWatcher._join_threadsc C s | S r r r� r r r r s z ThreadedChildWatcher.__enter__c C s d S r r rB r r r r! 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 )rK rM r r r rP s �z0ThreadedChildWatcher.__del__..z0 has registered but not finished child processesr# )r( rI rQ r" r, )r r� rR r r r r� s �z ThreadedChildWatcher.__del__c G sF t �� }tj| jdt| j�� �||||fdd�}|| j|< |�� d S )Nzwaitpid-T)�target�namerE rL ) r rD r< ZThreadr+ �nextrH rI �start)r rn rD rE r� rO r r r r_ s
�
z&ThreadedChildWatcher.add_child_handlerc C s dS r� r r r r r r s z)ThreadedChildWatcher.remove_child_handlerc C s d S r r r r r r r s z ThreadedChildWatcher.attach_loopc C s� |dks t �zt�|d�\}}W n( tk
rH |}d}t�d|� Y n X t|�}|�� rht�d||� |� � r�t�d||� n|j
|||f|�� | j � |� d S )Nr r4 r5 r6 rE )
rw rx r8 r: r
r r' r� r� rF rm rI r; )r r� r* rD rE rn r& ro r r r r+ " s( �
�z ThreadedChildWatcher._do_waitpidN)r� r� r� r� r r\ r% rJ r r! r* r+ r� r_ r r r+ r r r r r � s r c sH e Zd ZdZeZ� fdd�Zdd� Z� fdd�Zdd � Z d
d � Z
� Z S ) �_UnixDefaultEventLoopPolicyz:UNIX event loop policy with a watcher for child processes.c s t � �� d | _d S r )r r �_watcherr� r! r r r A s
z$_UnixDefaultEventLoopPolicy.__init__c C sH t j�8 | jd kr:t� | _tt�� tj�r:| j�| j j
� W 5 Q R X d S r ) r r= rX r rO r< �current_thread� _MainThreadr �_localr� r� r r r �
_init_watcherE s
�z)_UnixDefaultEventLoopPolicy._init_watcherc s6 t � �|� | jdk r2tt�� tj�r2| j�|� dS )z�Set the event loop.
As a side effect, if a child watcher was set before, then calling
.set_event_loop() from the main thread will call .attach_loop(loop) on
the child watcher.
N)r �set_event_looprX rO r< rY rZ r r r! r r r] M s
�z*_UnixDefaultEventLoopPolicy.set_event_loopc C s | j dkr| �� | j S )z~Get the watcher for child processes.
If not yet set, a ThreadedChildWatcher object is automatically created.
N)rX r\ r� r r r r[ [ s
z-_UnixDefaultEventLoopPolicy.get_child_watcherc C s4 |dkst |t�st�| jdk r*| j�� || _dS )z$Set the watcher for child processes.N)rO r rw rX r% )r rj r r r �set_child_watchere s
z-_UnixDefaultEventLoopPolicy.set_child_watcher) r� r� r� r� r Z
_loop_factoryr r\ r] r[ r^ r� r r r! r rW = s
rW )2r� rB r� rG rx r� r9 rz r� r r& r< r* � r r r r r r r r
r r �logr
�__all__r� � ImportErrorr ZBaseSelectorEventLoopr Z
ReadTransportrR Z_FlowControlMixinZWriteTransportrY ZBaseSubprocessTransportr^ r r' r( r r r r ZBaseDefaultEventLoopPolicyrW r r r r r r � s`
� NO5Ji}Y3