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__/asyncio_test.cpython-311.pyc
�

��b"����ddlZddlZddlZddlmZddlmZddlmZddl	m
Z
mZmZddl
mZmZGd�de��ZGd	�d
ej��ZGd�dej��ZdS)
�N)�ThreadPoolExecutor)�gen)�IOLoop)�AsyncIOLoop�to_asyncio_future�AnyThreadEventLoopPolicy)�
AsyncTestCase�gen_testc�L�eZdZd�Zd�Zed���Zed���Zd�ZdS)�AsyncIOLoopTestc�&�td���}|S�NF)�make_current)r)�self�io_loops  �;/usr/lib/python3/dist-packages/tornado/test/asyncio_test.py�get_new_ioloopzAsyncIOLoopTest.get_new_ioloops���5�1�1�1����c�~���fd�}�j�|��������dS)Nc��b�K�tj����j��dS�N)�asyncio�get_event_loop�	call_soon�stop�rs�r�add_callbackz;AsyncIOLoopTest.test_asyncio_callback.<locals>.add_callback#s,������"�$�$�.�.�t�y�9�9�9�9�9r)�asyncio_loop�run_until_complete�wait)rrs` r�test_asyncio_callbackz%AsyncIOLoopTest.test_asyncio_callback!sL���	:�	:�	:�	:�	:�	
��,�,�\�\�^�^�<�<�<��	�	�����rc#�
K�ttd��r
tj}nttd��}|tj���dd�����V�}|�|d��dS)N�
ensure_future�asyncc��dS�N�*�r(rr�<lambda>z5AsyncIOLoopTest.test_asyncio_future.<locals>.<lambda>5s��2�rr')�hasattrrr#�getattrr�run_in_executor�assertEqual)rr#�xs   r�test_asyncio_futurez#AsyncIOLoopTest.test_asyncio_future)s�����
�7�O�,�,�	6�#�1�M�M�$�G�W�5�5�M��-��"�$�$�4�4�T�:�:�F�F�
�
�
�
��	
����B�����rc#�xK�tjd���}|��V�}|�|d��dS)Nc3�jK�tj��}|�dd���Ed{V��}|S)Nc��dSr&r(r(rrr)zDAsyncIOLoopTest.test_asyncio_yield_from.<locals>.f.<locals>.<lambda>>s��B�r)rrr,)�
event_loopr.s  r�fz2AsyncIOLoopTest.test_asyncio_yield_from.<locals>.f;sB���� �/�1�1�J�%�5�5�d�J�J�G�G�G�G�G�G�G�G�A��Hrr')r�	coroutiner-)rr4�results   r�test_asyncio_yield_fromz'AsyncIOLoopTest.test_asyncio_yield_from9sN����	��	�	�
��	�
�q�s�s���������$�$�$�$�$rc�����tjd�����fd���fd�}�fd�}|�|j����d��|�|j�|��d��|�|j�|��d��|�|j������d��|�|j�|����d��|�|j�|����d��tjd��dS)Nc3�JK�tjV�tjd���r&)r�moment�Returnr(rr�tornado_coroutinez?AsyncIOLoopTest.test_asyncio_adapter.<locals>.tornado_coroutineIs"�����*�����*�R�.�.� rc��(�K�����d{V��Srr(�r<s�r� native_coroutine_without_adapterzNAsyncIOLoopTest.test_asyncio_adapter.<locals>.native_coroutine_without_adapterNs(�����*�*�,�,�,�,�,�,�,�,�,rc��B�K�t������d{V��Sr�rr>s�r�native_coroutine_with_adapterzKAsyncIOLoopTest.test_asyncio_adapter.<locals>.native_coroutine_with_adapterQs1�����*�+<�+<�+>�+>�?�?�?�?�?�?�?�?�?rc��B�K�t������d{V��SrrA)r?s�r�native_coroutine_with_adapter2zLAsyncIOLoopTest.test_asyncio_adapter.<locals>.native_coroutine_with_adapter2Us1�����*�+K�+K�+M�+M�N�N�N�N�N�N�N�N�Nrr')	rr5r-r�run_syncrrr�set_event_loop)rrBrDr?r<s   @@r�test_asyncio_adapterz$AsyncIOLoopTest.test_asyncio_adapterDs�����


��	!�	!�
��	!�	-�	-�	-�	-�	-�	@�	@�	@�	@�	@�	O�	O�	O�	O�	O�	
�����.�.�/O�P�P�RT�U�U�U������.�.�/L�M�M�r�R�R�R������.�.�/M�N�N�PR�S�S�S�	
�����0�0�1Q�1Q�1S�1S�T�T��	
�	
�	
�	
�����0�0�1N�1N�1P�1P�Q�Q��	
�	
�	
�	
�����0�0�1O�1O�1Q�1Q�R�R��	
�	
�	
�	��t�$�$�$�$�$rN)	�__name__�
__module__�__qualname__rr!r
r/r7rGr(rrrrsw�������������
 �
 ��X�
 ��%�%��X�%�)%�)%�)%�)%�)%rrc�&�eZdZd�Zd�Zd�Zd�ZdS)�LeakTestc���td������tj��|_tjtj����dSr)r�closer�get_event_loop_policy�orig_policy�set_event_loop_policy�DefaultEventLoopPolicyrs r�setUpzLeakTest.setUpqsR����'�'�'�-�-�/�/�/�#�8�:�:����%�g�&D�&F�&F�G�G�G�G�Grc��tj��������tj|j��dSr)rrOrrNrQrPrs r�tearDownzLeakTest.tearDownysC���%�'�'�6�6�8�8�>�>�@�@�@��%�d�&6�7�7�7�7�7rc��ttj��}td��D]i}t	j��5t	jdt��t��}|�	��ddd��n#1swxYwY�jttj��|z
}|�
|d��dS)N�
�ignorer)�lenr�_ioloop_for_asyncio�range�warnings�catch_warnings�simplefilter�DeprecationWarningrrNr-�r�
orig_count�i�loop�	new_counts     r�test_ioloop_close_leakzLeakTest.test_ioloop_close_leak}s�����3�4�4�
��r���	�	�A��(�*�*�
�
��%�h�0B�C�C�C�"�}�}���
�
����
�
�
�
�
�
�
�
�
�
�
����
�
�
�
����2�3�3�j�@�	�����A�&�&�&�&�&s�=B�B	�B	c��ttj��}td��D]v}t	j��}|�tj��|�|j��|�	��|�
���wttj��|z
}|�|d��dS)NrW�)rYrrZr[r�new_event_loopr�currentr�run_foreverrNr-r`s     r�test_asyncio_close_leakz LeakTest.test_asyncio_close_leak�s�����3�4�4�
��r���	�	�A��)�+�+�D��N�N�6�>�*�*�*��N�N�4�9�%�%�%��������J�J�L�L�L�L���2�3�3�j�@�	�	
����A�&�&�&�&�&rN)rHrIrJrSrUrerkr(rrrLrLpsS������H�H�H�8�8�8�	'�	'�	'�'�'�'�'�'rrLc�2�eZdZd�Zd�Zd�Zd�Zd�Zd�ZdS)�AnyThreadEventLoopPolicyTestc�^�tj��|_td��|_dS)Nrg)rrOrPr�executorrs rrSz"AnyThreadEventLoopPolicyTest.setUp�s&��"�8�:�:���*�1�-�-��
�
�
rc�j�tj|j��|j���dSr)rrQrPro�shutdownrs rrUz%AnyThreadEventLoopPolicyTest.tearDown�s0���%�d�&6�7�7�7��
��� � � � � rc�d�d�}|j�|��}|���S)Nc�T�tj��}|���|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.
            �rrrN)rcs r�get_and_close_event_loopzWAnyThreadEventLoopPolicyTest.get_event_loop_on_thread.<locals>.get_and_close_event_loop�s$���)�+�+�D��J�J�L�L�L��Kr)ro�submitr6)rru�futures   r�get_event_loop_on_threadz5AnyThreadEventLoopPolicyTest.get_event_loop_on_thread�s7��
	�
	�
	���%�%�&>�?�?���}�}���rc�*�tj��5tjdt��|�t
tf|j�|��j	��tjt����|�
|j�|���	��|��|j�d����	��ddd��dS#1swxYwYdS)NrXc�L�tj�����Srrtr(rrr)z>AnyThreadEventLoopPolicyTest.run_policy_test.<locals>.<lambda>�s���)?�)A�)A�)G�)G�)I�)I�r)r\r]r^r_�assertRaises�RuntimeError�AssertionErrorrorvr6rrQr�assertIsInstance)r�accessor�
expected_types   r�run_policy_testz,AnyThreadEventLoopPolicyTest.run_policy_test�sO��
�
$�
&�
&�	T�	T��!�(�,>�?�?�?�
����~�.��
�0D�0D�X�0N�0N�0U�
�
�
�
�)�*B�*D�*D�E�E�E��!�!��
�$�$�X�.�.�5�5�7�7��
�
�
�

�M� � �!I�!I�J�J�Q�Q�S�S�S�	T�	T�	T�	T�	T�	T�	T�	T�	T�	T�	T�	T����	T�	T�	T�	T�	T�	Ts�C'D�D�Dc�Z�|�tjtj��dSr)r�rr�AbstractEventLooprs r�test_asyncio_accessorz2AnyThreadEventLoopPolicyTest.test_asyncio_accessor�s$�����W�3�W�5N�O�O�O�O�Orc�P�|�tjt��dSr)r�rrirs r�test_tornado_accessorz2AnyThreadEventLoopPolicyTest.test_tornado_accessor�s �����V�^�V�4�4�4�4�4rN)	rHrIrJrSrUrxr�r�r�r(rrrmrm�st������.�.�.�!�!�!���� T�T�T�"P�P�P�5�5�5�5�5rrm)r�unittestr\�concurrent.futuresr�tornador�tornado.ioloopr�tornado.platform.asynciorrr�tornado.testingr	r
r�TestCaserLrmr(rr�<module>r�s<��������������1�1�1�1�1�1�������!�!�!�!�!�!�����������
4�3�3�3�3�3�3�3�Q%�Q%�Q%�Q%�Q%�m�Q%�Q%�Q%�h$'�$'�$'�$'�$'�x� �$'�$'�$'�N.5�.5�.5�.5�.5�8�#4�.5�.5�.5�.5�.5r

Youez - 2016 - github.com/yon3zu
LinuXploit