排jpUddlmZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z mZmZmZmZmZddlmZddlmZmZmZmZmZmZddlmZe r&dd lmZm Z dd l!m"Z"ej#d krdd l m$Z$ndd l%m$Z$ej&d Z'de(d<ej)Z*de(d<ej+j,dkZ-de(d<e.edoej+j,dko ej#dkZ/de(d<e0e1zej2e0zej2e1ze3ze4ze5ej6zdzZ7de(d<e8e4e4fZ9de(d<dZ:de(d<dZ;de(d <Gd!d"ej<Z=e=Z>d#e(d$<Gd%d&Z?e?Z@d#e(d'<Gd(d)ZAeAZBd#e(d*<Gd+d,ej6ZCGd-d.e5ZDGd/d0eD1ZEdId9ZFe dJd;ZGdKd=ZHdLdAZIdMdFZJee@eeBeeEe-rejKeIe.edrejLeHGd0dHgZMdS)N) 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<dS)_SQLiteTransitionContextrintdepthN)__name__ __module__ __qualname__r,__annotations__BC:\Projects\DSCons\.venv\Lib\site-packages\filelock\_read_write.pyr*r*2sENNNNNNr2r*r_SQLITE_TRANSITION_CONTEXTc&eZdZddZd dZddZdS) _ConnectionEscrowreturnNonecDtj|_d|_dSN) threadingRLock_lock _functionsselfs r3__init__z_ConnectionEscrow.__init__:s_&& txr2Xtuple[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@rD function_typeincrement_addressdecrement_addressmsgs r3 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|_dSr:)r;r<r=r?s r3_reset_after_fork_in_childz,_ConnectionEscrow._reset_after_fork_in_childSs_&& r2Nr7r8)r7rB)r-r.r/rArQrSr1r2r3r6r69sTyyyy####*''''''r2r6_CONNECTION_ESCROWcNeZdZddZddZdd Zdd Zdd Zedd Z d S)_ForkedDatabaseRegistryr7r8ctj|_t|_t|_d|_d|_dSNF)r;r<r=set_paths _identities _sqlite_used_all_paths_poisonedr?s r3rAz _ForkedDatabaseRegistry.__init__[s>_&& ), 3655!#(   r2path 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^r[r\rL)r@r_rball_paths_poisonedpoisonedrPs r3raise_if_poisonedz)_ForkedDatabaseRegistry.raise_if_poisonedbs==&& Z  !%!9 "tddk&9thd>R>sW_cgcsWs                  $&uaatttt  s## #  $ $s A  A A rb_DatabaseIdentity | Nonecv|j|||j|dSdSr:)r[addr\)r@r_rbs r3poison_after_forkz)_ForkedDatabaseRegistry.poison_after_forkqsA       * * * * * r2cftr)|j5d|_ddddS#1swxYwYdSdSNT)rr=r]r?s r3note_sqlite_usez'_ForkedDatabaseRegistry.note_sqlite_usevs  ) ) )$(! ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s $((cxtj|_|jp to|j|_d|_dSrY)r;r<r=r^rr]r?s r3rSz2_ForkedDatabaseRegistry._reset_after_fork_in_child{s7_&& #'#;#_@^TM^ !r2cl |}n#t$rYdSwxYw|j|jfSr:)statOSErrorst_devst_ino)r_ stat_results r3rbz _ForkedDatabaseRegistry.identitysI ))++KK   44 !;#555s  %%NrT)r_r`r7r8)r_r`rbrfr7r8)r_r`r7rf) r-r.r/rArerirlrS staticmethodrbr1r2r3rWrWZs)))) $ $ $ $++++ )))) """" 666\666r2rW_FORKED_DATABASEScNeZdZUded<ded<dfd Zdd ZddZddZxZS)_ForkSafeConnectionr+ _creator_pidz+Callable[[sqlite3.Connection], None] | None_decrement_escrow_argsr$_kwargsr7rc~t|}t|_d|_|Sr:)super__new__rrxry)clsrzr{ connection __class__s r3r~z_ForkSafeConnection.__new__s4 WW__S)) "))) '+ $r2r8c^t5t|jkr ddddSt5tj||jx}d|_||dddn #1swxYwYddddS#1swxYwYdSr:)_sqlite_transitionrrxrsqlite3 Connectionclosery)r@ decrements r3rz_ForkSafeConnection.closesL  ! ! $ $yyD--- $ $ $ $ $ $ $ $"## $ $"((...!%!77ID-1D*IdOOO  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s:B"B";B > B" B B"B B""B&)B&rQrBc<||\}}||||_dSdSr:)ry)r@rQ incrementrs r3acquire_escrowz"_ForkSafeConnection.acquire_escrows7  #, Iy IdOOO%.D " " " ! r2cttjt5|ddddS#1swxYwYdSr:)rrErrorrLrr?s r3__del__z_ForkSafeConnection.__del__s gm\ 2 2   JJLLL                  sAA A)rzr$r{r$r7rrT)rQrBr7r8) r-r.r/r0r~rrr __classcell__rs@r3rwrwsBBBB$$$$////r2rwcbeZdZUdZded<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]timeoutfloatrboolrr7 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__rLpathlibPathresolverrrrhdiscardrr ValueError) rrrrrconstruction_pidinstancerP normalizedconstruction_registryrs r3rz_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]]rr7r8ctt|_t j|_t|_t|_ t|dSr:) r}__init_subclass__r rr;r<rrrrZrr)rrs r3rzReadWriteLock.__init_subclass__sb !!###,..'o//$YY,/EE)S!!!!!r2rTrrrrrrrc||||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 rr1)rrrrs r3get_lockzReadWriteLock.get_locks s9g9999r2rrctj||_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_pathrurerrr;Lock_transaction_lock_internal_lock _lock_level _current_mode_write_thread_idrZ_acquisition_thread_ids_con _connection_transaction_released_connection_identity_closedrrx_fork_invalidatedrrr_open_connectionr)r@rrrrvalidation_connections r3rAzReadWriteLock.__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 r3 acquire_readzReadWriteLock.acquire_readJs }}VWx}@@@r2c2|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 r3 acquire_writezReadWriteLock.acquire_write\s$}}Wg}AAAr2N 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 r3 read_lockzReadWriteLock.read_lockpsk ?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 r3 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 r3rzReadWriteLock.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 r3rzReadWriteLock.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 ) rrrrrridrL_finish_connectionrrr_clear_lock_state)r@rrrPs r3rzReadWriteLock._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 r3rzReadWriteLock._clear_lock_states ! $r2ctt|ddkrat|ddx}Pttjt 5|ddddS#1swxYwYdSdSdS)Nrxr)rgetattrrrrrLr)r@rs r3rzReadWriteLock.__del__s 99nd;; ; ;wW[]ceiOjOjAj@w'-66 # #  """ # # # # # # # # # # # # # # # # # # < ;@w@wsA66A:=A:cD|j%t|j|jd|_d|_d|_t j|_t j|_ | t|_ d|_ dSrk)rrurirrrr;rrrrrZrrr?s r3rSz(ReadWriteLock._reset_after_fork_in_childs 9  / /0DdF_ ` ` ` 04-$(!!*!1!1'n..    '*uu$!%r2c>|jpt|jkSr:)rrrxr?s r3rzReadWriteLock._inheriteds%Gd6G)GGr2ct|jrd|jd}t||jrd}t j|dS)NReadWriteLock on 4 was invalidated by fork(); construct a new instancez$Cannot operate on a closed database.)rrrrLrrProgrammingError)r@rPs r3_raise_if_unusablez ReadWriteLock._raise_if_unusablesb!!! ? $jdnjjjCs## # < 08C*3// / 0 0r2modeLiteral['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_reentrantrrrLrhtime perf_counter_acquire_transaction_lock_do_acquire_innerrrr)r@rrrr thread_idrPrs r3rzReadWriteLock._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 r3rzReadWriteLock._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_sqliterrrrurbrrrrr )r@rrrrrrs r3rz#ReadWriteLock._open_for_acquisitionDs  ! ! : :"%#'#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) 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 ! ! 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-rrwc4t5t}t}t|krd}t |t t j|jt|}|| |t|krNt |jt |jd}t ||cdddS#1swxYwYdS)Nz9SQLite connection construction cannot continue after fork)factoryr)rrrUrQrL_connectrrrrwrrurirb)r@r creator_pidrQrPrs r3rzReadWriteLock._open_connectionvsN  ! !  !))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#1swxYwYdSrk) rrrin_transactionrollbackrrrrr)r@rrollback_errorr close_errors r3rz 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) rrrrLr;rrrr)r@ropposite directionrPcurs r3rz!ReadWriteLock._validate_reentrantsL   % %"&&..wwfH'+v~~ 9IO$OOOOBtHHOO%-OO6?OOO s## # 7??y':'<'< <AVVVXXX2d88XX"XX@D@UXX s## # A!t,,,,r2c|s|jd}n>|dkr|jd}n|jd|}|st|jddS)NFrrTr)racquirerr)r@rracquireds r3rz'ReadWriteLock._acquire_transaction_locks V-55u5EEHH ]]-55t5DDHH-55tW5UUH 4$.))t 3 4 4r2&Literal['acquire', 'close', 'release']c|j5tj|jv}dddn #1swxYwY|rd|d|jd}t |dS)NzCannot z ReadWriteLock on r)rr;rrrrL)r@ractive_in_current_threadrPs r3rz!ReadWriteLock._raise_if_acquirings   ] ]'0':'<'<@\'\ $ ] ] ] ] ] ] ] ] ] ] ] ] ] ] ] # $tItttttCs## # $ $s /33clt|ks|jrd|jd}t|dS)Nrr)rrrrL)r@rrPs r3r z'ReadWriteLock._raise_if_process_changeds@ 99 % % %jdnjjjCs## # & %r2rTr)rrrrrrr7r) rrrrrrrrr7r8)rrrrr7rr:)rrrrr7r)rrr7r8)rrrrr7r8)r7r)rrrrrrr7r) rrrrrrrr+rrr7r) rrrrrr+rrr7r8) rrrrrrrrr7r8)rrr7rw)rrr7r)rrrrr7r8)rr0r7r8)rr+r7r8)+r-r.r/rr rr0r;r<rrrrZrr classmethodrrArrrrrrrrrrrSpropertyrrrrrrrrrrrr rrs@r3rrsG*DWCVCXCXJXXXX%io''OWYYNAD!FFFF""""""AC:Y]:::::[:(* ! ******<ADAAAAAA$BTBBBBBB(QU^(RV^((-444444$ 2 2 2 2$$$$.%%%% #### & & & &HHHXH0000DDDD<0-0-0-0-d::::$9999@.%%%%<----$4444$$$$$$$$$$$$r2r) metaclassdatabaser rtype[_ForkSafeConnection]rrr7cfttj|d|d|S)NFr)check_same_threadrcached_statementsr)rurlrconnect)r7rrs r3r r s<%%''' ?    r2rc#Ktxjdz c_ dVtxjdzc_dS#txjdzc_wxYw)Nr )r4r,r1r2r3rrsc$$)$$. "((A-(((("((A-((((((s 4A r8cTtjrtjtdSdSr:)r4r,r_exitr(r1r2r3_abort_forked_sqlite_transitionr@s.!'+ )*****++r2eventrzrcH|dkrtdSdS)Nzsqlite3.connect)rurl)rArzs r3_track_sqlite_userCs. !!!))+++++"!r2rrrr+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)rrrrPrs r3rrs5q"}}%%{{;oo'A++c'N2A6667VZZ[[J***j1nnQSZ\rsss%% r2)after_in_childr)r7r rr8rrr7rw)r7rrT)rAr rzrr7r8)rrrrrrr7r+)N __future__rloggingrrrsysr;r contextlibrrtypingrrrr r r weakrefr _apirrrrrr_errorrcollections.abcrr _typeshedr version_infortyping_extensions getLoggerrr0getpidrimplementationnamerhasattrr#r bytesPathLikerr+typerr$tupler%r&r(localr*r4r6rUrWrurwrrr rr@rCr addaudithookr __all__r1r2r3r`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 r2