| 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 : |
�
��brB � �, � d dl Z d dlmZ d dlZd dlZd dlmZmZ d dlm Z d dl
mZmZ G d� de� � Z
G d� d e� � Z G d
� de� � Z G d� d
e� � Z G d� de� � Z G d� de� � Zedk r ej � � dS dS )� N)� timedelta)�gen�locks)�TimeoutError)�gen_test�
AsyncTestCasec �� � � e Zd Z� fd�Zd� Zd� Zd� Zed� � � Zd� Z d� Z
d� Zed � � � Zed
� � � Z
ed� � � Zed� � � Zed
� � � Zed� � � Z� xZS )�
ConditionTestc �V �� t � � � � � g | _ d S �N)�super�setUp�history)�self� __class__s ��9/usr/lib/python3/dist-packages/tornado/test/locks_test.pyr zConditionTest.setUp s �� �
���
�
��������� c �D � ��� ��� fd�}�� |� � dS )z=Record the resolution of a Future returned by Condition.wait.c � �� �� � � s�j � d� � d S �j � �� � d S )N�timeout)�resultr �append)�_�future�keyr s ���r �callbackz+ConditionTest.record_done.<locals>.callback sK �� ��=�=�?�?�
)���#�#�I�.�.�.�.�.���#�#�C�(�(�(�(�(r N)�add_done_callback)r r r r s ``` r �record_donezConditionTest.record_done sD ���� � )� )� )� )� )� )� )� � � ��*�*�*�*�*r c �l � | j � | j � � | � � � dS )z�Run all queued callbacks on the IOLoop.
In these tests, this method is used after calling notify() to
preserve the pre-5.0 behavior in which callbacks ran
synchronously.
N)�io_loop�add_callback�stop�wait�r s r �loop_brieflyzConditionTest.loop_briefly( s- � �
��!�!�$�)�,�,�,�� � �����r c �& � t j � � }| � dt |� � � � | � dt |� � � � |� � � | � dt |� � � � d S )N� Condition�waiters)r r'