This commit is contained in:
Xiang Li
2013-07-31 16:44:29 -07:00
2 changed files with 4 additions and 4 deletions

View File

@ -105,7 +105,7 @@ const (
) )
const ( const (
ELECTIONTIMTOUT = 200 * time.Millisecond ELECTIONTIMEOUT = 200 * time.Millisecond
HEARTBEATTIMEOUT = 50 * time.Millisecond HEARTBEATTIMEOUT = 50 * time.Millisecond
// Timeout for internal raft http connection // Timeout for internal raft http connection
@ -237,7 +237,7 @@ func startRaft(securityType int) {
} }
} }
raftServer.SetElectionTimeout(ELECTIONTIMTOUT) raftServer.SetElectionTimeout(ELECTIONTIMEOUT)
raftServer.SetHeartbeatTimeout(HEARTBEATTIMEOUT) raftServer.SetHeartbeatTimeout(HEARTBEATTIMEOUT)
raftServer.Start() raftServer.Start()

View File

@ -55,8 +55,8 @@ func TestKillLeader(t *testing.T) {
totalTime += take totalTime += take
avgTime := totalTime / (time.Duration)(i+1) avgTime := totalTime / (time.Duration)(i+1)
fmt.Println("Leader election time is ", take, "with election timeout", ELECTIONTIMTOUT) fmt.Println("Leader election time is ", take, "with election timeout", ELECTIONTIMEOUT)
fmt.Println("Leader election time average is", avgTime, "with election timeout", ELECTIONTIMTOUT) fmt.Println("Leader election time average is", avgTime, "with election timeout", ELECTIONTIMEOUT)
etcds[num], err = os.StartProcess("etcd", argGroup[num], procAttr) etcds[num], err = os.StartProcess("etcd", argGroup[num], procAttr)
} }
} }