| Server IP : 192.158.238.246 / Your IP : 18.117.156.19 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python37/lib/python3.7/site-packages/beaker/ext/__pycache__/ |
Upload File : |
B
��[D � @ s� d dl mZ ddlmZmZ ddlmZ ddlmZm Z ddl
m Z ddl m
Z
mZmZ ddlZd Zi Zdd d �Zd
d� ZG dd� de�ZG dd� de�ZG dd� de�ZdS )� )�PY2� )�NamespaceManager� Container)�sha1)�InvalidCacheBackendError�MissingCacheParameter)�file_synchronizer)�verify_directory�SyncDict�parse_memcached_behaviorsN� �autoc sh | t krt | S dd� �dd� �dd� �dd� � � ���fd d
�}���� |d �}|| � t | < }|S ) Nc S s dd l a t S )Nr )�pylibmc� r r �E/opt/alt/python37/lib/python3.7/site-packages/beaker/ext/memcached.py�_pylibmc s z _load_client.<locals>._pylibmcc S s dd l a t�d� t S )Nr z]cmemcache is known to have serious concurrency issues; consider using 'memcache' or 'pylibmc')� cmemcache�warnings�warnr r r r �
_cmemcache s
z _load_client.<locals>._cmemcachec S s dd l a t S )Nr )�memcacher r r r � _memcache s z _load_client.<locals>._memcachec S s dd l a t S )Nr )�
bmemcachedr r r r � _bmemcached% s z!_load_client.<locals>._bmemcachedc s> x8���� fD ] } y| � S t k
r, Y qX qW td��d S )NzQMemcached cache backend requires one of: 'pylibmc' or 'memcache' to be installed.)� ImportErrorr )Z_client)r r r r r r �_auto* s
z_load_client.<locals>._auto)r r r r r )� _client_libs)�namer �clientsZclibr )r r r r r � _load_client s r c C s | dkp|j �d�S )Nr )�__name__�
startswith)Zmemcache_module_config�memcache_clientr r r �_is_configured_for_pylibmc@ s r$ c @ sz e Zd ZdZe� Zdd� Zd dd�Zdd � Zd
d � Z d d
� Z
dd� Z dd� Z d dd�Z
dd� Zdd� Zdd� Zdd� ZdS ) �MemcachedNamespaceManagerzKProvides the :class:`.NamespaceManager` API over a memcache client library.c O s6 |� dd�}t|�}t||�r(t�t�S t�t�S d S )N�memcache_moduler )�popr r$ �object�__new__�PyLibMCNamespaceManagerr% )�cls�args�kwr& r# r r r r) J s
z!MemcachedNamespaceManager.__new__r Nc K s| t �| |� t| }|s td��d | _|r2|| _n|r@|d | _| jrPt| j� t||�sxtj� ||f|j
|� d��| _ d S )Nzurl is requiredz/container_mcd_lock�;)
r �__init__r r �lock_dirr
r$ r% r �get�Client�split�mc)�self� namespace�urlr& Zdata_dirr0 r- �_memcache_moduler r r r/ T s
z"MemcachedNamespaceManager.__init__c C s t d| j|f | jd�S )Nz!memcachedcontainer/funclock/%s/%s)�
identifierr0 )r r6 r0 )r5 �keyr r r �get_creation_lockq s z+MemcachedNamespaceManager.get_creation_lockc C sT t |t�s|�d�}| jd | �dd�}t|�tkrPtsD|�d�}t |��
� }|S )N�ascii�_� u ·zutf-8) �
isinstance�str�decoder6 �replace�len�MAX_KEY_LENGTHr �encoder � hexdigest)r5 r: Z formated_keyr r r � _format_keyv s
z%MemcachedNamespaceManager._format_keyc C s | j �| �|��S )N)r4 r1 rG )r5 r: r r r � __getitem__� s z%MemcachedNamespaceManager.__getitem__c C s | j �| �|��}|d k S )N)r4 r1 rG )r5 r: �valuer r r � __contains__� s z&MemcachedNamespaceManager.__contains__c C s || kS )Nr )r5 r: r r r �has_key� s z!MemcachedNamespaceManager.has_keyc C s6 |r | j j| �|�||d� n| j �| �|�|� d S )N)�time)r4 �setrG )r5 r: rI �
expiretimer r r � set_value� s z#MemcachedNamespaceManager.set_valuec C s | � ||� d S )N)rO )r5 r: rI r r r � __setitem__� s z%MemcachedNamespaceManager.__setitem__c C s | j �| �|�� d S )N)r4 �deleterG )r5 r: r r r � __delitem__� s z%MemcachedNamespaceManager.__delitem__c C s | j �� d S )N)r4 � flush_all)r5 r r r � do_remove� s z#MemcachedNamespaceManager.do_removec C s t d��d S )Nz=Memcache caching does not support iteration of all cache keys)�NotImplementedError)r5 r r r �keys� s z MemcachedNamespaceManager.keys)r NN)N)r! �
__module__� __qualname__�__doc__r r r) r/ r; rG rH rJ rK rO rP rR rT rV r r r r r% E s
r% c s` e Zd ZdZe� Z� fdd�Zdd� Zdd� Zdd � Z dd d �Z
d
d� Z dd� Z dd� Z
� ZS )r* z)Provide thread-local support for pylibmc.c
s� t t| �j||� |�dd�}t| }|�dd�}|�dd �}|�dd �}|�d�}t|�} tjj||f|j|� d�| |d k||d
�| _
tj �||ft j
| j
�| _d S ) Nr& r �protocol�text�username�passwordr7 r. �binary)Zservers� behaviorsr^ r\ r] )�superr* r/ r1 r r r% r r2 r3 r4 �poolsr ZThreadMappedPool�pool)
r5 �argr- r& r8 rZ r\ r] r7 r_ )� __class__r r r/ � s"
z PyLibMCNamespaceManager.__init__c C s& | j �� �}|�| �|��S Q R X d S )N)rb �reserver1 rG )r5 r: r4 r r r rH � s z#PyLibMCNamespaceManager.__getitem__c C s. | j �� �}|�| �|��}|d k S Q R X d S )N)rb re r1 rG )r5 r: r4 rI r r r rJ � s z$PyLibMCNamespaceManager.__contains__c C s || kS )Nr )r5 r: r r r rK � s z PyLibMCNamespaceManager.has_keyNc C sH | j �� �4}|r(|j| �|�||d� n|�| �|�|� W d Q R X d S )N)rL )rb re rM rG )r5 r: rI rN r4 r r r rO � s z!PyLibMCNamespaceManager.set_valuec C s | � ||� d S )N)rO )r5 r: rI r r r rP � s z#PyLibMCNamespaceManager.__setitem__c C s* | j �� �}|�| �|�� W d Q R X d S )N)rb re rQ rG )r5 r: r4 r r r rR � s z#PyLibMCNamespaceManager.__delitem__c C s" | j �� �}|�� W d Q R X d S )N)rb re rS )r5 r4 r r r rT � s z!PyLibMCNamespaceManager.do_remove)N)r! rW rX rY r ra r/ rH rJ rK rO rP rR rT �
__classcell__r r )rd r r* � s
r* c @ s e Zd ZdZeZdS )�MemcachedContainerzAContainer class which invokes :class:`.MemcacheNamespaceManager`.N)r! rW rX rY r% Znamespace_classr r r r rg � s rg )r )�_compatr Zbeaker.containerr r Zbeaker.crypto.utilr Zbeaker.exceptionsr r Zbeaker.synchronizationr Z beaker.utilr
r r r rD r r r$ r% r* rg r r r r �<module> s
1Z9