logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-05 22:43:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

updates

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-12 13:32:56 -07:00
parent 13d5d5c241
commit a21ecfa811
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/apatheia/jobs.nim
View File

@ -43,22 +43,18 @@ proc newJobQueue*[T](maxItems: int = 0, taskpool: Taskpool = Taskpool.new()): Jo
asyncSpawn(processJobs(result)) asyncSpawn(processJobs(result))
macro submitMacro*(tp: untyped, jobs: untyped, exp: untyped): untyped = macro submitMacro*(tp: untyped, jobs: untyped, exp: untyped): untyped =
## modifies the call expression to include the job queue and
echo "submit:::" ## the job id parameters
echo "submit:T: ", tp.treeRepr
echo "submit: ", exp.treerepr
let futName = genSym(nskLet, "fut") let futName = genSym(nskLet, "fut")
let idName = genSym(nskLet, "id") let idName = genSym(nskLet, "id")
let nm = newLit(repr(exp))
let queueExpr = quote do: let queueExpr = quote do:
`jobs`.queue `jobs`.queue
var fncall = nnkCall.newTree(exp[0]) var fncall = nnkCall.newTree(exp[0])
fncall.add(queueExpr) fncall.add(queueExpr)
fncall.add(idName) fncall.add(idName)
for p in exp[1..^1]: for p in exp[1..^1]: fncall.add(p)
fncall.add(p)
echo "submit: ", fncall.treeRepr
let nm = newLit(repr(exp))
result = quote do: result = quote do:
let (`idName`, `futName`) = createFuture(`jobs`, `nm`) let (`idName`, `futName`) = createFuture(`jobs`, `nm`)