Ei;j%SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r J r SSK J r Jr SSKJr SSKJr SSKJr \ (aSS KJr \R."S 5r\"5rS \S '\R8"5rSS jr\R>"\5 Sr SSjr!"SS\"5r#"SS\#S9r$g)) annotationsN)contextmanagersuppress) TYPE_CHECKINGLiteral)WeakValueDictionary)AcquireReturnProxy)Timeout) Generatorfilelockzset[sqlite3.Connection]_all_connectionsc [ [[5H+n[[5 UR 5 SSS5 M- [R 5 SSS5 g!,(df  M[=f!,(df  g=fN)_all_connections_locklistrr Exceptioncloseclear)cons Q/home/mande/repo/quber/.venv/lib/python3.13/site-packages/filelock/_read_write.py_cleanup_connectionsrsT ()C)$ %$*   $$  s!"A5A# A5# A2 -A55 Bi5wcUSLagUS:Xa[$US:a Sn[U5eUS:a[X- S5OUn[US-5nU[:dUS:a![R SU[5 [$U$)NFrz+timeout must be a non-negative number or -1iz7timeout %s is too large for SQLite, using %s ms instead)_MAX_SQLITE_TIMEOUT_MS ValueErrormaxint_LOGGERwarning)timeoutblockingalready_waitedmsg remaining timeout_mss rtimeout_for_sqliter'(s5"}%%{;o4;aKG,a0WIY%&J**j1nQSZ\rs%% ch^\rSrSr%SrS\S'S\S'S SSS.S U4S jjjjrS rU=r$) _ReadWriteLockMeta;a Metaclass that handles singleton resolution when is_singleton=True. Singleton logic lives here rather than in ReadWriteLock.get_lock so that ``ReadWriteLock(path)`` transparently returns cached instances without a 2-arg ``super()`` call that type checkers cannot verify. 0WeakValueDictionary[pathlib.Path, ReadWriteLock] _instanceszthreading.Lock_instances_lockTr" is_singletonc >U(d[TU]XX4S9$[R"U5R 5nUR  XPR ;a[TU]XX4S9nX`R U'OUR UnURU:wdURU:wa-SURSURSUSU3n[U5eUsSSS5 $!,(df  g=f)Nr/z$Singleton lock created with timeout=z , blocking=z, cannot be changed to timeout=) super__call__pathlibPathresolver.r-r!r"r) cls lock_filer!r"r0 normalizedinstancer$ __class__s rr3_ReadWriteLockMeta.__call__Gs7#I#e e\\),446  / 7+I+m-5z*>>*57*h.?.?8.K:8;K;K:LKX`XiXiWjk55B,0OODNNeL "   +# " "s  C CcU(dURRSS9nO:US:XaURRSS9nOURRSUS9nU(d[UR5Seg)NFrNrTr"r!)rXacquirer r8)rar"r!acquireds r_acquire_transaction_lock'ReadWriteLock._acquire_transaction_locksr--55u5EH ]--55t5DH--55tW5UH$..)t 3r(c ~URU:wa0SUSURS[U5SUSUS3 n[U5eUS:XaZ[R "5=oPR :wa6SURS[U5S US UR 3n[U5eU=RS - sl[US 9$) NzCannot acquire z lock on (lock id: z): already holding a z lock (z not allowed)writezCannot acquire write lock on z) from thread z while it is held by thread r lock) r[r8id RuntimeErrorrV get_identr\rZr )ramodeopposite directionr$curs r_validate_reentrant!ReadWriteLock._validate_reentrants    %!$y0@ BtH:V%%-Jgi[ O s# # 7?y':':'< <AVAVV//?{2d8*U"e#?@U@U?VX s# # A!t,,r(cb[R"5U- n[X#US9nURR SUS35R 5 URR S5R 5 [R"5U- n[X#US9=ov:wa-URR SUS35R 5 US:XaSOSnURR U5R 5 US:Xa*URR S 5R 5 gg) N)r"r#zPRAGMA busy_timeout=;zPRAGMA journal_mode=MEMORY;rlzBEGIN EXCLUSIVE TRANSACTION;zBEGIN TRANSACTION;readz'SELECT name FROM sqlite_schema LIMIT 1;)time perf_counterr'r_executer) rarrr!r" start_timewaitedr& recomputedstmts r_configure_and_begin"ReadWriteLock._configure_and_begins""$z1'SYZ  0 A>?EEG 78>>@""$z1,WX^_ _J n II   4ZLB C I I K15-FZ $%%' 6> II  G H N N P r(cUS:XaSOSnUS:XaSOSnUR URS:aURXU5sSSS5 $SSS5 [R"5nUR X2S9 UR URS:a5URXU5sSSS5 UR R5 $SSS5 URXX6S9 UR Xl SUlUS:Xa[R"5Ul SSS5 [US 9UR R5 $!,(df  GN=f!,(df  N=f!,(df  NT=f![Ra+nS [!U5;ae[#UR$5SeSnAff=f!UR R5 f=f) Nrzrl downgradeupgraderre)r"r~r rmzdatabase is locked)rYrZrvr{r|rhrXreleaserr[rVrqr\r r]OperationalErrorstrr r8)rarrr!r"rsrtr~excs r_acquireReadWriteLock._acquires"fn7&#'6>Ky  !#// J! #!&&(  &&&J -$$##a'33DIN%$&  " " * * ,%(%  % %dh % ^$$%)"#$ 7?,5,?,?,AD) % &40  " " * * ,7! %$ %$'' 4#3s83$..)t 3 4  " " * * ,se"E ; E?"E) E?$E?2.E. E? E E+'E?. E<8E??F>&F99F>>GGc"URSXS9$)a Acquire a shared read lock. If this instance already holds a read lock, the lock level is incremented (reentrant). Attempting to acquire a read lock while holding a write lock raises :class:`RuntimeError` (downgrade not allowed). :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: a proxy that can be used as a context manager to release the lock :raises RuntimeError: if a write lock is already held on this instance :raises Timeout: if the lock cannot be acquired within *timeout* seconds rzrNrrar!r"s r acquire_readReadWriteLock.acquire_reads }}VW}@@r(c"URSXS9$)a. Acquire an exclusive write lock. If this instance already holds a write lock from the same thread, the lock level is incremented (reentrant). Attempting to acquire a write lock while holding a read lock raises :class:`RuntimeError` (upgrade not allowed). Write locks are pinned to the acquiring thread: a different thread trying to re-enter also raises :class:`RuntimeError`. :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: a proxy that can be used as a context manager to release the lock :raises RuntimeError: if a read lock is already held, or a write lock is held by a different thread :raises Timeout: if the lock cannot be acquired within *timeout* seconds rlrNrrs r acquire_writeReadWriteLock.acquire_writes$}}Wg}AAr(FforcecSnUR URS:Xa8U(a SSS5 gSURS[U5S3n[ U5eU(aSUlOU=RS-slURS:XaSUlSUlSnSSS5 U(aURR5 gg!,(df  N1=f) aD Release one level of the current lock. When the lock level reaches zero the underlying SQLite transaction is rolled back, releasing the database lock. :param force: if ``True``, release the lock completely regardless of the current lock level :raises RuntimeError: if no lock is currently held and *force* is ``False`` FrNzCannot release a lock on rkz) that is not heldr T) rYrZr8rorpr[r\r_rollback)rarshould_rollbackr$s rrReadWriteLock.releases   1$! 2$..1ARPTXJVhi"3''#$   A% 1$%)"(,%"&!  II    ! sCA+C CNc## Uc URnUc URnURXS9 Sv UR5 g!UR5 f=f7f)aU Context manager that acquires and releases a shared read lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default NrN)r!r"rrrs r read_lockReadWriteLock.read_lock8sO ?llG  }}H '5   LLNDLLN.AAAAAc## Uc URnUc URnURXS9 Sv UR5 g!UR5 f=f7f)aZ Context manager that acquires and releases an exclusive write lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default NrN)r!r"rrrs r write_lockReadWriteLock.write_lockMsO ?llG  }}H 76   LLNDLLNrcURSS9 URR5 [ [R UR5 SSS5 g!,(df  g=f)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. TrN)rr_rrrdiscard)ras rrReadWriteLock.closebsA 4    "  $ $TYY /# " "s A A') r_r[rYrZrXr\r"r8r!r>)r8r?r!r@r"rArBrC) r8r?r!r@r"rAr0rArBNone)r"rAr!r@rBr)rrLiteral['read', 'write']rsrrtrrBr ) rrrr!r@r"rAr~r@rBr)rrrr!r@r"rArBr )r!r@r"rArBr )rrArBrr)r!z float | Noner"z bool | NonerBzGenerator[None]rBr)rDrErFrGrHrr-rIrVrWr. classmethodrPrbrhrvrrrrrrrrrrJr=r(rrCrCcs[(DWCXJ@Xnn&OAC:Y]:.:9>:RV: ::(, ! ,),,  ,  , ,(4- Q,Q7<QKOQ]bQ Q2-BADAA$BTBB((-!:QU(RV( 0r(rC) metaclassr)r!r@r"rAr#r@rBr)% __future__ratexitloggingrTr4r]rVr{ contextlibrrtypingrrweakrefr_apir _errorr collections.abcr getLoggerrsetrrIrWrrregisterrr'typer*rCr=r(rrs"   /)'$)   J ',/E)1!(!$%+&%%PI00I0r(