3
Pf @ sr d dl mZmZ d dlZd dlZye W n ek
r@ eZY nX ddlm Z m
Z
m Z m Z m
Z
G dd de ZdS ) )absolute_importdivisionN )LockBase NotLocked NotMyLock LockTimeout
AlreadyLockedc @ sP e Zd ZdZdZdddZdddZdd Zd
d Zd d
Z dd Z
dd Z dS )SQLiteLockFilez Demonstrate SQL-based locking.NTc
C s t j| ||| t| j| _t| j| _tjdkrdddl}|j \}}t j
| t j | ~~|t_ddl }|j
tj| _| jj }y|jd W n |jk
r Y n$X | jj ddl} | jt 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
testdbtempfileZmkstemposcloseunlinksqlite3Zconnect
connectioncursorexecuteZOperationalErrorcommitatexitregister)
selfpathZthreadedtimeoutr Z_fdr r cr r $/usr/lib/python3.6/sqlitelockfile.pyr s(
zSQLiteLockFile.__init__c C sH |d k r |n| j }tj }|d k r2|dkr2||7 }|d kr@d}n|dkrNd}n|d }| jj }x| j s|jd| j| jf | jj |jd| jf |j }t
|dkr|jd| jf | jj qd S n(|jd| jf |j }t
|dkrd S |d k r6tj |kr6|dkr(t d| j nt
d | j tj| qbW d 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 Zsleep)r r Zend_timewaitr rowsr r r acquire5 sD
zSQLiteLockFile.acquirec C s\ | j std| j | j s4td| j| j f | jj }|j d| jf | jj
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 s& | j j }|jd| jf |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 s* | j j }|jd| jf |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 s* | j j }|jd| j| jf |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 s( | j j }|jd| jf | 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)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 NameErrorstr r r r r r r
r r r r s