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

integrate setups

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-25 23:29:22 -07:00
parent 8eef3e6442
commit 9c7c47e66a
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
datastore/threads/threadproxyds.nim
View File

@ -73,12 +73,12 @@ proc acquireSignal(): ?!ThreadSignalPtr =
else:
success signal.get()
template dispatchTask(self: ThreadDatastore,
signal: ThreadSignalPtr,
blk: untyped
): auto =
template dispatchTask[T](self: ThreadDatastore,
signal: ThreadSignalPtr,
blk: untyped
): auto =
var
ctx {.inject.} = TaskCtx[SqliteDB, bool](signal: signal)
ctx {.inject.} = TaskCtx[SqliteDB, T](signal: signal)
try:
case self.backend.kind:
of Sqlite:
@ -130,7 +130,7 @@ method has*(self: ThreadDatastore,
return failure err
let key = KeyId.new key.id()
dispatchTask(self, signal):
dispatchTask[bool](self, signal):
self.tp.spawn hasTask(addr ctx, ds, key)
proc deleteTask[DB](ctx: ptr TaskCtx, ds: DB;
@ -146,7 +146,7 @@ method delete*(self: ThreadDatastore,
return failure err
let key = KeyId.new key.id()
dispatchTask(self, signal):
dispatchTask[void](self, signal):
self.tp.spawn deleteTask(addr ctx, ds, key)
method delete*(self: ThreadDatastore,