[ Root System Explorer ]
Location:
Root
/
proc
/
thread-self
/
root
/
proc
/
thread-self
/
root
/
opt
/
gsutil
/
third_party
/
fasteners
/
fasteners
/
__pycache__
+ Folder
+ File
Upload
Editing: process_lock.cpython-39.pyc
a V�EV�! � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ e�e �Z dd� Z G dd� de �Z G dd� de �ZG d d � d e �Zejd kr�d dlZeZn d dlZeZd d � ZdS )� N)�_utilsc C s� zt �| � W nl tyz } zT|jtjkrJt j�| �s:� qfW Y d}~dS n |jtjkrdW Y d}~dS � W Y d}~nd}~0 0 dS dS )zfCreate a directory (and any ancestor directories required). :param path: Directory to create NFT)�os�makedirs�OSError�errno�EEXIST�path�isdir�EISDIR)r �e� r �;/opt/gsutil/third_party/fasteners/fasteners/process_lock.py� _ensure_tree s r c @ s� e Zd ZdZdZdZejdfdd�Zdd� Z d d � Z d eedfd d �Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� ZdS ) �_InterProcessLockaT An interprocess locking implementation. This is a lock implementation which allows multiple locks, working around issues like http://bugs.debian.org/cgi-bin/bugreport.cgi?bug=632857 and does not require any cleanup. Since the lock is always held on a file descriptor rather than outside of the process, the lock gets dropped automatically if the process crashes, even if ``__exit__`` is not executed. There are no guarantees regarding usage by multiple threads in a single process here. This lock works only between processes. Note these locks are released when the descriptor is closed, so it's not safe to close the file descriptor while another thread holds the lock. Just opening and closing the lock file can break synchronization, so lock files must be accessed only using this abstraction. g�������?g{�G�z�?Nc C s* d | _ || _d| _|| _t�|t�| _d S )NF)�lockfiler �acquired� sleep_funcr �pick_first_not_none�LOG�logger)�selfr r r r r r �__init__U s z_InterProcessLock.__init__c C s� z | � � W np ty| } zX|jtjtjfv rR|r:|�� rHW Y d }~dS t�� �nt� d| j |d� ��W Y d }~nd }~0 0 dS d S )NFz9Unable to acquire lock on `%(path)s` due to %(exception)s)r � exceptionT) �trylock�IOErrorr ZEACCES�EAGAIN�expiredr � RetryAgain� threading� ThreadErrorr )r �blocking�watchr r r r � _try_acquire\ s �� z _InterProcessLock._try_acquirec C sT t j�| j�}|r0t|�}|r0| j�tjd|� | jd u sB| jj rPt | jd�| _d S )NzCreated lock base path `%s`�a) r r �dirnamer r �logr �BLATHERr �closed�open)r ZbasedirZ made_basedirr r r �_do_openp s �z_InterProcessLock._do_openTc C s� |dk rt d��|dur(|dk r(t d��||kr4|}| �� tj|d�}tj||| j|d�}|� || j||�}W d � n1 s�0 Y |s�d| _dS d| _| j� tj d | j |� � |j � dS dS ) a� Attempt to acquire the given lock. :param blocking: whether to wait forever to try to acquire the lock :type blocking: bool :param delay: when blocking this is the delay time in seconds that will be added after each failed acquisition :type delay: int/float :param max_delay: the maximum delay to have (this limits the accumulated delay(s) added after each failed acquisition) :type max_delay: int/float :param timeout: an optional timeout (limits how long blocking will occur for) :type timeout: int/float :returns: whether or not the acquisition succeeded :rtype: bool r z+Delay must be greater than or equal to zeroNz-Timeout must be greater than or equal to zero)�duration)r r! FTzHAcquired file lock `%s` after waiting %0.3fs [%s attempts were required])� ValueErrorr) r � StopWatch�Retryr r" r r r% r& r �elapsed�attempts)r r �delay� max_delay�timeoutr! �r�gottenr r r �acquire} s. �, �z_InterProcessLock.acquirec C s | j d ur| j �� d | _ d S �N)r �close�r r r r � _do_close� s z_InterProcessLock._do_closec C s | � � | S r6 )r5 r8 r r r � __enter__� s z_InterProcessLock.__enter__c C s� | j st�d��z | �� W n" ty> | j�d| j� Y nL0 d| _ z | �� W n" tyt | j�d| j� Y n0 | j� t j d| j� dS )z%Release the previously acquired lock.z$Unable to release an unacquired lockz1Could not unlock the acquired lock opened on `%s`Fz.Could not close the file handle opened on `%s`z*Unlocked and closed file lock open on `%s`N) r r r �unlockr r r r r9 r% r r& r8 r r r �release� s& � � �z_InterProcessLock.releasec C s | � � d S r6 )r< )r �exc_typeZexc_val�exc_tbr r r �__exit__� s z_InterProcessLock.__exit__c C s t j�| j�S )z<Checks if the path that this lock exists at actually exists.)r r �existsr8 r r r r@ � s z_InterProcessLock.existsc C s t � �d S r6 ��NotImplementedErrorr8 r r r r � s z_InterProcessLock.trylockc C s t � �d S r6 rA r8 r r r r; � s z_InterProcessLock.unlock)�__name__� __module__� __qualname__�__doc__Z MAX_DELAYZDELAY_INCREMENT�time�sleepr r" r) r5 r9 r: r< r? r@ r r; r r r r r 4 s" � +r c @ s e Zd ZdZdd� Zdd� ZdS )� _WindowsLockz?Interprocess lock implementation that works on windows systems.c C s t �| j�� t jd� d S �N� )�msvcrt�lockingr �filenoZLK_NBLCKr8 r r r r � s z_WindowsLock.trylockc C s t �| j�� t jd� d S rJ )rL rM r rN ZLK_UNLCKr8 r r r r; � s z_WindowsLock.unlockN�rC rD rE rF r r; r r r r rI � s rI c @ s e Zd ZdZdd� Zdd� ZdS )� _FcntlLockz=Interprocess lock implementation that works on posix systems.c C s t �| jt jt jB � d S r6 )�fcntl�lockfr ZLOCK_EXZLOCK_NBr8 r r r r � s z_FcntlLock.trylockc C s t �| jt j� d S r6 )rQ rR r ZLOCK_UNr8 r r r r; � s z_FcntlLock.unlockNrO r r r r rP � s rP �ntc s t | �� � fdd�}|S )zSAcquires & releases a interprocess lock around call into decorated function.c s t �� �� �fdd��}|S )Nc s6 �� � | i |��W d � S 1 s(0 Y d S r6 r )�args�kwargs)�f�lockr r �wrapper� s z7interprocess_locked.<locals>.decorator.<locals>.wrapper)�six�wraps)rV rX �rW )rV r � decorator� s z&interprocess_locked.<locals>.decorator)�InterProcessLock)r r\ r r[ r �interprocess_locked� s r^ )r �loggingr r rG rY � fastenersr � getLoggerrC r r �objectr rI rP �namerL r] rQ r^ r r r r �<module> s$ "
SAVE CHANGES
[ CANCEL ]
Name
Type
Actions
.. (Parent Directory)
📄 __init__.cpython-39.pyc
FILE
Ren
[EDIT]
DEL
📄 _utils.cpython-39.pyc
FILE
Ren
[EDIT]
DEL
📄 lock.cpython-39.pyc
FILE
Ren
[EDIT]
DEL
📄 process_lock.cpython-39.pyc
FILE
Ren
[EDIT]
DEL