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

setup query

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-26 13:02:34 -07:00
parent b2de461c41
commit 8595878244
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
datastore/threads/threadproxyds.nim
View File

@ -233,7 +233,7 @@ method query*(
return failure err return failure err
let dq = dbQuery( let dq = dbQuery(
key=query.key, key= KeyId.new query.key.id(),
value=query.value, value=query.value,
limit=query.limit, limit=query.limit,
offset=query.offset, offset=query.offset,
@ -241,7 +241,7 @@ method query*(
) )
dispatchTask[DbQueryResponse[KeyId, DataBuffer]](self, signal): dispatchTask[DbQueryResponse[KeyId, DataBuffer]](self, signal):
self.tp.spawn deleteTask(addr ctx, ds, dq) self.tp.spawn queryTask(addr ctx, ds, dq)
var var
lock = newAsyncLock() # serialize querying under threads lock = newAsyncLock() # serialize querying under threads