From 143febc21578506ed39f5e2577adbfd574ab15d5 Mon Sep 17 00:00:00 2001 From: Emery Hemingway Date: Sat, 23 Apr 2022 17:59:56 -0500 Subject: [PATCH] Tidy up connectUnix bootProc --- src/syndicate/relays.nim | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/syndicate/relays.nim b/src/syndicate/relays.nim index 281615d..cef4b05 100644 --- a/src/syndicate/relays.nim +++ b/src/syndicate/relays.nim @@ -287,7 +287,7 @@ method retract(e: ShutdownEntity; turn: var Turn; h: Handle) = type SturdyRef = sturdy.SturdyRef[Ref] Resolve = gatekeeper.Resolve[Ref] - ConnectProc* = proc (turn: var Turn; a: Assertion): TurnAction {.gcsafe.} + ConnectProc* = proc (turn: var Turn; ds: Ref) {.gcsafe.} proc connectUnix*(turn: var Turn; path: string; cap: SturdyRef; bootProc: ConnectProc) = var socket = newAsyncSocket( @@ -335,9 +335,9 @@ proc connectUnix*(turn: var Turn; path: string; cap: SturdyRef; bootProc: Connec run(gatekeeper.relay) do (turn: var Turn): reenable() discard publish(turn, shutdownRef, true) - proc duringCallback(turn: var Turn; ds: Assertion; h: Handle): TurnAction = + proc duringCallback(turn: var Turn; a: Assertion; h: Handle): TurnAction = let facet = facet(turn) do (turn: var Turn): - discard bootProc(turn, ds) # TODO: what to do with this? + bootProc(turn, unembed a) proc action(turn: var Turn) = stop(turn, facet) result = action