b+H d dl mZmZ d dlZd dlZ e n
# e$ r eZY nw xY wddlm Z m
Z
m Z m Z m
Z
G d de ZdS ) )absolute_importdivisionN )LockBase NotLocked NotMyLock LockTimeout
AlreadyLockedc D e Zd ZdZdZd dZd dZd Zd Zd Z d Z
d
Z dS )
SQLiteLockFilez Demonstrate SQL-based locking.NTc t j | ||| t | j | _ t | j | _ t
j Qddl}| \ }}t j
| t j | ~~|t
_ ddl }|
t
j | _ | j } | d | j ddl} | t j t
j dS # |j $ r Y dS w xY w)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
connectioncursorexecutecommitatexitregisterOperationalError)
selfpaththreadedtimeoutr _fdr r cr s
w/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/lockfile/sqlitelockfile.pyr zSQLiteLockFile.__init__ sG
$h888 00"4#344 ( OOO"**,,KC HSMMM If X$*N !!//.*?@@ O " " $ $ >
II
O " " $ $ $ MMM OOBI~'< = = = = = ' DD s )E
EEc ||n| j }t j }| |dk r||z
}|d}n|dk rd}n|dz }| j } | s| d| j | j f | j | d| j f | }t | dk r6| d| j f | j nGd S | d| j f | }t | dk rd S |Kt j |k r4|dk rt d | j z t d
| j z t j | r) Nr g?
Tz;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 fetchalllenr r" r
sleep)r! r$ end_timewaitr rowss r' acquirezSQLiteLockFile.acquire5 s $ 0''dl9;; 7Q;; H ?DD
\\DDR>##
* !%0@ A C C C
&&((( 9 $ 0 24 4 4 ((t99q==NN $=$($4#68 8 8 O**,,,, F 9 $ 0 24 4 4 ((t99>>F "ty{{X'='=Q;;% '5&*i'0 1 1 1
((>(JKKK
Jt ]. c x | st d| j z | s,t | j d| d | j }| d| j f | j
d S )Nz%s is not lockedz is locked, but not by me (by )r* ) r, r r" i_am_lockingr r _who_is_lockingr r r r r! r s r' releasezSQLiteLockFile.releaset s ~~ < . :;; ; "" H ! - - -t/C/C/E/E/E/E G H H
H '')) 1 (* , , ,
r4 c | j }| d| j f | d S )Nz2select unique_name from locks where lock_file = ?r )r r r r fetchoner9 s r' r8 z SQLiteLockFile._who_is_locking sO '')) / ( * * * ##r4 c | j }| d| j f | }| S )Nz(select * from locks where lock_file = ?)r r r r r- )r! r r2 s r' r, zSQLiteLockFile.is_locked sS '')) / ( * * * 8|r4 c | j }| d| j | j f | S )Nz?select * from locks where lock_file = ? and unique_name = ?)r r r r r r- r9 s r' r7 zSQLiteLockFile.i_am_locking sW '')) 1 (89 ; ; ; (((((r4 c | j }| d| j f | j d S )Nz&delete from locks where lock_file = ?)r r r r r r9 s r'
break_lockzSQLiteLockFile.break_lock sT '')) / ( * * *
r4 )TN)N) __name__
__module__ __qualname____doc__r r r3 r: r8 r, r7 r@ r4 r' r r s $$
F > > > >D= = = = ~
!
!
!$ $ $ ) ) )! ! ! ! !r4 r )
__future__r r r+ r r NameErrorstr r r r r r
r rE r4 r' rJ s 0 0 0 0 0 0 0 0 GG GGG I H H H H H H H H H H H H HN! N! N! N! N!X N! N! N! N! N!s