File: //usr/lib/python3/dist-packages/lockfile/__pycache__/sqlitelockfile.cpython-310.pyc
o
��UV� � @ sp d dl mZmZ d dlZd dlZze W n ey eZY nw 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�| _tjdu r2ddl}|�� \}}t �
|� t � |� ~~|t_ddl }|�
tj�| _| j�� }z|�d� W n |jyT Y dS w | 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�tempfile�mkstemp�os�close�unlink�sqlite3�connect�
connection�cursor�execute�OperationalError�commit�atexit�register)
�self�path�threaded�timeoutr �_fdr r �cr � r$ �9/usr/lib/python3/dist-packages/lockfile/sqlitelockfile.pyr s*
�
zSQLiteLockFile.__init__c C s8 |d ur|n| j }t�� }|d ur|dkr||7 }|d u r d}n |dkr'd}n|d }| j�� } | �� sf|�d| j| jf� | j�� |�d| jf� |� � }t
|�dkrd|�d| jf� | j�� nd S |�d| jf� |� � }t
|�dkrzd S |d ur�t�� |kr�|dkr�t d | j ��t
d
| j ��t�|� q1) 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 �fetchall�lenr r r �sleep)r r! �end_time�waitr �rowsr$ r$ r% �acquire5 sP
�
� � � �
�zSQLiteLockFile.acquirec C s\ | � � s td| j ��| �� std| 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
�fetchoner3 r$ r$ r% r2 � 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* r3 r$ r$ r% r1 � 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 r3 r$ r$ r% �
break_lock� s
�zSQLiteLockFile.break_lock)TN)N) �__name__�
__module__� __qualname__�__doc__r r r0 r4 r2 r) r1 r6 r$ r$ r$ r% r
s
"? r
)�
__future__r r r( r r � NameError�str� r r r r r r
r$ r$ r$ r% �<module> s �