File: //opt/saltstack/salt/lib/python3.10/site-packages/filelock/__pycache__/_soft.cpython-310.pyc
o
;j�! � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlmZ d dlm Z m
Z
m Z m Z d dl
mZ ddlmZ ddlmZmZ d Zd
Zd Zd Zd
ZG dd� de�Zddd�ZdgZdS )� )� annotationsN)�suppress)�EACCES�EEXIST�EPERM�ESRCH)�Path� )� BaseFileLock)�ensure_directory_exists�raise_on_not_writable_filei �W i g @i c @ s� e Zd ZdZd dd�Zd dd�Zd dd �Zed!d
d��Zed"dd��Z ed#dd��Z
e d$dd��Z e d%dd��Z
d dd�Zd dd �Zd d d �Zd S )&� SoftFileLocka�
Portable file lock based on file existence.
Unlike :class:`UnixFileLock <filelock.UnixFileLock>` and :class:`WindowsFileLock <filelock.WindowsFileLock>`, this
lock does not use OS-level locking primitives. Instead, it creates the lock file with ``O_CREAT | O_EXCL`` and
treats its existence as the lock indicator. This makes it work on any filesystem but leaves stale lock files behind
if the process crashes without releasing the lock.
To mitigate stale locks, the lock file contains the PID and hostname of the holding process. On contention, if the
holder is on the same host and its PID no longer exists, the stale lock is broken automatically.
�return�Nonec
C s� t | j� t| j� tjtjB tjB tjB }ttdd � }d ur$||O }z t� | j|| �
� �}W n' t yW } z|j t
ksH|j tkrGtjdksH� | �� W Y d }~d S d }~ww | �|� || j_d S )N�
O_NOFOLLOW�win32)r � lock_filer �os�O_WRONLY�O_CREAT�O_EXCL�O_TRUNC�getattr�openZ
_open_mode�OSError�errnor r �sys�platform�_try_break_stale_lock�_write_lock_info�_context� lock_file_fd)�self�flagsZ
o_nofollowZ file_handler� exception� r& �B/opt/saltstack/salt/lib/python3.10/site-packages/filelock/_soft.py�_acquire# s,
���� ��
zSoftFileLock._acquirec
C sD t tt��� t| j�\}}|r|�� �� ng }t|�dvr2t�� | t kr)| �
� W d � d S |d |d }}t|�dkrE|d nd }|t � � krV W d � d S t
|�}| �|�r�tjdkr�|d ur�t
|�}| �|�} | d urz| |krzn W d � d S W d � d S | �
� W d � d S 1 s�w Y d S )N> � � r r r* r) r )r r �
ValueError�_read_lock_filer �strip�
splitlines�len�time� _MALFORMED_LOCK_AGE_THRESHOLD�_evict_lock_file�socket� gethostname�int�_is_process_aliver r �_get_process_creation_time)
r# �content�mtime�linesZpid_str�hostnameZcreation_time_str�pidZstored�actualr& r& r' r : s4 � �
��
"�z"SoftFileLock._try_break_stale_lockc C s4 | j � dt�� � �}t| j ��|� t|��� d S )Nz.break.)r r �getpidr �rename�unlink)r# Z
break_pathr& r& r' r2 Y s z SoftFileLock._evict_lock_filer< r5 �boolc
C s� t jdkr#dd l}|jj}|�td| �}|r |�|� dS |�� t kS z t
� | d� W dS t yQ } z|j
tkr@W Y d }~dS |j
tkrLW Y d }~dS � d }~ww )Nr r TF)r r �ctypes�windll�kernel32� OpenProcess�_WIN_SYNCHRONIZE� CloseHandleZ GetLastError� _WIN_ERROR_INVALID_PARAMETERr �killr r r r )r< rB rD �handle�excr& r& r' r6 ^ s&
�
��z SoftFileLock._is_process_alive�
int | Nonec C s� t jdkrdS ddl}ddlm} |jj}|�td| �}|s dS z4|�� }|�� }|�� }|�� }|� ||�
|�|�
|�|�
|�|�
|��sNW |� |� dS W |� |� n|� |� w |j d> |j
B S )zRReturn the process creation FILETIME as an integer on Windows, ``None`` otherwise.r Nr )�wintypes� )r r rB rM rC rD rE �&_WIN_PROCESS_QUERY_LIMITED_INFORMATIONZFILETIMEZGetProcessTimes�byrefrG ZdwHighDateTimeZ
dwLowDateTime) r< rB rM rD rJ ZcreationZ exit_timeZ kernel_timeZ user_timer& r& r' r7 s s2
�� z'SoftFileLock._get_process_creation_time�fdc C s� t t��4 t�� � dt�� � d�}tjdkr(t� t�� � }d ur(||� d�7 }t�
| |� � � W d � d S 1 s;w Y d S )N�
r ) r r r r> r3 r4 r r r r7 �write�encode)rQ �info�ctr& r& r' r � s
"�z SoftFileLock._write_lock_infoc C s| t tt��/ t| j�\}}|r$|�� �� }r,t|d �W d � S W d � dS W d � dS 1 s7w Y dS )z�
The PID of the process holding this lock, read from the lock file.
:returns: the PID as an integer, or ``None`` if the lock file does not exist or cannot be parsed
r N)r r r+ r, r r- r. r5 )r# r8 �_r: r& r& r' r< � s
�
��
��zSoftFileLock.pidc C s | j t�� kS )z�
Whether this lock is held by the current process.
:returns: ``True`` if the lock file exists and contains the current process's PID
)r< r r> �r# r& r& r' �is_lock_held_by_us� s z SoftFileLock.is_lock_held_by_usc C s< t t�� t| j��� W d � dS 1 sw Y dS )zNForcibly break the lock by removing the lock file, regardless of who holds it.N)r r r r r@ rX r& r& r' �
break_lock� s
"�zSoftFileLock.break_lockc C sx | j jd usJ �t�| j j� d | j _tjdkr | �� d S tt�� t | j
�� � W d � d S 1 s5w Y d S )Nr ) r! r" r �closer r �_windows_unlink_with_retryr r r r r@ rX r& r& r' �_release� s
"�zSoftFileLock._releasec C s� d}d}t |�D ]=}z t| j��� W d S tyE } z$|jtthvr,W Y d }~ d S ||d k r;t� |� |d9 }W Y d }~qd }~ww d S )N�
g����MbP?r r) )
�ranger r r@ r r r r r0 �sleep)r# Z max_retriesZ retry_delay�attemptrK r& r& r' r\ � s �
���z'SoftFileLock._windows_unlink_with_retryN)r r )r< r5 r rA )r< r5 r rL )rQ r5 r r )r rL )r rA )�__name__�
__module__� __qualname__�__doc__r( r r2 � staticmethodr6 r7 r �propertyr< rY rZ r] r\ r& r& r& r' r s$
r �path�strr �tuple[str | None, float]c C s� t �| t jtt dd�B tt dd�B �}zt �|�jt �|td �}}W t �|� nt �|� w t |�tkrQt
t �� |� d�|fW d � S 1 sLw Y d |fS )Nr r �
O_NONBLOCKr zutf-8)
r r �O_RDONLYr �fstat�st_mtime�read�_MAX_LOCK_FILE_SIZEr[ r/ r �UnicodeDecodeError�decode)rh rQ r9 �datar& r& r' r, � s &
�r, )rh ri r rj ) �
__future__r r r3 r r0 �
contextlibr r r r r r �pathlibr Z_apir
Z_utilr r rF rH rO r1 rp r r, �__all__r& r& r& r' �<module> s(
<�