]j$ d dl Z d dlZd dlZd dlmZ d dlmZmZmZm Z d dl
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZmZmZmZ ej dk rd dl
mZ nd dl mZ dZ dZ ed Z ed
Z e
e e e f Z!e d e!e f Z"ee"e d d
f Z#e G d de Z$eej% G d dee Z&e G d dee Z'e G d dee e f Z( d!dee) de*dee+ de e#e ge'e f fdZ,e d"dd dee) de*dee+ de e#e ge'e f fd Z-ede#e de'e fd Z- d"dd deee) e#e f de*dee+ dee e#e ge'e f e'e f fd Z-dS )# N)
_is_coroutine)
_CacheInfo _make_keypartial
partialmethod)AnyCallable CoroutineGenericHashableOptional OrderedDictSetType TypedDictTypeVarUnioncastfinaloverload) )Selfz2.0.5)
alru_cache_T_R.zpartial[_Coro[_R]]zpartialmethod[_Coro[_R]]c D e Zd ZU eed< ee ed< eed< eed< dS )_CacheParameterstypedmaxsizetasksclosedN)__name__
__module__ __qualname__bool__annotations__r
int I/opt/imunify360/venv/lib64/python3.11/site-packages/async_lru/__init__.pyr r + s; KKK
c] JJJ LLLLLr* r c B e Zd ZU ded< eej ed< ddZdS )
_CacheItemasyncio.Future[_R]fut
later_callreturnNc X | j "| j d | _ d S d S N)r0 cancelselfs r+ r4 z_CacheItem.cancel9 s1 ? & O " " $ $ $ "DOOO ' &r* r1 N)r# r$ r% r' r
asyncioHandler4 r) r* r+ r- r- 3 sK
((((# # # # # #r* r- c
e Zd Zdee dee dedee ddf
dZ de
d e defd
Z d!d Z
d d
deddfdZdefdZdefdZde
ddfdZde
ddfdZddde
ddddfdZde de defd Zd ed eee deed f fd ZdS )"_LRUCacheWrapperfnr r ttlr1 Nc Z |j | _ n# t $ r Y nw xY w |j | _ n# t $ r Y nw xY w |j | _ n# t $ r Y nw xY w |j | _ n# t $ r Y nw xY w |j | _ n# t $ r Y nw xY w | j |j n# t $ r Y nw xY wt | _ || _ || _
|| _ || _ t | _ d| _ d| _ d| _ t% | _ d S )NFr )r$ AttributeErrorr# r% __doc__r' __dict__updater __wrapped___LRUCacheWrapper__maxsize_LRUCacheWrapper__typed_LRUCacheWrapper__ttlr _LRUCacheWrapper__cache_LRUCacheWrapper__closed_LRUCacheWrapper__hits_LRUCacheWrapper__missesset_LRUCacheWrapper__tasks)r6 r< r r r= s r+ __init__z_LRUCacheWrapper.__init__A s mDOO D KDMM D "D D :DLL D #%#5D D M - - - - D +
>Imm
03 _
-
:: A
AA A) )
A65A6: B
BB B8 8
CCargskwargsc t ||| j }| j |d }|dS | dS )NFT)r rE rG popr4 )r6 rO rP key
cache_items r+ cache_invalidatez!_LRUCacheWrapper.cache_invalidatem sN fdl33\%%c400
5 4r* c d| _ d| _ | j D ]"}|j r|j #| j | j d S )Nr )rI rJ rG valuesr0 r4 clearrL )r6 cs r+ cache_clearz _LRUCacheWrapper.cache_clearw sz
$$&& & &A|
& ##%%% r* F)waitr[ c K d| _ t | j }|sd S |s-|D ]*}| s| +t j |ddi d {V d S )NTreturn_exceptions)rH listrL doner4 r8 gather)r6 r[ r! tasks r+ cache_closez _LRUCacheWrapper.cache_close s
T\"" F "
"
"yy{{ "KKMMMne<t<<<<<<<<<<<r* c h t | j | j | j t | j S r3 )r rI rJ rD lenrG r5 s r+
cache_infoz_LRUCacheWrapper.cache_info s0 K M N
r* c j t | j | j t | j | j S )N)r r r! r" )r rD rE rd rL rH r5 s r+ cache_parametersz!_LRUCacheWrapper.cache_parameters s5 N,dl##=
r* rS c Z | xj dz
c_ | j | d S N )rI rG move_to_endr6 rS s r+
_cache_hitz_LRUCacheWrapper._cache_hit s. q %%%%%r* c & | xj dz
c_ d S ri )rJ rl s r+ _cache_missz _LRUCacheWrapper._cache_miss s
r* r/ r. ra zasyncio.Task[_R]c f | j | | r1| | j |d d S | }|2| | | j |d d S | j | }| j A|?t j }| | j | j j |d |_
| | d S r3 )rL discard cancelledr4 rG rR exception
set_exceptiongetrF r8 get_running_loop
call_laterr0
set_resultresult)r6 r/ rS ra excrT loops r+ _task_done_callbackz$_LRUCacheWrapper._task_done_callback s
T""" >> JJLLL L S$ ' ' ' Fnn ? c " " " L S$ ' ' ' F\%%c**
: !j&<+--D$(OO
DL ,c4% %J ! t{{}}%%%%%r* fn_args fn_kwargsc K | j rt d| t j }t ||| j }| j | }|f| | |j
s t j |j d {V S |j S |
} | j |i |}| | }| j | | t' | j || t+ |d | j |< | j Ot/ | j | j k r2| j d \ } }| | | t j | d {V S )Nzalru_cache is closed for F)last)rH RuntimeErrorr8 rv r rE rG ru rm r/ r_ shieldry
create_futurerC create_taskrL addadd_done_callbackr r| r- rD rd popitemr4 ro )
r6 r} r~ r{ rS rT r/ corora dropped_keys
r+ __call__z_LRUCacheWrapper.__call__ s = C A4 A ABB B'))DL99\%%c**
! OOC >&&((
< $^JN ; ;;;;;;;; >((** * "" t 6I66!%!1!1$!7!7 wt'?c J JKKK &sD 1 1 S > %#dl*;*;dn*L*L&*l&:&:&:&F&F #K ^C(((((((((r* instanceownerz&_LRUCacheWrapperInstanceMethod[_R, _T]c * || S t | | S r3 ) _LRUCacheWrapperInstanceMethod)r6 r r s r+ __get__z_LRUCacheWrapper.__get__ s =K1$AA Ar* r7 ) r# r$ r% _CBr r
r( r& floatrM r r rU rZ rb r re r rg rm ro r| r r r r r r r) r* r+ r; r; ? s *6 G*6 # *6 *6
e_ *6
*6 *6 *6 *6X S T 16 = = = =$ = = = =
J
"2
&h &4 & & & &x D &'&.6&>P&
& & & &2 )# )C )B ) ) ) )@BB#+DH#5B t== >B B B B B Br* r; c e Zd Zdee deddfdZdedede fdZ
dd Z d
d d d
e de ddfdZ de
fdZdefdZdededefdZdS )r wrapperr r1 Nc |j | _ n# t $ r Y nw xY w |j | _ n# t $ r Y nw xY w |j | _ n# t $ r Y nw xY w |j | _ n# t $ r Y nw xY w |j | _ n# t $ r Y nw xY w | j |j n# t $ r Y nw xY wt | _ |j | _ || _
|| _ d S r3 ) r$ r? r# r% r@ r' rA rB r rC (_LRUCacheWrapperInstanceMethod__instance'_LRUCacheWrapperInstanceMethod__wrapper)r6 r r s r+ rM z'_LRUCacheWrapperInstanceMethod.__init__ sb
% 0DOO D # ,DMM D ' 4D D "?DLL D #*#:D D M !1 2 2 2 2 D +"." rN rO rP c 8 | j j | j g|R i |S r3 )r rU r )r6 rO rP s r+ rU z/_LRUCacheWrapperInstanceMethod.cache_invalidate s) .t~.tPPPPPPPr* c 8 | j d S r3 )r rZ r5 s r+ rZ z*_LRUCacheWrapperInstanceMethod.cache_clear s ""$$$$$r* FT)r4 r] r4 r] c H K | j d {V d S r3 )r rb )r6 r4 r] s r+ rb z*_LRUCacheWrapperInstanceMethod.cache_close s4 n((***********r* c 4 | j S r3 )r re r5 s r+ re z)_LRUCacheWrapperInstanceMethod.cache_info s ~((***r* c 4 | j S r3 )r rg r5 s r+ rg z/_LRUCacheWrapperInstanceMethod.cache_parameters s ~..000r* r} r~ c > K | j | j g|R i | d {V S r3 )r r )r6 r} r~ s r+ r z'_LRUCacheWrapperInstanceMethod.__call__ s< #T^DOKgKKKKKKKKKKKKr* r7 )r# r$ r% r; r r rM r r r& rU rZ rb r re r rg r r) r* r+ r r s4 "!!"%"! "!
"! "! "! "!HQ QS QT Q Q Q Q% % % % !&+ + + +:>+
+ + + +
+J + + + +1"2 1 1 1 1L# LC LB L L L L L Lr* r r r r= r1 c d dt t dt t f fd }|S )Nr< r1 c z | }t |t t f r#|j }t |t t f #t j | st
d| t | d r| } t t t t | S )Nz$Coroutine function is required, got _make_unbound_method)
isinstancer r funcr8 iscoroutinefunctionr hasattrr r; r r r )r< originr r= r s r+ r z _make_wrapper.<locals>.wrapper( s '=!9:: ![F '=!9:: ! *622 N Lb L LMM M 2- . . +((**B SWb 1 17E3GGGr* )_CBPr r; )r r r= r s ``` r+
_make_wrapperr # sV
HDH
H!1"!5
H
H
H
H
H
H
H
H Nr* F)r= c d S r3 r) )r r r= s r+ r r : s Cr* c d S r3 r) )r s r+ r r D s
Cr* c ( | t | t rt | || S t t t
| }t
| st |d r t ddd | S t |d )Nr r Fz decorating is not supported) r r( r r r r callabler NotImplementedError)r r r= r< s r+ r r L s *Wc22 WeS111
#b'7
#
# B<< 772'=>> 72=eT22266 6!R"G"G"GHHHr* r3 )r F).r8 dataclassessysasyncio.coroutinesr functoolsr r r r typingr r r
r r r
r r r r r r r r r version_infor typing_extensions __version____all__r r _Coror r r dataclassr- r; r r( r& r r r r) r* r+ <module>r si
, , , , , , C C C C C C C C C C C C & w &&&&&&
WT]] WT]]#sB, sE"I~ SW*,F
FG y # # # # # # # # eB eB eB eB eBwr{ eB eB eBP 7L 7L 7L 7L 7LWRV_ 7L 7L 7Lz
c]
% tBxj*2../ .
c]
%
tBxj*2../
"X b
/2I I I I
8C=$r(*
+I I
% I
8T"XJ 0 44 57G7K KL I I I I I Ir*