From ec4b44212574d1f4d1fd210ee8947d4628b9e50a Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Thu, 24 Aug 2023 18:35:56 -0700 Subject: [PATCH] more changes --- datastore/sharedds.nim | 5 +++-- datastore/threadbackend.nim | 3 +-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/datastore/sharedds.nim b/datastore/sharedds.nim index a4ad564..c33fa2e 100644 --- a/datastore/sharedds.nim +++ b/datastore/sharedds.nim @@ -82,8 +82,9 @@ func new*[S: ref Datastore]( var self = SharedDatastore() - signal = newSignal() res = TResult[ThreadDatastore].new() - self.tds = ThreadDatastore.new(signal, backend, res) + + res[].signal = newSignal() + self.tds = ThreadDatastore.new(backend, res) success self diff --git a/datastore/threadbackend.nim b/datastore/threadbackend.nim index 328e0fa..efc2ee1 100644 --- a/datastore/threadbackend.nim +++ b/datastore/threadbackend.nim @@ -86,7 +86,6 @@ proc getTask*( key: KeyBuffer, ret: TResult[DataBuffer] ) = - # return ok(DataBuffer.new()) discard @@ -108,7 +107,7 @@ proc putTask*( # except Exception as exc: # return TResult[void].new() -func new*[S: ref Datastore]( +func new*( T: typedesc[ThreadDatastore], signal: ThreadSignalPtr, backend: ThreadBackend,