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

fixed kick messages

Browse Source
This commit is contained in:
dachus 2023-02-08 13:47:43 -05:00
parent 54d655aeda
commit c377008f62
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/arvo/sys/vane/eyre.hoon
View File

@ -1605,14 +1605,17 @@
=/ num=@ud =/ num=@ud
(~(gut by unacked.u.channel) request-id 0) (~(gut by unacked.u.channel) request-id 0)
:_ (~(put by unacked.u.channel) request-id +(num)) :_ (~(put by unacked.u.channel) request-id +(num))
?: ?& (gte num clog-threshold) ?& (gte num clog-threshold)
(lth (add last-ack.u.channel clog-timeout) now) (lth (add last-ack.u.channel clog-timeout) now)
== ==
((trace 1 |.("eyre: clogged {<channel-id>} {<request-id>}")) &) |
:: if we're clogged, or we ran into an event we can't serialize, :: if we're clogged, or we ran into an event we can't serialize,
:: kill this gall subscription. :: kill this gall subscription.
:: ::
=/ kicking=? |(clogged ?=(~ json)) =/ kicking=?
?: clogged
((trace 1 |.("clogged {<channel-id>} {<request-id>}")) &)
?: ?=(~ json)
((trace 1 |.("can't serialize event, kicking")) &) |
=? moves kicking =? moves kicking
:_ moves :_ moves
::NOTE this shouldn't crash because we ::NOTE this shouldn't crash because we