File: //usr/local/lib/python3.7/test/test_asyncio/__pycache__/test_server.cpython-37.opt-2.pyc
B
��g( � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dlm
Z G dd� de j �Z
G dd� de
ej�Ze�ee d �d
�G d d � d e
ej��Zed
kr�e�� dS )� N)�support)�utils)�
functionalc @ s e Zd Zdd� Zdd� ZdS )�BaseStartServerc C s t �d S )N)�NotImplementedError)�self� r �9/usr/local/lib/python3.7/test/test_asyncio/test_server.py�new_loop s zBaseStartServer.new_loopc
s dd d � � �fdd���fdd�}dd � }| j �tj|tjd
| j d d ���| ���� � | j �|�����j d
�
� �| � tj ��2 | �
��fd
d��� | j ��� W d Q R X W d Q R X | ��j g � | ��j� | ��j� | ���� � | �td�� | j ���� � W d Q R X d S )Ns 1111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111� �
c s^ x(t d�D ]}t�d� ��� r
P q
W t�| �d� | �|� | �� � | �d� | � � d S )N�
g�������?� � )
�range�timeZsleep�
is_serving� RuntimeError�
settimeout�connect�send�recv_all�close)�sock�addr�i)� HELLO_MSG�srvr r �client s
z3BaseStartServer.test_start_server_1.<locals>.clientc � s: | � � I d H � �� |�d� |�� |�� I d H d S )N� 1)�readline�cancel�writer � wait_closed)�reader�writer)� main_taskr r �serve" s
z2BaseStartServer.test_start_server_1.<locals>.servec
� s0 | 4 I d H � | � � I d H W d Q I d H R X d S )N)�
serve_forever)r r r r �main) s z1BaseStartServer.test_start_server_1.<locals>.mainr F)�loop�
start_servingc s
�| � �S )Nr )r )r r r r �<lambda>6 � z5BaseStartServer.test_start_server_1.<locals>.<lambda>z is closed)r* �run_until_complete�asyncioZ start_serverr ZHOSTv4� assertFalser � create_task�socketsZ getsockname� assertRaises�CancelledErrorZ
tcp_client� assertEqual� assertIsNone�_sockets�_waiters�assertRaisesRegexr r( )r r' r) r )r r r r& r r �test_start_server_1 s$
z#BaseStartServer.test_start_server_1N)�__name__�
__module__� __qualname__r
r: r r r r r s r c @ s. e Zd Zdd� Ze�eed�d�dd� �ZdS )�SelectorStartServerTestsc C s t �� S )N)r/ ZSelectorEventLoop)r r r r r
E s z!SelectorStartServerTests.new_loopZAF_UNIXzno Unix socketsc s dd d � t �� �� �fdd���fdd�}��fdd �}t�� �҉�j�tj|��jd
d ��}�j�||����� tj
��2 �� ��fd d
��� �j��� W d Q R X W d Q R X �� |j
g � ��|j� ��|j� ��|�� � ��td�� �j�|�� � W d Q R X W d Q R X d S )Ns 1111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111r r c s> | � d� ��d� | �|� | �� � | �d� | �� d S )Nr r r )r �waitr r r r )r r )r �startedr r r M s
zASelectorStartServerTests.test_start_unix_server_1.<locals>.clientc � s: | � � I d H � �� |�d� |�� |�� I d H d S )Nr )r r! r" r r# )r$ r% )r& r r r' U s
z@SelectorStartServerTests.test_start_unix_server_1.<locals>.servec
� sb | 4 I d H �F � � | �� � | �� I d H � �| �� � ��� | �� I d H W d Q I d H R X d S )N)r0 r r+ Z
assertTrue�setr( )r )r r@ r r r) \ s z?SelectorStartServerTests.test_start_unix_server_1.<locals>.mainF)r* r+ c s
�| � �S )Nr )r )r r r r r, k r- zCSelectorStartServerTests.test_start_unix_server_1.<locals>.<lambda>z is closed)� threadingZEvent�
test_utilsZunix_socket_pathr* r. r/ Zstart_unix_serverr1 r3 r4 Z unix_clientr5 r2 r6 r7 r8 r0 r r9 r r( )r r' r) r r )r r r r& r r@ r �test_start_unix_server_1H s$
z1SelectorStartServerTests.test_start_unix_server_1N) r; r< r= r
�unittest�
skipUnless�hasattr�socketrD r r r r r> C s r> �ProactorEventLoopz Windows onlyc @ s e Zd Zdd� ZdS )�ProactorStartServerTestsc C s t �� S )N)r/ rI )r r r r r
{ s z!ProactorStartServerTests.new_loopN)r; r< r= r
r r r r rJ x s rJ �__main__)r/ rH r rB rE Ztestr Ztest.test_asyncior rC r Z
func_testsZFunctionalTestCaseMixinr ZTestCaser> rF rG rJ r; r) r r r r �<module> s 75