Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
fasteners
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: lock.cpython-310.pyc
o V�EVJ, � @ s� d dl Z d dlZd dlZd dlmZ d dlZz d dlZd dlmZ W n e y/ dZdZY nw dd� Z dd� Z G dd � d e �Z ejd d � �Zd d � ZdS )� N)�_utils)�patcherc �4 � fdd�}� s | s |S t | �dkr|| d �S |S )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 �( �� dd�� t���� �fdd��}|S )N�lock�_lockc �L t | � �}|�� � �| g|�R i |��W d � S 1 s w Y d S �N)�getattr� read_lock��self�args�kwargs�rw_lock�� attr_name�f� �0/usr/lib/python3/dist-packages/fasteners/lock.py�wrapper2 � $�z/read_locked.<locals>.decorator.<locals>.wrapper��get�six�wraps�r r �r r r � decorator/ � z read_locked.<locals>.decorator� r ��len�r r r r r r � read_locked& � r$ c r )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 r )Nr r c r r )r � write_lockr r r r r Q r z0write_locked.<locals>.decorator.<locals>.wrapperr r r r r r N r z write_locked.<locals>.decoratorr r r! r# r r r � write_lockedE r% 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 urtd urt�d�rt jS tjS )N�thread)�eventlet�eventlet_patcher�is_monkey_patched� 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�_condr2 �_current_thread)r � condition_cls�current_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.)�boolr6 �r r r r �has_pending_writers� s z$ReaderWriterLock.has_pending_writersTc C s( | � � }| j|kr dS |r|| jv S dS )z?Returns if the caller is the active writer or a pending writer.TF)r9 r3 r6 )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)r3 �WRITERr7 �READERr> r r r �owner� s zReaderWriterLock.ownerc C s | � � }|| jv S )z,Returns if the caller is one of the readers.)r9 r7 )r rA r r r � is_reader� s zReaderWriterLock.is_readerc c s� � | � � }|| jv rtd| ��| j�5 | jdu s | j|kr;z | j| d | j|< W n ty9 d| j|< Y nw n| j�� qW d � n1 sKw Y zB| V W | j�1 z| j| }|dkrk|d | j|< n| j�|� W n ty{ Y nw | j� � W d � dS 1 s�w Y dS | j�0 z| j| }|dkr�|d | j|< n| j�|� W n ty� Y nw | j� � W d � w 1 s�w Y w )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 lockTNr ) r9 r6 � RuntimeErrorr8 r3 r7 �KeyError�wait�pop� notify_all)r rA � me_instancesr r r r � sX � � � � � � � *� � � �zReaderWriterLock.read_lockc c s. � | � � }| jdd�}| �� r|std| ��|r | V dS | j�/ | j�|� t| j�dkrC| j du rC| jd |krC| j� � | _ n| j� � q)W d � n1 sSw Y z"| V W | j� d| _ | j� � W d � dS 1 stw Y dS | j� d| _ | j� � W d � w 1 s�w Y w )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)r@ z4Reader %s to writer privilege escalation not allowedTr N) r9 rB rF rG r8 r6 �appendr" r7 r3 �popleftrI rK )r rA � i_am_writerr r r r& � s: � � � � *� �zReaderWriterLock.write_lock)T)�__name__� __module__� __qualname__�__doc__rC rD � staticmethodr2 r0 � Conditionr< �propertyr? rB rE rF � contextlib�contextmanagerr r& r r r r r( d s& � +r( c c s: � | � d�}z|V W |r| �� dS dS |r | �� w w )zDAttempts to acquire a lock, and auto releases if acquired (on exit).FN)�acquire�release)r � was_lockedr r r �try_lock� s � � �r\ c r )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�rFtj�d��*}t|�D ]\}}|�|�s)t� d|d ��q�| g|�R i |��W d � S 1 s?w Y d S |}|� �| g|�R i |��W d � S 1 s`w Y d S )N)r] zUnable to acquire lock %sr ) r � isinstance�tuple�listr � LockStack� enumerate� acquire_lockr0 � ThreadError)r r r � attr_value�stack�ir �r r r] r r r % s ��$�$�z*locked.<locals>.decorator.<locals>.wrapperr r r rh r r ! s zlocked.<locals>.decoratorr r r! r# r r r �locked s ri )r4 rW r0 � fastenersr r r, r r- � ImportErrorr$ r' �objectr( rX r\ ri r r r r �<module> s& �
Save
Cancel