logos-storage/nim-datastore
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-datastore.git synced 2026-01-02 13:43:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

test query

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-26 18:24:48 -07:00
parent be70ddb250
commit b746a266e7
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
datastore/threads/threadproxyds.nim
View File

@ -337,6 +337,11 @@ method query*(
echo "query:next:iter:finished"
return failure (ref QueryEndedError)(msg: "Calling next on a finished query!")
if not ctx[].running:
echo "query:next:iter:finished "
iter.finished = true
return
echo "query:next:acquire:lock"
await lock.acquire()
@ -347,10 +352,6 @@ method query*(
echo "query:next:iter:res: ", ctx[].res, "\n"
if not ctx[].running:
echo "query:next:iter:finished "
iter.finished = true
if ctx[].res.isErr():
return err(ctx[].res.error())
else:

9
tests/datastore/querycommontests.nim
View File

@ -37,18 +37,13 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
let
iter = (await ds.query(q)).tryGet
res = block:
var
res: seq[QueryResponse]
cnt = 0
var res: seq[QueryResponse]
for pair in iter:
let (key, val) = (await pair).tryGet
echo "test:query:result: ", $key
if key.isNone:
break
res.add((key, val))
cnt.inc
res
check: