logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-07 15:33:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

setting up wrappers

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-13 22:43:26 -07:00
parent fd323de9b7
commit 14392e838f
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/apatheia/tasks.nim
View File

@ -39,8 +39,12 @@ macro asyncTask*(p: untyped): untyped =
for paramId, paramType in paramsIter(params): for paramId, paramType in paramsIter(params):
echo "param: ", paramId, " tp: ", paramType.treeRepr echo "param: ", paramId, " tp: ", paramType.treeRepr
tcall.add newCall("checkParamType", paramId) tcall.add newCall("checkParamType", paramId)
asyncBody.add quote do: # asyncBody.add nnkLetSection.newTree(
let res = `tcall` # nnkIdentDefs.newTree(ident"res", newEmptyNode(), tcall))
asyncBody = quote do:
let res {.inject.} = `tcall`
discard jobResult.queue.send((jobResult.id, res,))
var asyncParams = params.copyNimTree() var asyncParams = params.copyNimTree()
let retType = if not hasReturnType(params): ident"void" let retType = if not hasReturnType(params): ident"void"
else: params.getReturnType() else: params.getReturnType()
@ -72,6 +76,7 @@ proc doHashes2*(data: openArray[byte],
opts: HashOptions): float {.asyncTask.} = opts: HashOptions): float {.asyncTask.} =
echo "hashing" echo "hashing"
# proc doHashesRes*(data: openArray[byte], # proc doHashesRes*(data: openArray[byte],
# opts: HashOptions): int {.asyncTask.} = # opts: HashOptions): int {.asyncTask.} =
# # echo "args: ", args.len() # # echo "args: ", args.len()