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

ames: count unsent messages for backpressure

Browse Source
This commit is contained in:
Philip Monk 2019-11-27 15:58:38 -08:00
parent 74b0f66850
commit fc74ab2dbd
No known key found for this signature in database
GPG Key ID: B66E1F02604E44EC
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1662,7 +1662,16 @@
|- ^- ?
?~ pumps
%.n
=. acc (add acc (sub [next current]:i.pumps))
=. acc
%+ add acc
%+ add
:: in-flight messages
::
(sub [next current]:i.pumps)
:: queued messages
::
~(wyt in unsent-messages.i.pumps)
::
?: (gte acc 5)
%.y
$(pumps t.pumps)