diff --git a/datastore/threadbackend.nim b/datastore/threadbackend.nim index bdcbf22..f7886f3 100644 --- a/datastore/threadbackend.nim +++ b/datastore/threadbackend.nim @@ -78,6 +78,7 @@ proc startupDatastore( ret[].value[].backendDatastore = ds.get() ret[].state = Success of TestBackend: + echo "startupDatastore: TestBackend" ret[].value[].backendDatastore = nil ret[].state = Success else: @@ -117,10 +118,12 @@ proc createThreadDatastore*( ) = try: - ret[].value[].tp = Taskpool.new(num_threads = 1) ##\ + echo "createThreadDatastore: start" + ret[].value[].tp = Taskpool.new(num_threads = 2) ##\ ## Default to one thread, multiple threads \ ## will require more work ret[].value[].tp.spawn startupDatastore(ret, backend) + echo "createThreadDatastore: done" except Exception as exc: ret[].state = Error diff --git a/tests/datastore/testsharedds.nim b/tests/datastore/testsharedds.nim index 99167ff..54b6ae0 100644 --- a/tests/datastore/testsharedds.nim +++ b/tests/datastore/testsharedds.nim @@ -20,7 +20,8 @@ suite "Test Basic SharedDatastore": let backend = ThreadBackend( kind: TestBackend, ) - let sds = newSharedDataStore(backend) + let sds = await newSharedDataStore(backend) + echo "sds: ", repr sds # suite "Test Basic FSDatastore": # let