| Server IP : 192.158.238.246 / Your IP : 3.144.84.11 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python38/lib/python3.8/site-packages/lockfile/__pycache__/ |
Upload File : |
U
��UV� � @ sr d dl mZmZ d dlZd dlZze W n ek
r@ eZY nX 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�| _tjdkrdddl}|�� \}}t �
|� t � |� ~~|t_ddl }|�
tj�| _| j�� }z|�d� W n |jk
r� Y n$X | 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�executeZOperationalError�commit�atexit�register)
�self�pathZthreaded�timeoutr Z_fdr r �cr � r! �H/opt/alt/python38/lib/python3.8/site-packages/lockfile/sqlitelockfile.pyr s(
zSQLiteLockFile.__init__c C sD |d k r |n| j }t�� }|d k r2|dkr2||7 }|d kr@d}n|dkrNd}n|d }| j�� }| �� s�|�d| j| jf� | j�� |�d| jf� |� � }t
|�dkr�|�d| jf� | j�� q�d S n(|�d| jf� |� � }t
|�dkr�d S |d k �r4t�� |k�r4|dk�r&t d| j ��nt
d | j ��t�|� q`d S )
Nr g�������?�
z;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 sL
�
� � �
�zSQLiteLockFile.acquirec C s\ | � � std| j ��| �� s4td| 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
Zfetchoner0 r! r! r" r/ � 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' r0 r! r! r" r. � 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 r0 r! r! r" �
break_lock� s
�zSQLiteLockFile.break_lock)TN)N) �__name__�
__module__� __qualname__�__doc__r r r- r1 r/ r& r. r2 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