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

Merge pull request #5947 from urbit/ted/staying-alive-rebase

Browse Source 
gall: revive %hood and %dojo on keypress
This commit is contained in:
fang 2022-08-19 21:22:28 +02:00 committed by GitHub
commit a9a8619daa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 31 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -382,8 +382,9 @@
++ mo-core . ++ mo-core .
++ mo-abed |=(hun=duct mo-core(hen hun)) ++ mo-abed |=(hun=duct mo-core(hen hun))
++ mo-abet [(flop moves) gall-payload] ++ mo-abet [(flop moves) gall-payload]
++ mo-pass |=(p=[wire note-arvo] mo-core(moves [[hen pass+p] moves]))
++ mo-give |=(g=gift mo-core(moves [[hen give+g] moves])) ++ mo-give |=(g=gift mo-core(moves [[hen give+g] moves]))
++ mo-pass |=(p=[wire note-arvo] mo-core(moves [[hen pass+p] moves]))
++ mo-slip |=(p=note-arvo mo-core(moves [[hen slip+p] moves]))
++ mo-past ++ mo-past
|= =(list [wire note-arvo]) |= =(list [wire note-arvo])
?~ list ?~ list
@ -869,6 +870,15 @@
?. =(run-nonce.u.yoke i.t.wire) ?. =(run-nonce.u.yoke i.t.wire)
%- (slog leaf+"gall: got old {<+<.sign-arvo>} for {<dap>}" ~) %- (slog leaf+"gall: got old {<+<.sign-arvo>} for {<dap>}" ~)
mo-core mo-core
:: if agent must be running, revive all needed agents then apply
::
?: ?& ?=(%| -.agent.u.yoke)
?=(?(%dojo %hood) dap)
==
=. mo-core (mo-pass /nowhere %g %jolt %base %hood)
=. mo-core (mo-pass /nowhere %g %jolt %base %dojo)
(mo-pass use+wire %b %huck sign-arvo)
::
?. ?=([?(%gall %behn) %unto *] sign-arvo) ?. ?=([?(%gall %behn) %unto *] sign-arvo)
?: ?=(%| -.agent.u.yoke) ?: ?=(%| -.agent.u.yoke)
%- (slog leaf+"gall: {<dap>} dozing, dropping {<+<.sign-arvo>}" ~) %- (slog leaf+"gall: {<dap>} dozing, dropping {<+<.sign-arvo>}" ~)
@ -1045,19 +1055,27 @@
=/ running (~(get by yokes.state) agent) =/ running (~(get by yokes.state) agent)
=/ is-running ?~(running %| ?=(%& -.agent.u.running)) =/ is-running ?~(running %| ?=(%& -.agent.u.running))
=/ is-blocked (~(has by blocked.state) agent) =/ is-blocked (~(has by blocked.state) agent)
:: agent is running; deliver move normally
:: ::
?: |(!is-running is-blocked) ?. |(!is-running is-blocked)
=/ blocked=(qeu blocked-move) (mo-apply agent routes deal)
=/ waiting (~(get by blocked.state) agent) :: if agent must be running, revive all needed agents then apply
=/ deals (fall waiting *(qeu blocked-move)) ::
=/ deal [hen routes &+deal] ?: ?=(?(%hood %dojo) agent)
(~(put to deals) deal) =. mo-core (mo-pass /nowhere %g %jolt %base %hood)
:: =. mo-core (mo-pass /nowhere %g %jolt %base %dojo)
%- (slog leaf+"gall: not running {<agent>} yet, got {<-.deal>}" ~) (mo-slip %g %deal [ship our] agent deal)
%_ mo-core ::
blocked.state (~(put by blocked.state) agent blocked) =/ blocked=(qeu blocked-move)
== =/ waiting (~(get by blocked.state) agent)
(mo-apply agent routes deal) =/ deals (fall waiting *(qeu blocked-move))
=/ deal [hen routes &+deal]
(~(put to deals) deal)
::
%- (slog leaf+"gall: not running {<agent>} yet, got {<-.deal>}" ~)
%_ mo-core
blocked.state (~(put by blocked.state) agent blocked)
==
:: +mo-handle-ames-request: handle %ames request message. :: +mo-handle-ames-request: handle %ames request message.
:: ::
++ mo-handle-ames-request ++ mo-handle-ames-request