Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/dogpile/testing/__pycache__/fixtures.cpython-39.pyc
Ðазад
a t�h�C � @ s8 d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlZd dlZd dl Z d dl m Z d dl m Z d dl mZ d dl mZ d dl mZ d d l mZ d d lmZ d d lmZ d d lmZ dd� ZG dd� d�ZG dd� de�Zdd� ZG dd� d�ZG dd� de�Z G dd� de �Z G d d � d e�Z e d e d � dS ) � N)�Lock��Thread)� CacheRegion)�register_backend)� CacheBackend)� CacheMutex��CantDeserializeException)�NO_VALUE)�_backend_loader� )�assert_raises_message)�eq_c C s dt �dd�� �S )NZ some_key_r i�� )�random�randint� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/dogpile/testing/fixtures.py� gen_some_key s r c @ s^ e Zd Zedd� �Zdd� Zedd� �Zi Zi Zi Z dZ dZ e � Z di i fdd �Zd d � ZdS ) �_GenericBackendFixturec C sX t �| j�}z| j�di �}||�}W n" tyH t�d| j � Y n0 | �|� d S )N� argumentszBackend %s not installed) r �load�backend� config_args�get� ImportError�pytest�skip�_check_backend_available)�cls� backend_clsr r r r r � setup_class s z"_GenericBackendFixture.setup_classc C sF t � }| jr0| jD ]}| j�|� q| j�� n| jrB| j�|� d S �N)r � _region_inst�_keys�delete�clear� _backend_inst)�self�method�some_key�keyr r r �teardown_method( s z&_GenericBackendFixture.teardown_methodc C s d S r" r )r r r r r r 1 s z/_GenericBackendFixture._check_backend_availableNc s� i }t �jj�D ] }d|jv r|�|jd � q|jf i |�� �j�� }|�|� � �fdd�}tf i |�� �_}�jj � |�j_ |�j_ |j |p��j fi |�� |S )N� region_argsc s � r � | �} �j �| � | S r" )r$ �add�r+ �Zexisting_key_manglerr( r r � _store_keysL s z3_GenericBackendFixture._region.<locals>._store_keys) �reversed� __class__�__mro__�__dict__�updater �copyr r# Z key_manglerZ_user_defined_key_mangler� configurer ) r( r r- r Z _region_argsr � _config_argsr1 �regr r0 r �_region> s z _GenericBackendFixture._regionc C s@ t �| j�}| j�� }|�di �}i |�| j�}||�| _| jS )Nr )r r r r r7 r �extra_argumentsr' )r( r r9 r r r r �_backend[ s z _GenericBackendFixture._backend)�__name__� __module__� __qualname__� classmethodr! r, r r- r r< r# r' �setr$ r; r= r r r r r s r c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zejjd#d$� �Zejjd%d&� �Zd'd(� Zejjd)d*� �Zd+d,� Zd-d.� Z d/S )0�_GenericBackendTestSuitec C s" | � � }t� }t|�|�t� d S r" )r= r r �get_serializedr �r( r r* r r r �test_backend_get_nothinge s z1_GenericBackendTestSuite.test_backend_get_nothingc C s | � � }t� }|�|� d S r" )r= r r% rE r r r �test_backend_delete_nothingj s z4_GenericBackendTestSuite.test_backend_delete_nothingc C s. | � � }t� }|�|d� t|�|�d� d S �Ns some value)r= r �set_serializedr rD rE r r r �test_backend_set_get_valueo s z3_GenericBackendTestSuite.test_backend_set_get_valuec C s8 | � � }t� }|�|d� |�|� t|�|�t� d S rH )r= r rI r% r rD r rE r r r �test_backend_deleteu s z,_GenericBackendTestSuite.test_backend_deletec C s� | � � }tt�� �}|�|�r"J �t|�|�d� t|�|�d� |j�|�}|r�|� � t|�|�d� |� � t|�|�d� d S )NFT) r; �str�uuid�uuid1r r Z key_is_lockedr � get_mutex�acquire�release)r( r: Z random_key�mutexr r r �test_region_is_key_locked| s z2_GenericBackendTestSuite.test_region_is_key_lockedc C s. | � � }t� }|�|d� t|�|�d� d S �N� some value)r; r rB r r �r( r: r* r r r �test_region_set_get_value� s z2_GenericBackendTestSuite.test_region_set_get_valuec C s^ | � � }dddd�}|�|� t|d |�d�� t|d |�d�� t|d |�d�� d S )N�value1�value2�value3��key1�key2�key3r\ r] r^ )r; � set_multir r �r( r: �valuesr r r � test_region_set_multiple_values� s z8_GenericBackendTestSuite.test_region_set_multiple_valuesc C s | � � }t|�g �g � d S r" )r; r � get_multi�r( r: r r r �$test_region_get_zero_multiple_values� s z=_GenericBackendTestSuite.test_region_get_zero_multiple_valuesc C s | � � }|�i � d S r" )r; r_ rd r r r �$test_region_set_zero_multiple_values� s z=_GenericBackendTestSuite.test_region_set_zero_multiple_valuesc C s& | � � }|�g dd� �}t|g � d S )Nc S s dS )Nr r r r r r �<lambda>� � z[_GenericBackendTestSuite.test_region_set_zero_multiple_values_w_decorator.<locals>.<lambda>�r; �get_or_create_multir r` r r r �0test_region_set_zero_multiple_values_w_decorator� s zI_GenericBackendTestSuite.test_region_set_zero_multiple_values_w_decoratorc C s6 | � � }|jg d�dd� dd� d�}t|g d�� d S )Nr[ c W s g d�S )N�NNNr )�kr r r rg � rh z^_GenericBackendTestSuite.test_region_get_or_create_multi_w_should_cache_none.<locals>.<lambda>c S s | d uS r" r ��vr r r rg � rh )Zshould_cache_fnrl ri r` r r r �3test_region_get_or_create_multi_w_should_cache_none� s �zL_GenericBackendTestSuite.test_region_get_or_create_multi_w_should_cache_nonec C sZ | � � }d}d}d}|�d|� |�d|� |�d|� |�g d��}t|||g|� d S )NrX rY rZ r\ r] r^ r[ )r; rB rc r )r( r: r\ r] r^ ra r r r � test_region_get_multiple_values� s z8_GenericBackendTestSuite.test_region_get_multiple_valuesc C sT | � � }|�g d�� dddd�}|�|� |�g d��}t|dtdtdtg� d S )N)r\ r] r^ �key4�key5rX rZ Zvalue5)r\ r^ rs )r\ r] r^ rr rs Zkey6)r; � delete_multir_ rc r r )r( r: ra � reg_valuesr r r � test_region_get_nothing_multiple� s ��z9_GenericBackendTestSuite.test_region_get_nothing_multiplec C s | � � }|�g �}t|g � d S r" )r; rc r )r( r: ru r r r � test_region_get_empty_multiple� s z7_GenericBackendTestSuite.test_region_get_empty_multiplec C sx | � � }dddd�}|�|� |�ddg� t|d |�d�� tt|�d�� t|d |�d�� tt|�d�� d S ) NrX rY rZ r[ r] Zkey10r\ r^ )r; r_ rt r r r r` r r r �test_region_delete_multiple� s z4_GenericBackendTestSuite.test_region_delete_multiplec C s. | � � }t� }|�|g� t|�|�t� d S r" )r; r rt r r r rV r r r �test_region_set_get_nothing� s z4_GenericBackendTestSuite.test_region_set_get_nothingc C s, | � � }dd� }t� }t|�||�d� d S )Nc S s dS rT r r r r r �creator� s z=_GenericBackendTestSuite.test_region_creator.<locals>.creatorrU )r; r r � get_or_create)r( r: rz r* r r r �test_region_creator� s z,_GenericBackendTestSuite.test_region_creatorc s� | j ddid��t� �g � t� �� �fdd�����fdd���fdd �td �D �}|D ] }|�� qX|D ] }|�� qjt� �d ks�J ��j�� s�d � vs�J �d S ) N�expiration_time� �?�r c s. �� d�} � �| � t�d� | r*��� dS )NFr~ rU )rP �append�time�sleeprQ )�ack)�canary�lockr r rz � s z?_GenericBackendTestSuite.test_threaded_dogpile.<locals>.creatorc s( t d�D ]} ���� � t�d� qd S )N� � �?)�ranger{ r� r� ��x)rz r: r* r r �f� s z9_GenericBackendTestSuite.test_threaded_dogpile.<locals>.fc s g | ]}t � d ��qS �)�targetr ��.0�i�r� r r � <listcomp>� rh zB_GenericBackendTestSuite.test_threaded_dogpile.<locals>.<listcomp>� � F) r; r r r� �start�join�lenr Zhas_lock_timeout�r( �threads�tr )r� rz r� r� r: r* r �test_threaded_dogpile� s z._GenericBackendTestSuite.test_threaded_dogpilec s� t � }| jddid���j�|�}|du}tdd� td�D ���t�t�� � �fdd ����fd d ���� �fd d �td�D �}|D ] }|� � q�|D ] }|� � q�t dd � � � � D ��dks�J �|s� � � D ]}d|vs�J �q�dS )z�This test is testing that when we get inside the "creator" for a certain key, there are no other "creators" running at all for that key. With "distributed" locks, this is not 100% the case. r} r~ r Nc s s | ]}t |�t� fV qd S r" )rL r r� r r r � <genexpr> rh zC_GenericBackendTestSuite.test_threaded_get_multi.<locals>.<genexpr>� c sx | sJ ��fdd�| D �}t || �D ]\}}� | �|� q$t�d� t || �D ]\}}|rP�| �� qPdd� | D �S )Nc s g | ]}� | � d ��qS )F)rP �r� r+ )�locksr r r� rh zU_GenericBackendTestSuite.test_threaded_get_multi.<locals>.creator.<locals>.<listcomp>r� c S s g | ] }d | �qS )z some value %sr )r� rm r r r r� ) rh )�zipr� r� r� rQ )�keysr� Zacqr+ )r� r� r r rz s zA_GenericBackendTestSuite.test_threaded_get_multi.<locals>.creatorc s> t d�D ]0} ��dd� t t�dd��D �� � t�d� qd S )Nr� c S s g | ]}t t�d d���qS )r r� )rL r r r� r r r r� . s �zO_GenericBackendTestSuite.test_threaded_get_multi.<locals>.f.<locals>.<listcomp>r r� )r� rj r r r� r� r� )rz r: r r r� + s ��z;_GenericBackendTestSuite.test_threaded_get_multi.<locals>.fc s g | ]}t � d ��qS r� r r� r� r r r� 8 rh zD_GenericBackendTestSuite.test_threaded_get_multi.<locals>.<listcomp>r� c S s g | ] }t |��qS r )r� )r� ro r r r r� > rh r� F) r r; r rO �dictr� � collections� defaultdict�listr� r� �sumra )r( r* Z backend_mutexZis_custom_mutexr� r� �lr )r� rz r� r� r: r �test_threaded_get_multi s$ z0_GenericBackendTestSuite.test_threaded_get_multic C sB | � � }t� }|�|d� |�|� |�|� t|�|�t� d S rT )r; r rB r% r r r rV r r r �test_region_deleteF s z+_GenericBackendTestSuite.test_region_deletec s� t � }d}| jd|id�}t�d�� � fdd�}t|�||�d� t�|d| � |j|d d �}|t urtt|d� t|�||�d � t|�|�d � d S ) Ng �?r} r r c s dt � � S )Nz some value %d��nextr ��counterr r rz ] s z<_GenericBackendTestSuite.test_region_expire.<locals>.creatorz some value 1g�������?T)Zignore_expirationz some value 2) r r; � itertools�countr r{ r� r� r r )r( r* � expire_timer: rz Zpost_expirationr r� r �test_region_expireN s z+_GenericBackendTestSuite.test_region_expirec s� | � � }t�d�� |�� � fdd��}|�dd� |�dd� |�dd� t|dd�d� t|dd�d � t|dd�d� t|dd�d � |�dd� t|dd�d � d S ) Nr c s t � �| | S r" r� )r� �yr� r r � my_functionu s zM_GenericBackendTestSuite.test_decorated_fn_functionality.<locals>.my_function� � r� � � � r� r� )r; r� r� Zcache_on_argumentsZ invalidater )r( r: r� r r� r � test_decorated_fn_functionalitym s z8_GenericBackendTestSuite.test_decorated_fn_functionalityc C s, t � }| �� }dd� }ttd|j||� d S )Nc S s t d��d S )N�boom)� Exceptionr r r r r� � s z>_GenericBackendTestSuite.test_exploding_value_fn.<locals>.boomr� )r r; r r� r{ )r( r* r: r� r r r �test_exploding_value_fn� s �z0_GenericBackendTestSuite.test_exploding_value_fnN) r> r? r@ rF rG rJ rK rS rW rb re rf rk rp rq rv rw rx ry r| r �mark�time_intensiver� r� r� r� r� r� r r r r rC d s4 @ rC c C s t � �d S r" r rn r r r � raise_cant_deserialize_exception� s r� c @ s4 e Zd Zdd� ejd�Zdd� Zdd� Zdd � Zd S ) �_GenericSerializerTestSuitec C s t �| ��d�S )N�ascii)�json�dumps�encodern r r r rg � rh z$_GenericSerializerTestSuite.<lambda>�� serializerZ deserializerc C sH | j | jd td�d�}dg d�i}|�d|� |�d�}t|t� d S )Nr� r� )r- �foo��barr FNrm )r; r- r� rB r r r �r( �region�valueZassertedr r r � test_serializer_cant_deserialize� s �� z<_GenericSerializerTestSuite.test_serializer_cant_deserializec C s� | � � }|j}dg d�i}|�d|� |�d�}t|t�s>J �|�d�}||d d � }t|| jd |�� t|� |�j |� d S )Nr� r� rm � |r r� ) r; r rB rD � isinstance�bytes�findr r- Z _parse_serialized_from_backend�payload)r( r� r r� �raw�piper� r r r �test_uses_serializer� s z0_GenericSerializerTestSuite.test_uses_serializerc C s8 | � � }dg d�i}|�d|� |�d�}t||� d S )Nr� r� rm )r; rB r r r� r r r �test_uses_deserializer� s z2_GenericSerializerTestSuite.test_uses_deserializerN) r> r? r@ r� �loadsr- r� r� r� r r r r r� � s � r� c @ s< e Zd Zdd� Zdd� Zejjdd� �Zdd� Z d d � Z d S ) �_GenericMutexTestSuitec C s| | � � }|�d�}|�� r J �|�� }|s.J �|�d�}|�� sDJ �|rLJ �|�� |�� r`J �|�� }|spJ �|�� d S )Nr� F)r= rO �lockedrP rQ )r( r rR �acZac2Zac3r r r � test_mutex� s z!_GenericMutexTestSuite.test_mutexc C s$ | � � }|�d�}t|t�s J �d S )Nr� )r= rO r� r )r( r rR r r r �test_subclass_match� s z*_GenericMutexTestSuite.test_subclass_matchc sv | � � � � �d� t� �g �� ��fdd���fdd�td�D �}|D ] }|�� qF|D ] }|�� qXd�vsrJ �d S )Nr� c sn t d�D ]`} � �d�}|�� t d�D ].}��d�}��|� t�d� |r&��� q&|�� t�d� qd S )Nr� r� Fg����Mb`?g{�G�z�?)r� rO rP r� r� r� rQ )r� rR r� r� )r r� r� r r r� � s z5_GenericMutexTestSuite.test_mutex_threaded.<locals>.fc s g | ]}t � d ��qS r� r r� r� r r r� � rh z>_GenericMutexTestSuite.test_mutex_threaded.<locals>.<listcomp>r� F)r= rO r r� r� r� r� r )r r� r� r� r �test_mutex_threaded� s z*_GenericMutexTestSuite.test_mutex_threadedc C s� | � � }td�D ]�}|�d�}|�d�}z\|�� |�d�s@J �|�d�rNJ �|�� |�d�sdJ �|�d�rrJ �|�� W |�� q|�� 0 qd S )Nr� r� r� F)r= r� rO rP rQ )r( r r� �m1�m2r r r � test_mutex_reentrant_across_keys� s z7_GenericMutexTestSuite.test_mutex_reentrant_across_keysc sF | � � �� �fdd�}dd� � t��d|�d� t��d|�d� d S )Nc s d�� d� � S )Nr� r� )r{ r �� create_barr: r r � create_foo s zA_GenericMutexTestSuite.test_reentrant_dogpile.<locals>.create_fooc S s dS )Nr� r r r r r r� s zA_GenericMutexTestSuite.test_reentrant_dogpile.<locals>.create_barr� Zfoobar)r; r r{ )r( r� r r� r �test_reentrant_dogpile s z-_GenericMutexTestSuite.test_reentrant_dogpileN) r> r? r@ r� r� r r� r� r� r� r� r r r r r� � s r� c @ s. e Zd Zdd� Zd dd�Zdd� Zdd � Zd S ) � MockMutexc C s || _ d S r" r/ �r( r+ r r r �__init__ s zMockMutex.__init__Tc C s dS )NTr )r( �blockingr r r rP s zMockMutex.acquirec C s d S r" r �r( r r r rQ ! s zMockMutex.releasec C s dS )NFr r� r r r r� $ s zMockMutex.lockedN)T)r> r? r@ r� rP rQ r� r r r r r� s r� c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )� MockBackendc C s || _ i | _d S r" )r �_cache)r( r r r r r� ) s zMockBackend.__init__c C s t |�S r" )r� r� r r r rO - s zMockBackend.get_mutexc C s( z | j | W S ty" t Y S 0 d S r" )r� �KeyErrorr r� r r r r 0 s zMockBackend.getc s � fdd�|D �S )Nc s g | ]}� � |��qS r )r r� r� r r r� 7 rh z)MockBackend.get_multi.<locals>.<listcomp>r )r( r� r r� r rc 6 s zMockBackend.get_multic C s || j |< d S r" )r� )r( r+ r� r r r rB 9 s zMockBackend.setc C s" |� � D ]\}}| �||� qd S r" )�itemsrB )r( �mappingr+ r� r r r r_ < s zMockBackend.set_multic C s | j �|d � d S r" )r� �popr� r r r r% @ s zMockBackend.deletec C s |D ]}| � |� qd S r" )r% )r( r� r+ r r r rt C s zMockBackend.delete_multiN) r> r? r@ r� rO r rc rB r_ r% rt r r r r r� ( s r� Zmock)!r� r� r� r � threadingr r r� rM r Z dogpile.cacher r Zdogpile.cache.apir r r r Zdogpile.cache.regionr Z assertionsr r r r rC r� r� r� �objectr� r� r> r r r r �<module> s8 G 02R
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка