From 80668e8de104f3849c32a0a9e415e1771f1a2394 Mon Sep 17 00:00:00 2001 From: Neil Twigg Date: Fri, 26 Jul 2024 17:47:45 +0100 Subject: [PATCH] De-flake `TestNRGSwitchStateClearsQueues` Signed-off-by: Neil Twigg --- server/raft_test.go | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/server/raft_test.go b/server/raft_test.go index 4baaaa85604..5b8e775d7cd 100644 --- a/server/raft_test.go +++ b/server/raft_test.go @@ -364,12 +364,26 @@ func TestNRGSwitchStateClearsQueues(t *testing.T) { rg := c.createMemRaftGroup("TEST", 3, newStateAdder) rg.waitOnLeader() + // Ensure there are no other nodes running that could + // send something into our IP queues or it may break the + // below assertions. + for _, n := range rg { + if !n.node().Leader() { + n.stop() + } + } + rg.lockAll() defer rg.unlockAll() n := rg.leader().node().(*raft) + require_Equal(t, n.prop.len(), 0) + require_Equal(t, n.resp.len(), 0) + n.prop.push(&Entry{}) n.resp.push(&appendEntryResponse{}) + require_Equal(t, n.prop.len(), 1) + require_Equal(t, n.resp.len(), 1) n.switchState(Follower) require_Equal(t, n.prop.len(), 0)