gsadmin/pulse
1
0
Fork 0
mirror of https://github.com/rcourtman/Pulse.git synced 2026-09-10 02:25:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge candidate 20260906T102520Z-core-runtime

Browse Source 
Integrate the reviewed host ownership rollback regression test without re-parenting its exact candidate commit.

Change-source: pulse-maintainer
This commit is contained in:
pulse-triage[bot]
2026-09-06 11:40:17 +01:00
parent 8c5fdd6e20 1a3450a5b0
commit d6dc795128
1 changed files with 46 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/config/host_continuity_test.go
+46
View File
@@ -308,3 +308,49 @@ func TestHostContinuityNodeLinkReplacesDormantOwner(t *testing.T) {
t.Fatal("replacement reservation incorrect")
}
}
// Replacing a dormant owner changes two entries even though the caller supplies
// only the new owner. A failed transaction must roll both back, including the
// reservation used by automatic matching before either host reconnects.
func TestHostContinuityNodeLinkReplacementRollback(t *testing.T) {
dir := t.TempDir()
s := NewHostContinuityStore(dir, nil)
for _, entry := range []HostContinuityEntry{
{HostID: "owner", LinkedNodeID: "node", NodeLinkSource: "manual", ReportStreamID: "owner-stream", ReportSequence: 42},
{HostID: "replacement", NodeLinkSource: "unlinked", ReportStreamID: "replacement-stream", ReportSequence: 17},
} {
if err := s.Upsert(entry); err != nil {
t.Fatal(err)
}
}
assertOwner := func(store *HostContinuityStore, ownerID string) {
t.Helper()
for id, sequence := range map[string]uint64{"owner": 42, "replacement": 17} {
entry, ok := store.Get(id)
wantNode, wantSource := "", "unlinked"
if id == ownerID {
wantNode, wantSource = "node", "manual"
}
if !ok || entry.LinkedNodeID != wantNode || entry.NodeLinkSource != wantSource || entry.ReportSequence != sequence {
t.Fatalf("%s ownership or report watermark changed: %+v", id, entry)
}
if got := store.NodeLinkReservedByOther(id, "node"); got != (id != ownerID) {
t.Fatalf("reservation for %s = %v, owner %s", id, got, ownerID)
}
}
}
s.fs = &mockFSError{FileSystem: defaultFileSystem{}, writeError: errors.New("synthetic journal failure")}
links := []HostContinuityEntry{{HostID: "replacement", LinkedNodeID: "node", NodeLinkSource: "manual"}}
if err := s.SetNodeLinkIntents(links); err == nil {
t.Fatal("replacement acknowledged despite failed persistence")
}
assertOwner(s, "owner")
assertOwner(NewHostContinuityStore(dir, nil), "owner")
// Retry on the same store, not a reload that could conceal memory corruption.
s.fs = defaultFileSystem{}
if err := s.SetNodeLinkIntents(links); err != nil {
t.Fatal(err)
}
assertOwner(s, "replacement")
assertOwner(NewHostContinuityStore(dir, nil), "replacement")
}