try queue setup

This commit is contained in:
Jaremy Creechley 2024-05-20 17:33:41 +03:00
parent 13c59ca575
commit f603b642a2
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 3 additions and 3 deletions

View File

@ -12,13 +12,13 @@ import ../../../utils/asyncthreads
import ./circomcompat import ./circomcompat
type AsyncCircomCompat* = object type AsyncCircomCompat* = object
params*: CircomCompatParams circom*: CircomCompat
tp*: Taskpool tp*: Taskpool
var circomBackend {.threadvar.}: Option[CircomCompat] var circomBackend {.threadvar.}: Option[CircomCompat]
proc proveTask[H]( proc proveTask[H](
params: CircomCompatParams, params: CircomCompat,
data: ProofInputs[H], data: ProofInputs[H],
results: SignalQueuePtr[Result[CircomProof, string]], results: SignalQueuePtr[Result[CircomProof, string]],
) = ) =
@ -43,7 +43,7 @@ proc prove*[H](
return failure(err) return failure(err)
proc spawnTask() = proc spawnTask() =
self.tp.spawn proveTask(self.params, input, queue) self.tp.spawn proveTask(self.circom, input, queue)
spawnTask() spawnTask()