Skip to content

Commit e62990d

Browse files
Fix data race when updating leader
Signed-off-by: Maurice van Veen <[email protected]>
1 parent d9454d3 commit e62990d

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

server/jetstream_cluster_4_test.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3967,7 +3967,9 @@ func TestJetStreamClusterDesyncAfterErrorDuringCatchup(t *testing.T) {
39673967
for _, n := range server.raftNodes {
39683968
rn := n.(*raft)
39693969
if rn.accName == "$G" {
3970+
rn.Lock()
39703971
rn.updateLeader(noLeader)
3972+
rn.Unlock()
39713973
}
39723974
}
39733975

0 commit comments

Comments
 (0)