[;j1dZddlZddlZddlmZmZmZddZGddZdZ d Z d Z d Z Gd d Z GddZGddZy)a/ Async wrappers for py-lmdb via :func:`asyncio.loop.run_in_executor`. Usage:: import lmdb import lmdb.aio env = lmdb.open('/tmp/mydb') aenv = lmdb.aio.wrap(env) async with aenv.begin(write=True) as txn: await txn.put(b'key', b'value') val = await txn.get(b'key') N)Cursor Environment Transactionct||S)zWrap an :class:`lmdb.Environment` for async use. *executor* is passed to :meth:`loop.run_in_executor`. ``None`` (the default) uses the loop's default executor. )AsyncEnvironment)envexecutors QG:\00. PROJECTS\API\Inventory\templateJSON\kerjaOCR\Lib\site-packages\lmdb/aio.pywrapr +s C **c,eZdZdZdZdZdZdZdZy)_AsyncContextWrapperzWraps a coroutine so it can be used as both ``await`` and ``async with``. Supports:: txn = await aenv.begin(write=True) # just await async with aenv.begin(write=True) as txn: # context manager _coro_resultc ||_d|_yNr)selfcoros r __init__z_AsyncContextWrapper.__init__?s  r c6|jjSr)r __await__rs r rz_AsyncContextWrapper.__await__Cszz##%%r cXK|jd{|_|jS7wrrrs r __aenter__z_AsyncContextWrapper.__aenter__Fs#!ZZ' ||(s *(*cXK|jj|||d{S7wr)r __aexit__)rexc_typeexc_valexc_tbs r rz_AsyncContextWrapper.__aexit__Js%\\++HgvFFFFs !*(*N) __name__ __module__ __qualname____doc__ __slots__rrrrr r rr4s#%I&Gr rcBtjfd}|S)z@Return a method that calls *sync* directly, without an executor.cDt||jg|i|Sr)getattr_WRAPS)rargskwargssyncs r methodz_sync_method..methodTs#GD$++.@@@@r  functoolswrapsr.r/s` r _sync_methodr4Rs%__TAA Mr cBtjfd}|S)z.method\s^''))) NN   dGD$++$> P P P    sA A*#A($A*r0r3s` r _async_methodr>Zs%__T  Mr cBtjfd}|S)z>Like :func:`_async_method`, but acquires ``self._lock`` first.c VK|j4d{tj}|j|jt j t||jg|i|d{cdddd{S7y77 #1d{7swYyxYwwr) _lockr7r8r9r:r1r;r*r+r<s r r/z$_async_method_locked..methodhsy:::++-D--!!$dkk(BTTTVT:::::sWB)BB)A B8B9B< B)B B)BB)B&B B&"B)r0r3s` r _async_method_lockedrBfs%__T Mr cBtjfd}|S)zvLike :func:`_async_method_locked`, but *sync* returns an iterator consumed in the executor and returned as a list.cKj4d{tj}|jjfdd{cdddd{S7S77 #1d{7swYyxYww)NcVttjgiSr)listr*r+)r,r-rr.sr z1_collect_locked..method..|s$T'$ "<NtNvNOr )rAr7r8r9r:r<s``` r r/z_collect_locked..methodvsW:::++-D--O:::::sVBA+B:A1A-A1 B%A/&B-A1/B1B7A: 8B?Br0r3s` r _collect_lockedrHss'__T Mr cTeZdZdZdZdZd dZdZdZdZ e e jZ e e jZ e e jZe e jZee j"Zee j$Zee j&Zee j(Zee j*Zee j,Zee j.Zee j0Zee j2Zee j4Zee j6Zd Zy) ruAsync wrapper for :py:class:`lmdb.Environment`. Created by :py:func:`wrap`. All methods of the underlying :py:class:`~lmdb.Environment` are available and are dispatched to an executor, except for the low-overhead accessors ``path()``, ``max_key_size()``, ``max_readers()``, and ``flags()``, which are called directly. Supports ``async with`` for lifetime management — the environment is closed on exit. _envr:rKNc ||_||_yrrJ)rr r s r rzAsyncEnvironment.__init__s !r cK|Swrr'rs r rzAsyncEnvironment.__aenter__  c@K|jjywr)rKcloser_excs r rzAsyncEnvironment.__aexit__s c6fd}t|S)a4Start a new transaction, returning an :py:class:`AsyncTransaction`. Accepts the same arguments as :py:meth:`lmdb.Environment.begin`. Can be used with ``await`` or ``async with``:: async with aenv.begin(write=True) as txn: await txn.put(b'key', b'value') cKtj}|jjt j j jgid{}t|jS7wr) r7r8r9r:r1r;rKbeginAsyncTransaction)r=txnr,r-rs r _beginz&AsyncEnvironment.begin.._beginsi++-D,,!!$))//CDCFCC$C8 8 sAA?"A=#A?r)rr,r-rZs``` r rWzAsyncEnvironment.begins 9$FH--r c^t|j|}t|r t||Sr)r*rKcallableAttributeErrorrnameattrs r __getattr__zAsyncEnvironment.__getattr__)tyy$' D> & & r r)r"r#r$r%r&r+rrrrWr4rpath max_key_size max_readersflagsr>statinforQcopycopyfdr.readers reader_check set_mapsizeopen_dbdbsrbr'r r rrs &I F"  .(  (( )D 8 89L{667K ** +E )) *D )) *D +++ ,E )) *D ;-- .F )) *DK//0G !9!9:L 7 78KK//0G   (Cr rceZdZdZdZdZd dZdZdZdZ e e jZ e e jZe e jZe e j Ze e j"Ze e j$Ze e j&Ze e j(Ze e j*Ze e j,Zd Zy) rXuAsync wrapper for :py:class:`lmdb.Transaction`. All methods of the underlying :py:class:`~lmdb.Transaction` are available. Most are dispatched to an executor; ``id()`` is called directly. An :py:class:`asyncio.Lock` serializes all operations dispatched through this transaction, including operations on its cursors. This makes :py:func:`asyncio.gather` safe on the same transaction. Supports ``async with`` — write transactions are committed on clean exit and aborted on exception. )_txnr:rArrNcR||_||_tj|_yr)rrr:r7LockrA)rrYr s r rzAsyncTransaction.__init__s !\\^ r cK|Swrr'rs r rzAsyncTransaction.__aenter__rNrOc^K|j4d{|r|jjnLtj}|j |j |jjd{dddd{y7~77 #1d{7swYyxYwwr)rArrabortr7r8r9r:commit)rr_exc_val_exc_tbr=s r rzAsyncTransaction.__aexit__so::: !//1**4>>499;K;KLLL :: M :::sWB-BB-A%B<B=B B- B B-BB-B*B! B*&B-c6fd}t|S)a;Open a cursor, returning an :py:class:`AsyncCursor`. Accepts the same arguments as :py:meth:`lmdb.Transaction.cursor`. Can be used with ``await`` or ``async with``:: async with txn.cursor() as cur: await cur.first() items = await cur.iternext() c Kj4d{tj}|jjt j jjgid{}dddd{tjjS7777)#1d{7swY9xYwwr) rAr7r8r9r:r1r;rrcursor AsyncCursor)r=curr,r-rs r _cursorz(AsyncTransaction.cursor.._cursorszzz//1 00NN%%dii&6&6HHH"z sDNNDJJ? ? ""zzzsWCB-CAB37B/8B3< CB1&C/B31C3C9B< :CCr[)rr,r-rs``` r r}zAsyncTransaction.cursors @$GI..r c^t|j|}t|r t||Sr)r*rrr]r^r_s r rbzAsyncTransaction.__getattr__rcr r)r"r#r$r%r&r+rrrr}r4ridrBrhdroprxrwgetputreplacepopdeleterbr'r r rXrXs /I F$M/, knn %B  0 0 1D  0 0 1D !+"4"4 5F !2!2 3E { /C { /C";#6#67G { /C !+"4"4 5Fr rXceZdZdZdZdZd dZdZdZe e jZ e e jZ e e jZ ee jZee j Zee j"Zee j$Zee j&Zee j(Zee j*Zee j,Zee j.Zee j0Zee j2Zee j4Zee j6Zee j8Zee j:Zee j<Zee j>Zee j@Z ee jBZ!ee jDZ"ee jFZ#ee jHZ$ee jJZ%e&e jNZ'e&e jPZ(e&e jRZ)e&e jTZ*e&e jVZ+e&e jXZ,dZ-y) r~uAsync wrapper for :py:class:`lmdb.Cursor`. All methods of the underlying :py:class:`~lmdb.Cursor` are available. Most are dispatched to an executor; ``key()``, ``value()``, and ``item()`` are called directly. Iterator methods (``iternext()``, ``iterprev()``, etc.) are consumed in the executor and returned as a list. Shares the parent transaction's :py:class:`asyncio.Lock`. Supports ``async with`` — the cursor is closed on exit. )rr:rArNcZ||_||_|xstj|_yr)rr:r7rtrA)rr}r locks r rzAsyncCursor.__init__6s" !+W\\^ r cK|Swrr'rs r rzAsyncCursor.__aenter__=rNrOc@K|jjywr)rrQrRs r rzAsyncCursor.__aexit__@s rTc^t|j|}t|r t||Sr)r*rr]r^r_s r rbzAsyncCursor.__getattr__js)t||T* D> & & r )NN).r"r#r$r%r&r+rrrr4rkeyvalueitemrBrQfirst first_duplastlast_dupprevprev_dup prev_nodupnextnext_dup next_nodupset_key set_key_dup set_range set_range_duprcountrputmultirrrgetmultirHiternext iternext_dupiternext_nodupiterprev iterprev_dupiterprev_noduprbr'r r r~r~#s 2I F, vzz "C  &E  $D  .E  .E$V%5%56I  ,D#FOO4H  ,D#FOO4H%f&7&78J  ,D#FOO4H%f&7&78J"6>>2G&v'9'9:K$V%5%56I()=)=>M !&-- 0F  .E vzz *C#FOO4H"6>>2G vzz *C vzz *C#FOO4Hv/H"6#6#67L$V%:%:;Nv/H"6#6#67L$V%:%:;Nr r~r)r%r7r1rrrr rr4r>rBrHrrXr~r'r r rsc* ..+GG<   $JJZNNbKKr