codekingpro/portable-devtools
114k
1�
2 �j�8 � �, � S r SSKJr SSKrSSKrSSKrSSKrSSKrSSKJ r SSK3J r SSK J
r
SSKJrJrJrJr SS KJrJrJrJr SS4KJr SS KJr SS K J r SS
K J r \( a3 SSK r SSK!J"r" SSK#J$r$ SSK%J&r& \ RN S:� a SSKJ(r( OSSK)J(r( \RT " S5 r+\ " S S\5 5 r, " S S\,\
5 r- " S S5 r.\" SSS 9r/ " S S \5 r0 " S S\\0S 9r1 " S! S"\\15 r2 " S# S$\ \15 r3 " S% S&\ \15 r4/ S'Qr5g)(z1An asyncio-based implementation of the file lock.� )� annotationsN)� dataclass)�iscoroutinefunction)�local)�
TYPE_CHECKING�Any�NoReturn�TypeVar� )�_UNSET_FILE_MODE� BaseFileLock�FileLockContext� FileLockMeta)�Timeout)� SoftFileLock)� UnixFileLock)�WindowsFileLock)�Callable)�futures)�
TracebackType)� � )�Self�filelockc �D � \ rS rSr% SrSrS\S' SrS\S' SrS \S5' S r g) �AsyncFileLockContext�$ zGA dataclass which holds the context for a ``BaseAsyncFileLock`` object.T�bool�run_in_executorN�futures.Executor | None�executor� asyncio.AbstractEventLoop | None�loop� )6�__name__�7__module__� __qualname__�__firstlineno__�__doc__r �__annotations__r! r# �__static_attributes__r$ � �BD:\code\apps\devtools\python\Lib\site-packages\filelock/asyncio.pyr r $ s+ � �Q� !�O�T� � )-�H�%�,� .2�D�8*�1r, r c � � \ rS rSrSrSrg)�AsyncThreadLocalFileContext�2 z8A thread local version of the ``FileLockContext`` class.r$ N�r% r& r' r( r) r+ r$ r, r- r/ r/ 2 s � �Br, r/ c �F � \ rS rSrSrSS jrS S jr S9S jrSrg) �AsyncAcquireReturnProxy�6 zDA context-aware object that will release the lock file when exiting.c � � Xl g �N��lock)�selfr8 s r- �__init__� AsyncAcquireReturnProxy.__init__9 s � �� r, c � �" # � U R $ 7fr6 r7 �r9 s r- �10__aenter__�"AsyncAcquireReturnProxy.__aenter__< s � � ��y�y��s �
c � �T # � U R R 5 I S h v�N g N7fr6 )r8 �release�r9 �exc_type� exc_value� tracebacks r- � __aexit__�!AsyncAcquireReturnProxy.__aexit__? s � � � �i�i� � �!�!�!�s � (�&�(r7 N)r8 �BaseAsyncFileLock�return�None)rI rH �rC �type[BaseException] | NonerD �BaseException | NonerE zTracebackType | NonerI rJ ) r% r& r' r( r) r: r> rF r+ r$ r, r- r3 r3 6 s: � �N���"�,�"� (�"� (� "�11 12� "r, r3 �_ATrH )�boundc �| ^ � \ rS rSrS\S4SSSSSSSS. S13U 4S jjjjrS rU =r$ ) �AsyncFileLockMeta�K �����FT皙�����?N��blocking� is_singleton�
poll_interval�lifetimer# r r! c �h >� U( a U14( a
Sn [ U 5 e[ T
U ] UUUUUUUUU U15U S9 $ )Nz:run_in_executor is not supported when thread_local is True) � lock_file�timeout�mode� thread_localrV rW rX rY r# r r! )�16ValueError�super�__call__)�clsr[ r\ r] r^ rV rW rX rY r# r r! �msg� __class__s �r- ra �AsyncFileLockMeta.__call__L sQ �� � �O�N�C� �S�/� !��w� � ���%� �%�'� �� +� � � 17� 18r, r$ )rb z type[_AT]r[ �str | os.PathLike[str]r\ �floatr] �intr^ r rV r rW r rX rg rY � float | Noner# r" r r r! r rI rN )r% r& r' r( r ra r+ �
__classcell__)rd s @r- rQ rQ K s� �� � �$� "� 19� � "� #�!%�15� $�,0� 20�
� 21�)� 22� � 23� � 24�25 � 26� � 27� � 28� � 29� � 30� /� 31� � 32� *� 33� 34
� 35� 36r, rQ c �j � \ rS rSrSrS\S4SSSSSSSS. SS jjjr\SS37 j5 r\SS j5 r \ R SS j5 r \S S
j5 r S SSS. S S jjjr S S S jjr
S!S jrS"S jr S#S jrS$S jr S%S jrS&S jrSrg)'rH �m zD38Base class for asynchronous file locks.39 40.. versionadded:: 3.15.041 42rS FTrT NrU c 43 � � X@l X`l [ R " U5 UUUUUU U44U S. n U( a [ O[45 " S0 U D6U l g)a� 46Create a new lock object.47 48:param lock_file: path to the file49:param timeout: default timeout when acquiring the lock, in seconds. It will be used as fallback value in the50 acquire method, if no timeout value (``None``) is given. If you want to disable the timeout, set it to a51 negative value. A timeout of 0 means that there is exactly one attempt to acquire the file lock.52:param mode: file permissions for the lockfile. When not specified, the OS controls permissions via umask and53 default ACLs, preserving POSIX default ACL inheritance in shared directories.54:param thread_local: Whether this object's internal context should be thread local or not. If this is set to55 ``False`` then the lock will be reentrant across threads.56:param blocking: whether the lock should be blocking or not57:param is_singleton: If this is set to ``True`` then only one instance of this class will be created per lock58 file. This is useful if you want to use the lock object for reentrant locking without needing to pass the59 same object around.60:param poll_interval: default interval for polling the lock file, in seconds. It will be used as fallback value61 in the acquire method, if no poll_interval value (``None``) is given.62:param lifetime: maximum time in seconds a lock can be held before it is considered expired. When set, a waiting63 process will break a lock whose file modification time is older than ``lifetime`` seconds. ``None`` (the64 default) means locks never expire.65:param loop: The event loop to use. If not specified, the running event loop will be used.66:param run_in_executor: If this is set to ``True`` then the lock will be acquired in an executor.67:param executor: The executor to use. If not specified, the default executor will be used.68 69) r[ r\ r] rV rX rY r# r r! Nr$ )�_is_thread_local�
_is_singleton�os�fspathr/ r �_context)
r9 r[ r\ r] r^ rV rW rX rY r# r r! �kwargss
r- r: �BaseAsyncFileLock.__init__u s_ � �P !-� � )��70 ���9�-� �� � *� �� .� �71"72�� O[�/J�`t�/t� /73��/74��
r, c �. � U R R $ )z":returns: whether run in executor.)rr r r= s r- r �!BaseAsyncFileLock.run_in_executor� s � � �}�}�,�,�,r, c �. � U R R $ )z:returns: the executor.�rr r! r= s r- r! �BaseAsyncFileLock.executor� s � � �}�}�%�%�%r, c �$ � XR l g)z[75Change the executor.76 77:param futures.Executor | None value: the new executor or ``None``78 79Nrx )r9 �values r- r! ry � s � � "'�
�
� r, c �. � U R R $ )z:returns: the event loop.)rr r# r= s r- r# �BaseAsyncFileLock.loop� s � � �}�}�!�!�!r, )rV � cancel_checkc � � # � Uc U R R nUc U R R nUc U R R nU R =R S-
sl [ U 5 nU R n[ R " 5 n U R ( dI U R 5 [ R SXV5 U R U R 5 I Sh v�N U R ( a [ R SXV5 O\U R UUUUUUS9( a [! U5 eSn[ R X�Xb5 [" R$ " U5 I Sh v�N M� [+ U S9$ N� N! [& a4 [) SU R R S-80 5 U R l e f = f7f) a� 81Try to acquire the file lock.82 83:param timeout: maximum wait time for acquiring the lock, ``None`` means use the default84 :attr:`~BaseFileLock.timeout` is and if ``timeout < 0``, there is no timeout and this method will block85 until the lock could be acquired86:param poll_interval: interval of trying to acquire the lock file, ``None`` means use the default87 :attr:`~BaseFileLock.poll_interval`88:param blocking: defaults to True. If False, function will return immediately if it cannot obtain a lock on the89 first attempt. Otherwise, this method will block until the timeout expires or the lock is acquired.90:param cancel_check: a callable returning ``True`` when the acquisition should be canceled. Checked on each poll91 iteration. When triggered, raises :class:`~Timeout` just like an expired timeout.92 93:returns: a context object that will unlock the file when the context is exited94 95:raises Timeout: if fails to acquire lock within the timeout period96 97.. code-block:: python98 99 # You can use this method in the context manager (recommended)100 with lock.acquire():101 pass102 103 # Or use an equivalent try-finally construct:104 lock.acquire()105 try:106 pass107 finally:108 lock.release()109 110Nr z#Attempting to acquire lock %s on %szLock %s acquired on %s)rV r~ r\ �111start_timez2Lock %s not acquired on %s, waiting %s seconds ...r r7 )rr r\ rV rX � lock_counter�idr[ �time� perf_counter� is_locked�_try_break_expired_lock�_LOGGER�debug�_run_internal_method�_acquire�_check_give_upr �asyncio�sleep�
BaseException�maxr3 ) r9 r\ rX rV r~ �lock_id�
lock_filenamer� rc s r- �acquire�BaseAsyncFileLock.acquire� s � � �P �?��m�m�+�+�G� � ��}�}�-�-�H� � � �M�M� 7� 7�M�
�
�
�"�"�a�'�"��T�(�� ���
��&�&�(�112� ���~�~��0�0�2��M�M�"G��`� �3�3�D�M�M�B�B�B��>�>��M�M�":�G�S���&�&��!� %�!-� #� )�
'� � "�-�0�0�J���
�
�c�M�I� �m�m�M�2�2�2�' �. '�D�1�1�' C� 3�� � �),�Q��
�
�0J�0J�Q�0N�)O�D�M�M� &� � �sP �BG�AF �0F�1+F � G� AF �2F�3F �9 G�F �F �>G�Gc � � # � U R ( a� U R =R S- sl U R R S:X d U( aw [ U 5 U R p2[113 R
SX#5 U R U R 5 I Sh v�N SU R l [114 R
SX#5 ggg N.7f)z�115Release the file lock. The lock is only completely released when the lock counter reaches 0. The lock file116itself is not automatically deleted.117 118:param force: If true, the lock counter is ignored and the lock is released in every case.119 120r r z#Attempting to release lock %s on %sNzLock %s released on %s) r� rr r� r� r[ r� r� r� �_release)r9 �forcer� r� s r- rA �BaseAsyncFileLock.release s� � � � �>�>� �M�M� &� &�!� +� &��}�}�)�)�Q�.�%�)+�D��4�>�>� ��
�
� C�W�\��/�/��
�
�>�>�>�-.��
�
�*��
�
� 6��O�
38� � ?�s �B C� C
� /Cc � �� # � [ U5 ( a U" 5 I S h v�N g U R ( a8 [ R " 5 R U R U5 I S h v�N g U" 5 g NV N7fr6 )r r r� �get_running_loopr! )r9 �methods r- r� �&BaseAsyncFileLock._run_internal_method. sR � � � �v� &� &��(�N�N�
�
!�
!��*�*�,�<�<�T�]�]�F�S� S� S� �H�
� S�s" �A8�A4�AA8�&A6�'A8�6A8c � � Sn[ U5 e)zTSync context manager entry is not supported because lock acquisition is a coroutine.�d Use `async with` — acquire/release are coroutines and cannot be awaited in a sync context manager.��NotImplementedError)r9 rc s r- � __enter__�BaseAsyncFileLock.__enter__6 s � �t��!�#�&�&r, c � � Sn[ U5 e)zOSync context manager exit is not supported because lock release is a coroutine.r� r� )r9 rC rD rE rc s r- �__exit__�BaseAsyncFileLock.__exit__; s � � u��!�#�&�&r, c � �B # � U R 5 I Sh v�N U $ N7f)z/121Acquire the lock.122 123:returns: the lock object124 125N)r� r= s r- r> � BaseAsyncFileLock.__aenter__E s � � � �l�l�n� � �� � �s � � � c � �@ # � U R 5 I Sh v�N g N7f)z�126Release the lock.127 128:param exc_type: the exception type if raised129:param exc_value: the exception value if raised130:param traceback: the exception traceback if raised131 132N)rA rB s r- rF �BaseAsyncFileLock.__aexit__O s � � � �l�l�n� � �s � � � c �. � [ R " [ 5 [ R " 5 nUc133 SSS5 gUR 5 ( d UR U R SS95 O UR U R SS95 SSS5 g! [134 a_ U R R ( a? U R R R 5 ( d U R R OSn N�f = f! , ( d f g= f)uR Release on deletion — safe to call during GC even when no event loop is running.NT)r� )
�135contextlib�suppress� Exceptionr� r� � RuntimeErrorrr r# � is_closed�136is_running�run_until_completerA � create_task)r9 r# s r- �__del__�BaseAsyncFileLock.__del___ s� � �
�
�
��
+�
q� �/�/�1�� �|�� ,�
+� �?�?�$�$��'�'�� � �4� �(@�A�� � �� � �D� �!9�:� ,�
+�� �
q�-1�]�]�-?�-?��
�
�HZ�HZ�Hd�Hd�Hf�Hf�t�}�}�)�)�lp��
q�� ,�
+�s4 �D�B�D�AD�A&D� D�D�D�137D)rr ro rn )r[ rf r\ rg r] rh r^ r rV r rW r rX rg rY ri r# r" r r r! r rI rJ )rI r )rI r )r{ r rI rJ )rI r" )NN)138r\ ri rX ri rV z bool | Noner~ zCallable[[], bool] | NonerI r3 )F)r� r rI rJ )r� zCallable[[], Any]rI rJ )rI r )rC rL rD rM rE �objectrI rJ )rI r rK )rI rJ )r% r& r' r( r) r r: �propertyr r! �setterr# r� rA r� r� r� r> rF r� r+ r$ r, r- rH rH m s� � �� �$� "� :139� � "� #�!%�15� $�,0�:140�)�:141� �:142� � :143�144 � :145� �:146� �:147� �:148� �:149� /�:150� �:151� *�:152� 153� :154�x �-� �-� �&� �&� �_�_�'� �'� �"� �"� !%�&*�O2�155 !%�26�
O2� �O2� $�O2�156 � O2� 0�
O2� 157!�O2�bP�&�'�158'�,�'� (�'� � '�159 160� '�� �,� � (� � (� �161 162� �
;r, )� metaclassc � � \ rS rSrSrSrg)�AsyncSoftFileLockio z.Simply watches the existence of the lock file.r$ Nr1 r$ r, r- r� r� o s � �8r, r� c � � \ rS rSrSrSrg)�AsyncUnixFileLockis zHUses the :func:`fcntl.flock` to hard lock the lock file on unix systems.r$ Nr1 r$ r, r- r� r� s s � �Rr, r� c � � \ rS rSrSrSrg)�AsyncWindowsFileLockiw zNUses the :func:`msvcrt.locking` to hard lock the lock file on windows systems.r$ Nr1 r$ r, r- r� r� w s � �Xr, r� )r3 r� r� r� rH )6r) �163__future__r r� r� �loggingrp r� � dataclassesr �inspectr � threadingr �typingr r r r164 �_apir r
r r �_errorr �_softr �_unixr �_windowsr �sys�collections.abcr �165concurrentr �typesr � version_infor �typing_extensions� getLoggerr� r r/ r3 rN rQ rH r� r� r� �__all__r$ r, r- �<module>r� s �� 7� "� � � � � � !� '� � 8� 8� O� O� � � � %���(�"�#�166���7�"� �*� �167�168�J�169'�� �1702�?� 1712� �1722�C�"6�� C�"� "�$ �e�.�/�� 173� � 174�D;� �0A� ;�D9� �&7� 9�S� �&7� S�Y�?�,=� Y� �r,