\jtUddlmZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z mZmZmZmZmZddlmZddlmZmZmZmZmZmZddlmZe r$dd lmZm Z ejBd k\rdd l m"Z"ndd l#m"Z"ejHd Z%d e&d<ejNZ(de&d<ejRjTdk(Z+de&d<e,edxr*ejRjTdk(xrejBdkZ-de&d<e.e/zej`e.zej`e/ze1ze2ze3ejhzdzZ5de&d<e6e2e2fZ7de&d<dZ8de&d<dZ9de&d<Gd d!ejtZ;e;Zd"e&d&<Gd'd(Z?e?Z@d"e&d)<Gd*d+ejhZAGd,d-e3ZBGd.d/eB0ZCd8d1ZDe d9d2ZEd:d3ZFd;d4ZGdee@eeCe+rejeGe,edrejeF6d/d7gZKy)=) annotationsN)contextmanagersuppress) TYPE_CHECKINGClassVarFinalLiteral TypeAliascast)WeakValueDictionary)AcquireReturnProxy_ensure_current_process_fork_transition_raise_chained_errors_register_fork_class_register_fork_object)Timeout)Callable Generator) )SelffilelockzFinal[logging.Logger]_LOGGERzFinal[Callable[[], int]]_GETPIDpypyz Final[bool]_IS_PYPYregister_at_forkcpython)r _NEEDS_CONNECTION_ESCROWr _ConnectionParameter_DatabaseIdentityi5wz Final[int]_MAX_SQLITE_TIMEOUT_MSF_UNSAFE_FORK_EXIT_STATUSceZdZUdZded<y)_SQLiteTransitionContextrintdepthN)__name__ __module__ __qualname__r+__annotations__G/root/.hermes/venv/lib/python3.12/site-packages/filelock/_read_write.pyr)r)0s E3Nr1r)r_SQLITE_TRANSITION_CONTEXTc(eZdZddZ ddZddZy)_ConnectionEscrowcDtj|_d|_yN) threadingRLock_lock _functionsselfs r2__init__z_ConnectionEscrow.__init__8s__& txr1c tsy|j5|jddl}|j d|j }|j |jj|jj}|j |jj|jj}|| d}t|t d||t d||f|_|jcdddS#1swYyxYw)Nrz+CPython reference functions have no addressz$Callable[[sqlite3.Connection], None]) r"r:r;ctypes PYFUNCTYPE py_objectr pythonapi Py_IncRefc_void_pvalue Py_DecRef RuntimeError)r=r@ function_typeincrement_addressdecrement_addressmsgs r2 functionsz_ConnectionEscrow.functions<s( ZZ #& & 1 1$8H8H I $*KK0@0@0J0JFOO$\$b$b!$*KK0@0@0J0JFOO$\$b$b!$,0A0IGC&s++?O`Aab?O`Aab#?? # # #s C&DD c6tj|_yr7)r8r9r:r<s r2_reset_after_fork_in_childz,_ConnectionEscrow._reset_after_fork_in_childQs__& r1NreturnNone)rQXtuple[Callable[[sqlite3.Connection], None], Callable[[sqlite3.Connection], None]] | None)r,r-r.r>rMrOr0r1r2r5r57sy# a#*'r1r5_CONNECTION_ESCROWcFeZdZddZd dZd dZddZddZed dZ y) _ForkedDatabaseRegistryctj|_t|_t|_d|_d|_yNF)r8r9r:set_paths _identities _sqlite_used_all_paths_poisonedr<s r2r>z _ForkedDatabaseRegistry.__init__Ys3__& ), 365!#( r1c|j|}|j5|j}|xs$||jvxs|duxr||jv}dddrrdnd|d}t |y#1swY!xYw)NzOReadWriteLock is unavailable in a PyPy fork child; exec or exit before using itzSQLite database zD was active across fork(); exec or exit before using it in the child)identityr:r]rZr[rH)r=pathr_all_paths_poisonedpoisonedrLs r2raise_if_poisonedz)_ForkedDatabaseRegistry.raise_if_poisoned`s==& ZZ !%!9!9 "tddkk&9thd>R>sW_cgcscsWs   &b'x/st  s# #    s 5A33A<cv|jj|||jj|yyr7)rZaddr[)r=r`r_s r2poison_after_forkz)_ForkedDatabaseRegistry.poison_after_forkos1        * r1cbtr|j5d|_dddyy#1swYyxYwNT)rr:r\r<s r2note_sqlite_usez'_ForkedDatabaseRegistry.note_sqlite_usets3  )$(! ) )  ) )s%.ctj|_|jxstxr |j |_d|_yrX)r8r9r:r]rr\r<s r2rOz2_ForkedDatabaseRegistry._reset_after_fork_in_childys6__& #'#;#;#_@^TM^M^ !r1cr |j}|j|jfS#t$rYywxYwr7)statOSErrorst_devst_ino)r` stat_results r2r_z _ForkedDatabaseRegistry.identity~s? ))+K!!;#5#555  s * 66NrP)r` pathlib.PathrQrR)r`rqr__DatabaseIdentity | NonerQrR)r`rqrQrr) r,r-r.r>rcrfrirO staticmethodr_r0r1r2rVrVXs/) $+ ) " 66r1rV_FORKED_DATABASEScbeZdZUded<ded< d fd Zd dZ d dZd dZxZS) _ForkSafeConnectionr* _creator_pidz+Callable[[sqlite3.Connection], None] | None_decrement_escrowcRt||}t|_d|_|Sr7)super__new__rrwrx)cls_args_kwargs connection __class__s r2r{z_ForkSafeConnection.__new__s+ W_S) ")) '+ $r1c:t5t|jk7r dddyt5tj j ||jx}d|_||ddddddy#1swYxYw#1swYyxYwr7)_sqlite_transitionrrwrsqlite3 Connectioncloserx)r= decrements r2rz_ForkSafeConnection.closes  ! $yD--- $ $"# $""((.!%!7!77ID-1D*dO  $ $ $ $ $ $ $s'B B=B4BB BBc2||\}}||||_yyr7)rx)r=rM incrementrs r2acquire_escrowz"_ForkSafeConnection.acquire_escrows(  #, Iy dO%.D " !r1cttjt5|j dddy#1swYyxYwr7)rrErrorrHrr<s r2__del__z_ForkSafeConnection.__del__s. gmm\ 2  JJL   s 9A)r}r#r~r#rQrrP)rMrSrQrR) r,r-r.r/r{rrr __classcell__rs@r2rvrvsQBB$(  $/k/ /r1rvcteZdZUdZded<ded<ded<ded < dd d d  dfd Zdd ZxZS)_ReadWriteLockMetaa  Resolve singleton instances for ``is_singleton=True`` construction. This logic lives here rather than in ReadWriteLock.get_lock so ``ReadWriteLock(path)`` returns cached instances without a 2-arg ``super()`` call that type checkers cannot verify. 0WeakValueDictionary[pathlib.Path, ReadWriteLock] _instanceszthreading.RLock_instances_lockr*_instances_pidzset[pathlib.Path]_instances_under_constructionTblocking is_singletonc t|jtk7r|jt}|s/t |||||}t|k7r d}t ||Stj|j}|j5||jvr||jvrd|}t ||j} | j| t |||||}t|k(r| j| t|k7r d}t |||j|<n|j|}|j|k7s|j |k7r-d|jd|j d|d|}t#||cdddS#t|k(r| j|wwxYw#1swYyxYw)Nrz5ReadWriteLock construction cannot continue after forkz2Singleton lock construction is already active for z$Singleton lock created with timeout=z , blocking=z, cannot be changed to timeout=)rrr_reset_class_after_forkrz__call__rHpathlibPathresolverrrrediscardtimeoutr ValueError) r| lock_filerrrconstruction_pidinstancerL normalizedconstruction_registryrs r2rz_ReadWriteLockMeta.__call__s !    *  ' ' )"9w' 7X\h'iHy,,M"3''O\\),446   /!B!BBNym\C&s++(+(I(I%%))*5B$w/ 7Xdp/qHy$44-55jA9 00QC&s++-5z*>>*57*h.?.?8.K:8;K;K:LKX`XiXiWjk55zReadWriteLock.__init__)s9-&||I6>>@++D,@,@A   !*!1'nn.>B,014$04 04->B! #I!&d#   *!3!5 *$($9$9$9$M ! ! ' ' ) * * * * * *s$ E#E ;E E EE!c*|jd||S)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 readr_acquirer=rrs r2 acquire_readzReadWriteLock.acquire_readGs }}VWx}@@r1c*|jd||S)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 writerrrs r2 acquire_writezReadWriteLock.acquire_writeYs$}}Wg}AAr1Nc#K| |j}| |j}|j|| d|jy#|jwxYww)a} 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 Nr)rrrreleasers r2 read_lockzReadWriteLock.read_lockmsR ?llG  }}H 'H5   LLNDLLN0AAAAAc#K| |j}| |j}|j|| d|jy#|jwxYww)a 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 Nr)rrrrrs r2 write_lockzReadWriteLock.write_locksR ?llG  }}H 7X6   LLNDLLNrF)forcect5t|jr dddy|jd|j |ddddy#1swYyxYw)al 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`` NrFrrrr _inherited_raise_if_acquiring_release)r=rs r2rzReadWriteLock.releasesY  4 # % 4 4  $ $Y / MMUM 3  4 4 4A$AA"ct5t|jr dddy|jd|j dddddy#1swYyxYw)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. NrTrrr<s r2rzReadWriteLock.closesY  2 # % 2 2  $ $W - MMDM 1  2 2 2rcv|j5|j5|jdk(rR|r'|j|rd|_ ddddddy|s'd|j dt |d}t||s6|jdkDr'|xjdzc_ ddddddy |j|j|rd|_ddddddy#tj$r|jr|jwxYw#1swYFxYw#1swYyxYw)NrTzCannot release a lock on (lock id: z) that is not heldr ) rrrrrridrH_finish_connectionrrr_clear_lock_state)r=rrrLs r2rzReadWriteLock._releases3  # # $T%8%8 $1$TYY.'+   $ $ $ 5dnn5E[QSTXQYPZZlmC&s++T--1  A%  $ $ $ '')  " " $# ) $ $ $== 88**,  $ $ $ $sM D/(D#D/AD##D/5C/D#D//1D  D##D, (D//D8c.d|_d|_d|_y)Nr)rrrr<s r2rzReadWriteLock._clear_lock_states! $r1ctt|ddk(rHt|ddx}8ttjt 5|j dddyyy#1swYyxYw)Nrwr)rgetattrrrrrHr)r=rs r2rzReadWriteLock.__del__si 9nd; ;wW[]ceiOjAj@w'--6 #  " # #Ax ; # #s A""A+cJ|j*tj|j|jd|_d|_d|_t j|_t j|_ |jt|_ d|_ yrh)rrtrfrrrr8rrrrrYrrr<s r2rOz(ReadWriteLock._reset_after_fork_in_childs{ 99  / /0D0DdF_F_ ` 04-$(!!*!1'nn.  '*u$!%r1cL|jxst|jk7Sr7)rrrwr<s r2rzReadWriteLock._inheriteds %%Gd6G6G)GGr1ct|jrd|jd}t||jrd}t j |y)NReadWriteLock on 4 was invalidated by fork(); construct a new instancez$Cannot operate on a closed database.)rrrrHrrProgrammingError)r=rLs r2_raise_if_unusablez ReadWriteLock._raise_if_unusablesP! ??%dnn%55ijCs# # <<8C**3/ / r1c t5|jt}tj}|j 5|j dkDr#|j|cdddcdddS||jvrd|jd}t||jj|ddd tj}|j|| |j|j||||||j j#|j 5|jj%|dddcdddS#1swYxYw#1swYxYw#|j j#wxYw#|j 5|jj%|dddw#1swYwxYwxYw#1swYyxYw)Nrz Cannot acquire ReadWriteLock on + while acquisition is active in this threadrrr operation_pid start_time)rrrr8 get_identrr_validate_reentrantrrrHretime perf_counter_acquire_transaction_lock_do_acquire_innerrrr)r=moderrr thread_idrLrs r2rzReadWriteLock._acquires   D  # # %#IM!++-I$$ <##a'33D9 < <  D D < <<  * *= 9!%D  D w(1(;(;(=%  > "t,,M 6 6& %!9!9:?SWZ[`Wa?a$+DNN$;!$)! H'')== H%&7GG H -'T1   > >sY C8=D&>F8D F ?F EFF1 F=FF FFF#c:t5t||tj|z dz }|j |}|dt j |jc|_|_ |_ |j|dddy#1swYyxYw)Nralready_waitedrF) rtimeout_for_sqliterrrrtr_rrrrr)r=rrrrrrs r2rz#ReadWriteLock._open_for_acquisitionAs  ! :"%#'#4#4#6#C   ..n.MJ!**4+?+?@ XDItW  * *= 9 : : :s A=BBct5|\}}td|j}tj|z }t |||} |j ||jd| djtj|z }t |||} |j || | k7rd| dnd} | |dk(rdnd z } |d k(r| d z } |j| jdddy#1swYyxYw) Nrvr zPRAGMA busy_timeout=z; PRAGMA journal_mode=MEMORY;z; rzBEGIN EXCLUSIVE TRANSACTION;zBEGIN TRANSACTION;rz( SELECT name FROM sqlite_schema LIMIT 1;) rr rrrrr executescriptr) r=rrrrrrrwaited timeout_ms recomputed statementss r2rz"ReadWriteLock._configure_and_beginSs ! 9(1 %M:3TYY?J&&(:5F+GhW]^J  * *= 9  $ $';J`bJ DGO8Qe eJv~HH  $ $Z 0 6 6 8- 9 9 9s C-DD ct5t}tj}t|k7r d}t |t t j|jt|}||j|t|k7rJtj|jtj|jd}t ||cdddS#1swYyxYw)Nz9SQLite connection construction cannot continue after fork)factoryr)rrrTrMrH_connectrrrrvrrtrfr_)r=r creator_pidrMrLrs r2rzReadWriteLock._open_connectionss  ! !)K*446IyK'Q"3''! $../+&J $)))4yK'!33((%..t/C/CDR"3'')   s CC((C1ct5|jx} dddyd}|js,|jr |j d|_nd|_ |jd|_d|_d|_ || dddy#t j $r }|jrd|_|}Yd}~bd}~wwxYw#t j $r}| t||d}~wwxYw#1swYyxYwrh) rrrin_transactionrollbackrrrrr)r=rrollback_errorr  close_errors r2rz ReadWriteLock._finish_connections  ! %"ii' 0 % %48N88,,E"++-AE=<@D9   " DI48D 1(,D %)$$*5 % %#==/%44!@D=). /== !-).+F ' % %s]C2C2BC2C/C2C%C;C2CC2C/C**C//C22C;c |j|k7rB|dk(rdnd}|dk(rdnd}d|d|jdt|d|d |d }t||dk(rYt j x}|j k7r6d |jdt|d |d |j }t||xjdz c_t|S)Nrr downgradeupgradezCannot acquire z lock on rz): already holding a z lock (z not allowed)zCannot acquire write lock on z) from thread z while it is held by thread r r) rrrrHr8rrrr)r=ropposite directionrLcurs r2rz!ReadWriteLock._validate_reentrants    %"&&.wfH'+v~ 9I!$y0@ BtH:V%%-Jgi[ O s# # 7?y':':'< <AVAVV//?{2d8*U"e#?@U@U?VX s# # A!t,,r1c|s|jjd}n?|dk(r|jjd}n|jjd|}|st|jdy)NFrrTr)racquirerr)r=rracquireds r2rz'ReadWriteLock._acquire_transaction_locksr--55u5EH ]--55t5DH--55tW5UH$..)t 3r1c|j5tj|jv}dddrd|d|jd}t |y#1swY*xYw)NzCannot z ReadWriteLock on r)rr8rrrrH)r=ractive_in_current_threadrLs r2rz!ReadWriteLock._raise_if_acquiringsl   ]'0':':'<@\@\'\ $ ] #I;&88HHstCs# # $ ] ]s !AA clt|k7s |jrd|jd}t|y)Nrr)rrrrH)r=rrLs r2rz'ReadWriteLock._raise_if_process_changeds6 9 %%dnn%55ijCs# #*9r1rPr)rrrrrrrQr) rrrrrrrrrQrR)rrrrrQrr7)rz float | Nonerz bool | NonerQGenerator[None])rrrQrR)rrrrrQrR)rQr)rLiteral['read', 'write']rrrrrQr) rr.rrrrrr*rrrQr) rrrrrr*rrrQrR) rr.rrrrrztuple[int, float]rQrR)rrrQrv)rr.rQr)rrrrrQrR)rz&Literal['acquire', 'close', 'release']rQrR)rr*rQrR)+r,r-r.rr rr/r8r9rrrrYrr classmethodrr>rrrrrrrrrrrOpropertyrrrrrrrrrrrrrrs@r2rrs*DWCXJ@X%ioo'OYNAD!#>F"AC:Y]:.:9>:RV: ::(* ! *)**  *  * *<ADA$BTB(QU(RV((-4$ 2$.% # &HH0D<0-&0-0-  0-  0-0- 0-d:$9&99  9 % 9 9@.%<-$4$$r1r) metaclassc^tjtj|d|d|S)NFr)check_same_threadrcached_statementsr)rtrirconnect)databaserrs r2rrs.%%' ??  r1c#Ktxjdz c_ dtxjdzc_y#txjdzc_wxYww)Nr )r3r+r0r1r2rrsB$$)$. "((A-("((A-(sA;AAAcXtjrtjtyyr7)r3r+r_exitr'r0r1r2_abort_forked_sqlite_transitionr:s!'' )*(r1c8|dk(rtjyy)Nzsqlite3.connect)rtri)eventr}s r2_track_sqlite_user=s !!))+"r1c|dury|dk(rtS|dkr d}t|t|dkDrt||z dn|dz}|tkDs|dkr!tj d|ttS|S)NFrrz+timeout must be a non-negative number or -1rz7timeout %s is too large for SQLite, using %s ms instead)r%rr*maxrwarning)rrrrLrs r2rrs5"}%%{;o'A+c'N2A67VZZ[J**j1nQSZ\rs%% r1)after_in_childr)r6rrztype[_ForkSafeConnection]rrrQrv)rQr-rP)r<rr}ztuple[object, ...]rQrR)rrrrrrrQr*)L __future__rloggingrrrsysr8r contextlibrrtypingrrrr r r weakrefr _apirrrrrr_errorrcollections.abcrr version_infortyping_extensions getLoggerrr/getpidrimplementationnamerhasattrr"rbytesPathLikerr*typerr#tupler$r%r'localr)r3r5rTrVrtrvrrrrr:r=r addaudithookr__all__r0r1r2rYs["   /KK'3 7"*!2!2!2:!> >$&II !-**//69+9 B"#k(:(:(?(?9(LkQTQaQadkQk+%K"++c""R[[%77%?#EWM_M_H``cggi %S#X9.&7 6')*)y%=$>E>''<./E/,6,6^3454#',,#LA2A2HZ$0Z$z..+ , $()'(]# C&' 2!"B'FG r1