adding test backend

This commit is contained in:
Jaremy Creechley 2023-08-24 19:59:37 -07:00 committed by Dmitriy Ryajov
parent 2e9695ea86
commit 464896bf88
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
2 changed files with 6 additions and 2 deletions

View File

@ -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

View File

@ -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