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

ames: skip corks if pending acks for naxplanations

Browse Source
This commit is contained in:
yosoyubik 2023-05-24 12:35:38 +02:00
parent 2f16a3b1b1
commit f6101569f5
1 changed files with 40 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
pkg/arvo/sys/vane/ames.hoon
View File

@ -3775,19 +3775,50 @@
%done (done ok.task) %done (done ok.task)
:: ::
%hear %hear
?. ?| corked |^ ?: ?| corked
?& %*(corked sink bone (mix 0b10 bone)) ?& %*(corked sink bone (mix 0b10 bone))
=(%nack (received bone)) =(%nack (received bone))
== == == ==
(hear [lane shut-packet ok]:task) ack-on-corked-bone
:: if we %hear a task on a corked bone, always ack
:: ::
=. peer-core ?> ?=(%& -.meat.shut-packet.task)
%+ send-shut-packet bone =+ [num-fragments fragment-num fragment]=+.meat.shut-packet.task
[message-num.shut-packet.task %| %| ok=& lag=*@dr] ?. &(=(num-fragments 1) =(fragment-num 0))
%. sink (hear [lane shut-packet ok]:task)
%+ pe-trace odd.veb (check-pending-acks fragment-num num-fragments fragment)
|.("hear {<(received bone)>} on corked bone={<bone>}") ::
++ ack-on-corked-bone
:: if we %hear a fragment on a corked bone, always ack
::
=. peer-core
%+ send-shut-packet bone
[message-num.shut-packet.task %| %| ok=& lag=*@dr]
%. sink
%+ pe-trace odd.veb
|.("hear {<(received bone)>} on corked bone={<bone>}")
::
++ check-pending-acks
:: if this is a %cork %plea and are still waiting to
:: hear %acks for previous naxplanation we sent, no-op
::
|= [num=@ud frags=@ud frag=@uw]
^+ sink
=/ message-blob=*
%+ assemble-fragments frags
(~(gas by *(map fragment-num fragment)) [num frag]~)
=/ cork-plea=?
?=(^ ;;((soft [%$ path %cork ~]) message-blob))
=/ pending-ack=?
=/ nax-bone=^bone (mix 0b10 bone)
=/ live-packets=@ud
~(wyt by live.packet-pump-state.state:(abed:mu nax-bone))
(gth live-packets 0)
?. &(cork-plea pending-ack)
(hear [lane shut-packet ok]:task)
%. sink
%+ pe-trace odd.veb
|.("pending ack for naxplanation, skip %cork bone={<bone>}")
--
== ==
:: ::
+| %tasks +| %tasks