File: //usr/local/lib/python3.10/test/test_importlib/__pycache__/test_locks.cpython-310.pyc
o
�i� � @ s d dl mZ e�d�ZddlZddlZddlZddlZddl m
Z
ddl m Z ddl m
Z
G dd � d �Zd
d � e�� D �Zejee
jed �\ZZG d
d� d�Zdd � e�� D �Zejeeed�\ZZG dd� d�Zejeed�\ZZdd� Z e dkr�e � � dS dS )� )�util� importlib� N)�support)�threading_helper)�
lock_testsc @ s8 e Zd Zedd� �ZdZdZdZdZdZ dZ
dZ dZ dS )�ModuleLockAsRLockTestsc C s
| � d�S )NZ some_lock��LockType)�cls� r �;/usr/local/lib/python3.10/test/test_importlib/test_locks.py�<lambda> s
z ModuleLockAsRLockTests.<lambda>N)
�__name__�
__module__� __qualname__� classmethodZlocktypeZtest__is_ownedZtest_try_acquireZtest_try_acquire_contendedZ test_withZ test_timeoutZ test_release_save_unacquiredZ test_reprZtest_locked_reprr r r r
r s r c C � i | ] \}}||j j�qS r )�
_bootstrap� _ModuleLock��.0�kindZ splitinitr r r
�
<dictcomp>! � �r r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �DeadlockAvoidanceTestsc C s6 z
t �� | _t�d� W d S ty d | _Y d S w )Ng���ư>)�sys�getswitchinterval�old_switchintervalr �setswitchinterval�AttributeError��selfr r r
�setUp, s
�z DeadlockAvoidanceTests.setUpc C s | j d ur
t�| j � d S d S �N)r r r r! r r r
�tearDown3 s
�z DeadlockAvoidanceTests.tearDownc s� d� �fdd�t � �D ��� �fdd�t � �D ��|r � }n� d }t�|��g ��fdd������fdd �}t�||��� ��t��|� �S )
N�
c s g | ] }� � t|���qS r )r
�str�r �ir! r r
�
<listcomp>9 s zFDeadlockAvoidanceTests.run_deadlock_avoidance_test.<locals>.<listcomp>c s$ g | ]}�| �|d � f�qS )r r r( )�NLOCKS�locksr r
r* : s $ r c s& z| � � W dS � jy Y dS w )zOTry to acquire the lock. Return True on success,
False on deadlock.FT)�acquire�
DeadlockError)�lockr! r r
�_acquireB s
��zDDeadlockAvoidanceTests.run_deadlock_avoidance_test.<locals>._acquirec sR �� � \} }� | �}��� � |�}��||f� |r |�� |r'| �� d S d S r$ )�pop�wait�append�release)�a�bZra�rb)r0 �barrier�pairs�resultsr r
�fL s �z=DeadlockAvoidanceTests.run_deadlock_avoidance_test.<locals>.f)�range� threading�Barrierr ZBunchZwait_for_finished� assertEqual�len)r" Zcreate_deadlockZNTHREADSr; r )r+ r0 r8 r, r9 r: r" r
�run_deadlock_avoidance_test7 s
z2DeadlockAvoidanceTests.run_deadlock_avoidance_testc C s> | � d�}|�d�}| �|d� | �|�d�t|�| � d S )NT�TFr �TT)rA �countZassertGreaterEqualr? r@ )r" r: Z nb_deadlocksr r r
�
test_deadlockZ s
z$DeadlockAvoidanceTests.test_deadlockc C s6 | � d�}| �|�d�d� | �|�d�t|�� d S )NFrB r rC )rA r? rD r@ )r" r: r r r
�test_no_deadlockc s
z'DeadlockAvoidanceTests.test_no_deadlockN)r r r r# r% rA rE rF r r r r
r * s # r c C r r )r �_DeadlockErrorr r r r
r i r )r
r. c @ s( e Zd Zedd� �Zdd� Zdd� ZdS )�
LifetimeTestsc C s | j jS r$ )�initr r! r r r
� bootstrapu s zLifetimeTests.bootstrapc C sd d}| � || jj� | j�|�}| �|| jj� t�|�}~t�� | � || jj� | � |� � d S )NZxyzzy)
Z assertNotInrJ �
_module_locks�_get_module_lockZassertIn�weakref�refr �
gc_collectZ assertIsNone)r" �namer/ �wrr r r
�test_lock_lifetimey s
z LifetimeTests.test_lock_lifetimec C s& t �� | �dt| jj�| jj� d S )Nr )r rO r? r@ rJ rK r! r r r
�test_all_locks� s �z LifetimeTests.test_all_locksN)r r r �propertyrJ rR rS r r r r
rH s s
rH )rI c C s t �� } tjt jg| �R � d S r$ )r Zthreading_setup�unittestZaddModuleCleanupZthreading_cleanup)� thread_infor r r
� setUpModule� s rW �__main__) � r Z test_utilZimport_importlibrI r r= rU rM �testr Z test.supportr r r �itemsZ
LOCK_TYPESZ test_bothZ
RLockTestsZ Frozen_ModuleLockAsRLockTestsZ Source_ModuleLockAsRLockTestsr ZDEADLOCK_ERRORSZ Frozen_DeadlockAvoidanceTestsZ Source_DeadlockAvoidanceTestsrH ZFrozen_LifetimeTestsZSource_LifetimeTestsrW r Zunittets�mainr r r r
�<module> sH
�
��?��� � �