1jqUddlmZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z mZmZmZmZmZddlmZddlmZmZmZmZmZmZddlmZe r*dd lmZm Z dd l!m"Z"ejFd k\rdd l m$Z$ndd l%m$Z$ejLd Z'de(d<ejRZ*de(d<ejVjXdk(Z-de(d<e.edxr*ejVjXdk(xrejFdkZ/de(d<e0e1zejde0zejde1ze3ze4ze5ejlzdzZ7de(d<e8e4e4fZ9de(d<dZ:de(d<dZ;de(d <Gd!d"ejxZ=e=Z>d#e(d$<Gd%d&Z?e?Z@d#e(d'<Gd(d)ZAeAZBd#e(d*<Gd+d,ejlZCGd-d.e5ZDGd/d0eD1ZEd9d2ZFe d:d3ZGd;d4ZHd) annotationsN)contextmanagersuppress) TYPE_CHECKINGClassVarFinalLiteral TypeAliascast)WeakValueDictionary)AcquireReturnProxy_ensure_current_process_fork_transition_raise_chained_errors_register_fork_class_register_fork_object)Timeout)Callable Generator)Unused) )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__/home/vela/workspace/domain/tn-silver/web/tn-site/.runtime/depth-eval/venv/lib/python3.12/site-packages/filelock/_read_write.pyr*r*2s E3Nr2r*r_SQLITE_TRANSITION_CONTEXTc(eZdZddZ ddZddZy)_ConnectionEscrowcDtj|_d|_yN) threadingRLock_lock _functionsselfs r3__init__z_ConnectionEscrow.__init__:s__& txr2c 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>rA function_typeincrement_addressdecrement_addressmsgs r3 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#??ZZs C&DD c6tj|_yr8)r9r:r;r=s r3_reset_after_fork_in_childz,_ConnectionEscrow._reset_after_fork_in_childSs__& r2NreturnNone)rRXtuple[Callable[[sqlite3.Connection], None], Callable[[sqlite3.Connection], None]] | None)r-r.r/r?rNrPr1r2r3r6r69sy# a#*'r2r6_CONNECTION_ESCROWcFeZdZddZd dZd dZddZddZed dZ y) _ForkedDatabaseRegistryctj|_t|_t|_d|_d|_yNF)r9r:r;set_paths _identities _sqlite_used_all_paths_poisonedr=s r3r?z _ForkedDatabaseRegistry.__init__[s3__& ), 365!#( r2c|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^r[r\rI)r>pathr`all_paths_poisonedpoisonedrMs r3raise_if_poisonedz)_ForkedDatabaseRegistry.raise_if_poisonedbs==& ZZ!%!9!9 "tddkk&9thd>R>sW_cgcscsWs  &b'x/st  s# #  Zs 5A33A<cv|jj|||jj|yyr8)r[addr\)r>rar`s r3poison_after_forkz)_ForkedDatabaseRegistry.poison_after_forkqs1        * r2cbtr|j5d|_dddyy#1swYyxYwNT)rr;r]r=s r3note_sqlite_usez'_ForkedDatabaseRegistry.note_sqlite_usevs& $(! s%.ctj|_|jxstxr |j |_d|_yrY)r9r:r;r^rr]r=s r3rPz2_ForkedDatabaseRegistry._reset_after_fork_in_child{s6__& #'#;#;#_@^TM^M^ !r2cr |j}|j|jfS#t$rYywxYwr8)statOSErrorst_devst_ino)ra stat_results r3r`z _ForkedDatabaseRegistry.identitys? ))+K!!;#5#555  s * 66NrQ)ra pathlib.PathrRrS)rarrr`_DatabaseIdentity | NonerRrS)rarrrRrs) r-r.r/r?rdrgrjrP staticmethodr`r1r2r3rWrWZs/) $+ ) " 66r2rW_FORKED_DATABASEScbeZdZUded<ded< d fd Zd dZ d dZd dZxZS) _ForkSafeConnectionr+ _creator_pidz+Callable[[sqlite3.Connection], None] | None_decrement_escrowcRt||}t|_d|_|Sr8)super__new__rrxry)cls_args_kwargs connection __class__s r3r|z_ForkSafeConnection.__new__s+ W_S) ")) '+ $r2c:t5t|jk7r dddyt5tj j ||jx}d|_||ddddddy#1swYxYw#1swYyxYwr8)_sqlite_transitionrrxrsqlite3 Connectionclosery)r> decrements r3rz_ForkSafeConnection.closes~  !yD---" !"#""((.!%!7!77ID-1D*dO $" !$#" !s'B B=B4BB BBc2||\}}||||_yyr8)ry)r>rN incrementrs r3acquire_escrowz"_ForkSafeConnection.acquire_escrows(  #, Iy dO%.D " !r2cttjt5|j dddy#1swYyxYwr8)rrErrorrIrr=s r3__del__z_ForkSafeConnection.__del__s% gmm\ 2 JJL3 2 2s 9A)r~r$rr$rRrrQ)rNrTrRrS) r-r.r/r0r|rrr __classcell__rs@r3rwrwsQBB$(  $/k/ /r2rwcteZdZUdZded<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_forkr{__call__rIpathlibPathresolverrrrfdiscardtimeoutr ValueError) r} lock_filerrrconstruction_pidinstancerM normalizedconstruction_registryrs r3rz_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`XiXiWjk55rrrrvalidation_connections r3r?zReadWriteLock.__init__,s 9-&||I6>>@++D,@,@A   !*!1'nn.>B,014$04 04->B! #I!&d#  !3!5$($9$9$9$M ! ! ' ' )"6  !5!5  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 r3 acquire_readzReadWriteLock.acquire_readJs }}VWx}@@r2c*|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 r3 acquire_writezReadWriteLock.acquire_write\s$}}Wg}AAr2Nc#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 r3 read_lockzReadWriteLock.read_lockpsR ?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 r3 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 r3rzReadWriteLock.releasesN  # %   $ $Y / MMUM 3   A$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 r3rzReadWriteLock.closesN  # %   $ $W - MMDM 1   rcv|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 ) rrrrrridrI_finish_connectionrrr_clear_lock_state)r>rrrMs r3rzReadWriteLock._releases  # #T%8%81$TYY.'+  &9 # # 5dnn5E[QSTXQYPZZlmC&s++T--1  A% &9 # # '')  " " $# )&9 # #== 88**, &9%8 # #sM D/(D#D/AD##D/5C/D#D//1D  D##D, (D//D8c.d|_d|_d|_y)Nr)rrrr=s r3rzReadWriteLock._clear_lock_states! $r2ctt|ddk(rHt|ddx}8ttjt 5|j dddyyy#1swYyxYw)Nrxr)rgetattrrrrrIr)r>rs r3rzReadWriteLock.__del__s^ 9nd; ;wW[]ceiOjAj@w'--6  "76Ax ;66s A""A+cJ|j*tj|j|jd|_d|_d|_t j|_t j|_ |jt|_ d|_ yri)rrurgrrrr9rrrrrZrrr=s r3rPz(ReadWriteLock._reset_after_fork_in_childs{ 99  / /0D0DdF_F_ ` 04-$(!!*!1'nn.  '*u$!%r2cL|jxst|jk7Sr8)rrrxr=s r3rzReadWriteLock._inheriteds %%Gd6G6G)GGr2ct|jrd|jd}t||jrd}t j |y)NReadWriteLock on 4 was invalidated by fork(); construct a new instancez$Cannot operate on a closed database.)rrrrIrrProgrammingError)r>rMs r3_raise_if_unusablez ReadWriteLock._raise_if_unusablesP! ??%dnn%55ijCs# # <<8C**3/ / r2c 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)rrrr9 get_identrr_validate_reentrantrrrIrftime perf_counter_acquire_transaction_lock_do_acquire_innerrrr)r>moderrr thread_idrMrs r3rzReadWriteLock._acquires    # # %#IM!++-I$$##a'33D9%$   < <<rrrrrerroracquisition_error cleanup_errors r3rzReadWriteLock._do_acquire_inners !#//5! #! 99  # # %   & &!+% '   % %!(*5 &   * *= 9  * *= 9!%D  D w(1(;(;(=% ! "t,,M! & %!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_sqliterrrrur`rrrrr)r>rrrrrrs r3rz#ReadWriteLock._open_for_acquisitionDs  !"%#'#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) NrwrzPRAGMA 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 r3rz"ReadWriteLock._configure_and_beginVs !(1 %M:3TYY?J&&(:5F+GhW]^J  * *= 9  $ $';J`bJ DGO8Qe eJv~HH  $ $Z 0 6 6 8-" ! !s 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)rrrUrNrI_connectrrrrwrrurgr`)r>r creator_pidrNrMrs r3rzReadWriteLock._open_connectionvs  !!)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#1swYyxYwri) rrrin_transactionrollbackrrrrr)r>rrollback_errorr  close_errors r3rz 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) rrrrIr9rrrr)r>ropposite directionrMcurs r3rz!ReadWriteLock._validate_reentrants    %"&&.wfH'+v~ 9I!$y0@ BtH:V%%-Jgi[ O s# # 7?y':':'< <AVAVV//?{2d8*U"e#?@U@U?VX s# # A!t,,r2c|s|jjd}n?|dk(r|jjd}n|jjd|}|st|jdy)NFrrTr)racquirerr)r>rracquireds r3rz'ReadWriteLock._acquire_transaction_locksr--55u5EH ]--55t5DH--55tW5UH$..)t 3r2c|j5tj|jv}dddrd|d|jd}t |y#1swY*xYw)NzCannot z ReadWriteLock on r)rr9rrrrI)r>ractive_in_current_threadrMs r3rz!ReadWriteLock._raise_if_acquiringsa  '0':':'<@\@\'\ $! #I;&88HHstCs# # $! s !AA clt|k7s |jrd|jd}t|y)Nrr)rrrrI)r>rrMs r3rz'ReadWriteLock._raise_if_process_changeds6 9 %%dnn%55ijCs# #*9r2rQr)rrrrrrrRr) rrrrrrrrrRrS)rrrrrRrr8)rz float | Nonerz bool | NonerRGenerator[None])rrrRrS)rrrrrRrS)rRr)rLiteral['read', 'write']rrrrrRr) rr/rrrrrr+rrrRr) rrrrrr+rrrRrS) rr/rrrrrztuple[int, float]rRrS)rrrRrw)rr/rRr)rrrrrRrS)rz&Literal['acquire', 'close', 'release']rRrS)rr+rRrS)+r-r.r/rr rr0r9r:rrrrZrr classmethodrr?rrrrrrrrrrrPpropertyrrrrrrrrrrrrrrs@r3rrs*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$$r2r) metaclassc^tjtj|d|d|S)NFr)check_same_threadrcached_statementsr)rurjrconnect)databaserrs r3rrs.%%' ??  r2c#Ktxjdz c_ dtxjdzc_y#txjdzc_wxYww)Nr )r4r,r1r2r3rrsB$$)$. "((A-("((A-(sA;AAAcXtjrtjtyyr8)r4r,r_exitr(r1r2r3_abort_forked_sqlite_transitionr;s!'' )*(r2c8|dk(rtjyy)Nzsqlite3.connect)rurj)eventr~s r3_track_sqlite_user>s !!))+"r2c|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)rrrrMrs r3rrs5"}%%{;o'A+c'N2A67VZZ[J**j1nQSZ\rs%% r2)after_in_childr)r7r rztype[_ForkSafeConnection]rrrRrw)rRr.rQ)r=r r~rrRrS)rrrrrrrRr+)N __future__rloggingrrrsysr9r contextlibrrtypingrrrr r r weakrefr _apirrrrrr_errorrcollections.abcrr _typeshedr version_infortyping_extensions getLoggerrr0getpidrimplementationnamerhasattrr#r bytesPathLikerr+typerr$tupler%r&r(localr*r4r6rUrWrurwrrrrr;r>r addaudithookr __all__r1r2r3r[s^"   /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$',,$NA2A2HZ$0Z$z..+ , $()'(]# C&' 2!"B'FG r2