Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/test/__pycache__/asyncio_test.cpython-39.pyc
Ðазад
a _�h� � @ s� d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlm Z m Z m Z d dl m Z mZ G dd� de �ZG d d � d ej�ZG d d � d ej�ZdS ) � N)�ThreadPoolExecutor)�gen)�IOLoop)� AsyncIOLoop�to_asyncio_future�AnyThreadEventLoopPolicy)� AsyncTestCase�gen_testc @ s< e Zd Zdd� Zdd� Zedd� �Zedd� �Zd d � Zd S ) �AsyncIOLoopTestc C s t � }|S �N)r )�self�io_loop� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/test/asyncio_test.py�get_new_ioloop s z AsyncIOLoopTest.get_new_ioloopc C s t �� �| j� | �� d S r )�asyncio�get_event_loop� call_soon�stop�wait�r r r r �test_asyncio_callback s z%AsyncIOLoopTest.test_asyncio_callbackc c sF t td�rtj}n ttd�}|t�� �d dd� ��V }| �|d� d S )N� ensure_future�asyncc S s dS �N�* r r r r r �<lambda>1 � z5AsyncIOLoopTest.test_asyncio_future.<locals>.<lambda>r )�hasattrr r �getattrr �run_in_executor� assertEqual)r r �xr r r �test_asyncio_future% s �z#AsyncIOLoopTest.test_asyncio_futurec c s& t jdd� �}|� V }| �|d� d S )Nc s s" t �� } | �d dd� �E d H }|S )Nc S s dS r r r r r r r : r zDAsyncIOLoopTest.test_asyncio_yield_from.<locals>.f.<locals>.<lambda>)r r r )Z event_loopr" r r r �f7 s z2AsyncIOLoopTest.test_asyncio_yield_from.<locals>.fr )r � coroutiner! )r r$ �resultr r r �test_asyncio_yield_from5 s z'AsyncIOLoopTest.test_asyncio_yield_fromc s� t jdd� ���fdd�� �fdd�}� fdd�}| �| j�� �d � | �| j�|�d � | �| j�|�d � | �t�� �� � �d � | �t�� �|� �d � | �t�� �|� �d � d S ) Nc s s t jV t �d��d S r )r Zmoment�Returnr r r r �tornado_coroutineE s z?AsyncIOLoopTest.test_asyncio_adapter.<locals>.tornado_coroutinec � s � � I d H S r r r �r) r r � native_coroutine_without_adapterJ s zNAsyncIOLoopTest.test_asyncio_adapter.<locals>.native_coroutine_without_adapterc � s t � � �I d H S r �r r r* r r � native_coroutine_with_adapterM s zKAsyncIOLoopTest.test_asyncio_adapter.<locals>.native_coroutine_with_adapterc � s t � � �I d H S r r, r )r+ r r � native_coroutine_with_adapter2Q s zLAsyncIOLoopTest.test_asyncio_adapter.<locals>.native_coroutine_with_adapter2r )r r% r! r Zrun_syncr r Zrun_until_complete)r r- r. r )r+ r) r �test_asyncio_adapter@ s4 ������z$AsyncIOLoopTest.test_asyncio_adapterN) �__name__� __module__� __qualname__r r r r# r' r/ r r r r r s r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �LeakTestc C s& t � �� t�� | _t�t�� � d S r )r �closer �get_event_loop_policy� orig_policy�set_event_loop_policyZDefaultEventLoopPolicyr r r r �setUpp s zLeakTest.setUpc C s t �� �� t �| j� d S r )r r r4 r7 r6 r r r r �tearDownx s zLeakTest.tearDownc C sD t tj�}td�D ]}t� }|�� qt tj�| }| �|d� d S )N� r )�lenr �_ioloop_for_asyncio�ranger r4 r! �r Z orig_count�i�loopZ new_countr r r �test_ioloop_close_leak| s z LeakTest.test_ioloop_close_leakc C sf t tj�}td�D ]4}t�� }|�tj� |�|j� |� � |� � qt tj�| }| � |d� d S )Nr: � ) r; r r< r= r Znew_event_loopr �currentr Z run_foreverr4 r! r> r r r �test_asyncio_close_leak� s z LeakTest.test_asyncio_close_leakN)r0 r1 r2 r8 r9 rA rD r r r r r3 o s r3 c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )� AnyThreadEventLoopPolicyTestc C s t �� | _td�| _d S )NrB )r r5 r6 r �executorr r r r r8 � s z"AnyThreadEventLoopPolicyTest.setUpc C s t �| j� | j�� d S r )r r7 r6 rF �shutdownr r r r r9 � s z%AnyThreadEventLoopPolicyTest.tearDownc C s dd� }| j �|�}|�� S )Nc S s t �� } | �� | S )a# Get the event loop. Close it if one is returned. Returns the (closed) event loop. This is a silly thing to do and leaves the thread in a broken state, but it's enough for this test. Closing the loop avoids resource leak warnings. �r r r4 )r@ r r r �get_and_close_event_loop� s zWAnyThreadEventLoopPolicyTest.get_event_loop_on_thread.<locals>.get_and_close_event_loop)rF �submitr& )r rI �futurer r r �get_event_loop_on_thread� s z5AnyThreadEventLoopPolicyTest.get_event_loop_on_threadc C sV | � ttf| j�|�j� t�t� � | � | j�|��� |� | j�dd� ��� d S )Nc S s t �� �� S r rH r r r r r � r z>AnyThreadEventLoopPolicyTest.run_policy_test.<locals>.<lambda>) Z assertRaises� RuntimeError�AssertionErrorrF rJ r& r r7 r ZassertIsInstance)r �accessor� expected_typer r r �run_policy_test� s � z,AnyThreadEventLoopPolicyTest.run_policy_testc C s | � tjtj� d S r )rQ r r ZAbstractEventLoopr r r r �test_asyncio_accessor� s z2AnyThreadEventLoopPolicyTest.test_asyncio_accessorc C s | � tjt� d S r )rQ r rC r r r r �test_tornado_accessor� s z2AnyThreadEventLoopPolicyTest.test_tornado_accessorN) r0 r1 r2 r8 r9 rL rQ rR rS r r r r rE � s rE )r Zunittest�concurrent.futuresr �tornador Ztornado.ioloopr Ztornado.platform.asyncior r r Ztornado.testingr r r ZTestCaser3 rE r r r r �<module> s T%
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка