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__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]


Current File : //opt/cppython/lib/python3.8/test/__pycache__/test_selectors.cpython-38.opt-2.pyc
U

>��g'G�@s�ddlZddlZddlZddlZddlZddlZddlZddlmZddl	m
Z
ddlZddlZddl
Z
ddl	mZ	zddlZWnek
r�dZYnXeed�r�ejZnejejdfdd�Zdd�ZGd	d
�d
ej�ZGdd�d�ZGd
d�de�ZGdd�de�Ze�eed�d�Gdd�dee��Ze�eed�d�Gdd�dee��Ze�eed�d�Gdd�dee��Ze�eed�d�Gdd �d ee��Zd!d"�Z e!d#k�r�e �dS)$�N)�support)�sleep)�	monotonic�
socketpairc
Cs�t�|||���}|�tjdf�|��t�|||�}zN|�|���|��}|��\}}||krx||fWW5QR�S|��qNWnt	k
r�|���YnXW5QRXdS)Nr)
�socket�bindrZHOST�listen�connect�getsockname�accept�close�OSError)�family�type�proto�l�cZcaddr�a�addr�r�2/opt/cppython/lib/python3.8/test/test_selectors.pyrscCs*g}|D]\}}||@r|�|j�q|S�N)�append�fileobj)�ready�flag�match�key�eventsrrr�find_ready_matching*s
rc@s�eZdZdd�Zdd�Zdd�Zdd�Ze�e	j
d	kd
�dd��Zd
d�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd �Ze�ejd!kd"�d#d$��Zd%d&�Ze�eed'�d(�d)d*��Ze�eed'�d(�d+d,��Zd-S).�BaseSelectorTestCasecCs*t�\}}|�|j�|�|j�||fSr)r�
addCleanupr)�self�rd�wrrrr�make_socketpair4s
z$BaseSelectorTestCase.make_socketpaircCs�|��}|�|j�|��\}}|�|tjd�}|�|tj�|�	|j
|�|�	|j|���|�	|j
tj�|�	|jd�|�t|jdd�|�t|jdtj�|�t|j|tj�|�t|j|��tj�dS)N�datar�?Bi����)�SELECTORr!rr%�register�	selectors�
EVENT_READZassertIsInstance�SelectorKey�assertEqualr�fd�filenorr&�assertRaises�
ValueError�KeyError�r"�sr#r$rrrr�
test_register:s�z"BaseSelectorTestCase.test_registercCs\|��}|�|j�|��\}}|�|tj�|�|�|�t	|jd�|�t	|j|�dS�Nr')
r(r!rr%r)r*r+�
unregisterr0r2�r"r4r#r$rrr�test_unregisterTs
z$BaseSelectorTestCase.test_unregistercCsv|��}|�|j�|��\}}|��|��}}|�|tj�|�|tj�|��|��|�	|�|�	|�dSr)
r(r!rr%r/r)r*r+�EVENT_WRITEr7)r"r4r#r$�r�wrrr�test_unregister_after_fd_closecs
z3BaseSelectorTestCase.test_unregister_after_fd_close�posixzrequires posixcCs�|��}|�|j�|��\}}|��|��}}|�|tj�|�|tj�|��\}}|��|��t	�
|��|�t	�
|��|�|�t	j|�|�t	j|�|�|�|�|�dSr)r(r!rr%r/r)r*r+r:�os�dup2r7)r"r4r#r$r;r<Zrd2Zwr2rrr�(test_unregister_after_fd_close_and_reuseos
z=BaseSelectorTestCase.test_unregister_after_fd_close_and_reusecCsd|��}|�|j�|��\}}|�|tj�|�|tj�|��|��|�|�|�|�dSr)	r(r!rr%r)r*r+r:r7r8rrr�"test_unregister_after_socket_close�s
z7BaseSelectorTestCase.test_unregister_after_socket_closec	Cs6|��}|�|j�|��\}}|�|tj�}|�|tj�}|�	|j
|j
�|�||�|��|�
|�t�}t�}|�|tj|�}|�|tj|�}|�|j
|j
�|�	|j|j�|�||�|��|�|j|�|�t|jdtj�t�}tj��|_tj��|_
|�|tj|�|�|jj�|�|j
j�dSr6)r(r!rr%r)r*r+�modifyr:ZassertNotEqualrr-�get_keyr7�objectr&r0r2�unittest�mock�Mock�assertFalseZcalled)	r"r4r#r$rZkey2Zd1Zd2Zd3rrr�test_modify�s.
z BaseSelectorTestCase.test_modifyc
Cs�|jjdkrtj�d�}n>|jjdkr4tj�d�}n$|jjdkrNtj�d�}n
|�d��|��}tjjtd�|j_	|��}|�
|j�|��\}}|�
|tj�|�t|j�d	�|�t��|�	|tj�W5QRX|�t|j�d
�W5QRXdS)N�
EpollSelectorz%selectors.EpollSelector._selector_cls�PollSelectorz$selectors.PollSelector._selector_cls�DevpollSelectorz'selectors.DevpollSelector._selector_cls�)Zside_effect�r)r(�__name__rFrG�patch�skipTestrH�ZeroDivisionErrorZreturn_valuerCr!rr%r)r*r+r-�len�_mapr0r:)r"rQ�mr4r#r$rrr�test_modify_unregister�s2���
�
z+BaseSelectorTestCase.test_modify_unregistercCs�|��}|�|j�|��}|��\}}|�|tj�|�|tj�|��|�	t
|j|�|�	t
|j|�|�	t|j
|�|�	t|j
|�dSr)r(r!r�get_mapr%r)r*r+r:r0�RuntimeErrorrDr2�__getitem__)r"r4�mappingr#r$rrr�
test_close�szBaseSelectorTestCase.test_closecCsV|��}|�|j�|��\}}|�|tjd�}|�||�|��|�	t
|jd�dS)Nr&r')r(r!rr%r)r*r+r-rDr0r2r3rrr�test_get_key�sz!BaseSelectorTestCase.test_get_keyc	Cs�|��}|�|j�|��\}}|��}|�|�|�t|�d�|�t|�g�|�	|t
jd�}|�||�|�|||�|�t|�d�|�t|�|�
�g�|�t|���|g�|�t��|dW5QRX|�t��||=W5QRXdS)Nrr&rOr')r(r!rr%rXrIr-rT�listr)r*r+ZassertInr/�valuesr0r2�	TypeError)r"r4r#r$�keysrrrr�test_get_map�s"
z!BaseSelectorTestCase.test_get_mapcCs�|��}|�|j�|��\}}|�|tj�|�|tj�}|��}|D]<\}}|�	t
|tj��|�	|�|�|tjtjB@�qH|�
|tjfg|�dSr)r(r!rr%r)r*r+r:�select�
assertTrue�
isinstancer,rIr-)r"r4r#r$Zwr_key�resultrrrrr�test_selects

�z BaseSelectorTestCase.test_selectc	Csp|��}|�|j�|��\}}|�"}|�|tj�|�|tj�W5QRX|�t	|j
|�|�t	|j
|�dSr)r(r!rr%r)r*r+r:r0rYrD)r"r4r#r$Zselrrr�test_context_managersz)BaseSelectorTestCase.test_context_managercCsF|��}|�|j�t|d�rB|��}|�t|t��|�|d�dS)Nr/r)	r(r!r�hasattrr/rdre�int�assertGreaterEqual)r"r4r.rrr�test_fileno!s
z BaseSelectorTestCase.test_filenocCs�|��}|�|j�d}d}t|�}g}g}i}i}t|�D]P}	|��\}
}|�|
tj�|�|tj	�|�
|
�|�
|�|||
<|
||<q<g}|�rr|��}
t|
tj	�}|s�|�
d�t�|�}|�|�td�D]*}	|��}
t|
tj�}|r��qtd�q�|�
d�|�||g|�|d}
|
�|�}|�t|�|�|�
|�|�||
�|�|
�|�||
�q�|�||g|�dS)N�s This is a test.zno sockets ready for writing�
g�������?zno sockets ready for readingr)r(r!rrT�ranger%r)r*r+r:rrcrZfail�random�choice�sendrr-�recvr7�remove)r"r4ZNUM_SOCKETSZMSGZMSG_LEN�readersZwritersZr2wZw2r�ir#r$ZbufsrZ
ready_writersZ
ready_readers�bufrrr�
test_selector*sV





�




z"BaseSelectorTestCase.test_selector�win32z1select.select() cannot be used with empty fd setscCs,|��}|�|j�|�|jdd�g�dS)Nr)�timeout)r(r!rr-rc)r"r4rrr�test_empty_select_sz&BaseSelectorTestCase.test_empty_selectcCs
|��}|�|j�|��\}}|�|tj�t�}|�dt	|�
d���|�dt	|�
d���|�t�|d�|�|�|�|tj
�t�}|�|�
d��|�|�
d��|�t�|d�t�}|�|�
d��t�}||}|�d|ko�dkn|�dS)NrOr���g�?g�������?g@)r(r!rr%r)r*r:�timer-rTrc�
assertLessr7r+rIrd)r"r4r#r$�t�t0�t1Zdtrrr�test_timeouths&
z!BaseSelectorTestCase.test_timeout�alarmz%signal.alarm() required for this testc	s�|��}|�|j�|��\}}Gdd�dt���fdd�}t�tj|�}|�tjtj|�zTt�d�|�|t	j
�t�}|����|�
d�W5QRX|�t�|d�W5t�d�XdS)	Nc@seZdZdS)zGBaseSelectorTestCase.test_select_interrupt_exc.<locals>.InterruptSelectN)rP�
__module__�__qualname__rrrr�InterruptSelect�sr�cs��dSrr��args�r�rr�handler�sz?BaseSelectorTestCase.test_select_interrupt_exc.<locals>.handlerrrO�g@)r(r!rr%�	Exception�signal�SIGALRMr�r)r*r+r}r0rcr~)r"r4r#r$r��orig_alrm_handlerrrr�r�test_select_interrupt_exc�s
z.BaseSelectorTestCase.test_select_interrupt_excc	Cs�|��}|�|j�|��\}}t�tjdd��}|�tjtj|�zDt�d�|�|tj	�t
�}|�|�d��|�
t
�|d�W5t�d�XdS)NcWsdSrrr�rrr�<lambda>��zDBaseSelectorTestCase.test_select_interrupt_noraise.<locals>.<lambda>rrOg�?g�?)r(r!rr%r�r�r�r)r*r+r}rIrcrk)r"r4r#r$r�rrrr�test_select_interrupt_noraise�s
z2BaseSelectorTestCase.test_select_interrupt_noraiseN)rPr�r�r%r5r9r=rF�
skipUnlessr?�namerArBrJrWr\r]rbrgrhrlrxZskipIf�sys�platformr{r�rir�r�r�rrrrr 2s:
&
	5�
�
�r c@s,eZdZe�dd�e�ed�dd���ZdS)�ScalableSelectorMixInrn�zTest needs resource modulec
Cs�t�tj�\}}z6t�tj||f�|�tjtj||f�t|d�}Wnttfk
rb|}YnX|d8}|��}|�|j	�t
|d�D]�}z|��\}}Wntk
r�|�d�YnXz |�
|tj�|�
|tj�Wq�tk
�r}z|jtjk�r|�d��W5d}~XYq�Xq�z|��}	WnJtk
�rx}z*|jtjk�rftjdk�rf|�d��W5d}~XYnX|�|dt|	��dS)Ni� �zFD limit reached�darwinz%Invalid argument error calling poll())�resourceZ	getrlimitZ
RLIMIT_NOFILEZ	setrlimitr!�minr
r1r(rror%rRr)r*r+r:�errno�ENOSPCrc�EINVALr�r�r-rT)
r"ZsoftZhardZNUM_FDSr4rvr#r$�e�fdsrrr�test_above_fd_setsize�s>�


z+ScalableSelectorMixIn.test_above_fd_setsizeN)	rPr�r�rZrequires_mac_verrFr�r�r�rrrrr��s

r�c@seZdZejZdS)�DefaultSelectorTestCaseN)rPr�r�r*�DefaultSelectorr(rrrrr��sr�c@seZdZejZdS)�SelectSelectorTestCaseN)rPr�r�r*�SelectSelectorr(rrrrr��sr�rLz!Test needs selectors.PollSelectorc@seZdZeedd�ZdS)�PollSelectorTestCaserLN�rPr�r��getattrr*r(rrrrr��sr�rKz"Test needs selectors.EpollSelectorc@s eZdZeedd�Zdd�ZdS)�EpollSelectorTestCaserKNc
Csd|��}t���J}|�t��|�|tj�W5QRX|�t��|�	|�W5QRXW5QRXdSr)
r(�tempfile�NamedTemporaryFiler0�IOErrorr)r*r+r2rD)r"r4�frrr�test_register_files
z(EpollSelectorTestCase.test_register_file)rPr�r�r�r*r(r�rrrrr��sr��KqueueSelectorz$Test needs selectors.KqueueSelector)c@s eZdZeedd�Zdd�ZdS)�KqueueSelectorTestCaser�Nc	Csj|��}t��}|�t��}|�|tj�W5QRX|�|j	j
t
j�|�t��|�
|�W5QRXdSr)r(rZmake_bad_fdr0r
r)r*r+r-�	exceptionr��EBADFr2rD)r"r4Zbad_f�cmrrr�test_register_bad_fdsz+KqueueSelectorTestCase.test_register_bad_fd)rPr�r�r�r*r(r�rrrrr�sr�rMz$Test needs selectors.DevpollSelectorc@seZdZeedd�ZdS)�DevpollSelectorTestCaserMNr�rrrrr�#sr�cCs&ttttttg}tj|�t��dSr)	r�r�r�r�r�r�rZrun_unittest�
reap_children)Ztestsrrr�	test_main+s�
r��__main__)"r�r?rpr*r�rr��testrr}rrFZ
unittest.mockr�rr��ImportErrorrir�AF_INET�SOCK_STREAMrZTestCaser r�r�r�r�r�r�r�r�r�rPrrrr�<module>s\


5����


F1le Man4ger