status-im/nim-codex
2
0
Fork 0
mirror of https://github.com/status-im/nim-codex.git synced 2025-02-20 06:28:55 +00:00
Code Issues Projects Releases Wiki Activity

work around windows - no without

Browse Source
This commit is contained in:
Jaremy Creechley 2024-05-20 21:15:34 +03:00
parent 26809823ed
commit 9dcf56b5f5
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -30,9 +30,10 @@ proc prove*[H](
self: AsyncCircomCompat, input: ProofInputs[H] self: AsyncCircomCompat, input: ProofInputs[H]
): Future[?!CircomProof] {.async.} = ): Future[?!CircomProof] {.async.} =
## Generates proof using circom-compat asynchronously ## Generates proof using circom-compat asynchronously
## let queueRes = newSignalQueue[?!CircomProof](maxItems = 1)
without queue =? newSignalQueue[?!CircomProof](maxItems = 1), err: if queueRes.isErr:
return (?!CircomProof).err(err) return failure queueRes.error()
let queue = queueRes.get()
proc spawnTask() = proc spawnTask() =
self.tp.spawn proveTask(self.circom, input, queue) self.tp.spawn proveTask(self.circom, input, queue)
@ -83,7 +84,9 @@ proc verify*[H](
success(verified) success(verified)
proc init*(_: type AsyncCircomCompat, params: CircomCompatParams, tp: Taskpool): AsyncCircomCompat = proc init*(
_: type AsyncCircomCompat, params: CircomCompatParams, tp: Taskpool
): AsyncCircomCompat =
## Create a new async circom ## Create a new async circom
## ##
let circom = CircomCompat.init(params) let circom = CircomCompat.init(params)

3
codex/utils/asyncthreads.nim
View File

@ -35,8 +35,7 @@ proc newSignalQueue*[T](
let queue = cast[ptr SignalQueue[T]](allocShared0(sizeof(SignalQueue[T]))) let queue = cast[ptr SignalQueue[T]](allocShared0(sizeof(SignalQueue[T])))
let sigRes = ThreadSignalPtr.new() let sigRes = ThreadSignalPtr.new()
if sigRes.isErr(): if sigRes.isErr():
let msg: string = sigRes.error() return failure((ref CatchableError)(msg: sigRes.error()))
return failure((ref CatchableError)(msg: msg))
else: else:
queue[].signal = sigRes.get() queue[].signal = sigRes.get()
queue[].chan.open(maxItems) queue[].chan.open(maxItems)