From 6199d9b9234c3aeef108e41023d552f073bd571d Mon Sep 17 00:00:00 2001
From: Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com>
Date: Fri, 12 Aug 2022 23:11:09 +0300
Subject: [PATCH] rand start garbageThreshold and reset metric
 ReplicaPlacementMismatch (#3396)

* rand start garbageThreshold
reset metrics MasterReplicaPlacementMismatch

* vacuum through sleep
---
 weed/topology/topology_event_handling.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/weed/topology/topology_event_handling.go b/weed/topology/topology_event_handling.go
index 96051d25f..d0d175a39 100644
--- a/weed/topology/topology_event_handling.go
+++ b/weed/topology/topology_event_handling.go
@@ -1,6 +1,7 @@
 package topology
 
 import (
+	"github.com/seaweedfs/seaweedfs/weed/stats"
 	"github.com/seaweedfs/seaweedfs/weed/storage/erasure_coding"
 	"github.com/seaweedfs/seaweedfs/weed/storage/types"
 	"google.golang.org/grpc"
@@ -22,11 +23,13 @@ func (t *Topology) StartRefreshWritableVolumes(grpcDialOption grpc.DialOption, g
 		}
 	}()
 	go func(garbageThreshold float64) {
-		c := time.Tick(15 * time.Minute)
-		for _ = range c {
+		for {
 			if t.IsLeader() {
 				t.Vacuum(grpcDialOption, garbageThreshold, 0, "", preallocate)
+			} else {
+				stats.MasterReplicaPlacementMismatch.Reset()
 			}
+			time.Sleep(14*time.Minute + time.Duration(120*rand.Float32())*time.Second)
 		}
 	}(garbageThreshold)
 	go func() {