+ ~j;~a0t$^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t H t ^RI HtHt^RIHt^RIHt^RIHt]'d^RIHt]P0!R 4t]!4tR ]R &]P:!4tR R lt]P@!]4Rt!RRlt"!RR]#4t$!RR]$R7t%R#)) annotationsN)contextmanagersuppress) TYPE_CHECKINGLiteral)WeakValueDictionary)AcquireReturnProxy)Timeout) Generatorfilelockzset[sqlite3.Connection]_all_connectionscV^8dQhRR/#returnNone)formats"i/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/filelock/_read_write.py __annotate__rs!!d!c 8\;_uu_4\\4F3p\\4;_uu_4VP 4RRR4K5 \P 4RRR4R# +'giKf;i +'giR#;iN)_all_connections_locklistr r Exceptioncloseclear)cons r_cleanup_connectionsr s`  ()C)$$ %$*   $$$   s"*BA4 B4 B? B B c(V^8dQhRRRRRRRR/#)rtimeoutfloatblockingboolalready_waitedrintr)rs"rrr(s)D%TWrcVRJd^#VR8Xd\#V^8dRp\V4hV^8d\W, ^4MTp\VR,4pV\8gV^8d"\P RV\4\#V#)Fz+timeout must be a non-negative number or -1iz7timeout %s is too large for SQLite, using %s ms instead)_MAX_SQLITE_TIMEOUT_MS ValueErrormaxr'_LOGGERwarning)r"r$r&msg remaining timeout_mss&$$ rtimeout_for_sqliter2(s5"}%%{;o4;aKG,a0WIY%&J**j1nQSZ\rs%% rcXa]tRt^;t$RtR]R&R]R&R RRRR/R V3R lllltR tV;t#) _ReadWriteLockMetaa 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_lockr$T is_singletonc ,V^8dQhRRRRRRRRRR /#) r lock_filestr | os.PathLike[str]r"r#r$r%r8r ReadWriteLockr)rs"rr_ReadWriteLockMeta.__annotate__Gs<)     rc  <V'g\SV`WW4R7#\P!V4P 4pVP ;_uu_4WPP 9d!\SV`WW4R7pW`P V&MVP V,pVPV8wgVPV8wd.RVP RVP RV RV 2p\V4hVuuRRR4# +'giR#;i))r$r8z$Singleton lock created with timeout=z , blocking=z, cannot be changed to timeout=N) super__call__pathlibPathresolver7r6r"r$r+) clsr:r"r$r8 normalizedinstancer/ __class__s &&&$$ rr@_ReadWriteLockMeta.__call__Gs7#I#e e\\),446  / 7+I+m-5z*>>*57*h.?.?8.K:8;K;K:LKX`XiXiWjk55:RV: :rc V!WVR7#)a Return the singleton :class:`ReadWriteLock` for *lock_file*. :param lock_file: path to the SQLite database file used as the lock :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: the singleton lock instance :raises ValueError: if an instance already exists for this path with different *timeout* or *blocking* values r$r)rDr:r"r$s&&&$rget_lockReadWriteLock.get_lock{s 999rr8c ,V^8dQhRRRRRRRRRR /#) rr:r;r"r#r$r%r8rrr)rs"rrrTs<,,),,  ,  , ,rc \P!V4VnW nW0n\ P !4Vn\ P !4Vn^Vn RVn RVn \P!VPRR7Vn\;_uu_4\ P#VP4RRR4R# +'giR#;i)rNF)check_same_thread)osfspathr:r"r$ threadingLock_transaction_lock_internal_lock _lock_level _current_mode_write_thread_idsqlite3connect_conrr add)selfr:r"r$r8s&&&$$r__init__ReadWriteLock.__init__s9-  !*!1'nn.>B,0OODNNeL " "   +# " " "s & C C! c$V^8dQhRRRRRR/#)rr$r%r"r#rrr)rs"rrrTs!44T4E4d4rc V'gVPPRR7pMAVR8XdVPPRR7pMVPPRVR7pV'g\VP4RhR#)FrVTr$r"Nr))r`acquirer r:)rir$r"acquireds&$$ r_acquire_transaction_lock'ReadWriteLock._acquire_transaction_locksr--55u5EH ]--55t5DH--55tW5UH$..)t 3rc(V^8dQhRRRRRRRR/#)rmodeLiteral['read', 'write']oppositestr directionrr r)rs"rrrTs+--(@-C-\_-dv-rc  VPV8wd1RV RVP R\V4 RV RV R2 p\V4hVR8Xd\\P !4;qPP 8wd7RVP R\V4 RV R VP 2p\V4hV;P^, un\VR 7#) zCannot 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 lock) rcr:id RuntimeErrorr^ get_identrdrbr )rirtrvrxr/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,,rc ,V^8dQhRRRRRRRRRR /#) rrtrur"r#r$r% start_timerrr)rs"rrrTs;QQ,Q7<QKOQ]bQ Qrc \P!4V, p\W#VR7pVPP RV R24P 4VPP R4P 4\P!4V, p\W#VR7;qv8wd.VPP RV R24P 4VR8XdRMRpVPP V4P 4VR8Xd,VPP R4P 4R #R #) )r$r&zPRAGMA busy_timeout=;zPRAGMA journal_mode=MEMORY;r{zBEGIN EXCLUSIVE TRANSACTION;zBEGIN TRANSACTION;readz'SELECT name FROM sqlite_schema LIMIT 1;N)time perf_counterr2rgexecuter) rirtr"r$rwaitedr1 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 rc(V^8dQhRRRRRRRR/#) rrtrur"r#r$r%rr r)rs"rrrTs+--5--TX-]o-rc VR8XdRMRpVR8XdRMRpVP;_uu_4VP^8dVPWV4uuRRR4#RRR4\P!4pVP W2R7VP;_uu_4VP^8d7VPWV4uuRRR4VP P4#RRR4VPWW6R7VP;_uu_4Wn ^VnVR8Xd\P!4Vn RRR4\VR7VP P4# +'giEL";i +'giL;i +'giL];i \Pd-pR\!T49dh\#TP$4RhRp?ii;i TP P4i;i) rr{ downgradeupgradeNrn)r$rr|zdatabase is locked)rarbrrrrqr`releaserrcr^rrdr reOperationalErrorrwr r:)rirtr"r$rvrxrexcs&&&$ r_acquireReadWriteLock._acquires"fn7&#'6>Ky  !#// J! #!&&(  &&&J -$$$##a'33DIN%$&  " " * * ,%(%  % %dh % ^$$$%)"#$ 7?,5,?,?,AD) % &40  " " * * ,7! %$ %$'' 4#3s83$..)t 3 4  " " * * ,se#E3 F-#F F-'/F-/FF-3 F  F F- F* %F--G.'G))G..G11H c$V^8dQhRRRRRR/#rr"r#r$r%rr r)rs"rrrTs'AAEATAM_Arc (VPRWR7#)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 rrVrrir"r$s&&$r acquire_readReadWriteLock.acquire_reads }}VW}@@rc$V^8dQhRRRRRR/#rr)rs"rrrTs'BBUBdBN`Brc (VPRWR7#)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 r{rVrrs&&$r acquire_writeReadWriteLock.acquire_writes$}}Wg}AArforceFc V^8dQhRRRR/#)rrr%rrr)rs"rrrTs!!!!rc RpVP;_uu_4VP^8Xd;V'd RRR4R#RVP R\V4 R2p\ V4hV'd ^VnMV;P^,unVP^8XdRVnRVnRpRRR4V'dVPP4R#R# +'giL6;i)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`` FNzCannot release a lock on rzz) that is not heldT) rarbr:r~rrcrdrgrollback)rirshould_rollbackr/s&$ rrReadWriteLock.releases   1$! 2$..1ARPTXJVhi"3''#$   A% 1$%)"(,%"&!  II    ! sCC.C+AC C+ Nc$V^8dQhRRRRRR/#rr"z float | Noner$z bool | NonerzGenerator[None]r)rs"rrrT9s";Zirc# "Vf VPpVf VPpVPWR7RxVP4R# TP4i;i5i)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 NrV)r"r$rrrs&&$r read_lockReadWriteLock.read_lock8sO ?llG  }}H '5   LLNDLLN3A!A A! AA!c$V^8dQhRRRRRR/#rr)rs"rrrTNs",Krc# "Vf VPpVf VPpVPWR7RxVP4R# TP4i;i5i)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 NrV)r"r$rrrs&&$r write_lockReadWriteLock.write_lockMsO ?llG  }}H 76   LLNDLLNrcV^8dQhRR/#rr)rs"rrrTbs 0 0t 0rc VPRR7VPP4\;_uu_4\P VP4RRR4R# +'giR#;i)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. T)rN)rrgrrr discard)ris&rrReadWriteLock.closebsG 4    " "  $ $TYY /# " " "s A%% A6 ) rgrcrarbr`rdr$r:r"rIr)rJrKrLrMrNrr6rOr^r_r7 classmethodrWrjrqrrrrrrrrrrrPrrrr<r<cs(DWCXJ@Xnn&O:Y]::",  , " ,,(4- Q2-BADAA$BTBB(!u!:QU(RV( 0 0rr<) metaclassi5w)&__conditional_annotations__ __future__ratexitloggingr\rArer^r contextlibrrtypingrrweakrefr_apir _errorr collections.abcr getLoggerr-setr rOr_rr registerr*r2typer4r<)rs@rrs""   /)'$)   J ',/E)1!(!$%+&%%PI00I0r