File: //usr/lib/python3/dist-packages/django/core/cache/backends/__pycache__/memcached.cpython-310.pyc
o
3�aR$ � @ s� d Z ddlZddlZddlZddlZddlmZmZmZm Z ddl
m Z ddl m
Z
G dd� de�ZG dd � d e�ZG d
d � d e�ZG d d
� d
e�ZdS )zMemcached cache backend� N)�DEFAULT_TIMEOUT� BaseCache�InvalidCacheKey�memcache_key_warnings)�RemovedInDjango41Warning)�cached_propertyc s� e Zd Z� fdd�Zedd� �Zedd� �Zefdd�Z ed fd
d �Z
d%d d
�Z ed fdd�Z ed fdd�Z
d&dd�Zd&dd�Zdd� Zd'dd�Zd'dd �Zed fd d �Zd&d d �Zd!d"� Zd#d$� Z� ZS )(�BaseMemcachedCachec sT t � �|� t|t�rt�d|�| _n|| _|| _|| _|j | _
|� d�p&i | _ d S )Nz[;,]�OPTIONS)
�super�__init__�
isinstance�str�re�split�_servers� LibraryValueNotFoundException�_lib�Client�_class�get�_options)�self�server�params�library�value_not_found_exception�� __class__� �F/usr/lib/python3/dist-packages/django/core/cache/backends/memcached.pyr s
zBaseMemcachedCache.__init__c C s | j S �N)r �r r r r �client_servers s z!BaseMemcachedCache.client_serversc C s | j | jfi | j��S )zQ
Implement transparent thread-safe access to a memcached client.
)r r" r r! r r r �_cache# s zBaseMemcachedCache._cachec C sJ |t kr| j}|du r
dS t|�dkrd}|dkr!|tt�� �7 }t|�S )z�
Memcached deals with long (> 30 days) timeouts in a special
way. Call this function to obtain a safe value for your timeout.
Nr ���i �' )r �default_timeout�int�time)r �timeoutr r r �get_backend_timeout* s z&BaseMemcachedCache.get_backend_timeoutNc C s. | j ||d�}| �|� | j�||| �|��S �N��version)�make_key� validate_keyr# �addr) �r �key�valuer( r, r r r r/ E s
zBaseMemcachedCache.addc C s& | j ||d�}| �|� | j�||�S r* �r- r. r# r )r r1 �defaultr, r r r r J s
zBaseMemcachedCache.getc C sB | j ||d�}| �|� | j�||| �|��s | j�|� d S d S r* )r- r. r# �setr) �deleter0 r r r r5 O s
�zBaseMemcachedCache.setc C s0 | j ||d�}| �|� t| j�|| �|���S r* )r- r. �boolr# �touchr) �r r1 r( r, r r r r8 V s
zBaseMemcachedCache.touchc C s( | j ||d�}| �|� t| j�|��S r* )r- r. r7 r# r6 �r r1 r, r r r r6 [ s
zBaseMemcachedCache.deletec sN ��fdd�|D �� � D ]}�� |� q �j�� �� �}� fdd�|�� D �S )Nc s i | ]
}� j |�d �|�qS �r+ �r- ��.0r1 �r r, r r �
<dictcomp>a s z/BaseMemcachedCache.get_many.<locals>.<dictcomp>c s i | ] \}}� | |�qS r r )r> �k�v)�key_mapr r r@ e � )r. r# � get_multi�keys�items)r rF r, r1 �retr )rC r r, r �get_many` s
zBaseMemcachedCache.get_manyc K � | j �� d S r )r# �disconnect_all�r �kwargsr r r �closeg s zBaseMemcachedCache.close� c C �t | j ||d�}| �|� |dk r| j�|| �S z | j�||�}W n | jy- d }Y nw |d u r8td| ��|S �Nr+ r zKey '%s' not found)r- r. r# �decr�incrr �
ValueError�r r1 �deltar, �valr r r rS k �
� zBaseMemcachedCache.incrc C rP rQ )r- r. r# rS rR r rT rU r r r rR | rX zBaseMemcachedCache.decrc sh i }i � |� � D ]\}}| j||d�}| �|� |||< |� |< q| j�|| �|��}� fdd�|D �S )Nr+ c s g | ]}� | �qS r r )r> rA ��
original_keysr r �
<listcomp>� s z/BaseMemcachedCache.set_many.<locals>.<listcomp>)rG r- r. r# � set_multir) ) r �datar( r, � safe_datar1 r2 �safe_key� failed_keysr rY r �set_many� s
zBaseMemcachedCache.set_manyc s8 � �fdd�|D �}|D ]}� � |� q � j�|� d S )Nc s g | ] }� j |�d ��qS r; r< r= r? r r r[ � rD z2BaseMemcachedCache.delete_many.<locals>.<listcomp>)r. r# � delete_multi)r rF r, r1 r r? r � delete_many� s z BaseMemcachedCache.delete_manyc C rJ r )r# � flush_allr! r r r �clear� s zBaseMemcachedCache.clearc C s t |�D ]}t|��d S r )r r )r r1 �warningr r r r. � s �z BaseMemcachedCache.validate_key�NNr )rO N)�__name__�
__module__� __qualname__r �propertyr" r r# r r) r/ r r5 r8 r6 rI rN rS rR ra rc re r. �
__classcell__r r r r r s(
r c s8 e Zd ZdZdZ� fdd�Zd dd�Zd
dd�Z� ZS ) �MemcachedCachez;An implementation of a cache binding using python-memcachedNc sB t jdtdd� dd l}t� j|||td� dtji| j �| _ d S )NzJMemcachedCache is deprecated in favor of PyMemcacheCache and PyLibMCCache.� )�
stacklevelr �r r �pickleProtocol)
�warnings�warnr �memcacher
r rT �pickle�HIGHEST_PROTOCOLr )r r r rt r r r r � s �zMemcachedCache.__init__c C s4 | j ||d�}| �|� | j�|�}|d u r|S |S r* r3 )r r1 r4 r, rW r r r r � s
zMemcachedCache.getc C s. | j ||d�}| �|� t| j�dgd|��S )Nr+ s DELETEDr6 )r- r. r7 r# � _deletetouchr: r r r r6 � s
zMemcachedCache.deleterg r ) rh ri rj �__doc__� _missing_keyr r r6 rl r r r r rm � s
rm c sB e Zd ZdZ� fdd�Zedd� �Zedfdd�Zd d
� Z � Z
S ) � PyLibMCCachez2An implementation of a cache binding using pylibmcc s" dd l }t� j||||jd� d S )Nr rp )�pylibmcr
r �NotFound)r r r r{ r r r r � s zPyLibMCCache.__init__c C s4 g }| j D ]}|�|�d�r|dd � n|� q|S )Nzunix:� )r �append�
startswith)r �outputr r r r r" � s
"zPyLibMCCache.client_serversNc C s@ | j ||d�}| �|� |dkr| j�|�S | j�|| �|��S )Nr+ r )r- r. r# r6 r8 r) r9 r r r r8 � s
zPyLibMCCache.touchc K s d S r r rL r r r rN � s zPyLibMCCache.close) rh ri rj rx r rk r" r r8 rN rl r r r r rz � s
rz c s e Zd ZdZ� fdd�Z� ZS )�PyMemcacheCachez6An implementation of a cache binding using pymemcache.c sB dd l }t� j|||td� | jj| _dd|jjd�| j �| _ d S )Nr rp TF)�allow_unicode_keys�default_noreply�serde)
�pymemcache.serder
r �KeyErrorr �
HashClientr r� � pickle_serder )r r r �
pymemcacher r r r � s
�
�zPyMemcacheCache.__init__)rh ri rj rx r rl r r r r r� � s r� )rx ru r r' rr � django.core.cache.backends.baser r r r �django.utils.deprecationr �django.utils.functionalr r rm rz r� r r r r �<module> s '