dtjdUddlmZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z mZmZmZmZmZddlmZddlmZmZmZmZmZmZddlmZe r dd lmZm Z ej!d krdd l m"Z"ndd l#m"Z"ej$d Z%d e&d<ej'Z(de&d<ej)j*dkZ+de&d<e,edoej)j*dko ej!dkZ-de&d<e.e/zej0e.zej0e/ze1ze2ze3ej4zdzZ5de&d<e6e2e2fZ7de&d<dZ8de&d<dZ9de&d<Gd d!ej:Z;e;Zd"e&d&<Gd'd(Z?e?Z@d"e&d)<Gd*d+ej4ZAGd,d-e3ZBGd.d/eB0ZCdHd8ZDe dId:ZEdJd<ZFdKd@ZGdLdEZHee>ee@eeCe+rejIeGe,edrejJeFFd/dGgZKdS)M) 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<dS)_SQLiteTransitionContextrintdepthN)__name__ __module__ __qualname__r+__annotations__R/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/filelock/_read_write.pyr)r)0sENNNNNNr1r)r_SQLITE_TRANSITION_CONTEXTc&eZdZddZd dZddZdS) _ConnectionEscrowreturnNonecDtj|_d|_dSN) threadingRLock_lock _functionsselfs r2__init__z_ConnectionEscrow.__init__8s_&& txr1Xtuple[Callable[[sqlite3.Connection], None], Callable[[sqlite3.Connection], None]] | NonectsdS|j5|jddl}|d|j}||jj|j j }||jj |j j }||d}t|t d||t d||f|_|jcdddS#1swxYwYdS)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?rC function_typeincrement_addressdecrement_addressmsgs r2 functionsz_ConnectionEscrow.functions<sE( 4 Z # #& & 1 1$8H I I $*KK0@0JFO$\$\$b!$*KK0@0JFO$\$\$b!$,0A0IGC&s+++?O`AaAabb?O`AaAabb#? # # # # # # # # # # # # # # # # # #sC C++C/2C/c6tj|_dSr9)r:r;r<r>s r2_reset_after_fork_in_childz,_ConnectionEscrow._reset_after_fork_in_childQs_&& r1Nr6r7)r6rA)r,r-r.r@rPrRr0r1r2r5r57sTyyyy####*''''''r1r5_CONNECTION_ESCROWcNeZdZddZddZdd Zdd Zdd Zedd Z d S)_ForkedDatabaseRegistryr6r7ctj|_t|_t|_d|_d|_dSNF)r:r;r<set_paths _identities _sqlite_used_all_paths_poisonedr>s r2r@z _ForkedDatabaseRegistry.__init__Ys>_&& ), 3655!#(   r1path pathlib.Pathc||}|j5|j}|p||jvp |duo||jv}dddn #1swxYwY|r|rdnd|d}t |dS)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[rK)r?r^raall_paths_poisonedpoisonedrOs r2raise_if_poisonedz)_ForkedDatabaseRegistry.raise_if_poisoned`s==&& Z  !%!9 "tddk&9thd>R>sW_cgcsWs                  $&uaatttt  s## #  $ $s A  A A ra_DatabaseIdentity | Nonecv|j|||j|dSdSr9)rZaddr[)r?r^ras r2poison_after_forkz)_ForkedDatabaseRegistry.poison_after_forkosA       * * * * * r1cftr)|j5d|_ddddS#1swxYwYdSdSNT)rr<r\r>s r2note_sqlite_usez'_ForkedDatabaseRegistry.note_sqlite_usets  ) ) )$(! ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s $((cxtj|_|jp to|j|_d|_dSrX)r:r;r<r]rr\r>s r2rRz2_ForkedDatabaseRegistry._reset_after_fork_in_childys7_&& #'#;#_@^TM^ !r1cl |}n#t$rYdSwxYw|j|jfSr9)statOSErrorst_devst_ino)r^ stat_results r2raz _ForkedDatabaseRegistry.identity~sI ))++KK   44 !;#555s  %%NrS)r^r_r6r7)r^r_rarer6r7)r^r_r6re) r,r-r.r@rdrhrkrR staticmethodrar0r1r2rVrVXs)))) $ $ $ $++++ )))) """" 666\666r1rV_FORKED_DATABASEScNeZdZUded<ded<dfd Zdd ZddZddZxZS)_ForkSafeConnectionr* _creator_pidz+Callable[[sqlite3.Connection], None] | None_decrement_escrow_argsr#_kwargsr6rc~t|}t|_d|_|Sr9)super__new__rrwrx)clsryrz connection __class__s r2r}z_ForkSafeConnection.__new__s4 WW__S)) "))) '+ $r1r7c^t5t|jkr ddddSt5tj||jx}d|_||dddn #1swxYwYddddS#1swxYwYdSr9)_sqlite_transitionrrwrsqlite3 Connectioncloserx)r? decrements r2rz_ForkSafeConnection.closesL  ! ! $ $yyD--- $ $ $ $ $ $ $ $"## $ $"((...!%!77ID-1D*IdOOO  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s:B"B";B > B" B B"B B""B&)B&rPrAc<||\}}||||_dSdSr9)rx)r?rP incrementrs r2acquire_escrowz"_ForkSafeConnection.acquire_escrows7  #, Iy IdOOO%.D " " " ! r1cttjt5|ddddS#1swxYwYdSr9)rrErrorrKrr>s r2__del__z_ForkSafeConnection.__del__s gm\ 2 2   JJLLL                  sAA A)ryr#rzr#r6rrS)rPrAr6r7) r,r-r.r/r}rrr __classcell__rs@r2rvrvsBBBB$$$$////r1rvcbeZdZUdZded<ded<ded<ded < dd d d dfdZddZxZS)_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_singleton lock_filestr | os.PathLike[str]timeoutfloatrboolrr6 ReadWriteLockc &t|jtkr|t}|sJt ||||}t|krd}t ||Stj| }|j 5||j vr||j vrd|}t ||j } | | t ||||}t|kr| |n-#t|kr| |wwxYwt|krd}t |||j |<n |j |}|j|ks |j|kr'd|jd|jd|d|}t#||cdddS#1swxYwYdS)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__rKpathlibPathresolverrrrgdiscardrr ValueError) r~rrrrconstruction_pidinstancerO normalizedconstruction_registryrs r2rz_ReadWriteLockMeta.__call__s !!!   * *  ' ' ) ) )"99 ww'' 7X\h'iiHyy,,,M"3'''O\),,4466    //!BBB\y\\C&s+++(+(I%%))*555B$ww// 7Xdp/qqHyy$444-55jAAAyy$444-55jAAAA599 000QC&s+++-5z**>*57**h.?8.K.KT8;KTTX`XiTT5<TTIQTT!oo%3                  s,AH%E+(H*E==AZ)xZ*S)Rrap Cross-process read-write lock backed by SQLite. Allows concurrent shared readers or a single exclusive writer. The lock is reentrant within the same mode (multiple ``acquire_read`` calls nest, as do multiple ``acquire_write`` calls from the same thread), but upgrading from read to write or downgrading from write to read raises :class:`RuntimeError`. Write locks are pinned to the thread that acquired them. By default, ``is_singleton=True``: calling ``ReadWriteLock(path)`` with the same resolved path returns the same instance. The path is handed to :func:`sqlite3.connect` as given, so a ``.db`` extension is a convention rather than a requirement; the filesystem must be one the active SQLite VFS supports. :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 :param is_singleton: if ``True``, reuse existing instances for the same resolved path .. versionadded:: 3.21.0 rrzClassVar[set[pathlib.Path]]rr6r7ctt|_t j|_t|_t|_ t|dSr9) r|__init_subclass__r rr:r;rrrrYrr)r~rs r2rzReadWriteLock.__init_subclass__sb !!###,..'o//$YY,/EE)S!!!!!r1rTrrrrrrrc||||S)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 rr0)r~rrrs r2get_lockzReadWriteLock.get_locks s9g9999r1rrctj||_tj||_t|j||_ ||_ tj |_ tj |_d|_d|_d|_t%|_d|_d|_d|_d|_t1|_d|_t7|t95t;5|d}|dddn #1swxYwYddddS#1swxYwYdS)NrTFg@sqlite_timeout) osfspathrrrr_canonical_pathrtrdrrr:Lock_transaction_lock_internal_lock _lock_level _current_mode_write_thread_idrY_acquisition_thread_ids_con _connection_transaction_released_connection_identity_closedrrw_fork_invalidatedrrr_open_connectionr)r?rrrrvalidation_connections r2r@zReadWriteLock.__init__*s9--&|I66>>@@++D,@AAA   !*!1!1'n..>B,014$04 04->B! #II!&d###    * *!3!5!5 * *$($9$9$9$M$M ! ! ' ' ) ) ) * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *s6E;,+E# E;#E' 'E;*E' +E;;E?E?rc2|d||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_readHs }}VWx}@@@r1c2|d||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_writeZs$}}Wg}AAAr1N float | None bool | NoneGenerator[None]c#K||j}||j}||| dV|dS#|wxYw)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_locknsk ?lG  }H 'H555  EEE LLNNNNNDLLNNNN AAc#K||j}||j}||| dV|dS#|wxYw)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_locksk ?lG  }H 7X666  EEE LLNNNNNDLLNNNNrF)forcerct5t|jr ddddS|d||dddddS#1swxYwYdS)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.releases   4 4 # % % %  4 4 4 4 4 4 4 4  $ $Y / / / MMUM 3 3 3  4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4A,,A,,A03A0ct5t|jr ddddS|d|ddddddS#1swxYwYdS)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.closes   2 2 # % % %  2 2 2 2 2 2 2 2  $ $W - - - MMDM 1 1 1  2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2rrcx|j5|j5|jdkrW|r)|j"|rd|_ dddddddS|s*d|jdt |d}t||s4|jdkr)|xjdzc_ dddddddS |n/#tj $r|j r| wxYw| |rd|_dddn #1swxYwYddddS#1swxYwYdS)NrTzCannot release a lock on (lock id: z) that is not heldr ) rrrrrridrK_finish_connectionrrr_clear_lock_state)r?rrrOs r2rzReadWriteLock._releasesi  # $ $T%8 $ $1$$TY.,'+   $ $ $ $ $ $ $ $ $ $ $ $ $ $ ,mdnmmQSTXQYQYmmmC&s+++ T-11  A%   $ $ $ $ $ $ $ $ $ $ $ $ $ $ ''))))=   8-**,,,   " " $ $ $ $# ) $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s^D/D D/A D D/*B?>D?,C++ D D/D D/D D//D36D3c0d|_d|_d|_dS)Nr)rrrr>s r2rzReadWriteLock._clear_lock_states ! $r1ctt|ddkrat|ddx}Pttjt 5|ddddS#1swxYwYdSdSdS)Nrwr)rgetattrrrrrKr)r?rs r2rzReadWriteLock.__del__s 99nd;; ; ;wW[]ceiOjOjAj@w'-66 # #  """ # # # # # # # # # # # # # # # # # # < ;@w@wsA66A:=A:cD|j%t|j|jd|_d|_d|_t j|_t j|_ | t|_ d|_ dSrj)rrtrhrrrr:rrrrrYrrr>s r2rRz(ReadWriteLock._reset_after_fork_in_childs 9  / /0DdF_ ` ` ` 04-$(!!*!1!1'n..    '*uu$!%r1c>|jpt|jkSr9)rrrwr>s r2rzReadWriteLock._inheriteds%Gd6G)GGr1ct|jrd|jd}t||jrd}t j|dS)NReadWriteLock on 4 was invalidated by fork(); construct a new instancez$Cannot operate on a closed database.)rrrrKrrProgrammingError)r?rOs r2_raise_if_unusablez ReadWriteLock._raise_if_unusablesb!!! ? $jdnjjjCs## # < 08C*3// / 0 0r1modeLiteral['read', 'write']c t5|t}tj}|j5|jdkr-||cdddcdddS||jvrd|j d}t||j |dddn #1swxYwY tj }||| ||||||||j|j5|j|dddn #1swxYwYcdddS#|jwxYw#|j5|j|dddw#1swxYwYwxYw#1swxYwYdS)Nrz Cannot acquire ReadWriteLock on + while acquisition is active in this threadrrr operation_pid start_time)rrrr: get_identrr_validate_reentrantrrrKrgtime perf_counter_acquire_transaction_lock_do_acquire_innerrrr)r?rrrr thread_idrOrs r2rzReadWriteLock._acquires|    D D  # # % % %#IIM!+--I$ < <#a''33D99 < < < < < < <  D D D D D D D D <<<xT^xxxC&s+++,00;;;  < < < < < < < < < < < < < < < D!.00 ..'.RRR 5++---11!)&3#- 2*22444(DD088CCCDDDDDDDDDDDDDDD5 D D D D D D D D0*224444(DD088CCCDDDDDDDDDDDDDDDD5 D D D D D D D D D Ds=G- C, G-=C G-C G-C G-*F/-F2F/ G-E9- G-9E= =G-E= G-F,,F//G*7G  G*G" "G*%G" &G**G--G14G1rr*rc|j5|jdkr!||cdddS dddn #1swxYwY|j| |||||||||||f||n#t$r}t|tj r&dt|vrt|j}n|} |n,#tj$r}t!||Yd}~nd}~wwxYw||ur|dd}~wwxYw|j5||||_d|_|dkrt%j|_dddn #1swxYwYt+|S)Nrr)r operationzdatabase is lockedr rlock)rrrrr_open_for_acquisition_configure_and_begin_raise_if_process_changed BaseException isinstancerOperationalErrorstrrrrrrr:rrr) r?rrrrrerroracquisition_error cleanup_errors r2rzReadWriteLock._do_acquire_inners  6 6!##//55 6 6 6 6 6 6 6 6# 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 9  # # % % %   & &!+% '     % %!(*5 &     * *= 9 9 9 9   %!9:: *?SWZ[`WaWa?a?a$+DN$;$;!!$)! H''))))= H H H%&7GGGGGGGG H --'T1    > >  * *= 9 9 9!%D  D w(1(;(=(=%  > > > > > > > > > > > > > > > "t,,,,sh AA A)A B33 E=AE DE D>$D94E 9D>> E  EAF&&F*-F*cbt5t||tj|z dz }||}|dt |jc|_|_ |_ | |ddddS#1swxYwYdS)Nralready_waitedrF) rtimeout_for_sqliterrrrtrarrrrr)r?rrrrrrs r2rz#ReadWriteLock._open_for_acquisitionBs  ! ! : :"%#'#4#6#6#C   ..n.MMJ!**4+?@@ XDItW  * *= 9 9 9 : : : : : : : : : : : : : : : : : :sBB$$B(+B(rtuple[int, float]clt5|\}}td|j}tj|z }t |||} |||d| dtj|z }t |||} ||| | krd| dnd} | |dkrdnd z } |d kr| d z } || ddddS#1swxYwYdS) NrvrzPRAGMA 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_beginTs ! ! 9 9(1 %M:3TY??J&((:5F+GhW]^^^J  * *= 9 9 9  $ $%eJ%e%e%e f f l l n n n&((:5F+GhW]^^^J  * *= 9 9 9BLPZBZBZ> >>>>`bJ DGOO88Qe eJv~~HH  $ $Z 0 0 6 6 8 8 8- 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9sD D))D-0D-rrvc4t5t}t}t|krd}t |t t j|jt|}|| |t|krNt |jt |jd}t ||cdddS#1swxYwYdS)Nz9SQLite connection construction cannot continue after fork)factoryr)rrrTrPrK_connectrrrrvrrtrhra)r?r creator_pidrPrOrs r2rzReadWriteLock._open_connectiontsN  ! !  !))K*4466IyyK''Q"3'''! $.//+&J $)))444yyK''!33(%..t/CDDR"3''')                  sC1D  DDct5|jx} ddddSd}|jsX|jrJ |d|_n4#t j$r}|jrd|_|}Yd}~nd}~wwxYwd|_ |n*#t j$r}|t||d}~wwxYwd|_d|_d|_ || ddddS#1swxYwYdSrj) rrrin_transactionrollbackrrrrr)r?rrollback_errorr  close_errors r2rz ReadWriteLock._finish_connections  ! ! % %"i' 0 % % % % % % % %48N8 A, AE"++---AE== #=///%4"!@D=). /=AD9   """"=   !-).+FFF DI48D 1(,D %)$$*5 % % % % % % % % % % % % % % % % % %sc C/C/A C/A>#A94C/9A>> C/ BC/C-CCC//C36C3c |j|krG|dkrdnd}|dkrdnd}d|d|jdt|d|d |d }t||dkrRt jx}|jkr4d |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) rrrrKr:rrrr)r?ropposite directionrOcurs r2rz!ReadWriteLock._validate_reentrantsL   % %"&&..wwfH'+v~~ 9IO$OOOOBtHHOO%-OO6?OOO s## # 7??y':'<'< <AVVVXXX2d88XX"XX@D@UXX s## # A!t,,,,r1c|s|jd}n>|dkr|jd}n|jd|}|st|jddS)NFrrTr)racquirerr)r?rracquireds r2rz'ReadWriteLock._acquire_transaction_locks V-55u5EEHH ]]-55t5DDHH-55tW5UUH 4$.))t 3 4 4r1&Literal['acquire', 'close', 'release']c|j5tj|jv}dddn #1swxYwY|rd|d|jd}t |dS)NzCannot z ReadWriteLock on r)rr:rrrrK)r?ractive_in_current_threadrOs r2rz!ReadWriteLock._raise_if_acquirings   ] ]'0':'<'<@\'\ $ ] ] ] ] ] ] ] ] ] ] ] ] ] ] ] # $tItttttCs## # $ $s /33clt|ks|jrd|jd}t|dS)Nrr)rrrrK)r?rrOs r2rz'ReadWriteLock._raise_if_process_changeds@ 99 % % %jdnjjjCs## # & %r1rSr)rrrrrrr6r) rrrrrrrrr6r7)rrrrr6rr9)rrrrr6r)rrr6r7)rrrrr6r7)r6r)rrrrrrr6r) rrrrrrrr*rrr6r) rrrrrr*rrr6r7) rrrrrrrrr6r7)rrr6rv)rrr6r)rrrrr6r7)rr/r6r7)rr*r6r7)+r,r-r.rr rr/r:r;rrrrYrr classmethodrr@rrrrrrrrrrrRpropertyrrrrrrrrrrrrrrs@r2rrsG*DWCVCXCXJXXXX%io''OWYYNAD!FFFF""""""AC:Y]:::::[:(* ! ******<ADAAAAAA$BTBBBBBB(QU^(RV^((-444444$ 2 2 2 2$$$$.%%%% #### & & & &HHHXH0000DDDD<0-0-0-0-d::::$9999@.%%%%<----$4444$$$$$$$$$$$$r1r) metaclassdatabaser rtype[_ForkSafeConnection]rrr6cfttj|d|d|S)NFr)check_same_threadrcached_statementsr)rtrkrconnect)r6rrs r2rrs<%%''' ?    r1rc#Ktxjdz c_ dVtxjdzc_dS#txjdzc_wxYw)Nr )r3r+r0r1r2rrsc$$)$$. "((A-(((("((A-((((((s 4A r7cTtjrtjtdSdSr9)r3r+r_exitr'r0r1r2_abort_forked_sqlite_transitionr?s.!'+ )*****++r1eventrytuple[object, ...]cH|dkrtdSdS)Nzsqlite3.connect)rtrk)r@rys r2_track_sqlite_userCs. !!!))+++++"!r1rrrr*c"|durdS|dkrtS|dkrd}t|t|dkrt||z dn|dz}|tks|dkr(td|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)rrrrOrs r2rrs5q"}}%%{{;oo'A++c'N2A6667VZZ[[J***j1nnQSZ\rsss%% r1)after_in_childr)r6r rr7rrr6rv)r6rrS)r@r ryrAr6r7)rrrrrrr6r*)L __future__rloggingrrrsysr:r contextlibrrtypingrrrr r r weakrefr _apirrrrrr_errorrcollections.abcrr version_infortyping_extensions getLoggerrr/getpidrimplementationnamerhasattrr"r bytesPathLikerr*typerr#tupler$r%r'localr)r3r5rTrVrtrvrrrrr?rCr addaudithookr__all__r0r1r2r_s"""""""   ////////KKKKKKKKKKKKKKKK''''''+33333333 7""******!2!2:!>!>>>>>$&I----*/699999 GB"##k(:(?9(LkQTQadkQk%K"+c""R[%77%?#EWM_H``cgg %S#X....&76666')))))y%=$<$>$>>>>>''''''''<.-//////,6,6,6,6,6,6,6,6^32444444$$$$$',$$$NA2A2A2A2A2A2A2A2HZ$Z$Z$Z$Z$0Z$Z$Z$Z$z....++++ ,,,, $()))'(((]### (C&''' 72!""HB'FGGGG r1