File: //usr/lib/python3/dist-packages/twisted/python/__pycache__/lockfile.cpython-38.pyc
U
�bZ � @ s� d Z ddlZddlZddlmZ ddlmZ dd� ZddlmZ e� � sfddlm
Z
m Z m Z
mZ d Znbd
ZzddlZdd lmZ W n ek
r� dZ
Y nX d Zd
Zdd� Z
eZdd� Zdd� Z dd� Z
G dd� d�Zdd� ZddgZdS )z&
Filesystem-based interprocess mutex.
� N)�time)�platformc C s t tt� d ��S )Ni� )�str�int� _uniquefloat� r r �9/usr/lib/python3/dist-packages/twisted/python/lockfile.py�unique s r )�rename)�kill�readlink�remove�symlinkFT)� OpenProcess� �W c
C sv zt dd| � W nX tjk
rh } z8|jd tkr<W Y �$d S |jd tkrVttjd ��� W 5 d }~X Y n
X t d��d S )Nr z OpenProcess is required to fail.)
r �
pywintypes�error�args�ERROR_ACCESS_DENIED�ERROR_INVALID_PARAMETER�OSError�errno�ESRCH� RuntimeError)�pid�signal�er r r r 4 s
r c C s� |d t � d }tj�|d�}t�|� d}t||��}|�| � |�� W 5 Q R X zt||� W n* t k
r� t�
|� t� |� � Y nX dS )z�
Write a file at C{filename} with the contents of C{value}. See the
above comment block as to why this is needed.
�.z.newlinkr �wN) r �os�path�join�mkdir�_open�write�flushr
�
BaseExceptionr
�rmdir)�value�filenameZ newlinknameZ
newvalname�mode�fr r r r E s
r c
C s� zt tj�| d�d�}W nH tk
r` } z*|jtjksB|jtjkrNt|jd��� W 5 d}~X Y n X |� |�� }W 5 Q R X |S dS )zq
Read the contents of C{filename}. See the above comment block as to why
this is needed.
r �rN) r$ r r! r" r r �ENOENT�EIO�read)r* ZfObjr �resultr r r r ` s r c C s" t �t j�| d�� t �| � d S )Nr )r r
r! r" r( )r* r r r �rmlinkr s r2 c @ s0 e Zd ZdZdZdZdd� Zdd� Zdd � ZdS )
�FilesystemLocka
A mutex.
This relies on the filesystem property that creating
a symlink is an atomic operation and that it will
fail if the symlink already exists. Deleting the
symlink will release the lock.
@ivar name: The name of the file associated with this lock.
@ivar clean: Indicates whether this lock was released cleanly by its
last owner. Only meaningful after C{lock} has been called and
returns True.
@ivar locked: Indicates whether the lock is currently held by this
object.
NFc C s
|| _ d S )N)�name)�selfr4 r r r �__init__� s zFilesystemLock.__init__c C s� d}zt tt�� �| j� W �n� tk
�r� } �zltrV|jtjtj fkrVW Y ��NdS |jtj
k�r�zt | j�}W nb tk
r� } zD|jtj kr�W Y �2W Y ��qn tr�|jtjkr�W Y �W Y ��dS � W 5 d}~X Y nX zt
dk r�t
t|�d� W n� tk
�r� } z~|jtjk�r|zt| j� W nH tk
�rh } z(|jtj k�rVW Y �W Y �4W Y �Lq� W 5 d}~X Y nX d}W Y �W Y �&q� W 5 d}~X Y nX W Y �
dS � W 5 d}~X Y nX d| _|| _dS )z�
Acquire this lock.
@rtype: C{bool}
@return: True if the lock is acquired, false otherwise.
@raise OSError: Any exception L{os.symlink()} may raise,
other than L{errno.EEXIST}.
TFNr )r r r �getpidr4 r �_windowsr ZEACCESr/ �EEXISTr r. r r r r2 �locked�clean)r5 r; r r r r r �lock� sD
zFilesystemLock.lockc C s@ t | j�}t|�t�� kr,td| j�d���t| j� d| _dS )z�
Release this lock.
This deletes the directory with the given name.
@raise OSError: Any exception L{os.readlink()} may raise.
@raise ValueError: If the lock is not owned by this process.
zLock z not owned by this processFN)r r4 r r r7 �
ValueErrorr2 r: )r5 r r r r �unlock� s
zFilesystemLock.unlock) �__name__�
__module__� __qualname__�__doc__r; r: r6 r< r> r r r r r3 w s =r3 c C s. t | �}d}z |�� }W 5 |r&|�� X | S )z�
Determine if the lock of the given name is held or not.
@type name: C{str}
@param name: The filesystem path to the lock to test
@rtype: C{bool}
@return: True if the lock is held, False otherwise.
N)r3 r> r< )r4 �lr1 r r r �isLocked� s
rD )rB r r r r �twisted.python.runtimer r r
� isWindowsr r r
r2 r r8 r �win32apir � ImportErrorr r �openr$ r3 rD �__all__r r r r �<module> s2
f