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

copy data and keys to thread local gc

Browse Source
This commit is contained in:
Dmitriy Ryajov 2023-09-20 14:00:29 -06:00
parent 81372c96d7
commit 3d84781d3e
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
datastore/threads/threadproxyds.nim
View File

@ -142,7 +142,8 @@ proc asyncHasTask(
return return
let let
fut = ctx[].ds.has(key[]) key = key[]
fut = ctx[].ds.has(key)
asyncSpawn signalMonitor(ctx, fut) asyncSpawn signalMonitor(ctx, fut)
without ret =? (await fut).catch and res =? ret, error: without ret =? (await fut).catch and res =? ret, error:
@ -181,7 +182,8 @@ proc asyncDelTask(ctx: ptr TaskCtx[void], key: ptr Key) {.async.} =
return return
let let
fut = ctx[].ds.delete(key[]) key = key[]
fut = ctx[].ds.delete(key)
asyncSpawn signalMonitor(ctx, fut) asyncSpawn signalMonitor(ctx, fut)
without res =? (await fut).catch, error: without res =? (await fut).catch, error:
@ -239,7 +241,9 @@ proc asyncPutTask(
return return
let let
fut = ctx[].ds.put(key[], @(data.toOpenArray(0, len - 1))) key = key[]
data = @(data.toOpenArray(0, len - 1))
fut = ctx[].ds.put(key, data)
asyncSpawn signalMonitor(ctx, fut) asyncSpawn signalMonitor(ctx, fut)
without res =? (await fut).catch, error: without res =? (await fut).catch, error:
@ -306,7 +310,8 @@ proc asyncGetTask(
return return
let let
fut = ctx[].ds.get(key[]) key = key[]
fut = ctx[].ds.get(key)
asyncSpawn signalMonitor(ctx, fut) asyncSpawn signalMonitor(ctx, fut)
without res =? (await fut).catch and data =? res, error: without res =? (await fut).catch and data =? res, error:
@ -314,7 +319,7 @@ proc asyncGetTask(
ctx[].res[].err(error) ctx[].res[].err(error)
return return
trace "Got data in get", data trace "Got data in get"
ctx[].res[].ok(DataBuffer.new(data)) ctx[].res[].ok(DataBuffer.new(data))
proc getTask( proc getTask(