middleware/secondary: add jitter (#841)

randomize the times when doing transfers and checks.

Fixes #840

1 files changed, 14 insertions, 0 deletions

diff --git a/middleware/file/secondary.go b/middleware/file/secondary.go
index e371600e9..a37d62442 100644
--- a/middleware/file/secondary.go
+++ b/middleware/file/secondary.go
@@ -2,6 +2,7 @@ package file
 
 import (
 	"log"
+	"math/rand"
 	"time"
 
 	"github.com/miekg/dns"
@@ -146,6 +147,9 @@ Restart:
 			if !retryActive {
 				break
 			}
+
+			time.Sleep(jitter(2000)) // 2s randomize
+
 			ok, err := z.shouldTransfer()
 			if err != nil && ok {
 				if err := z.TransferIn(); err != nil {
@@ -161,6 +165,9 @@ Restart:
 			}
 
 		case <-refreshTicker.C:
+
+			time.Sleep(jitter(5000)) // 5s randomize
+
 			ok, err := z.shouldTransfer()
 			retryActive = err != nil
 			if err != nil && ok {
@@ -180,6 +187,13 @@ Restart:
 	}
 }
 
+// jitter returns a random duration between [0,n) * time.Millisecond
+func jitter(n int) time.Duration {
+	r := rand.Intn(n)
+	return time.Duration(r) * time.Millisecond
+
+}
+
 // MaxSerialIncrement is the maximum difference between two serial numbers. If the difference between
 // two serials is greater than this number, the smaller one is considered greater.
 const MaxSerialIncrement uint32 = 2147483647