| 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_9# � @ sn d Z ddlZddlZddlZddlZddlZddlZeed�sHejd��G dd� dej �Z
e dkrjej � 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 j� }| j|j� dk|j� � | j|j � |j� | j|j� | jt|j� d S )Nr )�selectr �
assertTrue�fileno�closed�close� assertRaises�
ValueError)�self�kq� r
�5/opt/alt/python36/lib64/python3.6/test/test_kqueue.py�test_create_queue s z TestKQueue.test_create_queuec
C s* ddl m}m}m}m} tjtjtj�}| j tj
|� t j |�}t j d�}| j
|j|� | j
|jt j� | j
|jt j� | j
|jd� | j
|jd� | j
|jd� | j
||� | j||� | j||k � | j||k� xD||||fD ]4}| jt||d � | jt||d� | jt||d� q�W t j |t j�}| j
|j|� | j
|jt j� | j
|jt j� | j
|jd� | j
|jd� | j
|jd� | j
||� | j||� t j |t jt j�}| j
|j|� | j
|jt j� | j
|jt j� | j
|jd� | j
|jd� | j
|jd� | j
||� | j||� t j ddddd d
�}| j
|jd� | j
|jd� | j
|jd� | j
|jd� | j
|jd � | j
|jd
� | j
||� | j||� d } t j | ddd| d | �}| j
|j| � | j
|jd� | j
|jd� | j
|jd� | j
|j| d � | j
|j| � | j
||� | j||� d } t j dd| �}| j
|jd� | j
|jd� | j
|j| � | j
|jd� | j
|jd� | j
|jd� | j
||� | j||� d
} t j ddd| �}| j
|jd� | j
|jd� | j
|jd� | j
|j| � | j
|jd� | j
|jd� | j
||� | j||� 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 j � }|jd� |j� t j � }|jd� y|jd|j� d f� W n6 tk
r| } z| j|jd t j
� W Y d d }~X nX |j � \}}t j
� }t j
j|j� �}t j|j� t jt jt jB �}|j|gd� t j|j� t jt jt jB �}|j|gd� t j|j� t jt jt jB �}|j|gd� t j|j� t jt jt jB �}|j|gd� |jd dd�} tdd� | D ��} | j| t|j� t jf|j� t jfg�� |jd� |jd � xDtd
�D ].}
|jd dd�} t| �dk�r�P tjd � �q�W | j d � td
d� | D ��} | j| t|j� t jf|j� t jf|j� t jf|j� t jfg�� t j|j� t jt j �}|j|gd� t j|j� t jt j �}|j|gd� t j|j� t jt j �}|j|gdd� |jg dd�} tdd� | D ��} | j| t|j� t jfg�� |j � |j � |j � d S )N� 127.0.0.1r Fr 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$ )r0 r1 r
r
r r2 � s g�G�z��?c s s | ]}|j |jfV qd S )N)r# r$ )r0 r1 r
r
r r2 � s )r/ r ) �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 serverSocketZclientr1 ZserverZaddrr Zkq2r Zevents�ir
r
r �test_queue_eventp s�
&
zTestKQueue.test_queue_eventc C s� t j� }tj� \}}|jd� t j|t jt jt jB �}t j|t jt jt jB �}|j ||gdd�}| j
|� | j |d j t j
@ � | j|j|d j�d� |j� |j� |j� d S )Ns foor r )r r r4 �
socketpairr; r! r% r' r8 r9 r � assertFalser& Z KQ_EV_ERRORr" Zrecvr( r )r r �a�bZevent1Zevent2�rr
r
r �testPair� s
zTestKQueue.testPairc s� t j� }tj� \}}t j|t jt jt jB �� |j� gd� |j� fd� G � fdd�d�}|j|� d� |jt � g�d� |j
� |j
� |j
� 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__rG rI r
)r r
r �BadList� s rM ) r r r4 rA r! r% r' r8 r9 �iterr )r r rC rD rM r
)r r �test_issue30058� s zTestKQueue.test_issue30058c C s� t td�}| j|j� |j� }tj� }| j|j� t� | j |j
� |j� | j |j
� | j t
|j� |j� | j t
|jd d� d S )N�rbr )r �__file__r r r r r ZassertIsInstance�intrB r r r r
r9 )r Z open_filer+ r r
r
r �
test_close� s
zTestKQueue.test_closec C s. t j� }| j|j� | jtj|j� �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)
rJ rK rL r r. r@ rF rO rS rU r
r
r
r r s YSr �__main__)
�__doc__r7 r r r4 r> Zunittest�hasattrZSkipTestZTestCaser rJ �mainr
r
r
r �<module> s
y