randomly start the probe

megaease · Jul 2, 2022 · abc93fd · abc93fd
1 parent e6a7914
commit abc93fd
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/cmd/easeprobe/probe.go b/cmd/easeprobe/probe.go
@@ -18,6 +18,7 @@
 package main
 
 import (
+	"math/rand"
 	"sync"
 	"time"
 
@@ -60,6 +61,13 @@ func runProbers(probers []probe.Prober, wg *sync.WaitGroup, done chan bool) {
 		wg.Add(1)
 		defer wg.Done()
 
+		// Sleep a round time to avoid all probers start at the same time.
+		s := rand.NewSource(time.Now().UnixNano())
+		r := rand.New(s)
+		t := time.Duration(r.Int63n(int64(global.DefaultProbeInterval)))
+		log.Debugf("[%s / %s] Sleep %v seconds before probe", p.Kind(), p.Name(), t.Seconds())
+		time.Sleep(t)
+
 		interval := time.NewTimer(p.Interval())
 		defer interval.Stop()
 		for {