diff --git a/integration/cluster.go b/integration/cluster.go index 0e31a04de..be0ba8c53 100644 --- a/integration/cluster.go +++ b/integration/cluster.go @@ -608,8 +608,8 @@ func (m *member) listenGRPC() error { return nil } -func (m *member) electionTimeout() time.Duration { - return time.Duration(m.s.Cfg.ElectionTicks) * time.Millisecond +func (m *member) ElectionTimeout() time.Duration { + return time.Duration(m.s.Cfg.ElectionTicks*int(m.s.Cfg.TickMs)) * time.Millisecond } func (m *member) ID() types.ID { return m.s.ID() } diff --git a/integration/network_partition_test.go b/integration/network_partition_test.go index b94d6bc4c..cfbdda02a 100644 --- a/integration/network_partition_test.go +++ b/integration/network_partition_test.go @@ -44,7 +44,7 @@ func TestNetworkPartition5MembersLeaderInMinority(t *testing.T) { clus.waitNoLeader(t, minorityMembers) // wait extra election timeout - time.Sleep(2 * majorityMembers[0].electionTimeout()) + time.Sleep(2 * majorityMembers[0].ElectionTimeout()) // new leader must be from majority clus.waitLeader(t, majorityMembers) @@ -92,7 +92,7 @@ func testNetworkPartition5MembersLeaderInMajority(t *testing.T) error { clus.waitNoLeader(t, minorityMembers) // wait extra election timeout - time.Sleep(2 * majorityMembers[0].electionTimeout()) + time.Sleep(2 * majorityMembers[0].ElectionTimeout()) // leader must be hold in majority leadIndex2 := clus.waitLeader(t, majorityMembers)