Ything-RepoMirrors/rqlite
1
0
Fork 0
mirror of https://github.com/rqlite/rqlite.git synced 2026-01-25 04:16:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Deflake CDC test

Browse Source
This commit is contained in:
Philip O'Toole
2025-10-14 08:59:10 -04:00
parent 6717f27768
commit 778e99f527
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
cdc/service_cluster_test.go
View File

@@ -263,14 +263,11 @@ func Test_ClusterHWMPropagation(t *testing.T) {
// Check internals
testPoll(t, func() bool {
return services[1].hwmFollowerUpdated.Load() != 0 && services[2].hwmFollowerUpdated.Load() != 0
}, time.Second)
if services[0].hwmLeaderUpdated.Load() == 0 {
t.Fatalf("expected leader to have updated HWM, got 0")
}
if services[0].hwmFollowerUpdated.Load() != 0 {
t.Fatalf("expected leader to node have follower-updated HWM")
}
return services[0].hwmLeaderUpdated.Load() != 0 &&
services[0].hwmFollowerUpdated.Load() == 0 &&
services[1].hwmFollowerUpdated.Load() != 0 &&
services[2].hwmFollowerUpdated.Load() != 0
}, 2*time.Second)
}
// Test_ClusterLeadershipChange tests leadership changes and catch-up behavior