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

check predecessor before stabilizing

Browse Source
This commit is contained in:
Branden J Brown 2025-03-14 10:01:00 -04:00
parent 4c79714fcd
commit 6316576823
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
chord/httpnode/server.go
View File

@ -55,6 +55,7 @@ func (n *Node) Router() http.Handler {
// Check performs checks that implement the Chord protocol. // Check performs checks that implement the Chord protocol.
// It must be called periodically while the node is alive. // It must be called periodically while the node is alive.
func (n *Node) Check(ctx context.Context) error { func (n *Node) Check(ctx context.Context) error {
chord.CheckPredecessor(ctx, n.client, n.self)
if err := chord.Stabilize(ctx, n.client, n.self); err != nil { if err := chord.Stabilize(ctx, n.client, n.self); err != nil {
return fmt.Errorf("failed to stabilize: %w", err) return fmt.Errorf("failed to stabilize: %w", err)
} }
@ -62,7 +63,6 @@ func (n *Node) Check(ctx context.Context) error {
// if err := chord.FixFingers(ctx, n.client, n.self); err != nil { // if err := chord.FixFingers(ctx, n.client, n.self); err != nil {
// return fmt.Errorf("failed to fix fingers: %w", err) // return fmt.Errorf("failed to fix fingers: %w", err)
// } // }
chord.CheckPredecessor(ctx, n.client, n.self)
return nil return nil
} }