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

merge fix

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-18 14:18:17 -07:00
parent bbfc319624
commit 5e5ab2381c
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 6 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
datastore/threads/threadproxyds.nim
View File

@ -59,12 +59,10 @@ proc addrOf*[T](ctx: ref TaskCtx[T]): ptr TaskCtx[T] =
proc new*[T](
ctx: typedesc[TaskCtx[T]],
ds: Datastore,
signal: ThreadSignalPtr,
): ref TaskCtx[T] =
# let res = cast[ptr TaskCtx[T]](allocShared0(sizeof(TaskCtx[T])))
let res = (ref TaskCtx[T])()
res.ds = unsafeAddr ds
res.signal = signal
res
template withLocks(
@ -97,7 +95,7 @@ template dispatchTask(
runTask: proc): untyped =
try:
await self.semaphore.acquire()
ctx.signal = ThreadSignalPtr.new().valueOr:
ctx[].signal = ThreadSignalPtr.new().valueOr:
result = failure(error())
return
@ -176,9 +174,7 @@ method has*(self: ThreadDatastore, key: Key): Future[?!bool] {.async.} =
signal = ThreadSignalPtr.new().valueOr:
return failure(error())
ctx = TaskCtx[bool].new(
ds = self.ds,
signal = signal)
ctx = TaskCtx[bool].new( ds = self.ds)
proc runTask() =
self.tp.spawn hasTask(addrOf(ctx), unsafeAddr key)
@ -216,9 +212,7 @@ method delete*(
signal = ThreadSignalPtr.new().valueOr:
return failure(error())
ctx = TaskCtx[void].new(
ds= self.ds,
signal= signal)
ctx = TaskCtx[void].new( ds= self.ds)
proc runTask() =
self.tp.spawn delTask(addrOf(ctx), unsafeAddr key)
@ -277,9 +271,7 @@ method put*(
signal = ThreadSignalPtr.new().valueOr:
return failure(error())
ctx = TaskCtx[void].new(
ds= self.ds,
signal= signal)
ctx = TaskCtx[void].new( ds= self.ds)
proc runTask() =
self.tp.spawn putTask(
@ -334,9 +326,7 @@ method get*(
self: ThreadDatastore,
key: Key): Future[?!seq[byte]] {.async.} =
var
ctx = TaskCtx[DataBuffer].new(
ds= self.ds,
signal= signal)
ctx = TaskCtx[DataBuffer].new(ds= self.ds)
proc runTask() =
self.tp.spawn getTask(addrOf(ctx), unsafeAddr key)
@ -418,9 +408,7 @@ method query*(
signal = ThreadSignalPtr.new().valueOr:
return failure("Failed to create signal")
ctx = TaskCtx[(bool, DataBuffer, DataBuffer)].new(
ds= self.ds,
signal= signal)
ctx = TaskCtx[(bool, DataBuffer, DataBuffer)].new( ds= self.ds)
proc runTask() =
self.tp.spawn queryTask(addrOf(ctx), addr childIter)