mirror of
https://github.com/logos-storage/nim-datastore.git
synced 2026-01-02 13:43:11 +00:00
cleanup
This commit is contained in:
parent
7169a7d20f
commit
2d843857cd
@ -63,17 +63,17 @@ var ctxLock: Lock
|
||||
ctxLock.initLock()
|
||||
|
||||
proc setCancelled[T](ctx: TaskCtx[T]) =
|
||||
withLock(ctxLock):
|
||||
# withLock(ctxLock):
|
||||
ctx[].cancelled = true
|
||||
|
||||
proc setRunning[T](ctx: TaskCtx[T]): bool =
|
||||
withLock(ctxLock):
|
||||
# withLock(ctxLock):
|
||||
if ctx[].cancelled:
|
||||
return false
|
||||
ctx[].running = true
|
||||
return true
|
||||
proc setDone[T](ctx: TaskCtx[T]) =
|
||||
withLock(ctxLock):
|
||||
# withLock(ctxLock):
|
||||
ctx[].running = false
|
||||
|
||||
proc acquireSignal(): ?!ThreadSignalPtr =
|
||||
|
||||
@ -40,7 +40,6 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
|
||||
var res: seq[QueryResponse]
|
||||
for pair in iter:
|
||||
let (key, val) = (await pair).tryGet
|
||||
echo "test:query:result: ", $key
|
||||
if key.isNone:
|
||||
break
|
||||
res.add((key, val))
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user