Browse Source

Merge pull request #8783 from gyuho/election-timeout

integration: expose ElectionTimeout method
Gyu-Ho Lee 8 years ago
parent
commit
2200450022
2 changed files with 4 additions and 4 deletions
  1. 2 2
      integration/cluster.go
  2. 2 2
      integration/network_partition_test.go

+ 2 - 2
integration/cluster.go

@@ -608,8 +608,8 @@ func (m *member) listenGRPC() error {
 	return nil
 	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() }
 func (m *member) ID() types.ID { return m.s.ID() }

+ 2 - 2
integration/network_partition_test.go

@@ -44,7 +44,7 @@ func TestNetworkPartition5MembersLeaderInMinority(t *testing.T) {
 	clus.waitNoLeader(t, minorityMembers)
 	clus.waitNoLeader(t, minorityMembers)
 
 
 	// wait extra election timeout
 	// wait extra election timeout
-	time.Sleep(2 * majorityMembers[0].electionTimeout())
+	time.Sleep(2 * majorityMembers[0].ElectionTimeout())
 
 
 	// new leader must be from majority
 	// new leader must be from majority
 	clus.waitLeader(t, majorityMembers)
 	clus.waitLeader(t, majorityMembers)
@@ -92,7 +92,7 @@ func testNetworkPartition5MembersLeaderInMajority(t *testing.T) error {
 	clus.waitNoLeader(t, minorityMembers)
 	clus.waitNoLeader(t, minorityMembers)
 
 
 	// wait extra election timeout
 	// wait extra election timeout
-	time.Sleep(2 * majorityMembers[0].electionTimeout())
+	time.Sleep(2 * majorityMembers[0].ElectionTimeout())
 
 
 	// leader must be hold in majority
 	// leader must be hold in majority
 	leadIndex2 := clus.waitLeader(t, majorityMembers)
 	leadIndex2 := clus.waitLeader(t, majorityMembers)