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

graph: make the join thread back off

Browse Source 
Pushes the pathological case back a bit, but doesn't make it stop trying.
This commit is contained in:
fang 2021-01-06 23:12:01 +01:00
parent dde827b2d3
commit 69704c6a80
No known key found for this signature in database
GPG Key ID: EB035760C1BBA972
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -29,13 +29,15 @@
^- form:m ^- form:m
=/ pax =/ pax
(en-path:resource rid) (en-path:resource rid)
=/ hold=@dr ~s0..8000
|- ^- form:m |- ^- form:m
=* 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 `@dr`(div ~s1 2)) ;< ~ bind:m (sleep:strandio hold)
=. hold (min (mul hold 2) ~m5)
loop loop
:: ::
++ wait-for-md ++ wait-for-md
@ -44,13 +46,15 @@
^- form:m ^- form:m
=/ pax =/ pax
(en-path:resource rid) (en-path:resource rid)
=/ hold=@dr ~s0..8000
|- ^- form:m |- ^- form:m
=* loop $ =* loop $
;< groups=(set path) bind:m ;< groups=(set path) bind:m
(scry:strandio ,(set path) /gy/metadata-store/group-indices) (scry:strandio ,(set path) /gy/metadata-store/group-indices)
?: (~(has in groups) pax) ?: (~(has in groups) pax)
(pure:m ~) (pure:m ~)
;< ~ bind:m (sleep:strandio `@dr`(div ~s1 2)) ;< ~ bind:m (sleep:strandio hold)
=. hold (min (mul hold 2) ~m5)
loop loop
-- --
:: ::