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

��b�6��L�ddlZddlmZddlmZddlZddlmZmZddlm	Z	ddl
mZmZGd�de��Z
Gd	�d
e��ZGd�de��ZGd
�de��ZGd�de��ZGd�de��ZGd�de��Zedkrej��dSdS)�N)�	timedelta)�random)�gen�queues)�TimeoutError)�gen_test�
AsyncTestCasec�0�eZdZd�Zd�Zed���ZdS)�QueueBasicTestc���tjd���}|�tt	|����t|����|�tt	|����t|����|���t|��t|��fD]�}|�	|�
d����|�d|��|�d|��|�d|��|�d|����|�d��|�d��|�d��t|��t|��fD]D}|�d|��|�d	|��|�d
|���EdS)N���maxsizez<Queuez	maxsize=1z
getters[1]�putters�tasks�gettersz
putters[1]ztasks=2)r�Queue�assertIn�hex�id�repr�assertNotIn�str�get�
assertTrue�
startswith�put)�self�q�q_strs   �:/usr/lib/python3/dist-packages/tornado/test/queues_test.py�test_repr_and_strz QueueBasicTest.test_repr_and_strs����L��#�#�#���
�
�c�"�Q�%�%�j�j�$�q�'�'�*�*�*�����R��U�U���S��V�V�,�,�,�	�������!�W�W�c�!�f�f�_�	-�	-�E��O�O�E�,�,�X�6�6�7�7�7��M�M�+�u�-�-�-��M�M�,��.�.�.����Y��.�.�.����W�e�,�,�,�,�	���d����	���d����	���d�����!�W�W�c�!�f�f�_�	,�	,�E����Y��.�.�.��M�M�,��.�.�.��M�M�)�U�+�+�+�+�	,�	,�c����tj���dD]}��|����fd�td��D��}|�gd�|��dS)N)r
��c�8��g|]}������S�)�
get_nowait��.0�_rs  �r!�
<listcomp>z-QueueBasicTest.test_order.<locals>.<listcomp>4s!���2�2�2�A������2�2�2r#r%)rr�
put_nowait�range�assertEqual)r�i�itemsrs   @r!�
test_orderzQueueBasicTest.test_order/sm����L�N�N���	�	�A�
�L�L��O�O�O�O�2�2�2�2��q���2�2�2��������E�*�*�*�*�*r#c#��K�|�ttjd���|�ttjd���tjd���}|�|�����|�|�����|�	d|j
��|�|�d�������|�|�d�������|�|�����|�|�����|�d��}|�|�����|�	d|�
��V���|�|�����|�|�����|�|�����dS)Nr���r&rr
)�assertRaises�	TypeErrorrr�
ValueErrorr�empty�assertFalse�fullr0rr�doner)rr�put2s   r!�test_maxsizezQueueBasicTest.test_maxsize7s��������)�V�\�4��@�@�@����*�f�l�B��?�?�?��L��#�#�#��������	�	�"�"�"���������"�"�"�����A�I�&�&�&�������a���
�
���(�(�(�������a���
�
���(�(�(���������#�#�#���������!�!�!��u�u�Q�x�x����������%�%�%�����1�5�5�7�7�]�]�,�,�,�����	�	���$�$�$���������#�#�#���������!�!�!�!�!r#N)�__name__�
__module__�__qualname__r"r3rr>r(r#r!rrsM������,�,�,�.+�+�+��"�"��X�"�"�"r#rc���eZdZed���Zd�Zd�Zed���Zed���Zed���Z	ed���Z
ed���Zed	���Zed
���Z
dS)�QueueGetTestc#�K�tj��}|�d��|�d|���V���dS�Nr)rrr.r0r�rrs  r!�test_blocking_getzQueueGetTest.test_blocking_getMsH�����L�N�N��	���Q��������1�5�5�7�7�]�]�,�,�,�,�,r#c��tj��}|�d��|�d|�����dSrE)rrr.r0r)rFs  r!�test_nonblocking_getz!QueueGetTest.test_nonblocking_getSs@���L�N�N��	���Q��������A�L�L�N�N�+�+�+�+�+r#c�v�tj��}|�tj|j��dS�N)rrr6�
QueueEmptyr)rFs  r!�test_nonblocking_get_exceptionz+QueueGetTest.test_nonblocking_get_exceptionXs.���L�N�N�����&�+�Q�\�:�:�:�:�:r#c#�K�tjd��}|�d��|�d��}|�d|���V���|�|V���dS�Nr
r)rrr.rr0r�assertIsNone�rrrs   r!�test_get_with_puttersz"QueueGetTest.test_get_with_putters\sq�����L��O�O��	���Q�����e�e�A�h�h������1�5�5�7�7�]�]�,�,�,�����9�9�&�&�&�&�&r#c#��K�tj��}|�d��|j�d|jd��|j�d|jd��|�d|�td������V���|�d|�td������V���dS)Nr�{�G�z�?r
�{�G�z�?r&��seconds��timeout)	rrr�io_loop�
call_laterr.r0rrrFs  r!�test_blocking_get_waitz#QueueGetTest.test_blocking_get_waitds������L�N�N��	���a���������a�l�A�6�6�6������a�l�A�6�6�6�����1�5�5��1�1E�1E�1E�5�#F�#F�F�F�H�H�H�����1�5�5��1�1E�1E�1E�5�#F�#F�F�F�H�H�H�H�Hr#c#�fK�tj��}|�td������}|���}|�t
��5|V�ddd��n#1swxYwY|�d��|�d|V���dS)NrTrVrXr)rrrrr6rr.r0)rr�get_timeoutrs    r!�test_get_timeoutzQueueGetTest.test_get_timeoutms������L�N�N���e�e�I�d�$;�$;�$;�e�<�<���e�e�g�g��
�
�
�|�
,�
,�	�	�����	�	�	�	�	�	�	�	�	�	�	����	�	�	�	�	
���Q��������3�Y�Y�(�(�(�(�(s�(A9�9A=�A=c#�K�tj��}|�td������}|�d��tjd��V�|�d|V���dS)NrTrVrXrrU)rrrrrr�sleepr0)rrrs   r!�test_get_timeout_preemptedz'QueueGetTest.test_get_timeout_preemptedxsr�����L�N�N���e�e�I�d�3�3�3�e�4�4��	���a�����i��o�o��������3�Y�Y�(�(�(�(�(r#c#���K�tjd����fd�td��D��}��d��}|�dt�j����tjd��V�|�dt�j����|�	|�
������d��|�d����V���|�dt�j����|dd�D]"}|�t|j���#dS)Nr
c�X��g|]&}��|td�������'S�rTrV�rr�r+r1rs  �r!r-zBQueueGetTest.test_get_clears_timed_out_putters.<locals>.<listcomp>��2���H�H�H��1�5�5��I�d�3�3�3�4�4�H�H�Hr#�
rU�r)rrr/rr0�len�_puttersrrar:r<rr6r�result�rrr�putterrs    @r!�!test_get_clears_timed_out_puttersz.QueueGetTest.test_get_clears_timed_out_putters�s9������L��O�O��H�H�H�H�e�B�i�i�H�H�H���e�e�B�i�i������S���_�_�-�-�-��i��o�o��������S���_�_�-�-�-���������$�$�$�	���b�	�	�	�����1�5�5�7�7�]�]�,�,�,�����C��
�O�O�,�,�,��a�b�b�k�	;�	;�F����l�F�M�:�:�:�:�	;�	;r#c#��K�tj����fd�td��D��}tj������}|�dt�j����tj
d��V�|�dt�j����|�|���������|�dt�j����|D]"}|�
t|j���#dS)Nc	�z��g|]7}tj��td���������8Sre��asyncio�
ensure_futurerrr*s  �r!r-zBQueueGetTest.test_get_clears_timed_out_getters.<locals>.<listcomp>��H���
�
�
�FG�G�!�!�%�%�	�$�(?�(?�(?�"@�"@�A�A�
�
�
r#rirjrUr&)rrr/rtrurr0rk�_gettersrrar:r<r6rrm�rrr�getterrs    @r!�!test_get_clears_timed_out_gettersz.QueueGetTest.test_get_clears_timed_out_getters�s&������L�N�N��
�
�
�
�KP�QS�9�9�
�
�
���#�A�E�E�G�G�,�,������S���_�_�-�-�-��i��o�o��������S���_�_�-�-�-���������$�$�$�	����������C��
�O�O�,�,�,��	;�	;�F����l�F�M�:�:�:�:�	;�	;r#c#��K�tj���td��D]}��|����fd�}|��V�}|�|ttd������dS)N�c��d�K�g}�23d{V��}|�|��|dkr|cS�'6dS)N�)�append)�resultsr1rs  �r!�fz&QueueGetTest.test_async_for.<locals>.f�sf������G��
#�
#�
#�
#�
#�
#�
#�a����q�!�!�!���6�6�"�N�N�N���1�1s�/)rrr/rr0�list)rr1r�r�rs    @r!�test_async_forzQueueGetTest.test_async_for�s�������L�N�N���q���	�	�A�
�E�E�!�H�H�H�H�	#�	#�	#�	#�	#�����)�)������$�u�Q�x�x�.�.�1�1�1�1�1r#N)r?r@rArrGrIrMrRr\r_rbrprzr�r(r#r!rCrCLs������
�-�-��X�-�
,�,�,�
;�;�;��'�'��X�'��I�I��X�I��)�)��X�)��)�)��X�)��
;�
;��X�
;��
;�
;��X�
;��
2�
2��X�
2�
2�
2r#rCc���eZdZed���Zd�Zed���Zed���Zed���Zed���Z	ed���Z
ed���Zed	���Zed
���Z
dS)�QueuePutTestc��tj��}|�d��|�d|�����dSrE)rrrr0r)rFs  r!�test_blocking_putzQueuePutTest.test_blocking_put�s@���L�N�N��	���a��������A�L�L�N�N�+�+�+�+�+r#c��tjd��}|�d��|�tj|jd��dSrO)rrrr6�	QueueFullr.rFs  r!�test_nonblocking_put_exceptionz+QueuePutTest.test_nonblocking_put_exception�sA���L��O�O��	���a�������&�*�A�L�!�<�<�<�<�<r#c#�<K�tj��}|���}|���}|�d��V�|�d|V���|�d��V�|�d|V���dS�Nrr
)rrrrr0�rr�get0�get1s    r!�test_put_with_gettersz"QueuePutTest.test_put_with_getters�s������L�N�N���u�u�w�w���u�u�w�w���e�e�A�h�h��������4�Z�Z�)�)�)��e�e�A�h�h��������4�Z�Z�)�)�)�)�)r#c#�lK�tj��}|���}|���}|�d��tjV�|�d|V���|�d��tjV�|�d|V���dSr�)rrrr.r�momentr0r�s    r!�!test_nonblocking_put_with_gettersz.QueuePutTest.test_nonblocking_put_with_getters�s������L�N�N���u�u�w�w���u�u�w�w��	���Q�����j��������4�Z�Z�)�)�)�	���Q�����j��������4�Z�Z�)�)�)�)�)r#c#��K�tjd�����d���fd�}|j�d|��|j�d|����d����d��g}|�td�|D������|V�dS)Nr
rc�0������dSrK)r)rs�r!�get_and_discardz<QueuePutTest.test_blocking_put_wait.<locals>.get_and_discard�s���
�E�E�G�G�G�G�Gr#rTrUc3�>K�|]}|���V��dSrK)r<)r+r�s  r!�	<genexpr>z6QueuePutTest.test_blocking_put_wait.<locals>.<genexpr>�s*����7�7�!�Q�V�V�X�X�7�7�7�7�7�7r#)rrr.rZr[rr:�any)rr��futuresrs   @r!�test_blocking_put_waitz#QueuePutTest.test_blocking_put_wait�s�������L��O�O��	���Q����	�	�	�	�	�	
�����o�6�6�6������o�6�6�6��5�5��8�8�Q�U�U�1�X�X�&������7�7�w�7�7�7�7�7�8�8�8��
�
�
�
�
r#c#��K�tjd��}|�d��|�dt	d������}|�d��}|�t��5|V�ddd��n#1swxYwY|�d|�����|�d|�	��V���|V�dS)Nr
rrTrVrXr&)
rrr.rrr6rr0r)r)rr�put_timeoutrs    r!�test_put_timeoutzQueuePutTest.test_put_timeout�s�����L��O�O��	���Q�����e�e�A�y��'>�'>�'>�e�?�?���e�e�A�h�h��
�
�
�|�
,�
,�	�	�����	�	�	�	�	�	�	�	�	�	�	����	�	�	�	�	
����A�L�L�N�N�+�+�+�����1�5�5�7�7�]�]�,�,�,��	�	�	�	�	s�B�B�Bc#�K�tjd��}|�d��|�dt	d������}|���t
jd��V�|V�dS)Nr
rrTrVrXrU)rrr.rrrrrarQs   r!�test_put_timeout_preemptedz'QueuePutTest.test_put_timeout_preempted�sp�����L��O�O��	���Q�����e�e�A�y��6�6�6�e�7�7��	�������i��o�o�����	�	�	�	�	r#c#��K�tjd����fd�td��D��}��d��}|�dt�j����tjd��V�|�dt�j����|�	|�
������d��|�dt�j����|dd�D]"}|�t|j
���#dS)Nr
c�X��g|]&}��|td�������'Srerfrgs  �r!r-zBQueuePutTest.test_put_clears_timed_out_putters.<locals>.<listcomp>�rhr#rirUrjr&)rrr/rr0rkrlrrar:r<r6rrmrns    @r!�!test_put_clears_timed_out_puttersz.QueuePutTest.test_put_clears_timed_out_putters�s������L��O�O��H�H�H�H�e�B�i�i�H�H�H���e�e�B�i�i������S���_�_�-�-�-��i��o�o��������S���_�_�-�-�-���������$�$�$�	���b�	�	�	�����C��
�O�O�,�,�,��a�b�b�k�	;�	;�F����l�F�M�:�:�:�:�	;�	;r#c#���K�tj����fd�td��D��}tj������}����|�dt�j����tj
d��V�|�dt�j����|�|�������
d��|�dt�j����|�d|V���|D]"}|�t|j���#dS)Nc	�z��g|]7}tj��td���������8Srersr*s  �r!r-zBQueuePutTest.test_put_clears_timed_out_getters.<locals>.<listcomp>
rvr#ri�rUrr
)rrr/rtrurr0rkrwrrar:r<rr6rrmrxs    @r!�!test_put_clears_timed_out_gettersz.QueuePutTest.test_put_clears_timed_out_getters
sO������L�N�N��
�
�
�
�KP�QS�9�9�
�
�
���#�A�E�E�G�G�,�,��	����������S���_�_�-�-�-��i��o�o��������S���_�_�-�-�-���������$�$�$�	���a��������C��
�O�O�,�,�,�����3�Y�Y�(�(�(��	;�	;�F����l�F�M�:�:�:�:�	;�	;r#c#�HK�tjd���}|�|�����|�|�����|�d��|�d��|�|�����|�|�����|�tj|jd��|�	d|�
����|�|�����|�|�����|�d��V�|�d��}|�|�����|�	d|�
��V���|V�|�|�����dS)Ng�������?rrr
r&r%)rrrr9r:r;r.r6r�r0r)rr<rrQs   r!�test_float_maxsizezQueuePutTest.test_float_maxsizes�����
�L��%�%�%��������	�	�"�"�"���������"�"�"�	���Q����	���Q������������#�#�#���������!�!�!����&�*�A�L�!�<�<�<�����A�L�L�N�N�+�+�+���������#�#�#���������"�"�"��e�e�A�h�h�����e�e�A�h�h����������$�$�$�����1�5�5�7�7�]�]�,�,�,��	�	�	���������!�!�!�!�!r#N)r?r@rArr�r�r�r�r�r�r�r�r�r�r(r#r!r�r��s������
�,�,��X�,�
=�=�=�
�*�*��X�*��
*�
*��X�
*�����X���
�
��X�
�����X���;�;��X�;��;�;��X�;�"�"�"��X�"�"�"r#r�c�z�eZdZejZd�Zed���Zed���Z	ed���Z
ed���ZdS)�
QueueJoinTestc�n�|���}|�t|j��dSrK)�queue_classr6r8�	task_donerFs  r!�test_task_done_underflowz&QueueJoinTest.test_task_done_underflow9s1�����������*�a�k�2�2�2�2�2r#c#���K������td��D]}��|���d�_tj��fd���}|��|������V���ttd�����j��dS)N�drc3���K�	����V�}�xj|z
c_����tjt��dz��V��`)NTrT)r�accumulatorr�rrar)�itemrrs ��r!�workerz,QueueJoinTest.test_task_done.<locals>.workerEsa�����
1��U�U�W�W�}�}��� � �D�(� � ����
�
�
��i����4��0�0�0�0�0�	
1r#)	r�r/r.r�r�	coroutine�joinr0�sum)rr1r�rs`  @r!�test_task_donezQueueJoinTest.test_task_done=s��������������s���	�	�A�
�L�L��O�O�O�O����	��	1�	1�	1�	1�	1�
��	1�	�����������f�f�h�h��������U�3�Z�Z���$�*:�;�;�;�;�;r#c#�PK�|���}|�d��tj|�����}|�|�����|���V�|�|�����tj	V�|�|�����|�
��|�|�����dSrE)r�r.rtrur�r:r<rrr�r�r)rrr�s   r!�test_task_done_delayz"QueueJoinTest.test_task_done_delaySs�����
������	���Q�����$�Q�V�V�X�X�.�.����������%�%�%��e�e�g�g�
�
�
���������%�%�%��j������������%�%�%�	���
�
�
�����	�	���$�$�$�$�$r#c#�K�|���}|���V�|���V�dSrK)r�r�rFs  r!�test_join_empty_queuez#QueueJoinTest.test_join_empty_queueas=�����������f�f�h�h�����f�f�h�h�����r#c#�K�|���}|�d��|�t��5|�td������V�ddd��dS#1swxYwYdS)NrrTrVrX)r�rr6rr�rrFs  r!�test_join_timeoutzQueueJoinTest.test_join_timeoutgs�����������	���a����
�
�
�|�
,�
,�	:�	:��&�&��4�!8�!8�!8�&�9�9�9�9�9�	:�	:�	:�	:�	:�	:�	:�	:�	:�	:�	:�	:����	:�	:�	:�	:�	:�	:s�'A:�:A>�A>N)r?r@rArrr�r�rr�r�r�r�r(r#r!r�r�6s��������,�K�3�3�3��<�<��X�<�*�%�%��X�%�����X��
�:�:��X�:�:�:r#r�c�2�eZdZejZed���ZdS)�PriorityQueueJoinTestc#��K�|�d���}|�d��|�d��|�|�����|�d��|�d��|�d|�����|�d|���V���|�d|�����|�d|���V���|�|�����dS)Nr&r)r
�a)r�b)r%�c)r&�d�	r�r.rr;rr0r)rr9rFs  r!r3z PriorityQueueJoinTest.test_orderrs�������Q��'�'��	���X����	���X������������!�!�!�	���h����	���h��������1�<�<�>�>�2�2�2�����!�%�%�'�'�M�M�3�3�3�����1�<�<�>�>�2�2�2�����!�%�%�'�'�M�M�3�3�3�������	�	�"�"�"�"�"r#N)r?r@rAr�
PriorityQueuer�rr3r(r#r!r�r�os5�������&�K�
�#�#��X�#�#�#r#r�c�2�eZdZejZed���ZdS)�LifoQueueJoinTestc#��K�|�d���}|�d��|�d��|�|�����|�d��|�d��|�d|�����|�d|���V���|�d|�����|�d|���V���|�|�����dS)Nr&rr
rr%r�rFs  r!r3zLifoQueueJoinTest.test_order�s�������Q��'�'��	���Q����	���Q������������!�!�!�	���a����	���a��������A�L�L�N�N�+�+�+�����1�5�5�7�7�]�]�,�,�,�����A�L�L�N�N�+�+�+�����1�5�5�7�7�]�]�,�,�,�������	�	�"�"�"�"�"r#N)r?r@rAr�	LifoQueuer�rr3r(r#r!r�r��s5�������"�K�
�#�#��X�#�#�#r#r�c�$�eZdZed���ZdS)�ProducerConsumerTestc#�R��K�tjd����g�tj��fd���}tj�fd���}|��|��V�����V�|�t
td�������dS)Nr%rc3��K�	������V��������>rK)rrr�)�historyrs��r!�consumerz=ProducerConsumerTest.test_producer_consumer.<locals>.consumer�s<�����
����a�e�e�g�g�
�
�/�/�/����
�
�
�
r#c3�^�K�td��D]}��|��V��dS)Nri)r/r)r�rs �r!�producerz=ProducerConsumerTest.test_producer_consumer.<locals>.producer�s?������b�	�	�
"�
"���e�e�D�k�k�!�!�!�!�
"�
"r#ri)rrrr�r�r0r�r/)rr�r�r�rs   @@r!�test_producer_consumerz+ProducerConsumerTest.test_producer_consumer�s��������L��#�#�#����

��	�	�	�	�	�
��	�


��	"�	"�	"�	"�
��	"�	��
�
�
��h�j�j�����f�f�h�h��������e�B�i�i���'�2�2�2�2�2r#N)r?r@rArr�r(r#r!r�r��s-������
�3�3��X�3�3�3r#r��__main__)rt�datetimerr�unittest�tornadorr�tornado.genr�tornado.testingrr	rrCr�r�r�r�r�r?�mainr(r#r!�<module>r�s�������������������������������$�$�$�$�$�$�3�3�3�3�3�3�3�3�2"�2"�2"�2"�2"�]�2"�2"�2"�jb2�b2�b2�b2�b2�=�b2�b2�b2�JB"�B"�B"�B"�B"�=�B"�B"�B"�J6:�6:�6:�6:�6:�M�6:�6:�6:�r#�#�#�#�#�M�#�#�#�$#�#�#�#�#�
�#�#�#�$3�3�3�3�3�=�3�3�3�6�z����H�M�O�O�O�O�O��r#

Youez - 2016 - github.com/yon3zu
LinuXploit