File: //usr/local/lib/python3.7/test/__pycache__/test_threadsignals.cpython-37.opt-1.pyc
B
��g^( � @ s� d Z ddlZddlZddlZddlZddlmZ ddlZddl Z ej
dd� dkrbe� dej
��e� � Z
e�� Zejjdko�ejjdkZd d
� Zd d � Zd
d� ZG dd� dej�Zdd� Zedkr�e� dS )z6PyUnit testing that threads honor our signal semantics� N)�support� �winzCan't test signal on %sZpthreadz
mutex+condc C s4 t � t j| �}t � t j|�}t � t j|�}|||fS )N)�signal�SIGUSR1�SIGUSR2�SIGALRM)Zfor_usr1Zfor_usr2Zfor_alrmZusr1Zusr2Zalrm� r �3/usr/local/lib/python3.7/test/test_threadsignals.py�registerSignals s r c C s( t | d d7 < t�� t | d< d S )N�tripped� �
tripped_by)�signal_blackboard�thread� get_ident)�sig�framer r r
�handle_signals s r c C s( t �ttj� t �ttj� t�� d S )N)�os�kill� process_pidr r r �
signalled_all�releaser r r r
� send_signals" s r c @ s� e Zd Zdd� Zdd� Zdd� Ze�ed�e�e j
� d�oBe j j
d �e�e j
� d
�d �d d
� ���Ze�ed�e�e j
� d�o�e j j
d �e�e j
� d
�d �dd� ���Zdd� Zdd� Zdd� Zdd� ZdS )�
ThreadSignalsc C s� t �� � t�� | �� t�� W d Q R X ttj d dksPttj d dkrtzt� d� t�
� W d t� d� X | � ttj d d� | � ttj d t �
� � | � ttj d d� | � ttj d t �
� � t�� d S )Nr r r
r )r �wait_threads_exitr �acquire�spawnSignallingThreadr r r r �alarm�pauseZ assertEqualr r r )�selfr r r
� test_signals) s"
zThreadSignals.test_signalsc C s t �td� d S )Nr )r �start_new_threadr )r! r r r
r I s z#ThreadSignals.spawnSignallingThreadc C s t �d S )N)�KeyboardInterrupt)r! r r r r r
�alarm_interruptL s z ThreadSignals.alarm_interruptz/POSIX condition variables cannot be interruptedZlinuxzBIssue 34004: musl does not allow interruption of locks by signals.Zopenbsdz%lock cannot be interrupted on OpenBSDc
C s� t � t j| j�}zPt�� }|�� t �d� t�� }| j t
|jdd� t�� | }| � |d� W d t �d� t � t j|� X d S )Nr
� )�timeoutg @r ) r r r% r �
allocate_lockr r �time� monotonic� assertRaisesr$ �
assertLess)r! �oldalrm�lock�t1�dtr r r
� test_lock_acquire_interruptionO s
z,ThreadSignals.test_lock_acquire_interruptionc
s� t � t j| j�}z�t�� � � fdd�}t�� �r t�|d� x"� jdd�r^� � � t
� d� q>W t � d� t
�
� }| jt� jdd � t
�
� | }| �|d
� W d Q R X W d t � d � t � t j|� X d S ) Nc s � � � d S )N)r r )�rlockr r
� other_thread� s zCThreadSignals.test_rlock_acquire_interruption.<locals>.other_threadr F)�blockingg{�G�z�?r
r& )r' g @r )r r r% r �RLockr r r# r r r) �sleepr r* r+ r$ r, )r! r- r3 r/ r0 r )r2 r
� test_rlock_acquire_interruptionn s
z-ThreadSignals.test_rlock_acquire_interruptionc
s� d�_ �fdd�}t�tj|�}zr� fdd�}t�� �T t�|d� x"� jdd�rf� �� t �
d� qFW � �� }�� �j � �� |� W d Q R X W d t�tj|� X d S ) NFc s
d� _ d S )NT)� sig_recvd)r r )r! r r
�
my_handler� s z9ThreadSignals.acquire_retries_on_intr.<locals>.my_handlerc s6 � � � t�d� t�ttj� t�d� � �� d S )Ng �?) r r) r6 r r r r r r r )r. r r
r3 � s
z;ThreadSignals.acquire_retries_on_intr.<locals>.other_threadr )r4 g{�G�z�?) r8 r r r r r r# r r r) r6 Z
assertTrue)r! r. r9 � old_handlerr3 �resultr )r. r! r
�acquire_retries_on_intr� s
z%ThreadSignals.acquire_retries_on_intrc C s | � t�� � d S )N)r< r r( )r! r r r
�!test_lock_acquire_retries_on_intr� s z/ThreadSignals.test_lock_acquire_retries_on_intrc C s | � t�� � d S )N)r< r r5 )r! r r r
�"test_rlock_acquire_retries_on_intr� s z0ThreadSignals.test_rlock_acquire_retries_on_intrc
s� d �_ d �_d�_t�� � � �� t�� ���� �fdd�}t�tj|�}z���fdd�}� fdd�}t� � �V t�
|d� |� � �� �� �j�j d � �� �j�j d
� �� �jd� W d Q R X W d t�tj|� X d S ) Nr c s � j d7 _ d S )Nr
)�
sigs_recvd)Zsignumr )r! r r
r9 � s z@ThreadSignals.test_interrupted_timed_acquire.<locals>.my_handlerc s$ t �� �_� jdd� t �� �_d S )Ng �?)r' )r) r* �startr �endr )r. r! r r
�
timed_acquire� s
zCThreadSignals.test_interrupted_timed_acquire.<locals>.timed_acquirec s6 x(t d�D ] } t�d� t�ttj� q
W � �� d S )N�( g{�G�z�?) �ranger) r6 r r r r r r )�_)�doner r
r � s
zBThreadSignals.test_interrupted_timed_acquire.<locals>.send_signalsr g @g333333�?)
r@ rA r? r r( r r r r r r# r, Z
assertGreater)r! r9 r: rB r r )rF r. r! r
� test_interrupted_timed_acquire� s(
z,ThreadSignals.test_interrupted_timed_acquireN)�__name__�
__module__� __qualname__r" r r% �unittestZskipIf�USING_PTHREAD_COND�sys�platform�
startswith� thread_info�versionr1 r7 r< r= r> rG r r r r
r ' s* r c C sR t jddd�t jddd�t jddd�iatttt�} zt�t � W d t| � X d S )Nr )r r )
r r r r r r r r Z run_unittestr )Zoldsigsr r r
� test_main� s rR �__main__)�__doc__rK r r rM Ztestr �_threadr r) rN ZSkipTest�getpidr r( r rP �namer. rL r r r ZTestCaser rR rH r r r r
�<module> s* C