ejPvUdZddlmZgdZddlZddlZddlZddlmZddl m Z ddl m Z ddlmZdd lmZmZmZmZmZmZmZdd lmZdd lmZmZmZmZdd lm Z erdd l!m"Z"m#Z#m$Z$ddl m%Z%ddl&m'Z'ddl(m)Z)edZ*dZ+de,d<Gdde-Z.e dGddee*Z/GddZ0e GddZ1GddZ2eZ3d e,d!<eZ4d"e,d#<dGd'Z5dHd)Z6dId-Z7dJd/Z8dKd2Z9dJd3Z:dLd:Z;dMd<ZgdFZ?dS)PzKSeparate caller cancellation from backend task and executor-future results.) annotations)asyncio collectionszconcurrent.futureszfilelock._errorN)deque)Future) dataclass)Lock) TYPE_CHECKINGFinalGenericLiteralNoReturnTypeVarcast)WeakKeyDictionary)_append_exception_context_fork_transition_raise_chained_errors_resolve_read_write_timeout)Timeout)AsyncGenerator AwaitableCallable)Executor) ReadWriteLock)SoftReadWriteLock_Tz Final[int]_TASKS_THREAD_IDceZdZdS) _AsyncTransitionUnavailableErrorN)__name__ __module__ __qualname__W/home/spazio/cosmos_universe_media/venv/lib/python3.11/site-packages/filelock/_async.pyr r 'sDr%r T)frozenc,eZdZUdZded<dZded<dS)_BackendOutcomeNz _T | NonevaluezBaseException | Noneerror)r!r"r#r*__annotations__r+r$r%r&r)r)+s4E"&E&&&&&&r%r)ceZdZdZddZejddZejddZddZ ddZ ddZ ddZ ddZ dS)_AsyncTransitionGatea  First-in, first-out admission for the calls that transition one lock context. Each call queues a ticket, and the head of the queue holds the gate. A call that gives up removes its own ticket, so abandoned calls do not pile up behind a long holder. returnNonecRt|_t|_dSN)r _queue_lockr_queueselfs r&__init__z_AsyncTransitionGate.__init__9s(,floatc"Kt} |||s ||||||d{VdWV||dS#||wxYw)Nr:r?)r6r;r<r=r>rFs r&hold_for_acquirez%_AsyncTransitionGate.hold_for_acquireHs*:);); JJv   ;;== ))%!-%"/ * EEEE KK     DKK    rHrFConcurrentFuture[None]cK|sttj|}|s||rt|}|3|t jz x}dkrtt ||}tj|f|d{V||dSdS)Nrtimeout) r r wrap_futurerBtime perf_counterminwait _settle_head) r6rFr;r<r=r>waiter wait_interval remainings r&rCz#_AsyncTransitionGate._wait_for_turn`s 32 2$V,,++-- 'LLNN'66)M#!)D,=,?,?!??IAEE:: #M9 = = ,y-@@@ @ @ @ @ @ @ @      ++-- r%c|j5|j|t|jdkr|dddddS#1swxYwYdS)N)r3r4appendlen set_resultrEs r&rAz_AsyncTransitionGate._joinxs   ( ( K  v & & &4;1$$!!$''' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (sAAA!$A!c|j5 |j|n#t$rYddddSwxYw|ddddS#1swxYwYdSr2)r3r4remove ValueError_settle_head_lockedrEs r&rDz_AsyncTransitionGate._leave~s   ' '  ""6****     ' ' ' ' ' ' ' '   $ $ & & &  ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 's,A"%A" >A">A""A&)A&cn|j5|ddddS#1swxYwYdSr2)r3rdr5s r&rXz!_AsyncTransitionGate._settle_heads   ' '  $ $ & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 's *..c|jr8|jdx}s|ddSdSdS)Nr)r4rBr`)r6heads r&rdz(_AsyncTransitionGate._settle_head_lockedsV ; " A 6<<>> " OOD ! ! ! ! ! " " " "r%Nr/r0)r/r8) r;rIr<rJr=rKr>rLr/r8) rFrOr;rIr<rJr=rKr>rLr/r0rFrOr/r0)r!r"r#__doc__r7 contextlibasynccontextmanagerrGrNrCrArDrXrdr$r%r&r.r.1sDDDD#   $# #   $# .    0(((( ''''''''""""""r%r.ceZdZUdZded<dS) _TaskHoldz One task's hold, as the nesting count per wrapper it entered through. A task's hold ends when its last wrapper level is released or closed. Closing one wrapper ends only the levels taken through it. zdict[object, int]depthsN)r!r"r#rjr,r$r%r&rnrns*r%rncheZdZdZd-dZd.dZd/dZd0dZd1dZd2d!Z d"d#d3d'Z d4d)Z d5d+Z d-d,Z d"S)6 _TaskOwnersal Per-task ownership in front of a sync reader/writer lock that tracks threads. An async wrapper runs each call on an executor thread, and that thread does not identify the calling task. Waiting writers block new readers so a stream of readers cannot starve them. A thread lock guards the table because tasks on different event loops share it. The table stands for one backend level, taken once for all tasks. Sync code can end that level directly, with ``close()`` or a forced release on a shared singleton. The next admission then forgets the holds instead of letting more tasks join them. r/r0crt|_d|_i|_d|_d|_i|_dS)NFr)r _lock_mode_holds_transitioning_waiting_writers_waitersr5s r&r7z_TaskOwners.__init__s8"&&& 6: =? # !=? r%modeLiteral['read', 'write']rRrLr;rI lock_filestrviaobjectenter"Callable[[float], Awaitable[None]]joinableCallable[[], bool]c LKt}t||}|r|dkrdntj|z} d} t ||||||| x} t r |r| &tj| krt||dkr3| s1d} |j5|xj dz c_ dddn #1swxYwY| dn| tjz } tj tj | f| d{V| | n#| | wxYwt ||||||| x} t | rC|j5|xj dzc_ |dddn #1swxYwYnK#| rD|j5|xj dzc_ |dddw#1swxYwYwwxYw| d krdS || d n#td | tjz d{Vn%#t $r|d wxYw|||t%|di idS)N)r;rF)r}rwaiting_writerwriteTr]rQheldgryroryholds) _current_taskrrTrU isinstance_admitr@rrsrwrrWrS_forget_notifymax BaseException_finish_transitionrn) r6ryrRr;r{r}rrtaskr=r admissionrWs r&acquirez_TaskOwners.acquires-gIII'Y7Q;;44D>GG H%H9 HH H H H7I"I8rasyncio.Task[object]r1Literal['held', 'enter'] | ConcurrentFuture[None]c |j5|j1|js*|s |jd|_|j|x}m|j|kr.d|d|d|dkrdndd|dkrdndd }t ||j|d d z|j|< dddd S|j|z } |jsg|dkr5|jdkr*| s(t|d i |j|< dddd S|js%|dks| sd|c|_|_ ddddS| cdddS#1swxYwYdS)NzCannot acquire z lock on z: already holding a readrz lock ( downgradeupgradez not allowed)rr]rrTr) rsrtrvruclearget RuntimeErrorrorwrn_ticket) r6rryr{r}rrrGmsg writers_aheads r&rz_TaskOwners._admitshZ " "z%d.A%((**% !!###!  ---::%%X$XXXX&*fnn77&XX+/6>>KKyXXX 's+++#';??3#:#:Q#> C  " " " " " " " " !1NBM& #6>>djF&:&:=&:(1#q(B(B(BDK%!) " " " " " " " "*{#}6:D3D'"/ " " " " " " " "0<<>>1 " " " " " " " " " " " " " " " " " "s$B5E" ?E"E"E""E&)E&forceleave3Callable[[], asyncio.Future[_BackendOutcome[None]]] still_heldcpKt}|j5|j|x} ||jvr%|r ddddSd|d}t ||s4|j|dkr#|j|xxdzcc< ddddS|j|} |jr ddddS|j|=|jr ddddSd|_|j} dddn #1swxYwY|s+| dd|d}t | t|d{V} n>#t$r1| |j|<| |r| nd||iwxYw| d| | dS)NzCannot release a lock on z3 that is not held by this task through this wrapperr]Trz that is not held by this taskr) rrsrurrorpoprvrtr_drain_cancellationr) r6rr{r}rrrrGrremovedry cancellations r&releasez_TaskOwners.releases Z   ---6#T[:P:P        q)ppp"3''' T[-11 C   A%           kooc**G{          D!{         #'D :D!               "z|| $  # # # . . .WiWWWCs## # !4UUWW!=!=======LL   &DK   # #)G4PTVZ| # \ \ \    T***  #  $ #s5)C?>C?"C?C?%C??DDE;F object | NonecKd}t||x}tr tt j|d{Vn#tj$r }|}Yd}~nd}~wwxYw||n#||wxYwt||x}t|\}}| |t|rj t|d{Vp|}n2#t$r%| |r|nd|wxYw| dn|| d||dS)a End the holds taken through *via*, or every hold when it is ``None``, as one transition. Leaves the backend through *leave* when that ends the last hold, and always when *via* is ``None``. Arrivals wait while it runs, so none joins a hold the backend is letting go of. A transition already under way is waited out first: a task entering through *via* must not get a hold after the wrapper is gone. A cancellation is raised once the holds are settled. Nrr) r_drop_holds_viar@_wait_until_donerrSCancelledErrorrrrr) r6r}rrrsettledr+rydroppeds r&retirez_TaskOwners.retire0s7; D$8$8$=$==?OPP & &&w':7'C'CDDDDDDDDDD) % % %$  % W%%%% W%%%% D$8$8$=$==?OPP & g ;4+ + %8%A%AAAAAAAQ\     ''ZZ\\-KTTtSZ'[[[   # # # . . . .    # # # . . .  #  $ #s;'AB A3'A.)B .A33B B#$D/D3ftuple[Literal['read', 'write'] | None, dict[asyncio.Task[object], _TaskHold]] | ConcurrentFuture[None]c2|j5|jr |cdddS|.t|j}|jnoi}t |jD]F\}}|j |dx}$t||i||<|js|j|=G|jr|d|fcdddS|j }|dup|du|_||fcdddS#1swxYwYdS)Nr) rsrvrdictrurlistitemsrorrnrt)r6r}rrrGcountrys r&rz_TaskOwners._drop_holds_viaVs Z ! !" &||~~ ! ! ! ! ! ! ! !{t{++ !!####"&t{'8'8':':";";22JD$!%d!;!;;H(1#u(F(F(F #{2 $ D 1{ %sW} ! ! ! ! ! ! ! !:D"&d"2"AcTkD =# ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !sD B+D (D  DDN)rLiteral['read', 'write'] | Noner,dict[asyncio.Task[object], _TaskHold] | NonecT|j5d|c|_|_|b|r`|D]K\}}|j|t ij|jL| ddddS#1swxYwYdS)NFr) rsrvrtrru setdefaultrnroupdater)r6ryrrrGs r&rz_TaskOwners._finish_transitionnsZ  .3T +D E"'++--bbJD$K**4"1E1E1EFFMTTUYU`aaaa LLNNN                   sBBB!$B!rOc6t}d|j|<|Sr2)r@rxrEs r&rz_TaskOwners._ticketxs)9);); $ f r%rFc||j5|j|dddddS#1swxYwYdSr2)rsrxrrEs r&rz_TaskOwners._forget~s Z , , M  fd + + + , , , , , , , , , , , , , , , , , ,s 155cX|jic}|_|D]}|ddSr2)rxr`)r6waitersrFs r&rz_TaskOwners._notifysB!% $ $F   d # # # # $ $r%rh)ryrzrRrLr;rIr{r|r}r~rrrrr/r0)rrryrzr{r|r}r~rrrrIr/r) rrIr{r|r}r~rrrrr/r0)r}rrrrrr/r0)r}rr/r)ryrrrr/r0)r/rOri)r!r"r#rjr7rrrrrrrrrr$r%r&rqrqs????-U-U-U-U^""""""""H****X$$$$L!!!!2os ,,,,$$$$$$r%rqzHFinal[WeakKeyDictionary[ReadWriteLock | SoftReadWriteLock, _TaskOwners]] _TASK_OWNERSz Final[Lock]_TASK_OWNERS_LOCK sync_lock!ReadWriteLock | SoftReadWriteLockr/ct5t5t|x}t x}t|<|cdddcdddS#1swxYwYddddS#1swxYwYdS)zNSingleton wrappers share one sync lock, so they must share its task holds too.N)rrrrrq)rownerss r&_task_owners_forrs$   ."&&y11 1F :/:}} 6A& A>&A* *A>-A* .A>>BBrcRtjx}d}t||S)NzDan async reader/writer lock must be used from inside an asyncio task)r current_taskr)rrs r&rrs.$&&&/T3 Kr%future%asyncio.Future[_BackendOutcome[None]]asyncio.CancelledError | NonecK t|d{Vn\#tj$rJ} t|d{Vn'#t$r}t ||Yd}~nd}~wwxYw|cYd}~Sd}~wwxYwt |dSr2)rrr _drain_futurer_raise_cancelled_error_future_result)rrr+s r&rrsv&&&&&&&&&&  ! 8'' ' ' ' ' ' ' ' ' 8 8 8 "< 7 7 7 7 7 7 7 7 8  6 4s=A3AA. A$ AA.A$$A.(A3.A3#asyncio.Future[_BackendOutcome[_T]]c K|s_tjtj5t |d{Vdddn #1swxYwY|_t |Sr2)rBrksuppressrrrrrs r&rrskkmm+  !7 8 8 + +"6** * * * * * * * + + + + + + + + + + + + + + +kkmm+ & ! !!sAAAasyncio.Future[_T]r0clK|stj|fd{VdSdSr2)rBrrWrs r&rrsJ ;;==&lF9%%%%%%%%%%%&&r%c|}|jx}td|jS|j} |#t $r ||_wxYw)Nr)resultr+rr* __context__r)routcomer+contexts r&rrsfmmooG'D'-(((G # s =Aloopasyncio.AbstractEventLoopexecutorExecutor | NonefuncCallable[[], _T]c|dfd }||t||S)Ncallrr/r0c |}n4#tj$r"d}tt |}YnwxYw|dS)Nz;the executor shut down before running the lock backend callr+)rrrr)rr`)rrrrs r&settlez _run_in_executor..settlesu >[[]]FF% > > >PC$<+<+<===FFF  > 6"""""s.A A )rrr/r0) create_futurerun_in_executor _capture_calladd_done_callback)rrrrrs @r&_run_in_executorrsa483E3E3G3GG###### =$77II&QQQ Nr%_BackendOutcome[_T]c t|S#t$r}t|cYd}~Sd}~wwxYwN)r*rr)r)rr+s r&rrs],TTVV,,,, ,,,U+++++++++,s >9>>rasyncio.CancelledErrorr+rrc|jx}$||ur |jx}t||||_||_t|dSr2)rrr)rr+rcancellation_contexts r&rrs`$$1g\6Q6Q$0$< < I %g/C D D D#*  $E%     r% awaitable Awaitable[_T]cK t|d{VS#t$r}t|cYd}~Sd}~wwxYwrr)rr+s r&_capture_awaitablersg,9______5555 ,,,U+++++++++,s >9>>) rr.r r)rrrrrrrr)rrr/rq)r/r)rrr/r)rrr/r)rrr/r0)rrrrrrr/r)rrr/r)rrr+rr/r)rrr/r)@rj __future__r__lazy_modules__rrkrTrrconcurrent.futuresrr@ dataclassesr threadingr typingr r r r rrrweakrefr filelock._apirrrrfilelock._errorrcollections.abcrrrrfilelock._read_writerfilelock._soft_rwrrrr, Exceptionr r)r.rnrqrrrrrrrrrrrr__all__r$r%r&rsQQQ""""""VVV 999999!!!!!!RRRRRRRRRRRRRRRRRR%%%%%% $#####4CCCCCCCCCC++++++222222333333 WT]] !      y    $'''''gbk''' \"\"\"\"\"\"\"\"~  i$i$i$i$i$i$i$i$XZkYjYlYl llll!%''''    """"&&&&    &,,,, ! ! ! !,,,,   r%