File: //opt/alt/python35/lib/python3.5/site-packages/lockfile/__pycache__/sqlitelockfile.cpython-35.pyc
��UV� � @ s� d d l m Z m Z d d l Z d d l Z y e Wn e k
rP e Z Yn Xd d l m Z m
Z
m Z m Z m
Z
Gd d � d e � Z d S)� )�absolute_import�divisionN� )�LockBase� NotLocked� NotMyLock� LockTimeout�
AlreadyLockedc @ sy e Z d Z d Z d Z d d d d � Z d d d � Z d d � Z d
d � Z d d
� Z d d � Z
d d � Z d S)�SQLiteLockFilez Demonstrate SQL-based locking.NTc
C s t j | | | | � t | j � | _ t | j � | _ t j d k r� d d l } | j � \ } } t j
| � t j | � ~ ~ | t _ d d l } | j
t j � | _ | j j � } y | j d � Wn | j k
r� Yn0 X| j j � d d l } | j t j t j � d S)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�tempfile�mkstemp�os�close�unlink�sqlite3�connect�
connection�cursor�executeZOperationalError�commit�atexit�register)
�self�pathZthreaded�timeoutr Z_fdr r �cr � r! �/sqlitelockfile.pyr s(
zSQLiteLockFile.__init__c C s� | d k r | n | j } t j � } | d k rI | d k rI | | 7} | d k r^ d } n | d k rs d } n
| d } | j j � } x2| j � s%| j d | j | j f � | j j � | j d | j f � | j � } t
| � d k r | j d | j f � | j j � q]d Sn8 | j d | j f � | j � } t
| � d k r]d S| d k r�t j � | k r�| d k r�t d | j � � n t
d | j � � t j | � q� Wd S)
Nr g�������?�
z;insert into locks (lock_file, unique_name) values (?, ?)z*select * from locks where unique_name = ?r z(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 �end_time�waitr �rowsr! r! r" �acquire5 sD
zSQLiteLockFile.acquirec C s� | j � s t d | j � � | j � sJ t d | j | j � f � � | j j � } | j d | j f � | j j
� d S)Nz%s is not lockedz#%s is locked, but not by me (by %s)z(delete from locks where unique_name = ?) r% r r � i_am_lockingr r �_who_is_lockingr r r r )r r r! r! r" �releaset s
zSQLiteLockFile.releasec C s3 | j j � } | j d | j f � | j � d S)Nz2select unique_name from locks where lock_file = ?r )r r r r
Zfetchone)r r r! r! r" r. � s
z SQLiteLockFile._who_is_lockingc C s7 | j j � } | j d | j f � | j � } | 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 s7 | j j � } | j d | j | j f � | j � S)Nz?select * from locks where lock_file = ? and unique_name = ?)r r r r
r r& )r r r! r! r" r- � s zSQLiteLockFile.i_am_lockingc C s6 | j j � } | j d | j f � | j j � d S)Nz&delete from locks where lock_file = ?)r r r r
r )r r r! r! r" �
break_lock� s
zSQLiteLockFile.break_lock) �__name__�
__module__� __qualname__�__doc__r r r, r/ r. r% r- r0 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
(