Viewing File: /opt/alt/python312/lib64/python3.12/asyncio/__pycache__/staggered.cpython-312.opt-2.pyc
�
=��i� � �N � d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ dd�d �Zy)
)�staggered_race� N� )�events)�
exceptions)�locks)�tasks)�loopc
� �v ���� �
� � �
���K � �xs t j � �t | � �d �d �g �g � t � � d �
�
� �fd��
d��� �� � �
��f d� � d } t j
� }�j
� |d � � }� j |� |j �
� |j � d }� r �j � �
�
� d { ��� d �
� r� |�|���� f� ~�S 7 �# t j $ r,}|}� D ] } |j |j � � Y d }~�Nd }~ww xY w# � ~�w xY w�w)Nc �� �� �j | � ��#�j � s�s�j d � | j � ry | j � }|�y �j |� y �N)�discard�done�
set_result� cancelled� exception�append)�task�exc�on_completed_fut�
running_tasks�unhandled_exceptionss ����8/opt/alt/python312/lib64/python3.12/asyncio/staggered.py� task_donez!staggered_race.<locals>.task_doneJ sc �� �� � �d�#� � (�$�)�)�+�!� � '� '�� -� �>�>� � ��n�n� �� �;� � �#�#�C�(� c � �X � K � | j � � d { ��� |�Xt j t j � 5 t j |j � � � � d { ��� d d d � t � � \ }}t j � }t j � }�j �||� � }�j |� |j �� |j � �
j d � |� � d { ��� }|�|�t j �� }�D ] } | |us�| j# � � y 7 ��77 ��# 1 sw Y ��xY w# t $ r Y y w xY w7 �Z# t$ t& f$ r � t( $ r }
|
�
|< |j � Y d }
~
y d }
~
ww xY w�wr )�wait�
contextlib�suppress�exceptions_mod� TimeoutErrorr �wait_for�next�
StopIterationr �Event� create_task�add�add_done_callback�setr � current_task�cancel�
SystemExit�KeyboardInterrupt�
BaseException)� ok_to_start�previous_failed�
this_index�coro_fn� this_failed�next_ok_to_start� next_task�resultr) �t�e�delay�
enum_coro_fnsr r � run_one_coror r � winner_index�
winner_results ���������r r: z$staggered_race.<locals>.run_one_coro[ s� �� �� � � � � � � � � &��$�$�^�%@�%@�A�
�n�n�_�%9�%9�%;�U�C�C�C� B� �"&�}�"5� �J�� �k�k�m� � �;�;�=���$�$�\�2B�K�%P�Q� ����)�$��#�#�I�.� � � � ����$� � �"�9�_�F� &�L� "�M� !�-�-�d�3�L�"���L�(��H�H�J� #�a !�� D�� B�A�� � � � �� %��� -�.� � � � �%&�J�z� "� �O�O� � �� �s� �F*�E�)F*�(E�)E�*E�.F*�7E �BF*�
E0 �E.�E0 �"F*�;F*�E�E �F*� E+�(F*�*E+�+F*�.E0 �0F'�F"� F*�"F'�'F*)�returnN)r �get_running_loop� enumerater( r r$ r% r& r' �
create_futurer �CancelledErrorr* �args�ExceptionGroup)�coro_fnsr8 r � propagate_cancellation_errorr. �
first_task�exr r9 r r r: r r r r; r< s `` @@@@@@@@@r r r
sV ��� �� �1�f � ,�6�*�*�,�D� �h�'�M��M��L� ���J��E�M���)�"6 � 6 �p $(� �K��k�k�m� ��%�%�l�;��&E�F�
����*�%��$�$�Y�/�����'+�$�� #� 1� 1� 3� �
*�&�&�&�
$� � � � (� 3�.� .� �l�J�6� �4�6J� '��!�0�0�
*�/1�,� )�D� �D�K�K����)� *��
*��
�4�6J�sa �AD9� A2D1 �C/ �C-�C/ �D1 � D1 �)D9�-C/ �/D.�"D)�$D1 �)D.�.D1 �1D6�6D9) �__all__r � r r r r r r � r r �<module>rK s( �� L�
�� � � *� � � 37� aKr
Back to Directory
File Manager