From 9a94c35d4d3ebc5d94c50e7826e3500415855adc Mon Sep 17 00:00:00 2001 From: Philip Monk Date: Tue, 26 Nov 2019 18:18:44 -0800 Subject: [PATCH] gall: acutally delete outgoing on watch-ack --- pkg/arvo/sys/vane/gall.hoon | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/arvo/sys/vane/gall.hoon b/pkg/arvo/sys/vane/gall.hoon index c081f8f2e..79341eb40 100644 --- a/pkg/arvo/sys/vane/gall.hoon +++ b/pkg/arvo/sys/vane/gall.hoon @@ -567,7 +567,7 @@ %watch-ack =/ err=(unit error:ames) ?~ p.sign ~ - `[%reap u.p.sign] + `[%watch-ack u.p.sign] (mo-give %done err) == :: +mo-handle-sys-val: inbound validate. @@ -1206,7 +1206,7 @@ =? outgoing.subscribers.current-agent ?=(%watch-ack -.sign) ?^ p.sign %- ~(del by outgoing.subscribers.current-agent) - [wire dock] + [agent-wire dock] %+ ~(jab by outgoing.subscribers.current-agent) [agent-wire dock] |= [acked=? =path] ~| [%already-acked agent-name wire dock path] @@ -1422,7 +1422,7 @@ =/ =tang ~[leaf+"subscribe wire not unique" >agent-name< >short-wire< >dock<] %- (slog >out=outgoing.subscribers.current-agent< tang) - (ap-specific-take way %watch-ack `tang) + (ap-error %watch-not-unique tang) $(moves t.moves) =. outgoing.subscribers.current-agent (~(put by outgoing.subscribers.current-agent) [short-wire dock] [| path])