← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/filelock/__pycache__/_async.cpython-312.pyc
38 lines
�
c�bjY � �" � d Z ddlmZ ddlZddlZddlZddlmZ ddl m
Z
ddl m Z ddl
mZmZmZmZmZ er
ddlmZmZmZ ed � Z G d
� d e� Z e
d �
� G d� dee � � Z G d� d� Zdd�Z dd�Z dd�Z dd�Z dd�Z g d�Z!y) zKSeparate caller cancellation from backend task and executor-future results.� )� annotationsN)�Future)� dataclass)�Lock)�
TYPE_CHECKING�Final�Generic�TypeVar�cast)�
AsyncIterator� Awaitable�Callable�_Tc � � e Zd Zy)� _AsyncTransitionUnavailableErrorN)�__name__�
__module__� __qualname__� � �f/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/filelock/_async.pyr r s � �r r T)�frozenc �* � e Zd ZU dZded< dZded< y)�_BackendOutcomeNz _T | None�valuezBaseException | None�error)r r r r �__annotations__r r r r r r s � ��E�9��"&�E� �&r r c � � e Zd Zdd�Zej
dd�� Zej
d d�� Ze d
d�� Z d d�Z
y) �_AsyncTransitionGatec �0 � t � | _ d | _ y �N)r �
_tail_lock�_tail)�selfs r �__init__z _AsyncTransitionGate.__init__ s � �'+�v���48��
r c � � �K � t � �� j 5 � j }�� _ d d d � �' t t j
|� � � d { ��� d ��� � j �� y # 1 sw Y �JxY w7 �(# t j $ r |j � �fd�� � w xY w# � j �� w xY w�w)Nc �& �� �j �� S r! ��_leave�� _predecessorr$ �tickets ��r �<lambda>z+_AsyncTransitionGate.hold.<locals>.<lambda>, � �� �4�;�;�v�CVr ) �ConcurrentFuturer" r# �_wait_until_done�asyncio� wrap_future�CancelledError�add_done_callbackr) )r$ � predecessorr, s ` @r �holdz_AsyncTransitionGate.hold" s� �� �� �)9�);��
�_�_� �*�*�K� �D�J� � � "�
�&�w�':�':�;�'G�H�H�H� � � �K�K�� � �_��
I���)�)�
��-�-�.V�W��
��
�K�K�� �sV �C �A8�
C �!B �B� B �!B3 �&C �8B�=C �B �*B0�0C �3C�C c � � �K � t � �� j 5 � j }�� _ d d d � �/|j � s � j |||||�� � d { ��� d ��� � j �� y # 1 sw Y �RxY w7 �(# t
$ r |j
� �fd�� � w xY w# � j �� w xY w�w)N)�blocking� cancel_check�deadline�
poll_intervalc �& �� �j �� S r! r( r* s ��r r- z7_AsyncTransitionGate.hold_for_acquire.<locals>.<lambda>J r. r )r/ r" r# �done�_wait_for_predecessor�
BaseExceptionr4 r) )r$ r8 r9 r: r; r5 r, s ` @r �hold_for_acquirez%_AsyncTransitionGate.hold_for_acquire3 s� �� �� � *:�);��
�_�_� �*�*�K� �D�J� � � "�;�+;�+;�+=�
��0�0� � %�!-� %�"/� 1� � � � � � �K�K�� �% �_��
�� !�
��-�-�.V�W��
��
�K�K�� �sW �C�B �C�
B �#B �$B �)B1 �.C� B �C� B � B.�.C�1C�Cc � �b K � |st �t j | � }| j � s||�
|� rt �|�3|t j
� z
x}dk rt �|� t
||� n|}n|�|nd }t j |f|�� � d { ��� | j � s�{y y 7 ��w)Nr )�timeout)r r1 r2 r= �time� perf_counter�min�wait)r5 r8 r9 r: r; �waiter� remaining�
wait_intervals r r> z*_AsyncTransitionGate._wait_for_predecessorQ s� � �� � �2� 2��$�$�[�1�� �"�"�$��'�L�N�6�6��#�!)�D�,=�,=�,?�!?�?�I�A�E�:�:�AM�AY��M�9� =�_h�
�1=�1I�
�t�
��,�,��y�-�@� @� @� �"�"�$�
A�s �BB/�B-�B/�+B/c � � | j 5 | j |u rd | _ d d d � |j d � y # 1 sw Y �xY wr! )r" r# �
set_result)r$ r, s r r) z_AsyncTransitionGate._leaveh s9 � �
�_�_��z�z�V�#� !��
� � ���$� � �_�s �=�AN)�return�None)rL �AsyncIterator[None])
r8 �boolr9 �Callable[[], bool] | Noner: � float | Noner; �floatrL rN ) r5 �ConcurrentFuture[None]r8 rO r9 rP r: rQ r; rR rL rM )r, rS rL rM ) r r r r% �
contextlib�asynccontextmanagerr6 r@ � staticmethodr> r) r r r r r s� � �9� �#�#� � $� � �#�#� � � � 0� �
� � �
�
� � $� �: �A�+�A� �A� 0� A�
� A� �
A�
�A� �A�, r r c � �� K � | j � sPt j t j � 5 t | � � d { ��� d d d � | j � s�Pt
| � S 7 �(# 1 sw Y �'xY w�wr! )r= rT �suppressr1 r3 r0 �_future_result��futures r �
_drain_futurer\ o s\ � �� ��k�k�m�
�
�
��!7�!7�
8�"�6�*� *� *� 9� �k�k�m� �&� !�!�
+�� 9�
8�s4 �4A<�A0�A.�A0�
A<�# A<�.A0�0A9�5A<c � �n K � | j � s t j | f� � d { ��� y y 7 ��wr! )r= r1 rF rZ s r r0 r0 v s+ � �� � �;�;�=��l�l�F�9�%�%�%� �%�s �*5�3�5c � � | j � }|j x}�t d|j � S |j } |�# t
$ r ||_ � w xY w)Nr )�resultr r r � __context__r? )r[ �outcomer �contexts r rY rY { s\ � ��m�m�o�G�� � � ��'��D�'�-�-�(�(�� � �G��� �� � � #���
��s �A �Ac �j � t | � �� S # t $ r}t |�� cY d }~S d }~ww xY w�N)r )r �r r? )�funcr s r �
_capture_callrg � s/ � �,� �T�V�,�,�� � ,� �U�+�+��,�s � � 2� -�2�2c � �| K � t | � d { ��� �� S 7 � # t $ r}t |�� cY d }~S d }~ww xY w�wrd re )� awaitabler s r �_capture_awaitablerj � s4 � �� �,� �9�_�5�5�_�� � ,� �U�+�+��,�s0 �<�
�� �<� � 9� 4�9�<�9�<)r r r rj rg r\ rY r0 )r[ z#asyncio.Future[_BackendOutcome[_T]]rL r )r[ zasyncio.Future[_T]rL rM )rf zCallable[[], _T]rL �_BackendOutcome[_T])ri z
Awaitable[_T]rL rk )"�__doc__�
__future__r r1 rT rC �concurrent.futuresr r/ � dataclassesr � threadingr �typingr r r r
r �collections.abcr r
r r � Exceptionr r r r\ r0 rY rg rj �__all__r r r �<module>ru s� �� Q� "� � � � 9� !� � ?� ?��B�B� �T�]�� �y� � �$��'�g�b�k� '� �'�
O � O �d"�&�
�,�,� �r