diff --git a/etcd/etcd.go b/etcd/etcd.go index 6e1c84cb5..6bdda31c4 100644 --- a/etcd/etcd.go +++ b/etcd/etcd.go @@ -394,7 +394,7 @@ func (s *Server) runParticipant() { } func (s *Server) runStandby() { - syncDuration := time.Duration(0) + var syncDuration time.Duration for { select { case <-time.After(syncDuration): @@ -407,6 +407,7 @@ func (s *Server) runStandby() { log.Println("standby sync:", err) continue } + syncDuration = time.Duration(s.clusterConf.SyncInterval * float64(time.Second)) if s.clusterConf.ActiveSize <= len(s.nodes) { continue }