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

more docs

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-05 13:51:22 -07:00
parent 35d8f76649
commit a23ec47b24
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
datastore/threadproxyds.nim
View File

@ -138,13 +138,13 @@ method query*(
ret.failure(err)
var iter = newSharedPtr(QueryIterStore)
## note that bypasses SharedPtr isolation - may need `protect` here?
## does this bypasses SharedPtr isolation? - may need `protect` here?
iter[].it = it
var iterWrapper = QueryIter.new()
proc next(): Future[?!QueryResponse] {.async.} =
print "query:next:start: "
# print "query:next:start: "
iterWrapper.finished = iter[].it.finished
if not iter[].it.finished:
query(ret, self.tds, iter)
@ -191,6 +191,7 @@ proc newThreadProxyDatastore*(
var self = ThreadProxyDatastore()
let value = newSharedPtr(ThreadDatastore)
# GC_ref(ds) ## TODO: is this needed?
try:
value[].ds = ds
value[].tp = Taskpool.new(num_threads = 2)