Aluode/PerceptionLabPortable
0
1o
2 ��Yi�8 � @ s: d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m3Z4 d dl m Z d dl
mZ d dlmZmZmZ d dlmZ dd lmZ erfd dlZd d5lmZ ejd kr`d d lmZ nd d l mZ e� d
�Z G dd� d�Z e G dd� d��Z G dd� de e�Z!G dd� de �Z"G dd� dej#e"d�Z$ddgZ%dS )� )� annotationsN)�ABCMeta�abstractmethod)� dataclass)�local)�
TYPE_CHECKING�Any�cast)�WeakValueDictionary� )�Timeout)�
TracebackType)� � )�Self�filelockc @ s. e Zd ZdZddd�Zddd �Zddd�ZdS )�AcquireReturnProxyzDA context-aware object that will release the lock file when exiting.�lock� BaseFileLock�return�Nonec C s6 || _ d S �N�r )�selfr � r �wE:\DocsHouse\542 percep lab latest\PerceptionLab\PerceptionLab_Portable\python_embed\Lib\site-packages\filelock/_api.py�__init__$ s 7zAcquireReturnProxy.__init__c C � | j S r r �r r r r � __enter__' s z AcquireReturnProxy.__enter__�exc_type�type[BaseException] | None� exc_value�BaseException | None� traceback�TracebackType | Nonec C s | j �� d S r )r �release�r r r" r$ r r r �__exit__* s zAcquireReturnProxy.__exit__N)r r r r )r r �r r! r" r# r$ r% r r )�__name__�8__module__� __qualname__�__doc__r r r( r r r r r ! s9 1011r c @ sJ e Zd ZU dZded< ded< ded< ded < d12Zd ed < d
Zded< d13S )�FileLockContextzBA dataclass which holds the context for a ``BaseFileLock`` object.�str� lock_file�float�timeout�int�mode�bool�blockingNz14int | None� lock_file_fdr � lock_counter)r* r+ r, r- �__annotations__r7 r8 r r r r r. 3 s 15 r. c @ s e Zd ZdZdS )�ThreadLocalFileContextz8A thread local version of the ``FileLockContext`` class.N)r* r+ r, r- r r r r r: M s r: c s. e Zd Z dddd�d� fdd�Z� ZS )� FileLockMeta������ TF�r6 � is_singletonr0 �str | os.PathLike[str]r2 r1 r4 r3 � thread_localr5 r6 r? �kwargsr r r c s |rS| j �t|��}|rS||�� f||jf||jf||jfd�} dd� | �� D �}16|17s0td|�S d} | d7 } |18�� D ]\} \}
}| d| � d|� d |
� d19�7 } q:t | ��|||||d �|�}t20� | j �j
� � fd d�|�� D �}t� j|fi |��}|r�|| j t|�< td|�S )
N)rA r2 r4 r6 c S s& i | ]\}\}}||kr|||f�qS r r )�.0�name� passed_param� set_paramr r r �21<dictcomp>g s22 23�z)FileLockMeta.__call__.<locals>.<dictcomp>r zGSingleton lock instances cannot be initialized with differing argumentsz24Non-matching arguments: z25 z (existing lock has z but z was passed))r2 r4 rA r6 r? c s i | ] \}}|� v r||�qS r r )rC �key�value�Zpresent_paramsr r rG � s )�26_instances�getr/ �is_thread_localr2 r4 r6 �itemsr �27ValueError�inspect� signaturer �28parameters�super�__call__)�clsr0 r2 r4 rA r6 r? rB �instanceZparams_to_checkZnon_matching_params�msg�29param_namerE rF �30all_paramsZ init_params�� __class__rJ r rT R s@ 31��32 �� 33zFileLockMeta.__call__�r< r= T)r0 r@ r2 r1 r4 r3 rA r5 r6 r5 r? r5 rB r r r )r* r+ r, rT �
__classcell__r r rZ r r; Q s ��r; c s0 e Zd ZU dZded< dN� fdd � Z 34 dOd d
d�dPdd�ZdQdd �ZedQd d ��Z edRd d!��Z35edSd"d#��Z e j dTd&d#��Z edQd'd(��Z
e
j dUd)d(��Z
edVd*d+��ZedWd,d-��ZedWd.d/��ZedQd0d1��ZedVd2d3��Z 4 5dXd4d4d6�dYd<d=�ZdZd[d?d@�Zd\dBdC�Zd]dJdK�ZdWdLdM�Z� ZS )^r z+Abstract base class for a file lock object.z&WeakValueDictionary[str, BaseFileLock]rK rB �dict[str, Any]r r c s t � jdi |�� t� | _dS )z'Setup unique state for lock subclasses.Nr )rS �__init_subclass__r36 rK )rU rB rZ r r r_ � s z BaseFileLock.__init_subclass__r< r= TFr> r0 r@ r2 r1 r4 r3 rA r5 r6 r? c C s< || _ || _t�|�|||d�}|rtntdi |��| _dS )a� 37 Create a new lock object.38 39 :param lock_file: path to the file40 :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.41 :param mode: file permissions for the lockfile42 :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.43 :param blocking: whether the lock should be blocking or not44 :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.45 46 )r0 r2 r4 r6 Nr )�_is_thread_local�
_is_singleton�os�fspathr: r. �_context)r r0 r2 r4 rA r6 r? rB r r r r � s � zBaseFileLock.__init__c C r )z>:return: a flag indicating if this lock is thread local or not)r` r r r r rM � s z BaseFileLock.is_thread_localc C r )z;:return: a flag indicating if this lock is singleton or not)ra r r r r r? � s zBaseFileLock.is_singletonr/ c C � | j jS )z :return: path to the lock file)rd r0 r r r r r0 � � zBaseFileLock.lock_filec C re )za47 :return: the default timeout value, in seconds48 49 .. versionadded:: 2.0.050 )rd r2 r r r r r2 � s zBaseFileLock.timeoutrI � float | strc C s t |�| j_dS )ze51 Change the default timeout value.52 53 :param value: the new value, in seconds54 55 N)r1 rd r2 �r rI r r r r2 � s c C re )z/:return: whether the locking is blocking or not�rd r6 r r r r r6 � rf zBaseFileLock.blockingc C s || j _dS )zb56 Change the default blocking value.57 58 :param value: the new value as bool59 60 Nri rh r r r r6 � s c C re )z.:return: the file permissions for the lockfile)rd r4 r r r r r4 � rf zBaseFileLock.modec C � t �)zjIf the file lock could be acquired, self._context.lock_file_fd holds the file descriptor of the lock file.��NotImplementedErrorr r r r �_acquire� � zBaseFileLock._acquirec C rj )z>Releases the lock and sets self._context.lock_file_fd to None.rk r r r r �_release� rn zBaseFileLock._releasec C s | j jduS )z�61 62 :return: A boolean indicating if the lock file is holding the lock currently.63 64 .. versionchanged:: 2.0.065 66 This was previously a method and is now a property.67 N)rd r7 r r r r � is_locked� s 68zBaseFileLock.is_lockedc C re )zP:return: The number of times this lock has been acquired (but not yet released).)rd r8 r r r r r8 69 rf zBaseFileLock.lock_counterN皙�����?)�poll_intervallr6 � float | None�
poll_intervalrr � bool | Noner c C sD |du r| j j}|du r| j j}|dur d}tj|tdd� |}| j jd7 _t| �}| j}t �70� }zV | j sCt �
d||� | �� | j rNt �
d||� n:|d u r]t �
d71||� t|��d | krkt �72� | k rxn n t �
d ||� t|��d
}t �
||||� t �|� q5W n ty� td | j jd �| j _� w t| d�S )a_ 73 Try to acquire the file lock.74 75 :param timeout: maximum wait time for acquiring the lock, ``None`` means use the default :attr:`~timeout` is and76 if ``timeout < 0``, there is no timeout and this method will block until the lock could be acquired77 :param poll_interval: interval of trying to acquire the lock file78 :param poll_intervall: deprecated, kept for backwards compatibility, use ``poll_interval`` instead79 :param blocking: defaults to True. If False, function will return immediately if it cannot obtain a lock on the80 first attempt. Otherwise, this method will block until the timeout expires or the lock is acquired.81 :raises Timeout: if fails to acquire lock within the timeout period82 :return: a context object that will unlock the file when the context is exited83 84 .. code-block:: python85 86 # You can use this method in the context manager (recommended)87 with lock.acquire():88 pass89 90 # Or use an equivalent try-finally construct:91 lock.acquire()92 try:93 pass94 finally:95 lock.release()96 97 .. versionchanged:: 2.0.098 99 This method returns now a *proxy* object instead of *self*,100 so that it can be used in a with statement without side effects.101 102 Nz+use poll_interval instead of poll_intervall� )�103stacklevelr 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 )rd r2 r6 �warnings�warn�DeprecationWarningr8 �idr0 �time� perf_counterrp �_LOGGER�debugrm r �sleep�
BaseException�maxr ) r r2 rt rr r6 rW �lock_id�
lock_filename�104start_timer r r �acquire sH ( 105� 106�107zBaseFileLock.acquire�forcec C sn | j r3| j jd8 _| jjdks|r5t| �| j}}t�d||� | �� d| j_t�d||� dS dS dS )a+ 108 Releases the file lock. Please note, that the lock is only completely released, if the lock counter is 0.109 Also note, that the lock file itself is not automatically deleted.110 111 :param force: If true, the lock counter is ignored and the lock is released in every case/112 113 r r z#Attempting to release lock %s on %szLock %s released on %sN)rp rd r8 r{ r0 r~ r ro )r r� r� r� r r r r& ^ s �zBaseFileLock.releaser c C s | � � | S )zF114 Acquire the lock.115 116 :return: the lock object117 118 )r� r r r r r q s zBaseFileLock.__enter__r r! r" r# r$ r% c C s | � � dS )z�119 Release the lock.120 121 :param exc_type: the exception type if raised122 :param exc_value: the exception value if raised123 :param traceback: the exception traceback if raised124 125 N�r& r' r r r r( { s zBaseFileLock.__exit__c C s | j dd� dS )z'Called when the lock object is deleted.T)r� Nr� r r r r �__del__� s zBaseFileLock.__del__)rB r^ r r r\ )r0 r@ r2 r1 r4 r3 rA r5 r6 r5 r? r5 r r )r r5 )r r/ )r r1 )rI rg r r )rI r5 r r )r r3 )r r )Nrq )126r2 rs rt r1 rr rs r6 ru r r )F)r� r5 r r )r r r) )r* r+ r, r- r9 r_ r rM �propertyr? r0 r2 �setterr6 r4 r rm ro rp r8 r� r& r r( r� r] r r rZ r r � sX 127 ��128' �� O129130 131r )� metaclass)&�132__future__r �133contextlibrP �loggingrb r| rx �abcr r � dataclassesr � threadingr �typingr r r �weakrefr134 �_errorr �sys�typesr
� version_infor Ztyping_extensions� getLoggerr~ r r. r: r; �ContextDecoratorr �__all__r r r r �<module> s> 135 136= �