File: //usr/lib/python3/dist-packages/twisted/python/__pycache__/lockfile.cpython-38.pyc
U
��W[& � @ s d Z ddlmZmZ ddlZddlZddlmZ ddlm Z ddl
m Z dd� Z dd lm
Z
e �� s�dd
lmZ dd lmZ dd lmZ dd
lmZ dZnbdZzddlmZ ddlZW n ek
r� dZY nX dZdZdd� ZeZ dd� Zdd� Zdd� ZG dd � d e �Z d d � Z d d gZ dS ) z&
Filesystem-based interprocess mutex.
� )�absolute_import�divisionN)�time)�platform)�_PY3c 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)�symlink)�readlink)�removeFT)� 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 5 s
r c C s� |d t � d }tj�|d�}t�|� tr4d}nd}t||��}|�| � |�� W 5 Q R X zt ||� W n" 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 �wZwcN) r �os�path�join�mkdirr �_open�write�flushr
r �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% �IOErrorr �ENOENT�EIOr �read)r, ZfObjr �resultr
r
r r b s r c C s" t �t j�| d�� t �| � d S )Nr )r# r r$ r% r* )r, r
r
r �rmlinks s r5 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)�selfr7 r
r
r �__init__� s zFilesystemLock.__init__c C s� d}zt tt�� �| j� W �n� tk
�r� } �zptrV|jtjtj fkrVW Y ��RdS |jtj
k�r�zt | j�}W nf t tfk
r� } zD|jtj
kr�W Y �2W Y ��qn tr�|jtjkr�W Y �W Y ��dS � W 5 d}~X Y nX ztdk r�tt|�d� W n� tk
�r� } z~|jtjk�r�zt| j� W nH tk
�rl } z(|jtj
k�rZW 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: Any exception os.symlink() may raise, other than
EEXIST.
TFNr )r r r# �getpidr7 r �_windowsr ZEACCESr2 ZEEXISTr r0 r1 r r r r5 �locked�clean)r8 r= r r r
r
r �lock� sD
zFilesystemLock.lockc C s> t | j�}t|�t�� kr*td| jf ��t| j� d| _dS )z�
Release this lock.
This deletes the directory with the given name.
@raise: Any exception os.readlink() may raise, or
ValueError if the lock is not owned by this process.
z!Lock %r not owned by this processFN)r r7 r r# r: �
ValueErrorr5 r< )r8 r r
r
r �unlock� s
�
zFilesystemLock.unlock) �__name__�
__module__� __qualname__�__doc__r= r< r9 r> r@ r
r
r
r r6 y s >r6 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)r6 r@ r> )r7 �lr4 r
r
r �isLocked� s
rF )!rD Z
__future__r r r r# r r Ztwisted.python.runtimer Ztwisted.python.compatr r r
Z isWindowsr r r r r5 r; Zwin32apir r � ImportErrorr r �openr' �objectr6 rF �__all__r
r
r
r �<module> s<
j