From fec65d8717d6667e11d3c785c4e7a8516c669e3a Mon Sep 17 00:00:00 2001 From: Ivan7702 Date: Mon, 2 Sep 2013 17:05:35 -0400 Subject: [PATCH] change DefaultHeartbeat to DefaultElectionTimeout modified: raft_server.go modified: transporter_test.go --- raft_server.go | 4 ++-- transporter_test.go | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/raft_server.go b/raft_server.go index fb1294840..aeaa377a4 100644 --- a/raft_server.go +++ b/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) diff --git a/transporter_test.go b/transporter_test.go index 88fefdcf7..7dec4ea2e 100644 --- a/transporter_test.go +++ b/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()) }