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_importdivisionN )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
testdbtempfilemkstemposcloseunlinksqlite3connect
connectioncursorexecuteZOperationalErrorcommitatexitregister)
selfpathZthreadedtimeoutr 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 rt j | k r| d k rt 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 fetchalllenr r r sleep)r r end_timewaitr 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 NameErrorstr r r r r r r
r! r! r! r" <module> s
(