Browse Source

integration: expose ElectionTimeout, multiply ticks to timeout

To be consistent with etcdserver

Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
Gyu-Ho Lee 8 years ago
parent
commit
a41f3b64aa
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
 }
 
-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() }

+ 2 - 2
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)