OwlCyberSecurity - MANAGER
Edit File: filelock.cpython-38.pyc
U NA�\�3 � @ sp d Z ddlZddlZddlZddlZz ddlZW n ek rH dZY nX z ddlZW n ek rn dZY nX z ddlZW n ek r� dZY nX ze W n e k r� e Z Y nX ddddddgZ d Z dad d � ZG d d� de �ZG d d� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZdZe�rHeZn$e�rTeZneZedk �rle�d� dS )zD A platform independent file lock that supports the with-statement. � N�Timeout� BaseFileLock�WindowsFileLock� UnixFileLock� SoftFileLock�FileLockz3.0.12c C s t p t�t�a t S )z0Returns the logger instance used in this module.)�_logger�loggingZ getLogger�__name__� r r �*/usr/lib/python3/dist-packages/filelock.py�loggerL s r c @ s e Zd ZdZdd� Zdd� ZdS )r zN Raised when the lock could not be acquired in *timeout* seconds. c C s || _ dS �� N)� lock_file)�selfr r r r �__init__[ s zTimeout.__init__c C s d� | j�}|S )Nz)The file lock '{}' could not be acquired.)�formatr )r Ztempr r r �__str__b s �zTimeout.__str__N)r � __module__� __qualname__�__doc__r r r r r r r U s c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�_Acquire_ReturnProxyc C s || _ d S �N��lock)r r r r r r u s z _Acquire_ReturnProxy.__init__c C s | j S r r �r r r r � __enter__y s z _Acquire_ReturnProxy.__enter__c C s | j �� d S r )r �release�r �exc_type� exc_value� tracebackr r r �__exit__| s z _Acquire_ReturnProxy.__exit__N)r r r r r r# r r r r r s s r c @ s� e Zd ZdZd dd�Zedd� �Zedd� �Zejd d� �Zd d � Z d d � Z edd� �Z d dd�Z d dd�Z dd� Zdd� Zdd � ZdS ) r z3 Implements the base class of a file lock. ���c C s& || _ d| _|| _t�� | _d| _dS )r Nr )� _lock_file� _lock_file_fd�timeout� threadingZLock� _thread_lock� _lock_counter)r r r' r r r r � s zBaseFileLock.__init__c C s | j S )z, The path to the lock file. )r% r r r r r � s zBaseFileLock.lock_filec C s | j S )a~ You can set a default timeout for the filelock. 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. .. versionadded:: 2.0.0 )�_timeoutr r r r r' � s zBaseFileLock.timeoutc C s t |�| _dS r )�floatr+ )r �valuer r r r' � s c C s t � �dS )z� Platform dependent. If the file lock could be acquired, self._lock_file_fd holds the file descriptor of the lock file. N��NotImplementedErrorr r r r �_acquire� s zBaseFileLock._acquirec C s t � �dS )zH Releases the lock and sets self._lock_file_fd to None. Nr. r r r r �_release� s zBaseFileLock._releasec C s | j dk S )z� True, if the object holds the file lock. .. versionchanged:: 2.0.0 This was previously a method and is now a property. N)r& r r r r � is_locked� s zBaseFileLock.is_lockedN皙�����?c C s" |dkr| j }| j� | jd7 _W 5 Q R X t| �}| j}t�� }z�| j�$ | jslt� �d||� | � � W 5 Q R X | jr�t� � d||� q�qF|dkr�t�� | |kr�t� �d||� t | j��qFt� �d|||� t� |� qFW n2 | j� t d| jd �| _W 5 Q R X � Y nX t| d�S ) aY Acquires the file lock or fails with a :exc:`Timeout` error. .. 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() :arg float timeout: The maximum time waited for the file lock. If ``timeout < 0``, there is no timeout and this method will block until the lock could be acquired. If ``timeout`` is None, the default :attr:`~timeout` is used. :arg float poll_intervall: We check once in *poll_intervall* seconds if we can acquire the file lock. :raises Timeout: if the lock could not be acquired in *timeout* seconds. .. 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. N� z#Attempting to acquire lock %s on %szLock %s acquired on %sr z"Timeout on acquiring lock %s on %sz2Lock %s not acquired on %s, waiting %s seconds ...r )r' r) r* �idr% �timer2 r �debugr0 �infor �sleep�maxr )r r' Zpoll_intervall�lock_id� lock_filenameZ start_timer r r �acquire� s< $ � zBaseFileLock.acquireFc C st | j �d | jrf| jd8 _| jdks*|rft| �}| j}t� �d||� | �� d| _t� �d||� W 5 Q R X dS )aV Releases the file lock. Please note, that the lock is only completly released, if the lock counter is 0. Also note, that the lock file itself is not automatically deleted. :arg bool force: If true, the lock counter is ignored and the lock is released in every case. r4 r z#Attempting to release lock %s on %szLock %s released on %sN) r) r2 r* r5 r% r r7 r1 r8 )r �forcer; r< r r r r % s zBaseFileLock.releasec C s | � � | S r )r= r r r r r B s zBaseFileLock.__enter__c C s | � � d S r �r r r r r r# F s zBaseFileLock.__exit__c C s | j dd� d S )NT)r> r? r r r r �__del__J s zBaseFileLock.__del__)r$ )Nr3 )F)r r r r r �propertyr r' �setterr0 r1 r2 r= r r r# r@ r r r r r � s" J c @ s e Zd ZdZdd� Zdd� ZdS )r ze Uses the :func:`msvcrt.locking` function to hard lock the lock file on windows systems. c C s| t jt jB t jB }zt �| j|�}W n tk r8 Y n@X zt�|tj d� W n" t tfk rp t � |� Y nX || _ d S �Nr4 ) �os�O_RDWR�O_CREAT�O_TRUNC�openr% �OSError�msvcrt�lockingZLK_NBLCK�IOError�closer& �r Z open_mode�fdr r r r0 X s zWindowsFileLock._acquirec C sP | j }d | _ t�|tjd� t�|� zt�| j� W n tk rJ Y nX d S rC ) r& rJ rK ZLK_UNLCKrD rM �remover% rI �r rO r r r r1 h s zWindowsFileLock._releaseN�r r r r r0 r1 r r r r r R s c @ s e Zd ZdZdd� Zdd� ZdS )r zR Uses the :func:`fcntl.flock` to hard lock the lock file on unix systems. c C sf t jt jB t jB }t �| j|�}zt�|tjtj B � W n" t t fk rZ t � |� Y nX || _ d S r )rD rE rF rG rH r% �fcntl�flockZLOCK_EXZLOCK_NBrL rI rM r& rN r r r r0 ~ s zUnixFileLock._acquirec C s( | j }d | _ t�|tj� t�|� d S r )r& rS rT ZLOCK_UNrD rM rQ r r r r1 � s zUnixFileLock._releaseNrR r r r r r y s c @ s e Zd ZdZdd� Zdd� ZdS )r z8 Simply watches the existence of the lock file. c C sN t jt jB t jB t jB }zt �| j|�}W n ttfk rB Y nX || _ d S r ) rD �O_WRONLYrF �O_EXCLrG rH r% rL rI r& rN r r r r0 � s zSoftFileLock._acquirec C s< t �| j� d | _zt �| j� W n tk r6 Y nX d S r )rD rM r& rP r% rI r r r r r1 � s zSoftFileLock._releaseNrR r r r r r � s z only soft file lock is available)r r rD r( r6 �warnings� ImportErrorrJ rS � TimeoutError� NameErrorrI �__all__� __version__r r r �objectr r r r r r �warnr r r r �<module> sZ � R' !