ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-11-30 10:46:11 +03:00
Code Issues Packages Projects Releases Wiki Activity

graph-join: crash on backoff and fix scry mold

Browse Source
This commit is contained in:
Liam Fitzgerald 2021-01-21 10:43:25 +10:00
parent 69704c6a80
commit 3bf03ffc9b
No known key found for this signature in database
GPG Key ID: D390E12C61D1CFFB
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/arvo/ted/graph/join.hoon
View File

@ -31,13 +31,14 @@
(en-path:resource rid) (en-path:resource rid)
=/ hold=@dr ~s0..8000 =/ hold=@dr ~s0..8000
|- ^- form:m |- ^- form:m
?> (lte hold ~m5)
=* loop $ =* loop $
;< u-group=(unit group) bind:m ;< u-group=(unit group) bind:m
(scry:strandio ,(unit group) (weld /gx/group-store/groups (snoc pax %noun))) (scry:strandio ,(unit group) (weld /gx/group-store/groups (snoc pax %noun)))
?^ u-group ?^ u-group
(pure:m ~) (pure:m ~)
;< ~ bind:m (sleep:strandio hold) ;< ~ bind:m (sleep:strandio hold)
=. hold (min (mul hold 2) ~m5) =. hold (mul hold 2)
loop loop
:: ::
++ wait-for-md ++ wait-for-md
@ -48,13 +49,14 @@
(en-path:resource rid) (en-path:resource rid)
=/ hold=@dr ~s0..8000 =/ hold=@dr ~s0..8000
|- ^- form:m |- ^- form:m
?> (lte hold ~m5)
=* loop $ =* loop $
;< groups=(set path) bind:m ;< groups=(jug path md-resource) bind:m
(scry:strandio ,(set path) /gy/metadata-store/group-indices) (scry:strandio ,(jug path md-resource) /gy/metadata-store/group-indices)
?: (~(has in groups) pax) ?: (~(has by groups) pax)
(pure:m ~) (pure:m ~)
;< ~ bind:m (sleep:strandio hold) ;< ~ bind:m (sleep:strandio hold)
=. hold (min (mul hold 2) ~m5) =. hold (mul hold 2)
loop loop
-- --
:: ::