Browse Source

change DefaultHeartbeat to DefaultElectionTimeout
modified: raft_server.go
modified: transporter_test.go

Ivan7702 12 years ago
parent
commit
fec65d8717
2 changed files with 5 additions and 5 deletions
  1. 2 2
      raft_server.go
  2. 3 3
      transporter_test.go

+ 2 - 2
raft_server.go

@@ -30,8 +30,8 @@ var r *raftServer
 func newRaftServer(name string, url string, listenHost string, tlsConf *TLSConfig, tlsInfo *TLSInfo) *raftServer {
 
 	// Create transporter for raft
-	raftTransporter := newTransporter(tlsConf.Scheme, tlsConf.Client, raft.electionTimeout)
-
+	raftTransporter := newTransporter(tlsConf.Scheme, tlsConf.Client, raft.DefaultElectionTimeout)
+	
 	// Create raft server
 	server, err := raft.NewServer(name, dirPath, raftTransporter, etcdStore, nil)
 

+ 3 - 3
transporter_test.go

@@ -12,12 +12,12 @@ func TestTransporterTimeout(t *testing.T) {
 
 	ts := newTransporter("http", conf, time.Second)
 
-	_, err := ts.Get("http://127.0.0.2:7000")
+	_, err := ts.Get("http://google.com:9999") // it doesn't exisit
 	if err == nil || err.Error() != "Wait Response Timeout: 1s" {
-		t.Fatal("timeout error: ", err.Error())
+		t.Fatal("timeout error: ", err.Error( ))
 	}
 
-	_, err = ts.Post("http://127.0.0.2:7000", nil)
+	_, err = ts.Post("http://google.com:9999", nil) // it doesn't exisit
 	if err == nil || err.Error() != "Wait Response Timeout: 1s" {
 		t.Fatal("timeout error: ", err.Error())
 	}