ames, gall: cork flow if getting %nack for %watch

This commit is contained in:
yosoyubik 2022-11-21 14:23:19 +01:00
parent 2027907db5
commit 430233a3de
2 changed files with 14 additions and 0 deletions

View File

@ -2764,6 +2764,14 @@
::
(emit [/ames]~ %pass wire %b %rest next-wake)
=/ nax-bone=^bone (mix 0b10 bone)
%- %+ trace odd.veb
=/ dat [her.channel bone=nax-bone message-num=message-num -.task]
|.("remove naxplanation flow {<dat>}")
=. snd.peer-state
:: unconditionally delete possible naxplanation flows that
:: could have been sent (e.g. nacks for initial subscriptions)
::
(~(del by snd.peer-state) nax-bone)
=. peer-state
=, peer-state
%_ peer-state

View File

@ -838,6 +838,12 @@
?~ error=error.sign-arvo
~
`[[%leaf (trip tag.u.error)] tang.u.error]
:: send a %cork if we get a nack upon initial subscription
::
=? mo-core ?& ?=(^ err)
|(?=(%watch-as remote-request) ?=(%watch remote-request))
==
(mo-pass [%sys wire] %a %cork ship)
::
?- remote-request
%watch-as (mo-give %unto %watch-ack err)