codex-storage/nim-codex
1
0
Fork 0
mirror of https://github.com/codex-storage/nim-codex.git synced 2025-01-19 01:12:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix gc args issue

Browse Source
This commit is contained in:
Jaremy Creechley 2024-06-03 14:14:12 +01:00
parent b346f6cf9f
commit a695688faf
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
codex/slots/proofs/backends/asynccircoms.nim
View File

@ -14,13 +14,23 @@ import ./circomcompat
logScope:
topics = "codex asyncprover"
type AsyncCircomCompat* = object
circom*: CircomCompat
tp*: Taskpool
type
AsyncCircomCompat* = object
circom*: CircomCompat
tp*: Taskpool
ProverArgs[H] = object
circom: CircomCompat
data: ProofInputs[H]
proc proveTask[H](
circom: CircomCompat, data: ProofInputs[H], results: SignalQueuePtr[?!CircomProof]
args: ptr ProverArgs[H], results: SignalQueuePtr[?!CircomProof]
) =
let circom = args[].circom
let data = args[].data
let proof = circom.prove(data)
if (let sent = results.send(proof); sent.isErr()):
@ -34,12 +44,17 @@ proc prove*[H](
without queue =? newSignalQueue[?!CircomProof](maxItems = 1), qerr:
return failure(qerr)
var args = (ref ProverArgs[H])(circom: self.circom, data: input)
GC_ref(args)
proc spawnTask() =
self.tp.spawn proveTask(self.circom, input, queue)
self.tp.spawn proveTask(args[].addr, queue)
spawnTask()
let taskRes = await queue.recvAsync()
GC_unref(args)
if (let res = queue.release(); res.isErr):
error "Error releasing proof queue ", msg = res.error().msg
without proofRes =? taskRes, perr: