From c377008f62e022b3a4ca8b335b74fc67f0b1c833 Mon Sep 17 00:00:00 2001 From: dachus Date: Wed, 8 Feb 2023 13:47:43 -0500 Subject: [PATCH] fixed kick messages --- pkg/arvo/sys/vane/eyre.hoon | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/pkg/arvo/sys/vane/eyre.hoon b/pkg/arvo/sys/vane/eyre.hoon index 5bba29d22..3963f6245 100644 --- a/pkg/arvo/sys/vane/eyre.hoon +++ b/pkg/arvo/sys/vane/eyre.hoon @@ -1605,14 +1605,17 @@ =/ num=@ud (~(gut by unacked.u.channel) request-id 0) :_ (~(put by unacked.u.channel) request-id +(num)) - ?: ?& (gte num clog-threshold) - (lth (add last-ack.u.channel clog-timeout) now) - == - ((trace 1 |.("eyre: clogged {} {}")) &) | + ?& (gte num clog-threshold) + (lth (add last-ack.u.channel clog-timeout) now) + == :: if we're clogged, or we ran into an event we can't serialize, :: kill this gall subscription. :: - =/ kicking=? |(clogged ?=(~ json)) + =/ kicking=? + ?: clogged + ((trace 1 |.("clogged {} {}")) &) + ?: ?=(~ json) + ((trace 1 |.("can't serialize event, kicking")) &) | =? moves kicking :_ moves ::NOTE this shouldn't crash because we