File: //usr/local/lib/python3.10/test/test_asyncio/__pycache__/test_unix_events.cpython-310.pyc
o
�iu� � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl m
Z
ddlmZ ddlmZ e jdkrNe �d��ddlZddlmZ dd lmZ dd
lmZ d d � Ze
jZd
d� Z dd� Z dd� Z e � ed�G dd� dej ��Z!e � e"ed�d�G dd� dej ��Z#e � e"ed�d�G d d � d ej ��Z$G d d � d ej �Z%G d d!� d!ej �Z&G d"d#� d#e j �Z'G d$d%� d%e j �Z(G d&d'� d'�Z)G d(d)� d)e)ej �Z*G d*d+� d+e)ej �Z+G d,d-� d-e j �Z,G d.d/� d/e j �Z-e.d0k�re �/� dS dS )1zTests for unix_events.py.� N)�mock)� os_helper)�
socket_helper�win32z UNIX only)�log)� unix_events)�utilsc C s t �d � d S �N)�asyncioZset_event_loop_policy� r r �?/usr/local/lib/python3.10/test/test_asyncio/test_unix_events.py�tearDownModule � r
c C s d| S )N� � r )�exitcoder r r �EXITCODE$ � r c C s, d| kr
dksn t d| � ���d| S )N� �D zinvalid signum r )�AssertionError)�signumr r r �SIGNAL( s r c C s" | j d u rd S | j �� d | _ d S r )Z_pipe�close)� transportr r r �close_pipe_transport. s
r zSignals are not supportedc sF e Zd Z� fdd�Zdd� Zdd� Zdd� Ze�d �d
d � �Z e�d �d d
� �Z
e�d �dd� �Z e�d �dd� �Z e�d �e�d�dd� ��Z
e�d �e�d�dd� ��Ze�d �dd� �Ze�d �dd� �Ze�d �e�d�dd � ��Ze�d �d d � �Ze�d �d d � �Ze�d �d!d"� �Ze�d#�e�d �d$d%� ��Z� ZS )&� SelectorEventLoopSignalTestsc �$ t � �� t�� | _| �| j� d S r ��super�setUpr
ZSelectorEventLoop�loop�set_event_loop��self�� __class__r r r : �
z"SelectorEventLoopSignalTests.setUpc C s. | � t| jjd� | � t| jjtjd � d S )N�1r )� assertRaises� TypeErrorr Z
_check_signal�
ValueError�signal�NSIGr" r r r �test_check_signal? s
��z.SelectorEventLoopSignalTests.test_check_signalc C s | j �tjd � d S )Nr )r �_handle_signalr+ r, r" r r r � test_handle_signal_no_handlerE s z:SelectorEventLoopSignalTests.test_handle_signal_no_handlerc C sh t jt�� dt�� d�}|�� || jjtjd < t�� | j_ | j�
tjd � | jj � tjd � d S )Nr )r r ) r
�Handler �Mock�cancelr �_signal_handlersr+ r, �remove_signal_handlerr. �assert_called_with)r# �hr r r �$test_handle_signal_cancelled_handlerH s � zASelectorEventLoopSignalTests.test_handle_signal_cancelled_handlerzasyncio.unix_events.signalc C s6 t j|_t j|_t|j_| �t| jj t j
dd� � d S )Nc S � dS �NTr r r r r �<lambda>Z � zRSelectorEventLoopSignalTests.test_add_signal_handler_setup_error.<locals>.<lambda>) r+ r, �
valid_signalsr* �
set_wakeup_fd� side_effectr( � RuntimeErrorr �add_signal_handler�SIGINT�r# �m_signalr r r �#test_add_signal_handler_setup_errorQ s
�z@SelectorEventLoopSignalTests.test_add_signal_handler_setup_errorc C sP t j|_dd� }|}|� }| �|j� ||fD ]}| �td| jjt j|� qd S )Nc � s �d S r r r r r r �simple_coroutine` s �z^SelectorEventLoopSignalTests.test_add_signal_handler_coroutine_error.<locals>.simple_coroutinez1coroutines cannot be used with add_signal_handler) r+ r, �
addCleanupr �assertRaisesRegexr) r r@ rA )r# rC rE Z coro_funcZcoro_obj�funcr r r �'test_add_signal_handler_coroutine_error\ s ��zDSelectorEventLoopSignalTests.test_add_signal_handler_coroutine_errorc C sX t j|_t j|_dd� }| j�t j|� | jj�t j�}| �|t j
� | � |j |� d S )Nc S r8 r9 r r r r r r: r r; zFSelectorEventLoopSignalTests.test_add_signal_handler.<locals>.<lambda>)
r+ r, r< r r@ �SIGHUPr3 �get�assertIsInstancer
r0 � assertEqual� _callback)r# rC �cbr6 r r r �test_add_signal_handlerm s z4SelectorEventLoopSignalTests.test_add_signal_handlerc C sT t j|_t j|_dd� }||_G dd� dt�}||j _| �|| jjt j dd� � d S )Nc S s | dkrt � �d S )N���)r* )�fdr r r r= } s �zYSelectorEventLoopSignalTests.test_add_signal_handler_install_error.<locals>.set_wakeup_fdc @ � e Zd ZejZdS )zOSelectorEventLoopSignalTests.test_add_signal_handler_install_error.<locals>.ErrN)�__name__�
__module__� __qualname__�errnoZEFAULTr r r r �Err� �
rX c S r8 r9 r r r r r r: � r; zTSelectorEventLoopSignalTests.test_add_signal_handler_install_error.<locals>.<lambda>)
r+ r, r< r= �OSErrorr> r( r r@ rA )r# rC r= rX r r r �%test_add_signal_handler_install_errorx s
�zBSelectorEventLoopSignalTests.test_add_signal_handler_install_errorzasyncio.base_events.loggerc C sv t j|_t j|_G dd� dt�}||j _dd� | jjt j< | �t | jj
t j dd� � | � |j
j� | �d|jj� d S )Nc @ rS )zPSelectorEventLoopSignalTests.test_add_signal_handler_install_error2.<locals>.ErrN�rT rU rV rW �EINVALr r r r rX � rY rX c S r8 r9 r r r r r r: � r; zUSelectorEventLoopSignalTests.test_add_signal_handler_install_error2.<locals>.<lambda>c S r8 r9 r r r r r r: � r; r )r+ r, r< rZ r> r r3 rJ r( r? r@ rA � assertFalse�info�calledrM r= �
call_count�r# � m_loggingrC rX r r r �&test_add_signal_handler_install_error2� s
�zCSelectorEventLoopSignalTests.test_add_signal_handler_install_error2c C sd G dd� dt �}||j_tj|_tj|_| �t| jjtj dd� � | �
|j j � | �
d|jj� d S )Nc @ rS )zPSelectorEventLoopSignalTests.test_add_signal_handler_install_error3.<locals>.ErrNr\ r r r r rX � rY rX c S r8 r9 r r r r r r: � r; zUSelectorEventLoopSignalTests.test_add_signal_handler_install_error3.<locals>.<lambda>� )rZ r+ r> r, r< r( r? r r@ rA r^ r_ r` rM r= ra rb r r r �&test_add_signal_handler_install_error3� s
�zCSelectorEventLoopSignalTests.test_add_signal_handler_install_error3c C st t j|_t j|_| j�t jdd� � | �| j�t j�� | �|jj � | �|j j � | �
t j|j f|j j d � d S )Nc S r8 r9 r r r r r r: � r; zISelectorEventLoopSignalTests.test_remove_signal_handler.<locals>.<lambda>r )
r+ r, r< r r@ rJ �
assertTruer4 r= r` rM �SIG_DFL� call_argsrB r r r �test_remove_signal_handler� s ��z7SelectorEventLoopSignalTests.test_remove_signal_handlerc C s� t j|_t j|_t j|_| j�t jdd� � t� | jjt j< |j �
� | � | j� t j�� | �
|j j� | � |j j� | �t j|jf|j jd � d S )Nc S r8 r9 r r r r r r: � r; zKSelectorEventLoopSignalTests.test_remove_signal_handler_2.<locals>.<lambda>r )r+ r, rA r< r r@ �objectr3 rJ r= �
reset_mockrg r4 r^ r` rM �default_int_handlerri rB r r r � test_remove_signal_handler_2� s
�
�z9SelectorEventLoopSignalTests.test_remove_signal_handler_2c C sJ t j|_t j|_| j�t jdd� � t|j_| j� t j� | �
|j � d S )Nc S r8 r9 r r r r r r: � r; zWSelectorEventLoopSignalTests.test_remove_signal_handler_cleanup_error.<locals>.<lambda>) r+ r, r< r r@ rJ r* r= r> r4 rg r_ )r# rc rC r r r �(test_remove_signal_handler_cleanup_error� s zESelectorEventLoopSignalTests.test_remove_signal_handler_cleanup_errorc C sD t j|_t j|_| j�t jdd� � t|j _| �t| jj t j� d S )Nc S r8 r9 r r r r r r: � r; zOSelectorEventLoopSignalTests.test_remove_signal_handler_error.<locals>.<lambda>)
r+ r, r< r r@ rJ rZ r> r( r4 rB r r r � test_remove_signal_handler_error� s �z=SelectorEventLoopSignalTests.test_remove_signal_handler_errorc C sT t j|_t j|_| j�t jdd� � G dd� dt�}||j _| �t | jj
t j� d S )Nc S r8 r9 r r r r r r: � r; zPSelectorEventLoopSignalTests.test_remove_signal_handler_error2.<locals>.<lambda>c @ rS )zKSelectorEventLoopSignalTests.test_remove_signal_handler_error2.<locals>.ErrNr\ r r r r rX � rY rX ) r+ r, r< r r@ rJ rZ r> r( r? r4 )r# rC rX r r r �!test_remove_signal_handler_error2� s �z>SelectorEventLoopSignalTests.test_remove_signal_handler_error2c C s� t j|_t j|_| j�t jdd� � | j�t jdd� � | �t| jj �d� |j
� � | j� � | �t| jj �d� |j
�
d� d S )Nc S r8 r9 r r r r r r: � r; z9SelectorEventLoopSignalTests.test_close.<locals>.<lambda>c S r8 r9 r r r r r r: � r; re r rQ )r+ r, r< r r@ rJ �SIGCHLDrM �lenr3 r= rl r �assert_called_once_withrB r r r �
test_close� s
z'SelectorEventLoopSignalTests.test_closezasyncio.unix_events.sysc C s� t j|_t j|_| j�t jdd� � | �t| jj�d� d|j _
|j � � | � t
d��
| j�� W d � n1 s;w Y | �t| jj�d� | �|j j� d S )Nc S r8 r9 r r r r r r: r; zGSelectorEventLoopSignalTests.test_close_on_finalizing.<locals>.<lambda>r Tz skipping signal handlers removalr )r+ r, r< r r@ rJ rM rs r3 �
is_finalizing� return_valuerl �assertWarnsRegex�ResourceWarningr r^ r` )r# rC Zm_sysr r r �test_close_on_finalizing s
� �z5SelectorEventLoopSignalTests.test_close_on_finalizing)rT rU rV r r- r/ r7 r �patchrD rI rP r[ rd rf rj rn ro rp rq ru rz �
__classcell__r r r$ r r 7 sF
r �AF_UNIXz UNIX Sockets are not supportedc s� e Zd Z� fdd�Zejdd� �Zejdd� �Zdd� Zd d
� Z d d � Z
d
d� Z dd� Z dd� Z
e�eed�d�ejdd� ��Zdd� Zdd� Ze�d�d d � �Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Z � Z S )(� SelectorEventLoopUnixSocketTestsc r r r r" r$ r r r r& z&SelectorEventLoopUnixSocketTests.setUpc C s� t �� �8}t�tj�}|�|� |�d� |�� | j�dd� |�}| j� |�}|�� | j� |�
� � W d � d S 1 s?w Y d S )Nr c S � d S r r r r r r r: & r; z]SelectorEventLoopUnixSocketTests.test_create_unix_server_existing_path_sock.<locals>.<lambda>) �
test_utils�unix_socket_path�socketr} �bind�listenr r �create_unix_server�run_until_complete� wait_closed)r# �path�sock�coro�srvr r r �*test_create_unix_server_existing_path_sock s
"�zKSelectorEventLoopUnixSocketTests.test_create_unix_server_existing_path_sockc C sn t �� �)}t�|�}| j�dd� |�}| j�|�}|�� | j�|�� � W d � d S 1 s0w Y d S )Nc S r r r r r r r r: / r; zRSelectorEventLoopUnixSocketTests.test_create_unix_server_pathlib.<locals>.<lambda>) r� r� �pathlib�Pathr r� r� r r� )r# r� Zsrv_coror� r r r � test_create_unix_server_pathlib+ s
"�z@SelectorEventLoopUnixSocketTests.test_create_unix_server_pathlibc C s� t �� �:}t�|�}| j�dd� |�}| �t�� | j�|� W d � n1 s)w Y W d � d S W d � d S 1 sAw Y d S )Nc S r r r r r r r r: 7 r; zVSelectorEventLoopUnixSocketTests.test_create_unix_connection_pathlib.<locals>.<lambda>) r� r� r� r� r �create_unix_connectionr( �FileNotFoundErrorr� )r# r� r� r r r �#test_create_unix_connection_pathlib4 s
��"�zDSelectorEventLoopUnixSocketTests.test_create_unix_connection_pathlibc C s� t �� �7}| j�dd� |j�}| �td�� | j�|� W d � n1 s&w Y W d � d S W d � d S 1 s>w Y d S )Nc S r r r r r r r r: ? r; z`SelectorEventLoopUnixSocketTests.test_create_unix_server_existing_path_nonsock.<locals>.<lambda>zAddress.*is already in use)�tempfile�NamedTemporaryFiler r� �namerG rZ r� )r# �filer� r r r �-test_create_unix_server_existing_path_nonsock= s
� ��"�zNSelectorEventLoopUnixSocketTests.test_create_unix_server_existing_path_nonsockc C �T | j jdd� ddd�}| �td�� | j �|� W d � d S 1 s#w Y d S )Nc S r r r r r r r r: E r; zSSelectorEventLoopUnixSocketTests.test_create_unix_server_ssl_bool.<locals>.<lambda>�spamT)r� �sslz"ssl argument must be an SSLContext)r r� rG r) r� �r# r� r r r � test_create_unix_server_ssl_boolD s ��"�zASelectorEventLoopUnixSocketTests.test_create_unix_server_ssl_boolc C sR | j jdd� d d�}| �td�� | j �|� W d � d S 1 s"w Y d S )Nc S r r r r r r r r: L r; zXSelectorEventLoopUnixSocketTests.test_create_unix_server_nopath_nosock.<locals>.<lambda>�r� z#path was not specified, and no sock�r r� rG r* r� r� r r r �%test_create_unix_server_nopath_nosockK s �"�zFSelectorEventLoopUnixSocketTests.test_create_unix_server_nopath_nosockc C s� t � � }|�8 | jjdd� d |d�}| �td�� | j�|� W d � n1 s)w Y W d � d S W d � d S 1 sAw Y d S )Nc S r r r r r r r r: T r; zXSelectorEventLoopUnixSocketTests.test_create_unix_server_path_inetsock.<locals>.<lambda>�r� r� �"A UNIX Domain Stream.*was expected)r� r r� rG r* r� �r# r� r� r r r �%test_create_unix_server_path_inetsockQ s �� ��"�zFSelectorEventLoopUnixSocketTests.test_create_unix_server_path_inetsockc C s� t � t jt j�}|�8 | jjdd� d |d�}| �td�� | j�|� W d � n1 s-w Y W d � d S W d � d S 1 sEw Y d S )Nc S r r r r r r r r: ] r; zUSelectorEventLoopUnixSocketTests.test_create_unix_server_path_dgram.<locals>.<lambda>r� r� )r� r} �
SOCK_DGRAMr r� rG r* r� r� r r r �"test_create_unix_server_path_dgramZ s �� ��"�zCSelectorEventLoopUnixSocketTests.test_create_unix_server_path_dgram�
SOCK_NONBLOCKz$no socket.SOCK_NONBLOCK (linux only)c C s� t � t jt jt jB �}t�� � }|j}W d � n1 s w Y zD|�* |�|� | jj dd� d |d�}| j�
|�}|� � | j�
|� � � W d � n1 sRw Y W t
�|� d S W t
�|� d S t
�|� w )Nc S r r r r r r r r: n r; z^SelectorEventLoopUnixSocketTests.test_create_unix_server_path_stream_bittype.<locals>.<lambda>r� )r� r} � SOCK_STREAMr� r� r� r� r� r r� r� r r� �os�unlink)r# r� r� �fnr� r� r r r �+test_create_unix_server_path_stream_bittypec s& �
�
� ��zLSelectorEventLoopUnixSocketTests.test_create_unix_server_path_stream_bittypec C r� )Nc S r r r r r r r r: w r; zfSelectorEventLoopUnixSocketTests.test_create_unix_server_ssl_timeout_with_plain_sock.<locals>.<lambda>r� r �r� Zssl_handshake_timeout�1ssl_handshake_timeout is only meaningful with sslr� r� r r r �3test_create_unix_server_ssl_timeout_with_plain_sockv � ��"�zTSelectorEventLoopUnixSocketTests.test_create_unix_server_ssl_timeout_with_plain_sockc C s� t � � }|�7 | jjdd� |d�}| �td�� | j�|� W d � n1 s(w Y W d � d S W d � d S 1 s@w Y d S )Nc S r r r r r r r r: � r; z\SelectorEventLoopUnixSocketTests.test_create_unix_connection_path_inetsock.<locals>.<lambda>�r� r� )r� r r� rG r* r� r� r r r �)test_create_unix_connection_path_inetsock~ s �� ��"�zJSelectorEventLoopUnixSocketTests.test_create_unix_connection_path_inetsockzasyncio.unix_events.socketc C s� t �� }||j_t|j_| jjdd� dd�}| � t�� | j�
|� W d � n1 s,w Y | � |j j
� t|j_| jjdd� dd�}| � t�� | j�
|� W d � n1 s\w Y | � |j j
� d S )Nc S r r r r r r r r: � r; zUSelectorEventLoopUnixSocketTests.test_create_unix_server_bind_error.<locals>.<lambda>z/testr� c S r r r r r r r r: � r; )r r1 r� rw rZ r� r> r r� r( r� rg r r` � MemoryError)r# Zm_socketr� r� r r r �"test_create_unix_server_bind_error� s � �zCSelectorEventLoopUnixSocketTests.test_create_unix_server_bind_errorc C sX | j jdd� tjt� d�}| �td�� | j �|� W d � d S 1 s%w Y d S )Nc S r r r r r r r r: � r; zXSelectorEventLoopUnixSocketTests.test_create_unix_connection_path_sock.<locals>.<lambda>r� zpath and sock can not be)r r� r� �devnullrk rG r* r� r� r r r �%test_create_unix_connection_path_sock� s �"�zFSelectorEventLoopUnixSocketTests.test_create_unix_connection_path_sockc C sP | j �dd� d �}| �td�� | j �|� W d � d S 1 s!w Y d S )Nc S r r r r r r r r: � r; z\SelectorEventLoopUnixSocketTests.test_create_unix_connection_nopath_nosock.<locals>.<lambda>z no path and sock were specified�r r� rG r* r� r� r r r �)test_create_unix_connection_nopath_nosock� s ��"�zJSelectorEventLoopUnixSocketTests.test_create_unix_connection_nopath_nosockc C �V | j jdd� tjdd�}| �td�� | j �|� W d � d S 1 s$w Y d S )Nc S r r r r r r r r: � r; z_SelectorEventLoopUnixSocketTests.test_create_unix_connection_nossl_serverhost.<locals>.<lambda>r� )Zserver_hostnamez"server_hostname is only meaningful�r r� r� r� rG r* r� r� r r r �,test_create_unix_connection_nossl_serverhost� s ��"�zMSelectorEventLoopUnixSocketTests.test_create_unix_connection_nossl_serverhostc C r� )Nc S r r r r r r r r: � r; z_SelectorEventLoopUnixSocketTests.test_create_unix_connection_ssl_noserverhost.<locals>.<lambda>T)r� z/you have to pass server_hostname when using sslr� r� r r r �,test_create_unix_connection_ssl_noserverhost� s ��"�zMSelectorEventLoopUnixSocketTests.test_create_unix_connection_ssl_noserverhostc C r� )Nc S r r r r r r r r: � r; zjSelectorEventLoopUnixSocketTests.test_create_unix_connection_ssl_timeout_with_plain_sock.<locals>.<lambda>r� r r� r� r� r� r r r �7test_create_unix_connection_ssl_timeout_with_plain_sock� r� zXSelectorEventLoopUnixSocketTests.test_create_unix_connection_ssl_timeout_with_plain_sock) rT rU rV r r Z skip_unless_bind_unix_socketr� r� r� r� r� r� r� r� �unittest�
skipUnless�hasattrr� r� r� r� r r{ r� r� r� r� r� r� r| r r r$ r r~ s4
�
r~ �sendfilezsendfile is not supportedc s� e Zd Zdd ZG dd� dej�Ze� fdd��Ze� fdd��Z � fd d
�Z
d&d d
�Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Z� ZS )'�&SelectorEventLoopUnixSockSendfileTestss� 12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde� c @ �4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) z.SelectorEventLoopUnixSockSendfileTests.MyProtoc C s2 d| _ d| _t� | _|�� | _d | _|�� | _d S )NF)�started�closed� bytearray�data�
create_future�futr �_ready)r# r r r r �__init__� s
z7SelectorEventLoopUnixSockSendfileTests.MyProto.__init__c C s d| _ || _| j�d � d S r9 )r� r r� �
set_result)r# r r r r �connection_made� s z>SelectorEventLoopUnixSockSendfileTests.MyProto.connection_madec C s | j �|� d S r )r� �extend)r# r� r r r �
data_received� s z<SelectorEventLoopUnixSockSendfileTests.MyProto.data_receivedc C s d| _ | j�d � d S r9 )r� r� r� )r# �excr r r �connection_lost� s z>SelectorEventLoopUnixSockSendfileTests.MyProto.connection_lostc � s �| j I d H d S r )r� r" r r r r� � s �z:SelectorEventLoopUnixSockSendfileTests.MyProto.wait_closedN)rT rU rV r� r� r� r� r� r r r r �MyProto� s r� c sF t tjd��}|�| j� W d � n1 sw Y t� �� d S )N�wb)�openr �TESTFN�write�DATAr �
setUpClass)�cls�fpr$ r r r� � s �z1SelectorEventLoopUnixSockSendfileTests.setUpClassc s t �t j� t� �� d S r )r r� r� r �
tearDownClass)r� r$ r r r� � s z4SelectorEventLoopUnixSockSendfileTests.tearDownClassc s@ t �� | _| �| j� ttjd�| _| �| jj � t
� � � d S )N�rb) r
�new_event_loopr r! r� r r� r� rF r r r r" r$ r r r � s
z,SelectorEventLoopUnixSockSendfileTests.setUpTc C sR t � t jt j�}|�d� |�t jt jd� |�t jt jd� |r'| �|j � |S )NFr� )
r� �AF_INETr� � setblocking�
setsockopt�
SOL_SOCKET� SO_SNDBUF� SO_RCVBUFrF r )r# �cleanupr� r r r � make_socket� s
z2SelectorEventLoopUnixSockSendfileTests.make_socketc C s | j �|�S r )r r� r� r r r �run_loop� � z/SelectorEventLoopUnixSockSendfileTests.run_loopc s� �� � }���j�� t�� }�j dd�}|�tj|f� ���jj� fdd�|d������j� |tj|f�� ��� j
� � ��fdd�}�� |� |� fS )NF)r� c s � S r r r )�protor r r: r; z@SelectorEventLoopUnixSockSendfileTests.prepare.<locals>.<lambda>r� c s2 � j �� ��� �� � ��� ����� � d S r )r r r� r� r �r� r# Zserverr r r� s
z?SelectorEventLoopUnixSockSendfileTests.prepare.<locals>.cleanup) r� r� r r Zfind_unused_portr� ZHOSTr� �
create_serverZ sock_connectr� rF )r# r� �portZsrv_sockr� r r� r �prepare� s
�
z.SelectorEventLoopUnixSockSendfileTests.preparec
C s� | � � \}}tjdg d��, | �tjd�� | �| j�|| j dd �� W d � n1 s-w Y W d � n1 s<w Y | �
| j � � d� d S )Nzasyncio.unix_events.os)�specz$os[.]sendfile[(][)] is not availabler ) r� r r{ rG r
�SendfileNotAvailableErrorr� r �_sock_sendfile_nativer� rM �tell)r# r� r� r r r � test_sock_sendfile_not_available s �� �� �zGSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_not_availablec C sn | � � \}}t� }| �tjd�� | �| j�||dd �� W d � n1 s'w Y | �| j �
� d� d S �N�not a regular filer ) r� rk rG r
r� r� r r� rM r� r� �r# r� r� �fr r r � test_sock_sendfile_not_a_file s �� �zDSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_not_a_filec C sp | � � \}}t�� }| �tjd�� | �| j�||dd �� W d � n1 s(w Y | � | j
� � d� d S r� ) r� �io�BytesIOrG r
r� r� r r� rM r� r� r� r r r �test_sock_sendfile_iobuffer# s �� �zBSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_iobufferc C sx | � � \}}t�� }d|j_| �tjd�� | �| j �
||dd �� W d � n1 s,w Y | � | j �
� d� d S )NrQ r� r )r� r r1 �filenorw rG r
r� r� r r� rM r� r� r� r r r �#test_sock_sendfile_not_regular_file, s �� �zJSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_not_regular_filec
C s� | � � \}}| j�� }| j�� }| j�|d ||dd t| j�d� |�� t �
t j ��
| �
|� W d � n1 s:w Y | �t�� | jj�|� W d � d S 1 sWw Y d S �Nr )r� r r� r� r� �_sock_sendfile_native_implrs r� r2 �
contextlib�suppressr
�CancelledErrorr� r( �KeyError� _selector�get_key�r# r� r� r� r� r r r �test_sock_sendfile_cancel16 s
� � "�zASelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_cancel1c
C s� | � � \}}| j�� }| j�� }| j�|d ||dd t| j�d� |�� | j�||�� ||dd t| j�d� | � t
�� | jj � |� W d � d S 1 sNw Y d S r� )
r� r r� r� r� r� rs r� r2 r( r r r r r r r �test_sock_sendfile_cancel2C s
�� "�zASelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_cancel2c C s� | � � \}}| j�� }t�� }d|j_tjdt� d�� | j �
|d ||dd t | j �d� W d � n1 s6w Y | j j
�|�}| �|� |j�tj� d S )NF� os.sendfile�r> r )r� r� r� r r1 � cancelledrw r{ �BlockingIOErrorr r� rs r� r r �assertIsNotNone�add_done_callbackrt �ANY)r# r� r� r� r� �keyr r r �!test_sock_sendfile_blocking_errorP s
� �
zHSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_blocking_errorc C s� | � � \}}| j�� }| j�� }tjdt� d�� | j�|d ||dd t | j
�d� W d � n1 s3w Y | � t �� | jj
�|� W d � n1 sOw Y |�� }| �|tj� | �d| j�� � d S )Nr r r )r� r� r� r r� r r{ rZ r� rs r� r( r r r � exceptionrL r
r� rM r� )r# r� r� r� r� r� r r r �&test_sock_sendfile_os_error_first_call] s
� � �zMSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_os_error_first_callc C s� | � � \}}| j�� }| j�� }t� }tjd|d�� | j�||�� ||dd t | j
�d� W d � n1 s7w Y | � t �� | jj
�|� W d � n1 sSw Y |�� }| �||� | �d| j�� � d S �Nr r i� )r� r� r� r r� rZ r r{ r� rs r� r( r r r r �assertIsrM r� �r# r� r� r� r� �errr� r r r �%test_sock_sendfile_os_error_next_callk s"
� � � zLSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_os_error_next_callc C s� | � � \}}| j�� }| j�� }t�� }tjd|d�� | j� ||�� ||dd t
| j �d� W d � n1 s8w Y | � t
�� | jj�|� W d � n1 sTw Y |�� }| �||� | �d| j�� � d S r )r� r� r� r r� r
r� r r{ r� rs r� r( r r r r r rM r� r r r r � test_sock_sendfile_exception| s"
� � � zCSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_exception)T)rT rU rV r� r
�Protocolr� � classmethodr� r� r r� r� r� r� r� r� r� r r r r r r r| r r r$ r r� � s*
r� c s
e Zd Z� fdd�Zd(dd�Zdd� Ze�d�d d
� �Ze�d�d d � �Z e�d�d
d� �Z
e�d�e�d�dd� ��Z e�d�dd� �Z e�d�dd� �Z
e�d�dd� �Ze�d�dd� �Ze�d�dd� �Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Z� ZS ))�UnixReadPipeTransportTestsc � t � �� | �� | _t�tj�| _t j
t j d�| _
d| j
j_t �d�}|�� | �|j� t �d�}|�� }t �
� }tj|_||_| �|j� d S �N)Zspec_set� zos.set_blockingzos.fstat)r r �
new_test_loopr r� �make_test_protocolr
r �protocolr r1 r� � RawIOBase�piper� rw r{ �startrF �stop�stat�S_IFIFO�st_mode�r# Zblocking_patcherZ
fstat_patcherZm_fstat�str$ r r r � �
z UnixReadPipeTransportTests.setUpNc C �( t j| j| j| j|d�}| �t|� |S �N��waiter)r Z_UnixReadPipeTransportr r" r rF r �r# r. r r r r �read_pipe_transport� � � z.UnixReadPipeTransportTests.read_pipe_transportc C sR | j �� }| j|d�}| j �|� | jj�|� | j �d|j� | � |�
� � d S �Nr- r ) r r� r0 r� r r� r5 �
assert_reader� _read_ready� assertIsNone�result�r# r. �trr r r � test_ctor� s
z$UnixReadPipeTransportTests.test_ctorzos.readc C s6 | � � }d|_|�� |�d|j� | jj�d� d S �N� datar )r0 rw r4 r5 �max_sizer r� �r# �m_readr8 r r r �test__read_ready� s
z+UnixReadPipeTransportTests.test__read_readyc C s\ | � � }d|_|�� |�d|j� | �| jj� t� | j� | j
j �� | j
j �d � d S )N� r )
r0 rw r4 r5 r< r^ r �readersr� � run_brieflyr Z eof_receivedr� r= r r r �test__read_ready_eof� s z/UnixReadPipeTransportTests.test__read_ready_eofc C sD | � � }t|_|�� |�d|j� t�| j� | � | j
j j � d S �Nr )
r0 r
r> r4 r5 r< r� rB r r^ r r� r` r= r r r �test__read_ready_blocked� s z3UnixReadPipeTransportTests.test__read_ready_blocked�asyncio.log.logger.errorc C s^ | � � }t� }||_t�� |_|�� |�d|j� |j�|� |jt �
d�tt t fd� d S )Nr z;Fatal read error on pipe transport
protocol:.*
transport:.*)�exc_info) r0 rZ r> r r1 �_closer4 r5 r< r� Z MockPattern�MOCK_ANY)r# r> �m_logexcr8 r r r r �test__read_ready_error� s
�
�z1UnixReadPipeTransportTests.test__read_ready_errorc C s8 | � � }t�� }| j�d|� |�� | �| jj� d S rD )r0 r r1 r �
add_reader�
pause_readingr^ rA )r# r> r8 �mr r r �test_pause_reading� s
z-UnixReadPipeTransportTests.test_pause_readingc C s, | � � }|�� |�� | j�d|j� d S rD )r0 rM �resume_readingr r3 r4 r= r r r �test_resume_reading� s z.UnixReadPipeTransportTests.test_resume_readingc C s* | � � }t�� |_|�� |j�d � d S r )r0 r r1 rH r r5 r= r r r ru � s
z%UnixReadPipeTransportTests.test_closec C s2 | � � }d|_t�� |_|�� | �|jj� d S r9 )r0 �_closingr r1 rH r r^ r` r= r r r �test_close_already_closing� s
z5UnixReadPipeTransportTests.test_close_already_closingc C sR | � � }t� }|�|� | �|�� � | �| jj� t� | j� | j
j � |� d S r )
r0 rk rH rg �
is_closingr^ r rA r� rB r r� r5 )r# r> r8 r r r r � test__close s
z&UnixReadPipeTransportTests.test__closec C �d | � � }| �|j� | �|j� d }|�|� | jj�|� | jj �� | �
|j� | �
|j� d S r ) r0 r � _protocol�_loop�_call_connection_lostr r� r5 r" r r5 �r# r8 r r r r �test__call_connection_lost
�
z5UnixReadPipeTransportTests.test__call_connection_lostc C �f | � � }| �|j� | �|j� t� }|�|� | jj�|� | j j
�� | � |j� | � |j� d S r ) r0 r rW rX rZ rY r r� r5 r" r r5 rZ r r r �#test__call_connection_lost_with_err �
z>UnixReadPipeTransportTests.test__call_connection_lost_with_errc C �4 | � � }|�� t�| j� | �|j� |�� d S r )r0 r r� rB r r5 rX rM �r# r8 r r r �!test_pause_reading_on_closed_pipe$ �
z<UnixReadPipeTransportTests.test_pause_reading_on_closed_pipec C s | � � }|�� |�� d S r )r0 rM ra r r r �!test_pause_reading_on_paused_pipe+ s z<UnixReadPipeTransportTests.test_pause_reading_on_paused_pipec C r` r )r0 r r� rB r r5 rX rP ra r r r �"test_resume_reading_on_closed_pipe1 rc z=UnixReadPipeTransportTests.test_resume_reading_on_closed_pipec C s | � � }|�� d S r )r0 rP ra r r r �"test_resume_reading_on_paused_pipe8 s z=UnixReadPipeTransportTests.test_resume_reading_on_paused_piper )rT rU rV r r0 r9 r r{ r? rC rE rK rO rQ ru rS rU r[ r^ rb rd re rf r| r r r$ r r � s:
r c s~ e Zd Z� fdd�Zd7dd�Zdd� Zdd � Ze�d
�d d � �Z e�d
�d
d� �Z
e�d
�dd� �Z e�d
�dd� �Z e�d
�dd� �Z
e�d�e�d
�dd� ��Ze�d
�dd� �Zdd� Ze�d
�d d � �Ze�d
�d d � �Ze�d
�d d!� �Ze�d
�d"d#� �Ze�d$�e�d
�d%d&� ��Ze�d
�d'd(� �Ze�d
�d)d*� �Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z � Z S )8�UnixWritePipeTransportTestsc r r )r r r r r� r r
Z BaseProtocolr r r1 r� r! r" r� rw r{ r# rF r$ r% �S_IFSOCKr' r( r$ r r r A r* z!UnixWritePipeTransportTests.setUpNc C r+ r, )r Z_UnixWritePipeTransportr r" r rF r r/ r r r �write_pipe_transportS r1 z0UnixWritePipeTransportTests.write_pipe_transportc C sT | j �� }| j|d�}| j �|� | jj�|� | j �d|j� | � d |�
� � d S r2 ) r r� ri r� r r� r5 r3 r4 rM r6 r7 r r r r9 Z s
z%UnixWritePipeTransportTests.test_ctorc C s | � � }| �|�� � d S r )ri rg Z
can_write_eofra r r r �test_can_write_eofc s z.UnixWritePipeTransportTests.test_can_write_eofzos.writec C sF | � � }d|_|�d� |�dd� | �| jj� | �t� |j � d S )N� r; r )
ri rw r� r5 r^ r �writersrM r� �_buffer�r# �m_writer8 r r r �
test_writeg s
z&UnixWritePipeTransportTests.test_writec C sB | � � }|�d� | �|j� | �| jj� | �td�|j� d S )Nr@ ) ri r� r^ r` r rl rM r� rm rn r r r �test_write_no_datap s
z.UnixWritePipeTransportTests.test_write_no_datac C s> | � � }d|_|�d� | j�d|j� | �td�|j� d S )Nre r; r � ta) ri rw r� r �
assert_writer� _write_readyrM r� rm rn r r r �test_write_partialx s
z.UnixWritePipeTransportTests.test_write_partialc C s^ | � � }| j�d|j� td�|_|�d� | �|j� | j� d|j� | �
td�|j� d S )Nr s previousr; s previousdata) ri r �
add_writerrt r� rm r� r^ r` rs rM rn r r r �test_write_buffer� s
z-UnixWritePipeTransportTests.test_write_bufferc C sP | � � }t� |_|�d� |�dtd�� | j�d|j� | � td�|j
� d S r: ) ri r
r> r� r5 r� r rs rt rM rm rn r r r �test_write_again� s
z,UnixWritePipeTransportTests.test_write_againzasyncio.unix_events.loggerc C s� | � � }t� }||_t�� |_|�d� |�dd� | �| j j
� | � t � |j
� |j�|d� | � d|j� |�d� | � d|j� |�d� |�d� |�d� |�d� |j�d� |�� d S )Nr; r z#Fatal write error on pipe transportr re z=pipe closed by peer or os.write(pipe, data) raised exception.)ri rZ r> r r1 Z _fatal_errorr� r5 r^ r rl rM r� rm �
_conn_lost�warningr )r# ro Zm_logr8 r r r r �test_write_err� s.
�
� z*UnixWritePipeTransportTests.test_write_errc C sD | � � }|�� |�d� | �|jd� |�d� | �|jd� d S )Nr; r re )ri r4 r� rM ry rn r r r �test_write_close� s
z,UnixWritePipeTransportTests.test_write_closec C sX | � � }|�� | �| jj� | �| jj� | �|�� � t� | j� | j
j � d � d S r )
ri r4 r^ r rA rl rg rT r� rB r r� r5 ra r r r r? � s z,UnixWritePipeTransportTests.test__read_readyc C sR | � � }| j�d|j� td�|_d|_|�� | �| jj� | � t� |j� d S )Nr r; rk )
ri r rv rt r� rm rw r^ rl rM rn r r r �test__write_ready� s
z-UnixWritePipeTransportTests.test__write_readyc C sV | � � }| j�d|j� td�|_d|_|�� | j�d|j� | �td�|j� d S )Nr r; � � a) ri r rv rt r� rm rw rs rM rn r r r �test__write_ready_partial� s
z5UnixWritePipeTransportTests.test__write_ready_partialc C sh | � � }| j�d|j� td�|_t� |_|�� |�dtd�� | j� d|j� | �
td�|j� d S )Nr r; ) ri r rv rt r� rm r
r> r5 rs rM rn r r r �test__write_ready_again� s
z3UnixWritePipeTransportTests.test__write_ready_againc C sf | � � }| j�d|j� td�|_d|_|�� |�dtd�� | j�d|j� | � td�|j� d S )Nr r; r )
ri r rv rt r� rm rw r5 rs rM rn r r r �test__write_ready_empty� s
z3UnixWritePipeTransportTests.test__write_ready_emptyrF c C s� | � � }| j�d|j� td�|_t� |_}|�� | �| jj � | �| jj
� | � t� |j� | � |�
� � |�� | � d|j� t�| j� | jj�|� d S )Nr r; r )ri r rv rt r� rm rZ r> r^ rl rA rM rg rT Zassert_not_calledry r� rB r r� r5 )r# ro rJ r8 r r r r �test__write_ready_err� s
z1UnixWritePipeTransportTests.test__write_ready_errc C s� | � � }| j�d|j� d|_td�|_d|_|�� | �| jj � | �| jj
� | � t� |j� | j j
�d � | jj�� d S )Nr Tr; rk )ri r rv rt rR r� rm rw r^ rl rA rM r r� r5 r" r rn r r r �test__write_ready_closing� s
z5UnixWritePipeTransportTests.test__write_ready_closingc C s� | � � }| j�d|j� | j�d|j� ddg|_|�� | �|j � | �| jj
� | �| jj � | � g |j� | �
|�� � t�| j� | jj�d � d S )Nr s darr )ri r rv rt rL r4 rm �abortr^ r` rA rl rM rg rT r� rB r r� r5 rn r r r �
test_abort
s
z&UnixWritePipeTransportTests.test_abortc C rV r ) ri r rW rX rY r r� r5 r" r r5 rZ r r r r[ r\ z6UnixWritePipeTransportTests.test__call_connection_lostc C r] r ) ri r rW rX rZ rY r r� r5 r" r r5 rZ r r r r^ & r_ z?UnixWritePipeTransportTests.test__call_connection_lost_with_errc C s0 | � � }t�� |_|�� |j�� |�� d S r )ri r r1 � write_eofr r5 ra r r r ru 3 s
z&UnixWritePipeTransportTests.test_closec C s2 | � � }t�� |_d|_|�� | �|jj� d S r9 )ri r r1 r� rR r r^ r` ra r r r �test_close_closing< s
z.UnixWritePipeTransportTests.test_close_closingc C sJ | � � }|�� | �|�� � | �| jj� t�| j� | j j
� d � d S r ) ri r� rg rT r^ r rA r� rB r r� r5 ra r r r �test_write_eofC s z*UnixWritePipeTransportTests.test_write_eofc C s: | � � }dg|_|�� | �|�� � | �| jjj� d S )Nr; ) ri rm r� rg rT r^ r r� r` ra r r r �test_write_eof_pendingK s
z2UnixWritePipeTransportTests.test_write_eof_pendingr ) rT rU rV r ri r9 rj r r{ rp rq ru rw rx r{ r| r? r} r� r� r� r� r� r� r[ r^ ru r� r� r� r| r r r$ r rg ? sT
rg c @ � e Zd Zdd� ZdS )�AbstractChildWatcherTestsc C s� t �� }t�� }| �t|j||� | �t|j|� | �t|j|� | �t|j � | �t|j
� | �t|j � | �t|j |||� d S r )
r r1 r
ZAbstractChildWatcherr( �NotImplementedError�add_child_handler�remove_child_handler� attach_loopr Z is_active� __enter__�__exit__�r# r� �watcherr r r �test_not_implementedU s.
������ �z.AbstractChildWatcherTests.test_not_implementedN�rT rU rV r� r r r r r� S � r� c @ r� )�BaseChildWatcherTestsc C s$ t �� }t�� }| �t|j|� d S r )r r1 r ZBaseChildWatcherr( r� Z _do_waitpidr� r r r r� j s
�z*BaseChildWatcherTests.test_not_implementedNr� r r r r r� h r� r� c s� e Zd Zej�ejd�Z� fdd�Z dd� Z
dd� Z dd � Z d
d � Z
d d
� Zedd� �Zedd� �Zedd� �Zedd� �Zedd� �Zedd� �Zedd� �Zed d � �Zed d � �Zed d!� �Zed"d#� �Zed$d%� �Zed&d'� �Zed(d)� �Z � Z S )*�ChildWatcherTestsMixinrz c sp t � �� | �� | _d| _i | _tj�| jd��| _ | �
� | _ | j � | j� W d � d S 1 s1w Y d S )NFr@ )
r r r r �running�zombiesr r{ rk �m_add_signal_handler�create_watcherr� r� r" r$ r r r u s
�
"�z ChildWatcherTestsMixin.setUpc C sl t | jtj�s |dkr| �|d� z|dk r | j�� W S || j�|�fW S ty- Y nw | j r3dS t
� �)NrQ r )r r ) �
isinstancer� r
�SafeChildWatcherZ
assertGreaterr� �popitem�popr r� �ChildProcessError)r# �pid�flagsr r r �waitpid� s �z ChildWatcherTestsMixin.waitpidc C s || j |< d S r )r� )r# r� �statusr r r �
add_zombie� r z!ChildWatcherTestsMixin.add_zombiec C s4 |dkr|d S d| k rdk r|d S |S |S )Nr i� r )r# r� r r r �waitstatus_to_exitcode� s �z-ChildWatcherTestsMixin.waitstatus_to_exitcodec C s | j �tj| jj� d S r )r� rt r+ rr r� � _sig_chldr" r r r �test_create_watcher� s
�z*ChildWatcherTestsMixin.test_create_watcherc s � fdd�}|S )Nc s� dd� }|d| j ��, |d| j��
}� | |� W d � n1 s!w Y W d � d S W d � d S 1 s9w Y d S )Nc S s t j| |t jd�S )N)�wrapsZ new_callable)r r{ r1 )�target�wrapperr r r r{ � s �zIChildWatcherTestsMixin.waitpid_mocks.<locals>.wrapped_func.<locals>.patchz*asyncio.unix_events.waitstatus_to_exitcodez
os.waitpid)r� r� )r# r{ � m_waitpid�rH r r � wrapped_func� s
� P�z:ChildWatcherTestsMixin.waitpid_mocks.<locals>.wrapped_funcr )rH r� r r� r �
waitpid_mocks� s z$ChildWatcherTestsMixin.waitpid_mocksc C s t �� }| j� d| _| j�d|ddd� W d � n1 s w Y | �|j� | j�� | �|j� d| _| �dt d�� | j�� |�
ddddd� |� � | �dt d�� | j �
| j�� W d � n1 smw Y | �|j� | j
�� | j�� | �|j� d S ) NT�* � �
� F� �
)r r1 r� r� r� r^ r` r� r� r rt rl �ignore_warningsr� �clear�r# r� �callbackr r r � test_sigchld� s* �
�
z#ChildWatcherTestsMixin.test_sigchldc C s t �� }t �� }| j� d| _| j�d|dd� W d � n1 s"w Y | �|j� | �|j� | j� | j�d|dd� W d � n1 sJw Y | �|j� | �|j� | j�� | �|j� | �|j� | �dt d�� | j�� |�
dd dd� | �|j� |� � | j�� | �|j� | �|j� | �dt d
�� d | _| j�� |�
dd
dd� | �|j� |� � | �dt d �� | �dt d
�� | j
�
| j�� W d � n1 s�w Y | �|j� | �|j� | j�� | j�� | �|j� | �|j� d S )NT�+ � � �, � � r~ ����l Fr� � )r r1 r� r� r� r^ r` r� r� r rt rl r r� r� r� �r# r� � callback1� callback2r r r �test_sigchld_two_children� sR � �
�
z0ChildWatcherTestsMixin.test_sigchld_two_childrenc C s� t �� }t �� }| j� d| _| j�d|dd� W d � n1 s"w Y | �|j� | �|j� | j� | j�d|dd� W d � n1 sJw Y | �|j� | �|j� | j�� | �|j� | �|j� | �dt d�� | �dt
d �� d
| _| j�� |� dddd� |� dd dd� |� � |� � | �dt d �� | �dt d
�� | j
�
| j�� W d � n1 s�w Y | �|j� | �|j� d S )NT�- � r� �. i{ r� �N r F���r� r� )r r1 r� r� r� r^ r` r� r� r r rt rl r� r� r r r �.test_sigchld_two_children_terminating_together s> � �
� zEChildWatcherTestsMixin.test_sigchld_two_children_terminating_togetherc C s� t �� }| j� | �dtd�� | j�� | j�d|dd� W d � n1 s(w Y |�dddd� |�� | �dt d�� | j
�
| j�� W d � n1 sTw Y | � |j � d S )N�2 rk r r� )
r r1 r� r� r r� r� rt rl r r� r^ r` r� r r r �test_sigchld_race_conditionB s
� �z2ChildWatcherTestsMixin.test_sigchld_race_conditionc C sP t �� }t �� }| j� d| _| j�d|d� W d � n1 s!w Y | �|j� | �|j� | j� | j�d|d� W d � n1 sHw Y | �|j� | �|j� d| _| �dtd�� | j� � |�
ddd� | �|j� |� � | �dt d�� | j
�
| j� � W d � n1 s�w Y | �|j� | �|j� d S ) NT�3 � � Fr� i����r� )r r1 r� r� r� r^ r` r� r r� rt rl r r� r� r r r � test_sigchld_replace_handlerX s2 � �
� z3ChildWatcherTestsMixin.test_sigchld_replace_handlerc C s� t �� }| j� d| _| j�d|d� W d � n1 s w Y | �|j� | j�d� | �|j� d| _| �dt d�� | j
�
| j� � W d � n1 sRw Y | �|j� d S )NT�4 i� F�c ) r r1 r� r� r� r^ r` r� r� r r� r� r� r r r �test_sigchld_remove_handler~ s � �z2ChildWatcherTestsMixin.test_sigchld_remove_handlerc C s� t �� }| j� d| _| j�d|d� W d � n1 s w Y | �|j� d| jd< d| _| j�� |� ddd� |�
� | � dt d�� | j
�
| j�� W d � n1 s[w Y | �|j� d S )NT�5 i��i� F�e )r r1 r� r� r� r^ r` r� r� rt rl r� r r� r� r r r �test_sigchld_unknown_status� s �
�z2ChildWatcherTestsMixin.test_sigchld_unknown_statusc C sL t �� }t �� }t �� }| j�# d| _| j�d|d� | j�d|d� | j�d|d� W d � n1 s5w Y | �| j�d�� | �| j�d�� | �| j�d�� | �| j�d�� | �dt d�� | �dt d�� | �dt d�� d | _| j
�
| j� � W d � n1 s�w Y | �|j � | �|j � |�
ddd� d S )
NT�6 r �7 re �8 r~ r F)r r1 r� r� r� rg r� r^ r� r r� r� r` rt )r# r� r� r� � callback3r r r �test_remove_child_handler� s. � � z0ChildWatcherTestsMixin.test_remove_child_handlerc C s� t �� }| j� d| _| j�d|� W d � n1 s w Y t|_t j�t j
d��}| � | j� � d � | �
|j� W d � d S 1 sGw Y d S )NT�9 �error)r r1 r� r� r� r* r> r{ rk r �loggerrM r� rg r` )r# r� r� Zm_errorr r r � test_sigchld_unhandled_exception� s �
�"�z7ChildWatcherTestsMixin.test_sigchld_unhandled_exceptionc C s� t �� }| j� d| _| j�d|� W d � n1 s w Y | �|j� d| _| �dtd�� t �
dt j � |� � | j
�
| j�� W d � n1 sPw Y t| jtj�rd| �|j� d S |�dd� d S )NT�: Frk � )r r1 r� r� r� r^ r` r� r r� r� �WNOHANGrl r� r� r� r
�FastChildWatcherrt r� r r r �#test_sigchld_child_reaped_elsewhere� s � �z:ChildWatcherTestsMixin.test_sigchld_child_reaped_elsewherec C s� t �� }t �� }| j�A | j�. d| _| �dtd�� | �dtd�� | j�� | j�d|� | j�d|� W d � n1 s@w Y W d � n1 sOw Y |� dd� | �
|j � d S )NTiO r� iQ r� iP ) r r1 r� r� r� r� r r� r� rt r^ r` r� r r r �,test_sigchld_unknown_pid_during_registration s
�� zCChildWatcherTestsMixin.test_sigchld_unknown_pid_during_registrationc C s t �� }| j� d| _| j�d|� W d � n1 s w Y | j}| �� | _t jj}||d��4}|| jd�� }| j� | j� |�
t j � |�
t j | jj
� W d � n1 sZw Y W d � n1 siw Y d| _| �dtd�� | j�
� |�
dd� d S )NT�< r4 r@ Fr� )r r1 r� r� r� r r r{ rk r� rt r+ rr r� r� r )r# r� r� �old_loopr{ Z m_old_removeZ m_new_addr r r �
test_set_loop s4 �
��
� ��
z$ChildWatcherTestsMixin.test_set_loopc C s t �� }t �� }t �� }| j� d| _| j�d|� | j�d|� | j�d|� W d � n1 s2w Y | j}d | _t j�|d��*}| �t d�� | j�
d � W d � n1 s\w Y |� t j
� W d � n1 sqw Y | �dtd�� | �dtd�� | �|j� | �|j� | �|j� | �� | _t j�| jd ��*}| j�
| j� |� t j
| jj� |� dd� |� dd
� | �|j� W d � n1 s�w Y |�� |�� d | _| �dtd �� | j�� | �|j� | �|j� |� dd � d S )
NT�= �> in r4 zA loop is being detached� r r@ r� Fr� )r r1 r� r� r� r r{ rk rx �RuntimeWarningr� rt r+ rr r� r r r^ r` r r� rl )r# r� r� r� r� r� �m_remove_signal_handlerr� r r r � test_set_loop_race_condition7 sd ��� �� �
�
� �
z3ChildWatcherTestsMixin.test_set_loop_race_conditionc C s6 t �� }| j�� d| _| �dtd�� | �dtd�� | j�� | j�d|� | j�d|� | �t | jj
�d� t | jt j
�rI| �t | jj�d� t j�| jd��(}| j�� |�tj� | �| jj
� t | jt j
�rr| �| jj� W d � n1 s|w Y W d � d S W d � d S 1 s�w Y d S ) NT�? r� �A r� �@ r r4 )r r1 r� r� r� r r� r� rM rs Z
_callbacksr� r
r� Z_zombiesr{ rk r r rt r+ rr r^ )r# r� r� r� r r r ru u s8
�
�� ��"�z!ChildWatcherTestsMixin.test_close) rT rU rV r r{ rk r r� r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� ru r| r r r$ r r� q sH
%
B
/
%
=r� c @ r� )�SafeChildWatcherTestsc C � t �� S r )r
r� r" r r r r� � r z$SafeChildWatcherTests.create_watcherN�rT rU rV r� r r r r r� � � r� c @ r� )�FastChildWatcherTestsc C r� r )r
r� r" r r r r� � r z$FastChildWatcherTests.create_watcherNr� r r r r r� � r� r� c @ r� ) � PolicyTestsc C r� r )r
ZDefaultEventLoopPolicyr" r r r �
create_policy� r zPolicyTests.create_policyc C sL | � � }| �|j� |�� }| �|tj� | �|j|� | �||�� � d S r )r� r5 �_watcher�get_child_watcherrL r
ZThreadedChildWatcherr �r# �policyr� r r r � test_get_default_child_watcher� s z*PolicyTests.test_get_default_child_watcherc C s< | � � }t�� }|�|� | �|j|� | �||�� � d S r )r� r
r� �set_child_watcherr r� r� r r r r � test_get_child_watcher_after_set� s
z,PolicyTests.test_get_child_watcher_after_setc sD � �fdd�}�� � � � �t�� � tj|d�}|�� |�� d S )Nc sR � � � �� � ��� �� tj� � �� } ��| tj� ��| j � � �� �
� d S r ) r! r� rL Zget_event_loopr
ZAbstractEventLoopr� r� r5 rX r )r� �r r# r r r� � s
� z4PolicyTests.test_get_child_watcher_thread.<locals>.f)r� )r� r r
r� � threading�Threadr# �join)r# r� �thr r r � test_get_child_watcher_thread� s z)PolicyTests.test_get_child_watcher_threadc C s� | � � }|�� }|�|� t�� }|�|� |�|� | �|j|� |�� }|�|� | �|j|� |�d � | �|jd � |� � |� � d S r )
r� r� r! r
r� r r� r rX r )r# r r r� Znew_loopr r r �,test_child_watcher_replace_mainloop_existing� s
z8PolicyTests.test_child_watcher_replace_mainloop_existingN)rT rU rV r� r r r
r r r r r r� � s r� c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�TestFunctionalc C s t �� | _t �| j� d S r )r
r� r r! r" r r r r � s
zTestFunctional.setUpc C s | j �� t�d � d S r )r r r
r! r" r r r �tearDown� s
zTestFunctional.tearDownc s� � fdd�}dd� }|� � � j �t� |� W d � n1 s w Y |� � � j �t� |� W d � n1 s;w Y |� � � j �t� � W d � n1 sUw Y |� � � j �t� � W d � d S 1 spw Y d S )Nc � � � td�S )NzInvalid file object)rG r* r r" r r �
assert_raises� r� zFTestFunctional.test_add_reader_invalid_argument.<locals>.assert_raisesc S r r r r r r r r: � r; zATestFunctional.test_add_reader_invalid_argument.<locals>.<lambda>)r rL rk rv �
remove_reader�
remove_writer)r# r rO r r" r � test_add_reader_invalid_argument� s � � �"�z/TestFunctional.test_add_reader_invalid_argumentc s` �fdd�� � ��fdd�}t �� \�}z�j�|� � W ��� |�� d S ��� |�� w )Nc r )Nz'File descriptor .* is used by transport)rG r? r r" r r r s �zLTestFunctional.test_add_reader_or_writer_transport_fd.<locals>.assert_raisesc � s� ��j jdd� �d�I d H \} }z�dd� }� � � �j ��|� W d � n1 s*w Y � � � �j ���� |� W d � n1 sFw Y � � � �j ��� W d � n1 s_w Y � � � �j ���� � W d � n1 szw Y � � � �j ��|� W d � n1 s�w Y � � � �j ���� |� W d � n1 s�w Y � � � �j ��� W d � n1 s�w Y � � � �j ���� � W d � n1 s�w Y W | �� d S W | �� d S | �� w )Nc S r� r )r
r r r r r r: s zWTestFunctional.test_add_reader_or_writer_transport_fd.<locals>.runner.<locals>.<lambda>r� c S r r r r r r r r: r; )r �create_connectionrL r� r rv r r )r8 ZprrO �r Zrsockr# r r �runner sB �� � � � � � � � � �zETestFunctional.test_add_reader_or_writer_transport_fd.<locals>.runner)r� �
socketpairr r� r )r# r Zwsockr r r �&test_add_reader_or_writer_transport_fd s �
z5TestFunctional.test_add_reader_or_writer_transport_fdN)rT rU rV r r
r r r r r r r � s
r �__main__)0�__doc__r� rW r� r� r� r+ r� r% �sysr� r r� r Z test.supportr r �platformZSkipTestr
r r Ztest.test_asyncior r� r
r
rI r r r r� ZTestCaser r� r~ r� r rg r� r� r� r� r� r� r rT �mainr r r r �<module> sv
^� )� N 2 )G
F �