zephyr/chord
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

wrap stabilization errors

Browse Source
This commit is contained in:
Branden J Brown 2025-03-13 22:10:28 -04:00
parent 7a04a22f76
commit 8e73402c58
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
chord/client.go
View File

@ -88,14 +88,17 @@ func Stabilize(ctx context.Context, cl Client, n *Node) error {
pred, _, err := cl.Neighbors(ctx, n.Successor())
if err != nil {
// TODO(zeph): replication
return err
return fmt.Errorf("acquiring successor neighbors for stabilization: %w", err)
}
if pred.IsValid() && contains(n.self.id, n.Successor().id, pred.id) && pred.id != n.Successor().id {
// Shift in the new successor.
copy(n.succ[1:], n.succ)
n.succ[0] = pred
}
return cl.Notify(ctx, n, n.Successor())
if err := cl.Notify(ctx, n, n.Successor()); err != nil {
return fmt.Errorf("notifying successor: %w", err)
}
return nil
}
// Notify informs n that p considers n to be p's successor.