mirror of
https://github.com/urbit/shrub.git
synced 2025-01-01 17:16:47 +03:00
real queueing for clay writes
This commit is contained in:
parent
4d1c72dfb4
commit
89ce5cedbe
1115
sys/vane/clay.hoon
1115
sys/vane/clay.hoon
File diff suppressed because it is too large
Load Diff
@ -97,6 +97,7 @@
|
||||
== ::
|
||||
++ sign-behn ::
|
||||
$% {$mass p/mass} ::
|
||||
{$writ p/riot:clay} ::
|
||||
== ::
|
||||
++ sign-clay ::
|
||||
$% {$mere p/(each (set path) (pair term tang))} ::
|
||||
@ -420,7 +421,7 @@
|
||||
{$c $note *}
|
||||
(from %out (tuba p.sih ' ' ~(ram re q.sih)))
|
||||
::
|
||||
{$c $writ *}
|
||||
{?($b $c) $writ *}
|
||||
init
|
||||
::
|
||||
{$c $mere *}
|
||||
|
@ -161,9 +161,9 @@
|
||||
:: +sign: private response from another vane to ford
|
||||
::
|
||||
+= sign
|
||||
$% :: %c: from clay
|
||||
$? :: %c: from clay
|
||||
::
|
||||
$: %c
|
||||
$: ?(%b %c)
|
||||
:: %writ: internal (intra-ship) file response
|
||||
::
|
||||
$% $: %writ
|
||||
@ -6258,7 +6258,7 @@
|
||||
++ take-rebuilds
|
||||
^- [(list move) ford-state]
|
||||
::
|
||||
?> ?=([%c %wris *] sign)
|
||||
?> ?=([@tas %wris *] sign)
|
||||
=+ [ship desk date]=(raid:wired t.wire ~[%p %tas %da])
|
||||
=/ disc [ship desk]
|
||||
::
|
||||
@ -6289,7 +6289,7 @@
|
||||
++ take-unblocks
|
||||
^- [(list move) ford-state]
|
||||
::
|
||||
?> ?=([%c %writ *] sign)
|
||||
?> ?=([@tas %writ *] sign)
|
||||
:: scry-request: the +scry-request we had previously blocked on
|
||||
::
|
||||
=/ =scry-request
|
||||
|
@ -1445,7 +1445,7 @@
|
||||
net:(fall (~(get by pos.eth) who) *point)
|
||||
*[life pass continuity-number=@ud [? @p] (unit @p)]
|
||||
%+ weld
|
||||
%- flop
|
||||
:: %- flop
|
||||
^- (list move)
|
||||
:~ [hen %slip %a %sunk who rit]
|
||||
[hen %slip %c %sunk who rit]
|
||||
|
@ -424,18 +424,23 @@
|
||||
++ able ^?
|
||||
|%
|
||||
++ note :: out request $->
|
||||
$% $: %d :: to %dill
|
||||
$% [$flog =flog:dill]
|
||||
$% $: %b :: to %behn
|
||||
$% [%wait p=@da]
|
||||
== ==
|
||||
$: %d :: to %dill
|
||||
$% [%flog =flog:dill]
|
||||
== == ==
|
||||
++ gift :: out result <-$
|
||||
$% [%doze p=(unit @da)] :: next alarm
|
||||
[%mass p=mass] :: memory usage
|
||||
[%wake error=(unit tang)] :: wakeup or failed
|
||||
[%meta p=vase]
|
||||
==
|
||||
++ task :: in request ->$
|
||||
$% [%born ~] :: new unix process
|
||||
[%crud tag=@tas =tang] :: error with trace
|
||||
[%rest p=@da] :: cancel alarm
|
||||
[%drip p=vase] :: give in next event
|
||||
[%vega ~] :: report upgrade
|
||||
[%wait p=@da] :: set alarm
|
||||
[%wake ~] :: timer activate
|
||||
@ -7087,7 +7092,11 @@
|
||||
==
|
||||
++ sign-arvo :: in result $<-
|
||||
$% {$a gift:able:ames}
|
||||
{$b gift:able:behn}
|
||||
$: $b
|
||||
$% gift:able:behn
|
||||
[%writ ~]
|
||||
==
|
||||
==
|
||||
{$c gift:able:clay}
|
||||
{$d gift:able:dill}
|
||||
{$e gift:able:eyre}
|
||||
|
Loading…
Reference in New Issue
Block a user