← Back
Editing: 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
Save File
Cancel