| Server IP : 43.141.49.107 / Your IP : 113.219.202.141 Web Server : Apache System : Linux VM-8-5-opencloudos 6.6.34-9.oc9.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jun 19 19:35:45 CST 2024 x86_64 User : www ( 1000) PHP Version : 8.1.27 Disable Function : passthru,exec,system,putenv,chroot,chgrp,chown,shell_exec,popen,proc_open,pcntl_exec,ini_alter,ini_restore,dl,openlog,syslog,readlink,symlink,popepassthru,pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,imap_open,apache_setenv MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.11/asyncio/__pycache__/ |
Upload File : |
�
��e
� �� � d dl Z d dlmZ d dlmZmZmZ ddlmZ ddlm Z ddlm
Z
dZ G d � d
e j � � Z
e G d � d � � � � Zd
ee defd�Zdee defd�ZdS )� N)�
TracebackType)�final�Optional�Type� )�events)�
exceptions)�tasks)�Timeout�timeout�
timeout_atc �" � e Zd ZdZdZdZdZdZdS )�_State�created�active�expiring�expired�finishedN)�__name__�
__module__� __qualname__�CREATED�ENTERED�EXPIRING�EXPIRED�EXITED� � �)/usr/lib64/python3.11/asyncio/timeouts.pyr r s' � � � � � ��G��G��H��G�
�F�F�Fr r c �� � e Zd Z dee ddfd�Zdee fd�Zdee ddfd�Zdefd�Z de
fd�Z dd �Z d
ee
e d ee d ee dee fd
�Zdd�ZdS )r �when�returnNc �T � t j | _ d | _ d | _ || _ d S �N)r r �_state�_timeout_handler�_task�_when)�selfr! s r �__init__zTimeout.__init__! s, � � � �n�� �>B�� �+/��
���
�
�
r c � � | j S r$ )r( �r) s r r! z Timeout.when. s
� �*��z�r c � � | j t j ur t d| j j � d�� � �|| _ | j �| j � � � |� d | _ d S t j � � }||�
� � k r!|� | j � � | _ d S |�
|| j � � | _ d S )NzCannot change state of z Timeout)r% r r � RuntimeError�valuer( r& �cancelr �get_running_loop�time� call_soon� _on_timeout�call_at)r) r! �loops r �
reschedulezTimeout.reschedule2 s� � �%� �;�f�n� ,� ,� �E�$�+�*;�E�E�E�� �
� ��
� � � ,� � !� (� (� *� *� *� �<�$(�D� !� !� !��*�,�,�D��t�y�y�{�{�"�"�(,���t�7G�(H�(H��%�%�%�(,� � �T�4�;K�(L�(L��%�%�%r c �B � | j t j t j fv S r$ )r% r r r r, s r r zTimeout.expiredH s � �2��{�v���� ?�?�?r c �� � dg}| j t j u r6| j �t | j d� � nd }|� d|� �� � d� |� � }d| j j � d|� d�S )N� � zwhen=� z
<Timeout [�]�>)r% r r r( �round�append�joinr/ )r) �infor! �info_strs r �__repr__zTimeout.__repr__L sz � ��t�� �;�&�.� (� (�+/�:�+A�5���Q�'�'�'�t�D� �K�K����� '� '� '��8�8�D�>�>��;�D�K� -�;�;��;�;�;�;r c � � K � t j | _ t j � � | _ | j � � � | _ | j �t d� � �| � | j
� � | S )Nz$Timeout should be used inside a task) r r r% r
� current_taskr' �
cancelling� _cancellingr. r7 r( r, s r �
__aenter__zTimeout.__aenter__T se � � � � �n�� ��'�)�)��
� �:�0�0�2�2��� �:� � � E�F�F� F� ����
�#�#�#�� r �exc_type�exc_val�exc_tbc � �Z K � | j � | j � � � d | _ | j t j u rJt j | _ | j � � � | j k r|t j
u rt |�n$| j t j u rt j
| _ d S r$ )r& r0 r% r r r r' �uncancelrH r �CancelledError� TimeoutErrorr r )r) rJ rK rL s r � __aexit__zTimeout.__aexit__] s� � � � � � � ,� � !� (� (� *� *� *�$(�D� !� �;�&�/� )� )� �.�D�K��z�"�"�$�$��(8�8�8�X��Ib�=b�=b� #��/��
�[�F�N�
*�
*� �-�D�K��tr c �h � | j � � � t j | _ d | _ d S r$ )r' r0 r r r% r& r, s r r4 zTimeout._on_timeoutu s- � � �
������ �o�� � $�� � � r )r" r )r" N)r r r r �floatr* r! r7 �boolr �strrD rI r �
BaseExceptionr rQ r4 r r r r r s? � � � � � ��
�X�e�_� �� � � � ��h�u�o� � � � �M�x��� M�4� M� M� M� M�,@�� @� @� @� @�<�#� <� <� <� <�� � � ���4�
�.�/�� �-�(�� � �'� �
�$� � � � � �0%� %� %� %� %� %r r �delayr" c �z � t j � � }t | �|� � � | z nd � � S r$ )r r1 r r2 )rW r6 s r r r } s< � �� � "� $� $�D� �%�*;�4�9�9�;�;��&�&�� F� F�Fr r! c �" � t | � � S r$ )r )r! s r r
r
� s � ��$ �4�=�=�r )�enum�typesr �typingr r r r: r r r
�__all__�Enumr r rS r r
r r r �<module>r_ s@ �� � � � � � � � � � � (� (� (� (� (� (� (� (� (� (� � � � � � � � � � � � � � � � � � � ��� � � � �T�Y� � � � �_%� _%� _%� _%� _%� _%� _%� ��_%�DG�8�E�?� G�w� G� G� G� G�(�X�e�_� �� � � � � � r