OXIESEC PANEL
- Current Dir:
/
/
opt
/
gsutil
/
third_party
/
fasteners
/
fasteners
/
__pycache__
Server IP: 2a02:4780:11:1594:0:ef5:22d7:a
Upload:
Create Dir:
Name
Size
Modified
Perms
📁
..
-
02/11/2025 08:19:48 AM
rwxr-xr-x
📄
__init__.cpython-39.pyc
485 bytes
02/11/2025 08:19:48 AM
rw-r--r--
📄
_utils.cpython-39.pyc
3.98 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
lock.cpython-39.pyc
8.18 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
process_lock.cpython-39.pyc
7.55 KB
02/11/2025 08:19:48 AM
rw-r--r--
Editing: lock.cpython-39.pyc
Close
a V�EVJ, � @ s� d dl Z d dlZd dlZd dlmZ d dlZzd dlZd dlmZ W n e y^ dZdZY n0 dd� Z dd� Z G dd � d e �Z ejd d � �Zd d � ZdS )� N)�_utils)�patcherc s8 � fdd�}� s| s|S t | �dkr0|| d �S |S dS )a< Acquires & releases a read lock around call into decorated method. NOTE(harlowja): if no attribute name is provided then by default the attribute named '_lock' is looked for (this attribute is expected to be a :py:class:`.ReaderWriterLock`) in the instance object this decorator is attached to. c s( �� dd�� t���� �fdd��}|S )N�lock�_lockc sL t | � �}|�� �& �| g|�R i |��W d � S 1 s>0 Y d S �N)�getattr� read_lock��self�args�kwargsZrw_lock�� attr_name�f� �3/opt/gsutil/third_party/fasteners/fasteners/lock.py�wrapper2 s z/read_locked.<locals>.decorator.<locals>.wrapper��get�six�wraps�r r �r r r � decorator/ s z read_locked.<locals>.decorator� r N��len�r r r r r r � read_locked& s r c s8 � fdd�}� s| s|S t | �dkr0|| d �S |S dS )aD Acquires & releases a write lock around call into decorated method. NOTE(harlowja): if no attribute name is provided then by default the attribute named '_lock' is looked for (this attribute is expected to be a :py:class:`.ReaderWriterLock` object) in the instance object this decorator is attached to. c s( �� dd�� t���� �fdd��}|S )Nr r c sL t | � �}|�� �& �| g|�R i |��W d � S 1 s>0 Y d S r )r � write_lockr r r r r Q s z0write_locked.<locals>.decorator.<locals>.wrapperr r r r r r N s z write_locked.<locals>.decoratorr r Nr r r r r � write_lockedE s r c @ sz e Zd ZdZdZdZedd� �Zej dfdd�Z e d d � �Z dd d �Z e dd� �Zdd� Zejdd� �Zejdd� �ZdS )�ReaderWriterLocka A reader/writer lock. This lock allows for simultaneous readers to exist but only one writer to exist for use-cases where it is useful to have such types of locks. Currently a reader can not escalate its read lock to a write lock and a writer can not acquire a read lock while it is waiting on the write lock. In the future these restrictions may be relaxed. This can be eventually removed if http://bugs.python.org/issue8800 ever gets accepted into the python standard threading library... �w�rc C s& t d ur td ur t�d�r t jS tjS )N�thread)�eventlet�eventlet_patcherZis_monkey_patchedZ getcurrent� threading�current_threadr r r r � _fetch_current_thread_functorz s z.ReaderWriterLock._fetch_current_thread_functorNc C s8 d | _ t�� | _i | _|� | _|d u r.| �� }|| _d S r )�_writer� collections�deque�_pending_writers�_readers�_condr) �_current_thread)r Z condition_clsZcurrent_thread_functorr r r �__init__� s zReaderWriterLock.__init__c C s t | j�S )z@Returns if there are writers waiting to become the *one* writer.)�boolr- �r r r r �has_pending_writers� s z$ReaderWriterLock.has_pending_writersTc C s, | � � }| j|krdS |r$|| jv S dS dS )z?Returns if the caller is the active writer or a pending writer.TFN)r0 r* r- )r � check_pending�mer r r � is_writer� s zReaderWriterLock.is_writerc C s | j dur| jS | jr | jS dS )z9Returns whether the lock is locked by a writer or reader.N)r* �WRITERr. �READERr3 r r r �owner� s zReaderWriterLock.ownerc C s | � � }|| jv S )z,Returns if the caller is one of the readers.)r0 r. )r r6 r r r � is_reader� s zReaderWriterLock.is_readerc c s� | � � }|| jv r td| ��| j�h | jdu s:| j|krrz| j| d | j|< W q~ tyn d| j|< Y q~0 q~| j�� q&W d � n1 s�0 Y z�| V W | j�` z2| j| }|dkr�|d | j|< n | j�|� W n ty� Y n0 | j� � W d � n1 �s0 Y n~| j�d z4| j| }|dk�rN|d | j|< n | j�|� W n t�yp Y n0 | j� � W d � n1 �s�0 Y 0 dS )z�Context manager that grants a read lock. Will wait until no active or pending writers. Raises a ``RuntimeError`` if a pending writer tries to acquire a read lock. zFWriter %s can not acquire a read lock while waiting for the write lockNr ) r0 r- � RuntimeErrorr/ r* r. �KeyError�wait�pop� notify_all)r r6 Z me_instancesr r r r � sB � * ,� zReaderWriterLock.read_lockc c s* | � � }| jdd�}| �� r,|s,td| ��|r8| V n�| j�\ | j�|� t| j�dkr�| j du r�| jd |kr�| j� � | _ q�| j� � qLW d � n1 s�0 Y z@| V W | j� d| _ | j� � W d � n1 s�0 Y n:| j� d| _ | j� � W d � n1 �s0 Y 0 dS )z�Context manager that grants a write lock. Will wait until no active readers. Blocks readers after acquiring. Raises a ``RuntimeError`` if an active reader attempts to acquire a lock. F)r5 z4Reader %s to writer privilege escalation not allowedr N) r0 r7 r; r< r/ r- �appendr r. r* �popleftr> r@ )r r6 Z i_am_writerr r r r � s. � **�zReaderWriterLock.write_lock)T)�__name__� __module__� __qualname__�__doc__r8 r9 � staticmethodr) r' � Conditionr1 �propertyr4 r7 r: r; � contextlib�contextmanagerr r r r r r r! d s$ � +r! c c s4 | � d�}z|V W |r0| �� n|r.| �� 0 dS )zDAttempts to acquire a lock, and auto releases if acquired (on exit).FN)�acquire�release)r Z was_lockedr r r �try_lock� s �rN c s8 � fdd�}� s| s|S t | �dkr0|| d �S |S dS )a A locking **method** decorator. It will look for a provided attribute (typically a lock or a list of locks) on the first argument of the function decorated (typically this is the 'self' object) and before executing the decorated function it activates the given lock or list of locks as a context manager, automatically releasing that lock on exit. NOTE(harlowja): if no attribute name is provided then by default the attribute named '_lock' is looked for (this attribute is expected to be the lock/list of locks object/s) in the instance object this decorator is attached to. NOTE(harlowja): a custom logger (which will be used if lock release failures happen) can be provided by passing a logger instance for keyword argument ``logger``. c s4 �� dd�� �� d��t���� ��fdd��}|S )Nr r �loggerc s� t | � �}t|ttf�r�tj�d��T}t|�D ]$\}}|�|�s.t� d|d ��q.�| g|�R i |��W d � S 1 s~0 Y n>|}|�& �| g|�R i |��W d � S 1 s�0 Y d S )N)rO zUnable to acquire lock %sr ) r � isinstance�tuple�listr Z LockStack� enumerate� acquire_lockr' � ThreadError)r r r � attr_value�stack�ir �r r rO r r r % s �6z*locked.<locals>.decorator.<locals>.wrapperr r r rY r r ! s zlocked.<locals>.decoratorr r Nr r r r r �locked s rZ )r+ rJ r' � fastenersr r r% r r& � ImportErrorr r �objectr! rK rN rZ r r r r �<module> s"