Da

✏️ Editing: test_kqueue.cpython-310.pyc

����Z(YD��������������������@���sr���d�Z�ddlZddlZddlZddlZddlZddlZeed�s$e�d��G�dd��dej	�Z
edkr7e����dS�dS�)z
Tests for kqueue wrapper.
�����N�kqueueztest works only on BSDc�������������������@���sD���e�Zd�Zdd��Zdd��Zdd��Zdd��Zd	d
��Zdd��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����6/opt/plesk/python/3/lib/python3.10/test/test_kqueue.py�test_create_queue���s���zTestKQueue.test_create_queuec�����������
������C���s&��ddl�m}m}m}m}�t�tjtj�}|��	tj
|��t�|�}t�d�}|��
|j|��|��
|jtj��|��
|jtj��|��
|jd��|��
|jd��|��
|jd��|��
||��|��||��|��||k���|��||k��||||fD�]}|��t||d���|��t||d��|��t||d��qqt�|tj�}|��
|j|��|��
|jtj��|��
|jtj��|��
|jd��|��
|jd��|��
|jd��|��
||��|��||��t�|tjtj�}|��
|j|��|��
|jtj��|��
|jtj��|��
|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����

zTestKQueue.test_create_eventc��������������
���C���s���t��d�}t�����}|�d��z
|�d|���d�f��W�n�ty7�}�z|��|jd�tj	��W�Y�d�}~nd�}~ww�	�|�
��\}}t���}tj�
|����}t�|���tjtjtjB��}|�|gd��t�|���tjtjtjB��}|�|gd��t�|���tjtjtjB��}|�|gd��t�|���tjtjtjB��}|�|gd��|�d�dd�}	tdd��|	D���}	|��|	t|���tjf|���tjfg���|�d	��|�d
��td�D�]}
|�d�dd�}	t|	�dkr��nt�d��q�|��d
��tdd��|	D���}	|��|	t|���tjf|���tjf|���tjf|���tjfg���t�|���tjtj�}|�|gd��t�|���tjtj�}|�|gd��t�|���tjtj�}|�|gdd��|�g�dd�}	tdd��|	D���}	|��|	t|���tjfg���|����|����|����d�S�)N)�	127.0.0.1r���Fr0���r���r���r���c�����������������s���������|�]	}|j�|jfV��qd�S��N�r$���r%�����.0�er���r���r����	<genexpr>����������z.TestKQueue.test_queue_event.<locals>.<genexpr>s���Hello!s���world!!!�
���g�������?z'timeout waiting for event notificationsc�����������������s���r1���r2���r3���r4���r���r���r���r7�������r8���g�G�z��?c�����������������s���r1���r2���r3���r4���r���r���r���r7�������r8���)�socket�
create_server�setblocking�connect�getsockname�OSErrorr#����args�errnoZEINPROGRESS�acceptr���r����fromfdr���r"���r+���r(����KQ_EV_ENABLE�controlr&����set�send�range�len�time�sleepZfailZKQ_EV_DELETEr	���)r���ZserverSocket�clientr6���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�jt�j
@���|��|�|d�j�d��|����|����|����d�S�)Ns���foor���r���)r���r���r:����
socketpairrG���r"���r&���r(���rD���rE���r����assertFalser'���ZKQ_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���)rH���)r���rO����r���r���r����__iter__����s�����z4TestKQueue.test_issue30058.<locals>.BadList.__iter__N)�__name__�
__module__�__qualname__rX���r[���r���rZ���r���r����BadList����s����r_���)r���r���r:���rQ���r"���r&���r(���rD���rE����iterr	���)r���r
���rT���rU���r_���r���rZ���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�intrR���r���r���r
���r���rE���)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)
r\���r]���r^���r���r/���rP���rW���ra���re���rg���r���r���r���r���r������s����YQr����__main__)
�__doc__rA���r���r���r:���rJ���Zunittest�hasattrZSkipTestZTestCaser���r\����mainr���r���r���r����<module>���s����

�w�

📁 Sid Gifari File Manager