관리-도구
편집 파일: sqlitelockfile.cpython-311.pyc
� N�Dg� � � � 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_import�divisionN� )�LockBase� NotLocked� NotMyLock� LockTimeout� AlreadyLockedc �D � e Zd ZdZdZd d�Zd d�Zd� 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 �testdb�tempfile�mkstemp�os�close�unlink�sqlite3�connect� connection�cursor�execute�commit�atexit�register�OperationalError) �self�path�threaded�timeoutr �_fdr r �cr s �w/builddir/build/BUILD/imunify360-venv-2.4.0/opt/imunify360/venv/lib/python3.11/site-packages/lockfile/sqlitelockfile.pyr zSQLiteLockFile.__init__ sG � � ��$��h��8�8�8� �� �0�0���"�4�#3�4�4��� � � (� �O�O�O�"�*�*�,�,�K�C�� �H�S�M�M�M� �I�f� � � ��X�$*�N� !�����!�/�/�.�*?�@�@��� �O� "� "� $� $�� >� �I�I� � � � � �O� "� "� $� $� $� �M�M�M� �O�O�B�I�~�'<� =� =� =� =� =�� �'� � � � �D�D� ���s �)E � E�Ec � � |�|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 �fetchall�lenr r" r �sleep)r! r$ �end_time�waitr �rowss r' �acquirezSQLiteLockFile.acquire5 s � � $� 0�'�'�d�l���9�;�;�� � �7�Q�;�;� �� �H� �?��D�D� ��\�\��D�D��R�<�D�� �'�'�)�)��. ��>�>�#�#� ���� *� !%���0@� A� C� C� C� ��&�&�(�(�(� ��� 9� $� 0� 2�4� 4� 4� ���(�(���t�9�9�q�=�=��N�N� $=�$(�$4�#6�8� 8� 8� �O�*�*�,�,�,�,� �F� ��� 9� $� 0� 2�4� 4� 4� ���(�(���t�9�9��>�>��F� �"�t�y�{�{�X�'=�'=��Q�;�;�%� '5�&*�i�'0� 1� 1� 1� (�(>���(J�K�K�K� �J�t� � � �]. � 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� ���(8�9� ;� ;� ;� ���(�(�(�(�(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 � NameError�str� r r r r r r rE r4 r' �<module>rJ s� �� 0� 0� 0� 0� 0� 0� 0� 0� � � � � � � � �� �G�G��� � � ��G�G�G����� I� H� H� H� H� H� H� H� H� H� H� H� H� H�N!� N!� N!� N!� N!�X� N!� N!� N!� N!� N!s � � �