File: //usr/local/lib/python3.7/test/test_asyncio/__pycache__/test_unix_events.cpython-37.pyc
B
��g � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddl
mZ ddlmZ e
jdkr�e
�d��ddlZddlmZ ddlmZ dd lmZ dd
lmZ dd lmZ ejZ d d
� Z e
� ed�G dd� dej ��Z e
� e!ed�d�G dd� dej ��Z"e
� e!ed�d�G dd� dej ��Z#G dd� dej �Z$G dd � d ej �Z%G d d � d e
j �Z&G d d � d e
j �Z'e�(d!d"�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/d-k�re
�0� dS ).zTests for unix_events.py.� N)�mock)�support�win32z UNIX only)�log)� base_events)�events)� unix_events)�utilsc C s" | j d krd S | j �� d | _ d S )N)Z_pipe�close)� transport� r �>/usr/local/lib/python3.7/test/test_asyncio/test_unix_events.py�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 s$ t � �� t�� | _| �| j� d S )N)�super�setUp�asyncio�SelectorEventLoop�loop�set_event_loop)�self)� __class__r r
r . s
z"SelectorEventLoopSignalTests.setUpc C s. | � t| jjd� | � t| jjtjd � d S )N�1� )� assertRaises� TypeErrorr Z
_check_signal�
ValueError�signal�NSIG)r r r r
�test_check_signal3 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_handler9 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_handler< s zASelectorEventLoopSignalTests.test_handle_signal_cancelled_handlerzasyncio.unix_events.signalc C s. t j|_t|j_| �t| jjt j dd� � d S )Nc S s dS )NTr r r r r
�<lambda>M � zRSelectorEventLoopSignalTests.test_add_signal_handler_setup_error.<locals>.<lambda>)
r r r �
set_wakeup_fd� side_effectr � RuntimeErrorr �add_signal_handler�SIGINT)r �m_signalr r r
�#test_add_signal_handler_setup_errorE s z@SelectorEventLoopSignalTests.test_add_signal_handler_setup_errorc C sT t j|_dd� }|}|� }| �|j� x(||fD ] }| �td| jjt j|� q0W d S )Nc � s d S )Nr r r r r
�simple_coroutineS 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/ r0 )r r1 r3 Z coro_funcZcoro_obj�funcr r r
�'test_add_signal_handler_coroutine_errorO s zDSelectorEventLoopSignalTests.test_add_signal_handler_coroutine_errorc C sP t j|_dd� }| j�t j|� | jj�t j�}| �|tj � | �
|j |� d S )Nc S s dS )NTr r r r r
r* d r+ zFSelectorEventLoopSignalTests.test_add_signal_handler.<locals>.<lambda>) r r r r/ �SIGHUPr% �get�assertIsInstancer r" � assertEqualZ _callback)r r1 �cbr( r r r
�test_add_signal_handler` s z4SelectorEventLoopSignalTests.test_add_signal_handlerc C sL t j|_dd� }||_G dd� dt�}||j _| �|| jjt jdd� � d S )Nc S s | dkrt � �d S )N���)r )�fdr r r
r, n s zYSelectorEventLoopSignalTests.test_add_signal_handler_install_error.<locals>.set_wakeup_fdc @ s e Zd ZejZdS )zOSelectorEventLoopSignalTests.test_add_signal_handler_install_error.<locals>.ErrN)�__name__�
__module__� __qualname__�errnoZEFAULTr r r r
�Errs s rD c S s dS )NTr r r r r
r* z r+ zTSelectorEventLoopSignalTests.test_add_signal_handler_install_error.<locals>.<lambda>) r r r, �OSErrorr- r r r/ r0 )r r1 r, rD r r r
�%test_add_signal_handler_install_errorj s zBSelectorEventLoopSignalTests.test_add_signal_handler_install_errorzasyncio.base_events.loggerc C sn t j|_G dd� dt�}||j _dd� | jjt j< | �t| jj t j
dd� � | � |j j
� | �d|jj� d S )Nc @ s e Zd ZejZdS )zPSelectorEventLoopSignalTests.test_add_signal_handler_install_error2.<locals>.ErrN)r@ rA rB rC �EINVALr r r r
rD � s rD c S s dS )NTr r r r r
r* � r+ zUSelectorEventLoopSignalTests.test_add_signal_handler_install_error2.<locals>.<lambda>c S s dS )NTr r r r r
r* � r+ r )r r rE r- r r% r8 r r. r/ r0 � assertFalse�info�calledr; r, �
call_count)r � m_loggingr1 rD r r r
�&test_add_signal_handler_install_error2| s zCSelectorEventLoopSignalTests.test_add_signal_handler_install_error2c C s\ G dd� dt �}||j_tj|_| �t| jjtjdd� � | � |j
j � | � d|j
j� d S )Nc @ s e Zd ZejZdS )zPSelectorEventLoopSignalTests.test_add_signal_handler_install_error3.<locals>.ErrN)r@ rA rB rC rG r r r r
rD � s rD c S s dS )NTr r r r r
r* � r+ zUSelectorEventLoopSignalTests.test_add_signal_handler_install_error3.<locals>.<lambda>� )rE r r- r r r. r r/ r0 rH rI rJ r; r, rK )r rL r1 rD r r r
�&test_add_signal_handler_install_error3� s zCSelectorEventLoopSignalTests.test_add_signal_handler_install_error3c C sl t j|_| j�t jdd� � | �| j�t j�� | �|jj� | �|j j� | � t j|j
f|j j d � d S )Nc S s dS )NTr r r r r
r* � r+ zISelectorEventLoopSignalTests.test_remove_signal_handler.<locals>.<lambda>r ) r r r r/ r8 �
assertTruer& r, rJ r; �SIG_DFL� call_args)r r1 r r r
�test_remove_signal_handler� s z7SelectorEventLoopSignalTests.test_remove_signal_handlerc C s� t j|_t j|_| j�t jdd� � t� | jjt j< |j� � | �
| j� t j�� | � |jj
� | �
|j j
� | �t j|jf|j jd � d S )Nc S s dS )NTr r r r r
r* � r+ zKSelectorEventLoopSignalTests.test_remove_signal_handler_2.<locals>.<lambda>r )r r r0 r r/ �objectr% r8 r, �
reset_mockrP r& rH rJ r; �default_int_handlerrR )r r1 r r r
� test_remove_signal_handler_2� s
z9SelectorEventLoopSignalTests.test_remove_signal_handler_2c C sB t j|_| j�t jdd� � t|j_| j�t j� | � |j
� d S )Nc S s dS )NTr r r r r
r* � r+ zWSelectorEventLoopSignalTests.test_remove_signal_handler_cleanup_error.<locals>.<lambda>) r r r r/ r8 r r, r- r& rP rI )r rL r1 r r r
�(test_remove_signal_handler_cleanup_error� s
zESelectorEventLoopSignalTests.test_remove_signal_handler_cleanup_errorc C s< t j|_| j�t jdd� � t|j _| �t| jjt j� d S )Nc S s dS )NTr r r r r
r* � r+ zOSelectorEventLoopSignalTests.test_remove_signal_handler_error.<locals>.<lambda>) r r r r/ r8 rE r- r r& )r r1 r r r
� test_remove_signal_handler_error� s
z=SelectorEventLoopSignalTests.test_remove_signal_handler_errorc C sL t j|_| j�t jdd� � G dd� dt�}||j _| �t| jj t j� d S )Nc S s dS )NTr r r r r
r* � r+ zPSelectorEventLoopSignalTests.test_remove_signal_handler_error2.<locals>.<lambda>c @ s e Zd ZejZdS )zKSelectorEventLoopSignalTests.test_remove_signal_handler_error2.<locals>.ErrN)r@ rA rB rC rG r r r r
rD � s rD )
r r r r/ r8 rE r- r r. r& )r r1 rD r r r
�!test_remove_signal_handler_error2� s z>SelectorEventLoopSignalTests.test_remove_signal_handler_error2c C s| t j|_| j�t jdd� � | j�t jdd� � | �t| jj�d� |j �
� | j� � | �t| jj�d� |j � d� d S )Nc S s dS )NTr r r r r
r* � r+ z9SelectorEventLoopSignalTests.test_close.<locals>.<lambda>c S s dS )NTr r r r r
r* � r+ rN r r> )
r r r r/ r8 �SIGCHLDr; �lenr% r, rU r
�assert_called_once_with)r r1 r r r
�
test_close� s
z'SelectorEventLoopSignalTests.test_closezasyncio.unix_events.sysc C s� t j|_| j�t jdd� � | �t| jj�d� d|j_ |j �
� | � t d�� | j�
� W d Q R X | �t| jj�d� | �|j j� d S )Nc S s dS )NTr r r r r
r* � r+ zGSelectorEventLoopSignalTests.test_close_on_finalizing.<locals>.<lambda>r Tz skipping signal handlers removalr )r r r r/ r8 r; r\ r% �
is_finalizing� return_valuerU �assertWarnsRegex�ResourceWarningr
rH rJ )r r1 Zm_sysr r r
�test_close_on_finalizing� s
z5SelectorEventLoopSignalTests.test_close_on_finalizing)r@ rA rB r r r! r) r �patchr2 r7 r= rF rM rO rS rW rX rY rZ r^ rc �
__classcell__r r )r r
r + s*
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 s$ t � �� t�� | _| �| j� d S )N)r r r r r r )r )r r r
r s
z&SelectorEventLoopUnixSocketTests.setUpc C sv t �� �d}t�tj�}|�|� |�d� |�� | j�dd� |�}| j� |�}|�� | j� |�
� � W d Q R X d S )Nr c S s d S )Nr r r r r
r* r+ z]SelectorEventLoopUnixSocketTests.test_create_unix_server_existing_path_sock.<locals>.<lambda>) �
test_utils�unix_socket_path�socketrf �bindZlistenr
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 sX t �� �F}t�|�}| j�dd� |�}| j�|�}|�� | j�|�� � W d Q R X d S )Nc S s d S )Nr r r r r
r* r+ zRSelectorEventLoopUnixSocketTests.test_create_unix_server_pathlib.<locals>.<lambda>) rh ri �pathlib�Pathr rl rm r
rn )r ro Zsrv_cororr r r r
� test_create_unix_server_pathlib s
z@SelectorEventLoopUnixSocketTests.test_create_unix_server_pathlibc
C sV t �� �D}t�|�}| j�dd� |�}| �t�� | j�|� W d Q R X W d Q R X d S )Nc S s d S )Nr r r r r
r* r+ zVSelectorEventLoopUnixSocketTests.test_create_unix_connection_pathlib.<locals>.<lambda>) rh ri rt ru r �create_unix_connectionr �FileNotFoundErrorrm )r ro rq r r r
�#test_create_unix_connection_pathlib s
zDSelectorEventLoopUnixSocketTests.test_create_unix_connection_pathlibc
C sP t �� �>}| j�dd� |j�}| �td�� | j�|� W d Q R X W d Q R X d S )Nc S s d S )Nr r r r r
r* ' r+ z`SelectorEventLoopUnixSocketTests.test_create_unix_server_existing_path_nonsock.<locals>.<lambda>zAddress.*is already in use)�tempfile�NamedTemporaryFiler rl �namer5 rE rm )r �filerq r r r
�-test_create_unix_server_existing_path_nonsock% s
zNSelectorEventLoopUnixSocketTests.test_create_unix_server_existing_path_nonsockc C s> | j jdd� ddd�}| �td�� | j �|� W d Q R X d S )Nc S s d S )Nr r r r r
r* - r+ zSSelectorEventLoopUnixSocketTests.test_create_unix_server_ssl_bool.<locals>.<lambda>�spamT)ro �sslz"ssl argument must be an SSLContext)r rl r5 r rm )r rq r r r
� test_create_unix_server_ssl_bool, s
zASelectorEventLoopUnixSocketTests.test_create_unix_server_ssl_boolc C s< | j jdd� d d�}| �td�� | j �|� W d Q R X d S )Nc S s d S )Nr r r r r
r* 4 r+ zXSelectorEventLoopUnixSocketTests.test_create_unix_server_nopath_nosock.<locals>.<lambda>)ro z#path was not specified, and no sock)r rl r5 r rm )r rq r r r
�%test_create_unix_server_nopath_nosock3 s zFSelectorEventLoopUnixSocketTests.test_create_unix_server_nopath_nosockc
C sV t � � }|�@ | jjdd� d |d�}| �td�� | j�|� W d Q R X W d Q R X d S )Nc S s d S )Nr r r r r
r* < r+ zXSelectorEventLoopUnixSocketTests.test_create_unix_server_path_inetsock.<locals>.<lambda>)ro rp z"A UNIX Domain Stream.*was expected)rj r rl r5 r rm )r rp rq r r r
�%test_create_unix_server_path_inetsock9 s zFSelectorEventLoopUnixSocketTests.test_create_unix_server_path_inetsockc
C s^ t � t jt j�}|�@ | jjdd� d |d�}| �td�� | j�|� W d Q R X W d Q R X d S )Nc S s d S )Nr r r r r
r* E r+ zUSelectorEventLoopUnixSocketTests.test_create_unix_server_path_dgram.<locals>.<lambda>)ro rp z"A UNIX Domain Stream.*was expected)rj rf Z
SOCK_DGRAMr rl r5 r rm )r rp rq r r r
�"test_create_unix_server_path_dgramB 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 Q R X zX|�J |�|� | jj dd� d |d�}| j�
|�}|� � | j�
|� � � W d Q R X W d t
�|� X d S )Nc S s d S )Nr r r r r
r* V r+ z^SelectorEventLoopUnixSocketTests.test_create_unix_server_path_stream_bittype.<locals>.<lambda>)ro rp )rj rf � SOCK_STREAMr� rz r{ r| rk r rl rm r
rn �os�unlink)r rp r} �fnrq rr r r r
�+test_create_unix_server_path_stream_bittypeK s
zLSelectorEventLoopUnixSocketTests.test_create_unix_server_path_stream_bittypec C s> | j jdd� ddd�}| �td�� | j �|� W d Q R X d S )Nc S s d S )Nr r r r r
r* _ r+ zfSelectorEventLoopUnixSocketTests.test_create_unix_server_ssl_timeout_with_plain_sock.<locals>.<lambda>r r )ro �ssl_handshake_timeoutz1ssl_handshake_timeout is only meaningful with ssl)r rl r5 r rm )r rq r r r
�3test_create_unix_server_ssl_timeout_with_plain_sock^ s zTSelectorEventLoopUnixSocketTests.test_create_unix_server_ssl_timeout_with_plain_sockc
C sT t � � }|�> | jjdd� |d�}| �td�� | j�|� W d Q R X W d Q R X d S )Nc S s d S )Nr r r r r
r* i r+ z\SelectorEventLoopUnixSocketTests.test_create_unix_connection_path_inetsock.<locals>.<lambda>)rp z"A UNIX Domain Stream.*was expected)rj r rw r5 r rm )r rp rq r r r
�)test_create_unix_connection_path_inetsockf s zJSelectorEventLoopUnixSocketTests.test_create_unix_connection_path_inetsockzasyncio.unix_events.socketc C s� t �� }||j_t|j_| jjdd� dd�}| � t�� | j�
|� W d Q R X | � |j j
� t|j_| jjdd� dd�}| � t�� | j�
|� W d Q R X | � |j j
� d S )Nc S s d S )Nr r r r r
r* v r+ zUSelectorEventLoopUnixSocketTests.test_create_unix_server_bind_error.<locals>.<lambda>z/test)ro c S s d S )Nr r r r r
r* | r+ )r r# rj r` rE rk r- r rl r rm rP r
rJ � MemoryError)r Zm_socketrp rq r r r
�"test_create_unix_server_bind_erroro s zCSelectorEventLoopUnixSocketTests.test_create_unix_server_bind_errorc C sB | j jdd� tjt� d�}| �td�� | j �|� W d Q R X d S )Nc S s d S )Nr r r r r
r* � r+ zXSelectorEventLoopUnixSocketTests.test_create_unix_connection_path_sock.<locals>.<lambda>)rp zpath and sock can not be)r rw r� �devnullrT r5 r rm )r rq r r r
�%test_create_unix_connection_path_sock� s zFSelectorEventLoopUnixSocketTests.test_create_unix_connection_path_sockc C s: | j �dd� d �}| �td�� | j �|� W d Q R X d S )Nc S s d S )Nr r r r r
r* � r+ z\SelectorEventLoopUnixSocketTests.test_create_unix_connection_nopath_nosock.<locals>.<lambda>z no path and sock were specified)r rw r5 r rm )r rq r r r
�)test_create_unix_connection_nopath_nosock� s
zJSelectorEventLoopUnixSocketTests.test_create_unix_connection_nopath_nosockc C s@ | j jdd� tjdd�}| �td�� | j �|� W d Q R X d S )Nc S s d S )Nr 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 rw r� r� r5 r rm )r rq r r r
�,test_create_unix_connection_nossl_serverhost� s
zMSelectorEventLoopUnixSocketTests.test_create_unix_connection_nossl_serverhostc C s@ | j jdd� tjdd�}| �td�� | j �|� W d Q R X d S )Nc S s d S )Nr 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 ssl)r rw r� r� r5 r rm )r rq r r r
�,test_create_unix_connection_ssl_noserverhost� s
zMSelectorEventLoopUnixSocketTests.test_create_unix_connection_ssl_noserverhostc C s> | j jdd� ddd�}| �td�� | j �|� W d Q R X d S )Nc S s d S )Nr r r r r
r* � r+ zjSelectorEventLoopUnixSocketTests.test_create_unix_connection_ssl_timeout_with_plain_sock.<locals>.<lambda>r r )ro r� z1ssl_handshake_timeout is only meaningful with ssl)r rw r5 r rm )r rq r r r
�7test_create_unix_connection_ssl_timeout_with_plain_sock� s zXSelectorEventLoopUnixSocketTests.test_create_unix_connection_ssl_timeout_with_plain_sock) r@ rA rB r r Z skip_unless_bind_unix_socketrs rv ry r~ r� r� r� r� �unittest�
skipUnless�hasattrrj r� r� r� r rd r� r� r� r� r� r� re r r )r r
rg � s(
rg �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� 12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcdei c @ s4 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 )NT)r� r r� �
set_result)r r r r r
�connection_made� s z>SelectorEventLoopUnixSockSendfileTests.MyProto.connection_madec C s | j �|� d S )N)r� �extend)r r� r r r
�
data_received� s z<SelectorEventLoopUnixSockSendfileTests.MyProto.data_receivedc C s d| _ | j�d � d S )NT)r� r� r� )r �excr r r
�connection_lost� s z>SelectorEventLoopUnixSockSendfileTests.MyProto.connection_lostc � s | j I d H d S )N)r� )r r r r
rn � s z:SelectorEventLoopUnixSockSendfileTests.MyProto.wait_closedN)r@ rA rB r� r� r� r� rn r r r r
�MyProto� s
r� c s2 t tjd��}|�| j� W d Q R X t� �� d S )N�wb)�openr �TESTFN�write�DATAr �
setUpClass)�cls�fp)r r r
r� � s z1SelectorEventLoopUnixSockSendfileTests.setUpClassc s t �t j� t� �� d S )N)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} r4 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� |rN| �|j � |S )NFi )
rj ZAF_INETr� Z setblockingZ
setsockoptZ
SOL_SOCKETZ SO_SNDBUFZ SO_RCVBUFr4 r
)r �cleanuprp r r r
� make_socket� s
z2SelectorEventLoopUnixSockSendfileTests.make_socketc C s | j �|�S )N)r rm )r rq r r r
�run_loop� s 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 )Nr r )�protor r
r* � r+ z@SelectorEventLoopUnixSockSendfileTests.prepare.<locals>.<lambda>)rp c s2 � j �� ��� �� � ��� ����� � d S )N)r r
r� rn r )r� r �serverr r
r� � s
z?SelectorEventLoopUnixSockSendfileTests.prepare.<locals>.cleanup) r� r� r r Zfind_unused_portrk ZHOSTr� Z
create_serverZ sock_connectr� r4 )r rp ZportZsrv_sockr� r )r� r r� r
�prepare� s
z.SelectorEventLoopUnixSockSendfileTests.preparec
C sp | � � \}}tjdg d��: | �tjd�� | �| j�|| j dd �� W d Q R X W d Q R X | �
| j � � d� d S )Nzasyncio.unix_events.os)�specz$os[.]sendfile[(][)] is not availabler ) r� r rd r5 r �SendfileNotAvailableErrorr� r �_sock_sendfile_nativer} r; �tell)r rp r� r r r
� test_sock_sendfile_not_available� s zGSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_not_availablec C sZ | � � \}}t� }| �tjd�� | �| j�||dd �� W d Q R X | �| j �
� d� d S )Nznot a regular filer ) r� rT r5 r r� r� r r� r; r} r� )r rp r� �fr r r
� test_sock_sendfile_not_a_file s zDSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_not_a_filec C s\ | � � \}}t�� }| �tjd�� | �| j�||dd �� W d Q R X | � | j
� � d� d S )Nznot a regular filer ) r� �io�BytesIOr5 r r� r� r r� r; r} r� )r rp r� r� r r r
�test_sock_sendfile_iobuffer s zBSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_iobufferc C sd | � � \}}t�� }d|j_| �tjd�� | �| j �
||dd �� W d Q R X | � | j �
� d� d S )Nr> znot a regular filer )r� r r# �filenor` r5 r r� r� r r� r; r} r� )r rp 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 Q R X | �t�� | jj�|� W d Q R X d S )Nr )r� r r� r} r� �_sock_sendfile_native_implr\ r� r$ �
contextlib�suppressr ZCancelledErrorr� r �KeyError� _selector�get_key)r rp r� r� r� r r r
�test_sock_sendfile_cancel1 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 Q R X d S )Nr )
r� r r� r} r� r� r\ r� r$ r r� r� r� )r rp r� r� r� r r r
�test_sock_sendfile_cancel2+ s
zASelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_cancel2c C s� | � � \}}| j�� }t�� }d|j_tjdt� d��& | j �
|d ||dd t | j �d� W d Q R X | j j
�|�}| �|� |j�tj� d S )NFz os.sendfile)r- r )r� r} r� r r# Z cancelledr` rd �BlockingIOErrorr r� r\ r� r� r� �assertIsNotNoneZadd_done_callbackr] �ANY)r rp r� r� r� �keyr r r
�!test_sock_sendfile_blocking_error8 s
zHSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_blocking_errorc C s� | � � \}}| j�� }| j�� }tjdt� d��& | j�|d ||dd t | j
�d� W d Q R X | � t �� | jj
�|� W d Q R X |�� }| �|tj� | �d| j�� � d S )Nz os.sendfile)r- r )r� r} r� r r� r rd rE r� r\ r� r r� r� r� � exceptionr: r r� r; r� )r rp r� r� r� r� r r r
�&test_sock_sendfile_os_error_first_callE s
zMSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_os_error_first_callc C s� | � � \}}| j�� }| j�� }t� }tjd|d��* | j�||�� ||dd t | j
�d� W d Q R X | � t �� | jj
�|� W d Q R X |�� }| �||� | �d| j�� � d S )Nz os.sendfile)r- i� )r� r} r� r r� rE r rd r� r\ r� r r� r� r� r� �assertIsr; r� )r rp r� r� r� �errr� r r r
�%test_sock_sendfile_os_error_next_callS s
zLSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_os_error_next_callc C s� | � � \}}| j�� }| j�� }t�� }tjd|d��* | j� ||�� ||dd t
| j �d� W d Q R X | � t
�� | jj�|� W d Q R X |�� }| �||� | �d| j�� � d S )Nz os.sendfile)r- i� )r� r} r� r r� r r� r rd r� r\ r� r r� r� r� r� r� r; r� )r rp r� r� r� r� r� r r r
� test_sock_sendfile_exceptiond s
zCSelectorEventLoopUnixSockSendfileTests.test_sock_sendfile_exception)T)r@ rA rB r� r �Protocolr� � classmethodr� r� r r� r� r� r� r� r� r� r� r� r� r� r� r� re 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 s� t � �� | �� | _t�tj�| _t j
t j d�| _
d| j
j_t �d�}|�� | �|j� t �d�}|�� }t �
� }tj|_||_| �|j� d S )N)�spec_set� zos.set_blockingzos.fstat)r r �
new_test_loopr rh �make_test_protocolr r� �protocolr r# r� � RawIOBase�piper� r` rd �startr4 �stop�stat�S_IFIFO�st_mode)r �blocking_patcher�
fstat_patcher�m_fstat�st)r r r
r x s
z UnixReadPipeTransportTests.setUpNc C s( t j| j| j| j|d�}| �t|� |S )N)�waiter)r Z_UnixReadPipeTransportr r� r� r4 r )r r� r r r r
�read_pipe_transport� s
z.UnixReadPipeTransportTests.read_pipe_transportc C sV t j| jd�}| j|d�}| j�|� | jj�|� | j�d|j � | �
|� � � d S )N)r )r� r� ) r �Futurer r� rm r� r� r' �
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 )Ns datar� )r� r` r� r' �max_sizer� r� )r �m_readr� 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 )Nr+ r� )
r� r` r� r' r� rH r �readersrh � run_brieflyr� Z eof_receivedr� )r r� 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� )
r� r� r- r� r' r� rh r� r rH r� r� rJ )r r� r� r r r
�test__read_ready_blocked� s z3UnixReadPipeTransportTests.test__read_ready_blockedzasyncio.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) r� rE r- r r# �_closer� r' r� rh Z MockPattern�MOCK_ANY)r r� �m_logexcr� r� r r r
�test__read_ready_error� s
z1UnixReadPipeTransportTests.test__read_ready_errorc C s8 | � � }t�� }| j�d|� |�� | �| jj� d S )Nr� )r� r r# r �
add_reader�
pause_readingrH r� )r r� r� �mr r r
�test_pause_reading� s
z-UnixReadPipeTransportTests.test_pause_readingc C s, | � � }|�� |�� | j�d|j� d S )Nr� )r� r �resume_readingr r� r� )r r� r� r r r
�test_resume_reading� s z.UnixReadPipeTransportTests.test_resume_readingc C s* | � � }t�� |_|�� |j�d � d S )N)r� r r# r� r
r' )r r� r� r r r
r^ � s
z%UnixReadPipeTransportTests.test_closec C s2 | � � }d|_t�� |_|�� | �|jj� d S )NT)r� �_closingr r# r� r
rH rJ )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 )N)
r� rT r� rP �
is_closingrH r r� rh r� r� r� r' )r r� r� r� r r r
� test__close� s
z&UnixReadPipeTransportTests.test__closec C sd | � � }| �|j� | �|j� d }|�|� | jj�|� | jj �� | �
|j� | �
|j� d S )N) r� r� � _protocol�_loop�_call_connection_lostr� r� r' r� r
r� )r r� r� r r r
�test__call_connection_lost� s
z5UnixReadPipeTransportTests.test__call_connection_lostc C sf | � � }| �|j� | �|j� t� }|�|� | jj�|� | j j
�� | � |j� | � |j� d S )N) r� r� r r
rE r r� r� r' r� r
r� )r r� r� r r r
�#test__call_connection_lost_with_err� s
z>UnixReadPipeTransportTests.test__call_connection_lost_with_errc C s4 | � � }|�� t�| j� | �|j� |�� d S )N)r� r
rh r� r r� r
r )r r� r r r
�!test_pause_reading_on_closed_pipe s
z<UnixReadPipeTransportTests.test_pause_reading_on_closed_pipec C s | � � }|�� |�� d S )N)r� r )r r� r r r
�!test_pause_reading_on_paused_pipe s z<UnixReadPipeTransportTests.test_pause_reading_on_paused_pipec C s4 | � � }|�� t�| j� | �|j� |�� d S )N)r� r
rh r� r r� r
r )r r� r r r
�"test_resume_reading_on_closed_pipe s
z=UnixReadPipeTransportTests.test_resume_reading_on_closed_pipec C s | � � }|�� d S )N)r� r )r r� r r r
�"test_resume_reading_on_paused_pipe s z=UnixReadPipeTransportTests.test_resume_reading_on_paused_pipe)N)r@ rA rB r r� r� r rd r� r� r� r r r r^ r r r r r r r r re r r )r r
r� v 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 s� t � �� | �� | _t�tj�| _t j
t j d�| _
d| j
j_t �d�}|�� | �|j� t �d�}|�� }t �
� }tj|_||_| �|j� d S )N)r� r� zos.set_blockingzos.fstat)r r r� r rh r� r Z BaseProtocolr� r r# r� r� r� r� r` rd r� r4 r� r� �S_IFSOCKr� )r r� r� r� r� )r r r
r ) s
z!UnixWritePipeTransportTests.setUpNc C s( t j| j| j| j|d�}| �t|� |S )N)r� )r Z_UnixWritePipeTransportr r� r� r4 r )r r� r r r r
�write_pipe_transport; s
z0UnixWritePipeTransportTests.write_pipe_transportc C sX t j| jd�}| j|d�}| j�|� | jj�|� | j�d|j � | �
d |� � � d S )N)r )r� r� ) r r� r r rm r� r� r' r� r� r; r� )r r� r� r r r
r� B s z%UnixWritePipeTransportTests.test_ctorc C s | � � }| �|�� � d S )N)r rP Z
can_write_eof)r r� r r r
�test_can_write_eofK s z.UnixWritePipeTransportTests.test_can_write_eofzos.writec C sF | � � }d|_|�d� |�dd� | �| jj� | �t� |j � d S )N� s datar� )
r r` r� r' rH r �writersr; r� �_buffer)r �m_writer� r r r
�
test_writeO s
z&UnixWritePipeTransportTests.test_writec C sB | � � }|�d� | �|j� | �| jj� | �td�|j� d S )Nr+ ) r r� rH rJ r r r; r� r )r r r� r r r
�test_write_no_dataX s
z.UnixWritePipeTransportTests.test_write_no_datac C s> | � � }d|_|�d� | j�d|j� | �td�|j� d S )NrN s datar� s ta) r r` r� r �
assert_writer� _write_readyr; r� r )r r r� r r r
�test_write_partial` s
z.UnixWritePipeTransportTests.test_write_partialc C s^ | � � }| j�d|j� td�|_|�d� | �|j� | j� d|j� | �
td�|j� d S )Nr� s previouss datas previousdata) r r �
add_writerr r� r r� rH rJ r r; )r r r� r r r
�test_write_bufferh s
z-UnixWritePipeTransportTests.test_write_bufferc C sP | � � }t� |_|�d� |�dtd�� | j�d|j� | � td�|j
� d S )Ns datar� ) r r� r- r� r' r� r r r r; r )r r r� r r r
�test_write_againr 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 )Ns datar� z#Fatal write error on pipe transportr rN z=pipe closed by peer or os.write(pipe, data) raised exception.)r rE r- r r# Z _fatal_errorr� r' rH r r r; r� r �
_conn_lost�warningr
)r r Zm_logr� r� r r r
�test_write_err{ s*
z*UnixWritePipeTransportTests.test_write_errc C sD | � � }|�� |�d� | �|jd� |�d� | �|jd� d S )Ns datar rN )r r� r� r; r% )r r r� r r r
�test_write_close� s
z,UnixWritePipeTransportTests.test_write_closec C sX | � � }|�� | �| jj� | �| jj� | �|�� � t� | j� | j
j � d � d S )N)
r r� rH r r� r rP r
rh r� r� r� r' )r r� r r r
r� � s z,UnixWritePipeTransportTests.test__read_readyc C sR | � � }| j�d|j� td�|_d|_|�� | �| jj� | � t� |j� d S )Nr� s datar )
r r r" r r� r r` rH r r; )r r r� 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� s data� � a) r r r" r r� r r` r r; )r r r� 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� s data) r r r" r r� r r� r- r' r r; )r r r� 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� s datar )
r r r" r r� r r` r' r r; )r r r� r r r
�test__write_ready_empty� s
z3UnixWritePipeTransportTests.test__write_ready_emptyzasyncio.log.logger.errorc C s� | � � }| j�d|j� td�|_t� |_}|�� | �| jj � | �| jj
� | � t� |j� | � |�
� � |�� | � d|j� t�| j� | jj�|� d S )Nr� s datar )r r r" r r� r rE r- rH r r� r; rP r
Zassert_not_calledr% rh r� r� r� r' )r r r r� 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� Ts datar )r r r" r r r� r r` rH r r� r; r� r� r' r� r
)r r r� 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 das ta)r r r" r r r� r �abortrH rJ r� r r; rP r
rh r� r� r� r' )r r r� r r r
�
test_abort� s
z&UnixWritePipeTransportTests.test_abortc C sd | � � }| �|j� | �|j� d }|�|� | jj�|� | jj �� | �
|j� | �
|j� d S )N) r r� r r
r r� r� r' r� r
r� )r r� r� r r r
r s
z6UnixWritePipeTransportTests.test__call_connection_lostc C sf | � � }| �|j� | �|j� t� }|�|� | jj�|� | j j
�� | � |j� | � |j� d S )N) r r� r r
rE r r� r� r' r� r
r� )r r� r� r r r
r s
z?UnixWritePipeTransportTests.test__call_connection_lost_with_errc C s0 | � � }t�� |_|�� |j�� |�� d S )N)r r r# � write_eofr
r' )r r� r r r
r^ s
z&UnixWritePipeTransportTests.test_closec C s2 | � � }t�� |_d|_|�� | �|jj� d S )NT)r r r# r3 r r
rH rJ )r r� r r r
�test_close_closing$ s
z.UnixWritePipeTransportTests.test_close_closingc C sJ | � � }|�� | �|�� � | �| jj� t�| j� | j j
� d � d S )N) r r3 rP r
rH r r� rh r� r� r� r' )r r� r r r
�test_write_eof+ s z*UnixWritePipeTransportTests.test_write_eofc C s: | � � }dg|_|�� | �|�� � | �| jjj� d S )Ns data) r r r3 rP r
rH r� r� rJ )r r� r r r
�test_write_eof_pending3 s
z2UnixWritePipeTransportTests.test_write_eof_pending)N) r@ rA rB r r r� r r rd r r r! r# r$ r' r( r� r) r, r- r. r/ r0 r2 r r r^ r4 r5 r6 re r r )r r
r ' s6
r c @ s e Zd Zdd� ZdS )�AbstractChildWatcherTestsc C sv t �� }t�� }| �t|j||� | �t|j|� | �t|j|� | �t|j � | �t|j
� | �t|j |||� d S )N) r r# r ZAbstractChildWatcherr �NotImplementedError�add_child_handler�remove_child_handler� attach_loopr
� __enter__�__exit__)r r� �watcherr r r
�test_not_implemented= s
z.AbstractChildWatcherTests.test_not_implementedN)r@ rA rB r? r r r r
r7 ; s r7 c @ s e Zd Zdd� ZdS )�BaseChildWatcherTestsc C s$ t �� }t�� }| �t|j|� d S )N)r r# r ZBaseChildWatcherr r8 Z _do_waitpid)r r� r> r r r
r? P s z*BaseChildWatcherTests.test_not_implementedN)r@ rA rB r? r r r r
r@ N s r@ � WaitPidMocks)�waitpid� WIFEXITED� WIFSIGNALED� WEXITSTATUS�WTERMSIGc s e Zd Zej�ejd�Z� fdd�Z dd� Z
dd� Z dd � Z d
d � Z
d d
� Zdd� Zdd� Zdd� Zedd� �Zedd� �Zedd� �Zedd� �Zed d � �Zed d � �Zed d!� �Zed"d#� �Zed$d%� �Zed&d'� �Zed(d)� �Z ed*d+� �Z ed,d-� �Z ed.d/� �Z ed0d1� �Z � Z!S )2�ChildWatcherTestsMixinr& c sZ t � �� | �� | _d| _i | _tj�| jd�� | _ | �
� | _ | j � | j� W d Q R X d S )NFr/ )
r r r� r �running�zombiesr rd rT �m_add_signal_handler�create_watcherr> r; )r )r r r
r d s
z ChildWatcherTestsMixin.setUpc C sr t | jtj�s|dkr"| �|d� y&|dk r6| j�� S || j�|�fS W n tk
r\ Y nX | j rhdS t
� �d S )Nr> r )r r ) �
isinstancer> r �SafeChildWatcherZ
assertGreaterrI �popitem�popr� rH �ChildProcessError)r �pid�flagsr r r
rB o s
z ChildWatcherTestsMixin.waitpidc C s |d | j |< d S )Ni � )rI )r rQ �
returncoder r r
�
add_zombie~ s z!ChildWatcherTestsMixin.add_zombiec C s |dkS )Ni � r )r �statusr r r
rC � s z ChildWatcherTestsMixin.WIFEXITEDc C s d| k odk S S )Ni� i � r )r rU r r r
rD � s z"ChildWatcherTestsMixin.WIFSIGNALEDc C s | � | �|�� |d S )Ni � )rP rC )r rU r r r
rE � s z"ChildWatcherTestsMixin.WEXITSTATUSc C s | � | �|�� d| S )Ni � )rP rD )r rU r r r
rF � s z ChildWatcherTestsMixin.WTERMSIGc C s | j �tj| jj� d S )N)rJ r] r r[ r> � _sig_chld)r r r r
�test_create_watcher� s z*ChildWatcherTestsMixin.test_create_watcherc s � fdd�}|S )Nc
s� dd� }|d| j ��|}|d| j��d}|d| j��L}|d| j��4}|d| j�� }� | t|||||�� W d Q R X W d Q R X W d Q R X W d Q R X W d Q R X d S )Nc S s t j| |t jd�S )N)�wrapsZ new_callable)r rd r# )�target�wrapperr r r
rd � s zIChildWatcherTestsMixin.waitpid_mocks.<locals>.wrapped_func.<locals>.patchz os.WTERMSIGzos.WEXITSTATUSzos.WIFSIGNALEDz os.WIFEXITEDz
os.waitpid)rF rE rD rC rB rA )r rd Z
m_WTERMSIGZ
m_WEXITSTATUSZ
m_WIFSIGNALEDZ m_WIFEXITEDZ m_waitpid)r6 r r
� wrapped_func� s z:ChildWatcherTestsMixin.waitpid_mocks.<locals>.wrapped_funcr )r6 r[ r )r6 r
�
waitpid_mocks� s z$ChildWatcherTestsMixin.waitpid_mocksc C s t �� }| j� d| _| j�d|ddd� W d Q R X | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | j� � | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� d| _| � dd� | j� � | �
|jj� | �
|j j� | �|j
j� |�ddddd� |j�� |j�� |j �� |�� | � dd� | j� | j� � W d Q R X | �|j� | �|j
j� |j�� |j�� |j �� | j�� | j� � | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� d S ) NT�* � �
� F� �
)r r# r> rH r9 rH rJ rC rD rE rF rV rT rP r] rU �ignore_warningsrI �clear)r r �callbackr r r
� test_sigchld� sR
z#ChildWatcherTestsMixin.test_sigchldc C s� t �� }t �� }| j� d| _| j�d|dd� W d Q R X | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | j� | j�d|dd� W d Q R X | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | j� � | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | � dd� | j� � |�
dddd� | �|j� | �|jj� | �|j j� | �|j
j� |j�� |j�� |j
�� |�� | j� � | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | � dd � d
| _| j� � |�
dd dd� | �|j� | �|jj� | �|j j� | �|j
j� |j�� |j�� |j �� |�� | � dd � | � dd � | j� | j� � W d Q R X | �|j� | �|j� | �|j
j� |j�� |j�� |j �� | j�� | j� � | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� d S )
NT�+ � � �, � � ����l Fr` � )r r# r> rH r9 rH rJ rC rD rE rF rV rT r] rP rU rc rI rd )r r � callback1� callback2r r r
�test_sigchld_two_children� s�
z0ChildWatcherTestsMixin.test_sigchld_two_childrenc C sn t �� }t �� }| j� d| _| j�d|dd� W d Q R X | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | j� | j�d|dd� W d Q R X | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | j� � | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | � dd� | � dd � d
| _| j� � |�
dddd� |�
dd dd� | �|jj� | �|jj� | �|j j� | �|j
j� |j�� |j�� |j
�� |j �� |�� |�� | � dd � | � dd � | j� | j� � W d Q R X | �|j� | �|j� | �|j
j� d S )
NT�- � ri �. i{ rl �N ���Fr` ro )r r# r> rH r9 rH rJ rC rD rE rF rV rT r] rP rU rc )r r rp rq r r r
�.test_sigchld_two_children_terminating_togetherI sb
zEChildWatcherTestsMixin.test_sigchld_two_children_terminating_togetherc C s� t �� }| j�. | �dd� | j�� | j�d|dd� W d Q R X |�dddd� |�� | �dd� | j� | j�� W d Q R X | � |j
� d S )N�2 r r ra r> ) r r# r> rT rV r9 r] rU rc rH rJ )r r re r r r
�test_sigchld_race_condition� s
z2ChildWatcherTestsMixin.test_sigchld_race_conditionc C s� t �� }t �� }| j� d| _| j�d|d� W d Q R X | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | j� | j�d|d� W d Q R X | �|j� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� d| _| � dd� | j� � |�
ddd� | �|j� | �|jj� | �|j j� | �|j
j� |j�� |j�� |j
�� |�� | � dd� | j� | j� � W d Q R X | �|j� | �|j� | �|j
j� d S )NT�3 � � Fi����rb )r r# r> rH r9 rH rJ rC rD rE rF rT rV r] rP rU rc )r r rp rq r r r
� test_sigchld_replace_handler� sJ
z3ChildWatcherTestsMixin.test_sigchld_replace_handlerc C s t �� }| j� d| _| j�d|d� W d Q R X | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� | j� d� | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� d| _| � dd� | j
� | j�� W d Q R X | �|j� d S )NT�4 i� F�c )r r# r> rH r9 rH rJ rC rD rE rF r: rT rc rV )r r re r r r
�test_sigchld_remove_handler� s( z2ChildWatcherTestsMixin.test_sigchld_remove_handlerc C s( t �� }| j� d| _| j�d|d� W d Q R X | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� d| j d< d| _| j� � |�
ddd� | �|jj� | �|jj� | �|j j� | �|j
j� |�� |j�� |j�� | �dd� | j� | j� � W d Q R X | �|j� d S )NT�5 i��i� F�e )r r# r> rH r9 rH rJ rC rD rE rF rI rV r] rP rU rT rc )r r re r r r
�test_sigchld_unknown_status� s0
z2ChildWatcherTestsMixin.test_sigchld_unknown_statusc C s t �� }t �� }t �� }| j�< d| _| j�d|d� | j�d|d� | j�d|d� W d Q R X | �| j�d�� | �| j�d�� | �| j�d�� | �| j�d�� | �dd� | �dd� | �dd� d | _| j � | j�
� W d Q R X | �|j � | �|j � |� ddd� d S )
NT�6 r �7 rN �8 r* r F)
r r# r> rH r9 rP r: rH rT rc rV rJ r] )r r rp rq � callback3r r r
�test_remove_child_handler s* z0ChildWatcherTestsMixin.test_remove_child_handlerc C st t �� }| j� d| _| j�d|� W d Q R X t|j_t j� t
j d��$}| � | j�
� d � | �|j� W d Q R X d S )NT�9 �error)r r# r> rH r9 r rB r- rd rT r �loggerr; rV rP rJ )r r re Zm_errorr r r
� test_sigchld_unhandled_exception? s
z7ChildWatcherTestsMixin.test_sigchld_unhandled_exceptionc C s� t �� }| j� d| _| j�d|� W d Q R X | �|j� | �|jj� | �|jj� | �|j j� | �|j
j� d| _| � dd� t �
dt j� |j
�� | j� | j�� W d Q R X t| jtj�r�| �|j� n |�dd� d S )NT�: Fr � )r r# r> rH r9 rH rJ rC rD rE rF rT r� rB �WNOHANGrU rc rV rL r �FastChildWatcherr] )r r re r r r
�#test_sigchld_child_reaped_elsewhereQ s$
z:ChildWatcherTestsMixin.test_sigchld_child_reaped_elsewherec
C s� t �� }t �� }| j�\ | j�J d| _| �dd� | �dd� | j�� | j�d|� | j�d|� W d Q R X W d Q R X |�dd� | � |j
� d S )NTiO rh iQ rt iP ) r r# rc r> rH rT rV r9 r] rH rJ )r r rp rq r r r
�,test_sigchld_unknown_pid_during_registrationt s
" zCChildWatcherTestsMixin.test_sigchld_unknown_pid_during_registrationc
C s� t �� }| j� d| _| j�d|� W d Q R X | j}| �� | _t jj}||d��J}|| jd��2}| j� | j� |�
t j � |�
t j | jj
� W d Q R X W d Q R X d| _| �dd� | j�
� |�
dd� d S )NT�< r& r/ Fr^ )r r# r> rH r9 r r� rd rT r; r] r r[ rV rT )r r re �old_looprd Z m_old_removeZ m_new_addr r r
�
test_set_loop� s$
"
z$ChildWatcherTestsMixin.test_set_loopc
C s� t �� }t �� }t �� }| j�6 d| _| j�d|� | j�d|� | j�d|� W d Q R X | j}d | _t j�|d��6}| �t d�� | j�
d � W d Q R X |� t j
� W d Q R X | �dd� | �dd� | �|j� | �|j� | �|j� | �� | _t j�| jd ��J}| j�
| j� |� t j
| jj� |� dd� |� dd� | �|j� W d Q R X |�� |�� d
| _| �dd � | j�� | �|j� | �|j� |� dd � d S ) NT�= �> in r& zA loop is being detached� rw r/ Fr| )r r# r> rH r9 r rd rT ra �RuntimeWarningr; r] r r[ rT rH rJ r� rV rU )r r rp rq r� r� �m_remove_signal_handlerrJ r r r
� test_set_loop_race_condition� sN
z3ChildWatcherTestsMixin.test_set_loop_race_conditionc
C s� t �� }| j�� d| _| �dd� | �dd� | j�� | j�d|� | j�d|� | �t| jj �d� t
| jt j �r�| �t| jj
�d� t j�| jd��F}| j�� |�tj� | �| jj � t
| jt j �r�| �| jj
� W d Q R X W d Q R X d S ) NT�? r^ �A rl �@ r r& )r r# r> rH rT rV r9 r; r\ Z
_callbacksrL r r� Z_zombiesrd rT r r
r] r r[ rH )r r rp r� r r r
r^ � s(
z!ChildWatcherTestsMixin.test_closec
C sD t �� }| �� �*}| �td�� |�d|� W d Q R X W d Q R X d S )Nz/the child watcher does not have a loop attached�d )r r# rK r5 r. r9 )r r re r> r r r
�,test_add_child_handler_with_no_loop_attached s
zCChildWatcherTestsMixin.test_add_child_handler_with_no_loop_attached)"r@ rA rB r rd rT r r� rc r rB rT rC rD rE rF rW r\ rf rr rx rz r~ r� r� r� r� r� r� r� r� r^ r� re r r )r r
rG ` s2 = h E 5 % ! # > rG c @ s e Zd Zdd� ZdS )�SafeChildWatcherTestsc C s t �� S )N)r rM )r r r r
rK s z$SafeChildWatcherTests.create_watcherN)r@ rA rB rK r r r r
r� s r� c @ s e Zd Zdd� ZdS )�FastChildWatcherTestsc C s t �� S )N)r r� )r r r r
rK s z$FastChildWatcherTests.create_watcherN)r@ rA rB rK r r r r
r� s r� c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )� PolicyTestsc C s t �� S )N)r ZDefaultEventLoopPolicy)r r r r
�
create_policy s zPolicyTests.create_policyc C sX | � � }| �|j� |�� }| �|tj� | �|j|� | �||�� � | �|j� d S )N) r� r� �_watcher�get_child_watcherr: r rM r� r
)r �policyr> r r r
�test_get_child_watcher s z"PolicyTests.test_get_child_watcherc C s< | � � }t�� }|�|� | �|j|� | �||�� � d S )N)r� r r� Zset_child_watcherr� r� r� )r r� r> r r r
� test_get_child_watcher_after_set+ s
z,PolicyTests.test_get_child_watcher_after_setc C sL | � � }|�� }| �|j� |�� }| �|tj� | �|j |� |�
� d S )N) r� �get_event_loopr� r� r� r: r rM r� r
r
)r r� r r> r r r
�-test_get_child_watcher_with_mainloop_existing3 s z9PolicyTests.test_get_child_watcher_with_mainloop_existingc s6 � �fdd�}�� � � tj|d�}|�� |�� d S )Nc sR � � � �� � ��� �� tj� � �� } ��| tj� ��| j � � �� �
� d S )N) r r� r: r� r ZAbstractEventLoopr� rM r� r
r
)r> )r� r r r
r� A s
z4PolicyTests.test_get_child_watcher_thread.<locals>.f)rY )r� � threadingZThreadr� �join)r r� �thr )r� r r
� test_get_child_watcher_thread? s
z)PolicyTests.test_get_child_watcher_threadc C sr | � � }|�� }|�� }| �|j|� |�� }|�|� | �|j|� |�d � | �|jd � |�� |�� d S )N)r� r� r� r� r
r� r r
)r r� r r> Znew_loopr r r
�,test_child_watcher_replace_mainloop_existingS s
z8PolicyTests.test_child_watcher_replace_mainloop_existingN) r@ rA rB r� 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 )N)r r� r r )r r r r
r j s
zTestFunctional.setUpc C s | j �� t�d � d S )N)r r
r r )r r r r
�tearDownn s
zTestFunctional.tearDownc s� � fdd�}dd� }|� � � j �t� |� W d Q R X |� � � j �t� |� W d Q R X |� � � j �t� � W d Q R X |� � � j �t� � W d Q R X d S )Nc s � � td�S )NzInvalid file object)r5 r r )r r r
�
assert_raisess s zFTestFunctional.test_add_reader_invalid_argument.<locals>.assert_raisesc S s d S )Nr r r r r
r* v r+ zATestFunctional.test_add_reader_invalid_argument.<locals>.<lambda>)r r rT r" �
remove_reader�
remove_writer)r r� r< r )r r
� test_add_reader_invalid_argumentr s z/TestFunctional.test_add_reader_invalid_argumentc sR �fdd�� � ��fdd�}t �� \�}z�j�|� � W d ��� |�� X d S )Nc s � � td�S )Nz'File descriptor .* is used by transport)r5 r. r )r r r
r� � s zLTestFunctional.test_add_reader_or_writer_transport_fd.<locals>.assert_raisesc � sD �j jdd� �d�I d H \} }�zdd� }� � � �j ��|� W d Q R X � � � �j ���� |� W d Q R X � � � �j ��� W d Q R X � � � �j ���� � W d Q R X � � � �j ��|� W d Q R X � � � �j ���� |� W d Q R X � � � �j ��� W d Q R X � � � �j ���� � W d Q R X W d | �� X d S )Nc S s t �� S )N)r r� r r r r
r* � r+ zWTestFunctional.test_add_reader_or_writer_transport_fd.<locals>.runner.<locals>.<lambda>)rp c S s d S )Nr r r r r
r* � r+ )r Zcreate_connectionr r� r� r" r� r
)r� Zprr< )r� �rsockr r r
�runner� s* zETestFunctional.test_add_reader_or_writer_transport_fd.<locals>.runner)rj Z
socketpairr rm r
)r r� Zwsockr )r� r� r r
�&test_add_reader_or_writer_transport_fd� s z5TestFunctional.test_add_reader_or_writer_transport_fdN)r@ rA rB r r� r� r� r r r r
r� h s r� �__main__)1�__doc__� collectionsr� rC r� r� rt r rj r� �sysrz r� r� r Ztestr �platformZSkipTestr r r r r Ztest.test_asyncior rh r� r� r r� ZTestCaser r� rg r� r� r r7 r@ �
namedtuplerA rG r� r� r� r� r@ �mainr r r r
�<module> sr
R
)
N 2 5NF