2024-05-16 21:12:38 +03:00
|
|
|
|
|
|
|
|
import std/sequtils
|
|
|
|
|
|
|
|
|
|
import pkg/taskpools
|
|
|
|
|
import pkg/taskpools/flowvars
|
|
|
|
|
import pkg/chronos
|
|
|
|
|
import pkg/chronos/threadsync
|
|
|
|
|
import pkg/questionable/results
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const
|
|
|
|
|
CompletitionTimeout = 1.seconds # Maximum await time for completition after receiving a signal
|
|
|
|
|
CompletitionRetryDelay = 10.millis
|
|
|
|
|
|
|
|
|
|
type
|
2024-05-16 21:35:24 +03:00
|
|
|
AsyncCircomCompat* = object
|
|
|
|
|
params*: CircomCompatParams
|
2024-05-16 21:12:38 +03:00
|
|
|
|
|
|
|
|
# Args objects are missing seq[seq[byte]] field, to avoid unnecessary data copy
|
|
|
|
|
EncodeTaskArgs = object
|
|
|
|
|
signal: ThreadSignalPtr
|
|
|
|
|
backend: EncoderBackendPtr
|
|
|
|
|
blockSize: int
|
|
|
|
|
ecM: int
|
2024-05-16 21:35:24 +03:00
|
|
|
|
|
|
|
|
proc prove*[H](
|
|
|
|
|
self: CircomCompat,
|
|
|
|
|
input: ProofInputs[H]): ?!CircomProof =
|
