ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-12-15 18:12:47 +03:00
Code Issues Packages Projects Releases Wiki Activity

don't back off on skipped packet

Browse Source
This commit is contained in:
Ted Blackman 2019-08-28 18:30:31 -07:00
parent 99b98ca744
commit 72b2dbe19e
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bin/solid.pill
View File

@ -1,3 +1,3 @@
version https://git-lfs.github.com/spec/v1 version https://git-lfs.github.com/spec/v1
oid sha256:2e36bab49d8c7829d373037bba00dc67785024d45cfc73bec70104917ec9fa40 oid sha256:81cbdadd4bca830243762c097a7c85c24b8b7dc2b5b02e38448f2aafac925cbf
size 13236816 size 13237282

6
pkg/arvo/sys/vane/alef.hoon
View File

@ -2179,6 +2179,7 @@
:: ::
|- ^+ packet-pump |- ^+ packet-pump
?~ sent packet-pump ?~ sent packet-pump
~& %sent^[message-num fragment-num]:i.sent
=. packet-pump (give %send i.sent) =. packet-pump (give %send i.sent)
$(sent t.sent) $(sent t.sent)
:: +on-hear: handle ack on a live packet :: +on-hear: handle ack on a live packet
@ -2351,7 +2352,6 @@
~& %skipped^skipped ~& %skipped^skipped
%_ metrics %_ metrics
skipped 0 skipped 0
max-live (max 1 (div max-live 2))
== ==
:: ::
%_ metrics %_ metrics
@ -2450,7 +2450,7 @@
message-still message-still
:: ack all other packets :: ack all other packets
:: ::
::~& %send-ack^seq^fragment-num ~& %send-ack^seq^fragment-num
(give %send seq %& fragment-num) (give %send seq %& fragment-num)
:: last-heard<seq<10+last-heard; this is a packet in a live message :: last-heard<seq<10+last-heard; this is a packet in a live message
:: ::
@ -2489,7 +2489,7 @@
:: ack any packet other than the last one, and continue either way :: ack any packet other than the last one, and continue either way
:: ::
=? message-still !is-last-fragment =? message-still !is-last-fragment
::~& %send-ack^seq^fragment-num ~& %send-ack^seq^fragment-num
(give %send seq %& fragment-num) (give %send seq %& fragment-num)
:: enqueue all completed messages starting at +(last-heard.state) :: enqueue all completed messages starting at +(last-heard.state)
:: ::