gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Revert "randomize based on self address"

Browse Source 
This reverts commit 6230eb28a6.
This commit is contained in:
Chris Lu
2019-01-28 12:12:51 -08:00
parent 6230eb28a6
commit 1334507595
2 changed files with 0 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
weed/server/raft_server.go
View File

@@ -14,7 +14,6 @@ import (
"github.com/chrislusf/raft" "github.com/chrislusf/raft"
"github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/glog"
"github.com/chrislusf/seaweedfs/weed/topology" "github.com/chrislusf/seaweedfs/weed/topology"
"github.com/chrislusf/seaweedfs/weed/util"
"github.com/gorilla/mux" "github.com/gorilla/mux"
) )
@@ -72,7 +71,6 @@ func NewRaftServer(r *mux.Router, peers []string, httpAddr string, dataDir strin
for _, peer := range s.peers { for _, peer := range s.peers {
s.raftServer.AddPeer(peer, "http://"+peer) s.raftServer.AddPeer(peer, "http://"+peer)
} }
rand.Seed(util.HashBytesToInt64([]byte(httpAddr)))
time.Sleep(time.Duration(1000+rand.Int31n(3000)) * time.Millisecond) time.Sleep(time.Duration(1000+rand.Int31n(3000)) * time.Millisecond)
if s.raftServer.IsLogEmpty() { if s.raftServer.IsLogEmpty() {
// Initialize the server by joining itself. // Initialize the server by joining itself.

9
weed/util/randomizer.go
View File

@@ -1,9 +0,0 @@
package util
import "hash/fnv"
func HashBytesToInt64(x []byte) int64 {
hash := fnv.New64()
hash.Write(x)
return int64(hash.Sum64())
}