File: //proc/thread-self/root/usr/local/lib/python3.7/test/__pycache__/test_timeout.cpython-37.opt-2.pyc
B
��g�, � @ s� d dl Z d dlZd dlmZ e�d� Zd dlZd dlZd dlZe � � dd� �Z
G dd� dej �Z G dd � d ej �Z
G d
d � d e
�ZG d d
� d
e
�Zdd� Zedkr�e� dS )� N)�support�networkc C s2 t �| �� t�| |tjtj�d d S Q R X d S )Nr � )r �transient_internet�socketZ getaddrinfo�AF_INET� SOCK_STREAM)ZhostZport� r �-/usr/local/lib/python3.7/test/test_timeout.py�resolve_address s r c @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dS )�CreationTestCasec C s t � t jt j�| _d S )N)r r r �sock)�selfr r r
�setUp s zCreationTestCase.setUpc C s | j �� d S )N)r
�close)r r r r
�tearDown! s zCreationTestCase.tearDownc C s | � | j�� d d� d S )Nz timeout not disabled by default)� assertEqualr
�
gettimeout)r r r r
�testObjectCreation$ s z#CreationTestCase.testObjectCreationc C s^ | j �d� | �| j �� d� | j �d� | �| j �� d� | j �d � | �| j �� d � d S )Ng�z�Ga @� )r
�
settimeoutr r )r r r r
�testFloatReturnValue) s z%CreationTestCase.testFloatReturnValuec C sP | j �d� | �t| j �� �td�� | j �d� | �t| j �� �td�� d S )N� g �?g333333@)r
r r �typer )r r r r
�testReturnType4 s z CreationTestCase.testReturnTypec C s� | j �d� | j �d� | j �d� | j �d � | �t| j jd� | �t| j jd� | �t| j jd� | �t| j jg � | �t| j ji � | �t| j jd� d S )Nr g � r y )r
r � assertRaises� TypeError)r r r r
�
testTypeCheck< s z CreationTestCase.testTypeCheckc C s: | � t| jjd� | � t| jjd� | � t| jjd� d S )N���g �)r �
ValueErrorr
r )r r r r
�testRangeCheckI s z CreationTestCase.testRangeCheckc C s� | j �d� | j �d� | �| j �� d � | j �d� | �| j �� d� | j �d� | j �d� | �| j �� d� | j �d� | �| j �� d � d S )N�
r r g )r
r � setblockingr r )r r r r
�testTimeoutThenBlockingO s z(CreationTestCase.testTimeoutThenBlockingc C sX | j �d� | j �d� | �| j �� d� | j �d� | j �d� | �| j �� d� d S )Nr r )r
r# r r r )r r r r
�testBlockingThenTimeout] s z(CreationTestCase.testBlockingThenTimeoutN) �__name__�
__module__� __qualname__r r r r r r r! r$ r% r r r r
r s
r c @ s* e Zd ZdZejZdd� ZeZdd� Z dS )�TimeoutTestCaseg @c C s
t � �d S )N)�NotImplementedError)r r r r
r s s zTimeoutTestCase.setUpc G s� | j �|� t| j |�}xbt|�D ]L}t�� }y ||� W q" tjk
rl } zt�� | }P W d d }~X Y q"X q"W | �d� | � ||| j
� | � ||d � d S )Nz socket.timeout was not raisedg �?) r
r �getattr�range�timeZ monotonicr �timeoutZfailZ
assertLess�fuzzZ
assertGreater) r �countr. �method�args�iZt1�eZdeltar r r
�_sock_operationx s
z TimeoutTestCase._sock_operationN)
r& r' r( r/ r ZHOST� localhostr r r5 r r r r
r) h s
r) c @ sX e Zd Zdd� Zdd� Ze�dd�dd� �Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dS )�TCPTimeoutTestCasec C s" t � t jt j�| _tdd�| _d S )Nzwww.python.org.�P )r r r r
r � addr_remote)r r r r
r � s zTCPTimeoutTestCase.setUpc C s | j �� d S )N)r
r )r r r r
r � s zTCPTimeoutTestCase.tearDownTz*need to replace these hosts; see bpo-35518c
C s t dd�}t dd�}d}t�tjtj�}d}|�|� zZy|�|� W nF tjk
r\ Y n2 tk
r� } z|jtj kr|d}W d d }~X Y nX W d |�
� ~X |r�| � d� |d |d
||d |d
�� || _
t�| j
d �� | �d
d d | j
� W d Q R X d S )
Nzblackhole.snakebite.netiZ� zwhitehole.snakebite.neti[� Tr Fz�We didn't receive a connection reset (RST) packet from {}:{} within {} seconds, so we're unable to test connect timeout against the corresponding {}:{} (which is configured to silently drop packets).r r g����MbP?�connect)r r r r r r: r. �OSError�errnoZ ECONNREFUSEDr ZskipTest�formatr9 r r r5 )r Z blackholeZ whitehole�skipr
r. �errr r r
�testConnectTimeout� s4
z%TCPTimeoutTestCase.testConnectTimeoutc C s> t �| jd ��$ | j�| j� | �dddd� W d Q R X d S )Nr r g �?Zrecvi )r r r9 r
r: r5 )r r r r
�testRecvTimeout� s z"TCPTimeoutTestCase.testRecvTimeoutc C s, t �| j| j� | j�� | �ddd� d S )Nr g �?Zaccept)r � bind_portr
r6 �listenr5 )r r r r
�testAcceptTimeout� s
z$TCPTimeoutTestCase.testAcceptTimeoutc C sZ t � t jt j��@}t�|| j� |�� | j�|� � � | �
ddddd � W d Q R X d S )N�d g �?�send� Xi@
) r r r r rB r6 rC r
r: � getsocknamer5 )r �servr r r
�testSend� s
zTCPTimeoutTestCase.testSendc C s` t � t jt j��F}t�|| j� |�� | j�|� � � | �
ddddd |� � � W d Q R X d S )NrE g �?ZsendtorG i@
) r r r r rB r6 rC r
r: rH r5 )r rI r r r
�
testSendto s z TCPTimeoutTestCase.testSendtoc C sZ t � t jt j��@}t�|| j� |�� | j�|� � � | �
ddddd � W d Q R X d S )NrE g �?ZsendallrG i@
) r r r r rB r6 rC r
r: rH r5 )r rI r r r
� testSendall
s
z TCPTimeoutTestCase.testSendallN)
r& r' r( r r �unittestZskipIfr@ rA rD rJ rK rL r r r r
r7 � s U
r7 c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�UDPTimeoutTestCasec C s t � t jt j�| _d S )N)r r Z
SOCK_DGRAMr
)r r r r
r s zUDPTimeoutTestCase.setUpc C s | j �� d S )N)r
r )r r r r
r s zUDPTimeoutTestCase.tearDownc C s$ t �| j| j� | �dddd� d S )Nr g �?Zrecvfromi )r rB r
r6 r5 )r r r r
�testRecvfromTimeout s z&UDPTimeoutTestCase.testRecvfromTimeoutN)r& r' r( r r rO r r r r
rN s rN c C s t �d� t �ttt� d S )Nr )r ZrequiresZ run_unittestr r7 rN r r r r
� test_main' s
rP �__main__)� functoolsrM Ztestr Zis_resource_enabledZ
skip_expectedr- r< r � lru_cacher ZTestCaser r) r7 rN rP r& r r r r
�<module> s M'