File: //usr/local/lib/python3.10/test/test_asyncio/__pycache__/test_server.cpython-310.opt-1.pyc
o
�i6 � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z
dd� Z G dd� de
j �Z
G d d
� d
e
ej�Ze�ee d �d �G d
d� de
ej��ZedkrVe�� dS dS )� N)�
socket_helper)�utils)�
functionalc C s t �d � d S �N)�asyncioZset_event_loop_policy� r r �:/usr/local/lib/python3.10/test/test_asyncio/test_server.py�tearDownModule s r c @ s e Zd Zdd� Zdd� ZdS )�BaseStartServerc C s t �r )�NotImplementedError��selfr r r �new_loop s zBaseStartServer.new_loopc sX dd d � � �fdd���fdd�}dd � }| j �tj|tjd
d d ���| ���� � | j �|�����j d
�
� �| � tj ��( | �
��fd
d��� | j ��� W d � n1 s]w Y W d � n1 slw Y | ��j d� | ��j� | ��j� | ���� � | �td�� | j ���� � W d � d S 1 s�w Y d S )N� 1111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111� �
c s\ t d�D ]
}t�d� ��� r nqt�| �d� | �|� | �� � | �d� | � � d S )N�
g�������?� � )
�range�time�sleep�
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 � �< �| � � I d H � �� |�d� |�� |�� I d H d S �N� 1��readline�cancel�writer Z wait_closed��reader�writer�� main_taskr r �serve% � �
z2BaseStartServer.test_start_server_1.<locals>.servec � sN �| 4 I d H � | � � I d H W d �I d H d S 1 I d H s w Y d S r )�
serve_forever�r# r r r �main, s �.�z1BaseStartServer.test_start_server_1.<locals>.mainr F��
start_servingc �
�| � �S r r �r �r r$ r r �<lambda>9 �
z5BaseStartServer.test_start_server_1.<locals>.<lambda>r � is closed)�loop�run_until_completer Z start_serverr ZHOSTv4� assertFalser � create_task�sockets� getsockname� assertRaises�CancelledErrorZ
tcp_client� assertEqual� assertIsNone�_sockets�_waiters�assertRaisesRegexr r3 )r
r1 r5 r )r" r r$ r0 r# r �test_start_server_1 s.
� �� � "�z#BaseStartServer.test_start_server_1N)�__name__�
__module__� __qualname__r rK r r r r r
s r
c @ s" e Zd Zdd� Zejdd� �ZdS )�SelectorStartServerTestsc C � t �� S r )r ZSelectorEventLoopr r r r r H � z!SelectorStartServerTests.new_loopc
s~ dd d � t �� �� �fdd���fdd�}��fdd �}t�� ����j�tj|�d
d ��}�j�||����� tj
��( �� ��fd d
��� �j��� W d � n1 sYw Y W d � n1 shw Y �� |j
d� ��|j� ��|j� ��|�� � ��td�� �j�|�� � W d � n1 s�w Y W d � d S W d � d S 1 s�w Y d S )Nr r r c s> | � d� ��d� | �|� | �� � | �d� | �� d S )Nr r r )r �waitr r r r )r r )r" �startedr r r$ P s
zASelectorStartServerTests.test_start_unix_server_1.<locals>.clientc � r% r& r( r, r/ r r r1 X r2 z@SelectorStartServerTests.test_start_unix_server_1.<locals>.servec � s� �| 4 I d H �, � � | �� � | �� I d H � �| �� � ��� | �� I d H W d �I d H d S 1 I d H s9w Y d S r )r@ r r7 Z
assertTrue�setr3 r4 )r
rS r r r5 _ s �.�z?SelectorStartServerTests.test_start_unix_server_1.<locals>.mainFr6 c r8 r r r9 r: r r r; n r< zCSelectorStartServerTests.test_start_unix_server_1.<locals>.<lambda>r r= )� threading�Event�
test_utilsZunix_socket_pathr> r? r Zstart_unix_serverrA rD rE Z unix_clientrF rB rG rH rI r@ r rJ r r3 )r
r1 r5 r# r )r" r r$ r0 r
rS r �test_start_unix_server_1K s4
� �� � ��"�z1SelectorStartServerTests.test_start_unix_server_1N)rL rM rN r r Z skip_unless_bind_unix_socketrX r r r r rO F s rO �ProactorEventLoopz Windows onlyc @ s e Zd Zdd� ZdS )�ProactorStartServerTestsc C rP r )r rY r r r r r ~ rQ z!ProactorStartServerTests.new_loopN)rL rM rN r r r r r rZ { s rZ �__main__)r r rU ZunittestZ test.supportr Ztest.test_asyncior rW r Z
func_testsr ZFunctionalTestCaseMixinr
ZTestCaserO Z
skipUnless�hasattrrZ rL r5 r r r r �<module> s 75 �