File: //usr/local/lib/python3.10/test/test_asyncio/__pycache__/test_base_events.cpython-310.pyc
o
�iC< � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl m
Z
ddl Z ddl m Z ddl m
Z
ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ ddlZe
jZejd kZ d d
� Z dd� Z dd� Z G dd� dej �Z!G dd� dej �Z"G dd� de j#�Z$G dd� de j%�Z&G dd� dej �Z'G d d � d e j �Z(G d d � d ej �Z)G d d!� d!ej �Z*e+d"kr�e �,� dS dS )#zTests for base_events.py� N)�mock)� base_events)� constants)�utils)�support)�assert_python_ok)� os_helper)�
socket_helper)� � c C s t �d � d S �N)�asyncioZset_event_loop_policy� r r �?/usr/local/lib/python3.10/test/test_asyncio/test_base_events.py�tearDownModule � r c C s` t jtd�} dD ]}tt|�rt| |tt|�� qt| |� qt �� | _t�� | j_ d| j
_ | S )N)�spec)
�AF_INET�AF_INET6� AF_UNSPEC� IPPROTO_TCP� IPPROTO_UDP� SOCK_STREAM�
SOCK_DGRAM�
SOL_SOCKET� SO_REUSEADDR� inet_ptonF) r Z MagicMock�socket�hasattr�setattr�getattr�delattr�
test_utilsZmock_nonblocking_socket� return_value� getaddrinfo�
_is_coroutine)�m_socket�namer r r �mock_socket_module s
r( c C s t jdtd�| �S )Nzasyncio.base_events.socket)Z new_callable)r �patchr( )�fr r r � patch_socket1 s
��r+ c @ s( e Zd Zdd� Zdd� Zedd� �ZdS )�BaseEventTestsc
C s� t j}t j}t j}t j}t j}t j}t j}| �|||ddft �
dd|||�� | �|||ddft �
dd|||�� | �|||ddft �
dd|||�� | �|||ddft �
dd|||�� | �|||ddft �
dd||d�� | �|||ddft �
dd||d�� | � t �
dd|dd�� t j
r�| � t �
dd|||�� | �|||ddft �
dd|||�� | �|||ddft �
dd|||�� | � t �
dd|||�� | � t �
d d|||�� d S d S )
N� ��1.2.3.4� r/ r0 s 1.2.3.4r )�::3r0 r r r1 z::3%lo0)r r r r r r r r � assertEqualr � _ipaddr_info� assertIsNoner � IPV6_ENABLED)�selfZUNSPEC�INETZINET6�STREAMZDGRAM�TCPZUDPr r r �test_ipaddr_info8 sj � � � � � ��� � ����z BaseEventTests.test_ipaddr_infoc
C s� t j}t j}t j}| �|||ddft�dd |||�� | �|||ddft�dd|||�� | �|||ddft�dd|||�� | �|||ddft�dd|||�� | �|||ddft�dd|||�� d S )Nr- �r/ r r/ � r. �1� 1)r r r r r2 r r3 )r6 r7 r8 r9 r r r �test_port_parameter_typest s. � � � � �z(BaseEventTests.test_port_parameter_typesc C s& |` | �t�ddtjtjtj�� d S )Nr/ r0 )r r4 r r3 r r r r �r6 r& r r r � test_ipaddr_info_no_inet_pton� s
�z,BaseEventTests.test_ipaddr_info_no_inet_ptonN)�__name__�
__module__� __qualname__r: r? r+ rA r r r r r, 6 s
<r, c st e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z d7d8� Z d9d:� Z d;d<� Z d=d>� Z!d?d@� Z"dAdB� Z#dCdD� Z$dEdF� Z%dGdH� Z&dIdJ� Z'dKdL� Z(dMdN� Z)dOdP� Z*dQdR� Z+dSdT� Z,dUdV� Z-dWdX� Z.� Z/S )Y�BaseEventLoopTestsc s< t � �� t�� | _t�� | j_d| jjj_ | �
| j� d S �Nr ) �super�setUpr �
BaseEventLoop�loopr �Mock� _selector�selectr# �set_event_loop�r6 �� __class__r r rH � s
zBaseEventLoopTests.setUpc C s� t �� }| �t| jj||� | �t| jj||||� | �t| jj||� | �t| jjg � | �t| jj � | �t| jj
||� | �t| jj ||� | j� |||||||�}| �t�� |�
d � W d � d S 1 skw Y d S r )r rK � assertRaises�NotImplementedErrorrJ Z_make_socket_transport�_make_ssl_transportZ_make_datagram_transport�_process_events�_write_to_selfZ_make_read_pipe_transportZ_make_write_pipe_transportZ_make_subprocess_transport�send)r6 �m�genr r r �test_not_implemented� s>
��
�
��
�
� "�z'BaseEventLoopTests.test_not_implementedc C sn | � | j�� � | j�� | �| j�� � | j�� | j�� | j�� }| �t| jj� | �t| jj |� d S r )
� assertFalserJ Z is_closed�close�
assertTrue�
create_futurerR � RuntimeError� run_forever�run_until_complete)r6 r* r r r �
test_close� s
z BaseEventLoopTests.test_closec C sD t �dd� d| jd �}| j�|� | �| jj� | �|| jj� d S )Nc S � dS �NFr r r r r �<lambda>� � z>BaseEventLoopTests.test__add_callback_handle.<locals>.<lambda>r )r
�HandlerJ �
_add_callbackr[ �
_scheduled�assertIn�_ready�r6 �hr r r �test__add_callback_handle� s z,BaseEventLoopTests.test__add_callback_handlec C sJ t �dd� d| jd �}|�� | j�|� | �| jj� | �| jj� d S )Nc S rc rd r r r r r re � rf zHBaseEventLoopTests.test__add_callback_cancelled_handle.<locals>.<lambda>r )r
rg rJ �cancelrh r[ ri rk rl r r r �#test__add_callback_cancelled_handle� s
z6BaseEventLoopTests.test__add_callback_cancelled_handlec C sR G dd� dt jj�}t�� | j_t�� | j_|� }| j�|� | � || jj
� d S )Nc @ � e Zd Zdd� ZdS )zCBaseEventLoopTests.test_set_default_executor.<locals>.DummyExecutorc _ � t d��)Nz#cannot submit into a dummy executor)rS )r6 �fn�args�kwargsr r r �submit� s �zJBaseEventLoopTests.test_set_default_executor.<locals>.DummyExecutor.submitN)rB rC rD rv r r r r �
DummyExecutor� s rw ) �
concurrent�futures�ThreadPoolExecutorr rK rJ rU rV �set_default_executor�assertIs�_default_executor)r6 rw �executorr r r �test_set_default_executor� s z,BaseEventLoopTests.test_set_default_executorc C sJ t �� }| �t�� | j�|� W d � n1 sw Y d | j_d S r )r rK � assertWarns�DeprecationWarningrJ r{ r} )r6 r~ r r r �.test_set_default_executor_deprecation_warnings� s
� zABaseEventLoopTests.test_set_default_executor_deprecation_warningsc C sD dd� }| j �|�}| �|j|� | �|tj� | �|| j j� d S )Nc S � d S r r r r r r �cb� � z-BaseEventLoopTests.test_call_soon.<locals>.cb) rJ � call_soonr2 � _callback�assertIsInstancer
rg rj rk �r6 r� rm r r r �test_call_soon� s
z!BaseEventLoopTests.test_call_soonc C sJ | j �d� | �td�� | j �d� W d � d S 1 s w Y d S )NTza callable objectr0 )rJ � set_debug�assertRaisesRegex� TypeErrorr� rO r r r �test_call_soon_non_callable� s "�z.BaseEventLoopTests.test_call_soon_non_callablec C sH dd� }| j �d|�}| �|tj� | �|| j j� | �|| j j� d S )Nc S r� r r r r r r r� � r� z.BaseEventLoopTests.test_call_later.<locals>.cb� $@) rJ �
call_laterr� r
� TimerHandlerj ri Z assertNotInrk r� r r r �test_call_later� s
z"BaseEventLoopTests.test_call_laterc s\ g � � fdd�}t �� | j_| j�d|d� | j�d|d� t�| j� | �� ddg� d S )Nc s � � | � d S r )�append)�arg�Zcallsr r r� r z>BaseEventLoopTests.test_call_later_negative_delays.<locals>.cb����a����b)r rK rJ rU r� r" � run_brieflyr2 )r6 r� r r� r � test_call_later_negative_delays s z2BaseEventLoopTests.test_call_later_negative_delaysc s~ � fdd�}t �� � j_d}� j�� | }� j�||� � j�� }� j�� � j�� | }� �||d |� � �|d|� d S )Nc s � j �� d S r �rJ �stopr rO r r r� r z4BaseEventLoopTests.test_time_and_call_at.<locals>.cb皙�����?g�������?g�������?) r rK rJ rU �time�call_atr` ZassertGreaterEqual�assertLessEqual)r6 r� �delayZwhen�t0Zdtr rO r �test_time_and_call_at s
z(BaseEventLoopTests.test_time_and_call_atc C s� dd� }|� |� |rgd}| �t|��
|�|� W d � n1 s#w Y | �t|�� |�d|� W d � n1 s?w Y | �t|�� |�|�� d |� W d � d S 1 s`w Y d S |�|� |�d|� |�|�� d |� d S )Nc S r� r r r r r r r� # r� z+BaseEventLoopTests.check_thread.<locals>.cbzMNon-thread-safe operation invoked on an event loop other than the current one�< )r� r� r_ r� r� r� r� )r6 rJ �debugr� �msgr r r � check_thread" s
� �"�
z BaseEventLoopTests.check_threadc sn �fdd�� d� fdd� }t �� �j_t �� �j_|�jd� |�jd� |�jddd� |�jddd� d S ) Nc
s� |� � z/|r,t�� }zt�|� � �| |� W t�d � |�� nt�d � |�� w � �| |� W n tyM } z| �|j |� W Y d }~d S d }~ww | �|j
d � d S r ) �waitr rI r
rN r� r\ � Exception�call_soon_threadsafe�
set_exception�
set_result)rJ �eventr� � create_loop�futZloop2�excrO r r �check_in_thread6 s$
�
� ��z=BaseEventLoopTests.test_check_thread.<locals>.check_in_threadFc sV t �� }| �� }| �|j� | ||||f}t j� |d�}|�� | �|� |�� d S )N)�targetrt ) � threading�Eventr^ r� �set�Thread�startra �join)rJ r� r� r� r� rt �thread)r� r r � test_threadJ s
z9BaseEventLoopTests.test_check_thread.<locals>.test_threadT)r� �F)r rK rJ rU rV )r6 r� r )r� r6 r �test_check_thread5 s
z$BaseEventLoopTests.test_check_threadc C s� t �t�� d dd� d| jd �}t �t�� d dd� d| jd �}|�� t�� | j_| jj �
|� | jj �
|� | j� � | jj j
jd d }| �d| k oRd k n |� | �|g| jj � | �| jjj� d S )
Ng @c S rc �NTr r r r r re e rf z3BaseEventLoopTests.test__run_once.<locals>.<lambda>r r� c S rc r� r r r r r re g rf r g #@g %@)r
r� r� � monotonicrJ ro r rK rU ri r� � _run_oncerL rM � call_argsr] r2 �called)r6 Zh1Zh2�tr r r �test__run_onced s ��
z!BaseEventLoopTests.test__run_oncec C s< | j �d� | �| j �� � | j �d� | �| j �� � d S )NTF)rJ r� r] Z get_debugr[ rO r r r �test_set_debugv s z!BaseEventLoopTests.test_set_debugc s~ d � d�� �fdd�}t �t�� d || jf| jd �}t�� | j_| jj� |� | j�
� | � �� | � � gt
| jj�� d S )NFc s d�| � dd� �� d S )NTc S rc r� r r r r r re � rf zOBaseEventLoopTests.test__run_once_schedule_handle.<locals>.cb.<locals>.<lambda>)r� �rJ ��handleZ processedr r r� � s z=BaseEventLoopTests.test__run_once_schedule_handle.<locals>.cbr0 )r
r� r� r� rJ r rK rU ri r� r� r] r2 �listrk r� r r� r � test__run_once_schedule_handle| s �
z1BaseEventLoopTests.test__run_once_schedule_handlec C s� t �� | j_| �dtj k odk n � dd� }d}| j�d|� d}td�D ]
}| j�d|�}|� � q)|d7 }td�D ]
}| j�d |�}|� � q?| �
|| tj � | � | jj
|� | j�� |d8 }| � | jj
|� | � t| jj�|| � tt�tj tj ��d }ttj | d�}||7 }t|�D ] }| j�d|� q�||7 }t|�D ]
}| j�d|�}|� � q�| � t| jj�|| � | j�� | � t| jj�|� | �td
d � | jjD ��� d S ) Nr g �?c S r� r r r r r r r� � r� zEBaseEventLoopTests.test__run_once_cancelled_event_cleanup.<locals>.cbr0 � � i �d c S s g | ]}|j �qS r )Z
_cancelled)�.0�xr r r �
<listcomp>� s zMBaseEventLoopTests.test__run_once_cancelled_event_cleanup.<locals>.<listcomp>)r rK rJ rU r] r Z%_MIN_CANCELLED_TIMER_HANDLES_FRACTIONr� �rangero r� Z _MIN_SCHEDULED_TIMER_HANDLESr2 Z_timer_cancelled_countr� �lenri �int�math�ceil�max�all)r6 r� Znot_cancelled_countZcancelled_countr� rm Zadd_cancel_countZadd_not_cancel_countr r r �&test__run_once_cancelled_event_cleanup� sd �
�
������
�
z9BaseEventLoopTests.test__run_once_cancelled_event_cleanupc C s | � t| jjd� d S )NZblah)rR r� rJ ra rO r r r �"test_run_until_complete_type_error� s �z5BaseEventLoopTests.test_run_until_complete_type_errorc C s2 | j �� }| �� }| �|j� | �t|j|� d S r )rJ r^ Z
new_test_loop�
addCleanupr\ rR �
ValueErrorra )r6 �taskZ
other_loopr r r � test_run_until_complete_loop� s
�z/BaseEventLoopTests.test_run_until_complete_loopc s� G dd� dt �� dd� }� fdd�}t�� | j_| j�|� | �� �� | j�|d�� W d � n1 s6w Y | j�|d�� d S ) Nc @ � e Zd ZdS )z]BaseEventLoopTests.test_run_until_complete_loop_orphan_future_close_loop.<locals>.ShowStopperN�rB rC rD r r r r � ShowStopper� � r� c � s �t �| �I d H d S r �r
�sleep)r� r r r �foo� s �zUBaseEventLoopTests.test_run_until_complete_loop_orphan_future_close_loop.<locals>.fooc s � �r r r �r� r r �throw� r� zWBaseEventLoopTests.test_run_until_complete_loop_orphan_future_close_loop.<locals>.throwr� g�������?)�
SystemExitr rK rJ rU r� rR ra )r6 r� r� r r� r �5test_run_until_complete_loop_orphan_future_close_loop� s �zHBaseEventLoopTests.test_run_until_complete_loop_orphan_future_close_loopc C s� t jddg}| �t| jj| jjtj� | �t| jj| jjtj|� | �t| jj| jjtjt jd� | jt| jj| jjtjg|�R ddi� | jt| jj| jjtjg|�R ddi� | jt| jj| jjtjg|�R ddi� d S ) N�-c�pass�{ �universal_newlinesT�shell�bufsize� ) �sys�
executablerR r� rJ ra Zsubprocess_execr
�SubprocessProtocol)r6 rt r r r �!test_subprocess_exec_invalid_args� sJ � �
� ��� ��� ��
�z4BaseEventLoopTests.test_subprocess_exec_invalid_argsc C s� | � t| jj| jjtjd� | � t| jj| jjtjtjddg� | j t| jj| jjtjddd� | j t| jj| jjtjddd� | j t| jj| jjtjddd � d S )
Nr� r� r� zexit 0T)r� )r� r� )r� ) rR r� rJ ra Zsubprocess_shellr
r� r� r� rO r r r �"test_subprocess_shell_invalid_args s( � � � �
�z5BaseEventLoopTests.test_subprocess_shell_invalid_argsc s t �� � j_dd� }t �d��0}� j�� }� j�||� |�� fdd�� � j�� |j j
t � d�t
ttfd� W d � n1 sBw Y t �d��2}� j�� }� j�d||� |�� fd d�� � j�� |j j
t � d�t
ttfd� W d � d S 1 s�w Y d S )
Nc S s | � d� dd d S )NTr0 r )r� �r� r r r �
zero_error- s
zHBaseEventLoopTests.test_default_exc_handler_callback.<locals>.zero_error�asyncio.base_events.loggerc �
� j �� S r r� r� rO r r re 5 �
zFBaseEventLoopTests.test_default_exc_handler_callback.<locals>.<lambda>�Exception in callback.*zero��exc_info�{�G�z�?c r� r r� r� rO r r re ? r� )r rK rJ rU r) r^ r� �add_done_callbackr` �error�assert_called_withr" � MockPattern�ZeroDivisionError�MOCK_ANYr� )r6 r� �logr� r rO r �!test_default_exc_handler_callback* s,
� �
�"�z4BaseEventLoopTests.test_default_exc_handler_callbackc s� t �� � j_dd� }t �d��J}tj|� � jd�}|�� fdd�� � j�� d }t �
� t r>|j j
t�d�tttfd� n|j j
t�d �d
d� W d � d S W d � d S 1 s\w Y d S ) Nc � s �t �d�I d H dd d S )Nr� r0 r r� r r r r �zero_error_coroH s � zIBaseEventLoopTests.test_default_exc_handler_coro.<locals>.zero_error_coror� r� c r� r r� �rt rO r r re O r� zBBaseEventLoopTests.test_default_exc_handler_coro.<locals>.<lambda>z .*exception was never retrievedr� z(.*exception was never retrieved.*ZeroDivF)r rK rJ rU r) r
�
ensure_futurer� r` r �
gc_collect�PY34r� r r" r r r )r6 r r r� r rO r � test_default_exc_handler_coroE s,
���� "�z0BaseEventLoopTests.test_default_exc_handler_coroc C s> | � td�� | j�d� W d � d S 1 sw Y d S )NzA callable object or None�spam)r� r� rJ �set_exception_handlerrO r r r � test_set_exc_handler_invalid` s "�z/BaseEventLoopTests.test_set_exc_handler_invalidc s� dd� �� �fdd�}� j �d� t�� � j _� �� j �� � t�� }� j �|� � �� j �� |� |� }|� � j t
t � d�||j
d�� |�� � j �d � t�d��}|� |jj t � d �tt
t
fd
� W d � n1 spw Y � �|j� d S ) Nc S � dd d S �Nr0 r r r r r r r� e � zBBaseEventLoopTests.test_set_exc_handler_custom.<locals>.zero_errorc s � j ���} � j �� | S r �rJ r� r� )r� �r6 r� r r �run_looph s
z@BaseEventLoopTests.test_set_exc_handler_custom.<locals>.run_loopTz!Exception in callback.*zero_error)� exception�messager� Zsource_tracebackr� r� r� )rJ r� r rK rU r4 Zget_exception_handlerr
r| r r r" r Z_source_traceback�
reset_mockr) r� r r[ r� )r6 r Z mock_handlerr� r r r r �test_set_exc_handler_customd s: �� �� �z.BaseEventLoopTests.test_set_exc_handler_customc s~ � fdd�}dd� }t �� � j_� j�|� t �d��}|� |jjt� d�t
t t fd� W d � d S 1 s8w Y d S )Nc s" dd� } � j �| � � j �� d S )Nc S r r r r r r r r� � r zTBaseEventLoopTests.test_set_exc_handler_broken.<locals>.run_loop.<locals>.zero_errorr �r� rO r r r � s z@BaseEventLoopTests.test_set_exc_handler_broken.<locals>.run_loopc S rr �Nr )�AttributeError�rJ �contextr r r �handler� � z?BaseEventLoopTests.test_set_exc_handler_broken.<locals>.handlerr� z$Unhandled error in exception handlerr� ) r rK rJ rU r
r) r� r r" r r r )r6 r r r r rO r �test_set_exc_handler_broken� s ��"�z.BaseEventLoopTests.test_set_exc_handler_brokenc s d � G � fdd�dt j�}|� �| ��j� t��� �fdd�}t�d��}|� |jj ddd� W d � n1 s<w Y d d
� }d � ��
|� t�d��)}|� |jj t � d �dd� | �
d � � | �t� d d
�t� W d � d S 1 s}w Y d S )Nc s( e Zd Ze�� Ze�� Z� fdd�ZdS )z@BaseEventLoopTests.test_default_exc_handler_broken.<locals>.Loopc s |� t d��r �r� )r6 r ��_contextr r �default_exception_handler� s zZBaseEventLoopTests.test_default_exc_handler_broken.<locals>.Loop.default_exception_handlerN)rB rC rD r rK rL rU r$ r r" r r �Loop� s r% c s dd� } � � | � � �� d S )Nc S r r r r r r r r� � r zXBaseEventLoopTests.test_default_exc_handler_broken.<locals>.run_loop.<locals>.zero_error)r� r� r r� r r r � s
zDBaseEventLoopTests.test_default_exc_handler_broken.<locals>.run_loopr� z&Exception in default exception handlerTr� c S rr )NZhamr! r r r r �custom_handler� r zJBaseEventLoopTests.test_default_exc_handler_broken.<locals>.custom_handlerz9Exception in default exception.*while handling.*in customr r )r rI r� r\ r
rN r r) r� r r
r" r rj r| �typer )r6 r% r r r& r )r# rJ r � test_default_exc_handler_broken� s6
� �
� �"�z2BaseEventLoopTests.test_default_exc_handler_brokenc C sL | � td�� | j�d� W d � n1 sw Y | �| j�� � d S )Nz'task factory must be a callable or Noner0 )r� r� rJ �set_task_factoryr4 �get_task_factoryrO r r r � test_set_task_factory_invalid� s � �z0BaseEventLoopTests.test_set_task_factory_invalidc s� t �� | j_G dd� dtj�� dd� }� fdd�}| �| j�� � | j�|� | � | j�� |� | j�
|� �}| � t |� �� | j�
|� | j�d � | �| j�� � | j�
|� �}| � t |tj�� | �t |� �� | j�
|� d S )Nc @ r� )z8BaseEventLoopTests.test_set_task_factory.<locals>.MyTaskNr� r r r r �MyTask� r� r, c � � �d S r r r r r r �coro� � �z6BaseEventLoopTests.test_set_task_factory.<locals>.coroc s � || d�S �Nr� r �rJ r. �r, r r re � � z:BaseEventLoopTests.test_set_task_factory.<locals>.<lambda>)r rK rJ rU r
�Taskr4 r* r) r| � create_taskr] �
isinstancera r[ )r6 r. �factoryr� r r2 r �test_set_task_factory� s z(BaseEventLoopTests.test_set_task_factoryc C s� d� d�}tdd|�\}}}| �|�� d� td|ddd�\}}}| �|�� d� td|ddd�\}}}| �|�� d � tdd|dd
�\}}}| �|�� d� tdd d d|�\}}}| �|�� d � d S )
N�
)zimport asyncioz loop = asyncio.new_event_loop()zprint(loop.get_debug())z-Er� s Falser- )�PYTHONASYNCIODEBUGZ
PYTHONDEVMODEr= s True)r: z-X�dev)r� r r2 �rstrip)r6 �code�sts�stdout�stderrr r r �test_env_var_debug� s*
� � �
�z%BaseEventLoopTests.test_env_var_debugc st G dd� dt j�� dd� }G � �fdd�dtj�}|� �| ��� |� }t j|�d�}| �|� � d|_|�� d S ) Nc @ r� )z3BaseEventLoopTests.test_create_task.<locals>.MyTaskNr� r r r r r, r� r, c � r- r r r r r r �test r/ z1BaseEventLoopTests.test_create_task.<locals>.testc s e Zd Z� �fdd�ZdS )z6BaseEventLoopTests.test_create_task.<locals>.EventLoopc s � |�d�S r0 r �r6 r. �r, rJ r r r5 r zBBaseEventLoopTests.test_create_task.<locals>.EventLoop.create_taskN)rB rC rD r5 r rD r r � EventLoop s rE r� F) r
r4 r rI rN r r� Z_log_destroy_pendingr\ )r6 rB rE r. r� r rD r �test_create_task s
z#BaseEventLoopTests.test_create_taskc C s� dd� }t �� }|�� tjdd��.}| �t�� t j|� |d� W d � n1 s+w Y | �t |�d� W d � d S 1 sCw Y d S )Nc � r- r r r r r r rB % r/ zCBaseEventLoopTests.test_create_task_error_closes_coro.<locals>.testT)�recordr� r )
r
�new_event_loopr\ �warnings�catch_warningsrR r_ r r2 r� )r6 rB rJ �wr r r �"test_create_task_error_closes_coro$ s �"�z5BaseEventLoopTests.test_create_task_error_closes_coroc C s^ dd� }t �� }|j|� dd�}z| �|�� d� W |�|� |�� d S |�|� |�� w )Nc � r- r r r r r r rB 0 r/ zLBaseEventLoopTests.test_create_named_task_with_default_factory.<locals>.test� test_task�r' )r
rH r5 r2 �get_namera r\ )r6 rB rJ r� r r r �+test_create_named_task_with_default_factory/ s
�
z>BaseEventLoopTests.test_create_named_task_with_default_factoryc C sp dd� }dd� }t �� }|�|� |j|� dd�}z| �|�� d� W |�|� |�� d S |�|� |�� w )Nc S s t j|| d�S r0 )r
r4 r1 r r r � task_factory< r zSBaseEventLoopTests.test_create_named_task_with_custom_factory.<locals>.task_factoryc � r- r r r r r r rB ? r/ zKBaseEventLoopTests.test_create_named_task_with_custom_factory.<locals>.testrM rN )r
rH r) r5 r2 rO ra r\ )r6 rQ rB rJ r� r r r �*test_create_named_task_with_custom_factory; s
�
z=BaseEventLoopTests.test_create_named_task_with_custom_factoryc C sl dd� }t �� | j_t �� | j_z | j�|� � W n ty" Y nw | j�� t� � | �
| jjj � d S )Nc � � �t �r ��KeyboardInterruptr r r r �raise_keyboard_interruptO r/ zXBaseEventLoopTests.test_run_forever_keyboard_interrupt.<locals>.raise_keyboard_interrupt) r rK rJ rU Zcall_exception_handlerra rU r\ r r r[ r� �r6 rV r r r �#test_run_forever_keyboard_interruptK s �
z6BaseEventLoopTests.test_run_forever_keyboard_interruptc s� dd� }t �� �j_z �j�|� � W n ty Y nw � �fdd�� d� _z
�j�� � �j�� W n ty= Y nw �� � j� d S )Nc � rS r rT r r r r rV a r/ zZBaseEventLoopTests.test_run_until_complete_baseexception.<locals>.raise_keyboard_interruptc s �j �� d� _d S r� )rJ r� r� r ��funcr6 r r rZ k �
zFBaseEventLoopTests.test_run_until_complete_baseexception.<locals>.funcF)
r rK rJ rU ra rU r� r� r` r] rW r rY r �%test_run_until_complete_baseexception^ s � �z8BaseEventLoopTests.test_run_until_complete_baseexceptionc s� t � �d� d �����fdd�}� ��fdd����fdd��|�j_�f�jjj_tdd �D ],}��d
| �� �j��jj � �j�
� �� � d� W d � n1 sVw Y q/d S ) Nr c s �| v r �j �� ��d S d S r �rJ r� )Z
event_list)�do_event�doer�event_sentinelr6 r r � proc_events} s �zZBaseEventLoopTests.test_single_selecter_event_callback_after_stopping.<locals>.proc_eventsc s � d7 � �j ��� d S �Nr0 r] r )� callcount�clear_selectorr6 r r r^ � s zWBaseEventLoopTests.test_single_selecter_event_callback_after_stopping.<locals>.do_eventc s � � � d�jjj_d S rF )ro rJ rL rM r# r )r_ r6 r r rd � s z]BaseEventLoopTests.test_single_selecter_event_callback_after_stopping.<locals>.clear_selectorr0 r
z Loop %d/2) �objectrJ rU rL rM r# r� ZsubTestr� r� r` r2 )r6 ra �ir )rc rd r^ r_ r` r6 r �2test_single_selecter_event_callback_after_stoppingv s
���zEBaseEventLoopTests.test_single_selecter_event_callback_after_stoppingc sD d� � fdd�}t �� | j_| j�|� t�| j� | �� d� d S )Nr c s � d7 � d S rb r r ��countr r �callback� s z2BaseEventLoopTests.test_run_once.<locals>.callbackr0 )r rK rJ rU r� r" Zrun_oncer2 )r6 rj r rh r �
test_run_once� s z BaseEventLoopTests.test_run_oncec C s4 t �� | j_| j�� | j�� | jjj�d� d S �Nr ) r rK rJ rU r� r` rL rM Zassert_called_once_withrO r r r � test_run_forever_pre_stopped� s
z/BaseEventLoopTests.test_run_forever_pre_stoppedc � sH �dddd���fdd�}|� }|� � � � ��fdd��t��� � �S )NF)�started�stopped� finalizedc s4 �d� d< zdD ]} | V qW d� d< d S d� d< w )NTrn )ZZEROZONEZTWO�THREEZFOURrp r ��item)�statusr r �agen� s ��z;BaseEventLoopTests.leave_unfinalized_asyncgen.<locals>.agenc � sN �z � � � I d H } W n
ty Y d S w | dkr d�d< d S t��� � d S )Nrq Tro )� __anext__�StopAsyncIterationr
r5 rr �Zai�iter_onert r r ry � s � �z?BaseEventLoopTests.leave_unfinalized_asyncgen.<locals>.iter_one)� __aiter__r
r5 )r6 ru Zagr rx r �leave_unfinalized_asyncgen� s ��
z-BaseEventLoopTests.leave_unfinalized_asyncgenc C s� t �� | j_t �� | j_t�� �E | j�| �� �}|d s't �
| j� |d r | � |d � | � |d � | � |d � t�
� t �
| j� | � |d � W d � d S 1 sXw Y d S )Nro rn rp )r rK rJ rU rV r �
disable_gcra r{ r" r� r] r[ r �r6 rt r r r � test_asyncgen_finalization_by_gc� s
� "�z3BaseEventLoopTests.test_asyncgen_finalization_by_gcc C s� t �� | j_t �� | j_| j�d� t�� �M | j�| � � �}|d s-t
� | j� |d r#| � |d � | � |d � | �
|d � | j�| j�d tj�� t
� | j� | � |d � W d � d S 1 sfw Y d S )NTro rn rp )r rK rJ rU rV r� r r| ra r{ r" r� r] r[ �run_in_executorr r} r r r �0test_asyncgen_finalization_by_gc_in_other_thread� s"
�� "�zCBaseEventLoopTests.test_asyncgen_finalization_by_gc_in_other_thread)0rB rC rD rH rZ rb rn rp 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+ r8 rA rF rL rP rR rX r\ rg rk rm r{ r~ r� �
__classcell__r r rP r rE � sZ
/L $0 "rE c @ �B e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�MyProtoNFc C s& d| _ d| _|rt�� �� | _d S d S �N�INITIALr )�state�nbytesr
Zget_running_loopr^ �done)r6 r^ r r r �__init__� s
�zMyProto.__init__c G s$ | j |vrtd| j �d|����d S �Nzstate: z , expected: �r� �AssertionError�r6 Zexpectedr r r �
_assert_state� �
�zMyProto._assert_statec C s$ || _ | �d� d| _|�d� d S )Nr� � CONNECTEDs% GET / HTTP/1.0
Host: example.com
)� transportr� r� �write�r6 r� r r r �connection_made� s
zMyProto.connection_madec C � | � d� | jt|�7 _d S )Nr� �r� r� r� �r6 �datar r r �
data_received �
zMyProto.data_receivedc C s | � d� d| _d S )Nr� �EOF)r� r� rO r r r � eof_received r[ zMyProto.eof_receivedc C s, | � dd� d| _| jr| j�d � d S d S )Nr� r� �CLOSED�r� r� r� r� �r6 r� r r r �connection_lost s
�zMyProto.connection_lostr� )
rB rC rD r� r� r� r� r� r� r� r r r r r� � s
r� c @ r� )�MyDatagramProtoNFc C s" d| _ d| _|r|�� | _d S d S r� )r� r� r^ r� )r6 r^ rJ r r r r� s
�zMyDatagramProto.__init__c C s$ | j |krtd| j �d|����d S r� r� r� r r r r� r� z MyDatagramProto._assert_statec C s || _ | �d� d| _d S )Nr� � INITIALIZED)r� r� r� r� r r r r� s
z MyDatagramProto.connection_madec C r� �Nr� r� )r6 r� �addrr r r �datagram_received$ r� z!MyDatagramProto.datagram_receivedc C s | � d� d S r� )r� r� r r r �error_received( r z MyDatagramProto.error_receivedc C s* | � d� d| _| jr| j�d � d S d S )Nr� r� r� r� r r r r� + s
�z MyDatagramProto.connection_lost)FN)
rB rC rD r� r� r� r� r� r� r� r r r r r� s
r� c s� e Zd Z� fdd�Ze�d�dd� �Zedd� �Zedd � �Z d
d � Z
d d
� Z dd� Z dd� Z
e�eed�d�dd� �Ze�ejd�dd� �Zdd� Zdd � Zd d � Zd d � Zd!d"� Zed#d$� �Zd%d&� Z e�ejd�e� e j � d'�d(�ed)d*� ���Z!ed+d,� �Z"ed-d.� �Z#ed/d0� �Z$d1d2� Z%ed3d4� �Z&d5d6� Z'd7d8� Z(d9d:� Z)d;d<� Z*d=d>� Z+d?d@� Z,dAdB� Z-dCdD� Z.edEdF� �Z/edGdH� �Z0edIdJ� �Z1edKdL� �Z2dMdN� Z3dOdP� Z4dQdR� Z5edSdT� �Z6e�ejdU�dVdW� �Z7edXdY� �Z8dZd[� Z9ed\d]� �Z:d^d_� Z;e�eed`�da�dbdc� �Z<ej=ddde� �Z>dfdg� Z?e� e j dhkdi�djdk� �Z@dldm� ZAdndo� ZBedpdq� �ZCedrds� �ZDdtdu� ZEe�dv�dwdx� �ZFdydz� ZGe�dv�d{d|� �ZH� ZIS )}� BaseEventLoopWithSelectorTestsc s$ t � �� t�� | _| �| j� d S r )rG rH r
ZSelectorEventLooprJ rN rO rP r r rH 4 s
z$BaseEventLoopWithSelectorTests.setUpzsocket.getnameinfoc C s. dd� |_ | j�| j�d��}| �|d� d S )Nc W rc )N�* r r r r r re ; rf zABaseEventLoopWithSelectorTests.test_getnameinfo.<locals>.<lambda>)�abcr� r� )� side_effectrJ ra � getnameinfor2 )r6 Zm_gai�rr r r �test_getnameinfo9 s
z/BaseEventLoopWithSelectorTests.test_getnameinfoc s� G dd� dt j�}dd� ���fdd�}d�dd g� � �fd
d �}||_|�j_�j�|d d
�}��t��}�j�|� W d � n1 sFw Y �� t
|j �d� d S )Nc @ r� )zVBaseEventLoopWithSelectorTests.test_create_connection_multiple_errors.<locals>.MyProtoNr� r r r r r� B r� r� c � s
�ddgS �N�r� r0 � r- )z 107.6.106.82�P r �rt �kwr r r r$ E � ��zZBaseEventLoopWithSelectorTests.test_create_connection_multiple_errors.<locals>.getaddrinfoc � �j �� | i |���S r �rJ r5 �rt �kwds�r$ r6 r r �getaddrinfo_taskI � z_BaseEventLoopWithSelectorTests.test_create_connection_multiple_errors.<locals>.getaddrinfo_taskr� Zerr1Zerr2c s �d7 �t � � ��rb )�OSErrorr� )�errors�idxr r �_socketO s zVBaseEventLoopWithSelectorTests.test_create_connection_multiple_errors.<locals>._socket� example.comr� z Multiple exceptions: err1, err2) r
�Protocolr rJ r$ �create_connectionrR r� ra r2 �strr )r6 r& r� r� r� r. �cmr )r� r$ r� r6 r �&test_create_connection_multiple_errors? s �zEBaseEventLoopWithSelectorTests.test_create_connection_multiple_errorsc s� t �� }||j_� fdd�}|� j_t jj� jdtj d��4 � j�
t dd�}� � tj �� � j�
|� W d � n1 s=w Y � �|jj� W d � d S 1 sTw Y d S )Nc s, � j �� }tjtjdddf}|�|g� |S )Nr r- )� 127.0.0.1r� )rJ r^ r r r r� )rt r� r� r� rO r r r$ d s
� zRBaseEventLoopWithSelectorTests.test_create_connection_timeout.<locals>.getaddrinfo� sock_connect)r� r� r� )r rK r r# rJ r$ r) re r
� TimeoutErrorr� r� rR ra r] r\ r� )r6 r& �sockr$ r. r rO r � test_create_connection_timeout^ s � �"�z=BaseEventLoopWithSelectorTests.test_create_connection_timeoutc C �, | j jtddt� d�}| �t| j j|� d S )Nr� r� �r� )rJ r� r� re rR r� ra rC r r r �%test_create_connection_host_port_socks �
�zDBaseEventLoopWithSelectorTests.test_create_connection_host_port_sockc C � t � t jt j�}|�5 | jjt|d�}| �td�� | j�|� W d � n1 s*w Y W d � d S W d � d S 1 sBw Y d S �Nr� z A Stream Socket was expected) r r r rJ r� r� r� r� ra �r6 r� r. r r r �!test_create_connection_wrong_sockx � � ��"�z@BaseEventLoopWithSelectorTests.test_create_connection_wrong_sockc C r� r� ) r r r rJ �
create_serverr� r� r� ra r� r r r � test_create_server_wrong_sock� r� z<BaseEventLoopWithSelectorTests.test_create_server_wrong_sockc C �R | j jtdddd�}| �td�� | j �|� W d � d S 1 s"w Y d S �Nr� r� r0 )�ssl_handshake_timeoutz1ssl_handshake_timeout is only meaningful with ssl)rJ r� r� r� r� ra rC r r r �/test_create_server_ssl_timeout_for_plain_socket� � ��"�zNBaseEventLoopWithSelectorTests.test_create_server_ssl_timeout_for_plain_socket�
SOCK_NONBLOCKz$no socket.SOCK_NONBLOCK (linux only)c C sx t � t jt jt jB �}|�% | jjdd� |d�}| j�|�}|�� | j�|�� � W d � d S 1 s5w Y d S )Nc S r� r r r r r r re � rf zRBaseEventLoopWithSelectorTests.test_create_server_stream_bittype.<locals>.<lambda>r� ) r r r r� rJ r� ra r\ � wait_closed)r6 r� r. �srvr r r �!test_create_server_stream_bittype� s � "�z@BaseEventLoopWithSelectorTests.test_create_server_stream_bittypezno IPv6 supportc
sl � fdd�}z
� j �|� � W d S ty5 } zttd�r)|jtjkr)� �d� n� W Y d }~d S d }~ww )Nc � sb �t �dd� dd�I d H } z� �t| j�d� W | �� | �� I d H d S | �� | �� I d H w )Nc S r� r r r r r r re � rf zVBaseEventLoopWithSelectorTests.test_create_server_ipv6.<locals>.main.<locals>.<lambda>�::1r )r
Z start_serverZ
assertGreaterr� �socketsr\ r� )r� rO r r �main� s ��zDBaseEventLoopWithSelectorTests.test_create_server_ipv6.<locals>.main�
EADDRNOTAVAILzfailed to bind to ::1)rJ ra r� r �errnor� ZskipTest)r6 r� �exr rO r �test_create_server_ipv6� s
���z6BaseEventLoopWithSelectorTests.test_create_server_ipv6c C s� t � t j�}|�5 | jjt|d�}| �td�� | j�|� W d � n1 s(w Y W d � d S W d � d S 1 s@w Y d S )Nr� zA UDP Socket was expected)r r rJ �create_datagram_endpointr� r� r� ra r� r r r �(test_create_datagram_endpoint_wrong_sock� s � ��"�zGBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_wrong_sockc C �" | j �t�}| �t| j j|� d S r �rJ r� r� rR r� ra rC r r r �(test_create_connection_no_host_port_sock� � zGBaseEventLoopWithSelectorTests.test_create_connection_no_host_port_sockc sD dd� � � �fdd�}|�j _�j �tdd�}��t�j j|� d S )Nc � s �g S r r r� r r r r$ � r/ zYBaseEventLoopWithSelectorTests.test_create_connection_no_getaddrinfo.<locals>.getaddrinfoc r� r r� r� r� r r r� � r� z^BaseEventLoopWithSelectorTests.test_create_connection_no_getaddrinfo.<locals>.getaddrinfo_taskr� r� )rJ r$ r� r� rR r� ra �r6 r� r. r r� r �%test_create_connection_no_getaddrinfo� s
�zDBaseEventLoopWithSelectorTests.test_create_connection_no_getaddrinfoc sZ dd� � � �fdd�}|�j _t�� �j _t�j j_�j �tdd�}�� t�j j
|� d S )Nc � s �dgS r� r r� r r r r$ � s �zVBaseEventLoopWithSelectorTests.test_create_connection_connect_err.<locals>.getaddrinfoc r� r r� r� r� r r r� � r� z[BaseEventLoopWithSelectorTests.test_create_connection_connect_err.<locals>.getaddrinfo_taskr� r� ) rJ r$ r rK r� r� r� r� r� rR ra r� r r� r �"test_create_connection_connect_err� s
�zABaseEventLoopWithSelectorTests.test_create_connection_connect_errc s� dd� � � �fdd�}|�j _t�� �j _t�j j_�j jtddt j
d�}�� t�� �j � |� W d � d S 1 s<w Y d S )Nc � �
�ddgS �N)r� r0 r� r- )�0.0.0.1r� )r� r0 r� r- )z0.0.0.2r� r r� r r r r$ � r� zSBaseEventLoopWithSelectorTests.test_create_connection_multiple.<locals>.getaddrinfoc r� r r� r� r� r r r� � r� zXBaseEventLoopWithSelectorTests.test_create_connection_multiple.<locals>.getaddrinfo_taskr� r� ��family)
rJ r$ r rK r� r� r� r� r� r r rR ra r� r r� r � test_create_connection_multiple� s
� "�z>BaseEventLoopWithSelectorTests.test_create_connection_multiplec s� dd� }||j j_dd� � � �fdd�}|�j_t�� �j_td��jj_ �jj
t dd t j d
d �}��
t��}�j�|� W d � n1 sGw Y ��t|j��d �� ��|j jjj� d S )
Nc S s" | d dkrt d�}d|_|�d S )Nr r� �Err)r� �strerror)r� �errr r r �bind� s
�z^BaseEventLoopWithSelectorTests.test_create_connection_multiple_errors_local_addr.<locals>.bindc � r� r� r r� r r r r$ � r� zeBaseEventLoopWithSelectorTests.test_create_connection_multiple_errors_local_addr.<locals>.getaddrinfoc r� r r� r� r� r r r� � r� zjBaseEventLoopWithSelectorTests.test_create_connection_multiple_errors_local_addr.<locals>.getaddrinfo_taskZErr2r� r� �Ni� �r� �
local_addrzMultiple exceptions: )r r# r� rJ r$ r rK r� r� r� r� r� r rR ra r] r� r �
startswithr\ r� )r6 r& r� r� r. r� r r� r �1test_create_connection_multiple_errors_local_addr� s
� �zPBaseEventLoopWithSelectorTests.test_create_connection_multiple_errors_local_addrc C s� |s|` tj|_|jj}t�� | j_d| jj_t�� | j_ d| jj _| j�
t j dd�}| j�
|�\}}z*|j�d� |jj\}}| �|d |j� | �|d |j� W |�� t�| j� n |�� t�| j� w tjr�tj|_| j�
t j dd�}| j�
|�\}}z@|jjd \} | d d � \}
} | �|
d
� | �| d� |jj\}}| �|d |j� | �|d |j� W |�� t�| j� d S |�� t�| j� w d S ) NFr/ r� �r/ r� r� r' r� r r� z ::(0\.)*1) r r r$ r# r rK rJ � _add_readerr% � _add_writerr� r
r� ra �connectr r� r2 r r r\ r" r� r r5 r r� � assertRegex) r6 r& Zallow_inet_ptonr� r. r� �p�_ru �address�host�portr r r � _test_create_connection_ip_addr sH
� ��z>BaseEventLoopWithSelectorTests._test_create_connection_ip_addrZaixzDbpo-25545: IPv6 scope id and getaddrinfo() behave differently on AIXc C s� t j|_|j j}t j|_t�� | j_d| jj_ t�� | j_
d| jj
_ | j� t j
dd�}| j�|�\}}z+|j�d� |j j\}}| �|d |j� | �|d |j� W |�� t�| j� d S |�� t�| j� w )NFz fe80::1%1r� )zfe80::1r� r r0 r� r' )r r$ r# r r� r rK rJ r� r% r r� r
r� ra r r r� r2 r r\ r" r� )r6 r& r� r. r� r r ru r r r �!test_create_connection_ipv6_scope0 s$
�z@BaseEventLoopWithSelectorTests.test_create_connection_ipv6_scopec C � | � |d� d S r� �r r@ r r r � test_create_connection_ip_addrI � z=BaseEventLoopWithSelectorTests.test_create_connection_ip_addrc C r
rd r r@ r r r �#test_create_connection_no_inet_ptonM r
zBBaseEventLoopWithSelectorTests.test_create_connection_no_inet_ptonc
C s0 t j|_|j j}t�� | j_d| jj_t�� | j_d| jj_dD ]L\}}| j� t
j d|�}| j� |�\}}z,|j
�d|f� |j j\}} | �| d |j� | �| d |j� W |�� t�| j� q |�� t�| j� w dD ]&}| j� t
j d|�}| �t�� | j� |� W d � n1 s�w Y qod S )NF))�httpr� )s httpr� r� r� r' )Znonsenses nonsense)r r$ r# r rK rJ r� r% r r� r
r� ra r r r� r2 r r r\ r" r� rR r� )
r6 r& r� Zservicer r. r� r r ru r r r �#test_create_connection_service_nameQ s:
� �
� ���zBBaseEventLoopWithSelectorTests.test_create_connection_service_namec sL dd� � � �fdd�}|�j _�j jtddtjdd�}��t�j j|� d S ) Nc � s �| dkr ddgS g S )Nr� r� r )r rt r� r r r r$ q s ��zXBaseEventLoopWithSelectorTests.test_create_connection_no_local_addr.<locals>.getaddrinfoc r� r r� r� r� r r r� x r� z]BaseEventLoopWithSelectorTests.test_create_connection_no_local_addr.<locals>.getaddrinfo_taskr� r� r� r� ) rJ r$ r� r� r r rR r� ra r� r r� r �$test_create_connection_no_local_addrp s
�
�zCBaseEventLoopWithSelectorTests.test_create_connection_no_local_addrc s> d� � �fdd�}||_ |�� }�j�|� �}�j�|� d S )N)z00:01:02:03:04:05r0 c s$ �� | |f� � dddd� dffgS )Ni� r0 r- )r2 )r r rt r� �r� r6 r r r$ � s zTBaseEventLoopWithSelectorTests.test_create_connection_bluetooth.<locals>.getaddrinfo)r$ r rJ r� ra )r6 r& r$ r� r. r r r � test_create_connection_bluetooth� s z?BaseEventLoopWithSelectorTests.test_create_connection_bluetoothc s� t �� �j_�fdd�}|�jj_t �� �j_�j�� �jj_�jjj�d � t �� �j_ G dd� d�� � fdd�}|�jj _t j
}t � }�jj � � �jj
tddd |d
�}�j�|�\}}|�� �jj j||||d d|d � �jj � � �jj
tddd d
|d�}�j�|�\}}|�� �jj j||||d d
|d � �jj � � �jj
tddd d|d�}�j�|�\}}|�� �jj j||||d d|d � d S )Nc s* � j �� }|�tjtjtjddfg� |S )Nr- r� )rJ r^ r� r r r �SOL_TCP)rt r� r* rO r r �mock_getaddrinfo� s
�zkBaseEventLoopWithSelectorTests.test_create_connection_ssl_server_hostname_default.<locals>.mock_getaddrinfoc @ s e Zd ZdZdd� Zdd� ZdS )zqBaseEventLoopWithSelectorTests.test_create_connection_ssl_server_hostname_default.<locals>._SelectorTransportMockNc S s t �� S r )r rK )r6 �keyr r r �get_extra_info� r z�BaseEventLoopWithSelectorTests.test_create_connection_ssl_server_hostname_default.<locals>._SelectorTransportMock.get_extra_infoc S s | j �� d S r )�_sockr\ rO r r r r\ � r zwBaseEventLoopWithSelectorTests.test_create_connection_ssl_server_hostname_default.<locals>._SelectorTransportMock.close)rB rC rD r r r\ r r r r �_SelectorTransportMock� s r c s |� d � � � }| |_|S r )r� r )r� �protocolZ
sslcontext�waiterr� r� )r r r �mock_make_ssl_transport� s
zrBaseEventLoopWithSelectorTests.test_create_connection_ssl_server_hostname_default.<locals>.mock_make_ssl_transport�
python.orgr� T)�sslr� F)Z server_side�server_hostnamer� zperl.com)r r r� r- )r rK rJ r$ r� r� r^ r# r� rT �ANYre r r� r� ra r\ r )r6 r r r Zhandshake_timeoutr. r� r r )r r6 r �2test_create_connection_ssl_server_hostname_default� sj
�� �� �
�zQBaseEventLoopWithSelectorTests.test_create_connection_ssl_server_hostname_defaultc C sP | j jtdddd�}| �t| j j|� | j jtdddd�}| �t| j j|� d S )Nr r� r- )r r� rC r r r �4test_create_connection_no_ssl_server_hostname_errors� s � �zSBaseEventLoopWithSelectorTests.test_create_connection_no_ssl_server_hostname_errorsc C s� | j jtdddd�}| �t| j j|� | j jtd ddd�}| �t| j j|� t�� }| j jtd d d|d�}| �|j� | �t| j j|� d S )Nr- r� T)r )r r� ) rJ r� r� rR r� ra r r� r\ )r6 r. r� r r r �1test_create_connection_ssl_server_hostname_errors� s � zPBaseEventLoopWithSelectorTests.test_create_connection_ssl_server_hostname_errorsc C r� r� )rJ r� r� r� r� ra rC r r r �3test_create_connection_ssl_timeout_for_plain_socket� r� zRBaseEventLoopWithSelectorTests.test_create_connection_ssl_timeout_for_plain_socketc sX t � ��fdd�� � �fdd�}|�j_�j�tdd�}��t�jj|� ���� d S )Nc � s �| d � g S rl r r� )r r r r$ � s �zQBaseEventLoopWithSelectorTests.test_create_server_empty_host.<locals>.getaddrinfoc r� r r� r� r� r r r� r� zVBaseEventLoopWithSelectorTests.test_create_server_empty_host.<locals>.getaddrinfo_taskr- r ) re rJ r$ r� r� rR r� ra r4 )r6 r� r� r )r$ r r6 r � test_create_server_empty_host� s z<BaseEventLoopWithSelectorTests.test_create_server_empty_hostc C r� )N�0.0.0.0r r� )rJ r� r� re rR r� ra �r6 r� r r r �!test_create_server_host_port_sock r� z@BaseEventLoopWithSelectorTests.test_create_server_host_port_sockc C r� r )rJ r� r� rR r� ra r' r r r �$test_create_server_no_host_port_sock
r� zCBaseEventLoopWithSelectorTests.test_create_server_no_host_port_sockc C sN t �� }| j_| j�� |_|j�d � | j�tdd�}| � t
| jj |� d S )Nr r ) r rK rJ r$ r^ r# r� r� r� rR r� ra )r6 r$ r* r r r �!test_create_server_no_getaddrinfo s
z@BaseEventLoopWithSelectorTests.test_create_server_no_getaddrinfoc C sB t j|_|`t�� |j _| jjtdddd�}| � t
| jj |� d S )Nr& r T��
reuse_port) r r$ � SO_REUSEPORTr rK r# rJ r� r� rR r� ra �r6 r& r* r r r � test_create_server_nosoreuseport s �z?BaseEventLoopWithSelectorTests.test_create_server_nosoreuseportc C sD t j|_t�� |j _d|_| jjtdddd�}| � t
| jj |� d S )Nr� r& r Tr+ ) r r$ r rK r# r- rJ r� r� rR r� ra r. r r r �+test_create_server_soreuseport_only_defined$ s �zJBaseEventLoopWithSelectorTests.test_create_server_soreuseport_only_definedc C sn G dd� dt �}dg|j_d|j_t�� }|j_||j_| j �
t dd�}| � t | j j
|� | �|jj� d S )Nc @ s e Zd ZdZdS )zHBaseEventLoopWithSelectorTests.test_create_server_cant_bind.<locals>.Errr� N)rB rC rD r� r r r r r� 2 s r� )r� r0 r� r- )r� it' Fr& r )r� r$ r# r% r rK r r� r� rJ r� r� rR ra r] r\ r� �r6 r& r� Zm_sockr� r r r � test_create_server_cant_bind/ s �z;BaseEventLoopWithSelectorTests.test_create_server_cant_bindc C s6 g |j _d|j _| jjtdd�}| �t| jj|� d S )NF)� localhostr �r� ) r$ r# r% rJ r� r� rR r� ra �r6 r& r. r r r �)test_create_datagram_endpoint_no_addrinfo? s �
�zHBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_no_addrinfoc C sH | j jtdd�}| �t| j j|� | j jtdd�}| �t| j j|� d S )Nr3 r4 )r3 r0 r� r
)rJ r� r� rR r� ra rC r r r �(test_create_datagram_endpoint_addr_errorI s �
��
�zGBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_addr_errorc C s> t �� | j_t| jj_| jjtjdd�}| � t| jj
|� d S )N�r� r )� remote_addr) r rK rJ r� r� r� r� r
�DatagramProtocolrR ra rC r r r �)test_create_datagram_endpoint_connect_errS s
�
�zHBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_connect_errc s� t d| jd�� t�� | j_}g |_| jj� fdd�ddd�}| j�|�\}}| �|j � |�
� | j�� j � | � d� j
� d S )NT�r^ rJ c � � S r r r �r r r re b rf z^BaseEventLoopWithSelectorTests.test_create_datagram_endpoint_allow_broadcast.<locals>.<lambda>r8 )r9 �allow_broadcastr� )r� rJ r rK r� r# r� ra r[ r� r\ r� r2 r� )r6 r� r. r� r r r> r �-test_create_datagram_endpoint_allow_broadcast\ s
� zLBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_allow_broadcastc C s^ t j|_t|j _| jjtjt jd�}| � t| jj
|� | jjtjdd�}| � t| jj
|� d S )Nr� r8 r4 ) r r$ r� r� rJ r� r
r: r rR ra r5 r r r �(test_create_datagram_endpoint_socket_errm s �
��
�zGBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_socket_errz IPv6 not supported or enabledc C s* | j jtjddd�}| �t| j j|� d S )Nr8 )r� r )r9 r� �rJ r� r
r: rR r� ra rC r r r �0test_create_datagram_endpoint_no_matching_family| s �
�zOBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_no_matching_familyc C sH t |jjj_| jjtjtj d�}| �
t | jj |� | � |jjj
j� d S )Nr� )r� r r# � setblockingr� rJ r� r
r: r rR ra r] r\ r� r5 r r r �(test_create_datagram_endpoint_setblk_err� s �
�
�zGBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_setblk_errc C s$ | j �tj�}| �t| j j|� d S r rB rC r r r �-test_create_datagram_endpoint_noaddr_nofamily� s �zLBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_noaddr_nofamilyc C sh G dd� dt �}tj|_t�� }|j_||j_| jj t
dtj d�}| � || jj
|� | �|jj� d S )Nc @ r� )zSBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_cant_bind.<locals>.ErrNr� r r r r r� � r� r� r8 )r� r� )r� r r$ r rK r# r� r� rJ r� r� r rR ra r] r\ r� r1 r r r �'test_create_datagram_endpoint_cant_bind� s �zFBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_cant_bindc sj t � t jt j�}|�d� � jj� fdd�|d�}� j�|�\}}|�� � j�|j� � � d|j
� d S )Nr8 c � t d� jd�S �NTr< �r� rJ r rO r r re � � zSBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_sock.<locals>.<lambda>r� r� ) r r r r� rJ r� ra r\ r� r2 r� )r6 r� r� r� r r rO r �"test_create_datagram_endpoint_sock� s
�zABaseEventLoopWithSelectorTests.test_create_datagram_endpoint_sock�AF_UNIXzNo UNIX Socketsc sd � j j� fdd�tjd�}� j �|�\}}� �|jjtj� |�� � j �|j � � �d|j
� d S )Nc rH rI rJ r rO r r re � rK zXBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_sock_unix.<locals>.<lambda>r� r� ) rJ r� r rM ra r2 r r� r\ r� r� )r6 r� r� r r rO r �'test_create_datagram_endpoint_sock_unix� s
�zFBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_sock_unixc s� t �� �<}tjtjtjd�}|�|� |�� � jj� fdd�|tjd�}� j� |�\}}|�� � j� |j
� W d � d S 1 sCw Y d S )N)r' c rH rI rJ r rO r r re � rK zaBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_existing_sock_unix.<locals>.<lambda>r� ) r" Zunix_socket_pathr rM r r� r\ rJ r� ra r� )r6 �pathr� r. r� r r rO r �0test_create_datagram_endpoint_existing_sock_unix� s
�"�zOBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_existing_sock_unixc C s G dd� d�}| j jtd|� d�}| �t| j j|� | j jtd|� d�}| �t| j j|� | j jtd|� d�}| �t| j j|� | j jtd|� d�}| �t| j j|� | j jtd|� d �}| �t| j j|� | j jtd
|� d �}| �t| j j|� | j jtd
|� d �}| �t| j j|� d S )
Nc @ s e Zd ZejZdS )z\BaseEventLoopWithSelectorTests.test_create_datagram_endpoint_sock_sockopts.<locals>.FakeSockN)rB rC rD r r r' r r r r �FakeSock� s
rQ r8 )r� r� )r9 r� r0 )r� r� )�protor� )�flagsr� T)r, r� )r? r� )rJ r� r� rR r� ra )r6 rQ r� r r r �+test_create_datagram_endpoint_sock_sockopts� s: �������zJBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_sock_sockopts�vxworksz-SO_BROADCAST is enabled by default on VxWorksc s4 � j j� fdd�dd�}� j �|�\}}|�d�}ttd�}|r+� �|�tjtj �� � �|�tjtj
�� |� � � j �|j � � �
d|j� � j j� fdd�d|d d
�}� j �|�\}}|�d�}� �|�tjtj�� |r{� �|�tjtj �� � �|�tjtj
�� |� � � j �|j � � �
d|j� d S ) Nc rH rI rJ r rO r r re � rK zWBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_sockopts.<locals>.<lambda>r8 r4 r r- r� c rH rI rJ r rO r r re rK T)r� r, r? )rJ r� ra r r r r[ �
getsockoptr r- � SO_BROADCASTr\ r� r2 r� r r] )r6 r. r� r r� �reuseport_supportedr rO r �&test_create_datagram_endpoint_sockopts� s`
�
����
�
������zEBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_sockoptsc sV � j j� fdd�ddd�}� �t�� � j �|� W d � d S 1 s$w Y d S )Nc rH rI rJ r rO r r re rK zbBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_reuse_address_error.<locals>.<lambda>r8 T�r� Z
reuse_address)rJ r� rR r� ra rC r rO r �1test_create_datagram_endpoint_reuse_address_error s
� "�zPBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_reuse_address_errorc s~ � j j� fdd�ddd�}� �t��# � j �|�\}}|�� � j �|j� � �d|j� W d � d S 1 s8w Y d S )Nc rH rI rJ r rO r r re ( rK zdBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_reuse_address_warning.<locals>.<lambda>r8 FrZ r� ) rJ r� r� r� ra r\ r� r2 r� )r6 r. r� r r rO r �3test_create_datagram_endpoint_reuse_address_warning$ s
� "�zRBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_reuse_address_warningc s@ |` t�� |j_� jj� fdd�ddd�}� �t� jj |� d S )Nc � t � jd�S r0 rJ r rO r r re 8 r3 z\BaseEventLoopWithSelectorTests.test_create_datagram_endpoint_nosoreuseport.<locals>.<lambda>r8 T�r� r, )
r- r rK r r# rJ r� rR r� ra r5 r rO r �+test_create_datagram_endpoint_nosoreuseport2 s
�zJBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_nosoreuseportc s� � fdd�}||_ t�� |jj_}t�� � j_d� jj_t td�}� jj
� fdd�d|d�}� j� |�\}}z |� d� |jj |j
|j|jd � W |�� t�� j� d S |�� t�� j� w )
Nc s � � d� d S )Nz"should not have called getaddrinfo)Zfailr� rO r r r$ @ r zYBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_ip_addr.<locals>.getaddrinfoFr- c r] r0 rJ r rO r r re J r3 zVBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_ip_addr.<locals>.<lambda>r; r^ )r� rR r' )r$ r rK r r# r� rJ r� r% r r� ra r r r r r\ r" r� )r6 r& r$ r� rX r. r� r r rO r �%test_create_datagram_endpoint_ip_addr> s,
�
��zDBaseEventLoopWithSelectorTests.test_create_datagram_endpoint_ip_addrc C s2 t �� }t� |j_| j�t|� | �|j j
� d S r ) r rK �BlockingIOError�acceptr� rJ �_accept_connectionr� r[ r\ r� �r6 r� r r r � test_accept_connection_retryX s
z;BaseEventLoopWithSelectorTests.test_accept_connection_retryr� c
C s� t �� }d|j_ttjd�|j_t �� | j _
t �� | j _ | j � t
|� | �|jj� | �|jj� | j j
�d� | j j �tjt jt
|d d t jt j� d S )N�
zToo many open files)r rK �filenor# r� r� ZEMFILErb r� rJ Z_remove_readerr� rc r� r] r� r� r[ r\ r r ZACCEPT_RETRY_DELAYr )r6 Zm_logr� r r r � test_accept_connection_exception_ s �z?BaseEventLoopWithSelectorTests.test_accept_connection_exceptionc C s� | � t�� tjdd� �}W d � n1 sw Y | j�d� |}|� }| �|j� ||fD ]�}| �t �� | j�
|� W d � n1 sIw Y | �t �� | j� |� W d � n1 sdw Y | �t �� | j� d|� W d � n1 s�w Y | �t �� | j�
| j�� d |� W d � n1 s�w Y | �t �� | j�| j�d |�� W d � n1 s�w Y q1d S )Nc S r� r r r r r r �simple_coroutines s zLBaseEventLoopWithSelectorTests.test_call_coroutine.<locals>.simple_coroutineTr� )r� r� r
� coroutinerJ r� r� r\ rR r� r� r� r� r� r� ra r )r6 ri Z coro_funcZcoro_objrZ r r r �test_call_coroutineq s8 � � � � � � ���z2BaseEventLoopWithSelectorTests.test_call_coroutinec C s� dd� }dd� }t �| j� | j�d� d| j_| j�|| j� | j�� |jjd ^}}| � |t
|� d� t j || j�| jd � | j�� |jjd ^}}| � |t
|� d
� d S ) Nc S s | � � d S r �r� r� r r r � stop_loop_cb� r zLBaseEventLoopWithSelectorTests.test_log_slow_callbacks.<locals>.stop_loop_cbc � � �| � � d S r rl r� r r r �stop_loop_coro� � � zNBaseEventLoopWithSelectorTests.test_log_slow_callbacks.<locals>.stop_loop_coroTg r z4^Executing <Handle.*stop_loop_cb.*> took .* seconds$r� z4^Executing <Task.*stop_loop_coro.*> took .* seconds$) r
rN rJ r� Zslow_callback_durationr� r` �warningr� r �tupler )r6 Zm_loggerrm ro �fmtrt r r r �test_log_slow_callbacks� s"
�
�z6BaseEventLoopWithSelectorTests.test_log_slow_callbacks)JrB rC rD rH r r) r� r+ r� r� r� r� r� r� �unittest�
skipUnlessr r r� r r5 r� r� r� r� r� r� r� r ZskipIfr� �platformr� r r r r r r r! r" r# r$ r% r( r) r* r/ r0 r2 r6 r7 r; r@ rA rC rE rF rG rL rN Z skip_unless_bind_unix_socketrP rT rY r[ r\ r_ r` re rh rk rt r� r r rP r r� 2 s�
�
+�
I
�
/
r� c @ rq )�RunningLoopTestsc C s� dd� }t �� }t �� }z3| �td�� |�||�� W d � n1 s%w Y W |�� |�� d S W |�� |�� d S |�� |�� w )Nc � rn r )r` r� r r r �runner� rp z@RunningLoopTests.test_running_loop_within_a_loop.<locals>.runnerz while another loop is running)r
rH r� r_ ra r\ )r6 ry rJ Z
outer_loopr r r � test_running_loop_within_a_loop� s � � � �
z0RunningLoopTests.test_running_loop_within_a_loopN)rB rC rD rz r r r r rx � s rx c 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%� Zd&d'� Z� ZS ))�BaseLoopSockSendfileTestss� 12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcde12345abcdei c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) z!BaseLoopSockSendfileTests.MyProtoc C s( d| _ d| _t� | _|�� | _d | _d S rd )rn �closed� bytearrayr� r^ r� r� )r6 rJ r r r r� � s
z*BaseLoopSockSendfileTests.MyProto.__init__c C s d| _ || _d S r� )rn r� r� r r r r� � s
z1BaseLoopSockSendfileTests.MyProto.connection_madec C s | j �|� d S r )r� �extendr� r r r r� � s z/BaseLoopSockSendfileTests.MyProto.data_receivedc C s d| _ | j�d � d | _d S r� )r| r� r� r� r� r r r r� � s
z1BaseLoopSockSendfileTests.MyProto.connection_lostc � s �| j I d H d S r r� rO r r r r� � s �z-BaseLoopSockSendfileTests.MyProto.wait_closedN)rB rC rD r� r� r� r� r� r r r r r� � s r� c sT t j| _dt _ttjd��}|�| j� W d � n1 s w Y t� � � d S )Ni @ �wb)
r �!SENDFILE_FALLBACK_READBUFFER_SIZE�'_BaseLoopSockSendfileTests__old_bufsize�openr �TESTFNr� �DATArG �
setUpClass)�cls�fprP r r r� � s �z$BaseLoopSockSendfileTests.setUpClassc s" | j t_t�tj� t� �� d S r )r� r r� r �unlinkr� rG �
tearDownClass)r� rP r r r� � s z'BaseLoopSockSendfileTests.tearDownClassc sJ ddl m} |� | _| �| j� ttjd�| _| �| jj � t
� � � d S )Nr )�BaseSelectorEventLoop�rb) Zasyncio.selector_eventsr� rJ rN r� r r� �filer� r\ rG rH )r6 r� rP r r rH � s z BaseLoopSockSendfileTests.setUpFc C s* t � t jt j�}|�|� | �|j� |S r )r r r rD r� r\ )r6 �blockingr� r r r � make_socket� s
z%BaseLoopSockSendfileTests.make_socketc C s | j �|�S r )rJ ra rC r r r r � r z"BaseLoopSockSendfileTests.run_loopc s� �� � ����j�� ���jj� fdd�tjdtjd����j d �
� }t d�D ]!}z ���j� �|�� W n t
yG ��t�d�� Y q(w n
���j� �|�� � ���fdd�}��|� �� fS ) Nc r= r r r )rR r r re � rf z3BaseLoopSockSendfileTests.prepare.<locals>.<lambda>r r� rf g �?c sH �� � ����� � �� � � jd ur"� j� � ��� �� � d S d S r )r\ r r� r� r �rR r6 Zserverr� r r �cleanup s
�z2BaseLoopSockSendfileTests.prepare.<locals>.cleanup)r� r� rJ r r� r ZHOSTr r r� � getsocknamer� r� r� r
r� r� )r6 r� r r� r r� r �prepare� s$
� �
z!BaseLoopSockSendfileTests.preparec C sx | � � \}}| �tjd�� | �| j�|| jdd �� W d � n1 s%w Y | �|j d� | �| j�
� d� d S )N�sendfile is not availabler r< ) r� r� r
�SendfileNotAvailableErrorr rJ Z_sock_sendfile_nativer� r2 r� �tell�r6 r� rR r r r �"test__sock_sendfile_native_failure s �� �z<BaseLoopSockSendfileTests.test__sock_sendfile_native_failurec C sx | � � \}}| �tjd�� | �| jj|| jdd�� W d � n1 s%w Y | �| j� � d� | �|j
d� d S )Nr� F)�fallbackr r< ) r� r� r
r� r rJ �
sock_sendfiler� r2 r� r� r� r r r � test_sock_sendfile_no_fallback s �
� �z8BaseLoopSockSendfileTests.test_sock_sendfile_no_fallbackc C sv | � � \}}| �| j�|| j��}|�� | �|�� � | �|t| j �� | �| j�
� t| j �� | �|j | j � d S r ) r� r rJ r� r� r\ r� r2 r� r� r� r� �r6 r� rR �retr r r �test_sock_sendfile_fallback' s z5BaseLoopSockSendfileTests.test_sock_sendfile_fallbackc C sv | � � \}}| �| j�|| jdd��}|�� | �|�� � | �|d� | �| j�� d� | �|j | j
dd� � d S )Ni� i� r� ) r� r rJ r� r� r\ r� r2 r� r� r� r� r r r �,test_sock_sendfile_fallback_offset_and_count2 s � zFBaseLoopSockSendfileTests.test_sock_sendfile_fallback_offset_and_countc C s` | j �d� | jdd�}| �td�� | �| j �|| j�� W d � d S 1 s)w Y d S )NT)r� zmust be non-blocking)rJ r� r� r� r� r r� r� rd r r r �test_blocking_socket> s
"�z.BaseLoopSockSendfileTests.test_blocking_socketc C s� | � � }ttjdd��1}| �td�� | �| j�||�� W d � n1 s'w Y W d � d S W d � d S 1 s?w Y d S )Nzutf-8)�encodingz binary mode) r� r� r r� r� r� r rJ r� )r6 r� r* r r r �test_nonbinary_fileD s ��"�z-BaseLoopSockSendfileTests.test_nonbinary_filec C sn t � t jt j�}|�d� | �|j� | �td�� | �| j �
|| j �� W d � d S 1 s0w Y d S )NFzonly SOCK_STREAM type) r r r rD r� r\ r� r� r rJ r� r� rd r r r �test_nonstream_socketJ s
"�z/BaseLoopSockSendfileTests.test_nonstream_socketc C �T | � � }| �td�� | �| j�|| jdd�� W d � d S 1 s#w Y d S )N� count must be a positive integerr ri �r� r� r� r rJ r� r� rd r r r �test_notint_countQ � � "�z+BaseLoopSockSendfileTests.test_notint_countc C r� )Nr� r r� �r� r� r� r rJ r� r� rd r r r �test_negative_countW r� z-BaseLoopSockSendfileTests.test_negative_countc C �R | � � }| �td�� | �| j�|| jd�� W d � d S 1 s"w Y d S )N�%offset must be a non-negative integer�offsetr� rd r r r �test_notint_offset] � �"�z,BaseLoopSockSendfileTests.test_notint_offsetc C r� )Nr� r� r� rd r r r �test_negative_offsetc r� z.BaseLoopSockSendfileTests.test_negative_offsetr� )rB rC rD r� r
r� r� � classmethodr� r� rH r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r r rP r r{ � s,
r{ c @ s. e Zd Zdd� Ze�eed�d�dd� �ZdS )�TestSelectorUtilsc C sB |� tjtj�}| �|� t�|� |� tjtj�}| �|� d S r )rV r r � TCP_NODELAYr[ r Z _set_nodelayr] )r6 r� �optr r r �check_set_nodelayk s
z#TestSelectorUtils.check_set_nodelayr� zneed socket.TCP_NODELAYc C s� t j t jt jt jd�}|�
| �|� W d � n1 s w Y t j t jt jt jd�}|� |�d� | �|� W d � d S 1 sEw Y d S )N)r� r' rR F)r r r r r� rD rd r r r �test_set_nodelayt s � � �
"�z"TestSelectorUtils.test_set_nodelayN) rB rC rD r� ru rv r r r� r r r r r� j s �r� �__main__)-�__doc__�concurrent.futuresrx r� r� r r� r� r� ru r r
r r Ztest.test_asyncior r" rB r Ztest.support.script_helperr Z test.supportr r rI r r � version_infor
r r( r+ ZTestCaser, rE r� r� r: r� r� rx r{ r� rB r� r r r r �<module> s`
a _" y 5 �