ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-12-14 17:41:33 +03:00
Code Issues Packages Projects Releases Wiki Activity

gall: miscellaneous formatting fixes

Browse Source
This commit is contained in:
Jared Tobin 2019-08-14 04:57:51 -07:00
parent 97de72d2ce
commit 575aeb3b2e
No known key found for this signature in database
GPG Key ID: 0E4647D58F8A69E4
1 changed files with 169 additions and 178 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -6,8 +6,6 @@
=, gall =, gall
=> =~ => =~
:: ::
:: (rest of arvo)
::
|% |%
:: ::
:: +internal-gift: synonym for +cuft. :: +internal-gift: synonym for +cuft.
@ -41,8 +39,7 @@
:: +reverse-ames: reverse ames message. :: +reverse-ames: reverse ames message.
:: ::
++ reverse-ames ++ reverse-ames
$% $% :: diff
:: diff
:: ::
[action=%d p=mark q=*] [action=%d p=mark q=*]
:: etc. :: etc.
@ -53,16 +50,15 @@
:: +forward-ames: forward ames message. :: +forward-ames: forward ames message.
:: ::
++ forward-ames ++ forward-ames
$% $% :: message
:: message
:: ::
[action=%m mark=mark noun=*] [action=%m =mark noun=*]
:: "peel" subscribe :: "peel" subscribe
:: ::
[action=%l mark=mark path=path] [action=%l =mark =path]
:: subscribe :: subscribe
:: ::
[action=%s path=path] [action=%s =path]
:: cancel+unsubscribe :: cancel+unsubscribe
:: ::
[action=%u ~] [action=%u ~]
@ -78,8 +74,6 @@
== ==
-- --
:: ::
:: (local arvo)
::
|% |%
:: ::
:: +internal-note: +ap note. :: +internal-note: +ap note.
@ -95,9 +89,8 @@
:: duct. :: duct.
:: ::
++ internal-move ++ internal-move
$: $: =bone
=bone move=(wind internal-note internal-gift)
move=(wind internal-note internal-gift)
== ==
:: ::
:: +move: Arvo-level move. :: +move: Arvo-level move.
@ -105,8 +98,6 @@
++ move (pair duct (wind note-arvo gift-arvo)) ++ move (pair duct (wind note-arvo gift-arvo))
-- --
:: ::
:: (%gall state)
::
|% |%
:: ::
:: +gall-old: upgrade path. :: +gall-old: upgrade path.
@ -116,8 +107,7 @@
:: +gall: all state. :: +gall: all state.
:: ::
++ gall ++ gall
$: $: :: state version
:: state version
:: ::
%0 %0
:: agents by ship :: agents by ship
@ -128,8 +118,7 @@
:: +subscribers: subscriber data. :: +subscribers: subscriber data.
:: ::
++ subscribers ++ subscribers
$: $: :: incoming subscribers
:: incoming subscribers
:: ::
incoming=bitt incoming=bitt
:: outgoing subscribers :: outgoing subscribers
@ -143,8 +132,7 @@
:: +agents: ship state. :: +agents: ship state.
:: ::
++ agents ++ agents
$: $: :: (deprecated)
:: (deprecated)
:: ::
mak=* mak=*
:: system duct :: system duct
@ -164,32 +152,29 @@
:: +routes: new cuff. :: +routes: new cuff.
:: ::
++ routes ++ routes
$: $: :: disclosing to
:: disclosing to ::
:: disclosing=(unit (set ship))
disclosing=(unit (set ship)) :: attributed to
:: attributed to ::
:: attributing=ship
attributing=ship ==
==
:: ::
:: +privilege: privilege. :: +privilege: privilege.
:: ::
++ privilege ++ privilege
$: $: :: voltage
:: voltage ::
:: =volt
=volt :: routes
:: routes ::
:: =routes
=routes ==
==
:: ::
:: +foreign: foreign connections. :: +foreign: foreign connections.
:: ::
++ foreign ++ foreign
$: $: :: index
:: index
:: ::
index=@ud index=@ud
:: by duct :: by duct
@ -203,8 +188,7 @@
:: +ducts: opaque input. :: +ducts: opaque input.
:: ::
++ ducts ++ ducts
$: $: :: bone sequence
:: bone sequence
:: ::
bone=@ud bone=@ud
:: by duct :: by duct
@ -226,8 +210,7 @@
:: +agent: agent state. :: +agent: agent state.
:: ::
++ agent ++ agent
$: $: :: bad reqs
:: bad reqs
:: ::
misvale=misvale-data misvale=misvale-data
:: cache :: cache
@ -247,22 +230,22 @@
privilege=security-control privilege=security-control
:: statistics :: statistics
:: ::
stats=stats =stats
:: subscribers :: subscribers
:: ::
subscribers=subscribers =subscribers
:: running state :: running state
:: ::
running-state=vase running-state=vase
:: update control :: update control
:: ::
beak=beak =beak
:: req'd translations :: req'd translations
:: ::
marks=(map bone mark) marks=(map bone mark)
:: opaque ducts :: opaque ducts
:: ::
ducts=ducts =ducts
== ==
:: ::
:: +blocked: blocked tasks. :: +blocked: blocked tasks.
@ -272,8 +255,7 @@
:: +stats: statistics. :: +stats: statistics.
:: ::
++ stats ++ stats
$: $: :: change number
:: change number
:: ::
change=@ud change=@ud
:: entropy :: entropy
@ -285,15 +267,10 @@
== ==
-- --
:: ::
:: (vane header)
::
. == . ==
:: ::
:: (all vane state)
::
=| =gall =| =gall
|= $: |= $: :: identity
:: identity
:: ::
our=ship our=ship
:: urban time :: urban time
@ -307,12 +284,8 @@
ska=sley ska=sley
== ==
:: ::
:: (opaque core)
::
~% %gall-top ..is ~ ~% %gall-top ..is ~
:: ::
:: (state machine)
::
|% |%
:: ::
:: +gall-payload: gall payload. :: +gall-payload: gall payload.
@ -328,9 +301,8 @@
~% %gall-mo +> ~ ~% %gall-mo +> ~
:: ::
|_ |_
$: $: hen=duct
hen=duct moves=(list move)
moves=(list move)
== ==
:: ::
++ mo-state . ++ mo-state .
@ -371,7 +343,7 @@
=/ pass [path note-arvo] =/ pass [path note-arvo]
(mo-pass pass) (mo-pass pass)
:: ::
:: +mo-pass: prepend a standard %pass move to the current list of moves. :: +mo-pass: prepend a standard %pass to the current list of moves.
:: ::
++ mo-pass ++ mo-pass
|= pass=(pair path note-arvo) |= pass=(pair path note-arvo)
@ -380,7 +352,7 @@
=/ =move [hen [%pass pass]] =/ =move [hen [%pass pass]]
mo-state(moves [move moves]) mo-state(moves [move moves])
:: ::
:: +mo-give: prepend a standard %give move to the current list of moves. :: +mo-give: prepend a standard %give to the current list of moves.
:: ::
++ mo-give ++ mo-give
|= =gift:able |= =gift:able
@ -391,9 +363,6 @@
:: ::
:: +mo-contains-valid-bowl: check that a vase contains a valid bowl. :: +mo-contains-valid-bowl: check that a vase contains a valid bowl.
:: ::
:: The vase is expected to contain a bowl at +12, so we just check that the
:: type of the thing there nests under that of bowl.
::
++ mo-contains-valid-bowl ++ mo-contains-valid-bowl
~/ %mo-contains-valid-bowl ~/ %mo-contains-valid-bowl
|= =vase |= =vase
@ -412,10 +381,10 @@
:: Presuming we receive a good core, we first check to see if the agent :: Presuming we receive a good core, we first check to see if the agent
:: is already running. If so, we update its beak in %gall's state, :: is already running. If so, we update its beak in %gall's state,
:: initialise an +ap core for the agent, install the core we got from :: initialise an +ap core for the agent, install the core we got from
:: ford, and then resolve any moves associated with it. :: %ford, and then resolve any moves associated with it.
:: ::
:: If we're dealing with a new agent, we create one using the result we got :: If we're dealing with a new agent, we create one using the result we got
:: from ford, add it to the collection of agents %gall is keeping track of, :: from %ford, add it to the collection of agents %gall is keeping track of,
:: and then do more or less the same procedure as we did for the running :: and then do more or less the same procedure as we did for the running
:: agent case. :: agent case.
:: ::
@ -481,7 +450,7 @@
:: ::
:: +mo-new-agent: create a new agent and add it to %gall's state. :: +mo-new-agent: create a new agent and add it to %gall's state.
:: ::
:: %gall maintains a collection of running agents. This gate creates a :: %gall maintains a collection of running agents. This arm creates a
:: new one with the provided name, beak, and state (held in a vase). :: new one with the provided name, beak, and state (held in a vase).
:: ::
++ mo-new-agent ++ mo-new-agent
@ -583,7 +552,7 @@
%pull mo-state %pull mo-state
== ==
:: ::
:: +mo-assign-bone: assign an out bone to a ship. :: +mo-assign-bone: assign an outbone to a ship.
:: ::
:: If we know about the ship, we simply use its existing bone. Otherwise :: If we know about the ship, we simply use its existing bone. Otherwise
:: we register a new entry for the ship, and use a default bone for it. :: we register a new entry for the ship, and use a default bone for it.
@ -626,7 +595,7 @@
:: ::
:: +mo-handle-sys: handle a +sign incoming over /sys. :: +mo-handle-sys: handle a +sign incoming over /sys.
:: ::
:: Note that /sys implies the +sign should be routed to a vane. :: (Note that /sys implies the +sign should be routed to a vane.)
:: ::
++ mo-handle-sys ++ mo-handle-sys
~/ %mo-handle-sys ~/ %mo-handle-sys
@ -688,8 +657,8 @@
:: ::
:: +mo-handle-sys-red: diff ack. :: +mo-handle-sys-red: diff ack.
:: ::
:: On receipt of a valid +sign from %ames, it simply passes a %pump :: On receipt of a valid +sign from %ames, we simply pass a %pump
:: acknowledgement internally; otherwise it passes both an internal :: acknowledgement internally; otherwise we pass both an internal
:: unsubscribing %pull, plus a %want to %ames, before complaining about a :: unsubscribing %pull, plus a %want to %ames, before complaining about a
:: bad message acknowledgment. :: bad message acknowledgment.
:: ::
@ -904,7 +873,7 @@
:: ::
:: +mo-handle-use: handle a typed +sign incoming on /use. :: +mo-handle-use: handle a typed +sign incoming on /use.
:: ::
:: Note that /use implies the +sign should be routed to an agent. :: (Note that /use implies the +sign should be routed to an agent.)
:: ::
:: Initialises the specified agent and then performs an agent-level +take on :: Initialises the specified agent and then performs an agent-level +take on
:: the supplied +sign. :: the supplied +sign.
@ -1000,15 +969,15 @@
|= =term |= =term
^- beak ^- beak
:: ::
?~ app-data=(~(get by running.agents.gall) term) ?~ running=(~(get by running.agents.gall) term)
:: ::
:: XX this fallback is necessary, as .term could be either the source :: XX this fallback is necessary, as .term could be either the source
:: or the destination app. ie, it might not exist locally ... :: or the destination app. ie, it might not exist locally ...
:: ::
[our %home %da now] [our %home %da now]
beak.u.app-data beak.u.running
:: ::
:: Simply calls to +ap-peek, which is not accessible from outside of +mo. :: +mo-peek: call to +ap-peek (which is not accessible outside of +mo).
:: ::
++ mo-peek ++ mo-peek
~/ %mo-peek ~/ %mo-peek
@ -1172,6 +1141,9 @@
:: ::
:: +ap: agent engine :: +ap: agent engine
:: ::
:: An inner, agent-level core. The sample refers to the agent we're
:: currently focused on.
::
++ ap ++ ap
~% %gall-ap +> ~ ~% %gall-ap +> ~
:: ::
@ -1245,15 +1217,6 @@
:: ::
:: +ap-track-queue: track queue. :: +ap-track-queue: track queue.
:: ::
:: An agent, at any given time, may have some so-called internal moves
:: associated with it.
::
:: If there are any currently-associated non-%give internal moves, we
:: enqueue each along its associated bone. When we've finished enqueuing
:: them, we iterate over the relevant bones and
::
:: FIXME finish when i understand +ap-kill and +ap-load-delete
::
++ ap-track-queue ++ ap-track-queue
^+ ap-state ^+ ap-state
:: ::
@ -1302,7 +1265,6 @@
:: We convert from bone-indexed moves to duct-indexed moves when resolving :: We convert from bone-indexed moves to duct-indexed moves when resolving
:: them in Arvo. :: them in Arvo.
:: ::
:: FIXME too long; consider breaking into ap-from-give, ap-from-pass
++ ap-from-internal ++ ap-from-internal
~/ %ap-from-internal ~/ %ap-from-internal
|= =internal-move |= =internal-move
@ -1376,8 +1338,6 @@
:: ::
:: +ap-call: call into server. :: +ap-call: call into server.
:: ::
:: FIXME requires understanding of ap-produce-arm, etc.
::
++ ap-call ++ ap-call
~/ %ap-call ~/ %ap-call
|= [=term =vase] |= [=term =vase]
@ -1397,8 +1357,6 @@
:: ::
:: +ap-peek: peek. :: +ap-peek: peek.
:: ::
:: FIXME docs
::
++ ap-peek ++ ap-peek
~/ %ap-peek ~/ %ap-peek
|= [=term tyl=path] |= [=term tyl=path]
@ -1505,7 +1463,6 @@
:: ::
:: +ap-diff: pour a diff. :: +ap-diff: pour a diff.
:: ::
:: FIXME docs
++ ap-diff ++ ap-diff
~/ %ap-diff ~/ %ap-diff
|= [=ship =path =cage] |= [=ship =path =cage]
@ -1555,8 +1512,6 @@
:: ::
:: +ap-update-subscription: update subscription. :: +ap-update-subscription: update subscription.
:: ::
:: FIXME docs
::
++ ap-update-subscription ++ ap-update-subscription
~/ %ap-update-subscription ~/ %ap-update-subscription
|= [is-ok=? =ship =path] |= [is-ok=? =ship =path]
@ -1594,12 +1549,12 @@
=/ deleted (~(del by meter.subscribers.current-agent) agent-bone) =/ deleted (~(del by meter.subscribers.current-agent) agent-bone)
ap-state(meter.subscribers.current-agent deleted) ap-state(meter.subscribers.current-agent deleted)
:: ::
=/ dequeued (~(put by meter.subscribers.current-agent) agent-bone u.level) =/ dequeued
(~(put by meter.subscribers.current-agent) agent-bone u.level)
ap-state(meter.subscribers.current-agent dequeued) ap-state(meter.subscribers.current-agent dequeued)
:: ::
:: +ap-produce-arm: produce arm. :: +ap-produce-arm: produce arm.
:: ::
:: FIXME docs
++ ap-produce-arm ++ ap-produce-arm
~/ %ap-produce-arm ~/ %ap-produce-arm
|= =term |= =term
@ -1661,17 +1616,14 @@
[%.n ap-state] [%.n ap-state]
:: ::
=/ next =/ next
=/ meter (~(put by meter.subscribers.current-agent) agent-bone +(meter)) =/ meter
(~(put by meter.subscribers.current-agent) agent-bone +(meter))
ap-state(meter.subscribers.current-agent meter) ap-state(meter.subscribers.current-agent meter)
:: ::
[%.y next] [%.y next]
:: ::
:: +ap-find-arm: general arm. :: +ap-find-arm: general arm.
:: ::
:: If the arm exists in the running cache for the raw [term path] cell,
:: returns that. Otherwise we assemble
::
:: FIXME finish
++ ap-find-arm ++ ap-find-arm
~/ %ap-find-arm ~/ %ap-find-arm
|= [=term =path] |= [=term =path]
@ -1697,7 +1649,8 @@
~ ~
(some [dep term]) (some [dep term])
:: ::
=. arm-cache.current-agent (~(put by arm-cache.current-agent) [term path] result) =. arm-cache.current-agent
(~(put by arm-cache.current-agent) [term path] result)
:: ::
[result ap-state] [result ap-state]
:: ::
@ -1732,19 +1685,19 @@
%_ ap-state %_ ap-state
+12.q.running-state.current-agent +12.q.running-state.current-agent
^- bowl ^- bowl
:* :* our :: host :* :* our :: host
attributing.routes.agent-privilege :: guest attributing.routes.agent-privilege :: guest
agent-name :: agent agent-name :: agent
== :: == ::
:* wex=~ :: outgoing :* wex=~ :: outgoing
sup=incoming.subscribers.current-agent :: incoming sup=incoming.subscribers.current-agent :: incoming
== :: == ::
:* agent-bone=agent-bone :: cause :* agent-bone=agent-bone :: cause
act=change.stats.current-agent :: tick act=change.stats.current-agent :: tick
eny=eny.stats.current-agent :: nonce eny=eny.stats.current-agent :: nonce
now=time.stats.current-agent :: time now=time.stats.current-agent :: time
byk=beak.current-agent :: source byk=beak.current-agent :: source
== == :: == ==
== ==
:: ::
:: +ap-move: process each move. :: +ap-move: process each move.
@ -1855,7 +1808,6 @@
:_ ap-state :_ ap-state
[%& sto %give %http-response ;;(http-event:http q.vax)] [%& sto %give %http-response ;;(http-event:http q.vax)]
:: ::
::
:: +ap-move-mess: extract path, target. :: +ap-move-mess: extract path, target.
:: ::
++ ap-move-mess ++ ap-move-mess
@ -1915,7 +1867,8 @@
:: ::
=/ vane u.maybe-vane =/ vane u.maybe-vane
:: ::
=^ at-slot cache.current-agent (~(slot wa cache.current-agent) 3 vase) =^ at-slot cache.current-agent
(~(slot wa cache.current-agent) 3 vase)
:: ::
=/ =internal-move =/ =internal-move
=/ =path [(scot %p attributing.routes.agent-privilege) %inn u.pax] =/ =path [(scot %p attributing.routes.agent-privilege) %inn u.pax]
@ -1939,7 +1892,8 @@
?: ?=(%.n -.possibly-target) ?: ?=(%.n -.possibly-target)
[possibly-target ap-state] [possibly-target ap-state]
:: ::
=^ at-slot cache.current-agent (~(slot wa cache.current-agent) 7 vase) =^ at-slot cache.current-agent
(~(slot wa cache.current-agent) 7 vase)
:: ::
?. ?& ?=([p=@ q=*] q.at-slot) ?. ?& ?=([p=@ q=*] q.at-slot)
((sane %tas) p.q.at-slot) ((sane %tas) p.q.at-slot)
@ -1947,7 +1901,8 @@
=/ =tang (ap-tang "poke: malformed cage") =/ =tang (ap-tang "poke: malformed cage")
[[%.n tang] ap-state] [[%.n tang] ap-state]
:: ::
=^ specialised cache.current-agent (~(stop wa cache.current-agent) 3 at-slot) =^ specialised cache.current-agent
(~(stop wa cache.current-agent) 3 at-slot)
:: ::
=/ target p.possibly-target =/ target p.possibly-target
=/ =path p.target =/ =path p.target
@ -2089,7 +2044,8 @@
(gte 1 (met 7 q.q.vase)) (gte 1 (met 7 q.q.vase))
((sane %tas) r.q.vase) ((sane %tas) r.q.vase)
== ==
=/ =tang (ap-tang "send: improper ask.[%send wire gill agent-action]") =/ =tang
(ap-tang "send: improper ask.[%send wire gill agent-action]")
[[%.n tang] ap-state] [[%.n tang] ap-state]
:: ::
=/ pax ((soft path) p.q.vase) =/ pax ((soft path) p.q.vase)
@ -2102,7 +2058,8 @@
:: ::
?: ?=($poke s.q.vase) ?: ?=($poke s.q.vase)
:: ::
=^ specialised cache.current-agent (~(spot wa cache.current-agent) 7 vase) =^ specialised cache.current-agent
(~(spot wa cache.current-agent) 7 vase)
:: ::
?> =(%poke -.q.specialised) ?> =(%poke -.q.specialised)
:: ::
@ -2112,8 +2069,11 @@
=/ =tang (ap-tang "send: malformed poke") =/ =tang (ap-tang "send: malformed poke")
[[%.n tang] ap-state] [[%.n tang] ap-state]
:: ::
=^ specialised cache.current-agent (~(spot wa cache.current-agent) 3 specialised) =^ specialised cache.current-agent
=^ at-slot cache.current-agent (~(slot wa cache.current-agent) 3 specialised) (~(spot wa cache.current-agent) 3 specialised)
::
=^ at-slot cache.current-agent
(~(slot wa cache.current-agent) 3 specialised)
:: ::
=/ move =/ move
=/ =agent-action [%poke p.t.q.vase at-slot] =/ =agent-action [%poke p.t.q.vase at-slot]
@ -2297,7 +2257,8 @@
:: ::
=/ arm u.maybe-arm =/ arm u.maybe-arm
:: ::
=^ at-slot cache.current-agent (~(slot wa cache.current-agent) 3 vase) =^ at-slot cache.current-agent
(~(slot wa cache.current-agent) 3 vase)
:: ::
=/ vase (slop !>((slag p.arm path)) at-slot) =/ vase (slop !>((slag p.arm path)) at-slot)
:: ::
@ -2341,12 +2302,33 @@
|= [=path =internal-gift] |= [=path =internal-gift]
^+ ap-state ^+ ap-state
:: ::
=/ pax +.path
::
?- -.internal-gift ?- -.internal-gift
%coup (ap-non-diff-take %coup +.path (some !>(p.internal-gift))) ::
%diff (ap-diff attributing.routes.agent-privilege path p.internal-gift) %coup
%quit (ap-non-diff-take %quit +.path ~) ::
%reap (ap-non-diff-take %reap +.path (some !>(p.internal-gift))) =/ maybe-vase (some !>(p.internal-gift))
%http-response !! (ap-non-diff-take %coup pax maybe-vase)
::
%diff
::
=/ =ship attributing.routes.agent-privilege
=/ =cage p.internal-gift
(ap-diff ship path cage)
::
%quit
::
(ap-non-diff-take %quit pax ~)
::
%reap
::
=/ maybe-vase (some !>(p.internal-gift))
(ap-non-diff-take %reap pax maybe-vase)
::
%http-response
::
!!
== ==
:: ::
:: +ap-install: install wrapper. :: +ap-install: install wrapper.
@ -2376,9 +2358,9 @@
:: ::
=/ next =/ next
%= ap-state %= ap-state
misvale.current-agent new-misvale-data misvale.current-agent new-misvale-data
agent-config new-agent-config agent-config new-agent-config
arm-cache.current-agent ~ arm-cache.current-agent ~
== ==
:: ::
[maybe-tang next] [maybe-tang next]
@ -2406,7 +2388,8 @@
=/ =tang (ap-tang "prep mismatch") =/ =tang (ap-tang "prep mismatch")
[(some tang) ap-state] [(some tang) ap-state]
:: ::
=/ next ap-state(+13.q.running-state.current-agent +13.q.u.maybe-vase) =/ next
ap-state(+13.q.running-state.current-agent +13.q.u.maybe-vase)
[~ next] [~ next]
:: ::
=/ =vase =/ =vase
@ -2421,13 +2404,15 @@
++ ap-silent-delete ++ ap-silent-delete
^+ ap-state ^+ ap-state
:: ::
=/ incoming (~(get by incoming.subscribers.current-agent) agent-bone) ?~ incoming=(~(get by incoming.subscribers.current-agent) agent-bone)
?~ incoming
ap-state ap-state
:: ::
=. incoming (~(del by incoming.subscribers.current-agent) agent-bone)
=/ meter (~(del by meter.subscribers.current-agent) agent-bone)
::
%_ ap-state %_ ap-state
incoming.subscribers.current-agent (~(del by incoming.subscribers.current-agent) agent-bone) incoming.subscribers.current-agent incoming
meter.subscribers.current-agent (~(del by meter.subscribers.current-agent) agent-bone) meter.subscribers.current-agent meter
== ==
:: ::
:: +ap-load-delete: load delete. :: +ap-load-delete: load delete.
@ -2435,15 +2420,19 @@
++ ap-load-delete ++ ap-load-delete
^+ ap-state ^+ ap-state
:: ::
=/ maybe-incoming (~(get by incoming.subscribers.current-agent) agent-bone) =/ maybe-incoming
(~(get by incoming.subscribers.current-agent) agent-bone)
::
?~ maybe-incoming ?~ maybe-incoming
ap-state ap-state
:: ::
=/ incoming u.maybe-incoming =/ incoming u.maybe-incoming
:: ::
=: incoming.subscribers.current-agent (~(del by incoming.subscribers.current-agent) agent-bone) =. incoming.subscribers.current-agent
meter.subscribers.current-agent (~(del by meter.subscribers.current-agent) agent-bone) (~(del by incoming.subscribers.current-agent) agent-bone)
== ::
=. meter.subscribers.current-agent
(~(del by meter.subscribers.current-agent) agent-bone)
:: ::
=^ maybe-arm ap-state (ap-find-arm %pull q.incoming) =^ maybe-arm ap-state (ap-find-arm %pull q.incoming)
:: ::
@ -2553,7 +2542,7 @@
:: ::
=/ next =/ next
%_ ap-state %_ ap-state
agent-moves (weld (flop internal-moves) agent-moves) agent-moves (weld (flop internal-moves) agent-moves)
running-state.current-agent p.possibly-vase running-state.current-agent p.possibly-vase
== ==
:: ::
@ -2569,7 +2558,8 @@
=/ received-type p.vax =/ received-type p.vax
=/ running-type p.running-state.current-agent =/ running-type p.running-state.current-agent
:: ::
=^ nests cache.current-agent (~(nest wa cache.current-agent) running-type received-type) =^ nests cache.current-agent
(~(nest wa cache.current-agent) running-type received-type)
:: ::
=/ possibly-vase =/ possibly-vase
?. nests ?. nests
@ -2648,42 +2638,42 @@
:: ::
?+ term ~& [%ap-vain term] ?+ term ~& [%ap-vain term]
~ ~
%bonk `%a %bonk `%a
%build `%f %build `%f
%cash `%a %cash `%a
%conf `%g %conf `%g
%cred `%c %cred `%c
%crew `%c %crew `%c
%crow `%c %crow `%c
%deal `%g %deal `%g
%dirk `%c %dirk `%c
%drop `%c %drop `%c
%flog `%d %flog `%d
%info `%c %info `%c
%keep `%f %keep `%f
%kill `%f %kill `%f
%look `%j %look `%j
%listen `%j %listen `%j
%merg `%c %merg `%c
%mont `%c %mont `%c
%moon `%j %moon `%j
%nuke `%a %nuke `%a
%ogre `%c %ogre `%c
%perm `%c %perm `%c
%rest `%b %rest `%b
%rekey `%j %rekey `%j
%wait `%b %wait `%b
%want `%a %want `%a
%warp `%c %warp `%c
%wash `%g %wash `%g
%wipe `%f %wipe `%f
:: ::
%request `%i %request `%i
%cancel-request `%i %cancel-request `%i
%serve `%e %serve `%e
%connect `%e %connect `%e
%disconnect `%e %disconnect `%e
%rule `%e %rule `%e
== ==
-- --
-- --
@ -2758,8 +2748,9 @@
=/ mes ;;((pair @ud reverse-ames) noun) =/ mes ;;((pair @ud reverse-ames) noun)
=> (mo-handle-backward:initialised ship agent-name mes) => (mo-handle-backward:initialised ship agent-name mes)
mo-abet mo-abet
:: ::
%wash %wash
::
=. running.agents.gall =. running.agents.gall
(~(run by running.agents.gall) |=(=agent agent(cache *worm))) (~(run by running.agents.gall) |=(=agent agent(cache *worm)))
[~ gall-payload] [~ gall-payload]