Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/test/__pycache__/gen_test.cpython-39.pyc
Ðазад
a _�h�� � @ s� d dl Z d dlmZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl m Z d dl m Z d dlmZmZmZmZ d dlmZmZ d dlmZmZmZ d dlmZ z d dl Z W n e y� dZ Y n0 d dl Z e j r�d d l m Z m!Z! G d d � d e�Z"G d d � d e�Z#G dd� de�Z$G dd� de�Z%G dd� de�Z&G dd� de�Z'G dd� de�Z(G dd� de�Z)G dd� de�Z*G d d � d e�Z+G d d � d e�Z,e du�r�e �-d �Z.e �/e du d!�G d"d#� d#e��Z0e1d$k�r�e �2� dS )%� N)�futures)�Future)�app_log)�AsyncHTTPTestCase� AsyncTestCase� ExpectLog�gen_test)� skipOnTravis�skipNotCPython)� Application�RequestHandler� HTTPError)�gen)�List�Optionalc @ s0 e Zd Zejdd� �Zejdd� �Zejdd� �Zejdd� �Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zeed d � ��Zed!d"� �Zed#d$� �Zed%d&� �Zed'd(� �Zed)d*� �Zed+d,� �Z ed-d.� �Z d/d0� Z d1d2� Z d3d4� Z d5d6� Z!d7d8� Z"d9d:� Z#d;S )<� GenBasicTestc c s$ t |�D ] }tjV qt�|��dS )z0Returns arg after a number of IOLoop iterations.N)�ranger �moment�Return)�selfZ iterations�arg�i� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/test/gen_test.py�delay s zGenBasicTest.delayc c s t jV |S �N�r r �r �resultr r r � async_future& s zGenBasicTest.async_futurec c s t jV |�d S r r )r �er r r �async_exception+ s z GenBasicTest.async_exceptionc c s t jV t �|d ��d S �N� �r r r �r �xr r r � add_one_async0 s zGenBasicTest.add_one_asyncc C s t jdd� �}| j�|� d S )Nc S s d S r r r r r r �f6 s z%GenBasicTest.test_no_yield.<locals>.f�r � coroutine�io_loop�run_sync�r r( r r r � test_no_yield5 s zGenBasicTest.test_no_yieldc C s$ t jdd� �}| �t| jj|� d S )Nc S s dd d S �Nr# r r r r r r r( = s z-GenBasicTest.test_exception_phase1.<locals>.f�r r* � assertRaises�ZeroDivisionErrorr+ r, r- r r r �test_exception_phase1< s z"GenBasicTest.test_exception_phase1c C s$ t jdd� �}| �t| jj|� d S )Nc s s t jV dd d S r/ r r r r r r( D s z-GenBasicTest.test_exception_phase2.<locals>.fr0 r- r r r �test_exception_phase2C s z"GenBasicTest.test_exception_phase2c C s& t jdd� �}| �t j| jj|� d S )Nc s s dV d S �N�* r r r r r r( L s z(GenBasicTest.test_bogus_yield.<locals>.f�r r* r1 Z BadYieldErrorr+ r, r- r r r �test_bogus_yieldK s z GenBasicTest.test_bogus_yieldc C s& t jdd� �}| �t j| jj|� d S )Nc s s dV d S �N�r# � r r r r r r( S s z.GenBasicTest.test_bogus_yield_tuple.<locals>.fr7 r- r r r �test_bogus_yield_tupleR s z#GenBasicTest.test_bogus_yield_tuplec C s* t jdd� �}| j�|� | j�|� d S )Nc s s t jV d S r r r r r r r( Z s z"GenBasicTest.test_reuse.<locals>.fr) r- r r r � test_reuseY s zGenBasicTest.test_reusec C s t jdd� �}| j�|� d S )Nc s s d V d S r r r r r r r( b s z!GenBasicTest.test_none.<locals>.fr) r- r r r � test_nonea s zGenBasicTest.test_nonec s" t j� fdd��}� j�|� d S )Nc 3 s* � � d�� � d�gV } � �| ddg� d S )Nr# r; � )r' � assertEqual��results�r r r r( i s z"GenBasicTest.test_multi.<locals>.fr) r- r rC r � test_multih s zGenBasicTest.test_multic s" t j� fdd��}� j�|� d S )Nc 3 s2 t � �d�� �d�d�V } � �| t ddd�� d S )Nr# r; �Zfoo�barr? )�dictr' r@ rA rC r r r( q s z'GenBasicTest.test_multi_dict.<locals>.fr) r- r rC r �test_multi_dictp s z GenBasicTest.test_multi_dictc s" t j� fdd��}� j�|� d S )Nc 3 s4 t �� �dd�� �dd�g�V } � �| ddg� d S )Nr? �v1r# �v2)r � multi_futurer r@ �� responsesrC r r r( y s �z*GenBasicTest.test_multi_delayed.<locals>.fr) r- r rC r �test_multi_delayedx s z GenBasicTest.test_multi_delayedc s" t j� fdd��}� j�|� d S )Nc 3 s< t �t� �dd�� �dd�d��V } � �| tddd�� d S )Nr? rI r# rJ rE )r rK rG r r@ rL rC r r r( � s �z/GenBasicTest.test_multi_dict_delayed.<locals>.fr) r- r rC r �test_multi_dict_delayed� s z$GenBasicTest.test_multi_dict_delayedc c s8 t � � }dd� td�D �V t � � }| �|| d� d S )Nc S s g | ] }t j�qS r r )�.0r r r r � <listcomp>� � z7GenBasicTest.test_multi_performance.<locals>.<listcomp>i� g �?)�timer Z assertLess)r �start�endr r r �test_multi_performance� s z#GenBasicTest.test_multi_performancec c s0 g V }| � t|t�� i V }| � t|t�� d S r )� assertTrue� isinstance�listrG )r r& �yr r r �test_multi_empty� s z GenBasicTest.test_multi_emptyc c s | � d�V }| �|d� d S r" �r r@ r r r r � test_future� s zGenBasicTest.test_futurec c s* | � d�| � d�gV }| �|ddg� d S )Nr# r; r\ �r rB r r r �test_multi_future� s z GenBasicTest.test_multi_futurec c s8 | � d�}| � d�|| � d�|gV }| �|g d�� d S )Nr; r# r? )r# r; r? r; r\ )r r( rB r r r �test_multi_future_duplicate� s z(GenBasicTest.test_multi_future_duplicatec c s2 t | �d�| �d�d�V }| �|t ddd�� d S )Nr# r; rE )rG r r@ r^ r r r �test_multi_dict_future� s z#GenBasicTest.test_multi_dict_futurec c s, t td��^ | �t��4}t�| �td��| �td��g�V W d � n1 sP0 Y W d � n1 sn0 Y | �t|j �d� | �t��0 t�| �td��| � d�g�V W d � n1 s�0 Y | �t��8 tj| �td��| �td��gtd�V W d � n1 �s 0 Y d S �Nz!Multiple exceptions in yield listzerror 1zerror 2r; )Zquiet_exceptions) r r r1 � RuntimeErrorr ZMultir! r@ �str� exceptionr �r �cmr r r �test_multi_exceptions� s& ��B �$ ��z"GenBasicTest.test_multi_exceptionsc c s t td��X | �t��.}| �td��| �td��gV W d � n1 sJ0 Y W d � n1 sh0 Y | �t|j�d� | �t��* | �td��| �d�gV W d � n1 s�0 Y | �t��8 t j | �td��| �td��gtd�V W d � n1 �s0 Y d S rb ) r r r1 rc r! r@ rd re r r rK rf r r r � test_multi_future_exceptions� s �B 8 ��z)GenBasicTest.test_multi_future_exceptionsc C s t jdd� �}| j�|� d S )Nc S s t �� �d S r �r r r r r r r( � s z.GenBasicTest.test_sync_raise_return.<locals>.fr) r- r r r �test_sync_raise_return� s z#GenBasicTest.test_sync_raise_returnc C s t jdd� �}| j�|� d S )Nc s s t jV t �� �d S r r$ r r r r r( � s z/GenBasicTest.test_async_raise_return.<locals>.fr) r- r r r �test_async_raise_return� s z$GenBasicTest.test_async_raise_returnc C s& t jdd� �}| �d| j�|�� d S )Nc S s t �d��d S r5 rj r r r r r( � s z4GenBasicTest.test_sync_raise_return_value.<locals>.fr6 �r r* r@ r+ r, r- r r r � test_sync_raise_return_value� s z)GenBasicTest.test_sync_raise_return_valuec C s& t jdd� �}| �d| j�|�� d S )Nc S s t �d��d S r9 rj r r r r r( s z:GenBasicTest.test_sync_raise_return_value_tuple.<locals>.fr: rm r- r r r �"test_sync_raise_return_value_tuple s z/GenBasicTest.test_sync_raise_return_value_tuplec C s& t jdd� �}| �d| j�|�� d S )Nc s s t jV t �d��d S r5 r$ r r r r r( s z5GenBasicTest.test_async_raise_return_value.<locals>.fr6 rm r- r r r � test_async_raise_return_value s z*GenBasicTest.test_async_raise_return_valuec C s& t jdd� �}| �d| j�|�� d S )Nc s s t jV t �d��d S r9 r$ r r r r r( s z;GenBasicTest.test_async_raise_return_value_tuple.<locals>.fr: rm r- r r r �#test_async_raise_return_value_tuple s z0GenBasicTest.test_async_raise_return_value_tupleN)$�__name__� __module__� __qualname__r r* r r r! r' r. r3 r4 r8 r< r= r> rD rH rN rO r r rV r[ r] r_ r` ra rh ri rk rl rn ro rp rq r r r r r sT r c sT e Zd Z� fdd�Z� fdd�Zdd� Zdd� Zed d � �Zed d � �Z ed d� �Z edd� �Z edd� �Z edd� �Z edd� �Zedd� �Zedd� �Zedd � �Zed d � �Zed d � �Zed!d"� �Zed#d$� �Zed%d&� �Zed'd(� �Zed)d*� �Zed+d,� �Zee� d-e j k �o$d.k n d/�d0d1� ��Z d2d3� Z ed4d5� �Z!� Z"S )6�GenCoroutineTestc s d| _ tt| ��� d S )NF)�finished�superru �setUprC �� __class__r r rx s zGenCoroutineTest.setUpc s t t| ��� | jsJ �d S r )rw ru �tearDownrv rC ry r r r{ " s zGenCoroutineTest.tearDownc C sJ d| _ dd� }t�|�}| �|j|j� | �|j|j� | �|j|� d S )NTc s s t jV d S r r r r r r r( ) s z+GenCoroutineTest.test_attributes.<locals>.f)rv r r* r@ rr rs �assertIs� __wrapped__�r r( �coror r r �test_attributes& s z GenCoroutineTest.test_attributesc C sN d| _ dd� }t�|�}| �t�|�� | �t�|�� | �t�|� �� d S )NTc s s t jV d S r r r r r r r( 4 s z6GenCoroutineTest.test_is_coroutine_function.<locals>.f)rv r r* Z assertFalseZis_coroutine_functionrW r~ r r r �test_is_coroutine_function1 s z+GenCoroutineTest.test_is_coroutine_functionc c s, t jdd� �}|� V }| �|d� d| _d S )Nc S s t �d��d S r5 rj r r r r r( > s z0GenCoroutineTest.test_sync_gen_return.<locals>.fr6 T�r r* r@ rv �r r( r r r r �test_sync_gen_return< s z%GenCoroutineTest.test_sync_gen_returnc c s, t jdd� �}|� V }| �|d� d| _d S )Nc s s t jV t �d��d S r5 r$ r r r r r( H s z1GenCoroutineTest.test_async_gen_return.<locals>.fr6 Tr� r� r r r �test_async_gen_returnF s z&GenCoroutineTest.test_async_gen_returnc c s, t jdd� �}|� V }| �|d� d| _d S )Nc S s dS r5 r r r r r r( S s z,GenCoroutineTest.test_sync_return.<locals>.fr6 Tr� r� r r r �test_sync_returnQ s z!GenCoroutineTest.test_sync_returnc c s, t jdd� �}|� V }| �|d� d| _d S )Nc s s t jV dS r5 r r r r r r( ] s z-GenCoroutineTest.test_async_return.<locals>.fr6 Tr� r� r r r �test_async_return[ s z"GenCoroutineTest.test_async_returnc # s0 t j� fdd��}|� V }� �|d� d� _d S )Nc 3 s dS r5 )r �Taskr+ � add_callbackr rC r r r( k s z3GenCoroutineTest.test_async_early_return.<locals>.fr6 Tr� r� r rC r �test_async_early_returnf s z(GenCoroutineTest.test_async_early_returnc # s8 t jdd� �� � fdd�}|� V }| �|d� d| _d S )Nc s s t jV t �d��d S r5 r$ r r r r �f1w s z-GenCoroutineTest.test_async_await.<locals>.f1c � s � � I d H } | S r r �r �r� r r �f2 s z-GenCoroutineTest.test_async_await.<locals>.f2r6 Tr� �r r� r r r� r �test_async_awaitu s z!GenCoroutineTest.test_async_awaitc c s& dd� }|� V }| � |d� d| _d S )Nc � s dd l } | �d�I d H dS )Nr r6 )�asyncio�sleep)r� r r r r( � s z3GenCoroutineTest.test_asyncio_sleep_zero.<locals>.fr6 T)r@ rv r� r r r �test_asyncio_sleep_zero� s z(GenCoroutineTest.test_asyncio_sleep_zeroc # sP t jdd� �� � fdd�}t jdd� �}|� |� gV }| �|ddg� d | _d S ) Nc s s t jV d S r r r r r r r� � s zGGenCoroutineTest.test_async_await_mixed_multi_native_future.<locals>.f1c � s � � I d H dS r5 r r r� r r r� � s zGGenCoroutineTest.test_async_await_mixed_multi_native_future.<locals>.f2c s s t jV t �d��d S )N�+ r$ r r r r �f3� s zGGenCoroutineTest.test_async_await_mixed_multi_native_future.<locals>.f3r6 r� Tr� )r r� r� rB r r� r �*test_async_await_mixed_multi_native_future� s z;GenCoroutineTest.test_async_await_mixed_multi_native_futurec c s6 dd� }t �tjdd�|� �V }| �|d� d| _d S )Nc � s dS r5 r r r r r r� � s z4GenCoroutineTest.test_async_with_timeout.<locals>.f1r# )�hoursr6 T)r � with_timeout�datetime� timedeltar@ rv )r r� r r r r �test_async_with_timeout� s z(GenCoroutineTest.test_async_with_timeoutc c s, t jdd� �}|� V }| �|d � d| _d S )Nc S s d S r r r r r r r( � s z5GenCoroutineTest.test_sync_return_no_value.<locals>.fTr� r� r r r �test_sync_return_no_value� s z*GenCoroutineTest.test_sync_return_no_valuec c s, t jdd� �}|� V }| �|d � d| _d S )Nc s s t jV d S r r r r r r r( � s z6GenCoroutineTest.test_async_return_no_value.<locals>.fTr� r� r r r �test_async_return_no_value� s z+GenCoroutineTest.test_async_return_no_valuec c sN t jdd� �}|� }| �t�� |V W d � n1 s:0 Y d| _d S )Nc S s dd d S r/ r r r r r r( � s z+GenCoroutineTest.test_sync_raise.<locals>.fT�r r* r1 r2 rv �r r( �futurer r r �test_sync_raise� s $z GenCoroutineTest.test_sync_raisec c sN t jdd� �}|� }| �t�� |V W d � n1 s:0 Y d| _d S )Nc s s t jV dd d S r/ r r r r r r( � s z,GenCoroutineTest.test_async_raise.<locals>.fTr� r� r r r �test_async_raise� s $z!GenCoroutineTest.test_async_raisec # s` t jdd� �� t j� fdd��}|� }| �t�� |V W d � n1 sL0 Y d| _d S )Nc S s dd d S r/ r r r r r r� � s z>GenCoroutineTest.test_replace_yieldpoint_exception.<locals>.f1c 3 s* z � � V W n t y$ t� �Y n0 d S r )r2 �KeyErrorr r� r r r� � s z>GenCoroutineTest.test_replace_yieldpoint_exception.<locals>.f2T)r r* r1 r� rv )r r� r� r r� r �!test_replace_yieldpoint_exception� s $z2GenCoroutineTest.test_replace_yieldpoint_exceptionc # s> t jdd� �� t j� fdd��}|� V }| �|d� d| _d S )Nc S s dd d S r/ r r r r r r� � s z>GenCoroutineTest.test_swallow_yieldpoint_exception.<locals>.f1c 3 s. z � � V W n t y( t�d��Y n0 d S r5 )r2 r r r r� r r r� � s z>GenCoroutineTest.test_swallow_yieldpoint_exception.<locals>.f2r6 Tr� r� r r� r �!test_swallow_yieldpoint_exception� s z2GenCoroutineTest.test_swallow_yieldpoint_exceptionc # s� g � t j� fdd��}t� }|�d � |d|�|d|�gV | �d�� �d� g � |dt j�|dt j�gV | �d�� �d� d| _g � |dt j�|d|�gV | �d�� �d � d S ) Nc 3 s" t d�D ]}� �| � |V qd S )N� )r �append)�nameZ yieldabler �Zcallsr r r( s z'GenCoroutineTest.test_moment.<locals>.f�a�b� Z aaaaabbbbbZ abababababTZ abbbbbaaaa)r r* r � set_resultr@ �joinr rv )r r( Z immediater r� r � test_moment s z GenCoroutineTest.test_momentc c s t �d�V d| _d S )N�{�G�z�?T)r r� rv rC r r r � test_sleep# s zGenCoroutineTest.test_sleepc # s� G dd� dt �� tj� fdd��}z|d�V W n@ � yp } z(| �t|�d� | �|j� W Y d }~n d }~0 0 z|d�V W n@ � y� } z(| �t|�d� | �|j� W Y d }~n d }~0 0 d | _d S ) Nc @ s e Zd ZdS )zIGenCoroutineTest.test_py3_leak_exception_context.<locals>.LeakedExceptionN�rr rs rt r r r r �LeakedException* s r� c s � | ��d S r r )� iteration�r� r r �inner- s z?GenCoroutineTest.test_py3_leak_exception_context.<locals>.innerr# �1r; �2T)� Exceptionr r* r@ rd Z assertIsNone� __context__rv )r r� r r r� r � test_py3_leak_exception_context( s ""z0GenCoroutineTest.test_py3_leak_exception_context�r? )r? � z#asyncio.Future has reference cyclesc sN t j�fdd��� t j� fdd��}�jj|dd� ����� d � d�_d S )Nc 3 sD G dd� dt �} | � }t�|�� _dd� }t�|�� V td��d S )Nc @ s e Zd ZdS )zGGenCoroutineTest.test_coroutine_refcounting.<locals>.inner.<locals>.FooNr� r r r r �FooH s r� c S s d S r r r r r r �dummyN s zIGenCoroutineTest.test_coroutine_refcounting.<locals>.inner.<locals>.dummyz Some error)�object�weakref�ref� local_refr r* � ValueError)r� Z local_varr� rC r r r� F s z:GenCoroutineTest.test_coroutine_refcounting.<locals>.innerc 3 s$ z � � V W n t y Y n0 d S r )r� r )r� r r �inner2T s z;GenCoroutineTest.test_coroutine_refcounting.<locals>.inner2r? )�timeoutT)r r* r+ r, r| r� rv )r r� r )r� r r �test_coroutine_refcounting? s z+GenCoroutineTest.test_coroutine_refcountingc C sx d| _ t�� }| �|j|�� � |�d� dd� }t�|�� }| �|tj � dt |j j d f }t |�}| �||� d S )NTc s s t jV d S r r r r r r r( g s z:GenCoroutineTest.test_asyncio_future_debug_info.<locals>.fzcreated at %s:%dr? )rv r� �get_event_loopZ addCleanupZ set_debugZ get_debugr r* ZassertIsInstancer �__file__�__code__�co_firstlineno�reprZassertIn)r Z asyncio_loopr( r �expected�actualr r r � test_asyncio_future_debug_info` s z/GenCoroutineTest.test_asyncio_future_debug_infoc c s: t jdd� �}t�|� |� �V }| �|ddg� d| _d S )Nc s s t jV t �d��d S r" r$ r r r r r( v s z/GenCoroutineTest.test_asyncio_gather.<locals>.fr# T)r r* r� Zgatherr@ rv )r r( �retr r r �test_asyncio_gatherr s z$GenCoroutineTest.test_asyncio_gather)#rr rs rt rx r{ r� r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r �unittest�skipIf�sys� version_infor� r� r� � __classcell__r r ry r ru s` � ru c @ s e Zd Zejdd� �ZdS )�GenCoroutineSequenceHandlerc c s: t jV | �d� t jV | �d� t jV | �d� d S �Nr� r� �3)r r �write�finishrC r r r �get� s z GenCoroutineSequenceHandler.getN�rr rs rt r r* r� r r r r r� � s r� c @ s e Zd Zejdd� �ZdS )�%GenCoroutineUnfinishedSequenceHandlerc c s: t jV | �d� t jV | �d� t jV | �d� d S r� )r r r� rC r r r r� � s z)GenCoroutineUnfinishedSequenceHandler.getNr� r r r r r� � s r� c @ s( e Zd Zejdd� �Zejdd� �ZdS )� UndecoratedCoroutinesHandlerc c s g | _ tjV | j �d� d S )Nr� )�chunksr r r� rC r r r �prepare� s z$UndecoratedCoroutinesHandler.preparec c s> | j �d� tjV | j �d� tjV | �d�| j �� d S )Nr� r� r� )r� r� r r r� r� rC r r r r� � s z UndecoratedCoroutinesHandler.getN�rr rs rt r r* r� r� r r r r r� � s r� c @ s" e Zd Zejdd� �Zdd� ZdS )�AsyncPrepareErrorHandlerc c s t jV td��d S )N� )r r r rC r r r r� � s z AsyncPrepareErrorHandler.preparec C s | � d� d S )N�ok)r� rC r r r r� � s z AsyncPrepareErrorHandler.getNr� r r r r r� � s r� c @ s e Zd Zdd� ZdS )�NativeCoroutineHandlerc � s t �d�I d H | �d� d S )Nr r� )r� r� r� rC r r r r� � s zNativeCoroutineHandler.getN)rr rs rt r� r r r r r� � s r� c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )� GenWebTestc C s& t dtfdtfdtfdtfdtfg�S )N�/coroutine_sequence� /coroutine_unfinished_sequence�/undecorated_coroutine�/async_prepare_error�/native_coroutine)r r� r� r� r� r� rC r r r �get_app� s ���zGenWebTest.get_appc C s | � d�}| �|jd� d S )Nr� � 123��fetchr@ �body�r �responser r r � test_coroutine_sequence_handler� s z*GenWebTest.test_coroutine_sequence_handlerc C s | � d�}| �|jd� d S )Nr� r� r� r� r r r �*test_coroutine_unfinished_sequence_handler� s z5GenWebTest.test_coroutine_unfinished_sequence_handlerc C s | � d�}| �|jd� d S )Nr� r� r� r� r r r �test_undecorated_coroutines� s z&GenWebTest.test_undecorated_coroutinesc C s | � d�}| �|jd� d S )Nr� r� )r� r@ �coder� r r r � test_async_prepare_error_handler� s z+GenWebTest.test_async_prepare_error_handlerc C s* | � d�}| �|jd� | �|jd� d S )Nr� �� s ok)r� r@ r� r� r� r r r � test_native_coroutine_handler� s z(GenWebTest.test_native_coroutine_handlerN) rr rs rt r� r� r� r� r� r� r r r r r� � s r� c @ s` e Zd Zedd� �Zedd� �Zedd� �Zedd� �Zed d � �Zed d � �Z ed d� �Z dS )�WithTimeoutTestc c sH | � tj��( t�tjdd�t� �V W d � n1 s:0 Y d S )N皙�����?��seconds)r1 r � TimeoutErrorr� r� r� r rC r r r � test_timeout� s z WithTimeoutTest.test_timeoutc # sJ t � � | j�tjdd�� fdd�� t�tjdd�� �V }| �|d� d S )Nr� r� c s � � d�S )N�asdf)r� r �r� r r �<lambda>� rR z?WithTimeoutTest.test_completes_before_timeout.<locals>.<lambda>� r )r r+ � add_timeoutr� r� r r� r@ r r r r � test_completes_before_timeout� s �z-WithTimeoutTest.test_completes_before_timeoutc # sh t � � | j�tjdd�� fdd�� | �t��& t�tjdd�� �V W d � n1 sZ0 Y d S )Nr� r� c s � � t� �S r )� set_exceptionr2 r r r r r � rR z;WithTimeoutTest.test_fails_before_timeout.<locals>.<lambda>r ) r r+ r r� r� r1 r2 r r� rC r r r �test_fails_before_timeout� s � z)WithTimeoutTest.test_fails_before_timeoutc c s6 t � }|�d� t�tjdd�|�V }| �|d� d S )Nr r r� )r r� r r� r� r� r@ )r r� r r r r �test_already_resolved� s z%WithTimeoutTest.test_already_resolvedc c sx t �d��Z}| �tj��. t�| j�� |�tj d��V W d � n1 sL0 Y W d � n1 sj0 Y d S )Nr# r� ) r �ThreadPoolExecutorr1 r r� r� r+ rS �submitr� �r �executorr r r � test_timeout_concurrent_future� s �z.WithTimeoutTest.test_timeout_concurrent_futurec c s^ t �d��@}dd� }|�|�}|�� t�tjdd�|�V W d � n1 sP0 Y d S )Nr# c S s d S r r r r r r r� s z?WithTimeoutTest.test_completed_concurrent_future.<locals>.dummyr r� )r r r r r r� r� r� )r r r� r( r r r � test_completed_concurrent_future s z0WithTimeoutTest.test_completed_concurrent_futurec c sN t �d��0}t�tjdd�|�dd� ��V W d � n1 s@0 Y d S )Nr# r r� c S s t �d�S )Nr� )rS r� r r r r r rR z?WithTimeoutTest.test_normal_concurrent_future.<locals>.<lambda>)r r r r� r� r� r r r r r � test_normal_concurrent_future s �z-WithTimeoutTest.test_normal_concurrent_futureN) rr rs rt r r r r r r r r r r r r r� � s r� c @ sP e Zd Zedd� �Zedd� �Zdd� Zedd� �Zed d � �Zed d � �Z d S )�WaitIteratorTestc C sx t �� }| �|�� d� | �t��" t jt� t� d�}W d � n1 sJ0 Y | �|jd d� | �|j d d� d S )Nzempty generator iterated)rF �bad nil current index�bad nil current future) r � WaitIteratorrW �doner1 r� r r@ � current_index�current_future)r �gr r r �test_empty_iterator s 0z$WaitIteratorTest.test_empty_iteratorc c s� t � }t � }t � }|�d� |�d� |�d� t�|||�}d}|�� s�|�� V }|dkr�| �|jd� | �|j |� | �|d� nb|dkr�| �|jd� | �|j |� | �|d� n0|dkr�| �|jd� | �|j |� | �|d� |d7 }qB| �|jd d� | �|j d d� tj||d �}|�� �s�|�� V }|jd k�r^| � |j |k�oV|dkd � n<|jd k�r�| � |j |k�o�|dkd � n| � d � |j�� |d7 }�q | �|jd d� | �|j d d� d S )N� r6 �T r r# r; r r )r� r� r� z"WaitIterator dict status incorrectr� z got bad WaitIterator index {}) r r� r r r �nextr@ r r| r rW Zfail�format) r r� r� r� r r �r�dgZdrr r r �test_already_done) sT � � z"WaitIteratorTest.test_already_donec C sx |dkr|d � d� n>|dkr2|d �t� � n$|dkrV|d � d� |d � d � |dk rt| j�| j|d |� d S ) Nr? r; r r� r � r# r6 r )r� r r2 r+ r� �finish_coroutines)r r� r r r r r" _ s z"WaitIteratorTest.finish_coroutinesc c s� t � t � t � t � g}| �d|� tj|� }d}|�� s�z|�� V }W n& tyj | �|j|d d� Y nx0 |dkr�| � |dd� | � |j dd� nN|dkr�| � |dd� | � |j dd� n&|d kr�| � |d d� | � |j d d� |d7 }q.d S ) Nr zexception future invalidr �iterator value incorrectr; � wrong indexr6 r# r? r ) r r" r r r r r2 r| r r@ r )r r r r r r r r � test_iteratork s& z WaitIteratorTest.test_iteratorc # sL t � t � t � t � g� ��d� � d�_� �fdd�}|� V ���j� d S )Nr Fc � s� d} t j� � }zP|2 zD3 d H W }| dkrH��|dd� ��|jdd� ntd��| d7 } q6 W n tyx | d7 } Y n0 |2 zp3 d H W }| dkr���|dd� ��|jdd� n4| d krڈ�|d d� ��|jd d� n td | ��| d7 } q~6 d �_d S ) Nr r r# r; r$ z!expected exception on iteration 1r# r6 r? r zdidn't expect iteration %dT)r r r@ r r� r2 rv )r r r �r r r r r( � s* z5WaitIteratorTest.test_iterator_async_await.<locals>.f)r r" rv rW r- r r& r �test_iterator_async_await� s z*WaitIteratorTest.test_iterator_async_awaitc c s* t �tjdd�t �t �d���� �V d S )Nr� r� r )r r� r� r� r r� r rC r r r � test_no_ref� s �z WaitIteratorTest.test_no_refN) rr rs rt r r r r" r% r' r( r r r r r s 5 $r c @ s8 e Zd Zdd� Zedd� �Zdd� Zdd� Zd d � Zd S ) � RunnerGCTestc C s t �� dkotjdkS )N�PyPyr� )�platform�python_implementationr� r� rC r r r �is_pypy3� s zRunnerGCTest.is_pypy3c # sD d g��fdd�� t j� ��fdd��}t �tjdd�|� �V d S )Nc s t �d� � d � �d� d S )Nr; r �{ )�gc�collectr� r )� weakref_scoper r �callback� s z&RunnerGCTest.test_gc.<locals>.callbackc 3 s* t � } t�| ��d< �j�� � | V d S )Nr )r r� r� r+ r� �Zfut�r2 r r1 r r �tester� s z$RunnerGCTest.test_gc.<locals>.tester皙�����?r� )r r* r� r� r� )r r5 r r4 r �test_gc� s zRunnerGCTest.test_gcc s� | � � }g �g �tj�fdd��� tj� �fdd��}|�|� |�� t�� | ��d � d � | �t ��d� | � � s�| ��d d � d S )Nc 3 s8 z&t �d�V � �d� qW � �d � n � �d � 0 d S �Ng����MbP?T�r r� r� r r� r r � infinite_coro� s z9RunnerGCTest.test_gc_infinite_coro.<locals>.infinite_coroc 3 s, � � } | | _ ��t�| �� t�d�V d S �Nr6 )� _refcycler� r� r� r r� r3 )r: �wfutr r � do_something� s z8RunnerGCTest.test_gc_infinite_coro.<locals>.do_somethingr r; ���) �get_new_ioloopr r* r, �closer/ r0 r| �assertGreaterEqual�lenr- �r �loopr> r )r: r r= r �test_gc_infinite_coro� s z"RunnerGCTest.test_gc_infinite_coroc s� dd l � dd� �| �� }g �g �tj� ���fdd��}|�|� tdd�� |�� t�� W d � n1 sr0 Y | � �d � d � | � t ��d� | � � s�| � �d d � d S ) Nr c � s< z*t �d�I d H | �d� qW | �d � n | �d � 0 d S r8 r9 r� r r r r: � s z@RunnerGCTest.test_gc_infinite_async_await.<locals>.infinite_coroc 3 s8 � � � �����} | | _��t�| �� t�d�V d S r; )r� Z create_taskr< r� r� r� r r� r3 �r� r: r r= r r r> s z?RunnerGCTest.test_gc_infinite_async_await.<locals>.do_somethingr� z$Task was destroyed but it is pendingr; r? ) r� r@ r r* r, r rA r/ r0 r| rB rC r- rD r rG r � test_gc_infinite_async_await� s &z)RunnerGCTest.test_gc_infinite_async_awaitc C s4 t jdd� �}| �� }|�|�}| �|d d g� d S )Nc s s" t �t jt jg�V } t �| ��d S r )r �multir r r� r r r � wait_a_moment s z5RunnerGCTest.test_multi_moment.<locals>.wait_a_moment)r r* r@ r, r@ )r rJ rE r r r r �test_multi_moment s z RunnerGCTest.test_multi_momentN) rr rs rt r- r r7 rF rH rK r r r r r) � s $$r) �ctx_varz contextvars module not presentc @ sL e Zd Zdd� Zejdd� �Zdd� Zejdd� �Zd d � Z e d d � �Z d S )�ContextVarsTestc � s t �|� | �|�I d H d S r �rL �setr� r% r r r � native_root' s zContextVarsTest.native_rootc c s t �|� d V | �|�V d S r rN r% r r r �gen_root+ s zContextVarsTest.gen_rootc � s� �� t�� �� ����I d H �� t�� �� t�� � �j�d � ��fdd��I d H �� t�� �� t� � �d � ��fdd��I d H �� t�� �� d S )Nc s � � �j��S r ��run� thread_innerr ��ctxr r& r r r 8 rR z'ContextVarsTest.inner.<locals>.<lambda>c s � � �j��S r rR r rU r r r = rR ) r@ rL r� � gen_inner� contextvarsZ copy_contextr+ Zrun_in_executorr� r� r% r rU r r� 1 s � zContextVarsTest.innerc c s* | � t�� |� d V | � t�� |� d S r �r@ rL r� r% r r r rW A s zContextVarsTest.gen_innerc C s | � t�� |� d S r rY r% r r r rT G s z ContextVarsTest.thread_innerc c s* | � d�| � d�| �d�| �d�gV d S )Nr# r; r? � )rP rQ rC r r r �test_propagateJ s �z ContextVarsTest.test_propagateN) rr rs rt rP r r* rQ r� rW rT r r[ r r r r rM % s rM �__main__)3r� Z concurrentr r/ r� r+ r� rS r� r� Ztornado.concurrentr Z tornado.logr Ztornado.testingr r r r Ztornado.test.utilr r Z tornado.webr r r �tornador rX � ImportError�typing� TYPE_CHECKINGr r r ru r� r� r� r� r� r� r� r r) Z ContextVarrL r� rM rr �mainr r r r �<module> sT } h %@ l 0
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка