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

aww, that fixes the sig issue

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-14 15:43:55 -07:00
parent 6a45f9fa25
commit 84f3f8638b
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
datastore/threadproxyds.nim
View File

@ -91,31 +91,33 @@ method put*(
): Future[?!void] =
echoed "put request args: ", $getThreadId()
let tds = self.tds
var putRes = newFuture[?!void]("threadbackend.put(tds, key, data)")
let sig = SharedSignal.new(2)
let sig = SharedSignal.new(0)
echoed "put:sig: ", sig.repr
acquireSig(sig).
then(proc () =
echoed "got tresFut"
let
ret = newSharedPtr(ThreadResult[void])
bkey = KeyBuffer.new(key)
bval = DataBuffer.new(data)
# queue taskpool work
tds[].tp.spawn putTask(sig, ret, tds, bkey, bval)
# wait for taskpool work to finish
wait(sig).
then(proc () =
sig.decr()
# sig.decr()
os.sleep(400)
let val = ret.convert(void)
putRes.complete(val)
).cancelled(proc() =
sig.decr()
# sig.decr()
discard
).catch(proc(e: ref CatchableError) =
sig.decr()
# sig.decr()
discard
doAssert false, "will not be triggered"
)
).catch(proc(e: ref CatchableError) =