aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRyan Russell <ryanrussell@users.noreply.github.com>2022-09-15 05:12:30 -0500
committerGitHub <noreply@github.com>2022-09-15 03:12:30 -0700
commitc4fc007630c42118ecd615092f2caaeb9dd8617f (patch)
tree87084ce4b2d39ae253264cf6cb2a4df94bb7f425
parentc202d4c1b0894b396bff1b641f2869caa810ebed (diff)
downloadseaweedfs-c4fc007630c42118ecd615092f2caaeb9dd8617f.tar.xz
seaweedfs-c4fc007630c42118ecd615092f2caaeb9dd8617f.zip
refactor(raft_hashicorp): `timeSpeep` -> `timeSleep` (#3694)
Signed-off-by: Ryan Russell <git@ryanrussell.org> Signed-off-by: Ryan Russell <git@ryanrussell.org>
-rw-r--r--weed/server/raft_hashicorp.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/server/raft_hashicorp.go b/weed/server/raft_hashicorp.go
index 636ba8c37..8f81924d1 100644
--- a/weed/server/raft_hashicorp.go
+++ b/weed/server/raft_hashicorp.go
@@ -154,9 +154,9 @@ func NewHashicorpRaftServer(option *RaftServerOption) (*RaftServer, error) {
cfg := s.AddPeersConfiguration()
// Need to get lock, in case all servers do this at the same time.
peerIdx := getPeerIdx(s.serverAddr, s.peers)
- timeSpeep := time.Duration(float64(c.LeaderLeaseTimeout) * (rand.Float64()*0.25 + 1) * float64(peerIdx))
- glog.V(0).Infof("Bootstrapping idx: %d sleep: %v new cluster: %+v", peerIdx, timeSpeep, cfg)
- time.Sleep(timeSpeep)
+ timeSleep := time.Duration(float64(c.LeaderLeaseTimeout) * (rand.Float64()*0.25 + 1) * float64(peerIdx))
+ glog.V(0).Infof("Bootstrapping idx: %d sleep: %v new cluster: %+v", peerIdx, timeSleep, cfg)
+ time.Sleep(timeSleep)
f := s.RaftHashicorp.BootstrapCluster(cfg)
if err := f.Error(); err != nil {
return nil, fmt.Errorf("raft.Raft.BootstrapCluster: %v", err)