| Server IP : 118.27.122.248 / Your IP : 216.73.216.15 Web Server : Apache System : Linux web0264.sh.tyo1 4.18.0-553.79.1.lve.el7h.x86_64 #1 SMP Wed Oct 15 16:34:46 UTC 2025 x86_64 User : c9415830 ( 11735) PHP Version : 8.4.17 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python36/lib64/python3.6/test/__pycache__/ |
Upload File : |
3
�w2_ i � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
d dl m Z e
j
rpejd��y d dlZW n ek
r� dZY nX dZeed�ZG dd� d�ZG d d
� d
�ZG d d � d �ZG d
d� d�Zdd� Zdd� ZG dd� dej�ZG dd� dej�Z G dd� de j �Z G dd� dej�Z ej 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'ej e
j(d)�G d*d+� d+e&��Z)ej ed,�G d-d.� d.e&��Z*G d/d0� d0e'ej�Z+ej eed1�d2�G d3d4� d4e'ej��Z,G d5d6� d6e)ej�Z-ej eed1�d2�G d7d8� d8e)ej��Z.G d9d:� d:e*ej�Z/ej eed1�d2�G d;d<� d<e*ej��Z0e1d=k�r�ej2� 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 �7/opt/alt/python36/lib64/python3.6/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 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 j� �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 6 s zcrashingdummy.__init__c C s
t � �d S )N)� Exception)r r r r
r 9 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 5 s r c C s� z�y|j � |j� \}}W n tjk
r0 Y n�X d}tj� }xp|dkr�tj� | dk r�tj|gg g d�\}}} |r�|d8 }|jd�}
|j|
jdd�� d|
kr�P tj d � q@W |j
� W d |j
� | j � X d S )
N�� r g @g�������?� �
�
� g{�G�z�?) �listenZacceptr �timeout�time�select�recv�write�replace�sleepr �set) �evtZbufZserv�conn�addr�n�start�r�w�e�datar r r
�capture_serverD s&
r6 c C s6 t r(| jtjkr(tj|� tj| |� n
| j|� dS )z9Helper function to bind a socket according to its family.N)�HAS_UNIX_SOCKETS�familyr r r �unlinkZbind_unix_socket�bind)�sockr/ r r r
�
bind_af_aware] s
r< c @ sN e Zd Zdd� Zejeed�d�dd� �Zdd� Z d d
� Z
d d � Z d
d� Z dS )�HelperFunctionTestsc C s� t � }| jtjtj|� | jtjtj|� | jtjtj|� t� }tj|� | j|j d� t� }tj|� | j|j d� t� }tj|� | j|j d� d S )NT)
r � assertRaisesr r �readr) Z
_exceptionr � assertEqualr )r �tr1�tr2r r r
�test_readwriteexch s
z%HelperFunctionTests.test_readwriteexc�pollzselect.poll requiredc
C s� d
}t jdft jdft jdft jdft jdft jdff}G dd� d�}x�|D ]�\}}|� }| jt||�d� t j
||� x"|D ]}| jt||�||k� q~W t � }| j t j
t j
||� t� } | j| jd� t j
| |� | j| jd � qLW d S ) Nr? �exptr) 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 rE 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)rE )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 rF FT)r? rE r) r r )r' ZPOLLINZPOLLPRIZPOLLOUTZPOLLERRZPOLLHUPZPOLLNVALr@ �getattrr Z readwriter r> r r r )
r Z
attributes�expectedrF �flagZ expectedattrZtobj�attrrA rB r r r
�test_readwrite� s(
z"HelperFunctionTests.test_readwritec C s | j d� d S )NF)�closeall_check)r r r r
�
test_closeall� s z!HelperFunctionTests.test_closeallc C s | j d� d S )NT)rL )r r r r
�test_closeall_default� s z)HelperFunctionTests.test_closeall_defaultc C s� g }i }x8t d�D ],}t� }|j|� | j|jjd� |||< qW |rrtj}z|t_tj� W d tj| }t_X n
tj|� | jt |�d� x |D ]}| j|jjd� q�W d S )Nr! Fr T)
�ranger �appendr@ r r r �
socket_map� close_all�len)r Z
usedefault�lZtestmap�i�cZ socketmapr r r
rL � s"
z"HelperFunctionTests.closeall_checkc C s� y t d��W n" tj� \}}}tj� }Y n X | jd� |\\}}}}} }
| jtjj |�d d� | j|d� | j||� | j| |� | j|
d|||f � d S )NzI don't like spam!zExpected exceptionr ztest_asyncore.py�test_compact_tracebackz
[%s|%s|%s]���)
r �sys�exc_infor Zcompact_traceback�failr@ �os�path�split) r Zreal_tZreal_vZreal_tbr2 �fZfunction�line�t�v�infor r r
rW � s
z*HelperFunctionTests.test_compact_tracebackN)
r r r rC �unittest�
skipUnless�hasattrr' rK rM rN rL rW r r r r
r= g 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 j� d S )N)r rR )r r r r
�tearDown� s zDispatcherTests.tearDownc C s, t j� }| j|j� d� | j|j� d� d S )NT)r �
dispatcherr@ �readable�writable)r �dr r r
�
test_basic� s zDispatcherTests.test_basicc C s$ t j� }| jt|�dt|� � d S )Nz <asyncore.dispatcher at %#x>)r rj r@ �repr�id)r rm r r r
� test_repr� s zDispatcherTests.test_reprc C s` t j� }d}d}tj� �}|j|� |j|� W d Q R X |j� j� }| j|d| d| g� d S )Nz Lovely spam! Wonderful spam!zI don't like spam!zlog: %s)r rj r Zcaptured_stderr�log�getvalue�
splitlinesr@ )r rm �l1�l2�stderr�linesr r r
�test_log s
zDispatcherTests.test_logc C s| t j� }d}d}d}tj� �(}|j|d� |j|� |j|d� W d Q R X |j� j� }d| d| d| g}| j||� 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 rj r �captured_stdoutZlog_infors rt r@ )r rm ru rv �l3�stdoutrx rH r r r
�
test_log_info s
z DispatcherTests.test_log_infoc C sj t j� }f |_tj� �&}|j� |j� |j� |j� W d Q R X |j � j
� }ddddg}| j ||� d S )Nz*warning: unhandled incoming priority eventz warning: unhandled read eventz warning: unhandled write eventz warning: unhandled connect event) r rj Zignore_log_typesr rz � handle_expt� handle_read� handle_write�handle_connectrs rt r@ )r rm r| rx rH r r r
�test_unhandled s
z DispatcherTests.test_unhandledc C sF t jtj�}ttd�r*| j|tjtj�� t jd�}| j|dk� d S )N�strerrorr � rX ) r Z _strerror�errnoZEPERMrf r\ r@ r� �
assertTrue)r �errr r r
�
test_strerror1 s
z DispatcherTests.test_strerrorN) r r r rh ri rn rq ry r} r� r� r r r r
rg � s
rg c @ s e Zd Zdd� Zdd� ZdS )�dispatcherwithsend_noreadc C s dS )NFr )r r r r
rk ; s z"dispatcherwithsend_noread.readablec C s d S )Nr )r r r r
r� > s z(dispatcherwithsend_noread.handle_connectN)r r r rk r� r r r r
r� : s r� c @ s6 e Zd Zdd� Zdd� Zejed�ej dd� ��Z
dS ) �DispatcherWithSendTestsc C s d S )Nr )r r r r
rh C s z DispatcherWithSendTests.setUpc C s t j� d S )N)r rR )r r r r
ri F s z DispatcherWithSendTests.tearDownz!Threading required for this test.c
C s t j� }tj� }|jd� tj|�}t� }|||f}t jt|d�}|j � z�t
j d� d}t � }|j
� |jtj|f� t
j d� |j|� |j|� |jd� d} x"|jr�| dkr�tj� | d 8 } q�W |j� | j|j� |d
� W d |jtd � |j� �r| jd � X d S )
Nr )�target�argsg�������?s$ Suppose there isn't a 16-ton weight?g�������?r" i� r r � )r% zjoin() timed out)� threadingZEventr �
settimeoutr Z bind_portr �Threadr6 r1 r& r+ r� �
create_socket�connect�HOST�sendZ
out_bufferr rD �waitr@ rs �join�TIMEOUT�is_aliver[ )
r r- r; �portZcapr� ra r5 rm r0 r r r
� test_sendI s6
z!DispatcherWithSendTests.test_sendN) r r r rh ri rd re r� r � reap_threadsr� r r r r
r� B s
r� � file_wrapperz asyncore.file_wrapper requiredc @ sV e Zd Zdd� Zdd� Zdd� Zdd� Zeje e
d �d
�d d � �Z d
d� Z dd� Z
dS )�FileWrapperTestc C s. d| _ ttjd��}|j| j � W d Q R X d S )Ns It's not dead, it's sleeping!�wb)rm �openr �TESTFNr) )r �filer r r
rh w s zFileWrapperTest.setUpc C s t jt j� d S )N)r r9 r� )r r r r
ri | s zFileWrapperTest.tearDownc C s� t jtjt j�}tj|�}t j|� | j|j |� | j|j
� |� | j |j d�d� | j |j
d�d� |j� | jt|j
d� d S )N�
s
It's not dead� s , it'sr )r\ r� r r� �O_RDONLYr r� r ZassertNotEqual�fdr r@ r( r? r> �OSError)r r� r3 r r r
� test_recv s
zFileWrapperTest.test_recvc C s� d}d}t jtjt jt jB �}tj|�}t j|� |j |� |j
|� |j� ttjd�� }| j |j � | 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� r@ r? rm )r Zd1Zd2r� r3 r� r r r
r� � s
zFileWrapperTest.test_send�file_dispatcherz!asyncore.file_dispatcher requiredc sd t jtjt j�}g � G � fdd�dtj�}||�}t j|� tjdddd� | j dj
� �| j � d S )Nc s e Zd Z� fdd�ZdS )z7FileWrapperTest.test_dispatcher.<locals>.FileDispatcherc s � j | jd�� d S )N� )rP r( )r )r5 r r
r � s zCFileWrapperTest.test_dispatcher.<locals>.FileDispatcher.handle_readN)r r r r r )r5 r r
�FileDispatcher� s r� g{�G�z�?Tr� )r% �use_poll�countr# ) r\ r� r r� r� r r� r �loopr@ r� rm )r r� r� �sr )r5 r
�test_dispatcher� s
z FileWrapperTest.test_dispatcherc C sN t jtjt j�}tj|�}t j|� tjdt f�� d }tj
� 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 jtjt j�}tj|�}t j|� t j|j� | j t
�� |j� W d Q R X | j |jd� |j� d S )Nr rX ) r\ r� r r� r� r r� r r� r> r� r@ )r r� r_ r r r
�test_close_twice� s
z FileWrapperTest.test_close_twiceN)r r r rh ri r� r� rd re rf r r� r� r� r r r r
r� t s
r� c @ sF e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dS )�BaseTestHandlerNc C s t jj| |� d| _d S )NF)r rj r rI )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 jj| � | j|� | j� t| j|� | jd� || _d S )N� ) r rj r r� �set_reuse_addrr< r r$ �handler)r r8 r/ r� r r r
r � s
zBaseServer.__init__c C s
| j j� S )N)r � getsockname)r r r r
�address� s zBaseServer.addressc C s | j |� d S )N)r� )r r; r/ 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 j| � | j|� | j|� d S )N)r� r r� r� )r r8 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 j
ejjd�d�dd� �Zdd� Zdd� Zd d � Zd d � Zd d!� Ze jed"�ejd#d$� ��Zd%S )'� BaseTestAPIc C s t jdd� d S )NT)Z
ignore_all)r rR )r r r r
ri � s zBaseTestAPI.tearDownr� c C s` t |�d }d}x@tjrP|dkrPtjdd| jd� |jr<d S |d8 }tj|� qW | jd� d S )N�d r g{�G�z�?r )r% r� r� z flag not set) �floatr rQ r� r� rI 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�}| j|� d S )Nc @ s e Zd Zdd� ZdS )z3BaseTestAPI.test_handle_connect.<locals>.TestClientc S s
d| _ d S )NT)rI )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� r8 r/ 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�}| j|� d S )Nc @ s e Zd Zdd� Zdd� ZdS )z4BaseTestAPI.test_handle_accept.<locals>.TestListenerc S s: t j| � | j|� t| j|� | jd� | jj� | _d S )Nr� )r� r r� r< r r$ r� r� )r r8 r/ r r r
r s
z=BaseTestAPI.test_handle_accept.<locals>.TestListener.__init__c S s
d| _ d S )NT)rI )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� r8 r/ 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�}| j|� d S )Nc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )z6BaseTestAPI.test_handle_accepted.<locals>.TestListenerc S s: t j| � | j|� t| j|� | jd� | jj� | _d S )Nr� )r� r r� r< r r$ r� r� )r r8 r/ r r r
r , s
z?BaseTestAPI.test_handle_accepted.<locals>.TestListener.__init__c S s t jj| � d S )N)r rj r� )r r r r
r� 3 s zDBaseTestAPI.test_handle_accepted.<locals>.TestListener.handle_acceptc S s |j � d| _d S )NT)r rI )r r; r/ r r r
r� 6 s zFBaseTestAPI.test_handle_accepted.<locals>.TestListener.handle_acceptedN)r r r r r� r� r r r r
r� * s r� )r� r8 r/ 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�}| j|� d S )Nc @ s e Zd Zdd� ZdS )z0BaseTestAPI.test_handle_read.<locals>.TestClientc S s
d| _ d S )NT)rI )r r r r
r C s z<BaseTestAPI.test_handle_read.<locals>.TestClient.handle_readN)r r r r r r r r
r� B s r� c @ s e Zd Zdd� ZdS )z1BaseTestAPI.test_handle_read.<locals>.TestHandlerc S s t j| |� | jdd � d S )N� xi )r� r r� )r r. r r r
r G s z:BaseTestAPI.test_handle_read.<locals>.TestHandler.__init__N)r r r r r r r r
� TestHandlerF s r� )r� r� r� r8 r/ r� r� )r r� r� r� r� r r r
�test_handle_read? s
z BaseTestAPI.test_handle_readc C s: G dd� dt �}t| j| j�}|| j|j�}| j|� d S )Nc @ s e Zd Zdd� ZdS )z1BaseTestAPI.test_handle_write.<locals>.TestClientc S s
d| _ d S )NT)rI )r r r r
r� S s z>BaseTestAPI.test_handle_write.<locals>.TestClient.handle_writeN)r r r r� r r r r
r� R s r� )r� r� r8 r/ r� r� )r r� r� r� r r r
�test_handle_writeO s z BaseTestAPI.test_handle_writec C sL G dd� dt �}G dd� dt�}t| j| j|�}|| j|j�}| j|� d S )Nc @ s e Zd Zdd� Zdd� ZdS )z1BaseTestAPI.test_handle_close.<locals>.TestClientc S s | j d� d S )Ni )r( )r r r r
r ` s z=BaseTestAPI.test_handle_close.<locals>.TestClient.handle_readc S s d| _ | j� d S )NT)rI r )r r r r
r e s z>BaseTestAPI.test_handle_close.<locals>.TestClient.handle_closeN)r r r r r r r r r
r� ^ s r� c @ s e Zd Zdd� ZdS )z2BaseTestAPI.test_handle_close.<locals>.TestHandlerc S s t j| |� | j� d S )N)r� r r )r r. r r r
r j s z;BaseTestAPI.test_handle_close.<locals>.TestHandler.__init__N)r r r r r r r r
r� i s r� )r� r� r� r8 r/ r� r� )r r� r� r� r� r r r
�test_handle_closeZ s
z BaseTestAPI.test_handle_closec s\ dd � G � fdd�dt �}G � fdd�dt�}t| j| j|�}|| j|j�}| j|� d S )N� � c s( e Zd Z� fdd�Zdd� Zdd� ZdS )zCBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestClientc s | j � � d S )N)r� )r )r5 r r
r� z s zPBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestClient.handle_writec S s d| _ | j� d S )NT)rI r )r r r r
r } s zPBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestClient.handle_closec S s d| _ | j� d S )NT)rI 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 )r5 r r
r� x s r� c s e Zd Z� fdd�Zdd� ZdS )zDBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestHandlerc s | j t� �� | j� d S )N)r( rS r )r )r5 r r
r � s zPBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestHandler.handle_readc S s dS )NFr )r r r r
rl � s zMBaseTestAPI.test_handle_close_after_conn_broken.<locals>.TestHandler.writableN)r r r r rl r )r5 r r
r� � s r� )r� r� r� r8 r/ r� r� )r r� r� r� r� r )r5 r
�#test_handle_close_after_conn_brokenr s
z/BaseTestAPI.test_handle_close_after_conn_broken�sunosz OOB support is broken on Solarisc C s� t r| jtjkr| jd� tjdkr4| jr4| jd� G dd� dt�}G dd� dt �}t
| j| 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 jdt j� d| _d S )Ni T)r r( �MSG_OOBrI )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| |� | jjttd�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� )r7 r8 r r �skipTestrY �platformr� r� r� r� r/ 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�}| 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)rI �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� r8 r/ 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|j� | j|j� t j
d| j dd� | j|j� | j|j� | j|j� | j|j� |j � | j|j� | j|j� | j|j� | j|j� |j � | j|j� | j|j� d S )Ng{�G�z�?r� )r% r� r� )
r� r8 r/ 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 sv t j� }|j| j� | j|jj| j� ttdd�}tj|B }ttd�rb| j |jj
|tj B |f� n| j|jj
|� d S )N�
SOCK_NONBLOCKr � SOCK_CLOEXEC) r rj r� r8 r@ r rG � SOCK_STREAMrf ZassertIn�typer� )r r� r� Z sock_typer r r
�test_create_socket� s
z BaseTestAPI.test_create_socketc C s� t r| jtjkr| jd� tj� }|j| j� |j| j � |j
d� |jj � d }tj� }|j| j� | j t
|j| j d |f� d S )Nz"Not applicable to AF_UNIX sockets.r� r r )r7 r8 r r r� r rj r� r: r/ r$ r� r> r� )r �s1r� �s2r r r
� test_bind� s
zBaseTestAPI.test_bindc C s� t r| jtjkr| jd� tj| j���}y|jtjtjd� W n tk
r\ t j
d� Y nbX t j tj| j��}| j
|jjtjtj�� |jj� |j| j� |j� | j|jjtjtj�� W d Q R X d S )Nz"Not applicable to AF_UNIX sockets.r z+SO_REUSEADDR not supported on this platform)r7 r8 r r r� �
setsockopt�
SOL_SOCKETZ SO_REUSEADDRr� rd �skipr rj r� Z
getsockoptr r� r� r� )r r; r� r r r
�test_set_reuse_addr� s
z BaseTestAPI.test_set_reuse_addrz!Threading required for this test.c C s� | j tjttdt� �fkr$| jd� t| j | j�}tj dd� d�}|j
� zltj| j tj ��R}|j d� |j
tjtjtjddd �� y|j|j� W n tk
r� Y nX W d Q R X W d |jtd
� |j� r�| jd � 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�������?Ziir r )r% zjoin() timed out)r8 r �AF_INETrG �objectr� r� r/ r� r� r1 r� r� r� r� Z SO_LINGER�structZpackr� r� r� r� r� r� r[ )r r� ra r� r r r
�test_quick_connect s"
z BaseTestAPI.test_quick_connectN)r� ) r r r ri r� r� r� r� r� r� r� r� rd ZskipIfrY r� �
startswithr� r� r� r� r� r� re r� r r� r� r r r r
r� � s$
r� c @ s e Zd ZejZejdfZdS )�TestAPI_UseIPv4Socketsr N) r r r r r� r8 r r� r/ r r r r
r� & s r� zIPv6 support requiredc @ s e Zd ZejZejdfZdS )�TestAPI_UseIPv6Socketsr N) r r r r r� r8 r ZHOSTv6r/ r r r r
r� * s r� zUnix sockets requiredc @ s$ e Zd ZerejZejZ dd� Z
dS )�TestAPI_UseUnixSocketsc C s t j| j� tj| � d S )N)r r9 r/ r� ri )r r r r
ri 5 s z TestAPI_UseUnixSockets.tearDownN) r r r r7 r r r8 r r� r/ ri r r r r
r� / s r� c @ s e Zd ZdZdS )�TestAPI_UseIPv4SelectFN)r r r r� r r r r
r� 9 s r� rD 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� @ s r� c @ s e Zd ZdZdS )�TestAPI_UseIPv6PollTN)r r r r� r r r r
r� C s r� c @ s e Zd ZdZdS )� TestAPI_UseUnixSocketsSelectFN)r r r r� r r r r
r� G s r� c @ s e Zd ZdZdS )�TestAPI_UseUnixSocketsPollTN)r r r r� r r r r
r� J s r� �__main__)3r rd r' r\ r rY r& r� r� Ztestr �ior ZPGOZSkipTestr� � ImportErrorr� rf r7 r r r r r6 r< ZTestCaser= rg Zdispatcher_with_sendr� r� re r� rj r� r� r� r� r� Z IPV6_ENABLEDr� r� r� r� r� r� r� r� r �mainr r r r
�<module> sl
H2
G /