File: //usr/local/lib/python3.7/test/__pycache__/test_kqueue.cpython-37.pyc
B
��g9# � @ sn d Z ddlZddlZddlZddlZddlZddlZeed�sHe�d��G dd� dej �Z
e dkrje� � dS )z
Tests for kqueue wrapper.
� N�kqueueztest works only on BSDc @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�
TestKQueuec C sT t �� }| �|�� dk|�� � | �|j � |�� | �|j� | �t|j� d S )Nr )�selectr �
assertTrue�fileno�closed�close� assertRaises�
ValueError)�self�kq� r
�,/usr/local/lib/python3.7/test/test_kqueue.py�test_create_queue s z TestKQueue.test_create_queuec
C s* ddl m}m}m}m} t�tjtj�}| � tj
|� t � |�}t � d�}| �
|j|� | �
|jt j� | �
|jt j� | �
|jd� | �
|jd� | �
|jd� | �
||� | �||� | �||k � | �||k� xD||||fD ]4}| �t||d � | �t||d� | �t||d� q�W t � |t j�}| �
|j|� | �
|jt j� | �
|jt j� | �
|jd� | �
|jd� | �
|jd� | �
||� | �||� t � |t jt j�}| �
|j|� | �
|jt j� | �
|jt j� | �
|jd� | �
|jd� | �
|jd� | �
||� | �||� t � ddddd d
�}| �
|jd� | �
|jd� | �
|jd� | �
|jd� | �
|jd � | �
|jd
� | �
||� | �||� d } t � | ddd| d | �}| �
|j| � | �
|jd� | �
|jd� | �
|jd� | �
|j| d � | �
|j| � | �
||� | �||� d } t � dd| �}| �
|jd� | �
|jd� | �
|j| � | �
|jd� | �
|jd� | �
|jd� | �
||� | �||� d
} t � ddd| �}| �
|jd� | �
|jd� | �
|jd� | �
|j| � | �
|jd� | �
|jd� | �
||� | �||� d S )Nr )�lt�le�gt�gei� � �ev� � � � � i� i�� l �� ) �operatorr r r r �os�open�devnull�O_WRONLY�
addCleanupr r �kevent� assertEqual�ident�filter�KQ_FILTER_READ�flags� KQ_EV_ADDZfflags�dataZudataZassertNotEqualr r � TypeError�KQ_FILTER_WRITEZ
KQ_EV_ONESHOT)
r r r r r �fdr �other�opZbignumr
r
r �test_create_event s�
z TestKQueue.test_create_eventc
C s t � � }|�d� |�� t � � }|�d� y|�d|�� d f� W n6 tk
r| } z| �|jd t j
� W d d }~X Y nX |� � \}}t �
� }t j
�|�� �}t �|�� t jt jt jB �}|�|gd� t �|�� t jt jt jB �}|�|gd� t �|�� t jt jt jB �}|�|gd� t �|�� t jt jt jB �}|�|gd� |�d dd�} tdd� | D ��} | �| t|�� t jf|�� t jfg�� |�d � |�d
� xDtd �D ].}
|�d dd�} t| �dk�r�P t�d � �q�W | � d
� tdd� | D ��} | �| t|�� t jf|�� t jf|�� t jf|�� t jfg�� t �|�� t jt j �}|�|gd� t �|�� t jt j �}|�|gd� t �|�� t jt j �}|�|gdd� |�g dd�} tdd� | D ��} | �| t|�� t jfg�� |� � |� � |� � d S )N)z 127.0.0.1r Fz 127.0.0.1r r r c s s | ]}|j |jfV qd S )N)r# r$ )�.0�er
r
r � <genexpr>� s z.TestKQueue.test_queue_event.<locals>.<genexpr>s Hello!s world!!!�
g �?z'timeout waiting for event notificationsc s s | ]}|j |jfV qd S )N)r# r$ )r/ r0 r
r
r r1 � s g�G�z��?c s s | ]}|j |jfV qd S )N)r# r$ )r/ r0 r
r
r r1 � s ) �socketZbindZlistenZ setblockingZconnectZ getsockname�OSErrorr" �args�errnoZ EINPROGRESSZacceptr r Zfromfdr r! r* r' � KQ_EV_ENABLE�controlr% �set�send�range�len�timeZsleepZfailZ KQ_EV_DELETEr ) r Z serverSocketZclientr0 ZserverZaddrr Zkq2r Zevents�ir
r
r �test_queue_eventp s�
&
zTestKQueue.test_queue_eventc C s� t �� }t�� \}}|�d� t �|t jt jt jB �}t �|t jt jt jB �}|� ||gdd�}| �
|� | � |d j t j
@ � | �|�|d j�d� |�� |�� |�� d S )Ns foor r )r r r3 �
socketpairr: r! r% r' r7 r8 r � assertFalser& Z KQ_EV_ERRORr" Zrecvr( r )r r �a�bZevent1Zevent2�rr
r
r �testPair� s
zTestKQueue.testPairc s� t �� }t�� \}}t �|t jt jt jB �� |�� gd� |�� fd� G � fdd�d�}|�|� d� |�t � g�d� |�
� |�
� |�
� d S )Nr c s e Zd Zdd� Z� fdd�ZdS )z+TestKQueue.test_issue30058.<locals>.BadListc S s dS )Nr r
)r r
r
r �__len__� s z3TestKQueue.test_issue30058.<locals>.BadList.__len__c 3 s xt d�D ]
}� V q
W d S )N�d )r; )r r> )r r
r �__iter__� s z4TestKQueue.test_issue30058.<locals>.BadList.__iter__N)�__name__�
__module__� __qualname__rF rH r
)r r
r �BadList� s rL ) r r r3 r@ r! r% r' r7 r8 �iterr )r r rB rC rL r
)r r �test_issue30058� s zTestKQueue.test_issue30058c C s� t td�}| �|j� |�� }t�� }| �|�� t� | � |j
� |�� | � |j
� | � t
|j� |�� | � t
|jd d� d S )N�rbr )r �__file__r r r r r ZassertIsInstance�intrA r r r r
r8 )r Z open_filer+ r r
r
r �
test_close� s
zTestKQueue.test_closec C s. t �� }| �|j� | �t�|�� �d� d S )NF)r r r r r" r �get_inheritabler )r r r
r
r �test_fd_non_inheritable s z"TestKQueue.test_fd_non_inheritableN)
rI rJ rK r r. r? rE rN rR rT r
r
r
r r s YSr �__main__)
�__doc__r6 r r r3 r= Zunittest�hasattrZSkipTestZTestCaser rI �mainr
r
r
r �<module> s
y