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

result types

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

10
datastore/threads/threadproxyds.nim
View File

@ -85,25 +85,18 @@ proc acquireSignal(): ?!ThreadSignalPtr =
template executeTask[T](ctx: TaskCtx[T], blk: untyped) =
try:
echo "executeTask:start:"
if not ctx.setRunning():
echo "executeTask:notRunning!"
return
## run backend command
echo "executeTask:run:"
let res = `blk`
if res.isOk():
echo "executeTask:run:ok"
when T is void:
ctx[].res.ok()
else:
ctx[].res.ok(res.get())
else:
echo "executeTask:run:err"
ctx[].res.err res.error().toThreadErr()
echo "executeTask:run:done: ", ctx[].res.repr
echo ""
except CatchableError as exc:
trace "Unexpected exception thrown in async task", exc = exc.msg
@ -112,10 +105,8 @@ template executeTask[T](ctx: TaskCtx[T], blk: untyped) =
trace "Unexpected defect thrown in async task", exc = exc.msg
ctx[].res.err exc.toThreadErr()
finally:
echo "executeTask:finally:setDone"
ctx.setDone()
discard ctx[].signal.fireSync()
echo "executeTask:finally:done\n"
template dispatchTaskWrap[T](self: ThreadDatastore,
signal: ThreadSignalPtr,
@ -176,6 +167,7 @@ method delete*(self: ThreadDatastore,
let key = KeyId.new key.id()
dispatchTask[void](self, signal):
self.tp.spawn deleteTask(ctx, ds, key)
return ctx[].res.toRes()
method delete*(self: ThreadDatastore,