File: //opt/alt/python38/lib/python3.8/site-packages/__pycache__/async_lru.cpython-38.pyc
U
Wz8\� � @ s� d dl Z d dlmZ d dlmZmZmZmZ zd dl mZ W n e k
rZ e
e d�ZY nX dZ dZ dd � Z
d
d � Zd d
� Zdd� Zdd� Zdd� Zdddd�dd�Ze jdd� �Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd+ddddd(�d)d*�Z dS ),� N)� OrderedDict)�
_CacheInfo� _make_key�partial�wraps)�
ensure_future�asyncz1.0.2)�
alru_cachec C s0 z
| � � W S tk
r* tj| d� Y S X d S )N��loop)�
create_future�AttributeError�asyncio�Futurer
� r �:/opt/alt/python38/lib/python3.8/site-packages/async_lru.pyr s
r c C s t | d�r| j} q | S )N�func)�hasattrr )�fnr r r � unpartial s
r c C sD |� � r| �� d S |�� }|d k r2| �|� d S | �|�� � d S �N)� cancelled�cancel� exception�
set_exception�
set_result�result)�fut�task�excr r r �_done_callback s
r c O s* t |||�}|| jk}|r&| j�|� |S r )r �_cache�pop)�wrapped�typed�args�kwargs�key�existsr r r �_cache_invalidate* s
r) c C s d | _ | _t� | _t� | _d S )Nr )�hits�missesr r! �set�tasks)r# r r r � _cache_clear5 s r. c C s` | j std��| j| j koDt| j� koDt| j� koDdkn }|sVtd��d| _ d S )Nzalru_cache is not closedr z#alru_cache was not closed correctlyF)�closed� RuntimeErrorr* r+ �lenr- r! )r# Z
was_closedr r r �_open; s �����r2 FT)r �return_exceptionsr c C sB | j rtd��d| _ |r4| jD ]}|�� s |�� q t| ||d�S )Nzalru_cache is closedT�r3 r )r/ r0 r- �doner � _wait_closed)r# r r3 r r r r r �_closeM s
�r7 c c sV |d krt �� }t j| j||d��}|�tt| �� |E d H }t jd|d�E d H |S )Nr4 r r
)r �get_event_loopZgatherr- �add_done_callbackr �
_close_waited�sleep)r# r3 r Z wait_closed�retr r r r6 _ s �
r6 c C s | � � d S r )� cache_clear)r# �_r r r r: t s r: c C s t | j| j|t| j��S r )r r* r+ r1 r! )r# �maxsizer r r � _cache_infox s �r@ c C s* z| j �|� W n tk
r$ Y nX d S r )r! � move_to_end�KeyError�r# r' r r r �
__cache_touch� s rD c C s | j d7 _ t| |� d S �N� )r* rD rC r r r �
_cache_hit� s rG c C s | j d7 _ t| |� d S rE )r+ rD rC r r r � _cache_miss� s rH c C sv t |t�r\| |A std��| rRt|dd �}|d krF|s>td��|d }t||�}qr|| }n|d krnt�� }n|}|S )Nz"choose self.loop or kwargs["loop"]�__self__zseems not unbound functionr )�
isinstance�str�AssertionError�getattrr r8 )�clsr& r �fn_args� fn_kwargsr �_self�_loopr r r � _get_loop� s
rS � )rN r& �cache_exceptionsr c sN � �����fdd�}| d kr"|S t | �s4t| d�r<|| �S td�| ���d S )Nc
s� t � �}t�|�s td�� ���t� d�r2� �� � t� �tj��� �����fdd����t �� |�_
d�_ t t
����_t t ���_t t����_t t���_t t���_�S )Nz&Coroutine function is required, got {}�_make_unbound_methodc ? s: �j rtd�����t���j| |�d�}t| |��}�j�|�}|d k r�|�� spt �|� t
j ||d�E d H S |j }|d ks�� r�t �|� |�
� S �j�|� t|d�}�| |�}t||d�}|�tt|�� �j�|� |��jj� |�j|< �d k �r t�j��k�r �jjdd� t�|� t
j ||d�E d H S )Nzalru_cache is closed for {}r
F)�last)r/ r0 �formatrS �_originr r! �getr5 rG r Zshield�
_exceptionr r" r r r9 r r r- �add�remover1 �popitemrH )rO rP rR r' r r �coror )rU rN r r& r r? r$ r# r r r# � sD ��
z,alru_cache.<locals>.wrapper.<locals>.wrappedF)r r �iscoroutinefunctionr0 rX r rV r � coroutiner. rY r/ r r@ �
cache_infor= r) Z
invalidater7 �closer2 �open)r rY �rU rN r& r r? r$ )r r# r �wrapper� s&
�
0 zalru_cache.<locals>.wrapperrV z {} decorating is not supported)�callabler �NotImplementedErrorrX )r r? r$ rN r& rU r rf r re r r � s
Hr )NrT F) r � collectionsr � functoolsr r r r r � ImportErrorrM � __version__�__all__r r r r) r. r2 r7 ra r6 r: r@ rD rG rH rS r r r r r �<module> s@
��