mirror of
https://github.com/urbit/shrub.git
synced 2024-12-01 06:35:32 +03:00
/sys: |mass works again
This commit is contained in:
parent
63b77c1b7f
commit
a064afbd89
@ -104,8 +104,7 @@
|
||||
(pair cord (each * (list mass)))
|
||||
+$ monk (each ship (pair @tas @ta))
|
||||
+$ move [=duct =ball]
|
||||
+$ ovum $~ [/ %$ **]
|
||||
(pair wire curd)
|
||||
+$ ovum (pair wire curd)
|
||||
::
|
||||
+$ scry-sample
|
||||
[fur=(unit (set monk)) ren=@tas why=shop syd=desk lot=coin tyl=path]
|
||||
@ -742,6 +741,30 @@
|
||||
ball.move wite.ball.move
|
||||
==
|
||||
==
|
||||
:: +whey: measure memory usage
|
||||
::
|
||||
++ whey
|
||||
^- (list mass)
|
||||
=/ von
|
||||
%+ turn
|
||||
(sort ~(tap by van) |=([[a=@tas *] [b=@tas *]] (aor a b)))
|
||||
|=([lal=@tas =vane] (cat 3 %vane- lal)^vane)
|
||||
::
|
||||
:~ :+ %reports %|
|
||||
%+ turn von
|
||||
=/ bem=beam [[our %home da+now] /whey]
|
||||
|= [lal=@tas =vane]
|
||||
=/ met (need (need (peek ** ~ lal bem)))
|
||||
lal^|+;;((list mass) q.q.met)
|
||||
::
|
||||
:+ %caches %|
|
||||
%+ turn von
|
||||
|=([lal=@tas =vane] lal^&+worm.vane)
|
||||
::
|
||||
:+ %dregs %|
|
||||
%+ turn von
|
||||
|=([lal=@tas =vane] lal^&+vase.vane)
|
||||
==
|
||||
:: +peek: read from the entire namespace
|
||||
::
|
||||
++ peek
|
||||
@ -752,7 +775,6 @@
|
||||
:: XX identity is defaulted to ship from beam
|
||||
::
|
||||
=> .(fur ?^(fur fur `[[%& p.bed] ~ ~]))
|
||||
::
|
||||
:: XX vane and care are concatenated
|
||||
::
|
||||
=/ lal (end 3 1 ron)
|
||||
@ -766,7 +788,7 @@
|
||||
|= [=wire gift=maze]
|
||||
^- [(unit ovum) _this]
|
||||
=/ ovo=ovum [wire ;;(card q.p.gift)]
|
||||
?: ?=(?(%lyra %veer %wack) -.card.ovo)
|
||||
?: ?=(?(%lyra %veer %wack %verb %whey) -.card.ovo)
|
||||
[`ovo this]
|
||||
[~ this(out [ovo out])]
|
||||
:: +call: advance to target
|
||||
@ -1041,8 +1063,8 @@
|
||||
^- pram
|
||||
?: ?=([%345 *] ram)
|
||||
ram
|
||||
=| nub=debt:le:part
|
||||
~| ram+ram
|
||||
=| nub=debt:le:part
|
||||
[%345 nub(out ;;((list ovum) ram))]
|
||||
:: $prim: old $pram
|
||||
:: +drum: upgrade $prim to $pram, incompatible
|
||||
@ -1054,6 +1076,7 @@
|
||||
++ come
|
||||
|= [who=ship now=@da yen=@ rim=prim dub=vise nyf=pone]
|
||||
^- [(list ovum) *]
|
||||
~| %come
|
||||
=/ fyn (turn nyf |=([a=@tas b=vise] [a (slim b)]))
|
||||
=/ rum (drum rim)
|
||||
(load who now yen rum (slim dub) fyn)
|
||||
@ -1062,6 +1085,7 @@
|
||||
++ load
|
||||
|= [who=ship now=@da yen=@ ram=pram dub=vase nyf=pane]
|
||||
^- [(list ovum) *]
|
||||
~| %load
|
||||
=: our who
|
||||
eny yen
|
||||
bud dub
|
||||
@ -1076,6 +1100,8 @@
|
||||
|= {now/@da hap/path}
|
||||
^- (unit (unit))
|
||||
?~ hap [~ ~ hoon-version]
|
||||
?: =(hap /whey)
|
||||
``mass+(whey now)
|
||||
((sloy peek:(lead now ~)) [[151 %noun] hap])
|
||||
:: +poke: external apply
|
||||
::
|
||||
@ -1090,8 +1116,7 @@
|
||||
(leap now (poke:(lead now ~) (dint p.ovo) ovo))
|
||||
:: Process these events just as if they had come from a vane
|
||||
::
|
||||
?(%lyra %veer %verb %wack)
|
||||
(feck now ovo *debt:le:part)
|
||||
?(%lyra %veer %verb %wack %whey) (feck now ovo *debt:le:part)
|
||||
:: These external events (currently only %trim) are global
|
||||
:: notifications, spammed to every vane
|
||||
::
|
||||
@ -1143,6 +1168,16 @@
|
||||
?: ?=(%& -.zef)
|
||||
[p.zef arvo]
|
||||
(feck now [fec nub]:p.zef)
|
||||
:: +whey: report memory usage
|
||||
::
|
||||
++ whey
|
||||
|= now=@da
|
||||
^- mass
|
||||
:+ %arvo %|
|
||||
:~ hoon+&+pit
|
||||
zuse+&+bud
|
||||
vane+|+whey:(lead now ~)
|
||||
==
|
||||
:: +feck: handle an effect from a vane
|
||||
::
|
||||
++ feck
|
||||
@ -1152,17 +1187,21 @@
|
||||
?: ?=(%lyra -.q.ovo)
|
||||
(vega now nub ;;([@ @] +.q.ovo))
|
||||
?+ -.q.ovo ~|(bad-fec+-.q.ovo !!)
|
||||
:: produce memory usage report
|
||||
::
|
||||
%whey
|
||||
=. out.nub [[p.ovo mass+(whey now)] out.nub]
|
||||
(leap now (lead now `nub))
|
||||
:: %verb: toggle event verbose event printfs
|
||||
::
|
||||
%verb (leap(lac !lac) now (lead now `nub))
|
||||
%verb
|
||||
=. lac !lac
|
||||
(leap now (lead now `nub))
|
||||
:: %veer: install %zuse or vane
|
||||
::
|
||||
%veer
|
||||
=. soul (veer our now q.ovo)
|
||||
(leap now (lead now `nub))
|
||||
:: %mass: add data to memory profile
|
||||
::
|
||||
%mass !! :: XX convert %mass to a spam
|
||||
:: %wack: add entropy
|
||||
::
|
||||
%wack
|
||||
|
@ -1095,7 +1095,6 @@
|
||||
%sift (on-sift:event-core ships.task)
|
||||
%spew (on-spew:event-core veb.task)
|
||||
%vega on-vega:event-core
|
||||
%wegh on-wegh:event-core
|
||||
%plea (on-plea:event-core [ship plea]:task)
|
||||
==
|
||||
::
|
||||
@ -1195,6 +1194,13 @@
|
||||
?. =(%$ ren) [~ ~]
|
||||
?. =([%& our] why)
|
||||
[~ ~]
|
||||
?: =(tyl /whey)
|
||||
=/ maz=(list mass)
|
||||
=+ [known alien]=(skid ~(val by peers.ames-state) |=(^ =(%known +<-)))
|
||||
:~ peers-known+&+known
|
||||
peers-alien+&+alien
|
||||
==
|
||||
``mass+!>(maz)
|
||||
?+ syd ~
|
||||
%peer
|
||||
?. ?=([@ ~] tyl) [~ ~]
|
||||
@ -1836,20 +1842,6 @@
|
||||
^+ event-core
|
||||
::
|
||||
(emit unix-duct.ames-state %give %turf turfs)
|
||||
:: +on-wegh: produce memory usage report
|
||||
::
|
||||
++ on-wegh
|
||||
^+ event-core
|
||||
::
|
||||
=+ [known alien]=(skid ~(tap by peers.ames-state) |=(^ =(%known +<-)))
|
||||
::
|
||||
%- emit
|
||||
:^ duct %give %mass
|
||||
:+ %ames %|
|
||||
:~ peers-known+&+known
|
||||
peers-alien+&+alien
|
||||
dot+&+ames-state
|
||||
==
|
||||
:: +on-born: handle unix process restart
|
||||
::
|
||||
++ on-born
|
||||
|
@ -135,16 +135,6 @@
|
||||
::
|
||||
=< set-unix-wake
|
||||
(emit-vane-wake(timers.state t.timers.state) duct.i.timers.state ~)
|
||||
:: +wegh: produce memory usage report for |mass
|
||||
::
|
||||
++ wegh
|
||||
^+ [moves state]
|
||||
:_ state :_ ~
|
||||
:^ duct %give %mass
|
||||
:+ %behn %|
|
||||
:~ timers+&+timers.state
|
||||
dot+&+state
|
||||
==
|
||||
:: %utilities
|
||||
::
|
||||
::+|
|
||||
@ -277,7 +267,6 @@
|
||||
%vega vega:event-core
|
||||
%wait (wait:event-core date=p.task)
|
||||
%wake (wake:event-core error=~)
|
||||
%wegh wegh:event-core
|
||||
==
|
||||
[moves behn-gate]
|
||||
:: +load: migrate an old state to a new behn version
|
||||
@ -298,6 +287,11 @@
|
||||
::
|
||||
?. ?=(%& -.why)
|
||||
~
|
||||
?: &(=(ren %$) =(tyl /whey))
|
||||
=/ maz=(list mass)
|
||||
:~ timers+&+timers.state
|
||||
==
|
||||
``mass+!>(maz)
|
||||
[~ ~ %tank !>(>timers<)]
|
||||
::
|
||||
++ stay state
|
||||
|
@ -5571,27 +5571,6 @@
|
||||
[%foreign-warp (scot %p her) t.pax]
|
||||
[hen %pass wire %c %werp her our ryf]
|
||||
==
|
||||
::
|
||||
%wegh
|
||||
:_ ..^$ :_ ~
|
||||
:^ hen %give %mass
|
||||
:+ %clay %|
|
||||
=/ domestic
|
||||
%+ turn (sort ~(tap by dos.rom.ruf) aor)
|
||||
|= [=desk =dojo]
|
||||
:+ desk %|
|
||||
:~ ankh+&+ank.dom.dojo
|
||||
mime+&+mim.dom.dojo
|
||||
ford+&+fod.dom.dojo
|
||||
==
|
||||
:~ domestic+|+domestic
|
||||
foreign+&+hoy.ruf
|
||||
:+ %object-store %|
|
||||
:~ commits+&+hut.ran.ruf
|
||||
blobs+&+lat.ran.ruf
|
||||
==
|
||||
dot+&+ruf
|
||||
==
|
||||
==
|
||||
::
|
||||
++ load
|
||||
@ -5604,6 +5583,8 @@
|
||||
^- (unit (unit cage))
|
||||
?. ?=(%& -.why) ~
|
||||
=* his p.why
|
||||
?: &(=(ren %$) =(tyl /whey))
|
||||
``mass+!>(whey)
|
||||
:: ~& scry+[ren `path`[(scot %p his) syd ~(rent co lot) tyl]]
|
||||
:: =- ~& %scry-done -
|
||||
=+ luk=?.(?=(%$ -.lot) ~ ((soft case) p.lot))
|
||||
@ -5873,4 +5854,23 @@
|
||||
?~ -
|
||||
`[paf %ins %mime -:!>(*mime) u.mim]
|
||||
`[paf %mut %mime -:!>(*mime) u.mim]
|
||||
:: +whey: produce memory usage report
|
||||
::
|
||||
++ whey
|
||||
^- (list mass)
|
||||
=/ domestic
|
||||
%+ turn (sort ~(tap by dos.rom.ruf) aor)
|
||||
|= [=desk =dojo]
|
||||
:+ desk %|
|
||||
:~ ankh+&+ank.dom.dojo
|
||||
mime+&+mim.dom.dojo
|
||||
ford+&+fod.dom.dojo
|
||||
==
|
||||
:~ domestic+|+domestic
|
||||
foreign+&+hoy.ruf
|
||||
:+ %object-store %|
|
||||
:~ commits+&+hut.ran.ruf
|
||||
blobs+&+lat.ran.ruf
|
||||
==
|
||||
==
|
||||
--
|
||||
|
@ -8,21 +8,10 @@
|
||||
-- ::
|
||||
=> |% :: console protocol
|
||||
++ axle ::
|
||||
$: $2 ::
|
||||
$: %3 ::
|
||||
hey/(unit duct) :: default duct
|
||||
dug/(map duct axon) :: conversations
|
||||
lit/? :: boot in lite mode
|
||||
dog/_| :: auto-goad
|
||||
$= hef :: other weights
|
||||
$: a/(unit mass) ::
|
||||
b/(unit mass) ::
|
||||
c/(unit mass) ::
|
||||
e/(unit mass) ::
|
||||
f/(unit mass) ::
|
||||
g/(unit mass) ::
|
||||
i/(unit mass) ::
|
||||
j/(unit mass) ::
|
||||
== ::
|
||||
$= veb :: vane verbosities
|
||||
$~ (~(put by *(map @tas log-level)) %hole %soft) :: quiet packet crashes
|
||||
(map @tas log-level) ::
|
||||
@ -43,20 +32,10 @@
|
||||
++ move {p/duct q/(wind note gift:able)} :: local move
|
||||
++ note :: out request $->
|
||||
$~ [%d %verb ~] ::
|
||||
$% $: %a ::
|
||||
$>(%wegh task:able:ames) ::
|
||||
== ::
|
||||
$: %b ::
|
||||
$> $? %wait ::
|
||||
%wegh ::
|
||||
== ::
|
||||
task:able:behn ::
|
||||
== ::
|
||||
$: %c ::
|
||||
$% $: %c ::
|
||||
$> $? %merg :: merge desks
|
||||
%perm :: change permissions
|
||||
%warp :: wait for clay hack
|
||||
%wegh :: memory measure
|
||||
== ::
|
||||
task:able:clay ::
|
||||
== ::
|
||||
@ -71,46 +50,27 @@
|
||||
== ::
|
||||
task:able:dill ::
|
||||
== ::
|
||||
$: %e ::
|
||||
$>(%wegh task:able:eyre) ::
|
||||
== ::
|
||||
$: %f ::
|
||||
$>(%wegh task:able:ford) ::
|
||||
== ::
|
||||
$: %g ::
|
||||
$> $? %conf ::
|
||||
%deal ::
|
||||
%goad ::
|
||||
%wegh ::
|
||||
== ::
|
||||
task:able:gall ::
|
||||
== ::
|
||||
$: %i ::
|
||||
$>(%wegh task:able:iris) ::
|
||||
== ::
|
||||
$: %j ::
|
||||
$> $? %dawn ::
|
||||
%fake ::
|
||||
%wegh ::
|
||||
== ::
|
||||
task:able:jael ::
|
||||
== == ::
|
||||
++ sign :: in result $<-
|
||||
$~ [%j %init *@p] ::
|
||||
$% $: %a ::
|
||||
$% $>(%mass gift:able:ames) ::
|
||||
== == ::
|
||||
$: %b ::
|
||||
$% $> $? %mass ::
|
||||
%wake ::
|
||||
== ::
|
||||
gift:able:behn ::
|
||||
$>(%writ gift:able:clay) :: XX %slip
|
||||
$% $: %b ::
|
||||
$% $>(%writ gift:able:clay) :: XX %slip
|
||||
$>(%mere gift:able:clay) :: XX %slip
|
||||
== == ::
|
||||
$: %c ::
|
||||
$> $? %mass ::
|
||||
%mere ::
|
||||
$> $? %mere ::
|
||||
%note ::
|
||||
%writ ::
|
||||
== ::
|
||||
@ -119,25 +79,14 @@
|
||||
$: %d ::
|
||||
$>(%blit gift:able:dill) ::
|
||||
== ::
|
||||
$: %e ::
|
||||
$>(%mass gift:able:eyre) ::
|
||||
== ::
|
||||
$: %f ::
|
||||
$>(%mass gift:able:ford) ::
|
||||
== ::
|
||||
$: %g ::
|
||||
$> $? %mass ::
|
||||
%onto ::
|
||||
$> $? %onto ::
|
||||
%unto ::
|
||||
== ::
|
||||
gift:able:gall ::
|
||||
== ::
|
||||
$: %i ::
|
||||
$>(%mass gift:able:iris) ::
|
||||
== ::
|
||||
$: %j ::
|
||||
$> $? %init ::
|
||||
%mass ::
|
||||
== ::
|
||||
gift:able:jael ::
|
||||
== == ::
|
||||
@ -154,52 +103,19 @@
|
||||
^- {(list move) axle}
|
||||
[(flop moz) all(dug (~(put by dug.all) hen +<+))]
|
||||
::
|
||||
++ auto :: stage automation
|
||||
^+ .
|
||||
?. dog.all .
|
||||
=. dog.all |
|
||||
(pass /auto/one [%b %wait +(now)])
|
||||
::
|
||||
++ auto-wake :: resume automation
|
||||
|= [=wire error=(unit tang)]
|
||||
?+ wire
|
||||
?~ error
|
||||
~|(behn-bad-wake+wire !!)
|
||||
(crud %wake u.error)
|
||||
::
|
||||
[%auto %one ~]
|
||||
?~ error
|
||||
~& %behn-goad
|
||||
(pass / [%g %goad force=| ~])
|
||||
:: %goad crashed, wait again, then force
|
||||
::
|
||||
~& %behn-goad-retry
|
||||
%. [/auto/two [%b %wait +(now)]]
|
||||
pass:(crud %goad u.error)
|
||||
::
|
||||
[%auto %two ~]
|
||||
?~ error
|
||||
~& %behn-goad-again
|
||||
(pass / [%g %goad force=& ~])
|
||||
:: %goad crashed again, bail out
|
||||
::
|
||||
~& %behn-goad-fail
|
||||
(crud %goad u.error)
|
||||
==
|
||||
::
|
||||
++ call :: receive input
|
||||
|= kyz/task:able
|
||||
^+ +>
|
||||
?+ -.kyz ~& [%strange-kiss -.kyz] +>
|
||||
$flow +>
|
||||
$harm +>
|
||||
$hail auto:(send %hey ~)
|
||||
$hail (send %hey ~)
|
||||
$belt (send `dill-belt`p.kyz)
|
||||
$text (from %out (tuba p.kyz))
|
||||
$crud :: (send `dill-belt`[%cru p.kyz q.kyz])
|
||||
(crud p.kyz q.kyz)
|
||||
$blew (send %rez p.p.kyz q.p.kyz)
|
||||
$heft heft
|
||||
$heft (dump %whey ~)
|
||||
$lyra (dump kyz)
|
||||
$pack (dump kyz)
|
||||
$veer (dump kyz)
|
||||
@ -334,17 +250,6 @@
|
||||
~ '9'
|
||||
==
|
||||
--
|
||||
::
|
||||
++ heft
|
||||
=< (pass /heft/ames [%a %wegh ~])
|
||||
=< (pass /heft/behn [%b %wegh ~])
|
||||
=< (pass /heft/clay [%c %wegh ~])
|
||||
=< (pass /heft/eyre [%e %wegh ~])
|
||||
=< (pass /heft/ford [%f %wegh ~])
|
||||
=< (pass /heft/gall [%g %wegh ~])
|
||||
=< (pass /heft/iris [%i %wegh ~])
|
||||
=< (pass /heft/jael [%j %wegh ~])
|
||||
.
|
||||
:: XX move
|
||||
::
|
||||
++ sein
|
||||
@ -410,9 +315,6 @@
|
||||
|= {tea/wire sih/sign}
|
||||
^+ +>
|
||||
?- sih
|
||||
{?($a $b $c $e $f $g $i $j) $mass *}
|
||||
(wegh -.sih p.sih)
|
||||
::
|
||||
[%j %init *]
|
||||
:: pass thru to unix
|
||||
::
|
||||
@ -449,58 +351,7 @@
|
||||
::
|
||||
{$d $blit *}
|
||||
(done +.sih)
|
||||
::
|
||||
{$b $wake *}
|
||||
(auto-wake tea error.sih)
|
||||
==
|
||||
:: +wegh: receive a memory report from a vane and maybe emit full report
|
||||
::
|
||||
++ wegh
|
||||
|= [lal=?(%a %b %c %e %f %g %i %j) mas=mass]
|
||||
^+ +>
|
||||
:: update our listing of vane responses with this new one
|
||||
::
|
||||
=. hef.all
|
||||
?- lal
|
||||
%a ~?(?=(^ a.hef.all) %double-mass-a hef.all(a `mas))
|
||||
%b ~?(?=(^ b.hef.all) %double-mass-b hef.all(b `mas))
|
||||
%c ~?(?=(^ c.hef.all) %double-mass-c hef.all(c `mas))
|
||||
%e ~?(?=(^ e.hef.all) %double-mass-e hef.all(e `mas))
|
||||
%f ~?(?=(^ f.hef.all) %double-mass-f hef.all(f `mas))
|
||||
%g ~?(?=(^ g.hef.all) %double-mass-g hef.all(g `mas))
|
||||
%i ~?(?=(^ i.hef.all) %double-mass-i hef.all(i `mas))
|
||||
%j ~?(?=(^ j.hef.all) %double-mass-j hef.all(j `mas))
|
||||
==
|
||||
:: if not all vanes have responded yet, no-op
|
||||
::
|
||||
?. ?& ?=(^ a.hef.all)
|
||||
?=(^ b.hef.all)
|
||||
?=(^ c.hef.all)
|
||||
?=(^ e.hef.all)
|
||||
?=(^ f.hef.all)
|
||||
?=(^ g.hef.all)
|
||||
?=(^ i.hef.all)
|
||||
?=(^ j.hef.all)
|
||||
==
|
||||
+>.$
|
||||
:: clear vane reports from our state before weighing ourself
|
||||
::
|
||||
:: Otherwise, the state of vanes printed after this one get absorbed
|
||||
:: into Dill's %dot catchall report.
|
||||
::
|
||||
=/ ven=(list mass) ~[u.a u.b u.c u.e u.f u.g u.i u.j]:hef.all
|
||||
=> .(hef.all [~ ~ ~ ~ ~ ~ ~ ~])
|
||||
:: wegh ourself now that our state doesn't include other masses
|
||||
::
|
||||
=/ self=mass
|
||||
:+ %dill %|
|
||||
:~ hey+&+hey.all
|
||||
dug+&+dug.all
|
||||
dot+&+all
|
||||
==
|
||||
:: produce the memory report for all vanes
|
||||
::
|
||||
(done %mass %vanes %| [self ven])
|
||||
--
|
||||
::
|
||||
++ ax :: make ++as
|
||||
@ -591,7 +442,7 @@
|
||||
=> |%
|
||||
:: without .dog
|
||||
::
|
||||
++ axle-one
|
||||
++ axle-1
|
||||
$: $1
|
||||
hey/(unit duct)
|
||||
dug/(map duct axon)
|
||||
@ -610,15 +461,36 @@
|
||||
$~ (~(put by *(map @tas log-level)) %hole %soft)
|
||||
(map @tas log-level)
|
||||
==
|
||||
++ axle-2
|
||||
$: %2
|
||||
hey/(unit duct)
|
||||
dug/(map duct axon)
|
||||
lit/?
|
||||
dog/_|
|
||||
$= hef
|
||||
$: a/(unit mass)
|
||||
b/(unit mass)
|
||||
c/(unit mass)
|
||||
e/(unit mass)
|
||||
f/(unit mass)
|
||||
g/(unit mass)
|
||||
i/(unit mass)
|
||||
j/(unit mass)
|
||||
==
|
||||
$= veb
|
||||
$~ (~(put by *(map @tas log-level)) %hole %soft)
|
||||
(map @tas log-level)
|
||||
==
|
||||
::
|
||||
++ axle-both
|
||||
$%(axle-one axle)
|
||||
++ axle-any
|
||||
$%(axle-1 axle-2 axle)
|
||||
--
|
||||
::
|
||||
|= old=axle-both
|
||||
|= old=axle-any
|
||||
?- -.old
|
||||
%1 $(old [%2 [hey dug lit dog=& hef veb]:old])
|
||||
%2 ..^$(all old)
|
||||
%2 $(old [%3 [hey dug lit veb]:old])
|
||||
%3 ..^$(all old)
|
||||
==
|
||||
::
|
||||
++ scry
|
||||
@ -626,6 +498,12 @@
|
||||
^- (unit (unit cage))
|
||||
?. ?=(%& -.why) ~
|
||||
=* his p.why
|
||||
?: &(=(ren %$) =(tyl /whey))
|
||||
=/ maz=(list mass)
|
||||
:~ hey+&+hey.all
|
||||
dug+&+dug.all
|
||||
==
|
||||
``mass+!>(maz)
|
||||
[~ ~]
|
||||
::
|
||||
++ stay all
|
||||
|
@ -2186,20 +2186,6 @@
|
||||
%disconnect
|
||||
=. server-state.ax (remove-binding:server binding.task)
|
||||
[~ http-server-gate]
|
||||
::
|
||||
%wegh
|
||||
:_ http-server-gate
|
||||
:~ :* duct
|
||||
%give
|
||||
%mass
|
||||
^- mass
|
||||
:+ %eyre %|
|
||||
:~ bindings+&+bindings.server-state.ax
|
||||
auth+&+authentication-state.server-state.ax
|
||||
connections+&+connections.server-state.ax
|
||||
channels+&+channel-state.server-state.ax
|
||||
axle+&+ax
|
||||
== == ==
|
||||
==
|
||||
::
|
||||
++ take
|
||||
@ -2404,6 +2390,15 @@
|
||||
=* who p.why
|
||||
?. ?=(%$ ren)
|
||||
[~ ~]
|
||||
?: =(tyl /whey)
|
||||
=/ maz=(list mass)
|
||||
:~ bindings+&+bindings.server-state.ax
|
||||
auth+&+authentication-state.server-state.ax
|
||||
connections+&+connections.server-state.ax
|
||||
channels+&+channel-state.server-state.ax
|
||||
axle+&+ax
|
||||
==
|
||||
``mass+!>(maz)
|
||||
?. ?=(%$ -.lot)
|
||||
[~ ~]
|
||||
?. ?=(%host syd)
|
||||
|
@ -6206,17 +6206,6 @@
|
||||
=. state.ax (wipe:this-event percent-to-remove.task)
|
||||
::
|
||||
[~ ford-gate]
|
||||
::
|
||||
%wegh
|
||||
:_ ford-gate
|
||||
:_ ~
|
||||
:^ duct %give %mass
|
||||
^- mass
|
||||
:+ %ford %|
|
||||
:~ builds+&+builds.state.ax
|
||||
compiler-cache+&+compiler-cache.state.ax
|
||||
dot+&+ax
|
||||
==
|
||||
==
|
||||
:: +take: receive a response from another vane
|
||||
::
|
||||
@ -6361,6 +6350,11 @@
|
||||
:: +scry: request a path in the urbit namespace
|
||||
::
|
||||
++ scry
|
||||
|= *
|
||||
[~ ~]
|
||||
|= {fur/(unit (set monk)) ren/@tas why/shop syd/desk lot/coin tyl/path}
|
||||
^- (unit (unit cage))
|
||||
?. ?=(%& -.why) ~
|
||||
=* his p.why
|
||||
?: &(=(ren %$) =(tyl /whey))
|
||||
``mass+!>([state+&+ax]~)
|
||||
~
|
||||
--
|
||||
|
@ -1382,24 +1382,6 @@
|
||||
%sear mo-abet:(mo-filter-queue:mo-core ship.task)
|
||||
%trim [~ gall-payload]
|
||||
%vega [~ gall-payload]
|
||||
%wegh
|
||||
=/ blocked
|
||||
=/ queued (~(run by blocked.state) |=((qeu blocked-move) [%.y +<]))
|
||||
(sort ~(tap by queued) aor)
|
||||
::
|
||||
=/ running
|
||||
=/ active (~(run by yokes.state) |=(yoke [%.y +<]))
|
||||
(sort ~(tap by active) aor)
|
||||
::
|
||||
=/ =mass
|
||||
:+ %gall %.n
|
||||
:~ [%foreign %.y contacts.state]
|
||||
[%blocked %.n blocked]
|
||||
[%active %.n running]
|
||||
[%dot %.y state]
|
||||
==
|
||||
::
|
||||
[[duct %give %mass mass]~ gall-payload]
|
||||
==
|
||||
:: +load: recreate vane
|
||||
::
|
||||
@ -1825,6 +1807,22 @@
|
||||
?. ?=(%.y -.shop)
|
||||
~
|
||||
=/ =ship p.shop
|
||||
?: &(=(care %$) =(path /whey))
|
||||
=/ blocked
|
||||
=/ queued (~(run by blocked.state) |=((qeu blocked-move) [%.y +<]))
|
||||
(sort ~(tap by queued) aor)
|
||||
::
|
||||
=/ running
|
||||
=/ active (~(run by yokes.state) |=(yoke [%.y +<]))
|
||||
(sort ~(tap by active) aor)
|
||||
::
|
||||
=/ maz=(list mass)
|
||||
:~ [%foreign %.y contacts.state]
|
||||
[%blocked %.n blocked]
|
||||
[%active %.n running]
|
||||
==
|
||||
``mass+!>(maz)
|
||||
::
|
||||
?: ?& =(%u care)
|
||||
=(~ path)
|
||||
=([%$ %da now] coin)
|
||||
|
@ -366,20 +366,6 @@
|
||||
%receive
|
||||
=^ moves state.ax (receive:client +.task)
|
||||
[moves light-gate]
|
||||
::
|
||||
%wegh
|
||||
:_ light-gate
|
||||
:~ :* duct
|
||||
%give
|
||||
%mass
|
||||
^- mass
|
||||
:+ %iris %|
|
||||
:~ nex+&+next-id.state.ax
|
||||
outbound+&+outbound-duct.state.ax
|
||||
by-id+&+connection-by-id.state.ax
|
||||
by-duct+&+connection-by-duct.state.ax
|
||||
axle+&+ax
|
||||
== == ==
|
||||
==
|
||||
:: http-client issues no requests to other vanes
|
||||
::
|
||||
@ -404,6 +390,18 @@
|
||||
:: +scry: request a path in the urbit namespace
|
||||
::
|
||||
++ scry
|
||||
|= *
|
||||
|= {fur/(unit (set monk)) ren/@tas why/shop syd/desk lot/coin tyl/path}
|
||||
^- (unit (unit cage))
|
||||
?. ?=(%& -.why) ~
|
||||
=* his p.why
|
||||
?: &(=(ren %$) =(tyl /whey))
|
||||
=/ maz=(list mass)
|
||||
:~ nex+&+next-id.state.ax
|
||||
outbound+&+outbound-duct.state.ax
|
||||
by-id+&+connection-by-id.state.ax
|
||||
by-duct+&+connection-by-duct.state.ax
|
||||
axle+&+ax
|
||||
==
|
||||
``mass+!>(maz)
|
||||
[~ ~]
|
||||
--
|
||||
|
@ -488,20 +488,6 @@
|
||||
::
|
||||
%private-keys
|
||||
(curd abet:~(private-keys ~(feed su hen our now pki etn) hen))
|
||||
::
|
||||
%wegh
|
||||
%_ +>
|
||||
moz
|
||||
:_ moz
|
||||
^- move
|
||||
:^ hen %give %mass
|
||||
^- mass
|
||||
:+ %jael %|
|
||||
:~ pki+&+pki
|
||||
etn+&+etn
|
||||
dot+&+lex
|
||||
==
|
||||
==
|
||||
::
|
||||
:: authenticated remote request
|
||||
:: {$west p/ship q/path r/*}
|
||||
@ -1009,6 +995,12 @@
|
||||
::
|
||||
?. =(lot [%$ %da now]) ~
|
||||
?. =(%$ ren) [~ ~]
|
||||
?: =(tyl /whey)
|
||||
=/ maz=(list mass)
|
||||
:~ pki+&+pki.lex
|
||||
etn+&+etn.lex
|
||||
==
|
||||
``mass+!>(maz)
|
||||
?+ syd
|
||||
~
|
||||
::
|
||||
|
@ -211,9 +211,6 @@
|
||||
:: kernel upgraded
|
||||
::
|
||||
[%vega ~]
|
||||
:: produce labeled state (for memory measurement)
|
||||
::
|
||||
[%wegh ~]
|
||||
:: receive message via %ames
|
||||
::
|
||||
:: TODO: move .vane from $plea to here
|
||||
@ -396,7 +393,6 @@
|
||||
:: %sift: limit verbosity to .ships
|
||||
:: %spew: set verbosity toggles
|
||||
:: %vega: kernel reload notification
|
||||
:: %wegh: request for memory usage report
|
||||
::
|
||||
+$ task
|
||||
$% [%hear =lane =blob]
|
||||
@ -411,7 +407,6 @@
|
||||
[%sift ships=(list ship)]
|
||||
[%spew veb=(list verb)]
|
||||
$>(%vega vane-task)
|
||||
$>(%wegh vane-task)
|
||||
==
|
||||
:: $gift: effect from ames
|
||||
::
|
||||
@ -425,7 +420,6 @@
|
||||
::
|
||||
:: System and Lifecycle Gifts
|
||||
::
|
||||
:: %mass: memory usage report
|
||||
:: %turf: domain report, relayed from jael
|
||||
::
|
||||
+$ gift
|
||||
@ -435,7 +429,6 @@
|
||||
[%lost ~]
|
||||
[%send =lane =blob]
|
||||
::
|
||||
[%mass p=mass]
|
||||
[%turf turfs=(list turf)]
|
||||
==
|
||||
-- ::able
|
||||
@ -503,7 +496,6 @@
|
||||
|%
|
||||
++ gift :: out result <-$
|
||||
$% [%doze p=(unit @da)] :: next alarm
|
||||
[%mass p=mass] :: memory usage
|
||||
[%wake error=(unit tang)] :: wakeup or failed
|
||||
[%meta p=vase]
|
||||
==
|
||||
@ -518,7 +510,6 @@
|
||||
$>(%vega vane-task) :: report upgrade
|
||||
[%wait p=@da] :: set alarm
|
||||
[%wake ~] :: timer activate
|
||||
$>(%wegh vane-task) :: report memory
|
||||
==
|
||||
-- ::able
|
||||
-- ::behn
|
||||
@ -540,7 +531,6 @@
|
||||
{$ergo p/@tas q/mode} :: version update
|
||||
{$hill p/(list @tas)} :: mount points
|
||||
[%done error=(unit error:ames)] :: ames message (n)ack
|
||||
{$mass p/mass} :: memory usage
|
||||
{$mere p/(each (set path) (pair term tang))} :: merge result
|
||||
{$note p/@tD q/tank} :: debug message
|
||||
{$ogre p/@tas} :: delete mount point
|
||||
@ -574,7 +564,6 @@
|
||||
$>(%vega vane-task) :: report upgrade
|
||||
{$warp wer/ship rif/riff} :: internal file req
|
||||
{$werp who/ship wer/ship rif/riff} :: external file req
|
||||
$>(%wegh vane-task) :: report memory
|
||||
$>(%plea vane-task) :: ames request
|
||||
== ::
|
||||
-- ::able
|
||||
@ -796,10 +785,10 @@
|
||||
{$init p/@p} :: set owner
|
||||
{$logo ~} :: logout
|
||||
{$lyra p/@t q/@t} :: upgrade kernel
|
||||
{$mass p/mass} :: memory usage
|
||||
{$pack ~} :: compact memory
|
||||
{$veer p/@ta q/path r/@t} :: install vane
|
||||
{$verb ~} :: verbose mode
|
||||
[%whey ~] :: memory report
|
||||
== ::
|
||||
++ task :: in request ->$
|
||||
$~ [%vega ~] ::
|
||||
@ -910,9 +899,6 @@
|
||||
:: not allowed.
|
||||
::
|
||||
[%bound accepted=? =binding]
|
||||
:: memory usage report
|
||||
::
|
||||
[%mass p=mass]
|
||||
==
|
||||
::
|
||||
++ task
|
||||
@ -959,9 +945,6 @@
|
||||
:: the first place.
|
||||
::
|
||||
[%disconnect =binding]
|
||||
:: memory usage request
|
||||
::
|
||||
$>(%wegh vane-task)
|
||||
==
|
||||
::
|
||||
--
|
||||
@ -1215,9 +1198,6 @@
|
||||
:: %vega: report kernel upgrade
|
||||
::
|
||||
$>(%vega vane-task)
|
||||
:: %wegh: produce memory usage information
|
||||
::
|
||||
$>(%wegh vane-task)
|
||||
:: %wipe: wipes stored builds
|
||||
::
|
||||
[%wipe percent-to-remove=@ud]
|
||||
@ -1225,10 +1205,7 @@
|
||||
:: +gift:able:ford: responses from ford
|
||||
::
|
||||
+= gift
|
||||
$% :: %mass: memory usage; response to %wegh +task
|
||||
::
|
||||
[%mass p=mass]
|
||||
:: %made: build result; response to %build +task
|
||||
$% :: %made: build result; response to %build +task
|
||||
::
|
||||
$: %made
|
||||
:: date: formal date of the build
|
||||
@ -1897,7 +1874,6 @@
|
||||
++ gift :: outgoing result
|
||||
$% [%boon payload=*] :: ames response
|
||||
[%done error=(unit error:ames)] :: ames message (n)ack
|
||||
[%mass p=mass] :: memory usage
|
||||
[%onto p=(each suss tang)] :: about agent
|
||||
[%unto p=sign:agent] ::
|
||||
== ::
|
||||
@ -1911,7 +1887,6 @@
|
||||
$>(%trim vane-task) :: trim state
|
||||
$>(%vega vane-task) :: report upgrade
|
||||
$>(%plea vane-task) :: network request
|
||||
$>(%wegh vane-task) :: report memory
|
||||
== ::
|
||||
-- ::able
|
||||
++ bitt (map duct (pair ship path)) :: incoming subs
|
||||
@ -2043,9 +2018,6 @@
|
||||
:: %response: response to the caller
|
||||
::
|
||||
[%http-response =client-response]
|
||||
:: memory usage report
|
||||
::
|
||||
[%mass p=mass]
|
||||
==
|
||||
::
|
||||
++ task
|
||||
@ -2071,9 +2043,6 @@
|
||||
:: receives http data from outside
|
||||
::
|
||||
[%receive id=@ud =http-event:http]
|
||||
:: memory usage request
|
||||
::
|
||||
$>(%wegh vane-task)
|
||||
==
|
||||
--
|
||||
:: +client-response: one or more client responses given to the caller
|
||||
@ -2157,7 +2126,6 @@
|
||||
:: ::
|
||||
++ gift :: out result <-$
|
||||
$% [%init p=ship] :: report install unix
|
||||
[%mass p=mass] :: memory usage report
|
||||
[%done error=(unit error:ames)] :: ames message (n)ack
|
||||
[%boon payload=*] :: ames response
|
||||
[%private-keys =life vein=(map life ring)] :: private keys
|
||||
@ -2183,7 +2151,6 @@
|
||||
$>(%trim vane-task) :: trim state
|
||||
[%turf ~] :: view domains
|
||||
$>(%vega vane-task) :: report upgrade
|
||||
$>(%wegh vane-task) :: memory usage request
|
||||
$>(%plea vane-task) :: ames request
|
||||
== ::
|
||||
::
|
||||
|
Loading…
Reference in New Issue
Block a user