Merge pull request #1410 from 0chain/feat/random-worker

random redeem worker

Author: dabasov

code/go/0chain.net/blobbercore/writemarker/worker.go

@@ -256,7 +256,8 @@ func retryRedeem(errString string) bool {
 }
 
 func startCollector(ctx context.Context) {
-	ticker := time.NewTicker(config.Configuration.MarkerRedeemInterval)
+	randTime := getRandTime()
+	ticker := time.NewTicker(time.Duration(randTime) * time.Second)
 	defer ticker.Stop()
 	for {
 		select {
@@ -272,6 +273,8 @@ func startCollector(ctx context.Context) {
 				}
 			}
 			markerDataMut.Unlock()
+			randTime = getRandTime()
+			ticker.Reset(time.Duration(randTime) * time.Second)
 		}
 	}
 }
@@ -284,6 +287,13 @@ func (md *markerData) processMarker() bool {
 	return !md.processing && !md.inCommit && (md.chainLength >= config.Configuration.MaxChainLength || common.Now()-md.firstMarkerTimestamp > common.Timestamp(config.Configuration.MaxTimestampGap) || common.Now()-md.lastMarkerTimestamp > common.Timestamp(randTime))
 }
 
+func getRandTime() int64 {
+	secondsInterval := int64(config.Configuration.MarkerRedeemInterval.Seconds())
+	randTime := rand.Int63n(secondsInterval / 2)
+	randTime += secondsInterval / 2 // interval of secondsInterval/2 to secondsInterval
+	return randTime
+}
+
 // TODO: don't delete prev WM
 // func startCleanupWorker(ctx context.Context) {
 // 	for {