Viewing File: /opt/imunify360/venv/lib/python3.11/site-packages/async_lru/__pycache__/__init__.cpython-311.pyc

�

��i�$����ddlZddlZddlZddlmZddlmZmZmZm	Z	ddl
mZmZm
Z
mZmZmZmZmZmZmZmZmZmZmZmZejdkrddl
mZnddlmZdZdZed	��Zed
��Z e
eee fZ!ede!e fZ"ee"e dd
fZ#eGd�de����Z$eej%Gd�dee ������Z&eGd�dee ����Z'eGd�dee ef����Z(	d!dee)de*dee+dee#e ge'e ffd�Z,e		d"dd�dee)de*dee+dee#e ge'e ffd���Z-ede#e de'e fd���Z-		d"dd�deee)e#e fde*dee+deee#e ge'e fe'e ffd �Z-dS)#�N)�
_is_coroutine)�
_CacheInfo�	_make_key�partial�
partialmethod)�Any�Callable�	Coroutine�Generic�Hashable�Optional�OrderedDict�Set�Type�	TypedDict�TypeVar�Union�cast�final�overload)��)�Selfz2.0.5)�
alru_cache�_T�_R.zpartial[_Coro[_R]]zpartialmethod[_Coro[_R]]c�D�eZdZUeed<eeed<eed<eed<dS)�_CacheParameters�typed�maxsize�tasks�closedN)�__name__�
__module__�__qualname__�bool�__annotations__r
�int���I/opt/imunify360/venv/lib64/python3.11/site-packages/async_lru/__init__.pyrr+s;��������K�K�K�
�c�]�����J�J�J��L�L�L�L�Lr*rc�B�eZdZUded<eejed<dd�ZdS)�
_CacheItem�asyncio.Future[_R]�fut�
later_call�returnNc�X�|j�"|j���d|_dSdS�N)r0�cancel��selfs r+r4z_CacheItem.cancel9s1���?�&��O�"�"�$�$�$�"�D�O�O�O�'�&r*�r1N)r#r$r%r'r
�asyncio�Handler4r)r*r+r-r-3sK�������
�������(�(�(�(�#�#�#�#�#�#r*r-c
� �eZdZdeedeededeeddf
d�Z	de
d	edefd
�Zd!d�Z
dd
�deddfd�Zdefd�Zdefd�Zde
ddfd�Zde
ddfd�Zddde
ddddfd�Zdededefd�Zdedeeedeedffd �ZdS)"�_LRUCacheWrapper�fnr r�ttlr1Nc�Z�	|j|_n#t$rYnwxYw	|j|_n#t$rYnwxYw	|j|_n#t$rYnwxYw	|j|_n#t$rYnwxYw	|j|_n#t$rYnwxYw	|j�|j��n#t$rYnwxYwt|_||_	||_
||_||_t��|_d|_d|_d|_t%��|_dS)NFr)r$�AttributeErrorr#r%�__doc__r'�__dict__�updater�__wrapped__�_LRUCacheWrapper__maxsize�_LRUCacheWrapper__typed�_LRUCacheWrapper__ttlr�_LRUCacheWrapper__cache�_LRUCacheWrapper__closed�_LRUCacheWrapper__hits�_LRUCacheWrapper__misses�set�_LRUCacheWrapper__tasks)r6r<r rr=s     r+�__init__z_LRUCacheWrapper.__init__As���	� �m�D�O�O���	�	�	��D�	����	��K�D�M�M���	�	�	��D�	����	� "��D�����	�	�	��D�	����	��:�D�L�L���	�	�	��D�	����	�#%�#5�D� � ���	�	�	��D�	����	��M� � ���-�-�-�-���	�	�	��D�	����+������ ��������
�>I�m�m�����
������
�03�������_��
��-�
:�:�A�
A�A�A)�)
A6�5A6�:B�
B�B�B8�8
C�C�args�kwargsc��t|||j��}|j�|d��}|�dS|���dS)NFT)rrErG�popr4)r6rOrP�key�
cache_items     r+�cache_invalidatez!_LRUCacheWrapper.cache_invalidatemsN����f�d�l�3�3���\�%�%�c�4�0�0�
����5��������4r*c��d|_d|_|j���D]"}|jr|j����#|j���|j���dS)Nr)rIrJrG�valuesr0r4�clearrL)r6�cs  r+�cache_clearz_LRUCacheWrapper.cache_clearwsz�������
���$�$�&�&�	&�	&�A��|�
&���#�#�%�%�%�����������������r*F)�waitr[c���K�d|_t|j��}|sdS|s-|D]*}|���s|����+tj|ddi��d{V��dS)NT�return_exceptions)rH�listrL�doner4r8�gather)r6r[r!�tasks    r+�cache_closez_LRUCacheWrapper.cache_close�s�������
��T�\�"�"���	��F��	"��
"�
"���y�y�{�{�"��K�K�M�M�M���n�e�<�t�<�<�<�<�<�<�<�<�<�<�<r*c�h�t|j|j|jt	|j����Sr3)rrIrJrD�lenrGr5s r+�
cache_infoz_LRUCacheWrapper.cache_info�s0����K��M��N������	
�
�	
r*c�j�t|j|jt|j��|j���S)N)r rr!r")rrDrErdrLrHr5s r+�cache_parametersz!_LRUCacheWrapper.cache_parameters�s5����N��,��d�l�#�#��=�	
�
�
�	
r*rSc�Z�|xjdz
c_|j�|��dS�N�)rIrG�move_to_end�r6rSs  r+�
_cache_hitz_LRUCacheWrapper._cache_hit�s.�����q������ � ��%�%�%�%�%r*c�&�|xjdz
c_dSri)rJrls  r+�_cache_missz_LRUCacheWrapper._cache_miss�s���
�
���
�
�
�
r*r/r.razasyncio.Task[_R]c�f�|j�|��|���r1|���|j�|d��dS|���}|�2|�|��|j�|d��dS|j�|��}|j	�A|�?tj��}|�|j	|jj|d��|_
|�|�����dSr3)rL�discard�	cancelledr4rGrR�	exception�
set_exception�getrFr8�get_running_loop�
call_laterr0�
set_result�result)r6r/rSra�excrT�loops       r+�_task_done_callbackz$_LRUCacheWrapper._task_done_callback�s��	
����T�"�"�"��>�>���	��J�J�L�L�L��L���S�$�'�'�'��F��n�n�����?����c�"�"�"��L���S�$�'�'�'��F��\�%�%�c�*�*�
��:�!�j�&<��+�-�-�D�$(�O�O��
�D�L�,�c�4�%�%�J�!�	���t�{�{�}�}�%�%�%�%�%r*�fn_args�	fn_kwargsc��K�|jrtd|�����tj��}t	|||j��}|j�|��}|�f|�|��|j	�
��stj|j	���d{V��S|j	���S|�
��}|j|i|��}|�|��}|j�|��|�t'|j||����t+|d��|j|<|j�Ot/|j��|jkr2|j�d���\}	}|���|�|��tj|���d{V��S)Nzalru_cache is closed for F)�last)rH�RuntimeErrorr8rvrrErGrurmr/r_�shieldry�
create_futurerC�create_taskrL�add�add_done_callbackrr|r-rDrd�popitemr4ro)
r6r}r~r{rSrTr/�corora�dropped_keys
          r+�__call__z_LRUCacheWrapper.__call__�s������=�	C��A�4�A�A�B�B�B��'�)�)�����D�L�9�9���\�%�%�c�*�*�
��!��O�O�C� � � ��>�&�&�(�(�
<�$�^�J�N�;�;�;�;�;�;�;�;�;��>�(�(�*�*�*�� � �"�"���t���6�I�6�6��!%�!1�!1�$�!7�!7�������������w�t�'?��c�J�J�K�K�K�&�s�D�1�1���S���>�%�#�d�l�*;�*;�d�n�*L�*L�&*�l�&:�&:��&:�&F�&F�#�K����������������^�C�(�(�(�(�(�(�(�(�(r*�instance�ownerz&_LRUCacheWrapperInstanceMethod[_R, _T]c�*�|�|St||��Sr3)�_LRUCacheWrapperInstanceMethod)r6r�r�s   r+�__get__z_LRUCacheWrapper.__get__�s���=��K�1�$��A�A�Ar*r7)r#r$r%�_CBrr
r(r&�floatrMrrrUrZrbrrerrgrmror|r�rrrrr�r)r*r+r;r;?s�������*6���G�*6��#��*6��	*6�
�e�_�*6�
�
*6�*6�*6�*6�X���S��T���������16�=�=�=��=�$�=�=�=�=�
�J�
�
�
�
�
�"2�
�
�
�
�&�h�&�4�&�&�&�&��x��D�����&�'�&�.6�&�>P�&�	
�&�&�&�&�2)�#�)�C�)�B�)�)�)�)�@B��B�#+�D��H�#5�B�	�t�=�=�	>�B�B�B�B�B�Br*r;c��eZdZdeededdfd�Zdedede	fd�Z
dd	�Zd
dd�d
e	de	ddfd�Zde
fd�Zdefd�Zdededefd�ZdS)r��wrapperr�r1Nc���	|j|_n#t$rYnwxYw	|j|_n#t$rYnwxYw	|j|_n#t$rYnwxYw	|j|_n#t$rYnwxYw	|j|_n#t$rYnwxYw	|j�|j��n#t$rYnwxYwt|_|j	|_	||_
||_dSr3)r$r?r#r%r@r'rArBrrC�(_LRUCacheWrapperInstanceMethod__instance�'_LRUCacheWrapperInstanceMethod__wrapper)r6r�r�s   r+rMz'_LRUCacheWrapperInstanceMethod.__init__�sb��
	�%�0�D�O�O���	�	�	��D�	����	�#�,�D�M�M���	�	�	��D�	����	� '� 4�D�����	�	�	��D�	����	�"�?�D�L�L���	�	�	��D�	����	�#*�#:�D� � ���	�	�	��D�	����	��M� � ��!1�2�2�2�2���	�	�	��D�	����+���"�.���"��� ����rNrOrPc�8�|jj|jg|�Ri|��Sr3)r�rUr�)r6rOrPs   r+rUz/_LRUCacheWrapperInstanceMethod.cache_invalidates)��.�t�~�.�t��P��P�P�P��P�P�Pr*c�8�|j���dSr3)r�rZr5s r+rZz*_LRUCacheWrapperInstanceMethod.cache_clears����"�"�$�$�$�$�$r*FT)r4r]r4r]c��HK�|j����d{V��dSr3)r�rb)r6r4r]s   r+rbz*_LRUCacheWrapperInstanceMethod.cache_closes4�����n�(�(�*�*�*�*�*�*�*�*�*�*�*r*c�4�|j���Sr3)r�rer5s r+rez)_LRUCacheWrapperInstanceMethod.cache_infos���~�(�(�*�*�*r*c�4�|j���Sr3)r�rgr5s r+rgz/_LRUCacheWrapperInstanceMethod.cache_parameterss���~�.�.�0�0�0r*r}r~c��>K�|j|jg|�Ri|���d{V��Sr3)r�r�)r6r}r~s   r+r�z'_LRUCacheWrapperInstanceMethod.__call__s<����#�T�^�D�O�K�g�K�K�K��K�K�K�K�K�K�K�K�Kr*r7)r#r$r%r;rrrMrrr&rUrZrbrrerrgr�r)r*r+r�r��s4������"!�!�"�%�"!��"!�
�	"!�"!�"!�"!�HQ��Q�S�Q�T�Q�Q�Q�Q�%�%�%�%�!&��+�+�+��+�:>�+�	
�+�+�+�+�
+�J�+�+�+�+�1�"2�1�1�1�1�L�#�L�C�L�B�L�L�L�L�L�Lr*r�r rr=r1c�d����dttdttf���fd�}|S)Nr<r1c�z��|}t|ttf��r#|j}t|ttf���#t	j|��st
d|�����t|d��r|���}tttt|�������S)Nz$Coroutine function is required, got �_make_unbound_method)
�
isinstancerr�funcr8�iscoroutinefunctionr��hasattrr�r;rr�r)r<�originr r=rs  ���r+r�z_make_wrapper.<locals>.wrapper(s��������'�=�!9�:�:�	!��[�F���'�=�!9�:�:�	!��*�6�2�2�	N��L�b�L�L�M�M�M��2�-�.�.�	+��(�(�*�*�B���S��W�b� 1� 1�7�E�3�G�G�Gr*)�_CBPrr;)r rr=r�s``` r+�
_make_wrapperr�#sV�����

H�D��H�
H�!1�"�!5�
H�
H�
H�
H�
H�
H�
H�
H��Nr*�F)r=c��dSr3r))r rr=s   r+rr:s	���Cr*c��dSr3r))r s r+rrDs	��
�Cr*c�(�|�t|t��rt|||��Sttt
|��}t
|��st|d��rtddd��|��St|�d����)Nr�r�Fz decorating is not supported)	r�r(r�rr�r�callabler��NotImplementedError)r rr=r<s    r+rrLs�����*�W�c�2�2���W�e�S�1�1�1�
�#�b�'�7�
#�
#���B�<�<�	7�7�2�'=�>�>�	7�2�=��e�T�2�2�2�6�6�6�!�R�"G�"G�"G�H�H�Hr*r3)r�F).r8�dataclasses�sys�asyncio.coroutinesr�	functoolsrrrr�typingrr	r
rrr
rrrrrrrrr�version_infor�typing_extensions�__version__�__all__rr�_Coror�r�r�	dataclassr-r;r�r(r&r�r�rr)r*r+�<module>r�si����������
�
�
�
�,�,�,�,�,�,�C�C�C�C�C�C�C�C�C�C�C�C�����������������������������������&��w����������&�&�&�&�&�&���
��
�W�T�]�]���W�T�]�]���#�s�B�,����s�E�"�I�~����S��W�*�,F�
F�G��������y���������#�#�#�#�#����#�#�����#��eB�eB�eB�eB�eB�w�r�{�eB�eB���eB�P�7L�7L�7L�7L�7L�W�R��V�_�7L�7L���7L�z ���
�c�]����
�%����t�B�x�j�*�2�.�.�/�	����.
� ��� �	���
�c�]����
�%��	�
�t�B�x�j�*�2�.�.�/����
���
��
�"�X���b�����
���/2��I� �	I�I�I�
�8�C�=�$�r�(�*�
+�I��I�
�%��	I�
�8�T�"�X�J� 0�� 4�4�5�7G��7K�K�L�I�I�I�I�I�Ir*
Back to Directory File Manager