File: //usr/local/lib/python3.7/test/__pycache__/test_asyncore.cpython-37.pyc
B
��g?g � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
m Z d dl m
Z
e jrxe�d��dZeed�ZG dd� d�ZG d d
� d
�ZG d d � d �ZG d
d� d�Zdd� Zdd� ZG dd� dej�ZG dd� dej�ZG dd� de j �Z G dd� dej�Z e� ee d�d �G d d � d ej��Z G d d � d e j!�Z"G d!d"� d"e j!�Z#G d#d$� d$e"�Z$G d%d&� d&�Z%G d'd(� d(e%�Z&e� e j'd)�G d*d+� d+e%��Z(e� ed,�G d-d.� d.e%��Z)G d/d0� d0e&ej�Z*e� eed1�d2�G d3d4� d4e&ej��Z+G d5d6� d6e(ej�Z,e� eed1�d2�G d7d8� d8e(ej��Z-G d9d:� d:e)ej�Z.e� eed1�d2�G d;d<� d<e)ej��Z/e0d=k�r�e�1� dS )>� N)�support)�BytesIOztest is not helpful for PGO� �AF_UNIXc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� dummysocketc C s
d| _ d S )NF)�closed)�self� r �./usr/local/lib/python3.7/test/test_asyncore.py�__init__ s zdummysocket.__init__c C s
d| _ d S )NT)r )r r r r
�close s zdummysocket.closec C s dS )N�* r )r r r r
�fileno s zdummysocket.filenoN)�__name__�
__module__� __qualname__r r r r r r r
r s r c @ s e Zd Zdd� Zdd� ZdS )� dummychannelc C s t � | _d S )N)r �socket)r r r r
r ! s zdummychannel.__init__c C s | j �� d S )N)r r )r r r r
r $ s zdummychannel.closeN)r r r r r r r r r
r s r c @ s( e Zd Zdd� Zdd� ZeZeZeZdS )� exitingdummyc C s d S )Nr )r r r r
r ( s zexitingdummy.__init__c C s t �� �d S )N)�asyncore�ExitNow)r r r r
�handle_read_event+ s z exitingdummy.handle_read_eventN)r r r r r �handle_write_event� handle_close�handle_expt_eventr r r r
r ' s
r c @ s0 e Zd Zdd� Zdd� ZeZeZeZdd� ZdS )�
crashingdummyc C s
d| _ d S )NF)�
error_handled)r r r r
r 3 s zcrashingdummy.__init__c C s
t � �d S )N)� Exception)r r r r
r 6 s z crashingdummy.handle_read_eventc C s
d| _ d S )NT)r )r r r r
� handle_error= s zcrashingdummy.handle_errorN) r r r r r r r r r r r r r
r 2 s r c C s� z�y|� � |�� \}}W n tjk
r0 Y n�X d}t�� }xp|dkr�t�� | dk r�t�|gg g d�\}}} |r�|d8 }|�d�}
|�|
� dd�� d|
kr�P t�
d � q@W |� � W d |� � | � � X d S )
N�� r g @g�������?� �
�
� g{�G�z�?)
�listenZacceptr �timeout�timeZ monotonic�select�recv�write�replace�sleepr �set) �evt�bufZserv�conn�addr�n�start�r�w�e�datar r r
�capture_serverA s&
r7 c C s6 t r(| jtjkr(t�|� t�| |� n
| �|� dS )z9Helper function to bind a socket according to its family.N)�HAS_UNIX_SOCKETS�familyr r r �unlinkZbind_unix_socket�bind)�sockr0 r r r
�
bind_af_awareZ s
r= c @ sN e Zd Zdd� Ze�eed�d�dd� �Zdd� Z d d
� Z
d d � Z d
d� Z dS )�HelperFunctionTestsc C s� t � }| �tjtj|� | �tjtj|� | �tjtj|� t� }t�|� | �|j d� t� }t�|� | �|j d� t� }t�|� | �|j d� d S )NT)
r � assertRaisesr r �readr) Z
_exceptionr � assertEqualr )r �tr1�tr2r r r
�test_readwriteexce s
z%HelperFunctionTests.test_readwriteexc�pollzselect.poll requiredc
C s� d}t jdft jdft jdft jdft jdft jdff}G dd� d�}x�|D ]�\}}|� }| �t||�d� t �
||� x"|D ]}| �t||�||k� q~W t � }| � t j
t j
||� t� } | �| jd� t �
| |� | �| jd � qLW d S )
N)r@ �exptr) r r r@ rF r) r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )z3HelperFunctionTests.test_readwrite.<locals>.testobjc S s" d| _ d| _d| _d| _d| _d S )NF)r@ r) r rF r )r r r r
r � s
z<HelperFunctionTests.test_readwrite.<locals>.testobj.__init__c S s
d| _ d S )NT)r@ )r r r r
r � s zEHelperFunctionTests.test_readwrite.<locals>.testobj.handle_read_eventc S s
d| _ d S )NT)r) )r r r r
r � s zFHelperFunctionTests.test_readwrite.<locals>.testobj.handle_write_eventc S s
d| _ d S )NT)r )r r r r
r � s z@HelperFunctionTests.test_readwrite.<locals>.testobj.handle_closec S s
d| _ d S )NT)rF )r r r r
r � s zEHelperFunctionTests.test_readwrite.<locals>.testobj.handle_expt_eventc S s
d| _ d S )NT)r )r r r r
r � s z@HelperFunctionTests.test_readwrite.<locals>.testobj.handle_errorN) r r r r r r r r r r r r r
�testobj� s rG FT)r' ZPOLLINZPOLLPRIZPOLLOUTZPOLLERRZPOLLHUPZPOLLNVALrA �getattrr Z readwriter r? r r r )
r Z
attributes�expectedrG �flagZ expectedattrZtobj�attrrB rC r r r
�test_readwrite� s(
z"HelperFunctionTests.test_readwritec C s | � d� d S )NF)�closeall_check)r r r r
�
test_closeall� s z!HelperFunctionTests.test_closeallc C s | � d� d S )NT)rM )r r r r
�test_closeall_default� s z)HelperFunctionTests.test_closeall_defaultc C s� g }i }x8t d�D ],}t� }|�|� | �|jjd� |||< qW |rrtj}z|t_t�� W d tj| }t_X n
t�|� | �t |�d� x |D ]}| �|jjd� q�W d S )Nr! Fr T)
�ranger �appendrA r r r �
socket_map� close_all�len)r Z
usedefault�lZtestmap�i�cZ socketmapr r r
rM � s"
z"HelperFunctionTests.closeall_checkc C s� y t d��W n" t�� \}}}t�� }Y n X | �d� |\\}}}}} }
| �tj� |�d d� | �|d� | �||� | �| |� | �|
d|||f � d S )NzI don't like spam!zExpected exception���ztest_asyncore.py�test_compact_tracebackz
[%s|%s|%s])
r �sys�exc_infor Zcompact_traceback�failrA �os�path�split) r Zreal_tZreal_vZreal_tbr3 �fZfunction�line�t�v�infor r r
rY � s
z*HelperFunctionTests.test_compact_tracebackN)
r r r rD �unittest�
skipUnless�hasattrr' rL rN rO rM rY r r r r
r> d s <r> c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )�DispatcherTestsc C s d S )Nr )r r r r
�setUp� s zDispatcherTests.setUpc C s t �� d S )N)r rS )r r r r
�tearDown� s zDispatcherTests.tearDownc C s, t �� }| �|�� d� | �|�� d� d S )NT)r �
dispatcherrA �readable�writable)r �dr r r
�
test_basic� s zDispatcherTests.test_basicc C s$ t �� }| �t|�dt|� � d S )Nz <asyncore.dispatcher at %#x>)r rk rA �repr�id)r rn r r r
� test_repr� s zDispatcherTests.test_reprc C s` t �� }d}d}t�� �}|�|� |�|� W d Q R X |�� �� }| �|d| d| g� d S )Nz Lovely spam! Wonderful spam!zI don't like spam!zlog: %s)r rk r Zcaptured_stderr�log�getvalue�
splitlinesrA )r rn �l1�l2�stderr�linesr r r
�test_log� s
zDispatcherTests.test_logc C s| t �� }d}d}d}t�� �(}|�|d� |�|� |�|d� W d Q R X |�� �� }d| d| d| g}| �||� d S ) Nz#Have you got anything without spam?z.Why can't she have egg bacon spam and sausage?zTHAT'S got spam in it!ZEGGSZSPAMzEGGS: %szinfo: %szSPAM: %s)r rk r �captured_stdoutZlog_infort ru rA )r rn rv rw �l3�stdoutry rI r r r
�
test_log_info s
z DispatcherTests.test_log_infoc C sj t �� }d|_t�� �&}|�� |�� |�� |�� W d Q R X |� � �
� }ddddg}| � ||� d S )Nr z*warning: unhandled incoming priority eventz warning: unhandled read eventz warning: unhandled write eventz warning: unhandled connect event) r rk Zignore_log_typesr r{ � handle_expt� handle_read� handle_write�handle_connectrt ru rA )r rn r} ry rI r r r
�test_unhandled s
z DispatcherTests.test_unhandledc C sF t �tj�}ttd�r*| �|t�tj�� t �d�}| �|dk� d S )N�strerrorrX � ) r Z _strerror�errnoZEPERMrg r] rA r� �
assertTrue)r �errr r r
�
test_strerror. s
z DispatcherTests.test_strerrorN) r r r ri rj ro rr rz r~ r� r� r r r r
rh � s
rh c @ s e Zd Zdd� Zdd� ZdS )�dispatcherwithsend_noreadc C s dS )NFr )r r r r
rl 8 s z"dispatcherwithsend_noread.readablec C s d S )Nr )r r r r
r� ; s z(dispatcherwithsend_noread.handle_connectN)r r r rl r� r r r r
r� 7 s r� c @ s* e Zd Zdd� Zdd� Zejdd� �ZdS )�DispatcherWithSendTestsc C s d S )Nr )r r r r
ri @ s z DispatcherWithSendTests.setUpc C s t �� d S )N)r rS )r r r r
rj C s z DispatcherWithSendTests.tearDownc
C s� t �� }t�� }|�d� t�|�}t� }|||f}t jt|d�}|� � z�t
� d� d}t � }|�
� |�tj|f� t
� d� |�|� |�|� |�d� d} x"|jr�| dkr�t�� | d 8 } q�W |�� | �|�� |d
� W d tj|td � X d S ) Nr )�target�argsg�������?s$ Suppose there isn't a 16-ton weight?g�������?r" i� r r � )r% )� threadingZEventr �
settimeoutr Z bind_portr �Threadr7 r2 r& r+ r� �
create_socket�connect�HOST�sendZ
out_bufferr rE �waitrA rt � join_thread�TIMEOUT)
r r- r< �portZcapr� rb r6 rn r1 r r r
� test_sendF s2
z!DispatcherWithSendTests.test_sendN)r r r ri rj r � reap_threadsr� r r r r
r� ? s r� � file_wrapperz asyncore.file_wrapper requiredc @ sV e Zd Zdd� Zdd� Zdd� Zdd� Ze�e e
d �d
�d d � �Z d
d� Z dd� Z
dS )�FileWrapperTestc C s. d| _ ttjd��}|�| j � W d Q R X d S )Ns It's not dead, it's sleeping!�wb)rn �openr �TESTFNr) )r �filer r r
ri q s zFileWrapperTest.setUpc C s t �t j� d S )N)r r: r� )r r r r
rj v s zFileWrapperTest.tearDownc C s� t �tjt j�}t�|�}t �|� | �|j |� | �|�
� |� | � |� d�d� | � |�
d�d� |�� | �t|j
d� d S )N�
s
It's not dead� s , it'sr )r] r� r r� �O_RDONLYr r� r ZassertNotEqual�fdr rA r( r@ r? �OSError)r r� r4 r r r
� test_recvy s
zFileWrapperTest.test_recvc C s� d}d}t �tjt jt jB �}t�|�}t �|� |� |� |�
|� |�� ttjd�� }| � |� � | j
| | � W d Q R X d S )Ns Come again?s I want to buy some cheese.�rb)r] r� r r� �O_WRONLY�O_APPENDr r� r r) r� rA r@ rn )r Zd1Zd2r� r4 r� r r r
r� � s
zFileWrapperTest.test_send�file_dispatcherz!asyncore.file_dispatcher requiredc sd t �tjt j�}g � G � fdd�dtj�}||�}t �|� tjdddd� | � d�
� �| j � d S )Nc s e Zd Z� fdd�ZdS )z7FileWrapperTest.test_dispatcher.<locals>.FileDispatcherc s � � | �d�� d S )N� )rQ r( )r )r6 r r
r� � s zCFileWrapperTest.test_dispatcher.<locals>.FileDispatcher.handle_readN)r r r r� r )r6 r r
�FileDispatcher� s r� g{�G�z�?Tr� )r% �use_poll�countr# ) r] r� r r� r� r r� r �looprA �joinrn )r r� r� �sr )r6 r
�test_dispatcher� s
z FileWrapperTest.test_dispatcherc C sN t �tjt j�}t�|�}t �|� t�dt f�� d }t�
� W d Q R X d S )Nr� ) r] r� r r� r� r r� r Zcheck_warnings�ResourceWarningZ
gc_collect)r r� r` r r r
�test_resource_warning� s
z%FileWrapperTest.test_resource_warningc C sh t �tjt j�}t�|�}t �|� t �|j� | � t
�� |�� W d Q R X | � |jd� |�� d S )NrX ) r] r� r r� r� r r� r r� r? r� rA )r r� r` r r r
�test_close_twice� s
z FileWrapperTest.test_close_twiceN)r r r ri rj r� r� re rf rg r r� r� r� r r r r
r� n s
r� c @ sF e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dS )�BaseTestHandlerNc C s t j�| |� d| _d S )NF)r rk r rJ )r r< r r r
r � s zBaseTestHandler.__init__c C s t d��d S )Nz'handle_accept not supposed to be called)r )r r r r
�
handle_accept� s z BaseTestHandler.handle_acceptc C s t d��d S )Nz)handle_accepted not supposed to be called)r )r r r r
�handle_accepted� s z BaseTestHandler.handle_acceptedc C s t d��d S )Nz(handle_connect not supposed to be called)r )r r r r
r� � s z BaseTestHandler.handle_connectc C s t d��d S )Nz%handle_expt not supposed to be called)r )r r r r
r � s zBaseTestHandler.handle_exptc C s t d��d S )Nz&handle_close not supposed to be called)r )r r r r
r � s z BaseTestHandler.handle_closec C s � d S )Nr )r r r r
r � s z BaseTestHandler.handle_error)N)
r r r r r� r� r� r r r r r r r
r� � s
r� c @ s8 e Zd ZdZefdd�Zedd� �Zdd� Zdd � Z d
S ) �
BaseServerzYA server which listens on an address and dispatches the
connection to a handler.
c C s> t j�| � | �|� | �� t| j|� | �d� || _d S )N� ) r rk r r� �set_reuse_addrr= r r$ �handler)r r9 r0 r� r r r
r � s
zBaseServer.__init__c C s
| j �� S )N)r � getsockname)r r r r
�address� s zBaseServer.addressc C s | � |� d S )N)r� )r r< r0 r r r
r� � s zBaseServer.handle_acceptedc C s � d S )Nr )r r r r
r � s zBaseServer.handle_errorN)
r r r �__doc__r� r �propertyr� r� r r r r r
r� � s
r� c @ s e Zd Zdd� Zdd� ZdS )�
BaseClientc C s" t �| � | �|� | �|� d S )N)r� r r� r� )r r9 r� r r r
r � s
zBaseClient.__init__c C s d S )Nr )r r r r
r� � s zBaseClient.handle_connectN)r r r r r� r r r r
r� � s r� c @ s� e Zd Zdd� Zd%dd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z e �
ej�d�d�dd� �Zdd� Zdd� Zd d � Zd d � Zd d!� Zejd"d#� �Zd$S )&� BaseTestAPIc C s t jdd� d S )NT)Z
ignore_all)r rS )r r r r
rj � s zBaseTestAPI.tearDownr� c C s` t |�d }d}x@tjrP|dkrPtjdd| jd� |jr<d S |d8 }t�|� qW | �d� d S )N�d r g{�G�z�?r )r% r� r� z flag not set) �floatr rR r� r� rJ r& r+ r\ )r �instancer% r� r r r
�loop_waiting_for_flag� s z!BaseTestAPI.loop_waiting_for_flagc C s: G dd� dt �}t| j| j�}|| j|j�}| �|� d S )Nc @ s e Zd Zdd� ZdS )z3BaseTestAPI.test_handle_connect.<locals>.TestClientc S s
d| _ d S )NT)rJ )r r r r
r� s zBBaseTestAPI.test_handle_connect.<locals>.TestClient.handle_connectN)r r r r� r r r r
�
TestClient s r� )r� r� r9 r0 r� r� )r r� �server�clientr r r
�test_handle_connect s z BaseTestAPI.test_handle_connectc C s: G dd� dt �}|| j| j�}t| j|j�}| �|� d S )Nc @ s e Zd Zdd� Zdd� ZdS )z4BaseTestAPI.test_handle_accept.<locals>.TestListenerc S s: t �| � | �|� t| j|� | �d� | j�� | _d S )Nr� )r� r r� r= r r$ r� r� )r r9 r0 r r r
r s
z=BaseTestAPI.test_handle_accept.<locals>.TestListener.__init__c S s
d| _ d S )NT)rJ )r r r r
r� s zBBaseTestAPI.test_handle_accept.<locals>.TestListener.handle_acceptN)r r r r r� r r r r
� TestListener s r� )r� r9 r0 r� r� r� )r r� r� r� r r r
�test_handle_accept s z BaseTestAPI.test_handle_acceptc C s: G dd� dt �}|| j| j�}t| j|j�}| �|� d S )Nc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )z6BaseTestAPI.test_handle_accepted.<locals>.TestListenerc S s: t �| � | �|� t| j|� | �d� | j�� | _d S )Nr� )r� r r� r= r r$ r� r� )r r9 r0 r r r
r & s
z?BaseTestAPI.test_handle_accepted.<locals>.TestListener.__init__c S s t j�| � d S )N)r rk r� )r r r r
r� - s zDBaseTestAPI.test_handle_accepted.<locals>.TestListener.handle_acceptc S s |� � d| _d S )NT)r rJ )r r< r0 r r r
r� 0 s zFBaseTestAPI.test_handle_accepted.<locals>.TestListener.handle_acceptedN)r r r r r� r� r r r r
r� $ s r� )r� r9 r0 r� r� r� )r r� r� r� r r r
�test_handle_accepted! s z BaseTestAPI.test_handle_acceptedc C sL G dd� dt �}G dd� dt�}t| j| j|�}|| j|j�}| �|� d S )Nc @ s e Zd Zdd� ZdS )z0BaseTestAPI.test_handle_read.<locals>.TestClientc S s
d| _ d S )NT)rJ )r r r r
r� = s z<BaseTestAPI.test_handle_read.<locals>.TestClient.handle_readN)r r r r� r r r r
r� < s r� c @ s e Zd Zdd� ZdS )z1BaseTestAPI.test_handle_read.<locals>.TestHandlerc S s t �| |� | �d� d S )Ns xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx)r� r r� )r r/ r r r
r A s z:BaseTestAPI.test_handle_read.<locals>.TestHandler.__init__N)r r r r r r r r
� TestHandler@ s r� )r� r� r� r9 r0 r� r� )r r� r� r� r� r r r
�test_handle_read9 s
z BaseTestAPI.test_handle_readc C s: G dd� dt �}t| j| j�}|| j|j�}| �|� d S )Nc @ s e Zd Zdd� ZdS )z1BaseTestAPI.test_handle_write.<locals>.TestClientc S s
d| _ d S )NT)rJ )r r r r
r� M s z>BaseTestAPI.test_handle_write.<locals>.TestClient.handle_writeN)r r r r� r r r r
r� L s r� )r� r� r9 r0 r� r� )r r� r� r� r r r
�test_handle_writeI s z BaseTestAPI.test_handle_writec C sL G dd� dt �}G dd� dt�}t| j| j|�}|| j|j�}| �|� d S )Nc @ s e Zd Zdd� Zdd� ZdS )z1BaseTestAPI.test_handle_close.<locals>.TestClientc S s | � d� d S )Ni )r( )r r r r
r� Z s z=BaseTestAPI.test_handle_close.<locals>.TestClient.handle_readc S s d| _ | �� d S )NT)rJ r )r r r r
r _ s z>BaseTestAPI.test_handle_close.<locals>.TestClient.handle_closeN)r r r r� r r r r r
r� X s r� c @ s e Zd Zdd� ZdS )z2BaseTestAPI.test_handle_close.<locals>.TestHandlerc S s t �| |� | �� d S )N)r� r r )r r/ r r r
r d s z;BaseTestAPI.test_handle_close.<locals>.TestHandler.__init__N)r r r r r r r r
r� c s r� )r� r� r� r9 r0 r� r� )r r� r� r� r� r r r
�test_handle_closeT s
z BaseTestAPI.test_handle_closec sX d� G � fdd�dt �}G � fdd�dt�}t| j| j|�}|| j|j�}| �|� d S )Ns� c s( e Zd Z� fdd�Zdd� Zdd� ZdS )zCBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestClientc s | � � � d S )N)r� )r )r6 r r
r� t s zPBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestClient.handle_writec S s d| _ | �� d S )NT)rJ r )r r r r
r w s zPBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestClient.handle_closec S s d| _ | �� d S )NT)rJ r )r r r r
r { s zOBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestClient.handle_exptN)r r r r� r r r )r6 r r
r� r s r� c s e Zd Z� fdd�Zdd� ZdS )zDBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestHandlerc s | � t� �� | �� d S )N)r( rT r )r )r6 r r
r� � s zPBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestHandler.handle_readc S s dS )NFr )r r r r
rm � s zMBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestHandler.writableN)r r r r� rm r )r6 r r
r� s r� )r� r� r� r9 r0 r� r� )r r� r� r� r� r )r6 r
�#test_handle_close_after_conn_brokenl s
z/BaseTestAPI.test_handle_close_after_conn_brokenZsunosz OOB support is broken on Solarisc C s� t r| jtjkr| �d� tjdkr4| jr4| �d� G dd� dt�}G dd� dt �}t
| j| j |�}|| j|j �}| �
|� d S )Nz"Not applicable to AF_UNIX sockets.�darwinz(poll may fail on macOS; see issue #28087c @ s e Zd Zdd� ZdS )z0BaseTestAPI.test_handle_expt.<locals>.TestClientc S s | j �dt j� d| _d S )Ni T)r r( �MSG_OOBrJ )r r r r
r � s z<BaseTestAPI.test_handle_expt.<locals>.TestClient.handle_exptN)r r r r r r r r
r� � s r� c @ s e Zd Zdd� ZdS )z1BaseTestAPI.test_handle_expt.<locals>.TestHandlerc S s* t �| |� | j�ttd�d�tj� d S )N�� zlatin-1)r� r r r� �bytes�chrr� )r r/ r r r
r � s z:BaseTestAPI.test_handle_expt.<locals>.TestHandler.__init__N)r r r r r r r r
r� � s r� )r8 r9 r r �skipTestrZ �platformr� r� r� r� r0 r� r� )r r� r� r� r� r r r
�test_handle_expt� s
z BaseTestAPI.test_handle_exptc C s: G dd� dt �}t| j| j�}|| j|j�}| �|� d S )Nc @ s e Zd Zdd� Zdd� ZdS )z1BaseTestAPI.test_handle_error.<locals>.TestClientc S s dd d S )Ng �?r r )r r r r
r� � s z>BaseTestAPI.test_handle_error.<locals>.TestClient.handle_writec S s. d| _ y� W n tk
r Y n
X td��d S )NTzexception not raised)rJ �ZeroDivisionErrorr )r r r r
r � s z>BaseTestAPI.test_handle_error.<locals>.TestClient.handle_errorN)r r r r� r r r r r
r� � s r� )r� r� r9 r0 r� r� )r r� r� r� r r r
�test_handle_error� s z BaseTestAPI.test_handle_errorc C s� t | j| j�}t| j|j�}| �|j� | �|j� | �|j� t j
d| j dd� | �|j� | �|j� | �|j� | �|j� |� � | �|j� | �|j� | �|j� | �|j� |� � | �|j� | �|j� d S )Ng{�G�z�?r� )r% r� r� )
r� r9 r0 r� r� � assertFalseZ connectedr� Z acceptingr r� r� r )r r� r� r r r
�test_connection_attributes� s$ z&BaseTestAPI.test_connection_attributesc C s^ t �� }|�| j� | �|jjtj� | �|jj| j� | �|j�� d� | � |j�
� � d S )Nr ) r rk r� r9 rA r �type� SOCK_STREAMZ
gettimeoutr� �get_inheritable)r r� r r r
�test_create_socket� s z BaseTestAPI.test_create_socketc C s� t r| jtjkr| �d� t�� }|�| j� |�| j � |�
d� |j� � d }t�� }|�| j� | � t
|j| j d |f� d S )Nz"Not applicable to AF_UNIX sockets.r� r r )r8 r9 r r r� r rk r� r; r0 r$ r� r? r� )r �s1r� �s2r r r
� test_bind� s
zBaseTestAPI.test_bindc C s� t r| jtjkr| �d� t�| j���}y|�tjtjd� W n tk
r\ t �
d� Y nbX t � t�| j��}| �
|j�tjtj�� |j�� |�| j� |�� | �|j�tjtj�� W d Q R X d S )Nz"Not applicable to AF_UNIX sockets.r z+SO_REUSEADDR not supported on this platform)r8 r9 r r r� �
setsockopt�
SOL_SOCKETZ SO_REUSEADDRr� re �skipr rk r� Z
getsockoptr r� r� r� )r r< r� r r r
�test_set_reuse_addr� s
z BaseTestAPI.test_set_reuse_addrc
C s� | j tjttdt� �fkr$| �d� t| j | j�}tj dd� d�}|�
� zlt�| j tj ��R}|� d� |�
tjtjt�ddd �� y|�|j� W n tk
r� Y nX W d Q R X W d tj|td
� X d S ) N�AF_INET6z%test specific to AF_INET and AF_INET6c S s t jddd�S )Ng�������?r� )r% r� )r r� r r r r
�<lambda> s z0BaseTestAPI.test_quick_connect.<locals>.<lambda>)r� g�������?�iir r )r% )r9 r �AF_INETrH �objectr� r� r0 r� r� r2 r� r� r� r� Z SO_LINGER�struct�packr� r� r� r r� r� )r r� rb r� r r r
�test_quick_connect s
z BaseTestAPI.test_quick_connectN)r� )r r r rj r� r� r� r� r� r� r� r� re ZskipIfrZ r� �
startswithr� r� r� r� r� r� r r� r� r r r r
r� � s"
r� c @ s e Zd ZejZejdfZdS )�TestAPI_UseIPv4Socketsr N) r r r r r� r9 r r� r0 r r r r
r� s r� zIPv6 support requiredc @ s e Zd ZejZejdfZdS )�TestAPI_UseIPv6Socketsr N) r r r r r� r9 r ZHOSTv6r0 r r r r
r� s r� zUnix sockets requiredc @ s$ e Zd ZerejZejZ dd� Z
dS )�TestAPI_UseUnixSocketsc C s t �| j� t�| � d S )N)r r: r0 r� rj )r r r r
rj ( s z TestAPI_UseUnixSockets.tearDownN) r r r r8 r r r9 r r� r0 rj r r r r
r� " s r� c @ s e Zd ZdZdS )�TestAPI_UseIPv4SelectFN)r r r r� r r r r
r� , s r� rE zselect.poll requiredc @ s e Zd ZdZdS )�TestAPI_UseIPv4PollTN)r r r r� r r r r
r� / s r� c @ s e Zd ZdZdS )�TestAPI_UseIPv6SelectFN)r r r r� r r r r
r� 3 s r� c @ s e Zd ZdZdS )�TestAPI_UseIPv6PollTN)r r r r� r r r r
r� 6 s r� c @ s e Zd ZdZdS )� TestAPI_UseUnixSocketsSelectFN)r r r r� r r r r
r� : s r� c @ s e Zd ZdZdS )�TestAPI_UseUnixSocketsPollTN)r r r r� r r r r
r� = s r� �__main__)2r re r' r] r rZ r& r� r� r� Ztestr �ior ZPGOZSkipTestr� rg r8 r r r r r7 r= ZTestCaser> rh Zdispatcher_with_sendr� r� rf r� rk r� r� r� r� r� Z IPV6_ENABLEDr� r� r� r� r� r� r� r� r �mainr r r r
�<module> sf
H/
G (