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

setup query

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

9
datastore/threads/threadproxyds.nim
View File

@ -234,12 +234,14 @@ proc queryTask[DB](
) {.gcsafe, nimcall.} =
## run query command
executeTask(ctx):
# we execute this all inside `executeTask`
# so we need to return a final result
let qh = ds.query(dq)
if qh.isErr():
# set error and exit, which will fire final signal
# set error and exit executeTask, which will fire final signal
(?!QResult).err(qh.error())
else:
# otherwise set empty ok result
# otherwise manually an set empty ok result
ctx[].res.ok (KeyId.none, DataBuffer.new())
discard ctx[].signal.fireSync()
@ -257,7 +259,8 @@ proc queryTask[DB](
exc
discard ctx[].signal.fireSync()
(?!QResult).err((ref QueryEndedError)(msg: "done").toThreadErr())
# set final result
(?!QResult).ok((KeyId.none, DataBuffer.new()))
method query*(
self: ThreadDatastore,