urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2024-12-01 22:55:03 +03:00
Code Issues Packages Projects Releases Wiki Activity

basic vane ack handling

Browse Source
This commit is contained in:
Ted Blackman 2019-06-10 17:31:50 -07:00
parent 1c769b52e9
commit 34efa7f028
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
sys/vane/alef.hoon
View File

@ -652,13 +652,13 @@
==
:: $message-still-task: job for |message-still
::
:: %hear: handle receiving a message fragment packet
:: %done: receive confirmation from vane of processing completion or
:: failure with diagnostic
:: %hear: handle receiving a message fragment packet
::
+$ message-still-task
$% [%hear =lane =shut-packet]
[%done =message-num error=(unit error)]
$% [%done error=(unit error)]
[%hear =lane =shut-packet]
==
:: $message-still-gift: effect from |message-still
::
@ -1573,8 +1573,8 @@
=- [(flop gifts) state]
::
?- -.task
%done (on-done error.task)
%hear (on-hear [lane shut-packet]:task)
%done (on-done [message-num error]:task)
==
::
::
@ -1686,13 +1686,20 @@
?. empty
message-still
(give %hear-message message)
::
:: +on-done: handle confirmation of message processing from vane
::
++ on-done
|= [=message-num error=(unit error)]
|= error=(unit error)
^+ message-still
::
!!
=^ pending pending-vane-ack.state ~(get to pending-vane-ack.state)
=. last-acked.state +(last-acked.state)
=/ =message-num message-num.p.pending
:: TODO nacks, naxplanations
::
?~ error
(give %send-ack message-num %| ok=%.y lag=`@dr`0)
(give %send-ack message-num %| ok=%.n lag=`@dr`0)
--
:: +assemble-fragments: concatenate fragments into a $message
::