codex-storage
/
nim-codex
mirror of https://github.com/codex-storage/nim-codex.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

More gcsafe pragma

This commit is contained in:
Arnaud 2024-12-18 16:47:54 +01:00
parent a1c8c94ada
commit 599e868bc1
No known key found for this signature in database
GPG Key ID: 69D6CE281FCAE663
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
codex/utils/asyncstatemachine.nim
View File

@ -25,7 +25,7 @@ logScope:
proc new*[T: Machine](_: type T): T = proc new*[T: Machine](_: type T): T =
T(trackedFutures: TrackedFutures.new()) T(trackedFutures: TrackedFutures.new())
method `$`*(state: State): string {.base.} = method `$`*(state: State): string {.base, gcsafe.} =
raiseAssert "not implemented" raiseAssert "not implemented"
proc transition(_: type Event, previous, next: State): Event = proc transition(_: type Event, previous, next: State): Event =
@ -62,7 +62,7 @@ proc run(machine: Machine, state: State) {.async.} =
if next =? await state.run(machine): if next =? await state.run(machine):
machine.schedule(Event.transition(state, next)) machine.schedule(Event.transition(state, next))
proc scheduler(machine: Machine) {.async.} = proc scheduler(machine: Machine) {.async, gcsafe.} =
var running: Future[void] var running: Future[void]
while machine.started: while machine.started:
let event = await machine.scheduled.get().track(machine) let event = await machine.scheduled.get().track(machine)
@ -74,13 +74,15 @@ proc scheduler(machine: Machine) {.async.} =
machine.state = next machine.state = next
debug "enter state", state = fromState & " => " & $machine.state debug "enter state", state = fromState & " => " & $machine.state
running = machine.run(machine.state) running = machine.run(machine.state)
proc catchError(err: ref CatchableError) {.gcsafe.} =
trace "error caught in state.run, calling state.onError", state = $machine.state
machine.schedule(machine.onError(err))
running running
.track(machine) .track(machine)
.cancelled(proc() = trace "state.run cancelled, swallowing", state = $machine.state) .cancelled(proc() = trace "state.run cancelled, swallowing", state = $machine.state)
.catch(proc(err: ref CatchableError) = .catch(catchError)
trace "error caught in state.run, calling state.onError", state = $machine.state
machine.schedule(machine.onError(err))
)
proc start*(machine: Machine, initialState: State) = proc start*(machine: Machine, initialState: State) =
if machine.started: if machine.started: