logos-storage/nim-datastore
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-datastore.git synced 2026-01-06 23:53:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

setup query

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-26 15:50:22 -07:00
parent 911de83537
commit 9c6f2fc74a
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 18 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
datastore/threads/threadproxyds.nim
View File

@ -235,27 +235,29 @@ proc queryTask[DB](
## run query command
executeTask(ctx):
let qh = ds.query(dq)
if qh.isOk():
ctx[].res.ok default(QResult)
if qh.isErr():
# set error and exit, which will fire final signal
(?!QResult).err(qh.error())
else:
ctx[].res.err qh.error().toThreadErr()
return
# otherwise set empty ok result
ctx[].res.ok (KeyId.none, DataBuffer.new())
discard ctx[].signal.fireSync()
var handle = qh.get()
for item in handle.iter():
if ctx[].cancelled:
# cancel iter, then run next cycle so it'll finish and close
handle.cancel = true
continue
else:
var handle = qh.get()
for item in handle.iter():
# wait for next request from async thread
discard ctx[].signal.waitSync().get()
ctx[].res = item.mapErr() do(exc: ref CatchableError) -> ThreadResErr:
exc
discard ctx[].signal.fireSync()
(?!QResult).err((ref QueryEndedError)(msg: "done").toThreadErr())
if ctx[].cancelled:
# cancel iter, then run next cycle so it'll finish and close
handle.cancel = true
continue
else:
ctx[].res = item.mapErr() do(exc: ref CatchableError) -> ThreadResErr:
exc
discard ctx[].signal.fireSync()
(?!QResult).err((ref QueryEndedError)(msg: "done").toThreadErr())
method query*(
self: ThreadDatastore,