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

integrate setups

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-25 23:21:08 -07:00
parent 0926eaf245
commit 73df67899b
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
datastore/threads/threadproxyds.nim
View File

@ -99,7 +99,7 @@ template dispatchTask(self: ThreadDatastore,
discard ctx.signal.close()
self.semaphore.release()
proc runTask[D, T](ctx: ptr TaskCtx, ds: D, cb: proc(ctx: ptr TaskCtx): T {.gcsafe.}) {.gcsafe.} =
template runTask(ctx: ptr TaskCtx, blk: untyped) =
try:
withLock(ctxLock):
if ctx.cancelled:
@ -107,7 +107,7 @@ proc runTask[D, T](ctx: ptr TaskCtx, ds: D, cb: proc(ctx: ptr TaskCtx): T {.gcsa
ctx.running = true
## run backend command
let res = cb(ctx)
let res = `blk`
withLock(ctxLock):
ctx.running = false
@ -121,7 +121,7 @@ proc runTask[D, T](ctx: ptr TaskCtx, ds: D, cb: proc(ctx: ptr TaskCtx): T {.gcsa
proc hasTask[DB](ctx: ptr TaskCtx, ds: DB, key: KeyId) {.gcsafe.} =
## run backend command
runTask(ctx, ds) do(ctx: ptr TaskCtx) -> ?!bool:
runTask(ctx):
has(ds, key)
method has*(self: ThreadDatastore, key: Key): Future[?!bool] {.async.} =