-2iM'UddlmZdZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZmZmZmZmZmZmZmZdd lmZd d lmZd d lmZm Z ej!d krddlm"Z"nddl#m"Z"edZ$edZ%e"dZ&edZ'de(d<GddZ)e)Z*de(d<GddeZ+GddeZ,eGddee&e$fZ-Gddee$Z.edGd#Z/edHd&Z/dId)Z/ed*d*d*d+dJd2Z0edGd3Z0edHd4Z0 dKd5d6d6d+dLd9Z0edMd?Z1edNdBZ1e*fdOdFZ1dS)P) annotations)AsyncCacheInfoAsyncCacheParametersAsyncLRUCacheWrappercache lru_cachereduceN) OrderedDict) AsyncIterable AwaitableCallable CoroutineHashableIterable)update_wrapper)iscoroutinefunction)AnyGeneric NamedTuple TypedDictTypeVarcastfinaloverload)WeakKeyDictionary)Lock)RunVar checkpoint) ) ParamSpecTSPlru_cache_itemszRunVar[WeakKeyDictionary[AsyncLRUCacheWrapper[Any, Any], OrderedDict[Hashable, tuple[_InitialMissingType, Lock] | tuple[Any, None]]]]ceZdZdS)_InitialMissingTypeN)__name__ __module__ __qualname__N/var/www/html/pixcura-vrs/venv/lib/python3.11/site-packages/anyio/functools.pyr(r(8sDr-r(initial_missingc8eZdZUded<ded<ded<ded<dS)rinthitsmisses int | NonemaxsizecurrsizeNr)r*r+__annotations__r,r-r.rr?s7 IIIKKKMMMMMr-rc.eZdZUded<ded<ded<dS)rr4r5booltypedalways_checkpointNr7r,r-r.rrFs3KKKr-rc6eZdZddZdd Zdd ZddZddZdS)rfuncCallable[..., Awaitable[T]]r5r4r;r:r<c||_d|_d|_|t|dnd|_d|_||_||_t||dSNr) __wrapped___hits_missesmax_maxsize _currsize_typed_always_checkpointr)selfr>r5r;r<s r.__init__zAsyncLRUCacheWrapper.__init__Ns^   +2+>GQD  "3tT"""""r-returnrcNt|j|j|j|jSN)rrCrDrFrGrJs r. cache_infozAsyncLRUCacheWrapper.cache_info^sdj$, t~VVVr-rc,|j|j|jdS)Nr5r;r<rFrHrIrOs r.cache_parametersz%AsyncLRUCacheWrapper.cache_parametersas!}[!%!8   r-Nonectdx}r-||ddx|_x|_|_dSdSrA)r&getpoprCrDrG)rJrs r. cache_clearz AsyncLRUCacheWrapper.cache_clearhsT#''-- -5 ; IIdD ! ! !9: :DJ : ; ;r-argsP.argskwargsP.kwargsr#cK|jdkr%|j|i|d{V}|xjdz c_|S|}|r.|tft |dzz }|jrU|td|Dz }|r7|tftd|Dzz } t }n8#t$r+t}t |YnwxYw ||}n##t$rtx}||<YnwxYw ||\}}n4#t$r'tt!|j }}||f||<YnwxYw|U|xjdz c_|||jrt)d{Vt+t,|S|4d{V||dx}turi|xjdz c_|j'|j|jkr|dn|xjdz c_|j|i|d{V}|df||<n:|xjdz c_||t+t,|} dddd{Vn#1d{VswxYwY|S) Nrrr,c34K|]}t|VdSrNtype).0args r. z0AsyncLRUCacheWrapper.__call__..{s(33sc333333r-c34K|]}t|VdSrNr`)rbvals r.rdz0AsyncLRUCacheWrapper.__call__..}s(1W1W$s))1W1W1W1W1W1Wr-) fast_acquireF)last)rFrBrDr/sumitemsrHtuplevaluesr&rW LookupErrorrsetKeyErrorr rrIrC move_to_endrrr#rGpopitem) rJrZr\valuekeyr cache_entry cached_valuelocks r.__call__zAsyncLRUCacheWrapper.__call__ms =A  *$*D;F;;;;;;;;E LLA LLL $  @ O%FLLNNB(?(?? ?C ; X 533d33333 3C X)E1W1Wv}}1W1W1W,W,WWW '#''))EE ' ' '%''E    & & & & & ' 6+KK 6 6 6(3 5K%+++ 6 2!,S!1 L$$ 2 2 2 d&="=>>>L ,T1K     2 < JJ!OJJ  # #C ( ( (& # ll"""""""<(( ( . . . . . . . . +C 0 33 GG ! =,4=1P1P''U'3333NNa'NN.d.?????????#($; C   a '',,,Q --- . . . . . . . . . . . . . . . . . . . . . . . . . . ." sIC2DDDD>=D> E.E?>E?!B;J// J9<J9N)r>r?r5r4r;r:r<r:)rLr)rLr)rLrU)rZr[r\r]rLr#)r)r*r+rKrPrTrYrwr,r-r.rrLs#### WWWW    ;;;; BBBBBBr-rcNeZdZddZedd ZeddZddZdS)_LRUCacheWrapperr5r4r;r:r<c0||_||_||_dSrNrS)rJr5r;r<s r.rKz_LRUCacheWrapper.__init__s  "3r-r>#Callable[P, Coroutine[Any, Any, T]]rLAsyncLRUCacheWrapper[P, T]cdSrNr,rJr>s r.rwz_LRUCacheWrapper.__call__s &)Sr-Callable[..., T]functools._lru_cache_wrapper[T]cdSrNr,r~s r.rwz_LRUCacheWrapper.__call__s +.#r-f6Callable[P, Coroutine[Any, Any, T]] | Callable[..., T]r{rLr|r>rrLr)rrrLr)r)r*r+rKrrwr,r-r.ryrys4444 )))X)...X.PPPPPPr-ryr>r{rLr|cdSrNr,r>s r.rr "%r-rrcdSrNr,rs r.rrsILr-6Callable[..., T] | Callable[P, Coroutine[Any, Any, T]]rc4td|S)z A convenient shortcut for :func:`lru_cache` with ``maxsize=None``. This is the asynchronous equivalent to :func:`functools.cache`. N)r5)rrs r.rrs #9T " " "4 ( ((r-.rRr5r4r;r:r<_LRUCacheWrapper[Any]cdSrNr,rRs r.rrs  Cr-cdSrNr,rs r.rrrr-cdSrNr,rs r.rrsMPSr-F=Callable[P, Coroutine[Any, Any, T]] | Callable[..., T] | NoneTAsyncLRUCacheWrapper[P, T] | functools._lru_cache_wrapper[T] | _LRUCacheWrapper[Any]c|tt|||St|stdtt||||S)a An asynchronous version of :func:`functools.lru_cache`. If a synchronous function is passed, the standard library :func:`functools.lru_cache` is applied instead. :param always_checkpoint: if ``True``, every call to the cached function will be guaranteed to yield control to the event loop at least once .. note:: Caches and locks are managed on a per-event loop basis. Nz#the first argument must be callable)ryrcallable TypeErrorr#)r>r5r;r<s r.rrsa, |$We5FGGG D>>?=>>> A A w/@ A A$ G GGr-initialfunctionCallable[[T, S], Awaitable[T]]iterableIterable[S] | AsyncIterable[S]c KdSrNr,)rrrs r.r r s r-Callable[[T, T], Awaitable[T]]Iterable[T] | AsyncIterable[T]c KdSrNr,)rrs r.r r s r-T | _InitialMissingType?Callable[[T, T], Awaitable[T]] | Callable[[T, S], Awaitable[T]]?Iterable[T] | Iterable[S] | AsyncIterable[T] | AsyncIterable[S]cKd}t|tr|}|turM t t |d{V}n3#t$rtddwxYwt t |}|23d{V}|||d{V}d}6nt|trt|}|turB t t t|}n3#t$rtddwxYwt t |}|D]}|||d{V}d}ntd|std{V|S)at Asynchronous version of :func:`functools.reduce`. :param function: a coroutine function that takes two arguments: the accumulated value and the next element from the iterable :param iterable: an iterable or async iterable :param initial: the initial value (if missing, the first element of the iterable is used as the initial value) FNz0reduce() of empty sequence with no initial valueTz9reduce() argument 2 must be an iterable or async iterable) isinstancer __aiter__r/rr# __anext__StopAsyncIterationrriternext StopIterationr)rrrfunction_calledasync_itrrelementits r.r r #s"O(M**U%%'' o % % Qh&8&8&:&: : : : : : :;;%   F  G$$E% # # # # # # #'"(5'22222222E"OO&X Hh ' 'U (^^ o % % QR))    F  G$$E # #G"(5'22222222E"OO #STTT ll Ls-A&&BB7'"D D%rr)r>rrLr)r5r4r;r:r<r:rLrrN) r>rr5r4r;r:r<r:rLr)rr#rrrrrLr#)rrrrrLr#)rrrrrrrLr#)2 __future__r__all__rsys collectionsr collections.abcr r r rrrrinspectrtypingrrrrrrrrweakrefr_core._synchronizationrlowlevelrr version_infor"typing_extensionsr#r$r%r&r8r(r/rrrryrrr r,r-r.rsU"""""""  ######%$$$$$''''''                    &%%%%%((((((((((((((w       ++++++ GCLL GCLL IcNN  F          (;':'<'<<<<<Z9 bbbbb71a4=bbbJPPPPPwqzPPP6 %%% %  LLL L ) ) ) )  s        %%% %  PPP PKOH# HHHHHH>            (7 8888888r-