| Server IP : 118.27.122.248 / Your IP : 216.73.216.124 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 dlmZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlmZ d dlZd dlZd dlZd dlZd dlZd dlZy d dlZW n ek
r� dZY nX y d dlZW n ek
�r dZY nX ejZdj d�Z dZ yd dl Z d dl!Z!W n ek
�rL dZ dZ!Y nX y d dl"Z"W n ek
�rt dZ"Y nX dd � Z#d
d � Z$d d
� Z%e#� Z&e$� Z'e%� Z(ejd�j)Z*G dd� de j+�Z,G dd� de j+�Z-G dd� de j+�Z.G dd� de j+�Z/G dd� de j+�Z0G dd� d�Z1G dd � d e,e1�Z2G d d � d e-e1�Z3G d d � d e/e1�Z4G d!d"� d"e0e1�Z5G d#d$� d$e2�Z6G d%d&� d&e j+e1�Z7G d'd(� d(e j+�Z8G d)d*� d*e8�Z9G d+d,� d,e.e8e1�Z:G d-d.� d.e9e:�Z;G d/d0� d0e8�Z<G d1d2� d2e<�Z=G d3d4� d4e8�Z>G d5d6� d6e>�Z?G d7d8� d8e>�Z@G d9d:� d:e>�ZAG d;d<� d<e>�ZBG d=d>� d>eB�ZCd?d@� ZDdAdB� ZEdCdD� ZFG dEdF� dFe j+�ZGe jHe&dG�G dHdI� dIe j+��ZIe jHe&dG�e jHe dJ�G dKdL� dLe4���ZJe jHe'dM�G dNdO� dOe j+��ZKe jHe'dM�e jHe dJ�G dPdQ� dQe5���ZLe jHe dJ�G dRdS� dSe6��ZMe jHe dJ�G dTdU� dUe3��ZNG dVdW� dWe.�ZOG dXdY� dYeO�ZPG dZd[� d[eO�ZQG d\d]� d]eO�ZRG d^d_� d_eO�ZSG d`da� daeO�ZTG dbdc� dceO�ZUG ddde� deeU�ZVG dfdg� dgeV�ZWG dhdi� dieV�ZXG djdk� dkeO�ZYG dldm� dmeY�ZZG dndo� doeY�Z[G dpdq� dqePeY�Z\G drds� dse j+�Z]G dtdu� dueU�Z^G dvdw� dweU�Z_G dxdy� dyeQeSe:e@�Z`eEejdz�e jHe dJ�G d{d|� d|eXe`���ZaeEejd}�e jHe dJ�G d~d� de[e`���ZbeEejd��e jHe dJ�G d�d�� d�e\e`���ZcG d�d�� d�eQeSe:eC�ZdeEejdz�e jHejed��eFd�d��e jHe dJ�G d�d�� d�eXed�����ZfeEejd}�e jHejed��eFd�d��e jHe dJ�G d�d�� d�e[ed�����ZgeEejd��e jHejed��eFd�d��e jHe dJ�G d�d�� d�e\ed�����ZheEejd}�e jHejed��eEed��eFd�d��e jHe dJ�G d�d�� d�e_ed������ZieEejd��e jHejed��eEed��eFd�d��e jHe dJ�G d�d�� d�ePe_ed������ZjG d�d�� d�eTe;e?�ZkeEejdz�e jHe dJ�G d�d�� d�eWek���ZleEejd}�e jHe dJ�G d�d�� d�e[eZek���ZmeEejd��e jHe dJ�G d�d�� d�e\eZek���ZnG d�d�� d�eReTe;eA�ZoeEejdz�eFd�d�d��e jHe dJ�G d�d�� d�eWeo����ZpeEejd}�eFd�d�d��e jHe dJ�G d�d�� d�e[eZeo����ZqeEejd��eFd�d�d��e jHe dJ�G d�d�� d�e\eZeo����ZrG d�d�� d�eTe;e=�ZseEejdz�eEed��e jHe dJ�G d�d�� d�eWes����ZteEejd}�eEed��e jHe dJ�G d�d�� d�e[eZes����ZueEejd��eEed��e jHe dJ�G d�d�� d�e\eZes����ZveEejdzd}�eEed�d�d��e jHe dJ�G d�d�� d�e^es����ZweEejdzd��eEed�d�d��e jHe dJ�G d�d�� d�ePe^es����ZxG d�d�� d�e j+�ZyeEed��e jHezed���
pezed��d��G d�d�� d�eye@���Z{eEed��e jHezed���
p<ezed��d��e jHe dJ�G d�d�� d�eye.e9e?����Z|e jHe dJ�G d�d�� d�e2��Z}e jHe dJ�G d�d d�e7��Z~e jHe dJ�G d�dĄ d�e2��Ze jHe dJ�G d�dƄ d�e6��Z�G d�dȄ d�e��Z�G d�dʄ d�e��Z�G d�d̄ d�e��Z�G d�d΄ d�e��Z�G d�dЄ d�e��Z�G d�d҄ d�e��Z�G d�dԄ d�e��Z�G d�dք d�e�eM�Z�G d�d d�e j+�Z�e jHe dJ�G d�dڄ d�e,e1��Z�e jHe dJ�G d�d܄ d�e,e1��Z�G d�dބ d�e,�Z�G d�d� d�e-�Z�G d�d� d�e j+�Z�e jHe j�d�kd�G d�d� d�e j+��Z�e jHezed��d�G d�d� d�e j+��Z�e jHe dJ�G d�d� d�e6��Z�d�Z�d�Z�d�Z�d�d� Z�e jHe�� d�G d�d� d�e j+��Z�e jHe�� d�G d�d�� d�e j+e1��Z�e jHe dJ�G d�d�� d�e2��Z�G d�d�� d�e j+�Z�e jHezed��d��G d�d�� d�e j+��Z�e jHe
j�d�kd��e jHe�d �G �d�d� �de,���Z�e jHe dJ�G �d�d� �de2��Z�e jHe dJ�e jHeze
�d��d�G �d�d� �de����Z�e jHe(�d �G �d
�d � �d e j+��Z�e jHe j�j��d ��d
�G �d�d� �de j+��Z��d�d� Z�e��dk�
r�e�� dS ( � N)�support)�proxyFu Michael Gilfix was hereሴ
zutf-8g N@c C s> yt j t jt jt j�} W n ttfk
r0 dS X | j� dS )NFT)�socket�PF_CAN�SOCK_RAW�CAN_RAW�AttributeError�OSError�close)�s� r �0/opt/alt/python36/lib64/python3.6/test_socket.py�_have_socket_can1 s r c C s< yt j t jt jd�} W n ttfk
r. dS X | j� dS )Nr FT)r �PF_RDS�SOCK_SEQPACKETr r r
)r r r r
�_have_socket_rds; s r c C s< yt j t jt jd�} W n ttfk
r. dS X | j� dS )Nr FT)r �AF_ALGr r r r
)r r r r
�_have_socket_algE s r �ic @ s e Zd Zdd� Zdd� ZdS )�
SocketTCPTestc C s. t j t jt j�| _tj| j�| _| jj� d S )N)r �AF_INET� SOCK_STREAM�servr � bind_port�port�listen)�selfr r r
�setUpZ s zSocketTCPTest.setUpc C s | j j� d | _ d S )N)r r
)r r r r
�tearDown_ s
zSocketTCPTest.tearDownN)�__name__�
__module__� __qualname__r r r r r r
r X s r c @ s e Zd Zdd� Zdd� ZdS )�
SocketUDPTestc C s$ t j t jt j�| _tj| j�| _d S )N)r r �
SOCK_DGRAMr r r r )r r r r
r e s zSocketUDPTest.setUpc C s | j j� d | _ d S )N)r r
)r r r r
r i s
zSocketUDPTest.tearDownN)r r r! r r r r r r
r" c s r" c s8 e Zd Zer0� fdd�Z� fdd�Z� fdd�Z� ZS )�ThreadSafeCleanupTestCasec s t � j||� tj� | _d S )N)�super�__init__� threading�RLock�
_cleanup_lock)r �args�kwargs)� __class__r r
r& u s z"ThreadSafeCleanupTestCase.__init__c
s | j � t� j||�S Q R X d S )N)r) r% �
addCleanup)r r* r+ )r, r r
r- y s z$ThreadSafeCleanupTestCase.addCleanupc
s | j � t� j||�S Q R X d S )N)r) r% �
doCleanups)r r* r+ )r, r r
r. } s z$ThreadSafeCleanupTestCase.doCleanups)r r r! r' r& r- r. �
__classcell__r r )r, r
r$ m s r$ c @ sD e Zd ZdZdZdZeje�ZdZ e deje �d 7 Z dd� Z
d S )
�
SocketCANTestZvcan0� z=IB3x8sz@3I4l2I�x� c C sb t j t jt jt j�| _| j| jj� y| jj| jf� W n$ t k
r\ | j
d| j � Y nX d S )Nz%network interface `%s` does not exist) r r r r r r- r
�bind� interfacer �skipTest)r r r r
r � s zSocketCANTest.setUpN) r r r! r5 �bufsize�
can_frame_fmt�struct�calcsizeZcan_frame_size�bcm_cmd_msg_fmtr r r r r
r0 � s
r0 c @ s e Zd ZdZdd� ZdS )�
SocketRDSTesti c C sX t j t jt jd�| _| j| jj� ytj| j�| _W n t k
rR | j
d� Y nX d S )Nr zunable to bind RDS socket) r r r r r- r
r r r r r6 )r r r r
r � s zSocketRDSTest.setUpN)r r r! r7 r r r r r
r< � s r< c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�ThreadableTestc C s$ | j | _| j| _| j| _ | j| _d S )N)r �_ThreadableTest__setUpr �_ThreadableTest__tearDown�_setUp� _tearDown)r r r r
r& � s zThreadableTest.__init__c C s | j j� d S )N)� server_ready�set)r r r r
�serverExplicitReady� s z"ThreadableTest.serverExplicitReadyc C s� t j� | _| jj� tj� | _tj� | _tj� | _t j
d�| _ d| _ | j � }|j
d�}||d d � }t| d| �}tj| j|f�| _z&y | j� W n d| _ � Y nX W d | jj� X | jj� d S )N� F�.�_T)r Zwait_threads_exit� wait_threads� __enter__r' �EventrB � client_ready�done�queue�Queue�server_crashed�id�rfind�getattr�thread�start_new_thread� clientRunZ
client_threadr> rC �wait)r Z
methodnamer Z test_methodr r r
r@ � s(
zThreadableTest._setUpc C s> | j � | jj� | jjd d d � | jj� r:| jj� }|�d S )N)r? rL rV rH �__exit__rM Zqsize�get)r �excr r r
rA s
zThreadableTest._tearDownc * C s� | j j� zFy | j� W n4 tk
rL } z| jj|� | j� d S d }~X nX W d | jj� X | j rp| j� d S t
|d�s�t d��z>y
|� W n. tk
r� } z| jj|� W Y d d }~X nX W d | j� X d S )N�__call__z%test_func must be a callable function) rB rV � clientSetUp�
BaseExceptionrM �put�clientTearDownrK rC rO �hasattr� TypeError)r Z test_func�er r r
rU s$
"zThreadableTest.clientRunc C s t d��d S )Nz clientSetUp must be implemented.)�NotImplementedError)r r r r
r[ 2 s zThreadableTest.clientSetUpc C s | j j� tj� d S )N)rL rC rS �exit)r r r r
r^ 5 s
z ThreadableTest.clientTearDownN)
r r r! r& rD r@ rA rU r[ r^ r r r r
r= � s & r= c @ s& e Zd Zd dd�Zdd� Zdd� ZdS )
�ThreadedTCPSocketTest�runTestc C s t j| |d� tj| � d S )N)�
methodName)r r& r= )r rf r r r
r& ; s z ThreadedTCPSocketTest.__init__c C s t j t jt j�| _d S )N)r r r �cli)r r r r
r[ ? s z!ThreadedTCPSocketTest.clientSetUpc C s | j j� d | _ tj| � d S )N)rg r
r= r^ )r r r r
r^ B s
z$ThreadedTCPSocketTest.clientTearDownN)re )r r r! r& r[ r^ r r r r
rd 9 s
rd c @ s& e Zd Zd dd�Zdd� Zdd� ZdS )
�ThreadedUDPSocketTestre c C s t j| |d� tj| � d S )N)rf )r" r& r= )r rf r r r
r& I s z ThreadedUDPSocketTest.__init__c C s t j t jt j�| _d S )N)r r r# rg )r r r r
r[ M s z!ThreadedUDPSocketTest.clientSetUpc C s | j j� d | _ tj| � d S )N)rg r
r= r^ )r r r r
r^ P s
z$ThreadedUDPSocketTest.clientTearDownN)re )r r r! r& r[ r^ r r r r
rh G s
rh c @ s& e Zd Zd dd�Zdd� Zdd� ZdS )
�ThreadedCANSocketTestre c C s t j| |d� tj| � d S )N)rf )r0 r& r= )r rf r r r
r& W s z ThreadedCANSocketTest.__init__c C sD t j t jt jt j�| _y| jj| jf� W n tk
r> Y nX d S )N)r r r r rg r4 r5 r )r r r r
r[ [ s
z!ThreadedCANSocketTest.clientSetUpc C s | j j� d | _ tj| � d S )N)rg r
r= r^ )r r r r
r^ d s
z$ThreadedCANSocketTest.clientTearDownN)re )r r r! r& r[ r^ r r r r
ri U s
ri c @ s& e Zd Zd dd�Zdd� Zdd� ZdS )
�ThreadedRDSSocketTestre c C s t j| |d� tj| � d S )N)rf )r< r& r= )r rf r r r
r& k s z ThreadedRDSSocketTest.__init__c C sN t j t jt jd�| _y | jjtdf� | jj� | _W n tk
rH Y nX d S )Nr ) r r r rg r4 �HOST� getsockname�cli_addrr )r r r r
r[ o s z!ThreadedRDSSocketTest.clientSetUpc C s | j j� d | _ tj| � d S )N)rg r
r= r^ )r r r r
r^ z s
z$ThreadedRDSSocketTest.clientTearDownN)re )r r r! r& r[ r^ r r r r
rj i s
rj c @ s6 e Zd Zd
dd�Zdd� Zdd� Zdd � Zd
d � Zd S )�SocketConnectedTestre c C s t j| |d� d S )N)rf )rd r& )r rf r r r
r& � s z SocketConnectedTest.__init__c C s* t j| � | j� | jj� \}}|| _d S )N)rd r rD r �accept�cli_conn)r �conn�addrr r r
r � s
zSocketConnectedTest.setUpc C s | j j� d | _ tj| � d S )N)rp r
rd r )r r r r
r � s
z SocketConnectedTest.tearDownc C s( t j| � | jjt| jf� | j| _d S )N)rd r[ rg �connectrk r � serv_conn)r r r r
r[ � s
z SocketConnectedTest.clientSetUpc C s | j j� d | _ tj| � d S )N)rt r
rd r^ )r r r r
r^ � s
z"SocketConnectedTest.clientTearDownN)re )r r r! r& r r r[ r^ r r r r
rn s
rn c @ s6 e Zd Zd
dd�Zdd� Zdd� Zdd � Zd
d � Zd S )�SocketPairTestre c C s t jj| |d� tj| � d S )N)rf )�unittest�TestCaser& r= )r rf r r r
r& � s zSocketPairTest.__init__c C s t j� \| _| _d S )N)r �
socketpairr rg )r r r r
r � s zSocketPairTest.setUpc C s | j j� d | _ d S )N)r r
)r r r r
r � s
zSocketPairTest.tearDownc C s d S )Nr )r r r r
r[ � s zSocketPairTest.clientSetUpc C s | j j� d | _ tj| � d S )N)rg r
r= r^ )r r r r
r^ � s
z SocketPairTest.clientTearDownN)re )r r r! r& r r r[ r^ r r r r
ru � s
ru c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�SocketTestBasec C s | j � | _| j� d S )N)� newSocketr �
bindServer)r r r r
r � s
zSocketTestBase.setUpc C s | j | j� | jj� | _d S )N)�bindSockr rl � serv_addr)r r r r
r{ � s zSocketTestBase.bindServerc C s | j j� d | _ d S )N)r r
)r r r r
r � s
zSocketTestBase.tearDownN)r r r! r r{ r r r r r
ry � s ry c s e Zd Z� fdd�Z� ZS )�SocketListeningTestMixinc s t � j� | jj� d S )N)r% r r r )r )r, r r
r � s
z SocketListeningTestMixin.setUp)r r r! r r/ r r )r, r
r~ � s r~ c s< e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Z� ZS ) �ThreadedSocketTestMixinc s t � j||� tj| � d S )N)r% r& r= )r r* r+ )r, r r
r& � s z ThreadedSocketTestMixin.__init__c C s | j � | _| j� d S )N)�newClientSocketrg �
bindClient)r r r r
r[ � s
z#ThreadedSocketTestMixin.clientSetUpc C s | j � S )N)rz )r r r r
r� � s z'ThreadedSocketTestMixin.newClientSocketc C s | j | j� | jj� | _d S )N)r| rg rl rm )r r r r
r� � s z"ThreadedSocketTestMixin.bindClientc C s | j j� d | _ tj| � d S )N)rg r
r= r^ )r r r r
r^ � s
z&ThreadedSocketTestMixin.clientTearDown) r r r! r& r[ r� r� r^ r/ r r )r, r
r � s
r c s@ e Zd Z� fdd�Z� fdd�Z� fdd�Z� fdd�Z� ZS ) �ConnectedStreamTestMixinc s* t � j� | j� | jj� \}}|| _d S )N)r% r rD r ro rp )r rq rr )r, r r
r s
z ConnectedStreamTestMixin.setUpc s | j j� d | _ t� j� d S )N)rp r
r% r )r )r, r r
r s
z!ConnectedStreamTestMixin.tearDownc s$ t � j� | jj| j� | j| _d S )N)r% r[ rg rs r} rt )r )r, r r
r[ s
z$ConnectedStreamTestMixin.clientSetUpc s8 y| j j� d | _ W n tk
r( Y nX t� j� d S )N)rt r
r r% r^ )r )r, r r
r^ s
z'ConnectedStreamTestMixin.clientTearDown)r r r! r r r[ r^ r/ r r )r, r
r� � s r� c s$ e Zd Z� fdd�Zdd� Z� ZS )�UnixSocketTestBasec s( t j� | _| jtj| j� t� j� d S )N)�tempfileZmkdtemp�dir_pathr- �os�rmdirr% r )r )r, r r
r & s
zUnixSocketTestBase.setUpc C s, t j| jd�}tj||� | jtj|� d S )N)�dir)r� Zmktempr� r �bind_unix_socketr- �unlink)r �sock�pathr r r
r| + s zUnixSocketTestBase.bindSock)r r r! r r| r/ r r )r, r
r� s r� c @ s e Zd Zdd� ZdS )�UnixStreamBasec C s t j t jt j�S )N)r �AF_UNIXr )r r r r
rz 3 s zUnixStreamBase.newSocketN)r r r! rz r r r r
r� 0 s r� c s( e Zd ZeZ� fdd�Zdd� Z� ZS )� InetTestBasec s t � j� | jd | _d S )NrE )r% r r} r )r )r, r r
r < s
zInetTestBase.setUpc C s t j|| jd� d S )N)�host)r r r� )r r� r r r
r| @ s zInetTestBase.bindSock)r r r! rk r� r r| r/ r r )r, r
r� 7 s r� c @ s e Zd Zdd� ZdS )� TCPTestBasec C s t j t jt j�S )N)r r r )r r r r
rz F s zTCPTestBase.newSocketN)r r r! rz r r r r
r� C s r� c @ s e Zd Zdd� ZdS )� UDPTestBasec C s t j t jt j�S )N)r r r# )r r r r
rz L s zUDPTestBase.newSocketN)r r r! rz r r r r
r� I s r� c @ s e Zd Zdd� ZdS )�SCTPStreamBasec C s t j t jt jt j�S )N)r r r � IPPROTO_SCTP)r r r r
rz R s zSCTPStreamBase.newSocketN)r r r! rz r r r r
r� O s r� c @ s e Zd ZejZdS )�
Inet6TestBaseN)r r r! r �HOSTv6r� r r r r
r� W s r� c @ s e Zd Zdd� ZdS )� UDP6TestBasec C s t j t jt j�S )N)r �AF_INET6r# )r r r r
rz _ s zUDP6TestBase.newSocketN)r r r! rz r r r r
r� \ s r� c s* dd� � � �fdd�}dd� }| r&|S |S )Nc _ s d S )Nr )r* r+ r r r
� client_passn s z%skipWithClientIf.<locals>.client_passc s* t j��| �}t| t�s&� fdd�|_|S )Nc s � S )Nr )�f)r� r r
�<lambda>s s z3skipWithClientIf.<locals>.skipdec.<locals>.<lambda>)rv �skip�
isinstance�type� client_skip)�objZretval)r� �reasonr r
�skipdecp s
z!skipWithClientIf.<locals>.skipdecc S s" t | t�pt| d�s dd� | _| S )Nr� c S s | S )Nr )r� r r r
r� w s z5skipWithClientIf.<locals>.noskipdec.<locals>.<lambda>)r� r� r_ r� )r� r r r
� noskipdecu s
z#skipWithClientIf.<locals>.noskipdecr )Z conditionr� r� r� r )r� r� r
�skipWithClientIfe s r� c s0 � fdd�|D �}t |ddjdd� |D �� �S )Nc s g | ]}t � |�s|�qS r )r_ )�.0�name)r� r r
�
<listcomp>� s z requireAttrs.<locals>.<listcomp>z don't have z, c s s | ]
}|V qd S )Nr )r� r� r r r
� <genexpr>� s z requireAttrs.<locals>.<genexpr>)r� �join)r� Z
attributes�missingr )r� r
� requireAttrs| s r� c G s� d }dd� | D �}|r0ddj dd� |D �� }nPdd� | D �}ytj|� }W n* tk
rv } zt|�}W Y d d }~X n
X |j� t|d k djdj d d� | D ��|��S )
Nc S s& g | ] }t |t�rtt|� r|�qS r )r� �strr_ r )r� r� r r r
r� � s z!requireSocket.<locals>.<listcomp>z don't have z, c s s | ]
}|V qd S )Nr )r� r� r r r
r� � s z requireSocket.<locals>.<genexpr>c S s$ g | ] }t |t�r tt|�n|�qS r )r� r� rR r )r� r� r r r
r� � s z can't create socket({0}): {1}c s s | ]}t |�V qd S )N)r� )r� �or r r
r� � s )r� r r r� r
r� �format)r* �errr� Zcallargsr ra r r r
�
requireSocket� s r� c @ s� e Zd Zdd� Zdd� Zejedk d�dd� �Zd d
� Z d d � Z
d
d� Z dd� Z dd� Z
dd� Zdd� Zejeed�d�ejeed�d�dd � ��Zejeed �d �d d � �Zejeed �d �d!d"� �Zejeed#�d$�d%d&� �Zd'd(� Zd)d*� Zejd+d,� �Zd-d.� Z d/d0� Z ejeed1�d2�d3d4� �Z ejeed5�d6�d7d8� �Z ejeed5�d6�d9d:� �Z ejeed;�d<�d=d>� �Z!ejeed;�d<�d?d@� �Z"dAdB� Z#dCdD� Z$dEdF� Z%dGdH� Z&dIdJ� Z'dKdL� Z(dMdN� Z)eje*j+dOkdP�dQdR� �Z,eje*j+dOkdP�ejeedS�dT�dUdV� ��Z-dWdX� Z.dYdZ� Z/ejej0d[�d\�d]d^� �Z1d_d`� Z2dadb� Z3dcdd� Z4dedf� Z5dgdh� Z6didj� Z7dkdl� Z8dmdn� Z9dodp� Z:dqdr� Z;ejdsdt� �Z<ejej=du�dvdw� �Z>dxdy� Z?ej@e*j+dOkdz�d{d|� �ZAejee*d}�d~�dd�� �ZBdS )��GeneralModuleTestsc C s< dd l }| jtj|jk� tj� }| j|tj� |j� d S )Nr )�_socket�
assertTruer Z
SocketType�assertIsInstancer
)r r� r r r r
� test_SocketType_is_socketobject� s
z2GeneralModuleTests.test_SocketType_is_socketobjectc C s� t j t jt j�}|�� | jd|j� t|�� | jdt j t|�� | jdt j t|�� | jdt|�� | jdt|�� |jd
� | jdt|�� | jt|j � �t|�� W d Q R X | jd t|�� | jdt|�� d S ) Nzfd=%iz family=%sztype=%szproto=0Zraddr� 127.0.0.1r Zladdrz[closed])r� r )
r r r �assertIn�fileno�repr� assertNotInr4 r� rl )r r r r r
� test_repr� s
"z GeneralModuleTests.test_reprNzneed _socket modulec C sr t jt jt j�}z.d|j� |j|j|jf }| jt |�|� W d |j
� X d|j|j|jf }| jt |�|� d S )Nz4<socket object, fd=%s, family=%s, type=%s, proto=%s>z4<socket object, fd=-1, family=%s, type=%s, proto=%s>) r� r r r r� �familyr� �proto� assertEqualr� r
)r r �expectedr r r
�test_csocket_repr� s
z$GeneralModuleTests.test_csocket_reprc C sh t j t jt j�}t|�}| j|j� |j� � |j� d }y |j� W n tk
rX Y n X | jd� d S )NzSocket proxy still exists) r r r r r� r� r
�ReferenceError�fail)r r �pr r r
� test_weakref� s z GeneralModuleTests.test_weakrefc C sr d}| j t|d d��
t�W d Q R X | j t|d d�� tj�W d Q R X | j t|d d�� tj�W d Q R X d S )Nz$Error raising socket exception (%s).r )�msgz
socket.herrorzsocket.gaierror)� assertRaisesr r �herror�gaierror)r r� r r r
�testSocketError� s z"GeneralModuleTests.testSocketErrorc K C sF t j t jt j�}| j|j� |jd� |j� }| jt��}|j d|� W d Q R X | j
t |j �d� | jt��}|j d|� W d Q R X | j
t |j �d� | jt��}|j dd � W d Q R X | j
dt |j �� | jt��}|j dd|� W d Q R X | j
t |j �d� | jt��}|j dd|� W d Q R X | j
t |j �d� | jt��}|j ddd � W d Q R X | j
dt |j �� | jt��}|j dd |� W d Q R X | j
d
t |j �� | jt��}|j dd d � W d Q R X | j
d
t |j �� | jt��}|j d� W d Q R X | j
d t |j �� | jt��}|j dd|d � W d Q R X | j
d
t |j �� d S )N� r u ☠z*a bytes-like object is required, not 'str'y @z.a bytes-like object is required, not 'complex's fooz not NoneType�barzan integer is requiredz (1 given)� z (4 given))r� r )r r r# r- r
r4 rl r� r` �sendtor� r� � exceptionr� )r r Zsockname�cmr r r
�testSendtoErrors� sL
z#GeneralModuleTests.testSendtoErrorsc C s4 t j t j t j t j t j t j t j t j d S )N) r r r r# r �SOCK_RDMr �
SOL_SOCKET� SO_REUSEADDR)r r r r
�testCrucialConstants s z'GeneralModuleTests.testCrucialConstantsc C s� t j� }yt j|�}W n tk
r4 | jd� Y nX | j|jd�dkd� yt j|�\}}}W n tk
r~ | jd� Y nX ||g| }t j|�}||kr�| j d|t
|�f � d S )Nzname lookup failurerF r zError resolving host to ip.z=Error testing host resolution mechanisms. (fqdn: %s, all: %s)) r � gethostname�
gethostbynamer r6 r� �find�
gethostbyaddrZgetfqdnr� r� )r ZhostnameZipZhname�aliasesZipaddrsZall_host_namesZfqhnr r r
�testHostnameRes s
z"GeneralModuleTests.testHostnameResc C sT x&t jddgD ]}| jtj|�|� qW x&t jgD ]}| j|tj|�d � q2W d S )Nz10.0.0.1z255.255.255.255� )r rk r� r r� r� r� )r rr r� r r r
�test_host_resolution* s z'GeneralModuleTests.test_host_resolutionc C sZ d}xPdD ]H}| j t�� tj|� W d Q R X | j t|d�� tj|� W d Q R X q
W d S ) Nz[resolving an invalid IP address did not raise OSError; can be caused by a broken DNS server�0.1.1.~1�1+.1.1.1�::1q�::1::2�1:1:1:1:1:1:1:1:1)r� )r� r� r� r� r� )r� r r r� r� )r Z explanationrr r r r
� test_host_resolution_bad_address3 s z3GeneralModuleTests.test_host_resolution_bad_address� sethostnamez test needs socket.sethostname()r� z test needs socket.gethostname()c C s� t j� }yt jd� W n< tk
rR } z |jtjkr@| jd� n� W Y d d }~X nX z.| jt j� d� t jd� | jt j� d� W d t j|� X d S )N�newztest should be run as roots barr� )r r� r� r �errnoZEPERMr6 r� )r Zoldhnra r r r
�test_sethostnameB s
z#GeneralModuleTests.test_sethostname� if_nameindexz$socket.if_nameindex() not available.c C s� t j� }xx|D ]p\}}| j|t� | j|t� | j|d� t j|�}| j|t� | j||� t j|�}| j|t� | j||� qW d S )Nr ) r r� r� �intr� �
assertGreater�if_nametoindexr� �if_indextoname)r Z
interfaces�indexr� Z_index�_namer r r
�testInterfaceNameIndexV s
z)GeneralModuleTests.testInterfaceNameIndexc C sD | j ttjd� | j ttjd� | j ttjd� | j ttjd� d S )Nr Z _DEADBEEF)r� r r r� r� r` )r r r r
� testInvalidInterfaceNameIndexf s z0GeneralModuleTests.testInvalidInterfaceNameIndex� getrefcountz test needs sys.getrefcount()c C sL yt jt�}tjtd� W n, tk
rF t jt�|krB| jd� Y nX d S )Nr z$socket.getnameinfo loses a reference)�sysr� r r � getnameinfor` r� )r Zorigr r r
�testRefCountGetNameInfop s
z*GeneralModuleTests.testRefCountGetNameInfoc C s* yt jdd� W n tk
r$ Y nX d S )Nr2 r )r2 r r r )r r� r )r r r r
�testInterpreterCrash| s z'GeneralModuleTests.testInterpreterCrashc C s� t jdt jdt jdt jdi}xt|j� D ]h\}}d|> d }x,d D ]$}| j||@ ||||@ ��|@ � q@W ||�}| j||@ |� | jt|d � q&W d S )
N� � rE r � r� �gE#�2Tv�" � ��)r rE r� r� r� r� r� l ) r �htonl�ntohl�htons�ntohs�itemsr� r� �
OverflowError)r Zsizes�func�size�maskr Zswappedr r r
�testNtoH� s
$zGeneralModuleTests.testNtoHc C s� ddddddg}dddddd g}x4|D ],}t j|� t j|� t j|� t j|� q&W xL|D ]D}| jtt j|� | jtt j|� | jtt j|� | jtt j|� q\W d S )
NrE r� � ���������r r r )r r� r� r� r� r� r )r Z good_valuesZ
bad_values�kr r r
�testNtoHErrors� s
z!GeneralModuleTests.testNtoHErrorsc C s | j }tjjd�s tjdkr"d}nd}x8|D ],}ytj|d
�}P W q, tk
rV Y q,X q,W t�tj|�}|||� ytj|d �}W n tk
r� d }Y n X |||� |tj|�|� |tj|d
�|� |d k r�|tj|d �|� | jt tjd� | jt tjd
� d S )N�freebsd�netbsd� gnukfreebsd�linux�darwin�daytime�qotd�domain�echoZtcpZudprE i )r r
r )r r )r r r )r r r r )
r� r� �platform�
startswithr Z
getservbynamer Z
getservbyportr� r )r �eqZservicesZservicer Zport2Zudpportr r r
�
testGetServBy� s2
z GeneralModuleTests.testGetServByc C s� | j tj� d � tj� }| j |j� d � |j� tjd� | j tj� d� tj� }| j |j� d� |j� tjd � | j tj� d � tj� }| j |j� d � |j� | jttjd� | jttjd� d S )N�
rE Zspamr ) r� r �getdefaulttimeout�
gettimeoutr
�setdefaulttimeoutr� �
ValueErrorr` )r r r r r
�testDefaultTimeout� s
z%GeneralModuleTests.testDefaultTimeout� inet_atonz test needs socket.inet_aton()c C s( | j dtjd�� | j dtjd�� d S )N� r� z0.0.0.0� �z255.255.255.255s s ����)r� r r )r r r r
� testIPv4_inet_aton_fourbytes� s z/GeneralModuleTests.testIPv4_inet_aton_fourbytes� inet_ptonz test needs socket.inet_pton()c s& ddl m}m�m� � �fdd�}�fdd�}�jd|d�� �jd|d �� �jd
|d �� �jd |d
�� �jd|d�� ||d� ||d� ||d� ||d� ||d� �jd|d�� �jd|d �� �jd
|d �� �jd|d�� ||d� ||d� ||d� ||d� ||d� d S )Nr )r r# r c s
�� | �S )Nr )�a)r r# r r
r� � s z5GeneralModuleTests.testIPv4toString.<locals>.<lambda>c s � j ttf| |�S )N)r� r r )r r$ )r r r
r� � s s z0.0.0.0s � � z 255.0.255.0s ����z170.170.170.170s z1.2.3.4s ����z255.255.255.255z0.0.0.z 300.0.0.0za.0.0.0z 1.2.3.4.5z::1)r r r# r r� )r r� �g�
assertInvalidr )r r# r r
�testIPv4toString� s,
z#GeneralModuleTests.testIPv4toStringc s� y&ddl m�m� m} |s$�jd� W n tk
rD �jd� Y nX tjdkr�y�� d� W n6 tk
r� } z|j dkr��jd� W Y d d }~X nX � �fd d
����fd d
�}�j
d2�d�� �j
d3�d�� �j
d5�d�� �j
d�d�� �j
d8�d�� �j
d:�d�� |d� |d � |d � |d � |d � |d � |d!� |d"� |d#� �j
d<�d%�� �j
d?�d)�� �j
d*�d+�� |d,� |d-� |d.� |d/� |d0� |d1� d S )@Nr )r# r� �has_ipv6zIPv6 not availablez+could not import needed symbols from socket�win32z::i&' zIPv6 might not be supportedc s
�� | �S )Nr )r$ )r� r# r r
r� s z5GeneralModuleTests.testIPv6toString.<locals>.<lambda>c s �j ttf� | �S )N)r� r r )r$ )r� r r r
r� s r r� z0::0s � z1::s E�v� V�� �$��z$45ef:76cb:1a:56ef:afeb:bac:1924:aeaes �B
�r� s ' T zad42:abc::127:0:254:2s
� z12:a::z0x20::z:::z::0::z1::abc::z 1::abc::defz 1:2:3:4:5:6:z 1:2:3:4:5:6z1:2:3:4:5:6:7:8:z1:2:3:4:5:6:7:8:0s �*@z::254.42.23.64s Br3 s ���*@z42::a29b:254.42.23.64s B�� �����*@z"42:a8b9:0:2:ffff:a29b:254.42.23.64z255.254.253.252z 1::260.2.3.0z 1::0.be.e.0z1:2:3:4:5:6:7:1.2.3.4z ::1.2.3.4:0z0.100.200.0:3:4:5:6:7:8s s s s s s �B
� s �B
� ' T s s
s s �*@s s
B s B ���*@) r r# r� r( r6 � ImportErrorr� r r �winerrorr� )r r( ra r& r )r� r� r# r r
�testIPv6toString s^
z#GeneralModuleTests.testIPv6toString� inet_ntopz test needs socket.inet_ntop()c s ddl m}m�m� � �fdd�}�fdd�}�jd|d�� �jd|d �� �jd
|d �� �jd |d
�� ||d� ||d� ||d� �jd|td ��� �jd|d�� �jd|d �� �jd
|d �� ||d� ||d� ||d� �jd|td ��� d S )Nr )� inet_ntoar/ r c s
�� | �S )Nr )r$ )r r/ r r
r� M s z5GeneralModuleTests.testStringToIPv4.<locals>.<lambda>c s � j ttf| |�S )N)r� r r )r r$ )r r r
r� N s z1.0.1.0s z
170.85.170.85s �U�Uz255.255.255.255s ����z1.2.3.4s r r � r� s s s s s s )r r0 r/ r r� � bytearray)r r� r% r& r )r r/ r r
�testStringToIPv4I s$
z#GeneralModuleTests.testStringToIPv4c s y&ddl m�m� m} |s$�jd� W n tk
rD �jd� Y nX tjdkr�y�� d� W n6 tk
r� } z|j dkr��jd � W Y d d }~X nX � �fd
d ����fd d �}�j
d
�d�� �j
d�d�� �j
d�d�� �j
d�t d��� |d � |d � |d � d S ) Nr )r/ r� r( zIPv6 not availablez+could not import needed symbols from socketr) r r� i&' zIPv6 might not be supportedc s
�� | �S )Nr )r$ )r� r/ r r
r� t s z5GeneralModuleTests.testStringToIPv6.<locals>.<lambda>c s �j ttf� | �S )N)r� r r )r$ )r� r r r
r� u s z::z::1� � z!aef:b01:506:1001:ffff:9997:55:170s
� ���� Up� � r� s s s s s s s s s ) r r/ r� r( r6 r, r� r r r- r� r2 )r r( ra r& r )r� r� r/ r r
�testStringToIPv6c s.
z#GeneralModuleTests.testStringToIPv6c C s� t j� }tjtjtj�}| j|j� |jd|f� |j� }ytj tj
� �}W n t k
rj | j d� Y nX | j
|d d|fd|d � | j|d |� d S )Nz0.0.0.0zname lookup failurer z
%s invalidrE )r �find_unused_portr r r r- r
r4 rl r� r� r r6 r� r� )r r r� r� Z
my_ip_addrr r r
� testSockName� s z GeneralModuleTests.testSockNamec C s@ t j t jt j�}| j|j� |jt jt j�}| j|dkd� d S )Nr zinitial mode is reuse) r r r r- r
�
getsockoptr� r� � assertFalse)r r� �reuser r r
�testGetSockOpt� s z!GeneralModuleTests.testGetSockOptc C sR t j t jt j�}| j|j� |jt jt jd� |jt jt j�}| j |dkd� d S )NrE r zfailed to set reuse mode)
r r r r- r
�
setsockoptr� r� r; r< )r r� r= r r r
�testSetSockOpt� s
z!GeneralModuleTests.testSetSockOptc C s6 t j t jt j�}|jd� |j� | jt|jd� d S )NrE s spam)r r r �
settimeoutr
r� r �send)r r� r r r
�testSendAfterClose� s
z%GeneralModuleTests.testSendAfterClosec C sp t j � }t j |j� d�j� y |j� W n8 tk
r` } z | j|jtjtjf� W Y d d }~X n X | jd� d S )N)r� z#close() should raise EBADF/ENOTSOCK) r r� r
r r� r� ZEBADFZENOTSOCKr� )r r� r� r r r
�testCloseException� s (z%GeneralModuleTests.testCloseExceptionc C sr t j t jt j�}| j|jt j� tt d�rH| j|jt jt jB t jf� n| j|jt j� | j|j d� |j
� d S )N� SOCK_CLOEXECr ) r r r r� r� r_ r� r� rE r� r
)r r� r r r
�testNewAttributes� s
z$GeneralModuleTests.testNewAttributesc C s� t j � }| j|j� tj� }|d }|d }| jt|jt|f� | jt|jt|f� xft j
� D ]Z}tj� }y|jt|f� W n8 t k
r� } z |j t j
ks�|dkr�� W Y d d }~X q^X P q^W d S )Ni r1 )r r- r
r r9 r� r r4 rk � itertools�countr r� Z
EADDRINUSE)r r� r Zbig_portZneg_portr ra r r r
�test_getsockaddrarg� s z&GeneralModuleTests.test_getsockaddrarg�ntzWindows specificc C s� | j ttjd�� | j ttd�� | j ttd�� | j ttd�� | j ttd�� tj� }| j|j� | jt|jdd � |jtjd � d S )
N�ioctlZ
SIO_RCVALLZ RCVALL_ONZ
RCVALL_OFF�SIO_KEEPALIVE_VALSrE �d r )rE rM rM ) r� r_ r r- r
r� r rK rL )r r r r r
�test_sock_ioctl� s z"GeneralModuleTests.test_sock_ioctl�SIO_LOOPBACK_FAST_PATHz1Loopback fast path support required for this testc C s| t j � }| j|j� y|jt jd� W n< tk
rb } z d}|j|krP| jd� � W Y d d }~X nX | jt |jt jd � d S )NTi=' zQSIO_LOOPBACK_FAST_PATH is defined but doesn't implemented in this Windows version)
r r- r
rK rO r r- r6 r� r` )r r rY Z
WSAEOPNOTSUPPr r r
�test_sio_loopback_fast_path� s
z.GeneralModuleTests.test_sio_loopback_fast_pathc
C s6 yt jdd� W n< t jk
rL } z |jt jkr:| jd� � W Y d d }~X nX x$t jtd �D ]}| jt|�d� q\W t jdd� t jdd� t jd d� t j
r�t jdd� t jtd� t jtd� t jtd � t jtdt j t j �}xR|D ]J\}}}}}| j|t j � | jt
|�d� | j|t j � | jt
|�d � q�W t jtd d
t j �}x&|D ] \}}}}}| j|t j � �qNW t jtd d
d
t j� t jtd d
d
d
t j� t jd d
t jt j d
t j� t jtd �}t jtd d �} | j|| � t jtd t j �}t jtd t j d �} | j|| � t jtd d
t j �}t jtd t j d
�} | j|| � t jtd d
d
t j�}t jtd t jd�} | j|| � t jtd d
d
d
t j�}t jtd t jd�} | j|| � t jd d
t jt j d
t j�}t jd d
t jt j d
t jd�} | j|| � | jtt jdd� tt d��r2yt jdd d
d
d
t j� W n t jk
�r0 Y nX d S )NZ localhost�P zbuggy libc versionr1 z 127.0.0.1z::1ZhttpzAddressFamily.AF_INETzSocketKind.SOCK_STREAMr )r� r )r� )r� )r� )�flags)r� r r� r� r� rR u ��AI_NUMERICSERV)r � getaddrinfor� r� Z EAI_SERVICEr6 rk r� �lenr � IPV6_ENABLEDr r r� ZSOL_TCPZ
AI_PASSIVE� AF_UNSPECr� �UnicodeEncodeErrorr_ rS )
r r� �infoZinfosr� r� rG Zsocktyper$ �br r r
�testGetaddrinfo� sr
z"GeneralModuleTests.testGetaddrinfoc C s | j ttjdd� d S )N�mail.python.orgr )r\ r )r� r r r� )r r r r
�test_getnameinfoD s z#GeneralModuleTests.test_getnameinfoZnetworkznetwork is not enabledc C sP t jd�� tjd� W d Q R X d}tj|� tj|� tj|dtjtj� d S )Nz
python.orgu! испытание.pythontest.netr )r Ztransient_internetr r� Zgethostbyname_exrT rW r )r r r r r
� test_idnaH s
z GeneralModuleTests.test_idnac s� t td� st td� r"� jd� � fdd�}� fdd�}tj� \}}tjtj|�}zv|rd|jd� � jt�� tj d � |j
d
t j � W d Q R X |r�tjtj|� tj d � � jtj
|j
d
t j � W d tj d � tjtj|� |j� |j� X d S ) N�alarmrx z9signal.alarm and socket.socketpair required for this testc s � j ttjd� d S )Nr )r� r �math�acosh)r* )r r r
�
ok_handler_ s z@GeneralModuleTests.check_sendall_interrupted.<locals>.ok_handlerc s � j ttjd� dd d S )Nr rE )r� r r` ra )r* )r r r
�raising_handlera s zEGeneralModuleTests.check_sendall_interrupted.<locals>.raising_handlerg �?rE � xr )r_ �signalr r6 rx �SIGALRMrA r� �ZeroDivisionErrorr_ �sendallr �
SOCK_MAX_SIZE�timeoutr
)r Z with_timeoutrb rc �cr � old_alarmr )r r
�check_sendall_interruptedY s*
z,GeneralModuleTests.check_sendall_interruptedc C s | j d� d S )NF)rm )r r r r
�test_sendall_interruptedx s z+GeneralModuleTests.test_sendall_interruptedc C s | j d� d S )NT)rm )r r r r
�%test_sendall_interrupted_with_timeout{ s z8GeneralModuleTests.test_sendall_interrupted_with_timeoutc C s� t j t jt j�}t|�}| jt��}d }tj� W d Q R X | j|t |j
j d �� t j t jt j�}|j d�}t|�}d }tj� | jt�� d }tj� W d Q R X d S )Nr �rb)
r r r r� Z assertWarns�ResourceWarningr Z
gc_collectr� r� Zwarningr* �makefile)r r� �rr� r� r r r
�test_dealloc_warn~ s
z$GeneralModuleTests.test_dealloc_warnc
C sB t j t jt j��(}|jd�}|j� | jt|�d� W d Q R X d S )Nrp z <_io.BufferedReader name=-1>)r r r rr r
r� r� )r r� �fpr r r
�test_name_closed_socketio� s
z,GeneralModuleTests.test_name_closed_socketioc C s� t j � �p}|jddd�}| j|j� � | j|j� � | j|j� � |j� | jt |j� | jt |j� | jt |j� W d Q R X d S )Nrp r )� buffering)
r rr r� �readabler< �writable�seekabler
r� r )r r� ru r r r
� test_unusable_closed_socketio� s
z0GeneralModuleTests.test_unusable_closed_socketioc C sb x\dD ]T}| j |d��> tj� �*}|j|��}| j|j|� W d Q R X W d Q R X W d Q R X qW d S )Nrs rp �rw�w�wb)�mode)rs rp r| r} r~ )�subTestr rr r� r )r r r� ru r r r
�test_makefile_mode� s
z%GeneralModuleTests.test_makefile_modec C s` xZdD ]R}| j |d��< tj� �(}| jtd�� |j|� W d Q R X W d Q R X W d Q R X qW d S )N�rtr2 �+r$ )r z invalid mode)r� r2 r� r$ )r� r �assertRaisesRegexr rr )r r r� r r r
�test_makefile_invalid_mode� s
z-GeneralModuleTests.test_makefile_invalid_modec
C s� t j � }|�0 x(ttjd �D ]}| jttj||� q W W d Q R X xZttjd �D ]H}tjtjt j|��}| j |t j� tjtjt j
|��}| j |t j
� qRW d S )NrE ) r �range�pickleZHIGHEST_PROTOCOLr� r` �dumps�loadsr r� r )r r� Zprotocolr� r� r r r
� test_pickle� s z GeneralModuleTests.test_picklec C sx x@dD ]8}t j t jt j�� }|jtdf� |j|� W d Q R X qW t j t jt j�� }|jtdf� |j� W d Q R X d S )Nr rE r )r r )r r r r4 rk r )r Zbacklog�srvr r r
�test_listen_backlog� s
z&GeneralModuleTests.test_listen_backlogc C sH dd l }tjtjtj�}|jtdf� | jt|j|j d � |j
� d S )Nr rE ) � _testcapir r r r4 rk r� r r �INT_MAXr
)r r� r� r r r
� test_listen_backlog_overflow� s
z/GeneralModuleTests.test_listen_backlog_overflowz IPv6 required for this test.c
C sR | j ttjtjddfd� tjtjtj�� }| j t|jtjddf� W d Q R X d S )Nr l �� r i����) r� r r r� r r� r� r r4 )r r r r r
�
test_flowinfo� s
z GeneralModuleTests.test_flowinfoc
C sD t j t jt j��*}| jt|j�d� | jt|j�d� W d Q R X d S )NzAddressFamily.AF_INETzSocketKind.SOCK_STREAM)r r r r� r� r� r� )r r r r r
�test_str_for_enums� s z%GeneralModuleTests.test_str_for_enumszWill not work on Windowsc
C sV t j� \}}| jtj|� tjdd|d��"}| j|jd� | j|jd� W d Q R X d S )Ni�� i4 )r� r� r� ) r� �mkstempr- r� r� r r� r� r� )r �fdr� r r r r
� test_uknown_socket_family_repr� s
z1GeneralModuleTests.test_uknown_socket_family_repr�sendfileztest needs os.sendfile()c C s� G dd� d�}t j � ��}tjtjtj�}tj|� | jt j�� |j||�� W d Q R X | jt �� |j|dd �� W d Q R X | jt
�� |j|d �� W d Q R X W d Q R X d S )Nc @ s e Zd Zdd� Zdd� ZdS )z<GeneralModuleTests.test__sendfile_use_sendfile.<locals>.Filec S s
|| _ d S )N)r� )r r� r r r
r& � s zEGeneralModuleTests.test__sendfile_use_sendfile.<locals>.File.__init__c S s | j S )N)r� )r r r r
r� � s zCGeneralModuleTests.test__sendfile_use_sendfile.<locals>.File.filenoN)r r r! r& r� r r r r
�File� s r� r� i� ) r r� �open�curdir�O_RDONLYr
r� �_GiveupOnSendfile�_sendfile_use_sendfiler r` )r r� r� r� r r r
�test__sendfile_use_sendfile� s
z.GeneralModuleTests.test__sendfile_use_sendfile)Cr r r! r� r� rv �
skipUnlessr� r� r� r� r� r� r� r� r� r_ r r� r� r� r� r� r� r r � cpython_onlyr r r r" r' r. r3 r8 r: r> r@ rC rD rF rI r� r� rN rP r[ r] Zis_resource_enabledr^ rm rn ro rt rv r{ r� r� r� r� r� rV r� r� �skipIfr� r� r r r r
r� � s~
, ' = # K
r� z!SocketCan required for this test.c @ s� e Zd Zdd� Zejeed�d�dd� �Zdd� Z ejeed�d�d d
� �Z
d d � Z d
d� Z ejeed�d�dd� �Z
ejeed�d�dd� �ZdS )� BasicCANTestc C s t j t j t j d S )N)r �AF_CANr r )r r r r
r� s z!BasicCANTest.testCrucialConstants�CAN_BCMz&socket.CAN_BCM required for this test.c C sR t j t j t j t j t j t j t j t j t j t j
t j t j t j
d S )N)r r� ZCAN_BCM_TX_SETUPZCAN_BCM_TX_DELETEZCAN_BCM_TX_READ�CAN_BCM_TX_SENDZCAN_BCM_RX_SETUPZCAN_BCM_RX_DELETEZCAN_BCM_RX_READZCAN_BCM_TX_STATUSZCAN_BCM_TX_EXPIREDZCAN_BCM_RX_STATUSZCAN_BCM_RX_TIMEOUTZCAN_BCM_RX_CHANGED)r r r r
�testBCMConstants s z BasicCANTest.testBCMConstantsc C s$ t j t jt jt j��}W d Q R X d S )N)r r r r )r r r r r
�testCreateSocket s z BasicCANTest.testCreateSocketc C s$ t j t jt jt j��}W d Q R X d S )N)r r r# r� )r r r r r
�testCreateBCMSocket s z BasicCANTest.testCreateBCMSocketc C s. t j t jt jt j��}|jd� W d Q R X d S )Nr� )r� )r r r r r4 )r r r r r
� testBindAny" s zBasicCANTest.testBindAnyc
C s< t j t jt jt j�� }| jtd|jdd f� W d Q R X d S )Nzinterface name too longr2 i )r r r r r� r r4 )r r r r r
�testTooLongInterfaceName& s z%BasicCANTest.testTooLongInterfaceName�CAN_RAW_LOOPBACKz/socket.CAN_RAW_LOOPBACK required for this test.c
C s\ t j t jt jt j��>}x6dD ].}|jt jt j|� | j||jt jt j�� q W W d Q R X d S )Nr rE )r rE ) r r r r r? � SOL_CAN_RAWr� r� r; )r r Zloopbackr r r
� testLoopback, s
zBasicCANTest.testLoopback�CAN_RAW_FILTERz-socket.CAN_RAW_FILTER required for this test.c
C s| d\}}t jd||�}tjtjtjtj��H}|jtjtj|� | j ||j
tjtjd�� |jtjtjt |�� W d Q R X d S )N� � z=IIr3 )r� r� ) r9 �packr r r r r? r� r� r� r; r2 )r �can_idZcan_maskZ
can_filterr r r r
�
testFilter6 s zBasicCANTest.testFilterN)r r r! r� rv r� r_ r r� r� r� r� r� r� r� r r r r
r� � s r� z!Threading required for this test.c @ s� e Zd Zddd�Zedd� �Zedd� �Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z e
jeed�d�dd� �Ze
jeed�d�dd� �ZdS ) �CANTestre c C s t j| |d� d S )N)rf )ri r& )r rf r r r
r& F s zCANTest.__init__c C s& t |�}|jdd�}tj| j|||�S )Nr3 r )rU �ljustr9 r� r8 )�clsr� �data�can_dlcr r r
�build_can_frameI s zCANTest.build_can_framec C s& t j| j|�\}}}|||d |� fS )N)r9 �unpackr8 )r� �framer� r� r� r r r
�dissect_can_frameP s zCANTest.dissect_can_framec C sH | j j| j�\}}| j| j|� | j|d | j� | j|d tj� d S )Nr rE )r �recvfromr7 r� �cfr5 r r� )r r� rr r r r
�
testSendFrameV s zCANTest.testSendFramec C s | j dd�| _| jj| j� d S )Nr s )r� r� rg rB )r r r r
�_testSendFrame\ s zCANTest._testSendFramec C s$ | j j| j�\}}| j| j|� d S )N)r r� r7 r� r� )r r� rr r r r
�testSendMaxFrame` s zCANTest.testSendMaxFramec C s | j dd�| _| jj| j� d S )Nr � r3 s )r� r� rg rB )r r r r
�_testSendMaxFramed s zCANTest._testSendMaxFramec C sD | j j| j�\}}| j| j|� | j j| j�\}}| j| j|� d S )N)r r� r7 r� �cf1�cf2)r r� rr r r r
�testSendMultiFramesh s zCANTest.testSendMultiFramesc C s< | j dd�| _| jj| j� | j dd�| _| jj| j� d S )N� s D3"� s �"3)r� r� rg rB r� )r r r r
�_testSendMultiFrameso s z CANTest._testSendMultiFramesr� z&socket.CAN_BCM required for this test.c C sP | j j| j�\}}| j| j|� | j|�\}}}| j| j|� | j| j|� d S )N)rg r� r7 r� r� r� r� r� )r r� rr r� r� r� r r r
�_testBCMv s
zCANTest._testBCMc C s� t j t jt jt j�}| j|j� |j| jf� d| _t dddg�| _
| j | j| j
�| _ t j
}d}d}d } } }}d} d}
tj| j|||||||| |
�
} | | j } |j| �}
| j|
t| �� d S )Ni# � � �� r i" rE )r r r# r� r- r
rs r5 r� �bytesr� r� r� r� r9 r� r; rB r� rU )r ZbcmZopcoderR rH Z
ival1_secondsZ
ival1_usecZ
ival2_secondsZ
ival2_usecZ
bcm_can_idZnframes�headerZheader_plus_frameZ
bytes_sentr r r
�testBCM s2
zCANTest.testBCMN)re )r r r! r& � classmethodr� r� r� r� r� r� r� r� rv r� r_ r r� r� r r r r
r� B s
r� z#RDS sockets required for this test.c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� BasicRDSTestc C s t j t j d S )N)r ZAF_RDSr )r r r r
r� � s z!BasicRDSTest.testCrucialConstantsc C s" t j t jt jd��}W d Q R X d S )Nr )r r r )r r r r r
r� � s z BasicRDSTest.testCreateSocketc C sJ d}t j t jt jd��*}|jt jt j|� |jt jt j|� W d Q R X d S )Ni @ r )r r r r? r� Z SO_RCVBUFZ SO_SNDBUF)r r7 r r r r
�testSocketBufferSize� s z!BasicRDSTest.testSocketBufferSizeN)r r r! r� r� r� r r r r
r� � s r� c s� e Zd Zd dd�Z� fdd�Zdd� Zdd � Zd
d � Zd d
� Ze e
j
d�dd� �Z e e
j
d�dd� �Z dd� Z
dd� Zdd� Zdd� Z� ZS ) �RDSTestre c C s t j| |d� d S )N)rf )rj r& )r rf r r r
r& � s zRDSTest.__init__c s t � j� tj� | _d S )N)r% r r' rJ Zevt)r )r, r r
r � s
z
RDSTest.setUpc C s2 | j j| j�\}}| j| j|� | j| j|� d S )N)r r� r7 r� r� rm )r r� rr r r r
�testSendAndRecv� s zRDSTest.testSendAndRecvc C s" d| _ | jj| j dt| jf� d S )Ns spamr )r� rg r� rk r )r r r r
�_testSendAndRecv� s zRDSTest._testSendAndRecvc C sH | j j| jtj�\}}| j| j|� | j j| j�\}}| j| j|� d S )N)r r� r7 r �MSG_PEEKr� r� )r r� rr r r r
�testPeek� s zRDSTest.testPeekc C s" d| _ | jj| j dt| jf� d S )Ns spamr )r� rg r� rk r )r r r r
� _testPeek� s zRDSTest._testPeek�recvmsgc C s( | j j| j�\}}}}| j| j|� d S )N)r r� r7 r� r� )r r� �ancdataZ msg_flagsrr r r r
�testSendAndRecvMsg� s zRDSTest.testSendAndRecvMsg�sendmsgc C s* dd | _ | jj| j gf dt| jf� d S )Ns hello r r )r� rg r� rk r )r r r r
�_testSendAndRecvMsg� s
zRDSTest._testSendAndRecvMsgc C sD | j j| j�\}}| j| j|� | j j| j�\}}| j| j|� d S )N)r r� r7 r� �data1�data2)r r� rr r r r
�testSendAndRecvMulti� s z RDSTest.testSendAndRecvMultic C s@ d| _ | jj| j dt| jf� d| _| jj| jdt| jf� d S )Ns baconr s egg)r� rg r� rk r r� )r r r r
�_testSendAndRecvMulti� s z RDSTest._testSendAndRecvMultic C sL t j | jgg g d�\}}}| j| j|� | jj| j�\}}| j| j|� d S )Ng @)�selectr r� r� r7 r� r� )r rs r} r2 r� rr r r r
�
testSelect� s zRDSTest.testSelectc C s" d| _ | jj| j dt| jf� d S )Ns selectr )r� rg r� rk r )r r r r
� _testSelect� s zRDSTest._testSelect)re )r r r! r& r r� r� r� r� r� r r� r� r� r� r� r� r/ r r )r, r
r� � s
r� c @ s� e Zd Zd+dd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zeje�Zejd$d%� �Zd&d'� Zd(d)� Zd*S ),� BasicTCPTestre c C s t j| |d� d S )N)rf )rn r& )r rf r r r
r& � s zBasicTCPTest.__init__c C s | j jd�}| j|t� d S )Ni )rp �recvr� �MSG)r r� r r r
�testRecv� s zBasicTCPTest.testRecvc C s | j jt� d S )N)rt rB r� )r r r r
� _testRecv� s zBasicTCPTest._testRecvc C s8 | j jtt�d �}| j jd�}|| }| j|t� d S )Nr i )rp r� rU r� r� )r �seg1�seg2r� r r r
�testOverFlowRecv s z BasicTCPTest.testOverFlowRecvc C s | j jt� d S )N)rt rB r� )r r r r
�_testOverFlowRecv s z BasicTCPTest._testOverFlowRecvc C s | j jd�\}}| j|t� d S )Ni )rp r� r� r� )r r� rr r r r
� testRecvFrom
s zBasicTCPTest.testRecvFromc C s | j jt� d S )N)rt rB r� )r r r r
�
_testRecvFrom s zBasicTCPTest._testRecvFromc C s@ | j jtt�d �\}}| j jd�\}}|| }| j|t� d S )Nr i )rp r� rU r� r� )r r� rr r� r� r r r
�testOverFlowRecvFrom s z!BasicTCPTest.testOverFlowRecvFromc C s | j jt� d S )N)rt rB r� )r r r r
�_testOverFlowRecvFrom s z"BasicTCPTest._testOverFlowRecvFromc C s8 d}x | j jd�}|sP ||7 }qW | j|dd � d S )N� i � fi )rp r� r� )r r� �readr r r
� testSendAll s zBasicTCPTest.testSendAllc C s dd }| j j|� d S )Nr� i )rt rh )r Z big_chunkr r r
� _testSendAll& s zBasicTCPTest._testSendAllc C sP | j j� }tj|tjtj�}| j|j� | j|tj� |j d�}| j
|t � d S )Ni ) rp r� r Zfromfdr r r- r
r� r� r� r� )r r� r� r� r r r
�
testFromFd* s
zBasicTCPTest.testFromFdc C s | j jt� d S )N)rt rB r� )r r r r
� _testFromFd3 s zBasicTCPTest._testFromFdc C s0 | j j� }| j|j� |jd�}| j|t� d S )Ni )rp �dupr- r
r� r� r� )r r� r� r r r
�testDup6 s
zBasicTCPTest.testDupc C s | j jt� d S )N)rt rB r� )r r r r
�_testDup= s zBasicTCPTest._testDupc C s& | j jd�}| j|t� | jj� d S )Ni )rp r� r� r� rL rV )r r� r r r
� testShutdown@ s zBasicTCPTest.testShutdownc C s | j jt� | j jd� d S )Nr� )rt rB r� �shutdown)r r r r
�
_testShutdownI s zBasicTCPTest._testShutdownc C sX dd l }| jjt� | jt| jj|jd � | jt| jjd|jd � | jjd� d S )Nr rE r� ) r� rt rB r� r� r r� r� �UINT_MAX)r r� r r r
�_testShutdown_overflowO s z#BasicTCPTest._testShutdown_overflowc C s� | j j� }| j j� }| j||� | j| j j� | jt| j jd� | j j � t
j
t
j t
j |d�}| j
|j � |jd�}| j|t� d S )Ni )r� )rp r� �detachr� r� �_closedr� r r� r
r r r r- r� )r r� r� r� r� r r r
�
testDetachZ s
zBasicTCPTest.testDetachc C s | j jt� d S )N)rt rB r� )r r r r
� _testDetachj s zBasicTCPTest._testDetachN)re )r r r! r& r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� ZtestShutdown_overflowr� r r r r r r
r� � s*
r� c @ sF e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dS )� BasicUDPTestre c C s t j| |d� d S )N)rf )rh r& )r rf r r r
r& p s zBasicUDPTest.__init__c C s | j jtt��}| j|t� d S )N)r r� rU r� r� )r r� r r r
�testSendtoAndRecvs s z BasicUDPTest.testSendtoAndRecvc C s | j jtdt| jf� d S )Nr )rg r� r� rk r )r r r r
�_testSendtoAndRecvx s z BasicUDPTest._testSendtoAndRecvc C s$ | j jtt��\}}| j|t� d S )N)r r� rU r� r� )r r� rr r r r
r� { s zBasicUDPTest.testRecvFromc C s | j jtdt| jf� d S )Nr )rg r� r� rk r )r r r r
r� � s zBasicUDPTest._testRecvFromc C s | j t| jjd� d S )NrE r )r� r r r� )r r r r
�testRecvFromNegative� s z!BasicUDPTest.testRecvFromNegativec C s | j jtdt| jf� d S )Nr )rg r� r� rk r )r r r r
�_testRecvFromNegative� s z"BasicUDPTest._testRecvFromNegativeN)re )
r r r! r& r r r� r� r r r r r r
r m s
r c s� e Zd ZdZ� fdd�Zdd� Zf Zdd� Zdd � Zd
d � Z d d
� Z
dZ x dD ]Z e e
ee d�O Z qNW dZdZdZddd�Z� ZS )�SendrecvmsgBaseg @c s t j� | _t� j� d S )N)r' rJ �
misc_eventr% r )r )r, r r
r � s
zSendrecvmsgBase.setUpc C s | j j|�S )N)�cli_sockrB )r r� r r r
� sendToServer� s z SendrecvmsgBase.sendToServerc G s | j j|| jt|�d � � S )N)r r� �sendmsg_to_server_defaultsrU )r r* r r r
�sendmsgToServer� s z SendrecvmsgBase.sendmsgToServerc G s |j |f|�� }| j|� |S )N)r� �registerRecvmsgResult)r r� r7 r* �resultr r r
� doRecvmsg� s
zSendrecvmsgBase.doRecvmsgc C s d S )Nr )r r r r r
r � s z%SendrecvmsgBase.registerRecvmsgResultc C s | j ||� d S )N)r� )r �addr1�addr2r r r
�checkRecvmsgAddress� s z#SendrecvmsgBase.checkRecvmsgAddressr �
MSG_CTRUNC�MSG_OOBNc
C s� | j }| j}|r&|| jO }|| jO }n |d k rB|| jO }|| jO }|| M }|| M }||O }||O }||@ | @ }|r�tdj|���||B | @ } | j|| @ || @ � d S )Nz6contradictory set, unset requirements for flags {0:#x})�msg_flags_common_set�msg_flags_common_unset�msg_flags_eor_indicator�msg_flags_non_eor_indicator� Exceptionr� r� )
r rR �eor�checkset�
checkunset�ignoreZ
defaultsetZ defaultunsetZinbothr r r r
�
checkFlags� s$
zSendrecvmsgBase.checkFlags)r r )Nr r r )r r r! � fail_timeoutr r r
r r r r r r� rR r r r r r r/ r r )r, r
r � s
r c @ s e Zd Zdd� ZdS )�RecvmsgIntoMixinc G sf t |�}|j|gf|�� }| j|� | j|d d� | j|d |� t|d |d � �f|dd � S )Nr rE )r2 � recvmsg_intor �assertGreaterEqual�assertLessEqualr� )r r� r7 r* �bufr r r r
r s
zRecvmsgIntoMixin.doRecvmsgN)r r r! r r r r r
r" s r" c s e Zd Ze� fdd��Z� ZS )�SendrecvmsgDgramFlagsBasec s t � jtjB S )N)r% r r � MSG_TRUNC)r )r, r r
r + s z5SendrecvmsgDgramFlagsBase.msg_flags_non_eor_indicator)r r r! �propertyr r/ r r )r, r
r' ( s r' c s e Zd Ze� fdd��Z� ZS )�SendrecvmsgSCTPFlagsBasec s t � jtjB S )N)r% r r ZMSG_EOR)r )r, r r
r 3 s z0SendrecvmsgSCTPFlagsBase.msg_flags_eor_indicator)r r r! r) r r/ r r )r, r
r* 0 s r* c @ s8 e Zd Zedd� �Zedd� �Zedd� �Zdd� Zd S )
� SendrecvmsgConnectionlessBasec C s | j S )N)r )r r r r
� serv_sock= s z'SendrecvmsgConnectionlessBase.serv_sockc C s | j S )N)rg )r r r r
r A s z&SendrecvmsgConnectionlessBase.cli_sockc C s g g d| j fS )Nr )r} )r r r r
r
E s z8SendrecvmsgConnectionlessBase.sendmsg_to_server_defaultsc C s | j j|| j�S )N)r r� r} )r r� r r r
r I s z*SendrecvmsgConnectionlessBase.sendToServerN)r r r! r) r, r r
r r r r r
r+ 8 s r+ c @ s, e Zd Zedd� �Zedd� �Zdd� ZdS )�SendrecvmsgConnectedBasec C s | j S )N)rp )r r r r
r, S s z"SendrecvmsgConnectedBase.serv_sockc C s | j S )N)rt )r r r r
r W s z!SendrecvmsgConnectedBase.cli_sockc C s d S )Nr )r r r r r r
r [ s z,SendrecvmsgConnectedBase.checkRecvmsgAddressN)r r r! r) r, r r r r r r
r- M s r- c s e Zd Z� fdd�Z� ZS )� SendrecvmsgServerTimeoutBasec s t � j� | jj| j� d S )N)r% r r, rA r! )r )r, r r
r d s
z"SendrecvmsgServerTimeoutBase.setUp)r r r! r r/ r r )r, r
r. a s r. c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zeed �d d � �Zejd d!� �Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*S )+� SendmsgTestsc C s | j | jjtt��t� d S )N)r� r, r� rU r� )r r r r
� testSendmsgm s zSendmsgTests.testSendmsgc C s | j | jtg�tt�� d S )N)r� r r� rU )r r r r
� _testSendmsgq s zSendmsgTests._testSendmsgc C s | j | jjtt��t� d S )N)r� r, r� rU r� )r r r r
�testSendmsgDataGeneratort s z%SendmsgTests.testSendmsgDataGeneratorc C s& | j | jdd� tgD ��tt�� d S )Nc s s | ]
}|V qd S )Nr )r� r� r r r
r� y s z9SendmsgTests._testSendmsgDataGenerator.<locals>.<genexpr>)r� r r� rU )r r r r
�_testSendmsgDataGeneratorx s z&SendmsgTests._testSendmsgDataGeneratorc C s | j | jjtt��t� d S )N)r� r, r� rU r� )r r r r
� testSendmsgAncillaryGenerator| s z*SendmsgTests.testSendmsgAncillaryGeneratorc C s( | j | jtgdd� g D ��tt�� d S )Nc s s | ]
}|V qd S )Nr )r� r� r r r
r� � s z>SendmsgTests._testSendmsgAncillaryGenerator.<locals>.<genexpr>)r� r r� rU )r r r r
� _testSendmsgAncillaryGenerator� s z+SendmsgTests._testSendmsgAncillaryGeneratorc C s | j | jjtt��t� d S )N)r� r, r� rU r� )r r r r
�testSendmsgArray� s z SendmsgTests.testSendmsgArrayc C s$ | j | jtjdt�g�tt�� d S )N�B)r� r �arrayr� rU )r r r r
�_testSendmsgArray� s z SendmsgTests._testSendmsgArrayc C s | j | jjtt��t� d S )N)r� r, r� rU r� )r r r r
�testSendmsgGather� s z SendmsgTests.testSendmsgGatherc C s. | j | jtd d� tdd � g�tt�� d S )Nr )r� r r� rU )r r r r
�_testSendmsgGather� s z SendmsgTests._testSendmsgGatherc C s | j | jjd�d� d S )Ni� s done)r� r, r� )r r r r
�testSendmsgBadArgs� s z SendmsgTests.testSendmsgBadArgsc C s� | j t| jj� | j t| jd� | j t| jt� � | j t| jt� g� | j t| jtt� g� | j t| jtgt� � | j t| jtgg t� � | j t| jtgg dt� � | jd� d S )Ns not in an iterabler s done)r� r` r r� r �objectr� r )r r r r
�_testSendmsgBadArgs� s
z SendmsgTests._testSendmsgBadArgsc C s | j | jjd�d� d S )Ni� s done)r� r, r� )r r r r
�testSendmsgBadCmsg� s z SendmsgTests.testSendmsgBadCmsgc C s� | j t| jtgt� g� | j t| jtgt� ddfg� | j t| jtgdt� dfg� | j t| jtgddt� fg� | j t| jtgdg� | j t| jtgdg� | jd� d S )Nr � data�* s done)r r )r r r@ rA )r� r` r r� r= r )r r r r
�_testSendmsgBadCmsg� s
z SendmsgTests._testSendmsgBadCmsg�
CMSG_SPACEc C s | j | jjd�d� d S )Ni� s done)r� r, r� )r r r r
�testSendmsgBadMultiCmsg� s z$SendmsgTests.testSendmsgBadMultiCmsgc C sB | j t| jtgdddg� | j t| jtgdt� g� | jd� d S )Nr r� s done)r r r� )r� r` r r� r= r )r r r r
�_testSendmsgBadMultiCmsg� s
z%SendmsgTests._testSendmsgBadMultiCmsgc C s | j | jjd�d� d S )Ni� s done)r� r, r� )r r r r
�testSendmsgExcessCmsgReject� s z(SendmsgTests.testSendmsgExcessCmsgRejectc
C sN t td�s@| jt��}| jtgddg� W d Q R X | j|jj� | j d� d S )NrC r r� s done)r r r� )r r r� )
r_ r r� r r r� � assertIsNoner� r� r )r r� r r r
� _testSendmsgExcessCmsgReject� s
z)SendmsgTests._testSendmsgExcessCmsgRejectc C s d S )Nr )r r r r
�testSendmsgAfterClose� s z"SendmsgTests.testSendmsgAfterClosec C s | j j� | jt| jtg� d S )N)r r
r� r r r� )r r r r
�_testSendmsgAfterClose� s
z#SendmsgTests._testSendmsgAfterCloseN)r r r! r0 r1 r2 r3 r4 r5 r6 r9 r: r; r< r> r? rB r� r rD r� rE rF rH rI rJ r r r r
r/ i s( r/ c @ sR e Zd Zdd� Zdd� Zdd� Zdd� Zeej dkd
�d d � �Z
e
j d
d� �Z dS )�SendmsgStreamTestsc C s | j | jjtt��t� d S )N)r� r, r� rU r� )r r r r
�testSendmsgExplicitNoneAddr� s z.SendmsgStreamTests.testSendmsgExplicitNoneAddrc C s" | j | jtgg dd �tt�� d S )Nr )r� r r� rU )r r r r
� _testSendmsgExplicitNoneAddr� s z/SendmsgStreamTests._testSendmsgExplicitNoneAddrc C s2 | j | jjd�dd � | j| jj| jd�� d S )Ni � a)rj )r� r, r� r� r
rV r! )r r r r
�testSendmsgTimeout� s z%SendmsgStreamTests.testSendmsgTimeoutc C s� zz| j jd� yx| jdd g� qW W nD tjk
r> Y n: tk
rl } z|jtjkr\� W Y d d }~X n X | jd� W d | j j
� X d S )Ng� ��Q��?rN i zsocket.timeout not raised) r rA r r rj r r� �ENOMEMr� r
rC )r rY r r r
�_testSendmsgTimeout� s z&SendmsgStreamTests._testSendmsgTimeoutr z<MSG_DONTWAIT not known to work on this platform when sendingc C s2 | j | jjd�dd � | j| jj| jd�� d S )Ni rN )rj )r� r, r� r� r
rV r! )r r r r
�testSendmsgDontWait s z&SendmsgStreamTests.testSendmsgDontWaitc C sd zR| j t��"}x| jdd gg tj� qW W d Q R X | j|jjtjtj tj
f� W d | j j � X d S )NrN i )
r� r r r Z MSG_DONTWAITr� r� r� ZEAGAINZ EWOULDBLOCKrP r
rC )r r� r r r
�_testSendmsgDontWait s $
z'SendmsgStreamTests._testSendmsgDontWaitN> r )
r r r! rL rM rO rQ r� r� r rR r� rS r r r r
rK � s
rK c @ s e Zd Zdd� Zdd� ZdS )�SendmsgConnectionlessTestsc C s d S )Nr )r r r r
�testSendmsgNoDestAddr" s z0SendmsgConnectionlessTests.testSendmsgNoDestAddrc C s2 | j t| jjtg� | j t| jjtgg dd � d S )Nr )r� r r r� r� )r r r r
�_testSendmsgNoDestAddr' s z1SendmsgConnectionlessTests._testSendmsgNoDestAddrN)r r r! rU rV r r r r
rT s rT c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Ze j
d
�dd� �Z e j
d
�dd� �Z dd� Z
dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zeed"�d#d$� �Zejd%d&� �Zeejd'�d(d)� �Zejd*d+� �Zd,S )-�RecvmsgGenericTestsc C sR | j | jtt��\}}}}| j|t� | j|| j� | j|g � | j|dd� d S )NT)r )r r, rU r� r� r rm r )r r� r� rR rr r r r
� testRecvmsg2 s
z RecvmsgGenericTests.testRecvmsgc C s | j t� d S )N)r r� )r r r r
� _testRecvmsg: s z RecvmsgGenericTests._testRecvmsgc C sV | j | jtt�dd�\}}}}| j|t� | j|| j� | j|g � | j|dd� d S )Nr T)r )r r, rU r� r� r rm r )r r� r� rR rr r r r
�testRecvmsgExplicitDefaults= s z/RecvmsgGenericTests.testRecvmsgExplicitDefaultsc C s | j t� d S )N)r r� )r r r r
� _testRecvmsgExplicitDefaultsF s z0RecvmsgGenericTests._testRecvmsgExplicitDefaultsc C sV | j | jtt�d �\}}}}| j|t� | j|| j� | j|g � | j|dd� d S )NrA T)r )r r, rU r� r� r rm r )r r� r� rR rr r r r
�testRecvmsgShorterI s z&RecvmsgGenericTests.testRecvmsgShorterc C s | j t� d S )N)r r� )r r r r
�_testRecvmsgShorterR s z'RecvmsgGenericTests._testRecvmsgShorterr3 c C s^ | j | jtt�d �\}}}}| j|td d� � | j|| j� | j|g � | j|dd� d S )Nr F)r r )r r, rU r� r� r rm r )r r� r� rR rr r r r
�testRecvmsgTruncW s z$RecvmsgGenericTests.testRecvmsgTruncc C s | j t� d S )N)r r� )r r r r
�_testRecvmsgTrunca s z%RecvmsgGenericTests._testRecvmsgTruncc C sT | j | jtt�d�\}}}}| j|t� | j|| j� | j|g � | j|dd� d S )NrE T)r )r r, rU r� r� r rm r )r r� r� rR rr r r r
� testRecvmsgShortAncillaryBufe s z0RecvmsgGenericTests.testRecvmsgShortAncillaryBufc C s | j t� d S )N)r r� )r r r r
� _testRecvmsgShortAncillaryBufn s z1RecvmsgGenericTests._testRecvmsgShortAncillaryBufc C sT | j | jtt�d�\}}}}| j|t� | j|| j� | j|g � | j|dd� d S )Ni ( T)r )r r, rU r� r� r rm r )r r� r� rR rr r r r
�testRecvmsgLongAncillaryBufq s z/RecvmsgGenericTests.testRecvmsgLongAncillaryBufc C s | j t� d S )N)r r� )r r r r
� _testRecvmsgLongAncillaryBufz s z0RecvmsgGenericTests._testRecvmsgLongAncillaryBufc C s" | j j� | jt| j| j d� d S )Ni )r, r
r� r r )r r r r
�testRecvmsgAfterClose} s
z)RecvmsgGenericTests.testRecvmsgAfterClosec C s d S )Nr )r r r r
�_testRecvmsgAfterClose� s z*RecvmsgGenericTests._testRecvmsgAfterClosec C s< z*| j jd� | jtj| j| j tt�� W d | jj � X d S )Ng� ��Q��?)
r, rA r� r rj r rU r� r
rC )r r r r
�testRecvmsgTimeout� s
z&RecvmsgGenericTests.testRecvmsgTimeoutc C s | j | jj| jd�� d S )N)rj )r� r
rV r! )r r r r
�_testRecvmsgTimeout� s z'RecvmsgGenericTests._testRecvmsgTimeoutr� c C s | j | jtt�d dtj�\}}}}| j|td d� � | j|| j� | j|g � | j |dt
tdd�d� | j | jtt�dtj�\}}}}| j|t� | j|| j� | j|g � | j |dd� | j | jtt��\}}}}| j|t� | j|| j� | j|g � | j |dd� d S ) Nr r Fr( )r r T)r r ) r r, rU r� r r� r� r rm r rR )r r� r� rR rr r r r
�testRecvmsgPeek� s( z#RecvmsgGenericTests.testRecvmsgPeekc C s | j t� d S )N)r r� )r r r r
�_testRecvmsgPeek� s z$RecvmsgGenericTests._testRecvmsgPeekr� c C s` | j j| j� | j| j tt��\}}}}| j|t� | j|| j� | j|g � | j |dd� d S )NT)r )
r, rA r! r rU r� r� r rm r )r r� r� rR rr r r r
�testRecvmsgFromSendmsg� s z*RecvmsgGenericTests.testRecvmsgFromSendmsgc C s. | j | jtd d� tdd � g�tt�� d S )Nr )r� r r� rU )r r r r
�_testRecvmsgFromSendmsg� s z+RecvmsgGenericTests._testRecvmsgFromSendmsgN) r r r! rX rY rZ r[ r\ r] r Zrequires_freebsd_versionr^ r_ r` ra rb rc rd re rf rg r� r rh r� ri rj rk r r r r
rW . s(
# rW c @ s6 e Zd Zejd�dd� �Zdd� Zdd� Zdd � Zd
S ) �RecvmsgGenericStreamTestsz)fails intermittently when run within Kojic C sN | j | jd�\}}}}| j|d� | j|| j� | j|g � | j|d d� d S )Ni r� )r )r r, r� r rm r )r r� r� rR rr r r r
�testRecvmsgEOF� s
z(RecvmsgGenericStreamTests.testRecvmsgEOFc C s | j j� d S )N)r r
)r r r r
�_testRecvmsgEOF� s z)RecvmsgGenericStreamTests._testRecvmsgEOFc C s� | j | jtt�d �\}}}}| j|| j� | j|g � | j|dd� | j | jd�\}}}}| j|| j� | j|g � | j|dd� || }| j|t� d S )Nr F)r i T)r r, rU r� r rm r� r )r r� r� rR rr r� r� r r r
�testRecvmsgOverflow� s z-RecvmsgGenericStreamTests.testRecvmsgOverflowc C s | j t� d S )N)r r� )r r r r
�_testRecvmsgOverflow� s z.RecvmsgGenericStreamTests._testRecvmsgOverflowN) r r r! rv Z_skipInRpmBuildrm rn ro rp r r r r
rl � s rl c @ s e Zd Zdd� Zdd� ZdS )� RecvmsgTestsc C s | j t| jj� | j t| jjddd� | j t| jjtt�dd� | j t| jjtd�gdd� | j t| jjt� dd� | j t| jjtt�t� d� | j t| jjtt�dt� � | jjtt�dd�\}}}}| j |t� | j
|| j � | j |g � | j |dd� d S )NrE r r T)r r r )
r� r` r, r� r rU r� r2 r= r� r rm r )r r� r� rR rr r r r
�testRecvmsgBadArgs� s$
z RecvmsgTests.testRecvmsgBadArgsc C s | j t� d S )N)r r� )r r r r
�_testRecvmsgBadArgs
s z RecvmsgTests._testRecvmsgBadArgsN)r r r! rr rs r r r r
rq � s rq c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )�RecvmsgIntoTestsc C sL t tt��}| jt| jj� | jt| jjtt�dd� | jt| jj|dd� | jt| jjt� gdd� | jt| jjdgdd� | jt| jj|t� gdd� | jt| jj|gdd� | jt| jj|gt� d� | jt| jj|gdt� � | jj|gdd�\}}}}| j |tt�� | j |t t�� | j
|| j � | j |g � | j |dd� d S )Nr s I'm not writablerE T)r r )
r2 rU r� r� r` r, r# r= r r� r rm r )r r& �nbytesr� rR rr r r r
�testRecvmsgIntoBadArgs
s0
z'RecvmsgIntoTests.testRecvmsgIntoBadArgsc C s | j t� d S )N)r r� )r r r r
�_testRecvmsgIntoBadArgs(
s z(RecvmsgIntoTests._testRecvmsgIntoBadArgsc C sx t tt��}| jjdd� |gD ��\}}}}| j|tt�� | j|t t�� | j|| j� | j|g � | j|dd� d S )Nc s s | ]
}|V qd S )Nr )r� r� r r r
r� /
s z<RecvmsgIntoTests.testRecvmsgIntoGenerator.<locals>.<genexpr>T)r ) r2 rU r� r, r# r� r rm r )r r& ru r� rR rr r r r
�testRecvmsgIntoGenerator+
s z)RecvmsgIntoTests.testRecvmsgIntoGeneratorc C s | j t� d S )N)r r� )r r r r
�_testRecvmsgIntoGenerator6
s z*RecvmsgIntoTests._testRecvmsgIntoGeneratorc C sx t j ddgtt� �}| jj|g�\}}}}| j|tt�� | j|j� t� | j|| j� | j|g � | j |dd� d S )Nr7 r T)r )
r8 rU r� r, r# r� �tobytesr rm r )r r& ru r� rR rr r r r
�testRecvmsgIntoArray9
s z%RecvmsgIntoTests.testRecvmsgIntoArrayc C s | j t� d S )N)r r� )r r r r
�_testRecvmsgIntoArrayC
s z&RecvmsgIntoTests._testRecvmsgIntoArrayc C s� t d�}t d�}t d�}| jj|t|�dd� |g�\}}}}| j|td�� | j|t d�� | j|t d�� | j|t d �� | j|| j� | j|g � | j|d
d � d S ) Ns ----s
0123456789s --------------r� � s Mary had a little lambs Marys
01 had a 9s little lamb---T)r ) r2 r, r# �
memoryviewr� rU r rm r )r Zb1Zb2Zb3ru r� rR rr r r r
�testRecvmsgIntoScatterF
s z'RecvmsgIntoTests.testRecvmsgIntoScatterc C s | j d� d S )Ns Mary had a little lamb)r )r r r r
�_testRecvmsgIntoScatterU
s z(RecvmsgIntoTests._testRecvmsgIntoScatterN) r r r! rv rw rx ry r{ r| r r� r r r r
rt
s
rt c @ sb e Zd Zy ddlZW n ek
r, dZY nX edej�Zee d�dd� �Z
ee d�dd � �Z dS )
�CmsgMacroTestsr Ni����CMSG_LENc C s� | j tjd� d }ttd��tt|d |�� }| jtjd�tjd�jd � x:|D ]2}tj|�}| j|tjd� |� | j || j � qVW | j
t tjd� | j
t tj|� | j
t tjt j
� d S )Nr rE i r r� r )�socklen_t_limitr r� �listr� r� r8 �itemsizer� r% r� r r� �maxsize)r �toobig�values�n�retr r r
� testCMSG_LENf
s
zCmsgMacroTests.testCMSG_LENrC c C s� | j tjd� d }ttd��tt|d |�� }tjd�}| j|tjd�jd � x\|D ]T}tj|�}| j||� | j|tj |�� | j||tj d� � | j
|| j � |}qZW | j t tjd� | j t tj|� | j t tjt
j� d S )NrE i r r r� r )r� r rC r� r� r� r8 r� r$ r� r% r� r r� r� )r r� r� Zlastr� r� r r r
�testCMSG_SPACE{
s
z CmsgMacroTests.testCMSG_SPACE) r r r! r� r, r� �minr� r� r r� r� r r r r
r� Y
s
r� c @ sh e Zd ZdeZdd� Zdd� Zdd� Zdd � Zd
d � Zdfdd�Z dd� Z
dd� Z dd� Z dd� Z
eed�dd� �Zejdd � �Zd d � Zd d � Zejejd!kd"�ejejjd#�d$�eed�d%d&� ���Zejejejd!kd"�ejejjd#�d$�d'd(� ���Zejejd!kd"�ejejjd#�d$�eed�d)d*� ���Z e jejejd!kd"�ejejjd#�d$�d+d,� ���Z d-d.� Z ejejd!kd/�d0d1� �Z d2d3� Z d4d5� Z!d6d7� Z"eed�d8d9� �Z#e#jd:d;� �Z$dgd<d=�Z%d>d?� Z&d@dA� Z'dBdC� Z(dDdE� Z)dFdG� Z*dHdI� Z+dJdK� Z,dLdM� Z-dNdO� Z.dPdQ� Z/dhdRdS�Z0dTdU� Z1dVdW� Z2dXdY� Z3dZd[� Z4d\d]� Z5d^d_� Z6d`da� Z7dbdc� Z8ddS )i�
SCMRightsTestiUU c C s` g }xVt |�D ]J}tj� \}}| jtj|� | jtj|� tj|t|�j � � |j
|� qW |S )N) r� r� r� r- r� r� r
�writer� �encode�append)r r� �fdsr r� r� r r r
�newFDs�
s zSCMRightsTest.newFDsc C sF x@t |�D ]4\}}tj|dtj� | jtj|d�t|�j� � q
W d S )Nr i )� enumerater� �lseek�SEEK_SETr� r� r� r� )r r� r� r� r r r
�checkFDs�
s zSCMRightsTest.checkFDsc C s | j | j|� d S )N)r- �closeRecvmsgFDs)r r r r r
r �
s z#SCMRightsTest.registerRecvmsgResultc C sv xp|d D ]d\}}}|t jkr
|t jkr
tjd�}|j|d t|�t|�|j � � x|D ]}tj|� q\W q
W d S )NrE r ) r r� �
SCM_RIGHTSr8 � frombytesrU r� r� r
)r Zrecvmsg_result�
cmsg_level� cmsg_type� cmsg_datar� r� r r r
r� �
s
z SCMRightsTest.closeRecvmsgFDsc C s8 | j | jtgtjtjtjd| j|��fg�tt�� d S )Nr ) r� r r� r r� r� r8 r� rU )r r� r r r
�createAndSendFDs�
s z SCMRightsTest.createAndSendFDsrE r c C s� |\}}}}| j |t� | j|| j� | j|dtj|d� | j|t� | j t
|�|� t j d�} xh|D ]`}
| j|
t � |
\} } }
| j | tj
� | j | tj� | j|
t� | j t
|
�t d� | j|
� qfW | j t
| �|� | j| � d S )NT)r r r r r )r� r� r rm r r r r� r� r% rU r8 �tupler� r� r� �
SIZEOF_INTr� r� )r Znumfdsr �maxcmsgs� ignoreflagsr� r� rR rr r� �itemr� r� r� r r r
�checkRecvmsgFDs�
s$
z SCMRightsTest.checkRecvmsgFDsc C s | j d| j| jtt�d�� d S )NrE i ( )r� r r, rU r� )r r r r
�testFDPassSimple�
s z SCMRightsTest.testFDPassSimplec C s< | j | jtgtjtjtjd| jd��j� fg�t t�� d S )Nr rE )
r� r r� r r� r� r8 r� rz rU )r r r r
�_testFDPassSimple�
s z SCMRightsTest._testFDPassSimplec C s | j d| j| jtt�d�� d S )Nr� i ( )r� r r, rU r� )r r r r
�testMultipleFDPass�
s z SCMRightsTest.testMultipleFDPassc C s | j d� d S )Nr� )r� )r r r r
�_testMultipleFDPass�
s z!SCMRightsTest._testMultipleFDPassrC c C s* | j d| j| jtt�tjdt ��� d S )Nr� )r� r r, rU r� r rC r� )r r r r
�testFDPassCMSG_SPACE�
s z"SCMRightsTest.testFDPassCMSG_SPACEc C s | j d� d S )Nr� )r� )r r r r
�_testFDPassCMSG_SPACE s z#SCMRightsTest._testFDPassCMSG_SPACEc C s0 | j d| j| jtt�tjdt ��tjd� d S )NrE r� )r� ) r� r r, rU r� r r� r� r )r r r r
�testFDPassCMSG_LEN s z SCMRightsTest.testFDPassCMSG_LENc C s | j d� d S )NrE )r� )r r r r
�_testFDPassCMSG_LEN s z!SCMRightsTest._testFDPassCMSG_LENr zskipping, see issue #12958�aixzskipping, see issue #22397c C s$ | j d| j| jtt�d�dd� d S )Nr� i ( )r� )r� r r, rU r� )r r r r
�testFDPassSeparate s z SCMRightsTest.testFDPassSeparatec C sX | j d�\}}| j| jtgtjtjtjd|g�ftjtjtjd|g�fg�tt�� d S )Nr� r ) r� r� r r� r r� r� r8 rU )r �fd0�fd1r r r
�_testFDPassSeparate s z!SCMRightsTest._testFDPassSeparatec C s@ d}| j || j| jtt�tjt�tjt| � �dtj d� d S )Nr� )r� r� )
r� r r, rU r� r rC r� r� r )r Znum_fdsr r r
�testFDPassSeparateMinSpace) s z(SCMRightsTest.testFDPassSeparateMinSpacec C sX | j d�\}}| j| jtgtjtjtjd|g�ftjtjtjd|g�fg�tt�� d S )Nr� r ) r� r� r r� r r� r� r8 rU )r r� r� r r r
�_testFDPassSeparateMinSpace6 s z)SCMRightsTest._testFDPassSeparateMinSpacec C sd y| j |g|�}W n< tk
rN } z | j|jt� | j |g�}W Y d d }~X nX | j|t|�� d S )N)r r r� r� r� r� rU )r r� r� ru ra r r r
�sendAncillaryIfPossibleD s z%SCMRightsTest.sendAncillaryIfPossiblezsee issue #24725c C s& | j d| j| jtt�d�tjd� d S )Nr i ( )r� )r� r r, rU r� r r )r r r r
�testFDPassEmptyO s
z SCMRightsTest.testFDPassEmptyc C s | j ttjtjdfg� d S )Nr� )r� r� r r� r� )r r r r
�_testFDPassEmptyW s
z SCMRightsTest._testFDPassEmptyc C s� | j | jtt�d�\}}}}| j|t� | j|| j� | j|dtj d� | j
t|�d� x>|D ]6\}}}| j|tj � | j|tj � | j
t|�t� q^W d S )Ni ( T)r r rE )r r, rU r� r� r rm r r r r% r� r� �
assertLessr� )r r� r� rR rr r� r� r� r r r
�testFDPassPartialInt\ s z"SCMRightsTest.testFDPassPartialIntc C s4 | j ttjtjtjd| jg�j� d d� fg� d S )Nr rE r )r� r� r r� r� r8 �badfdrz )r r r r
�_testFDPassPartialInti s
z#SCMRightsTest._testFDPassPartialIntc C s� | j | jtt�d�\}}}}| j|t� | j|| j� | j|dtj d� | j
t|�d� t j d�}xR|D ]J\}}}| j|tj � | j|tj
� |j|d t|�t|�|j � � qhW | j
t|�d� | j|� d S )Ni ( T)r r r� r )r r, rU r� r� r rm r r r r% r8 r� r� r� r� r� ) r r� r� rR rr r� r� r� r� r r r
� testFDPassPartialIntInMiddlep s
z*SCMRightsTest.testFDPassPartialIntInMiddlec C sZ | j d�\}}| jttjtjtjd|| jg�j� d d� ftjtjtjd|g�fg� d S )Nr� r rE r ) r� r� r� r r� r� r8 r� rz )r r� r� r r r
� _testFDPassPartialIntInMiddle� s z+SCMRightsTest._testFDPassPartialIntInMiddlec C sJ |\}}}}| j |t� | j|| j� | j |g � | j|dtj|d� d S )NT)r r r )r� r� r rm r r r )r r r� r� r� rR rr r r r
�checkTruncatedHeader� s z"SCMRightsTest.checkTruncatedHeaderc C s" | j | j| jtt��tjd� d S )N)r� )r� r r, rU r� r r )r r r r
�testCmsgTruncNoBufSize� s z$SCMRightsTest.testCmsgTruncNoBufSizec C s | j d� d S )NrE )r� )r r r r
�_testCmsgTruncNoBufSize� s z%SCMRightsTest._testCmsgTruncNoBufSizec C s$ | j | j| jtt�d�tjd� d S )Nr )r� )r� r r, rU r� r r )r r r r
�testCmsgTrunc0� s z SCMRightsTest.testCmsgTrunc0c C s | j d� d S )NrE )r� )r r r r
�_testCmsgTrunc0� s z SCMRightsTest._testCmsgTrunc0c C s | j | j| jtt�d�� d S )NrE )r� r r, rU r� )r r r r
�testCmsgTrunc1� s z SCMRightsTest.testCmsgTrunc1c C s | j d� d S )NrE )r� )r r r r
�_testCmsgTrunc1� s z SCMRightsTest._testCmsgTrunc1c C s" | j | j| jtt�td �� d S )Nr� )r� r r, rU r� r� )r r r r
�testCmsgTrunc2Int� s z SCMRightsTest.testCmsgTrunc2Intc C s | j d� d S )NrE )r� )r r r r
�_testCmsgTrunc2Int� s z SCMRightsTest._testCmsgTrunc2Intc C s( | j | j| jtt�tjd�d �� d S )Nr rE )r� r r, rU r� r r� )r r r r
�testCmsgTruncLen0Minus1� s z%SCMRightsTest.testCmsgTruncLen0Minus1c C s | j d� d S )NrE )r� )r r r r
�_testCmsgTruncLen0Minus1� s z&SCMRightsTest._testCmsgTruncLen0Minus1c C s� | j | jtt�|�\}}}}| j|t� | j|| j� | j|dtj d� |dkr\|g kr\d S | jt|�d� |d \}} }
| j|tj
� | j| tj � | j t|
�|� | j
t|
�|� tjd�} | j|
d t|
�t|
�| j � � | j| � d S )NT)r r r rE r )r r, rU r� r� r rm r r r r� r� r$ r% r8 r� r� r� ) r �ancbuf�maxdataZmindatar� r� rR rr r� r� r� r� r r r
�checkTruncatedArray� s"
z!SCMRightsTest.checkTruncatedArrayc C s | j tjd�dd� d S )Nr )r� r� )r� r r� )r r r r
�testCmsgTruncLen0� s z SCMRightsTest.testCmsgTruncLen0c C s | j d� d S )NrE )r� )r r r r
�_testCmsgTruncLen0� s z SCMRightsTest._testCmsgTruncLen0c C s | j tjd�d dd� d S )Nr rE )r� r� )r� r r� )r r r r
�testCmsgTruncLen0Plus1� s z$SCMRightsTest.testCmsgTruncLen0Plus1c C s | j d� d S )Nr� )r� )r r r r
�_testCmsgTruncLen0Plus1� s z%SCMRightsTest._testCmsgTruncLen0Plus1c C s | j tjt�td� d S )N)r� r� )r� r r� r� )r r r r
�testCmsgTruncLen1� s z SCMRightsTest.testCmsgTruncLen1c C s | j d� d S )Nr� )r� )r r r r
�_testCmsgTruncLen1� s z SCMRightsTest._testCmsgTruncLen1c C s( | j tjdt �d dt d d� d S )Nr� rE )r� r� )r� r r� r� )r r r r
�testCmsgTruncLen2Minus1� s z%SCMRightsTest.testCmsgTruncLen2Minus1c C s | j d� d S )Nr� )r� )r r r r
�_testCmsgTruncLen2Minus1� s z&SCMRightsTest._testCmsgTruncLen2Minus1Ni����)rE r )r )r )9r r r! r� r� r� r r� r� r� r� r� r� r� r� r r� r� r� r� r� rv r� r� r r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r
r� �
sl
r� c @ s e Zd ZdZd^Zdd� Zd_dd�Zeed d
�d d � �Z e j
d
d� �Z eedd d
�dd� �Z e j
dd� �Z
eejd�eed d
�dd� ��Zej
dd� �Zd`dd�Zeed d
dd �d d � �Zej
d d � �Zeedd d
dd �d!d"� �Zej
d#d$� �Zeejd�eedd d
dd �d%d&� ��Zej
d'd(� �Zeejd�eedd d
dd �d)d*� ��Zej
d+d,� �Zdad-d.�Zeed d
�d/d0� �Zej
d1d2� �Zeed d
�d3d4� �Z e j
d5d6� �Z eed d
�d7d8� �Z e j
d9d:� �Z eed d
�d;d<� �Z e j
d=d>� �Z!eed d
�d?d@� �Z"e"j
dAdB� �Z#eed d
�dCdD� �Z$e$j
dEdF� �Z%dbdGdH�Z&eedd d
dd �dIdJ� �Z'e'j
dKdL� �Z(eedd d
dd �dMdN� �Z)e)j
dOdP� �Z*eedd d
dd �dQdR� �Z+e+j
dSdT� �Z,eedd d
dd �dUdV� �Z-e-j
dWdX� �Z.eedd d
dd �dYdZ� �Z/e/j
d[d\� �Z0d]S )c�RFC3542AncillaryTestr� rE c C s8 i }x.|D ]&\}}}| j ||f|� ||||f< q
W |S )N)r� )r r� �dr� r� r� r r r
�ancillaryMapping s
z%RFC3542AncillaryTest.ancillaryMappingr� r c C s | j jtjtjd� | jj� | j| j tt �|�\}}}}| j
|t � | j || j � | j
|dtj|d� | j
t|�d� | j|d t� |d \}} }
| j
|tj� | j
| tj� | j|
t� | j
t|
�t� tjd�} | j|
� | j| d d� | j| d |� d S )NrE T)r r r r r )r, r? r � IPPROTO_IPV6�IPV6_RECVHOPLIMITr
rC r rU r� r� r rm r r r� r� �
IPV6_HOPLIMITr� r� r8 r� r$ r% ) r �
ancbufsize�maxhopr� r� r� rR rr r� r� r� r$ r r r
�
checkHopLimit s(
z"RFC3542AncillaryTest.checkHopLimitr� r� c C s | j dd� d S )Ni ( )r� )r� )r r r r
�testRecvHopLimit4 s z%RFC3542AncillaryTest.testRecvHopLimitc C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testRecvHopLimit9 s z&RFC3542AncillaryTest._testRecvHopLimitrC c C s | j tjt�d� d S )N)r� )r� r rC r� )r r r r
�testRecvHopLimitCMSG_SPACEA s z/RFC3542AncillaryTest.testRecvHopLimitCMSG_SPACEc C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testRecvHopLimitCMSG_SPACEF s z0RFC3542AncillaryTest._testRecvHopLimitCMSG_SPACEr� c C s | j d| jd� d S )Ni ( )r� r� )r� � hop_limit)r r r r
�testSetHopLimitP s z$RFC3542AncillaryTest.testSetHopLimitc C sL | j | jj| jd�� | j| jtgtjtj t
j
d| j g�fg�t t�� d S )N)rj r )
r� r
rV r! r� r r� r r� r� r8 r� rU )r r r r
�_testSetHopLimitW s z%RFC3542AncillaryTest._testSetHopLimitc C sB | j jtjtjd� | j jtjtjd� | jj� | j| j t t
�|�\}}}}| j |t
� | j || j
� | j|dtj|d� | j t |�d� | j|�}|tjtjf } | j t | �t� tjd�}
|
j| � | j|
d d� | j|
d d� |tjtjf } | j t | �t� tjd�}
|
j| � | j|
d d� | j|
d |� d S )NrE T)r r r r� r r r� )r, r? r r� r� �IPV6_RECVTCLASSr
rC r rU r� r� r rm r r r� � IPV6_TCLASSr� r8 r� r$ r% r� ) r r� r� r� r� r� rR rr ZancmapZtcdatar$ Zhldatar r r
� checkTrafficClassAndHopLimit` s2
z1RFC3542AncillaryTest.checkTrafficClassAndHopLimitr� r� c C s | j dd� d S )Ni ( )r� )r� )r r r r
� testRecvTrafficClassAndHopLimit� s z4RFC3542AncillaryTest.testRecvTrafficClassAndHopLimitc C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
� _testRecvTrafficClassAndHopLimit� s z5RFC3542AncillaryTest._testRecvTrafficClassAndHopLimitc C s | j tjt�d d� d S )Nr� )r� )r� r rC r� )r r r r
�)testRecvTrafficClassAndHopLimitCMSG_SPACE� s z>RFC3542AncillaryTest.testRecvTrafficClassAndHopLimitCMSG_SPACEc C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�*_testRecvTrafficClassAndHopLimitCMSG_SPACE� s z?RFC3542AncillaryTest._testRecvTrafficClassAndHopLimitCMSG_SPACEc C s | j d| jd� d S )Ni ( )r� r� )r� r� )r r r r
� testSetTrafficClassAndHopLimit� s z3RFC3542AncillaryTest.testSetTrafficClassAndHopLimitc C sd | j | jj| jd�� | j| jtgtjtj t
j
d| j g�ftjtj t
j
d| j
g�fg�tt�� d S )N)rj r )r� r
rV r! r� r r� r r� r� r8 �
traffic_classr� r� rU )r r r r
� _testSetTrafficClassAndHopLimit� s z4RFC3542AncillaryTest._testSetTrafficClassAndHopLimitc C s | j d| jd� d S )Ni ( )r� r� )r� r� )r r r r
�testOddCmsgSize� s z$RFC3542AncillaryTest.testOddCmsgSizec C s� | j | jj| jd�� yJ| jtgtjtjt j d| j
g�j � d ftjtj t j d| j
g�fg�}W n~ tk
r� } zb| j|jt� | jtgtjtjt j d| j
g�ftjtj t j d| j
g�fg�}| j|tt�� W Y d d }~X nX d S )N)rj r r )r� r
rV r! r r� r r� r� r8 r� rz r� r� r r� r� r� r� rU )r ru ra r r r
�_testOddCmsgSize� s" z%RFC3542AncillaryTest._testOddCmsgSizec C s� | j jtjtjd� | jj� |d kr*f n|f}| j| j tt �f|�� \}}}}| j
|t � | j || j � | j
|g � | j
|dtj|d� d S )NrE T)r r r )r, r? r r� r� r
rC r rU r� r� r rm r r )r r� r� r* r� r� rR rr r r r
� checkHopLimitTruncatedHeader� s
z1RFC3542AncillaryTest.checkHopLimitTruncatedHeaderc C s | j d tjd� d S )N)r� r� )r� r r )r r r r
r� � s z+RFC3542AncillaryTest.testCmsgTruncNoBufSizec C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
r� � s z,RFC3542AncillaryTest._testCmsgTruncNoBufSizec C s | j dtjd� d S )Nr )r� r� )r� r r )r r r r
�testSingleCmsgTrunc0� s z)RFC3542AncillaryTest.testSingleCmsgTrunc0c C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testSingleCmsgTrunc0� s z*RFC3542AncillaryTest._testSingleCmsgTrunc0c C s | j dd� d S )NrE )r� )r� )r r r r
�testSingleCmsgTrunc1
s z)RFC3542AncillaryTest.testSingleCmsgTrunc1c C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testSingleCmsgTrunc1
s z*RFC3542AncillaryTest._testSingleCmsgTrunc1c C s | j dt d� d S )Nr� )r� )r� r� )r r r r
�testSingleCmsgTrunc2Int
s z,RFC3542AncillaryTest.testSingleCmsgTrunc2Intc C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testSingleCmsgTrunc2Int
s z-RFC3542AncillaryTest._testSingleCmsgTrunc2Intc C s | j tjd�d d� d S )Nr rE )r� )r� r r� )r r r r
� testSingleCmsgTruncLen0Minus1
s z2RFC3542AncillaryTest.testSingleCmsgTruncLen0Minus1c C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
� _testSingleCmsgTruncLen0Minus1
s z3RFC3542AncillaryTest._testSingleCmsgTruncLen0Minus1c C s� | j jtjtjd� | jj� | j| j tt �tj
t �d �\}}}}| j |t � | j
|| j� | j|dtjd� | jt|�d� |r�|d \}}}| j |tj� | j |tj� | jt|�t � d S )NrE T)r r r )r, r? r r� r� r
rC r rU r� r� r� r� r rm r r r% r� r� )r r� r� rR rr r� r� r� r r r
�testSingleCmsgTruncInData
s
" z.RFC3542AncillaryTest.testSingleCmsgTruncInDatac C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testSingleCmsgTruncInData4
s z/RFC3542AncillaryTest._testSingleCmsgTruncInDatac C s | j jtjtjd� | j jtjtjd� | jj� | j| j t t
�|�\}}}}| j |t
� | j || j
� | j|dtj|d� | j t |�d� |d \}}} | j |tj� | j|tjtjh� | j t | �t� tjd�}
|
j| � | j|
d d� | j|
d d� d S )NrE T)r r r r r r� )r, r? r r� r� r� r
rC r rU r� r� r rm r r r� r� r� r� r8 r� r$ r% ) r r� r� r� r� rR rr r� r� r� r$ r r r
�checkTruncatedSecondHeader9
s(
z/RFC3542AncillaryTest.checkTruncatedSecondHeaderc C s | j tjt�tjd� d S )N)r� )r� r rC r� r )r r r r
�testSecondCmsgTrunc0Y
s z)RFC3542AncillaryTest.testSecondCmsgTrunc0c C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testSecondCmsgTrunc0_
s z*RFC3542AncillaryTest._testSecondCmsgTrunc0c C s | j tjt�d � d S )NrE )r� r rC r� )r r r r
�testSecondCmsgTrunc1d
s z)RFC3542AncillaryTest.testSecondCmsgTrunc1c C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testSecondCmsgTrunc1i
s z*RFC3542AncillaryTest._testSecondCmsgTrunc1c C s | j tjt�dt � d S )Nr� )r� r rC r� )r r r r
�testSecondCmsgTrunc2Intn
s z,RFC3542AncillaryTest.testSecondCmsgTrunc2Intc C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testSecondCmsgTrunc2Intt
s z-RFC3542AncillaryTest._testSecondCmsgTrunc2Intc C s" | j tjt�tjd� d � d S )Nr rE )r� r rC r� r� )r r r r
� testSecondCmsgTruncLen0Minus1y
s z2RFC3542AncillaryTest.testSecondCmsgTruncLen0Minus1c C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
� _testSecondCmsgTruncLen0Minus1
s z3RFC3542AncillaryTest._testSecondCmsgTruncLen0Minus1c
C sT | j jtjtjd� | j jtjtjd� | jj� | j| j t t
�tj t �tj
t � d �\}}}}| j|t
� | j|| j� | j|dtjd� tjtjh}|jd�\}}}| j|tj� |j|� | jt |�t � tjd�} | j|� | j| d d� | j| d d� |�rD|jd�\}}}| j|tj� |j|� | jt |�t � | j|g � d S )NrE T)r r r r r� ) r, r? r r� r� r� r
rC r rU r� rC r� r� r� r rm r r r� r� �pop�remover8 r� r$ r% r� )
r r� r� rR rr Z
cmsg_typesr� r� r� r$ r r r
�testSecomdCmsgTruncInData�
s4
"
z.RFC3542AncillaryTest.testSecomdCmsgTruncInDatac C s$ | j | jj| jd�� | jt� d S )N)rj )r� r
rV r! r r� )r r r r
�_testSecomdCmsgTruncInData�
s z/RFC3542AncillaryTest._testSecomdCmsgTruncInDataNr )r� r )r� r )r )r )1r r r! r� r� r� r� r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r r r r
r� � sp
#
$r� c @ s e Zd ZdS )�SendrecvmsgUDPTestBaseN)r r r! r r r r
r �
s r r� c @ s e Zd ZdS )�SendmsgUDPTestN)r r r! r r r r
r �
s r r� c @ s e Zd ZdS )�RecvmsgUDPTestN)r r r! r r r r
r �
s r r# c @ s e Zd ZdS )�RecvmsgIntoUDPTestN)r r r! r r r r
r
�
s r
c @ s e Zd Zdd� ZdS )�SendrecvmsgUDP6TestBasec C s | j |d d� |d d� � d S )NrE r r )r� )r r r r r r
r �
s z+SendrecvmsgUDP6TestBase.checkRecvmsgAddressN)r r r! r r r r r
r �
s r z IPv6 required for this test.r� r# c @ s e Zd ZdS )�SendmsgUDP6TestN)r r r! r r r r
r �
s r c @ s e Zd ZdS )�RecvmsgUDP6TestN)r r r! r r r r
r
�
s r
c @ s e Zd ZdS )�RecvmsgIntoUDP6TestN)r r r! r r r r
r �
s r r� c @ s e Zd ZdS )� RecvmsgRFC3542AncillaryUDP6TestN)r r r! r r r r
r �
s r c @ s e Zd ZdS )�#RecvmsgIntoRFC3542AncillaryUDP6TestN)r r r! r r r r
r �
s r c @ s e Zd ZdS )�SendrecvmsgTCPTestBaseN)r r r! r r r r
r �
s r c @ s e Zd ZdS )�SendmsgTCPTestN)r r r! r r r r
r �
s r c @ s e Zd ZdS )�RecvmsgTCPTestN)r r r! r r r r
r s r c @ s e Zd ZdS )�RecvmsgIntoTCPTestN)r r r! r r r r
r s r c @ s e Zd ZdS )� SendrecvmsgSCTPStreamTestBaseN)r r r! r r r r
r s r r r r� c @ s e Zd ZdS )�SendmsgSCTPStreamTestN)r r r! r r r r
r s r c s e Zd Z� fdd�Z� ZS )�RecvmsgSCTPStreamTestc sR yt t| �j� W n: tk
rL } z |jtjkr2� | jd� W Y d d }~X nX d S )Nz4sporadic ENOTCONN (kernel issue?) - see issue #13876)r% r rm r r� �ENOTCONNr6 )r ra )r, r r
rm s z$RecvmsgSCTPStreamTest.testRecvmsgEOF)r r r! rm r/ r r )r, r
r s r c s e Zd Z� fdd�Z� ZS )�RecvmsgIntoSCTPStreamTestc sR yt t| �j� W n: tk
rL } z |jtjkr2� | jd� W Y d d }~X nX d S )Nz4sporadic ENOTCONN (kernel issue?) - see issue #13876)r% r rm r r� r r6 )r ra )r, r r
rm - s z(RecvmsgIntoSCTPStreamTest.testRecvmsgEOF)r r r! rm r/ r r )r, r
r ' s r c @ s e Zd ZdS )� SendrecvmsgUnixStreamTestBaseN)r r r! r r r r
r 6 s r r� c @ s e Zd ZdS )�SendmsgUnixStreamTestN)r r r! r r r r
r : s r c @ s e Zd ZdS )�RecvmsgUnixStreamTestN)r r r! r r r r
r @ s r c @ s e Zd ZdS )�RecvmsgIntoUnixStreamTestN)r r r! r r r r
r G s r r� r� c @ s e Zd ZdS )�RecvmsgSCMRightsStreamTestN)r r r! r r r r
r N s r c @ s e Zd ZdS )� RecvmsgIntoSCMRightsStreamTestN)r r r! r r r r
r T s r c sD e Zd Z� fdd�ZdZeed�r0dZdd� Zn dZd d� Z� Z S )
�InterruptedTimeoutBasec s2 t � j� tjtjdd� �}| jtjtj|� d S )Nc S s dd S )NrE r r )Zsignumr� r r r
r� i s z.InterruptedTimeoutBase.setUp.<locals>.<lambda>)r% r re rf r- )r Zorig_alrm_handler)r, r r
r f s
z InterruptedTimeoutBase.setUpg @� setitimerg�������?c C s t jt j|� d S )N)re r! � ITIMER_REAL)r �secondsr r r
�setAlarmu s z InterruptedTimeoutBase.setAlarmr� c C s t j|� d S )N)re r_ )r r# r r r
r$ { s )
r r r! r rj r_ re �
alarm_timer$ r/ r r )r, r
r a s
r � siginterruptr_ r! z+Don't have signal.alarm or signal.setitimerc sl e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Ze e
j
d
�dd� �Z e e
j
d�dd� �Z � Z
S )�InterruptedRecvTimeoutTestc s t � j� | jj| j� d S )N)r% r r rA rj )r )r, r r
r � s
z InterruptedRecvTimeoutTest.setUpc O sB z0| j | j� | jt��}|||� W d Q R X W d | j d� X d S )Nr )r$ r% r� rg )r r r* r+ r� r r r
�checkInterruptedRecv� s
z/InterruptedRecvTimeoutTest.checkInterruptedRecvc C s | j | jjd� d S )Ni )r( r r� )r r r r
�testInterruptedRecvTimeout� s z5InterruptedRecvTimeoutTest.testInterruptedRecvTimeoutc C s | j | jjtd�� d S )Ni )r( r � recv_intor2 )r r r r
� testInterruptedRecvIntoTimeout� s z9InterruptedRecvTimeoutTest.testInterruptedRecvIntoTimeoutc C s | j | jjd� d S )Ni )r( r r� )r r r r
� testInterruptedRecvfromTimeout� s z9InterruptedRecvTimeoutTest.testInterruptedRecvfromTimeoutc C s | j | jjtd�� d S )Ni )r( r �
recvfrom_intor2 )r r r r
�"testInterruptedRecvfromIntoTimeout� s z=InterruptedRecvTimeoutTest.testInterruptedRecvfromIntoTimeoutr� c C s | j | jjd� d S )Ni )r( r r� )r r r r
� testInterruptedRecvmsgTimeout� s z8InterruptedRecvTimeoutTest.testInterruptedRecvmsgTimeoutr# c C s | j | jjtd�g� d S )Ni )r( r r# r2 )r r r r
�!testInterruptedRecvmsgIntoTimeout� s z<InterruptedRecvTimeoutTest.testInterruptedRecvmsgIntoTimeout)r r r! r r( r) r+ r, r. r� r r/ r0 r/ r r )r, r
r' � s
r' c st e Zd Z� fdd�Zdd� Zdd� Zejdd�d d
� �Zejdd�d d � �Z ejdd�e
e j d
�dd� ��Z � Z
S )�InterruptedSendTimeoutTestc sp t � j� | j� | _| j| jj� tj| jd�}|j � | j
j � \| _ }| j| j j� |j
� | jj| j� d S )N)�target)r% r rz rt r- r
r' ZThread� doConnect�startr ro rp r� rA rj )r Z
cli_threadrr )r, r r
r � s
z InterruptedSendTimeoutTest.setUpc C s | j j| j� d S )N)rt rs r} )r r r r
r3 � s z$InterruptedSendTimeoutTest.doConnectc O sH z6| j t��"}x| j| j� |||� qW W d Q R X W d | jd� X d S )Nr )r� rg r$ r% )r r r* r+ r� r r r
�checkInterruptedSend� s z/InterruptedSendTimeoutTest.checkInterruptedSendr r� c C s | j | jjdd � d S )NrN i )r5 rt rB )r r r r
�testInterruptedSendTimeout� s z5InterruptedSendTimeoutTest.testInterruptedSendTimeoutc C s | j | jjdd | j� d S )NrN i )r5 rt r� r} )r r r r
� testInterruptedSendtoTimeout� s z7InterruptedSendTimeoutTest.testInterruptedSendtoTimeoutr� c C s | j | jjdd g� d S )NrN i )r5 rt r� )r r r r
� testInterruptedSendmsgTimeout� s z8InterruptedSendTimeoutTest.testInterruptedSendmsgTimeout)r r r! r r3 r5 r Zrequires_mac_verr6 r7 r� r r8 r/ r r )r, r
r1 � s
r1 c @ s e Zd Zdd� Zdd� ZdS )�
TCPCloserTestc C sh | j j� \}}|j� | j}tj|gg g d�\}}}| j||g� | j|jd�d� |j� |j� d S )Ng �?rE r� )r ro r
rg r� r� r� )r rq rr �sdr� r� r� r r r
� testClose� s zTCPCloserTest.testClosec C s | j jt| jf� tjd� d S )Ng �?)rg rs rk r �time�sleep)r r r r
�
_testClose� s zTCPCloserTest._testCloseN)r r r! r; r> r r r r
r9 � s
r9 c @ sN e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dS )�BasicSocketPairTestre c C s t j| |d� d S )N)rf )ru r& )r rf r r r
r& � s z BasicSocketPairTest.__init__c C s\ | j |tj� ttd�r*| j|jtj� n| j|jtj� | j|jtj� | j|j d� d S )Nr� r )
r� r r_ r� r� r� r r� r r� )r r� r r r
�_check_defaults s
z#BasicSocketPairTest._check_defaultsc C s | j | j� d S )N)r@ rg )r r r r
�
_testDefaults s z!BasicSocketPairTest._testDefaultsc C s | j | j� d S )N)r@ r )r r r r
� testDefaults s z BasicSocketPairTest.testDefaultsc C s | j jd�}| j|t� d S )Ni )r r� r� r� )r r� r r r
r� s z BasicSocketPairTest.testRecvc C s | j jt� d S )N)rg rB r� )r r r r
r� s z BasicSocketPairTest._testRecvc C s | j jt� d S )N)r rB r� )r r r r
�testSend s z BasicSocketPairTest.testSendc C s | j jd�}| j|t� d S )Ni )rg r� r� r� )r r� r r r
� _testSend s z BasicSocketPairTest._testSendN)re ) r r r! r& r@ rA rB r� r� rC rD r r r r
r? � s
r? c @ s� e Zd Zd$dd�Zdd� Zdd� Zejdd � �Zeje�Z e
j e e
d
�d �ejd d
d�dd� ��Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#S )%�NonBlockingTCPTestsre c C s t j� | _tj| |d� d S )N)rf )r' rJ �eventrd r& )r rf r r r
r& " s
z NonBlockingTCPTests.__init__c C s� | j jd� | j| j j� � | j jd� | j| j j� d� tj� }y| j j� W n tk
rd Y nX tj� }| j|| dk d� d S )NTFg g �?z Error setting non-blocking mode.) r � setblockingrG r r� r< ro r r� )r r4 �endr r r
�testSetBlocking& s z#NonBlockingTCPTests.testSetBlockingc C s d S )Nr )r r r r
�_testSetBlocking4 s z$NonBlockingTCPTests._testSetBlockingc C sb dd l }|j|jkr | jd� | jjd� | j| jj� d� | jj|jd � | j| jj� � d S )Nr zneeds UINT_MAX < ULONG_MAXFg rE ) r� r� Z ULONG_MAXr6 r rG r� r rG )r r� r r r
�testSetBlocking_overflow7 s
z,NonBlockingTCPTests.testSetBlocking_overflow�
SOCK_NONBLOCKz test needs socket.SOCK_NONBLOCKr� � � c C s� | j j� tjtjtjtjB �| _ tj| j �| _| j j � t
j
� }y| j j � W n t k
rd Y nX t
j
� }| j
|| dk d� d S )Ng �?z&Error creating with non-blocking mode.)r r
r r r rL r r r r r< ro r r� )r r4 rH r r r
�testInitNonBlockingD s
z'NonBlockingTCPTests.testInitNonBlockingc C s d S )Nr )r r r r
�_testInitNonBlockingW s z(NonBlockingTCPTests._testInitNonBlockingc C sH | j jd� z | j j� \}}|jtt��}W d |j� | j jd � X d S )Nr )r rA ro r� rU r� r
)r rq rr �messager r r
�testInheritFlagsZ s z$NonBlockingTCPTests.testInheritFlagsc C s6 t jd� | jjt| jf� t jd� | jjt� d S )Ng�������?g �?)r< r= rg rs rk r rB r� )r r r r
�_testInheritFlagse s
z%NonBlockingTCPTests._testInheritFlagsc C s� | j jd� | jt�� | j j� \}}W d Q R X | jj� tj| j gg g t�\}}}| j |krh| j d� | j j� \}}| j
|j � | j |j
� � d S )Nr z'Error trying to do accept after select.)r rG r� �BlockingIOErrorro rF rC r� � MAIN_TIMEOUTr� r- r
rG r )r rq rr r� r� r� r r r
�
testAcceptk s
z NonBlockingTCPTests.testAcceptc C s | j j� | jjt| jf� d S )N)rF rV rg rs rk r )r r r r
� _testAccept~ s
z NonBlockingTCPTests._testAcceptc C s | j j� \}}|j� d S )N)r ro r
)r rq rr r r r
� testConnect� s z NonBlockingTCPTests.testConnectc C s" | j jd� | j jt| jf� d S )Nr )rg rA rs rk r )r r r r
� _testConnect� s z NonBlockingTCPTests._testConnectc C s� | j j� \}}| j|j� |jd� | jt�� |jtt ��}W d Q R X | j
j � t j |gg g t
�\}}}||kr|| jd� |jtt ��}| j|t � d S )Nr z0Error during select call to non-blocking socket.)r ro r- r
rG r� rT r� rU r� rF rC r� rU r� r� )r rq rr r� r� r� r� r r r
r� � s
z NonBlockingTCPTests.testRecvc C s, | j jt| jf� | jj� | j jt� d S )N)rg rs rk r rF rV rh r� )r r r r
r� � s
z NonBlockingTCPTests._testRecvN)re )r r r! r& rI rJ r r� rK Z_testSetBlocking_overflowrv r� r_ r �requires_linux_versionrO rP rR rS rV rW rX rY r� r� r r r r
rE s"
rE c @ s� e Zd Zd:ZdZdZdZdZeZ dZ
eZ d;dd �Z d
d � Z
d d
� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d*d+� Z d,d-� Z d.d/� Z d0d1� Z d2d3� Z!d4d5� Z"d6d7� Z#d8d9� Z$dS )<�FileObjectClassTestCaserE zutf-8�strictNrp r~ re c C s t j| |d� d S )N)rf )rn r& )r rf r r r
r& � s z FileObjectClassTestCase.__init__c C sR dd� t d�D �\| _| _| _| _tj| � | jj| j | j
| j | j | j
d�| _d S )Nc S s g | ] }t j� �qS r )r' rJ )r� r r r r
r� � s z1FileObjectClassTestCase.setUp.<locals>.<listcomp>r� )�encoding�errors�newline)r� �evt1�evt2�
serv_finished� cli_finishedrn r rp rr � read_moder7 r] r^ r_ � read_file)r r r r
r � s "
z FileObjectClassTestCase.setUpc C s6 | j j� | jj� | j| jj� d | _tj| � d S )N)rb rC re r
r� �closedrn r )r r r r
r � s
z FileObjectClassTestCase.tearDownc C s0 t j| � | jj| j| j| j| j| jd�| _ d S )N)r] r^ r_ )
rn r[ rt rr �
write_moder7 r] r^ r_ �
write_file)r r r r
r[ � s
z#FileObjectClassTestCase.clientSetUpc C s6 | j j� | jj� | j| jj� d | _tj| � d S )N)rc rC rh r
r� rf rn r^ )r r r r
r^ � s
z&FileObjectClassTestCase.clientTearDownc C sd | j jd� | jjd� | jtj| jjd� | jt��}| jjd� W d Q R X | jdt |j
�� d S )NrE r z!cannot read from timed out object) rp rA re r� r� r rj r r� r� r� )r Zctxr r r
�testReadAfterTimeout� s z,FileObjectClassTestCase.testReadAfterTimeoutc C s. | j j| jdd� � | j j� | jj� d S )Nr r )rh r� � write_msg�flushrb rV )r r r r
�_testReadAfterTimeout� s
z-FileObjectClassTestCase._testReadAfterTimeoutc C s< | j jt| j�d �}| j jd�}|| }| j|| j� d S )Nr )re r� rU �read_msgr� )r � first_segZ
second_segr� r r r
�
testSmallRead� s z%FileObjectClassTestCase.testSmallReadc C s | j j| j� | j j� d S )N)rh r� rj rk )r r r r
�_testSmallRead� s z&FileObjectClassTestCase._testSmallReadc C s | j j� }| j|| j� d S )N)re r� r� rm )r r� r r r
� testFullRead s
z$FileObjectClassTestCase.testFullReadc C s | j j| j� | j j� d S )N)rh r� rj r
)r r r r
�
_testFullRead s z%FileObjectClassTestCase._testFullReadc C s> t | j�� }x | jjd�}|s P ||7 }qW | j|| j� d S )NrE )r� rm re r� r� )r r& �charr r r
�testUnbufferedRead s z*FileObjectClassTestCase.testUnbufferedReadc C s | j j| j� | j j� d S )N)rh r� rj rk )r r r r
�_testUnbufferedRead s z+FileObjectClassTestCase._testUnbufferedReadc C s | j j� }| j|| j� d S )N)re �readliner� rm )r �liner r r
� testReadline s
z$FileObjectClassTestCase.testReadlinec C s | j j| j� | j j� d S )N)rh r� rj rk )r r r r
�
_testReadline s z%FileObjectClassTestCase._testReadlinec C s& | j j� | jj� }| j|| j� d S )N)rp r
re r� r� rm )r r� r r r
�testCloseAfterMakefile" s
z.FileObjectClassTestCase.testCloseAfterMakefilec C s | j j| j� | j j� d S )N)rh r� rj rk )r r r r
�_testCloseAfterMakefile) s z/FileObjectClassTestCase._testCloseAfterMakefilec C s@ | j j� | jjtt��}t| jt�r.|j � }| j
|| j� d S )N) re r
rp r� rU r� r� rm r� �decoder� )r r� r r r
� testMakefileAfterMakefileClose- s
z6FileObjectClassTestCase.testMakefileAfterMakefileClosec C s | j j| j� | j j� d S )N)rh r� rj rk )r r r r
� _testMakefileAfterMakefileClose4 s z7FileObjectClassTestCase._testMakefileAfterMakefileClosec C s | j | jj � d S )N)r� re rf )r r r r
�testClosedAttr8 s z&FileObjectClassTestCase.testClosedAttrc C s | j | jj � d S )N)r� rh rf )r r r r
�_testClosedAttr; s z'FileObjectClassTestCase._testClosedAttrc C s, | j | jj| j� | j | jj| jj� � d S )N)r� re r rd r� rp r� )r r r r
�testAttributes> s z&FileObjectClassTestCase.testAttributesc C s, | j | jj| j� | j | jj| jj� � d S )N)r� rh r rg r� rt r� )r r r r
�_testAttributesB s z'FileObjectClassTestCase._testAttributesc C s8 | j j� | jt| j j� | jj� | jt| jj� d S )N)re r
r� r r� rp r rl )r r r r
�
testRealCloseF s
z%FileObjectClassTestCase.testRealClosec C s d S )Nr )r r r r
�_testRealCloseL s z&FileObjectClassTestCase._testRealCloser )re )%r r r! r7 r] r^ r_ rd r� rm rg rj r& r r r[ r^ ri rl ro rp rq rr rt ru rx ry rz r{ r} r~ r r� r� r� r� r� r r r r
r[ � sB
r[ c @ s` e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dS )�!UnbufferedFileObjectClassTestCaser c C sL | j j� }| j|d| j � | jjdd�| _ | j j� }| j|d| j � d S )Ns A. rp r s B. )re rv r� rj rp rr )r rw r r r
�testUnbufferedReadline\ s
z8UnbufferedFileObjectClassTestCase.testUnbufferedReadlinec C s2 | j jd| j � | j jd| j � | j j� d S )Ns A. s B. )rh r� rj rk )r r r r
�_testUnbufferedReadlined s z9UnbufferedFileObjectClassTestCase._testUnbufferedReadlinec C sD | j j� | j jd�}| j|| j� | jj� | jt| j jd� d S )Ni )rp r
r� r� rm re r� r )r r� r r r
�testMakefileClosei s
z3UnbufferedFileObjectClassTestCase.testMakefileClosec C s | j j| j� | j j� d S )N)rh r� rj rk )r r r r
�_testMakefileCloser s z4UnbufferedFileObjectClassTestCase._testMakefileClosec C s6 t j| j�}| jj� t j| j�}| j|d |� d S )NrE )r� r� rp re r
r� )r Zrefcount_beforeZrefcount_afterr r r
� testMakefileCloseSocketDestroyv s
z@UnbufferedFileObjectClassTestCase.testMakefileCloseSocketDestroyc C s d S )Nr )r r r r
� _testMakefileCloseSocketDestroy| s zAUnbufferedFileObjectClassTestCase._testMakefileCloseSocketDestroyc C s | j jd� | j| jjtd��d � | j| jjt| j�d �d � | j j
� | j j d� | jjt| j�d �}|d kr�t
jd� | jjt| j�d �}td�}| jj|�}| j|d� ||d |� }| j|| j� | j| jjtd��d � | j| jjd�d � d S )NFr r g �?g �?r� rE )rp rG r� re �readintor2 r� rU rm r` rC ra rV r< r= )r rn r& r� r� r r r
�testSmallReadNonBlocking� s
z:UnbufferedFileObjectClassTestCase.testSmallReadNonBlockingc C s> | j jd� | jj| j� | jj� | jj� | jjd� d S )Ng �?g @) r` rV rh r� rj rk ra rC rb )r r r r
�_testSmallReadNonBlocking� s
z;UnbufferedFileObjectClassTestCase._testSmallReadNonBlockingc C s" | j jd� | jr | j| j� d S )Ng @)rc rV � serv_skippedr6 )r r r r
�testWriteNonBlocking� s z6UnbufferedFileObjectClassTestCase.testWriteNonBlockingc C sv d | _ | jjd� dtj }d}| jj|�}| j|d� x8t|�D ]&}| jj|�}|d kr\P | j|d� qBW d| _ d S )NFrd r r z$failed to saturate the socket buffer) r� rt rG r ri rh r� r� r� )r ZBIGZLIMITr� r r r r
�_testWriteNonBlocking� s
z7UnbufferedFileObjectClassTestCase._testWriteNonBlockingN)r r r! r7 r� r� r� r� r� r� r� r� r� r� r r r r
r� P s
r� c @ s e Zd ZdZdS )�#LineBufferedFileObjectClassTestCaserE N)r r r! r7 r r r r
r� � s r� c @ s e Zd ZdZdS )�$SmallBufferedFileObjectClassTestCaser� N)r r r! r7 r r r r
r� � s r� c @ s& e Zd ZdZejd�ZdZeZdZ dS )�"UnicodeReadFileObjectClassTestCasers zutf-8r~ r� N)
r r r! rd r� r| rm rg rj r_ r r r r
r� � s
r� c @ s& e Zd ZdZeZdZejd�ZdZ dS )�#UnicodeWriteFileObjectClassTestCaserp r} zutf-8r� N)
r r r! rd r� rm rg r| rj r_ r r r r
r� � s
r� c @ s, e Zd ZdZejd�ZdZejd�ZdZ dS )�'UnicodeReadWriteFileObjectClassTestCasers zutf-8r} r� N)
r r r! rd r� r| rm rg rj r_ r r r r
r� � s
r� c @ s e Zd Zdd� ZdS )�NetworkConnectionTestc C s t jt| jf�| _| j| _d S )N)r �create_connectionrk r rg rt )r r r r
r[ � s z!NetworkConnectionTest.clientSetUpN)r r r! r[ r r r r
r� � s r� c @ s e Zd ZdS )�
BasicTCPTest2N)r r r! r r r r
r� � s r� c @ sD e Zd ZG dd� dej�Zejdd� �Zdd� Zdd� Z d d
� Z
d S ) �NetworkConnectionNoServerc @ s e Zd Zdd� ZdS )z$NetworkConnectionNoServer.MockSocketc G s t jd��d S )Nz timed out)r rj )r r* r r r
rs � s z,NetworkConnectionNoServer.MockSocket.connectN)r r r! rs r r r r
�
MockSocket� s r� c c s& t j }| jt _ z
d V W d |t _ X d S )N)r r� )r Z
old_socketr r r
�mocked_socket_module� s
z.NetworkConnectionNoServer.mocked_socket_modulec
C s^ t j� }tjtjtj�}| j|j� | jt��}|j t
|f� W d Q R X | j |j j
t
j� d S )N)r r9 r r r r- r
r� r rs rk r� r� r� � ECONNREFUSED)r r rg r� r r r
� test_connect s z&NetworkConnectionNoServer.test_connectc
C st t j� }| jt��}tjt|f� W d Q R X tjg}t td�rJ|j
tj � t td�r`|j
tj � | j
|jj|� d S )N� ENETUNREACH�
EADDRNOTAVAIL)r r9 r� r r r� rk r� r� r_ r� r� r� r� r� )r r r� Zexpected_errnosr r r
�test_create_connection s
z0NetworkConnectionNoServer.test_create_connectionc C s> | j � �, | jtj�� tjtdf� W d Q R X W d Q R X d S )Ni� )r� r� r rj r� rk )r r r r
� test_create_connection_timeout( s
z8NetworkConnectionNoServer.test_create_connection_timeoutN) r r r! r r� �
contextlib�contextmanagerr� r� r� r� r r r r
r� � s
r� c @ sv e Zd Zddd�Zdd� Zdd� Zdd � ZeZd
d � ZeZ d d
� Z
eZ dd� Z eZ
dd� ZeZdd� ZeZdd� ZdS )� NetworkConnectionAttributesTestre c C s t j| |d� tj| � d S )N)rf )r r& r= )r rf r r r
r& 3 s z(NetworkConnectionAttributesTest.__init__c C s t j� | _d S )N)r r9 � source_port)r r r r
r[ 7 s z+NetworkConnectionAttributesTest.clientSetUpc C s | j j� d | _ tj| � d S )N)rg r
r= r^ )r r r r
r^ : s
z.NetworkConnectionAttributesTest.clientTearDownc C s | j j� \}}|j� d S )N)r ro r
)r rq rr r r r
� _justAccept? s z+NetworkConnectionAttributesTest._justAcceptc C s8 t jt| jfdd�| _| j| jj� | j| jjd� d S )N� )rj r� ) r r� rk r rg r- r
r� r� )r r r r
� _testFamilyD s z+NetworkConnectionAttributesTest._testFamilyc C sH t jt| jfdd| jfd�| _| j| jj� | j| jj � d | j� d S )Nr� r� )rj Zsource_addressrE )
r r� rk r r� rg r- r
r� rl )r r r r
�_testSourceAddressJ s z2NetworkConnectionAttributesTest._testSourceAddressc C sd | j tj� d k� tjd� z$tjt| jf�| _| j| jj � W d tjd � X | j
| jj � d� d S )NrA ) r� r r r r� rk r rg r- r
r� r )r r r r
�_testTimeoutDefaultS s
z3NetworkConnectionAttributesTest._testTimeoutDefaultc C sh | j tj� d k� tjd� z(tjt| jfd d�| _| j| jj � W d tjd � X | j
| jj � d � d S )Nr� )rj ) r� r r r r� rk r rg r- r
r� r )r r r r
�_testTimeoutNone_ s
z0NetworkConnectionAttributesTest._testTimeoutNonec C s, t jt| jfdd�| _| j| jj� d� d S )Nr� )rj )r r� rk r rg r� r )r r r r
�_testTimeoutValueNamedk s z6NetworkConnectionAttributesTest._testTimeoutValueNamedc C s8 t jt| jfd�| _| j| jj� | j| jj� d� d S )Nr� ) r r� rk r rg r- r
r� r )r r r r
�_testTimeoutValueNonamedp s z8NetworkConnectionAttributesTest._testTimeoutValueNonamedN)re )r r r! r& r[ r^ r� Z
testFamilyr� ZtestSourceAddressr� ZtestTimeoutDefaultr� ZtestTimeoutNoner� ZtestTimeoutValueNamedr� ZtestTimeoutValueNonamedr� r r r r
r� 0 s
r� c @ sB e Zd Zddd�Zdd� Zdd� Zdd � ZeZd
d � Zd d
� Z dS )� NetworkConnectionBehaviourTestre c C s t j| |d� tj| � d S )N)rf )r r& r= )r rf r r r
r& x s z'NetworkConnectionBehaviourTest.__init__c C s d S )Nr )r r r r
r[ | s z*NetworkConnectionBehaviourTest.clientSetUpc C s | j j� d | _ tj| � d S )N)rg r
r= r^ )r r r r
r^ s
z-NetworkConnectionBehaviourTest.clientTearDownc C s2 | j j� \}}| j|j� tjd� |jd� d S )Nr s done!)r ro r- r
r< r= rB )r rq rr r r r
�testInsideTimeout� s
z0NetworkConnectionBehaviourTest.testInsideTimeoutc C s0 t jt| jf� | _}|jd�}| j|d� d S )Nr1 s done!)r r� rk r rg r� r� )r r� r� r r r
�_testInsideTimeout� s
z1NetworkConnectionBehaviourTest._testInsideTimeoutc s4 t jt| jfdd� | _� | jt j� fdd�� d S )NrE )rj c s
� j d�S )Nr1 )r� r )r� r r
r� � s zDNetworkConnectionBehaviourTest._testOutsideTimeout.<locals>.<lambda>)r r� rk r rg r� rj )r r )r� r
�_testOutsideTimeout� s z2NetworkConnectionBehaviourTest._testOutsideTimeoutN)re )
r r r! r& r[ r^ r� ZtestOutsideTimeoutr� r� r r r r
r� u s
r� c @ s6 e Zd Zdd� Zdd� Zejeed�d�dd� �Z d S )
�TCPTimeoutTestc s � fdd�}� j tj|d� d S )Nc s � j jd� � j j� d S )Ng �?)r rA ro )r* r+ )r r r
�
raise_timeout� s z4TCPTimeoutTest.testTCPTimeout.<locals>.raise_timeoutz*Error generating a timeout exception (TCP))r� r rj )r r� r )r r
�testTCPTimeout� s
z TCPTimeoutTest.testTCPTimeoutc C s| d}y| j jd� | j j� }W nJ tjk
r> | jd� Y n, tk
rT d}Y n | jd� Y nX |sx| jd� d S )NFg z%caught timeout instead of error (TCP)Tz!caught unexpected exception (TCP)z3accept() returned success when we did not expect it)r rA ro r rj r� r )r �ok�foor r r
�testTimeoutZero� s z TCPTimeoutTest.testTimeoutZeror_ ztest needs signal.alarm()c s
| j jd� G dd� dt�� � fdd�}tjtj|�}z�y�z�ytjd� | j j� }W n` tjk
rt | j d� Y nL � k
r� Y n: | j dt
j � d d� t j
� f � Y n X | j d � W d tjd
� X W n � k
r� | j d � Y nX W d tjtj|� X d S ) Ng @c @ s e Zd ZdS )z4TCPTimeoutTest.testInterruptedTimeout.<locals>.AlarmN)r r r! r r r r
�Alarm� s r� c s � �d S )Nr )re r� )r� r r
�
alarm_handler� s z<TCPTimeoutTest.testInterruptedTimeout.<locals>.alarm_handlerr� z caught timeout instead of Alarmz3caught other exception instead of Alarm: %s(%s):
%sznothing caughtr zgot Alarm in wrong place)r rA r re rf r_ ro r rj r� r� �exc_info� traceback�
format_exc)r r� rl r� r )r� r
�testInterruptedTimeout� s(
$z%TCPTimeoutTest.testInterruptedTimeoutN)
r r r! r� r� rv r� r_ re r� r r r r
r� � s r� c @ s e Zd Zdd� Zdd� ZdS )�UDPTimeoutTestc s � fdd�}� j tj|d� d S )Nc s � j jd� � j jd� d S )Ng �?i )r rA r� )r* r+ )r r r
r� � s z4UDPTimeoutTest.testUDPTimeout.<locals>.raise_timeoutz*Error generating a timeout exception (UDP))r� r rj )r r� r )r r
�testUDPTimeout� s
z UDPTimeoutTest.testUDPTimeoutc C s~ d}y | j jd� | j jd�}W nJ tjk
r@ | jd� Y n, tk
rV d}Y n | jd� Y nX |sz| jd� d S )NFg i z%caught timeout instead of error (UDP)Tz!caught unexpected exception (UDP)z1recv() returned success when we did not expect it)r rA r� r rj r� r )r r� r� r r r
r� � s z UDPTimeoutTest.testTimeoutZeroN)r r r! r� r� r r r r
r� � s r� c @ s e Zd Zdd� Zdd� ZdS )�TestExceptionsc C sJ | j ttt�� | j ttjt�� | j ttjt�� | j ttjt�� d S )N)r� �
issubclassr r r r� r� rj )r r r r
�testExceptionTree� s z TestExceptions.testExceptionTreec C sb t j t jt jd�}t j t jt jd|j� �}|j� | j|j� | jt�� |j d� W d Q R X d S )Nr F)
r r r r� r
r- r r� r rG )r Zsock0r� r r r
�test_setblocking_invalidfd� s z)TestExceptions.test_setblocking_invalidfdN)r r r! r� r� r r r r
r� � s r� r zLinux specific testc @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd S )
�TestLinuxAbstractNamespace�l c C s� d}t j t jt j��z}|j|� |j� t j t jt j��L}|j|j� � |j� d �&}| j|j� |� | j|j � |� W d Q R X W d Q R X W d Q R X d S )Ns python-test-hello �r )
r r� r r4 r rs rl ro r� Z getpeername)r �address�s1�s2Zs3r r r
�testLinuxAbstractNamespace� s
z5TestLinuxAbstractNamespace.testLinuxAbstractNamespacec
C sL dd| j d }tjtjtj�� }|j|� | j|j� |� W d Q R X d S )Nr � hrE )�
UNIX_PATH_MAXr r� r r4 r� rl )r r� r r r r
� testMaxName
s
z&TestLinuxAbstractNamespace.testMaxNamec C s> dd| j }tjtjtj��}| jt|j|� W d Q R X d S )N� �h)r� r r� r r� r r4 )r r� r r r r
�testNameOverflow s z+TestLinuxAbstractNamespace.testNameOverflowc
C s> t j t jt j�}z |jd� | j|j� d� W d |j� X d S )Nz
python test s
python test )r r� r r4 r� rl r
)r r r r r
� testStrName s
z&TestLinuxAbstractNamespace.testStrNamec
C s> t j t jt j��$}|jtd�� | j|j� d� W d Q R X d S )Ns
python test )r r� r r4 r2 r� rl )r r r r r
�testBytearrayName s z,TestLinuxAbstractNamespace.testBytearrayNameN) r r r! r� r� r� r� r� r� r r r r
r� � s r� ztest needs socket.AF_UNIXc @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dS )�TestUnixDomainc C s t j t jt j�| _d S )N)r r� r r� )r r r r
r ' s zTestUnixDomain.setUpc C s | j j� d S )N)r� r
)r r r r
r * s zTestUnixDomain.tearDownc C s: y
t j|�S tk
r4 | jdj|tj� �� Y nX d S )NzBPathname {0!a} cannot be represented in file system encoding {1!r})r� �fsencoderX r6 r� r� �getfilesystemencoding)r r� r r r
�encoded- s
zTestUnixDomain.encodedc C sX yt j||� W nB tk
rR } z&t|�dkr@| jdj|�� n� W Y d d }~X nX d S )NzAF_UNIX path too longz6Pathname {0!a} is too long to serve as an AF_UNIX path)r r� r r� r6 r� )r r� r� ra r r r
r4 8 s
zTestUnixDomain.bindc C s | j | jj� d� d S )Nr� )r� N)r� r� rl )r r r r
� testUnboundD s zTestUnixDomain.testUnboundc C s@ t jjtj�}| j| j|� | jtj|� | j | jj
� |� d S )N) r� r� �abspathr �TESTFNr4 r� r- r� r� rl )r r� r r r
� testStrAddrH s zTestUnixDomain.testStrAddrc C sF t jjtj�}| j| j| j|�� | jtj |� | j
| jj � |� d S )N) r� r� r� r r� r4 r� r� r- r� r� rl )r r� r r r
�
testBytesAddrO s z TestUnixDomain.testBytesAddrc C sR t jjtj�}| j|�}| j| j|jdd�� | j tj
|� | j | jj � |� d S )N�ascii�surrogateescape)
r� r� r� r ZTESTFN_UNICODEr� r4 r� r| r- r� r� rl )r r� rZ r r r
�testSurrogateescapeBindV s
z&TestUnixDomain.testSurrogateescapeBindc C sT t jd kr| jd� tjjt j�}| j| j|� | jt j |� | j
| jj � |� d S )Nz!No unencodable filename available) r ZTESTFN_UNENCODABLEr6 r� r� r� r4 r� r- r� r� rl )r r� r r r
�testUnencodableAddr_ s
z"TestUnixDomain.testUnencodableAddrN) r r r! r r r� r4 r� r� r� r� r� r r r r
r� $ s r� c @ s� e Zd Zddd�Zdd� Zdd� Zdd � ZeZd
d � ZeZ d d
� Z
dd� Z dd� Z e Z
dd� Ze Zdd� Zdd� Zdd� Ze ZdS ) � BufferIOTestre c C s t j| |d� d S )N)rf )rn r& )r rf r r r
r& n s zBufferIOTest.__init__c C sZ t j ddgtt� �}| jj|�}| j|tt�� |j� }|d tt�� }| j|t� d S )Nr7 r )r8 rU r� rp r* r� rz )r r& ru r� r r r
�testRecvIntoArrayq s z BufferIOTest.testRecvIntoArrayc C s t t�}| jj|� d S )N)r� r� rt rB )r r& r r r
�_testRecvIntoArrayy s z BufferIOTest._testRecvIntoArrayc C sD t d�}| jj|�}| j|tt�� |d tt�� }| j|t� d S )Ni )r2 rp r* r� rU r� )r r& ru r� r r r
�testRecvIntoBytearray} s
z"BufferIOTest.testRecvIntoBytearrayc C sH t d�}| jjt|��}| j|tt�� |d tt�� }| j|t� d S )Ni )r2 rp r* r~ r� rU r� )r r& ru r� r r r
�testRecvIntoMemoryview� s
z#BufferIOTest.testRecvIntoMemoryviewc C s^ t j ddgtt� �}| jj|�\}}| j|tt�� |j� }|d tt�� }| j|t� d S )Nr7 r )r8 rU r� rp r- r� rz )r r& ru rr r� r r r
�testRecvFromIntoArray� s z"BufferIOTest.testRecvFromIntoArrayc C s t t�}| jj|� d S )N)r� r� rt rB )r r& r r r
�_testRecvFromIntoArray� s z#BufferIOTest._testRecvFromIntoArrayc C sH t d�}| jj|�\}}| j|tt�� |d tt�� }| j|t� d S )Ni )r2 rp r- r� rU r� )r r& ru rr r� r r r
�testRecvFromIntoBytearray� s
z&BufferIOTest.testRecvFromIntoBytearrayc C sL t d�}| jjt|��\}}| j|tt�� |d tt�� }| j|t� d S )Ni )r2 rp r- r~ r� rU r� )r r& ru rr r� r r r
�testRecvFromIntoMemoryview� s
z'BufferIOTest.testRecvFromIntoMemoryviewc C s t d�}| jt| jj|d� d S )Nr3 i )r2 r� r rp r- )r r& r r r
�testRecvFromIntoSmallBuffer� s z(BufferIOTest.testRecvFromIntoSmallBufferc C s | j jt� d S )N)rt rB r� )r r r r
� _testRecvFromIntoSmallBuffer� s z)BufferIOTest._testRecvFromIntoSmallBufferc C s$ t � }| jj|� | jj|d� d S )Nr )r2 rp r- )r r& r r r
�testRecvFromIntoEmptyBuffer� s z(BufferIOTest.testRecvFromIntoEmptyBufferN)re )r r r! r& r� r� r� Z_testRecvIntoBytearrayr� Z_testRecvIntoMemoryviewr� r� r� Z_testRecvFromIntoBytearrayr� Z_testRecvFromIntoMemoryviewr� r� r� Z _testRecvFromIntoEmptyBufferr r r r
r� i s"
r� i� �� �� c C sf t td�sdS y td�} W n tttfk
r4 dS X | �" x| D ]}|jd�rBdS qBW W d Q R X dS )N�AF_TIPCFz
/proc/modulesztipc T)r_ r r� �FileNotFoundError�IsADirectoryError�PermissionErrorr )r� rw r r r
�isTipcAvailable� s
r� z6TIPC module is not loaded, please 'sudo modprobe tipc'c @ s e Zd Zdd� ZdS )�TIPCTestc C s� t j t jt j�}t j t jt j�}| j|j� | j|j� |jt jt jd� t jt t
t f}|j |� t j
t t
tt t
d � df}|jt|� |jd�\}}| j|j� |� | j|t� d S )NrE r� r i )r r� r� r- r
r? r� r� �TIPC_ADDR_NAMESEQ�
TIPC_STYPE�
TIPC_LOWER�
TIPC_UPPERr4 �TIPC_ADDR_NAMEr� r� r� r� r� rl )r r� rg �srvaddrZsendaddrr� Zrecvaddrr r r
�testRDM� s
zTIPCTest.testRDMN)r r r! r� r r r r
r� � s r� c @ s6 e Zd Zd
dd�Zdd� Zdd� Zdd � Zd
d � Zd S )�TIPCThreadableTestre c C s t jj| |d� tj| � d S )N)rf )rv rw r& r= )r rf r r r
r& � s zTIPCThreadableTest.__init__c C s� t j t jt j�| _| j| jj� | jjt jt jd� t j t
t t f}| jj
|� | jj� | j� | jj� \| _| _| j| jj� d S )NrE )r r� r r� r- r
r? r� r� r� r� r� r� r4 r rD ro rq �connaddr)r r� r r r
r � s
zTIPCThreadableTest.setUpc C sd t jd� tjtjtj�| _| j| jj� tjt t
t t t
d � df}| jj
|� | jj� | _d S )Ng�������?r� r )r< r= r r� r rg r- r
r� r� r� r� r� rs rl �cliaddr)r rr r r r
r[ s
z TIPCThreadableTest.clientSetUpc C s, | j jd�}| j|t� | j| j| j� d S )Ni )rq r� r� r� r� r� )r r� r r r
�
testStream s z TIPCThreadableTest.testStreamc C s | j jt� | j j� d S )N)rg rB r� r
)r r r r
� _testStream s z TIPCThreadableTest._testStreamN)re )r r r! r& r r[ r� r� r r r r
r� � s
r� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �ContextManagersTestc C s� t j � �}| j|j� W d Q R X | j|j� t j � �}|j� W d Q R X | j|j� t j � �}| jt|jd� W d Q R X | j|j� d S )Ns foo)r r< r r� r
r� r rh )r r� r r r
�_testSocketClass s
z$ContextManagersTest._testSocketClassc C s2 | j j� \}}| j|j� |jd�}|j|� d S )Ni )r ro r- r
r� rh )r rq rr r� r r r
�testCreateConnectionBase' s
z,ContextManagersTest.testCreateConnectionBasec
C sX | j j� }tj|��.}| j|j� |jd� | j|jd�d� W d Q R X | j |j� d S )Ns fooi )
r rl r r� r< r rh r� r� r� )r r� r� r r r
�_testCreateConnectionBase- s
z-ContextManagersTest._testCreateConnectionBasec C s2 | j j� \}}| j|j� |jd�}|j|� d S )Ni )r ro r- r
r� rh )r rq rr r� r r r
�testCreateConnectionClose5 s
z-ContextManagersTest.testCreateConnectionClosec C sH | j j� }tj|��}|j� W d Q R X | j|j� | jt|j d� d S )Ns foo)
r rl r r� r
r� r r� r rh )r r� r� r r r
�_testCreateConnectionClose; s
z.ContextManagersTest._testCreateConnectionCloseN)r r r! r r r r r r r r r
r s
r c @ s� e Zd Zejeed�d�ejddd�dd� ��Z dd � Z
d
d � Z d d
� Z ej
edkd�dd� �Zej
edkd�dd� �Zejeed�d�dd� �ZdS )�InheritanceTestrE zSOCK_CLOEXEC not definedr� rM rN c
C sF t j t jt jt jB ��&}| j|jt j@ � | j|j� � W d Q R X d S )N)r r r rE r� r� r< �get_inheritable)r r r r r
�test_SOCK_CLOEXECD s z!InheritanceTest.test_SOCK_CLOEXECc
C s, t j � }|� | j|j� d� W d Q R X d S )NF)r r� r )r r� r r r
�test_default_inheritableM s z(InheritanceTest.test_default_inheritablec C sL t j � }|�6 |j� }|j� |� | j|j� d� W d Q R X W d Q R X d S )NF)r r� r
r� r )r r� Znewsockr r r
�test_dupR s zInheritanceTest.test_dupc
C sP t j � }|�: |jd� | j|j� d� |jd� | j|j� d� W d Q R X d S )NTF)r �set_inheritabler� r )r r� r r r
�test_set_inheritableZ s
z$InheritanceTest.test_set_inheritableNz
need fcntlc C sn t j � }|�X |j� }| j|j� d� tj|tj�}|tj M }tj|tj|� | j|j� d� W d Q R X d S )NFT)r r� r� r �fcntl�F_GETFD�
FD_CLOEXECZF_SETFD)r r� r� rR r r r
� test_get_inheritable_cloexecc s z,InheritanceTest.test_get_inheritable_cloexecc C sh t j � }|�R |j� }| jtj|tj�tj@ tj� |jd� | jtj|tj�tj@ d� W d Q R X d S )NTr )r r� r� r
r r r )r r� r� r r r
� test_set_inheritable_cloexecq s
z,InheritanceTest.test_set_inheritable_cloexecrx zneed socket.socketpair()c C sH t j� \}}| j|j� | j|j� | j|j� d� | j|j� d� d S )NF)r rx r- r
r� r )r r� r� r r r
�test_socketpair~ s
z InheritanceTest.test_socketpair)r r r! rv r� r_ r r rZ r r r
r r� r
r r r r r r r
r C s
r rL zSOCK_NONBLOCK not definedc @ s, e Zd Zd dd�Zejddd�dd � �Zd
S ) �NonblockConstantTestT� c C sN |r(| j |jtj@ � | j|j� |� n"| j|jtj@ � | j|j� d � d S )N)r� r� r rL r� r r< )r r Znonblockrj r r r
�
checkNonblock� s
z"NonblockConstantTest.checkNonblockr� rM rN c & C sX t j t jt jt jB ��~}| j|� |jd� | j|d� |jd� | j|� |jd � | j|d� |jd� | j|dd� |jd� | j|d� W d Q R X t j� }t jd� t j � �}| j|� W d Q R X t jd � t j � �}| j|d� W d Q R X t jd� t j � �}| j|dd� W d Q R X t jd � t j � �}| j|d� W d Q R X t j|� d S )NrE Fr g @)rj g ) r r r rL r rG rA r r )r r �tr r r
�test_SOCK_NONBLOCK� s6
z'NonblockConstantTest.test_SOCK_NONBLOCKN)Tr )r r r! r r rZ r r r r r
r � s
r rJ zWindows specificzneed multiprocessingc @ s@ e Zd Zedd� �Zdd� Zdd� Zdd� Zd d
� Zd d � Z d
S )�TestSocketSharingc C sD |j � }|j � }tj|�}|j� \}}|j|� |j� |j� d S )N)rX r � fromsharero rh r
)r� �qZsdatarQ r r� rk r r r
�remoteProcessServer� s
z%TestSocketSharing.remoteProcessServerc C s� t j� }t j| j|fd�}|j� | jj|j�}| jj� }| jj � |j
|� d}|j
|� t j |�}g }x |j
d�}|s|P |j|� qlW |j � dj|�}| j||� |j� d S )N)r2 r* s
slapmahfrorM r� )�multiprocessingrN ZProcessr r4 r �share�pidrl r
r] r r� r� r� r� r� ) r r r� r� rr rQ r �m�receivedr r r
� testShare� s(
zTestSocketSharing.testSharec C s@ | j jtj� �}| jttj|d d� � | jttj|d � d S )NrE s foor )r r r� �getpidr� r r r )r r� r r r
�testShareLength� s z!TestSocketSharing.testShareLengthc C sb | j |j� d � | j |j� |j� � | j |j|j� | j |j|j� |jdkr^| j |j|j� d S )Nr )r� r r� r� r� )r Zorg�otherr r r
�compareSockets� s
z TestSocketSharing.compareSocketsc
C s< | j jtj� �}tj|�}z| j| j |� W d |j� X d S )N)r r r� r" r r r% r
)r r� r r r r
�testShareLocal s
z TestSocketSharing.testShareLocalc C s� t jt jg}t jt jg}x�|D ]~}xx|D ]p}yt j ||�}W n tk
rR w(Y nX z8|jtj� �}t j |�}z| j
||� W d |j � X W d |j � X q(W q W d S )N) r r r� r r# r r r� r" r r% r
)r Zfamilies�typesr� r �sourcer� Zsharedr r r
� testTypes s
zTestSocketSharing.testTypesN)
r r r! r� r r! r# r% r& r) r r r r
r � s #r c @ s� e Zd Zd>ZdZdZdZedd� �Zedd � �Z d
d � Z
d d
� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Z d0d1� Z d2d3� Z d4d5� Z d6d7� Z d8d9� Z!d:d;� Z"d<S )?�SendfileUsingSendTestr i i r� r� c C s� dd� }dj dd� t| j�D ��}ttjd��(}x || j| j�D ]}|j|� q@W W d Q R X ttjd��}|j� | _ W d Q R X d S )Nc s s* x| |kr|V | |8 } qW | r&| V d S )Nr )Ztotal�stepr r r
�chunks) s
z0SendfileUsingSendTest.setUpClass.<locals>.chunksr� c S s g | ]}t jtj�j� �qS r )�random�choice�stringZ
ascii_lettersr� )r� r r r r
r� 1 s z4SendfileUsingSendTest.setUpClass.<locals>.<listcomp>r~ rp )
r� r� �BUFSIZEr� r r� �FILESIZEr� r� �FILEDATA)r� r, �chunkr� Zcsizer r r
�
setUpClass' s
z SendfileUsingSendTest.setUpClassc C s t jt j� d S )N)r r� r� )r� r r r
�
tearDownClass: s z#SendfileUsingSendTest.tearDownClassc C s8 | j j| j� | j j� \}}|j| j� | j|j� |S )N)r rA �TIMEOUTro r- r
)r rq rr r r r
� accept_conn> s
z!SendfileUsingSendTest.accept_connc C s0 g }x |j | j�}|sP |j|� qW dj|�S )Nr� )r� r0 r� r� )r rq r r3 r r r
� recv_dataE s z SendfileUsingSendTest.recv_datac C s
t |d�S )NZ_sendfile_use_send)rR )r r� r r r
�meth_from_sockN s z$SendfileUsingSendTest.meth_from_sockc C sr | j j� }ttjd�}tj|��H}|�8}| j|�}||�}| j|| j � | j|j
� | j � W d Q R X W d Q R X d S )Nrp ) r rl r� r r� r r� r9 r� r1 �tell)r r� �filer� �meth�sentr r r
�_testRegularFileU s
z&SendfileUsingSendTest._testRegularFilec C s6 | j � }| j|�}| jt|�| j� | j|| j� d S )N)r7 r8 r� rU r1 r2 )r rq r� r r r
�testRegularFile^ s
z%SendfileUsingSendTest.testRegularFilec C s| | j j� }tj| j�}tj|��R}|�B}|j|�}| j|| j � | j|j
� | j � | j tj |j
|� W d Q R X W d Q R X d S )N)r rl �io�BytesIOr2 r r� r� r� r1 r: r� r� r� )r r� r; r� r= r r r
�_testNonRegularFilef s
z)SendfileUsingSendTest._testNonRegularFilec C s6 | j � }| j|�}| jt|�| j� | j|| j� d S )N)r7 r8 r� rU r1 r2 )r rq r� r r r
�testNonRegularFilep s
z(SendfileUsingSendTest.testNonRegularFilec C s� | j j� }tjd }t|d�� | jtj|� W d Q R X t|d�}tj|��D}|�4}| j |�}||�}| j
|d� | j
|j � d� W d Q R X W d Q R X d S )N�2r~ rp r ) r rl r r� r� r- r� r r� r9 r� r: )r r� �filenamer; r� r< r= r r r
�_testEmptyFileSendx s
z(SendfileUsingSendTest._testEmptyFileSendc C s" | j � }| j|�}| j|d� d S )Nr� )r7 r8 r� )r rq r� r r r
�testEmptyFileSend� s
z'SendfileUsingSendTest.testEmptyFileSendc C sz | j j� }ttjd�}tj|��P}|�@}| j|�}||dd�}| j|| j d � | j|j
� | j � W d Q R X W d Q R X d S )Nrp i� )�offset) r rl r� r r� r r� r9 r� r1 r: )r r� r; r� r< r= r r r
� _testOffset� s
z!SendfileUsingSendTest._testOffsetc C sB | j � }| j|�}| jt|�| jd � | j|| jdd � � d S )Ni� )r7 r8 r� rU r1 r2 )r rq r� r r r
�
testOffset� s
z SendfileUsingSendTest.testOffsetc C sz | j j� }ttjd�}tj|dd��L}|�<}d}| j|�}|||d�}| j||� | j|j � |� W d Q R X W d Q R X d S )Nrp r� )rj iGKL )rH )
r rl r� r r� r r� r9 r� r: )r r� r; r� rH r< r= r r r
�
_testCount� s
z SendfileUsingSendTest._testCountc C s@ d}| j � }| j|�}| jt|�|� | j|| jd |� � d S )NiGKL )r7 r8 r� rU r2 )r rH rq r� r r r
� testCount� s
z SendfileUsingSendTest.testCountc C sz | j j� }ttjd�}tj|dd��L}|�<}d}| j|�}|||d�}| j||� | j|j � |� W d Q R X W d Q R X d S )Nrp r� )rj rE )rH )
r rl r� r r� r r� r9 r� r: )r r� r; r� rH r< r= r r r
�_testCountSmall� s
z%SendfileUsingSendTest._testCountSmallc C s@ d}| j � }| j|�}| jt|�|� | j|| jd |� � d S )NrE )r7 r8 r� rU r2 )r rH rq r� r r r
�testCountSmall� s
z$SendfileUsingSendTest.testCountSmallc C s� | j j� }ttjd�}tj|dd��R}|�B}d}| j|�}||d|d�}| j||� | j|j � |d � W d Q R X W d Q R X d S )Nrp r� )rj i�� i� )rH rH )
r rl r� r r� r r� r9 r� r: )r r� r; r� rH r< r= r r r
�_testCountWithOffset� s
z*SendfileUsingSendTest._testCountWithOffsetc C sD d}| j � }| j|�}| jt|�|� | j|| jd|d � � d S )Ni�� i� )r7 r8 r� rU r2 )r rH rq r� r r r
�testCountWithOffset� s
z)SendfileUsingSendTest.testCountWithOffsetc C sr | j j� }ttjd�}tj|��H}|�8}|jd� | j|�}| j t
||� | j t
|j |� W d Q R X W d Q R X d S )Nrp F) r rl r� r r� r r� rG r9 r� r r� )r r� r; r� r< r r r
�_testNonBlocking� s
z&SendfileUsingSendTest._testNonBlockingc C s | j � }|jd�r | jd� d S )Ni z$was not supposed to receive any data)r7 r� r� )r rq r r r
�testNonBlocking� s
z%SendfileUsingSendTest.testNonBlockingc C sd | j j� }ttjd�}tj|dd��6}|�&}| j|�}||�}| j|| j � W d Q R X W d Q R X d S )Nrp r� )rj )
r rl r� r r� r r� r9 r� r1 )r r� r; r� r< r= r r r
�_testWithTimeout� s
z&SendfileUsingSendTest._testWithTimeoutc C s6 | j � }| j|�}| jt|�| j� | j|| j� d S )N)r7 r8 r� rU r1 r2 )r rq r� r r r
�testWithTimeout� s
z%SendfileUsingSendTest.testWithTimeoutc C sZ | j j� }ttjd��:}tj|dd�� }| j|�}| jtj ||� W d Q R X W d Q R X d S )Nrp g{�G�z�?)rj )
r rl r� r r� r r� r9 r� rj )r r� r; r� r< r r r
� _testWithTimeoutTriggeredSend� s
z3SendfileUsingSendTest._testWithTimeoutTriggeredSendc C s | j � }|jd� d S )Ni�X )r7 r� )r rq r r r
� testWithTimeoutTriggeredSend� s z2SendfileUsingSendTest.testWithTimeoutTriggeredSendc C s d S )Nr )r r r r
� _test_errors s z"SendfileUsingSendTest._test_errorsc 1 C s t tjd��:}tjtjd�� }| j|�}| jtd||� W d Q R X W d Q R X t tjd��4}tj� � }| j|�}| jtd||� W d Q R X W d Q R X t tjd��t}tj� �`}| j|�}| jtd||dd� | jtd||d d� | jtd||d
d� | jtd||d d� W d Q R X W d Q R X d S )
Nrp )r� r r� z binary modezpositive integerrD )rH g�������?r rE r ) r� r r� r r# r9 r� r r` )r r; r r< r r r
� test_errors s*
z!SendfileUsingSendTest.test_errorsNi ( i � )#r r r! r1 r0 r2 r6 r� r4 r5 r7 r8 r9 r> r? rB rC rF rG rI rJ rK rL rM rN rO rP rQ rR rS rT rU rV rW rX r r r r
r* s>
r* r� z%os.sendfile() required for this test.c @ s e Zd Zdd� ZdS )�SendfileUsingSendfileTestc C s
t |d�S )Nr� )rR )r r� r r r
r9 $ s z(SendfileUsingSendfileTest.meth_from_sockN)r r r! r9 r r r r
rY s rY zAF_ALG requiredc @ s| e Zd Zdd� Zejdd�dd� �Zdd� Zejdd �d
d � �Zejdd �d
d� �Z ejdd �dd� �Z
dd� Z dd� Z dS )�LinuxKernelCryptoAPIc C sj t j t jt jd�}y|j||f� W n< tk
r` } z |j� tjt|�||��W Y d d }~X nX |S d S )Nr ) r r r r4 r� r
rv ZSkipTestr� )r �typr� r� ra r r r
�
create_alg+ s $z LinuxKernelCryptoAPI.create_algr� r1 c C s� t jd�}| jdd���}|j� \}}|�" |jd� | j|jd�|� W d Q R X |j� \}}|�L |jdtj � |jdtj � |jdtj � |jd � | j|jd�|� W d Q R X W d Q R X d S )
NZ@ba7816bf8f01cfea414140de5dae2223b00361a396177a9cb410ff61f20015ad�hashZsha256s abci rN � b� cr� )
r� �fromhexr\ ro rh r� r� rB r �MSG_MORE)r r� �algo�oprG r r r
� test_sha2568 s
z LinuxKernelCryptoAPI.test_sha256c C sp t jd�}| jdd��P}|jtjtjd� |j� \}}|�" |jd� | j |j
d�|� W d Q R X W d Q R X d S )NZ(effcdf6ae5eb2fa2d27416d5f184df9c259a7c79r] z
hmac(sha1)s Jefes what do ya want for nothing?i ) r� r` r\ r? r �SOL_ALG� ALG_SET_KEYro rh r� r� )r r� rb rc rG r r r
�test_hmac_sha1J s
z#LinuxKernelCryptoAPI.test_hmac_sha1r c
( C s� t jd�}t jd�}d}t jd�}t|�}| jdd���z}|jtjtj|� |j� \}}|�6 |j tj
|tj d� |j |� | j
|j|�|� W d Q R X |j� \}}|�, |j |gtj|d� | j
|j|�|� W d Q R X d } |g| }
|j� \}}|�& |j |
tj
|d� |j|| �} W d Q R X | j
t| �|| � | j
| d |� |� |j� \}}|�( |j | gtj|d� |j|| �} W d Q R X | j
t| �|| � | j
| || � W d Q R X d S )
NZ 06a9214036b8a15b512e03d534120006Z 3dafba429d9eb430b422da802c9fac41s Single block msgZ e353779c1079aeb82708942dbe77181aZskcipherzcbc(aes))rc �ivrR )rc rh i )r� r` rU r\ r? r re rf ro �
sendmsg_afalg�ALG_OP_ENCRYPTra rh r� r� �ALG_OP_DECRYPT)
r �keyrh r� Z
ciphertextZmsglenrb rc rG Z
multiplierZlongmsg�encZdecr r r
� test_aes_cbcU sD
z!LinuxKernelCryptoAPI.test_aes_cbcr} c ) C s� t jd�}t jd�}t jd�}t jd�}t jd�}t jd�}t|�}t|�}| jdd���N} | jtjtj|� | jtjtjd |� | j � \}
} |
�v |
j
tj ||tj d � |
j
|tj � |
j
|� |
j|t|� | �} | j|| || � � | j|| | d � � W d Q R X | j � \}
} |
�f || }
|
j
|
gtj ||d
� |
j|t|� | �} | j|| || � � | j|| | d � � W d Q R X tjd �j}| j � \}
} |
�� || }
|
j|
gtjtj|tj �gtjtj|t|��| gtjtj||�gf� |
jt|
�| �} | j|| || � � | j|| | d � � W d Q R X | j � \}
} |
�N || | }
|
j
|
gtj||d
� |
jt|
�| �} | j|| |d � � W d Q R X W d Q R X d S ) NZ c939cc13397c1d37de6ae0e1cb7c423cZb3d8cc017cbb89b39e0f67e2Z c3b3c41f113a31b73d9a5cd432103069Z 24825602bd12a984e0092d3e448eda5fZ 93fe7d9e9bfd10348a5606e5cafa7354Z 0032a1dc85f1c9786925a2e71d8272ddZaeadzgcm(aes))rc rh �assoclenrR )rc rh ro �I)r� r` rU r\ r? r re rf ZALG_SET_AEAD_AUTHSIZEro ri rj ra rh r� r� r9 �Structr� r� Z
ALG_SET_OPZ
ALG_SET_IVZALG_SET_AEAD_ASSOCLENrk )r rl rh ZplainZassocZ expected_ctZ expected_tagZtaglenro rb rc rG �resr� Z pack_uint32r r r
�test_aead_aes_gcm~ s`
z&LinuxKernelCryptoAPI.test_aead_aes_gcmc C sn | j dd��X}tjd�}|jtjtj|� |j� \}}|� |jd�}| j t
|�d� W d Q R X W d Q R X d S )N�rngZdrbg_pr_sha256r� ) r\ r� �urandomr? r re rf ro r� r� rU )r rb Z
extra_seedrc rG Zrnr r r
�test_drbg_pr_sha256� s
z(LinuxKernelCryptoAPI.test_drbg_pr_sha256c . C s� t j t jt jd�}|�� | jt�� |j� W d Q R X | jt�� |jd d� W d Q R X | jt�� |jd� W d Q R X | jt�� |jt jd d� W d Q R X | jt�� |jt jdd� W d Q R X W d Q R X d S )Nr )rc rE )rc ro r )r r r r� r` ri rj )r r� r r r
�test_sendmsg_afalg_args� s z,LinuxKernelCryptoAPI.test_sendmsg_afalg_argsc C s� t j t jt jd�}| j|j� | jt�� |jd
� W d Q R X | jt d�� |jd� W d Q R X | jt�� |jddd f� W d Q R X | jt d
�� |jddd f� W d Q R X d S )Nr r �
r� z
type too longr* r� r� �? z
name too long�@ �
ttttttttttttt)r{ r� �tttttttttttttt)r| r� )
r r r r- r
r� r� r4 r� r )r r� r r r
�test_length_restriction� s z,LinuxKernelCryptoAPI.test_length_restrictionN)
r r r! r\ r rZ rd rg rn rs rv rw r} r r r r
rZ ( s
)? rZ �winzrequires Windowsc @ s e Zd ZddddhZdd� ZdS )�TestMSWindowsTCPFlagsZ
TCP_MAXSEGZ TCP_NODELAYZ TCP_FASTOPENZ TCP_KEEPCNTc s6 dd� t t�D �}� fdd�|D �}� jg |d� d S )Nc S s g | ]}|j d �r|�qS )ZTCP)r )r� r r r r
r� � s z<TestMSWindowsTCPFlags.test_new_tcp_flags.<locals>.<listcomp>c s g | ]}|� j kr|�qS r )�
knownTCPFlags)r� r )r r r
r� � s zANew TCP flags were discovered. See bpo-32394 for more information)r� r r� )r Zprovided�unknownr )r r
�test_new_tcp_flags� s z(TestMSWindowsTCPFlags.test_new_tcp_flagsN)r r r! r� r� r r r r
r � s
r c C s� t ttttttttg } | j t
t t t
ttttttttttg� | jt� | jt� | jt� | j t t g� | j t t g� | j t t!g� | jt"� | j t#t$t%t&t't(t)t*t+t,t-t.t/t0t1t2t3t4t5t6t7t8t9t:t;g� | jt<� t=j>� }t=j?| � t=j@|� d S )N)Ar� r� r9 r� r� r� r� r r� �extendrE r[ r� r� r� r� r� r� r� r� r� r r r r� r? r� r� r� r� r� r� r� r� rZ r� r r r
r r
r r r r r r r r r r r r r r r' r1 r r* rY r r Zthreading_setupZ run_unittestZthreading_cleanup)Ztests� thread_infor r r
� test_main� sl
r� �__main__)�rv Ztestr r� r@ rG r r� r� r< r� rM r� r� r8 r� �weakrefr re r` r� r9 r- r/ r r, r
rk r� r� rU �_threadrS r' r� r r r ZHAVE_SOCKET_CANZHAVE_SOCKET_RDSZHAVE_SOCKET_ALGr� r� rw r r" r$ r0 r< r= rd rh ri rj rn ru ry r~ r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r" r' r* r+ r- r. r/ rK rT rW rl rq rt r� r� r� r r r r
r rV r r
r r r r r r r r r r r r r r r r r r r_ r' r1 r9 r? rE r[ r� r� r� r� r� r� r= r� r� r� r� r� r� r� r� r r� r� r� r� r� r� r� r� r� r r r r� r r* rY rZ r r r� r r r r r
�<module> sZ
3u! #
^
D
[
?z7w w= $ P; k 7
)5"
$l
?
D
9
)
DS
',E
+
e
D&
=