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

gall: acutally delete outgoing on watch-ack

Browse Source
This commit is contained in:
Philip Monk 2019-11-26 18:18:44 -08:00
parent c7252bce85
commit 9a94c35d4d
No known key found for this signature in database
GPG Key ID: B66E1F02604E44EC
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/arvo/sys/vane/gall.hoon
View File

@ -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])