File: //usr/lib/python3/dist-packages/lockfile/__pycache__/mkdirlockfile.cpython-310.pyc
o
��UV � @ sd d dl mZmZ d dlZd dlZd dlZd dlZddlmZm Z m
Z
m Z m Z m
Z
G dd� de�ZdS )� )�absolute_import�divisionN� )�LockBase�
LockFailed� NotLocked� NotMyLock� LockTimeout�
AlreadyLockedc @ sD e Zd ZdZddd�Zddd�Zdd � Zd
d � Zd d
� Zdd� Z dS )�
MkdirLockFilez"Lock file by creating a directory.TNc C s6 t �| |||� tj�| jd| j| j| jf �| _ dS )zs
>>> lock = MkdirLockFile('somefile')
>>> lock = MkdirLockFile('somefile', threaded=False)
z%s.%s%sN)
r �__init__�os�path�join� lock_file�hostname�tname�pid� unique_name)�selfr �threaded�timeout� r �8/usr/lib/python3/dist-packages/lockfile/mkdirlockfile.pyr s
�
�zMkdirLockFile.__init__c C s |d ur|n| j }t�� }|d ur|dkr||7 }|d u r d}ntd|d �} zt�| j� W nH tyx t�� d }|j t j
krotj � | j
�rMY d S |d urit�� |kri|dkrbtd| j ��td| j ��t�|� ntd| j ��Y n w t| j
d ��� d S q()
Nr g�������?�
Tr z&Timeout waiting to acquire lock for %sz%s is already lockedzfailed to create %s�wb)r �time�maxr
�mkdirr �OSError�sys�exc_info�errno�EEXISTr �existsr r r
�sleepr �open�close)r r �end_time�wait�errr r r �acquire s< �� ���zMkdirLockFile.acquirec C sN | � � s td| j ��tj�| j�std| j ��t�| j� t�| j � d S )Nz%s is not lockedz%s is locked, but not by me)
� is_lockedr r r
r$ r r �unlink�rmdirr �r r r r �releaseA s zMkdirLockFile.releasec C s t j�| j�S �N)r
r r$ r r/ r r r r, I s zMkdirLockFile.is_lockedc C s | � � o
tj�| j�S r1 )r, r
r r$ r r/ r r r � i_am_lockingL s �zMkdirLockFile.i_am_lockingc C sJ t j�| j�r#t �| j�D ]
}t �t j�| j|�� q
t �| j� d S d S r1 )r
r r$ r �listdirr- r r. )r �namer r r �
break_lockP s
�zMkdirLockFile.break_lock)TNr1 )
�__name__�
__module__� __qualname__�__doc__r r+ r0 r, r2 r5 r r r r r s
& r )�
__future__r r r r
r r" � r r r r r r
r r r r r �<module> s