|
Server : LiteSpeed System : Linux server51.dnsbootclub.com 4.18.0-553.62.1.lve.el8.x86_64 #1 SMP Mon Jul 21 17:50:35 UTC 2025 x86_64 User : nandedex ( 1060) PHP Version : 8.1.33 Disable Function : NONE Directory : /opt/cppython/lib/python3.8/test/__pycache__/ |
U
>��g# � @ 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 �//opt/cppython/lib/python3.8/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� ||||fD ]4}| �t||d � | �t||d� | �t||d� q�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� z|�d|�� d f� W n6 tk
rl } z| �|jd tj � W 5 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
� td �D ]2}
|�d dd�} t| �dk�r� �q�t�d � �q�| �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)� 127.0.0.1r Fr0 r 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 r1 r2 r3 r r r r6 � s g�G�z��?c s s | ]}|j |jfV qd S r1 r2 r3 r r r r6 � s ) �socket�
create_server� setblocking�connect� getsockname�OSErrorr# �args�errnoZ EINPROGRESS�acceptr r �fromfdr r" r+ r( � KQ_EV_ENABLE�controlr& �set�send�range�len�time�sleepZfailZ KQ_EV_DELETEr ) r Z serverSocket�clientr5 Zserver�addrr
Zkq2r �events�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 r8 �
socketpairrE r" r& r( rB rC r � assertFalser' Z KQ_EV_ERRORr# �recvr) 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 r r )r r r r �__len__� s z3TestKQueue.test_issue30058.<locals>.BadList.__len__c 3 s t d�D ]
}� V qd S )N�d )rF )r rM �r r r �__iter__� s z4TestKQueue.test_issue30058.<locals>.BadList.__iter__N)�__name__�
__module__� __qualname__rV rY r rX r r �BadList� s r] ) r r r8 rO r" r& r( rB rC �iterr )r r
rR rS r] r rX 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�intrP r r r
r rC )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)
rZ r[ r\ r r/ rN rU r_ rc re r r r r r s YQr �__main__)
�__doc__r? r r r8 rH Zunittest�hasattrZSkipTestZTestCaser rZ �mainr r r r �<module> s
w