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

test query

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-26 17:52:35 -07:00
parent b4ce2868ed
commit 690b3d4453
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
datastore/threads/threadproxyds.nim
View File

@ -106,6 +106,7 @@ template executeTask[T](ctx: TaskCtx[T], blk: untyped) =
ctx[].res.err exc.toThreadErr()
finally:
ctx.setDone()
# echo "\t\texecuteTask:fireSync!"
discard ctx[].signal.fireSync()
template dispatchTaskWrap[T](self: ThreadDatastore,
@ -119,6 +120,7 @@ template dispatchTaskWrap[T](self: ThreadDatastore,
proc runTask() =
`blk`
runTask()
# echo "\t\tdispatchTask:wait!"
await wait(ctx[].signal)
except CancelledError as exc:
@ -271,14 +273,17 @@ proc queryTask[DB](
var handle = qh.get()
for item in handle.iter():
# wait for next request from async thread
echo "\tqueryTask:query:iter:wait "
echo "\tqueryTask:query:iter:wait! "
discard ctx[].signal.waitSync().get()
echo "\tqueryTask:query:iter:wait:done "
if ctx[].cancelled:
echo "\tqueryTask:query:iter:cancelled"
# cancel iter, then run next cycle so it'll finish and close
handle.cancel = true
continue
else:
echo "\tqueryTask:query:iter:done"
ctx[].res = item.mapErr() do(exc: ref CatchableError) -> ThreadResErr:
exc
echo "\tqueryTask:query:iter:fireSync "
@ -335,10 +340,11 @@ method query*(
await lock.acquire()
echo "query:next:iter:dispatch"
await ctx[].signal.fire()
dispatchTaskWrap[DbQueryResponse[KeyId, DataBuffer]](self, signal):
# trigger query task to iterate then wait for new result!
discard ctx[].signal.fireSync()
echo "query:next:iter:dispatch:fire"
echo "query:next:iter:dispatch:fireSync"
echo "query:next:iter:dispatch:wait"
echo "query:next:iter:res: "
if not ctx[].running: