File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/filelock/__pycache__/_soft.cpython-310.pyc
Back
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( <�
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings