File: //lib64/python3.6/test/__pycache__/test_poll.cpython-36.pyc
3
\h � @ s� d dl Z d dlZd dlZd dlZy d dlZW n ek
rD dZY nX d dlZd dlZd dlm Z m
Z
m Z m Z y
ej
W n ek
r� ejd��Y nX dd� ZG dd� dej�Zdd � Zed
kr�e� dS ) � N)�TESTFN� run_unittest� reap_threads� cpython_onlyzselect.poll not definedc C s, g }x"| D ]\}}||@ r
|j |� q
W |S )N)�append)�ready�flag�match�fd�mode� r �!/usr/lib64/python3.6/test_poll.py�find_ready_matching s
r c @ sh e Zd Zdd� Zdd� Zdd� Zdd� Zed d
� �Ze j
e d �e d d
� ��Z
e j
e d �e dd� ��ZdS )� PollTestsc C sz t j� }d}d}t|�}g }g }i }i }xft|�D ]Z} tj� \}
} |j|
� |j|
t j� |j| t j � |j
|
� |j
| � | ||
< |
|| < q2W g } x�|�rb|j� }
t |
t j �}|s�t d��t
j|�} tj| |� |j� }
t |
t j�}|s�t d��t
j|�}
tj|
|�}| jt|�|� | j
|� tj||
� tj|
� |j||
� |j|
� |j||
� q�W | j| |g| � d S )N� s This is a test.zno pipes ready for writingzno pipes ready for reading)�select�poll�len�range�os�pipe�register�modify�POLLIN�POLLOUTr r � RuntimeError�randomZchoice�write�read� assertEqual�close�
unregister�remove)�self�pZ NUM_PIPESZMSGZMSG_LENZreadersZwritersZr2wZw2r�iZrd�wrZbufsr Z
ready_writersZ
ready_readersZbufr r r
�
test_poll1 sN
zPollTests.test_poll1c
C sP t j� \}}t j|� t j|� tj� }|j|� |j� }| j|d |tjf� tt d�}|j
� }tj� }|j|� |j� }| j|d d |� |j� |j� }| j|d |tjf� t j t � tj� }| j t
|j|� | j t
|j|� tj� }| j t|jd� tj� }G dd� d�}G dd� d�} | j t
|j|� d� | j t
|j| � d� d S )Nr �w� c @ s e Zd ZdS )z,PollTests.test_poll_unit_tests.<locals>.NopeN)�__name__�
__module__� __qualname__r r r r
�Nopeo s r- c @ s e Zd Zdd� ZdS )z.PollTests.test_poll_unit_tests.<locals>.Almostc S s dS )N�filenor )r# r r r
r. s s z5PollTests.test_poll_unit_tests.<locals>.Almost.filenoN)r* r+ r, r. r r r r
�Almostr s r/ )r r r r r r r ZPOLLNVAL�openr r. �unlink� assertRaises� TypeErrorr! �KeyError)
r# ZFDr( r$ �r�fr
�pollsterr- r/ r r r
�test_poll_unit_testsO s6
z PollTests.test_poll_unit_testsc
C s� d}t j|dt jdd�}|j� | j|jd d d � |j}tj� }|j |tj
� x�dD ]�}|j|�}|g krlqT|d \}}|tj @ r�|j � } | d krT| j
d
� qTqT|tj
@ r�|j � } | s�P | j| d� qTqT| j
d| � qTW d S )Nz?for i in 0 1 2 3 4 5 6 7 8 9; do echo testing...; sleep 1; doneTr )�shell�stdout�bufsize�� �� � �@ �> � �
� z6error: pipe seems to be closed, but still returns datas testing...
z,Unexpected return value from select.poll: %s)r r< r= r> r? r@ ���)rD )
rD rD rD rD rD rD rD rD rD rD )r r< r= r> r? r@ rD rD rD rD rD rD rD rD rD rD )�
subprocess�Popen�PIPE� __enter__�
addCleanup�__exit__r: r r r r ZPOLLHUP�readline�failr )
r# �cmd�procr$ r7 ZtoutZfdlistr
�flags�liner r r
�
test_poll2| s2
zPollTests.test_poll2c C s� t j� }|jd� | jt|jd� d }|dkr8| jd� | jt|jdd
� | jt|jdd � | jt|jdd � | jt|jdd
� d S )NrA �@ � r) � zOverflow must have occurredr l rT rD l rD l )r r r r2 �
OverflowErrorrL r )r# r7 �xr r r
�
test_poll3� s
zPollTests.test_poll3c C s~ ddl m}m}m} tj� }|jd� | jt|jd|d � | jt|j d|d � | jt|j|d � | jt|j|d � d S )Nr )� USHRT_MAX�INT_MAX�UINT_MAXrA )
Z _testcapirX rY rZ r r r r2 rU r )r# rX rY rZ r7 r r r
�test_poll_c_limits� s
z PollTests.test_poll_c_limitsz!Threading required for this test.c C s� t j� \}}| jt j|� | jt j|� g }x2td�D ]&}t j|�}| jt j|� |j|� q6W tj� }x|D ]}|j |tj
� qnW t j |jd�}|j
� zBtjd� x|D ]}|j|� q�W |j |tj� | jt|j� W d t j|d� |j� X d S )NrB )�targetg �?s spam)r r rI r r �dupr r r r r � threading�Thread�start�timeZsleepr! r r2 r r �join)r# r5 r( Zrfdsr% r
r7 �tr r r
�test_threaded_poll� s*
z PollTests.test_threaded_pollc C s� x�dD ]�}t j� \}}tj� }|j|tj� tj|j|fd�}|j� |j dd� | j
|j � � t j |d� |j � | j
|j � � t j|� t j|� qW d S )Ni� rA g �?g�������?g0��.�++)r\ �args)Ztimeouts spam����rD � �皙�������0��.�+�)Nrf rD rg rh ri )r r r r r r r^ r_ r` rb Z
assertTrueZis_aliver Z assertFalser )r# Z
timeout_msr5 r( r7 Z poll_threadr r r
�!test_poll_blocks_with_negative_ms� s
z+PollTests.test_poll_blocks_with_negative_msN)r* r+ r, r' r8 rQ rW r r[ �unittestZ
skipUnlessr^ r rd rj r r r r
r s 1-
r c C s t t� d S )N)r r r r r r
� test_main� s rl �__main__)r rE r r r^ � ImportErrorra rk Z test.supportr r r r r �AttributeErrorZSkipTestr ZTestCaser rl r* r r r r
�<module> s(
O