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

gall: add %cork to remote-request action

Browse Source
This commit is contained in:
yosoyubik 2022-04-05 04:41:03 +02:00
parent 0a96d69785
commit c380cf3f42
1 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -111,6 +111,7 @@
%poke %poke
%leave %leave
%missing %missing
%cork
== ==
:: |migrate: data structures for upgrades :: |migrate: data structures for upgrades
:: ::
@ -508,10 +509,11 @@
=. outstanding.state =. outstanding.state
=/ stand =/ stand
(~(gut by outstanding.state) [wire hen] *(qeu remote-request)) (~(gut by outstanding.state) [wire hen] *(qeu remote-request))
(~(put by outstanding.state) [wire hen] (~(put to stand) -.deal)) %+ ~(put by outstanding.state) [wire hen]
?. ?=(%leave -.deal) (~(gas to stand) ?.(?=(%leave -.deal) ~[-.deal] ~[%leave %cork]))
(mo-pass wire note-arvo)
=. mo-core (mo-pass wire note-arvo) =. mo-core (mo-pass wire note-arvo)
?. ?=(%leave -.deal)
mo-core
(mo-pass wire [%a [%cork ship]]) (mo-pass wire [%a [%cork ship]])
:: +mo-track-ship: subscribe to ames and jael for notices about .ship :: +mo-track-ship: subscribe to ames and jael for notices about .ship
:: ::
@ -734,7 +736,12 @@
(~(put to *(qeu remote-request)) %missing) (~(put to *(qeu remote-request)) %missing)
~| [full-wire=full-wire hen=hen stand=stand] ~| [full-wire=full-wire hen=hen stand=stand]
=^ rr stand ~(get to stand) =^ rr stand ~(get to stand)
[rr (~(put by outstanding.state) [full-wire hen] stand)] ~? &(=(rr %cork) ?=(^ stand))
[%outstanding-queue-not-empty wire hen]
:- rr
?: ?=(%cork rr)
(~(del by outstanding.state) [full-wire hen])
(~(put by outstanding.state) [full-wire hen] stand)
:: non-null case of wire is old, remove on next breach after :: non-null case of wire is old, remove on next breach after
:: 2019/12 :: 2019/12
:: ::
@ -750,6 +757,7 @@
%watch (mo-give %unto %watch-ack err) %watch (mo-give %unto %watch-ack err)
%poke (mo-give %unto %poke-ack err) %poke (mo-give %unto %poke-ack err)
%leave mo-core %leave mo-core
%cork mo-core
%missing (mo-give:(mo-give %unto %watch-ack err) %unto %poke-ack err) %missing (mo-give:(mo-give %unto %watch-ack err) %unto %poke-ack err)
== ==
:: ::
@ -1756,13 +1764,10 @@
=/ sub-wire=^wire (slag 6 `^wire`wire) =/ sub-wire=^wire (slag 6 `^wire`wire)
:: ::
?. (~(has by outbound.watches.yoke) sub-wire dock) ?. (~(has by outbound.watches.yoke) sub-wire dock)
=. ap-core =; =tang
=/ =tang %- (slog tang)
:~ leaf+"got %leave for missing subscription" $(moves t.moves)
>agent-name< >sub-wire< >dock< [leaf+"gall: {<agent-name>} missing subscription, got %leave"]~
==
(ap-error %leave-missing-subscription tang)
$(moves t.moves)
=/ have=[acked=? =path nonce=@] =/ have=[acked=? =path nonce=@]
(~(got by outbound.watches.yoke) sub-wire dock) (~(got by outbound.watches.yoke) sub-wire dock)
=. p.move.move =. p.move.move