Server : LiteSpeed System : Linux premium84.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64 User : claqxcrl ( 523) PHP Version : 8.1.32 Disable Function : NONE Directory : /opt/alt/python312/lib64/python3.12/asyncio/__pycache__/ |
�
�� h> � � � d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddlm
Z
ddlm Z G d � d
ej � Z
G d � d � Zddd
�d�Zd� Zy))�Runner�run� N� )�
coroutines)�events)�
exceptions)�tasks)� constantsc � � e Zd ZdZdZdZy)�_State�created� initialized�closedN)�__name__�
__module__� __qualname__�CREATED� INITIALIZED�CLOSED� � �6/opt/alt/python312/lib64/python3.12/asyncio/runners.pyr r s � ��G� �K�
�Fr r c �L � e Zd Z ddd�d�Zd� Zd� Zd� Zd� Zdd�d �Zd
� Z d � Z
y) r N��debug� loop_factoryc � � t j | _ || _ || _ d | _ d | _ d| _ d| _ y )Nr F) r r �_state�_debug�
_loop_factory�_loop�_context�_interrupt_count�_set_event_loop)�selfr r s r �__init__zRunner.__init__0 s: � � �n�n�� ��� � )�����
� ��
� !�� � $�� r c �& � | j � | S �N)�
_lazy_init�r% s r � __enter__zRunner.__enter__9 s � � ����� r c �$ � | j � y r( )�close)r% �exc_type�exc_val�exc_tbs r �__exit__zRunner.__exit__= s � � �
�
� r c �H � | j t j ury | j }t |� |j |j
� � |j |j t j � � | j rt j d � |j � d | _ t j | _ y # | j rt j d � j � d | _ t j | _ w xY wr( )r r r r! �_cancel_all_tasks�run_until_complete�shutdown_asyncgens�shutdown_default_executorr
�THREAD_JOIN_TIMEOUTr$ r �set_event_loopr- r )r% �loops r r- z Runner.close@ s� � �,� �;�;�f� 0� 0� 0� � (��:�:�D� �d� #� � #� #�D�$;�$;�$=� >� � #� #��.�.�y�/L�/L�M�
O� �#�#��%�%�d�+� �J�J�L� �D�J� �-�-�D�K�� �#�#��%�%�d�+� �J�J�L� �D�J� �-�-�D�K�s
�A$C �AD!c �< � | j � | j S r( )r) r! r* s r �get_loopzRunner.get_loopQ s � �)� �����z�z�r ��contextc �� � t j |� st dj |� � �t j
� � t
d� �| j � |� | j }| j j ||�� }t j � t j � u rzt j t j � t j" u rGt% j& | j( |�� } t j t j |� nd }d| _ | j j- |� |�Yt j t j � |u r3t j t j t j" � S S S # t $ r d }Y ��w xY w# t. j0 $ r4 | j* dkD r#t3 |dd � }|� |� dk( r
t5 � �� w xY w# |�Yt j t j � |u r3t j t j t j" � w w w xY w)Nz"a coroutine was expected, got {!r}z7Runner.run() cannot be called from a running event loopr< )� main_taskr �uncancel)r � iscoroutine�
ValueError�formatr �_get_running_loop� RuntimeErrorr) r" r! � create_task� threading�current_thread� main_thread�signal� getsignal�SIGINT�default_int_handler� functools�partial�
_on_sigintr# r4 r �CancelledError�getattr�KeyboardInterrupt)r% �coror= �task�sigint_handlerr@ s r r z
Runner.runV s� � �=��%�%�d�+� � A� H� H�� N�O� O� � #� #� %� 1� �I�K�
K�
���� �?��m�m�G��z�z�%�%�d�G�%�<�� � $� $� &�)�*?�*?�*A� A�� � �� � �/�6�3M�3M�M� &� .� .�t���$� O�N�
&��
�
�f�m�m�^�<� "�N� !�� � I��:�:�0�0��6� �*��$�$�V�]�]�3�~�E��
�
�f�m�m�V�-G�-G�H� F� +��% �
&� "&��
&�� �(�(� ��$�$�q�(�"�4��T�:���'�H�J�!�O�+�-�-� � �� �*��$�$�V�]�]�3�~�E��
�
�f�m�m�V�-G�-G�H� F� +�s, �$F- �7F> �- F;�:F;�>AH�H �A I%c �$ � | j t j u r t d� �| j t j u ry | j
�Lt
j � | _ | j s<t
j | j � d| _ n| j � | _ | j �%| j j | j � t j � | _ t j | _ y )NzRunner is closedT)r r r rE r r r �new_event_loopr! r$ r8 r � set_debug� contextvars� copy_contextr" r* s r r) zRunner._lazy_init� s� � � �;�;�&�-�-� '� � 1�2� 2� �;�;�&�,�,� ,� � � � � %� �.�.�0�D�J��'�'� �%�%�d�j�j�1�'+��$� �+�+�-�D�J� �;�;� "� �J�J� � ���� -�#�0�0�2��
� �(�(�� r c �� � | xj dz
c_ | j dk( r=|j � s-|j � | j j d� � y t � �)Nr c � � y r( r r r r �<lambda>z#Runner._on_sigint.<locals>.<lambda>� s � �Dr )r# �done�cancelr! �call_soon_threadsaferS )r% �signum�framer? s r rP zRunner._on_sigint� sT � � � � ��"� � � � �A� %�i�n�n�.>� � � � � �J�J� +� +�L� 9� � �!�!r ) r r r r& r+ r1 r- r; r r) rP r r r r r s= � ��6 !%�4� %���(�"�
$(� +I�Z)�&"r r r c � � t j � � t d� �t ||�� 5 }|j | � cd d d � S # 1 sw Y y xY w)Nz8asyncio.run() cannot be called from a running event loopr )r rD rE r r )�mainr r �runners r r r � sP � ��8 � � �!�-�� F�H� H�
�e�,� 7�6��z�z�$� �
8� 7� 7�s �A � Ac �B � t j | � }|sy |D ] }|j � � | j t j |ddi�� |D ]G }|j � r�|j
� ��%| j d|j
� |d�� �I y )N�return_exceptionsTz1unhandled exception during asyncio.run() shutdown)�message� exceptionrU )r � all_tasksr` r4 �gather� cancelledrj �call_exception_handler)r9 � to_cancelrU s r r3 r3 � s� � �����%�I� ���� � � �
� � ���E�L�L�)� L�t� L�M��� �>�>� � � �>�>� � '� � '� '�N� !�^�^� -� �)�
� r )�__all__rZ �enumrN rG rJ � r r r r r
�Enumr r r r3 r r r �<module>rt sW ��
�� � � � �
� � � � � ��T�Y�Y� � I"� I"�X �$� # �Lr