aboutsummaryrefslogtreecommitdiff
path: root/weed/server/raft_server.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/server/raft_server.go')
-rw-r--r--weed/server/raft_server.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/server/raft_server.go b/weed/server/raft_server.go
index e2a091e83..01ca41aac 100644
--- a/weed/server/raft_server.go
+++ b/weed/server/raft_server.go
@@ -3,6 +3,7 @@ package weed_server
import (
"encoding/json"
"io/ioutil"
+ "math/rand"
"os"
"path"
"reflect"
@@ -68,7 +69,7 @@ func NewRaftServer(r *mux.Router, peers []string, httpAddr string, dataDir strin
for _, peer := range s.peers {
s.raftServer.AddPeer(peer, "http://"+peer)
}
- time.Sleep(2 * time.Second)
+ time.Sleep(time.Duration(1000+rand.Int31n(3000)) * time.Millisecond)
if s.raftServer.IsLogEmpty() {
// Initialize the server by joining itself.
glog.V(0).Infoln("Initializing new cluster")