|
Server : Apache System : Linux cvar2.toservers.com 3.10.0-962.3.2.lve1.5.73.el7.x86_64 #1 SMP Wed Aug 24 21:31:23 UTC 2022 x86_64 User : njnconst ( 1116) PHP Version : 8.4.18 Disable Function : NONE Directory : /opt/alt/python37/lib/python3.7/site-packages/beaker/__pycache__/ |
Upload File : |
B
��[- � @ s0 d Z ddlZddlZddlZddlZy ddlZW n ek
rL ddlZY nX ye� � dZ
W n6 yddl Z dZ
W n ek
r� dZ
Y nX Y nX ddl m
Z
ddlmZ ddd d
d gZG d d
� d
e�Ze
�� Zd
d� Zdd� Zdd� ZG dd � d e�ZG dd� de�ZG dd� de�ZG dd� de�ZdS )z�Synchronization functions.
File- and mutex-based mutual exclusion synchronizers are provided,
as well as a name-based mutex which locks within an application
based on a string name.
� NFT)�util)� LockError�file_synchronizer�mutex_synchronizer�null_synchronizer�NameLock�
_threadingc @ sD e Zd ZdZe�� ZG dd� de�Zd
dd�Z dd d
�Z
d d � Z dS )r z�a proxy for an RLock object that is stored in a name based
registry.
Multiple threads can get a reference to the same RLock based on the
name alone, and synchronize operations related to that name.
c @ s e Zd Zdd� Zdd� ZdS )zNameLock.NLContainerc C s |rt �� | _n
t �� | _d S )N)r �RLock�lock�Lock)�self� reentrant� r �G/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.py�__init__/ s z NameLock.NLContainer.__init__c C s | j S )N)r
)r r r r �__call__5 s z NameLock.NLContainer.__call__N)�__name__�
__module__� __qualname__r r r r r r � NLContainer. s r NFc C s. |d krt �|�| _nt j�|t j|�| _d S )N)r r �_lock�locks�get)r �
identifierr
r r r r 8 s zNameLock.__init__Tc C s | � � �|�S )N)r �acquire)r �waitr r r r ? s zNameLock.acquirec C s | � � �� d S )N)r �release)r r r r r B s zNameLock.release)NF)T) r r r �__doc__r �WeakValuedRegistryr �objectr r r r r r r r r $ s
c K s t j| |f|| f|�S )N)�_synchronizersZsync_get)r �cls�kwargsr r r �
_synchronizerI s r# c K s& t r d|krt| �S t| tf|�S d S )N�lock_dir)� has_flockr r# �FileSynchronizer)r r" r r r r M s c K s t | tf|�S )N)r# �ConditionSynchronizer)r r" r r r r T s c @ s: e Zd ZdZd dd�Zdd� Zdd� Zd d
� ZeZeZ d S )
r zmA 'null' synchronizer, which provides the :class:`.SynchronizerImpl` interface
without any locking.
Tc C s dS )NTr )r r r r r �acquire_write_lock] s z$null_synchronizer.acquire_write_lockc C s d S )Nr )r r r r �acquire_read_lock` s z#null_synchronizer.acquire_read_lockc C s d S )Nr )r r r r �release_write_lockc s z$null_synchronizer.release_write_lockc C s d S )Nr )r r r r �release_read_lockf s z#null_synchronizer.release_read_lockN)T)
r r r r r( r) r* r+ r r r r r r r X s
c @ s� e Zd ZdZdd� ZG dd� de�Zdd� Zee�Zdd � Z dd d �Z
d
d� Z e Z ddd�Z
e
Zdd� Zdd� Zdd� Zdd� ZdS ) �SynchronizerImplz_Base class for a synchronization object that allows
multiple readers, single writers.
c C s t �� | _d S )N)r � ThreadLocal�_state)r r r r r q s zSynchronizerImpl.__init__c @ s e Zd ZdZdd� ZdS )zSynchronizerImpl.SyncState)�reentrantcount�writing�readingc C s d| _ d| _d| _d S )Nr F)r/ r0 r1 )r r r r r w s z#SynchronizerImpl.SyncState.__init__N)r r r � __slots__r r r r r � SyncStatet s r3 c C s0 | j �� s"t�� }| j �|� |S | j �� S d S )N)r. Zhasr, r3 �putr )r �stater r r r5 | s
zSynchronizerImpl.statec C sL | j }|jrtd��|js"td��|jdkr:| �� d|_| jd8 _d S )Nzlock is in writing statez lock is not in reading state� F)r5 r0 r r1 r/ �do_release_read_lock)r r5 r r r r+ � s
z"SynchronizerImpl.release_read_lockTc C sd | j }|jrtd��|jdkrH| �|�}|s0|rD| jd7 _d|_|S |jr`| jd7 _dS d S )Nzlock is in writing stater r6 T)r5 r0 r r/ �do_acquire_read_lockr1 )r r r5 �xr r r r) � s
z"SynchronizerImpl.acquire_read_lockc C sL | j }|jrtd��|js"td��|jdkr:| �� d|_| jd8 _d S )Nzlock is in reading statez lock is not in writing stater6 F)r5 r1 r r0 r/ �do_release_write_lock)r r5 r r r r* � s
z#SynchronizerImpl.release_write_lockc C sd | j }|jrtd��|jdkrH| �|�}|s0|rD| jd7 _d|_|S |jr`| jd7 _dS d S )Nzlock is in reading stater r6 T)r5 r1 r r/ �do_acquire_write_lockr0 )r r r5 r9 r r r r( � s
z#SynchronizerImpl.acquire_write_lockc C s
t � �d S )N)�NotImplementedError)r r r r r7 � s z%SynchronizerImpl.do_release_read_lockc C s
t � �d S )N)r< )r r r r r r8 � s z%SynchronizerImpl.do_acquire_read_lockc C s
t � �d S )N)r< )r r r r r: � s z&SynchronizerImpl.do_release_write_lockc C s
t � �d S )N)r< )r r r r r r; � s z&SynchronizerImpl.do_acquire_write_lockN)T)T)r r r r r r r3 r5 �propertyr+ r) r* r r( r r7 r8 r: r; r r r r r, l s
r, c sh e Zd ZdZ� fdd�Zdd� Zee�Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dd� Z dd� Z
� ZS )r& z/A synchronizer which locks using flock().
c sV t t| ��� t�� | _|d kr*t�� }n|}tj||gdd�| _ t
j � | j �| _
d S )Nz.lock)� extension)�superr& r r r- �_filedescriptor�tempfile�
gettempdirZ encoded_path�filename�os�path�dirnamer$ )r r r$ )� __class__r r r � s
zFileSynchronizer.__init__c C s
| j �� S )N)r@ r )r r r r � _filedesc� s zFileSynchronizer._filedescc C s t j�| j�st�| j� d S )N)rD rE �existsr$ r Zverify_directory)r r r r �
_ensuredir� s zFileSynchronizer._ensuredirc C s4 | j }|d kr0| �� t�| j|�}| j�|� |S )N)rH rJ rD �openrC r@ r4 )r �mode�filedescriptorr r r �_open� s zFileSynchronizer._openc C sp | � tjtjB �}|sZyt�|tjtjB � dS tk
rV t� |� | j
� � dS X nt�|tj� dS d S )NTF) rN rD �O_CREAT�O_RDONLY�fcntl�flockZLOCK_SH�LOCK_NB�IOError�closer@ �remove)r r rM r r r r8 � s
z%FileSynchronizer.do_acquire_read_lockc C sp | � tjtjB �}|sZyt�|tjtjB � dS tk
rV t� |� | j
� � dS X nt�|tj� dS d S )NTF) rN rD rO �O_WRONLYrQ rR ZLOCK_EXrS rT rU r@ rV )r r rM r r r r; s
z&FileSynchronizer.do_acquire_write_lockc C s | � � d S )N)�_release_all_locks)r r r r r7 s z%FileSynchronizer.do_release_read_lockc C s | � � d S )N)rX )r r r r r: s z&FileSynchronizer.do_release_write_lockc C s4 | j }|d k r0t�|tj� t�|� | j�� d S )N)rH rQ rR ZLOCK_UNrD rU r@ rV )r rM r r r rX s
z#FileSynchronizer._release_all_locks)r r r r r rH r= rJ rN r8 r; r7 r: rX �
__classcell__r r )rG r r& � s r& c sD e Zd ZdZ� fdd�Zd
dd�Zdd� Zdd d
�Zd d � Z� Z S )r' z!a synchronizer using a Condition.c s. t t| ��� d| _d | _t�t�� �| _d S )Nr ) r? r' r �asynch�current_sync_operationr � Conditionr � condition)r r )rG r r r # s z ConditionSynchronizer.__init__Tc C sd | j �� z@|r,x(| jd k r(| j �� qW n| jd k r:dS | jd7 _W d | j �� X |s`dS d S )NFr6 T)r] r r[ r rZ r )r r r r r r8 / s
z*ConditionSynchronizer.do_acquire_read_lockc C s` | j �� zD| jd8 _| jdkr:| jd k rL| j �� n| jdk rLtd��W d | j �� X d S )Nr6 r z7Synchronizer error - too many release_read_locks called)r] r rZ r[ � notifyAllr r )r r r r r7 C s
z*ConditionSynchronizer.do_release_read_lockc C s� | j �� z`|r,x(| jd k r(| j �� qW n| jd k r:dS t�� | _| jdkrh|r^| j �� n
d | _dS W d | j �� X |s�dS d S )NFr T)r] r r[ r r �
currentThreadrZ r )r r r r r r; U s
z+ConditionSynchronizer.do_acquire_write_lockc C sF | j �� z*| jt�� k r"td��d | _| j �� W d | j �� X d S )Nz>Synchronizer error - current thread doesnt have the write lock)r] r r[ r r_ r r^ r )r r r r r: y s
z+ConditionSynchronizer.do_release_write_lock)T)T)
r r r r r r8 r7 r; r: rY r r )rG r r' s
$r' ) r �errnorD �sysrA � threadingr � ImportErrorZdummy_threading�getwindowsversionr% rQ �beakerr Zbeaker.exceptionsr �__all__r r r r r# r r r r, r& r' r r r r �<module> s< "fN