fixup! Use binary Preserves over Unix sockets

This commit is contained in:
Emery Hemingway 2022-10-16 15:41:28 -05:00
parent e9133f823b
commit 0231e31b76
2 changed files with 2 additions and 3 deletions

View File

@ -318,12 +318,12 @@ proc connectUnix*(turn: var Turn; path: string; cap: SturdyRef; bootProc: Connec
run(facet) do (turn: var Turn): stopActor(turn)
else:
if wireBuf.len == 0: wireBuf = move buf
else: wireBuf.add(buf)
else: wireBuf.add(move buf)
try:
var pr = decodePreserves(wireBuf, WireRef)
dispatch(relay, cast[Preserve[WireRef]](pr))
wireBuf.setLen(0)
except ValueError: discard
except IOError, ValueError: discard
socket.recv(recvSize).addCallback(recvCb)
# TODO: should this need be callSoon?
socket.recv(recvSize).addCallback(recvCb)

View File

@ -49,6 +49,5 @@ bootDataspace("main") do (root: Ref; turn: var Turn):
sendLine(turn)
do:
lineElements.excl a
sendLine(turn)
runForever()