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

kiln: synchronize install flow for local desks

Browse Source 
When installing from an existing local desk, kiln now scries the
relevant data out of clay instead of sending moves to it and awaiting
responses.

This prepares for coming kiln work.
This commit is contained in:
Fang 2021-09-15 23:42:44 +02:00
parent 17f6285430
commit d7afe32291
No known key found for this signature in database
GPG Key ID: EB035760C1BBA972
1 changed files with 34 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
pkg/arvo/lib/hood/kiln.hoon
View File

@ -418,8 +418,20 @@
=: loc lac =: loc lac
rak [[paused=| her rem *aeon] next=~ rein:(fall got *arak)] rak [[paused=| her rem *aeon] next=~ rein:(fall got *arak)]
== ==
~> %slog.0^leaf/"kiln: beginning install into {here}" ?. ?& =(our her)
(emit find:pass) ::
=- (~(has in -) rem)
.^((set desk) %cd /(scot %p our)//(scot %da now))
==
~> %slog.0^leaf/"kiln: beginning install into {here}"
(emit find:pass)
~> %slog.0^leaf/"kiln: beginning local install into {here}"
%- take-find
:+ %clay %writ
:- ~
:+ [%y ud+1 rem] /
:- %arch
!> .^(arch %cy /(scot %p our)/[rem]/1)
:: +reset: resync after failure :: +reset: resync after failure
:: ::
++ reset ++ reset
@ -595,8 +607,16 @@
?~ p.syn ?~ p.syn
~> %slog.0^leaf/"kiln: cancelled (1) install into {here}, aborting" ~> %slog.0^leaf/"kiln: cancelled (1) install into {here}, aborting"
vats(ark (~(del by ark) loc)) vats(ark (~(del by ark) loc))
~> %slog.0^leaf/"kiln: activated install into {here}" ?. =(our ship.rail.rak)
(emit sync-da:pass) ~> %slog.0^leaf/"kiln: activated install into {here}"
(emit sync-da:pass)
~> %slog.0^leaf/"kiln: activated local install into {here}"
%- take-sync
:+ %clay %writ
:- ~
:+ [%w da+now desk.rail.rak] /
:- %cass
!> .^(cass %cw /(scot %p our)/[desk.rail.rak]/(scot %da now))
:: ::
++ take-sync ++ take-sync
|= syn=sign-arvo |= syn=sign-arvo
@ -607,9 +627,17 @@
?~ p.syn ?~ p.syn
~> %slog.0^leaf/"kiln: cancelled (1) install into {here}, retrying" ~> %slog.0^leaf/"kiln: cancelled (1) install into {here}, retrying"
reset reset
~> %slog.0^leaf/"kiln: downloading update for {here}"
=? aeon.rail.rak ?=(%w p.p.u.p.syn) ud:;;(cass:clay q.q.r.u.p.syn) =? aeon.rail.rak ?=(%w p.p.u.p.syn) ud:;;(cass:clay q.q.r.u.p.syn)
(emit download:pass) ?. =(our ship.rail.rak)
~> %slog.0^leaf/"kiln: downloading update for {here}"
(emit download:pass)
~> %slog.0^leaf/"kiln: loading update for {here}"
%- take-download
:+ %clay %writ
:- ~
:+ [%v ud+aeon.rail.rak desk.rail.rak] /
:- %dome
!> .^(dome:clay %cv /(scot %p our)/[desk.rail.rak]/(scot %ud aeon.rail.rak))
:: ::
++ take-download ++ take-download
|= syn=sign-arvo |= syn=sign-arvo