U
��UV� � @ sr d dl mZmZ d dlZd dlZze W n ek
r@ eZY nX ddlm Z m
Z
m Z m Z m
Z
G dd� de �ZdS )� )�absolute_import�divisionN� )�LockBase� NotLocked� NotMyLock� LockTimeout�
AlreadyLockedc @ sP e Zd ZdZdZddd�Zddd�Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dS )�SQLiteLockFilez Demonstrate SQL-based locking.NTc
C s� t �| |||� t| j�| _t| j�| _tjdkrdddl}|�� \}}t �
|� t � |� ~~|t_ddl }|�
tj�| _| j�� }z|�d� W n |jk
r� Y n$X | j�� ddl} | �t j tj� dS )zu
>>> lock = SQLiteLockFile('somefile')
>>> lock = SQLiteLockFile('somefile', threaded=False)
Nr zGcreate table locks( lock_file varchar(32), unique_name varchar(32)))r �__init__�unicode� lock_file� unique_namer
�testdb�tempfileZmkstemp�os�close�unlink�sqlite3Zconnect�
connection�cursor�executeZOperationalError�commit�atexit�register)
�self�pathZthreaded�timeoutr Z_fdr r �cr � r �/sqlitelockfile.pyr s(
zSQLiteLockFile.__init__c C sD |d k r |n| j }t�� }|d k r2|dkr2||7 }|d kr@d}n|dkrNd}n|d }| j�� }| �� s�|�d| j| jf� | j�� |�d| jf� |� � }t
|�dkr�|�d| jf� | j�� q�d S n(|�d| jf� |� � }t
|�dkr�d S |d k �r4t�� |k�r4|dk�r&t d| j ��nt
d | j ��t�|� q`d S )
Nr g�������?�
z;insert into locks (lock_file, unique_name) values (?, ?)z*select * from locks where unique_name = ?r �(delete from locks where unique_name = ?z&Timeout waiting to acquire lock for %sz%s is already locked)r �timer r � is_lockedr r
r r �fetchall�lenr r r �sleep)r r Zend_time�waitr �rowsr r r �acquire5 sL
�
� � �
�zSQLiteLockFile.acquirec C s\ | � � std| j ��| �� s4td| j| �� f ��| j�� }|� d| jf� | j�
� d S )Nz%s is not lockedz#%s is locked, but not by me (by %s)r" ) r$ r r � i_am_lockingr r �_who_is_lockingr r r r �r r r r r �releaset s �
�zSQLiteLockFile.releasec C s& | j �� }|�d| jf� |�� d S )Nz2select unique_name from locks where lock_file = ?r )r r r r
Zfetchoner- r r r r, � s
�z SQLiteLockFile._who_is_lockingc C s* | j �� }|�d| jf� |�� }| S )Nz(select * from locks where lock_file = ?)r r r r
r% )r r r) r r r r$ � s
�zSQLiteLockFile.is_lockedc C s* | j �� }|�d| j| jf� |�� S )Nz?select * from locks where lock_file = ? and unique_name = ?)r r r r
r r% r- r r r r+ � s
�zSQLiteLockFile.i_am_lockingc C s( | j �� }|�d| jf� | j �� d S )Nz&delete from locks where lock_file = ?)r r r r
r r- r r r �
break_lock� s
�zSQLiteLockFile.break_lock)TN)N) �__name__�
__module__� __qualname__�__doc__r r r* r. r, r$ r+ r/ r r r r r
s
"
? r
)Z
__future__r r r# r r � NameError�str� r r r r r r
r r r r �<module> s
| Name | Type | Size | Permission | Actions |
|---|---|---|---|---|
| __init__.cpython-38.opt-1.pyc | File | 9.49 KB | 0644 |
|
| __init__.cpython-38.pyc | File | 9.49 KB | 0644 |
|
| linklockfile.cpython-38.opt-1.pyc | File | 2.17 KB | 0644 |
|
| linklockfile.cpython-38.pyc | File | 2.17 KB | 0644 |
|
| mkdirlockfile.cpython-38.opt-1.pyc | File | 2.53 KB | 0644 |
|
| mkdirlockfile.cpython-38.pyc | File | 2.53 KB | 0644 |
|
| pidlockfile.cpython-38.opt-1.pyc | File | 4.68 KB | 0644 |
|
| pidlockfile.cpython-38.pyc | File | 4.68 KB | 0644 |
|
| sqlitelockfile.cpython-38.opt-1.pyc | File | 3.56 KB | 0644 |
|
| sqlitelockfile.cpython-38.pyc | File | 3.56 KB | 0644 |
|
| symlinklockfile.cpython-38.opt-1.pyc | File | 2.06 KB | 0644 |
|
| symlinklockfile.cpython-38.pyc | File | 2.06 KB | 0644 |
|