mX d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl
m Z d dl m
Z
d dlmZmZmZ d dlmZ dd lmZ er"d dlZd d
lmZ ej d k rd d lmZ nd d lmZ ej d
Z G d d Z e G d d Z G d de e
Z G d deej! Z"ddgZ#dS ) ) annotationsN)ABCabstractmethod) dataclass)local)
TYPE_CHECKINGAnyClassVar)WeakValueDictionary )Timeout)
TracebackType) )Selffilelockc * e Zd ZdZddZddZddZdS )AcquireReturnProxyzDA context aware object that will release the lock file when exiting.lock BaseFileLockreturnNonec || _ d S Nr )selfr s _/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/filelock/_api.py__init__zAcquireReturnProxy.__init__# s
c | j S r r r s r __enter__z AcquireReturnProxy.__enter__& s
yr exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | Nonec 8 | j d S r )r releaser r# r% r' s r __exit__zAcquireReturnProxy.__exit__) s
r N)r r r r )r r r# r$ r% r& r' r( r r )__name__
__module__ __qualname____doc__r r" r, r r r r sV NN r r c N e Zd ZU dZded< ded< ded< dZd ed
< d Zded < dS )
FileLockContextzBA dataclass which holds the context for a ``BaseFileLock`` object.str lock_filefloattimeoutintmodeNz
int | None lock_file_fdr lock_counter)r. r/ r0 r1 __annotations__r; r< r2 r r r4 r4 2 s_ LL NNN NNN III $L#### Lr r4 c e Zd ZdZdS )ThreadLocalFileContextz8A thread local version of the ``FileLockContext`` class.N)r. r/ r0 r1 r2 r r r? r? I s BBBBr r? c r e Zd ZU dZ e Zded< d9ddd: fdZ d9ddd;dZdd Z
e
j d?d Z
ed@d! Zed@d" Ze
d%%c)nn55 6 wws++H-5CN3y>> *r r c || _ || _ t j | ||d} |rt nt
di || _ dS )a
Create a new lock object.
:param lock_file: path to the file
:param timeout: default timeout when acquiring the lock, in seconds. It will be used as fallback value in the acquire method, if no timeout value (``None``) is given. If you want to disable the timeout, set it to a negative value. A timeout of 0 means, that there is exactly one attempt to acquire the file lock.
:param mode: file permissions for the lockfile
:param thread_local: Whether this object's internal context should be thread local or not. If this is set to ``False`` then the lock will be reentrant across threads.
:param is_singleton: If this is set to ``True`` then only one instance of this class will be created per lock file. This is useful if you want to use the lock object for reentrant locking without needing to pass the same object around.
)r6 r8 r: Nr2 )_is_thread_local
_is_singletonosfspathr? r4 _context)r r6 r8 r: rF rD rH s r r zBaseFileLock.__init__g s` . !- )
9-- "
"
+fL*e*@*@Ve)p)pio)p)p
r c | j S )z>:return: a flag indicating if this lock is thread local or not)rR r! s r is_thread_localz BaseFileLock.is_thread_local s $$r c | j S )z;:return: a flag indicating if this lock is singleton or not)rS r! s r rD zBaseFileLock.is_singleton s
!!r r5 c | j j S )z :return: path to the lock file)rV r6 r! s r r6 zBaseFileLock.lock_file s }&&r c | j j S )za
:return: the default timeout value, in seconds
.. versionadded:: 2.0.0
)rV r8 r! s r r8 zBaseFileLock.timeout s }$$r value float | strc 8 t | | j _ dS )zd
Change the default timeout value.
:param value: the new value, in seconds
N)r7 rV r8 )r r\ s r r8 zBaseFileLock.timeout s !&e
r c t )zjIf the file lock could be acquired, self._context.lock_file_fd holds the file descriptor of the lock file.NotImplementedErrorr! s r _acquirezBaseFileLock._acquire
"!r c t )z>Releases the lock and sets self._context.lock_file_fd to None.r` r! s r _releasezBaseFileLock._release rc r c | j j duS )z
:return: A boolean indicating if the lock file is holding the lock currently.
.. versionchanged:: 2.0.0
This was previously a method and is now a property.
N)rV r; r! s r is_lockedzBaseFileLock.is_locked s })55r c | j j S )zP:return: The number of times this lock has been acquired (but not yet released).)rV r< r! s r r< zBaseFileLock.lock_counter s }))r N皙?)poll_intervallblocking float | None
poll_intervalrj rk r c | | j j }| d}t j |t d |}| j xj dz
c_ t
| }| j }t j } | j
s0t d|| |
| j
r t d|| n|d u r+t d
|| t | d |cxk rt j |z
k r.n n+t d || t | d
}t |||| t j | n6# t $ r) t# d | j j dz
| j _ w xY wt% | S )a_
Try to acquire the file lock.
:param timeout: maximum wait time for acquiring the lock, ``None`` means use the default :attr:`~timeout` is and
if ``timeout < 0``, there is no timeout and this method will block until the lock could be acquired
:param poll_interval: interval of trying to acquire the lock file
:param poll_intervall: deprecated, kept for backwards compatibility, use ``poll_interval`` instead
:param blocking: defaults to True. If False, function will return immediately if it cannot obtain a lock on the
first attempt. Otherwise, this method will block until the timeout expires or the lock is acquired.
:raises Timeout: if fails to acquire lock within the timeout period
:return: a context object that will unlock the file when the context is exited
.. code-block:: python
# You can use this method in the context manager (recommended)
with lock.acquire():
pass
# Or use an equivalent try-finally construct:
lock.acquire()
try:
pass
finally:
lock.release()
.. versionchanged:: 2.0.0
This method returns now a *proxy* object instead of *self*,
so that it can be used in a with statement without side effects.
Nz+use poll_interval instead of poll_intervall )
stacklevelr Tz#Attempting to acquire lock %s on %szLock %s acquired on %sFz+Failed to immediately acquire lock %s on %sr z"Timeout on acquiring lock %s on %sz2Lock %s not acquired on %s, waiting %s seconds ...r )rV r8 warningswarnDeprecationWarningr< idr6 time perf_counterrg _LOGGERdebugrb r
sleep
BaseExceptionmaxr ) r r8 rm rj rk msglock_id
lock_filename
start_times r acquirezBaseFileLock.acquire s P ?m+G %?C M# 1a @ @ @ @ *M
""a'""T((
&((
*~ $MM"GR_```MMOOO> MM":G]SSSu$$MM"OQXZghhh!-000BBBB$"3"5"5
"BBBBBBMM"FQ^___!-000J
c7M=III
=)))
* ),Q
0JQ0N)O)ODM & "t,,,,s
0DF 3F3forcec F | j r| j xj dz c_ | j j dk s|rrt | | j }}t
d|| | d| j _ t
d|| dS dS dS )a*
Releases the file lock. Please note, that the lock is only completely released, if the lock counter is 0. Also
note, that the lock file itself is not automatically deleted.
:param force: If true, the lock counter is ignored and the lock is released in every case/
r r z#Attempting to release lock %s on %szLock %s released on %sN)rg rV r< rt r6 rw rx re )r r r} r~ s r r* zBaseFileLock.release s > P M & &! + & &})Q..%.)+D4>
CWm\\\
-.
*
6 OOOOO P P /.r c . | | S )zE
Acquire the lock.
:return: the lock object
)r r! s r r" zBaseFileLock.__enter__# s
r r# r$ r% r& r' r( c . | dS )z
Release the lock.
:param exc_type: the exception type if raised
:param exc_value: the exception value if raised
:param traceback: the exception traceback if raised
Nr* r+ s r r, zBaseFileLock.__exit__, s
r c 2 | d dS )z'Called when the lock object is deleted.T)r Nr r! s r __del__zBaseFileLock.__del__; s 4 r )rB rC T)r6 rE r8 r7 r: r9 rF rG rD rG rH rI r r ) r6 rE r8 r7 r: r9 rF rG rD rG r r )r rG )r r5 )r r7 )r\ r] r r )r r )r r9 )Nri )
r8 rl rm r7 rj rl rk rG r r )F)r rG r r )r r r- )r. r/ r0 r1 r rA r= rL r rX propertyrD r6 r8 setterr rb re rg r< r r* r" r, r
__classcell__)rP s @r r r M sd 55CVCVCXCXJXXXX
! # 0 ! !q #!q !q !q !q !q !qF% % % % " " " X" ' ' ' X' % % % X%
^- - - ^- " " " ^" " " " ^" 6 6 6 X 6 * * * X* !% #J-
(,
J- J- J- J- J- J-XP P P P P$
! ! ! ! ! ! ! !r r )$
__future__r
contextlibloggingrT ru rq abcr r dataclassesr threadingr typingr r r
weakrefr _errorr
systypesr version_infor typing_extensions getLoggerrw r r4 r? ContextDecoratorr __all__r2 r r r s " " " " " " # # # # # # # # ! ! ! ! ! ! / / / / / / / / / / ' ' ' ' ' ' +JJJ######
7"" ****** '
J
'
' $ ,C C C C C_e C C Cp! p! p! p! p!3
3 p! p! p!h r