chore: sleep before next iteration (#446)

acha-bill · web-flow · commit 92c3f85baa16 · 2025-01-16T07:11:58.000-05:00
* chore: sleep before next iteration

* lint: fix
diff --git a/config/config.yaml b/config/config.yaml
@@ -329,6 +329,7 @@ checks:
       nodes-sync-wait: 1m
       upload-timeout: 1m
       download-timeout: 1m
+      iteration-wait: 5m
       duration: 15m
     timeout: 30m
     type: smoke
diff --git a/config/local.yaml b/config/local.yaml
@@ -281,6 +281,7 @@ checks:
       nodes-sync-wait: 1m
       upload-timeout: 1m
       download-timeout: 1m
+      iteration-wait: 5m
     timeout: 5m
     type: smoke
   ci-soc:
diff --git a/pkg/check/smoke/smoke.go b/pkg/check/smoke/smoke.go
@@ -36,6 +36,7 @@ type Options struct {
 	MaxUseBatch            time.Duration
 	MaxStorageRadius       uint8
 	StorageRadiusCheckWait time.Duration
+	IterationWait          time.Duration
 }
 
 // NewDefaultOptions returns new default options
@@ -54,6 +55,7 @@ func NewDefaultOptions() Options {
 		MaxUseBatch:            12 * time.Hour,
 		MaxStorageRadius:       2,
 		StorageRadiusCheckWait: 5 * time.Minute,
+		IterationWait:          5 * time.Minute,
 	}
 }
 
@@ -83,6 +85,8 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, opts int
 
 	c.logger.Info("random seed: ", o.RndSeed)
 	c.logger.Info("content size: ", o.ContentSize)
+	c.logger.Info("upload timeout: ", o.UploadTimeout)
+	c.logger.Info("download timeout: ", o.DownloadTimeout)
 
 	rnd := random.PseudoGenerator(o.RndSeed)
 
@@ -237,6 +241,8 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, opts int
 			c.logger.Infof("data mismatch: found %d different bytes, ~%.2f%%", diff, float64(diff)/float64(txLen)*100)
 		}
 		rxCancel()
+
+		time.Sleep(o.IterationWait)
 	}
 
 	return nil

Original file line number	Diff line number	Diff line change
`@@ -36,6 +36,7 @@ type Options struct {`
`36`	`36`	`MaxUseBatch time.Duration`
`37`	`37`	`MaxStorageRadius uint8`
`38`	`38`	`StorageRadiusCheckWait time.Duration`
	`39`	`+ IterationWait time.Duration`
`39`	`40`	`}`
`40`	`41`
`41`	`42`	`// NewDefaultOptions returns new default options`
`@@ -54,6 +55,7 @@ func NewDefaultOptions() Options {`
`54`	`55`	`MaxUseBatch: 12 * time.Hour,`
`55`	`56`	`MaxStorageRadius: 2,`
`56`	`57`	`StorageRadiusCheckWait: 5 * time.Minute,`
	`58`	`+ IterationWait: 5 * time.Minute,`
`57`	`59`	`}`
`58`	`60`	`}`
`59`	`61`
`@@ -83,6 +85,8 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, opts int`
`83`	`85`
`84`	`86`	`c.logger.Info("random seed: ", o.RndSeed)`
`85`	`87`	`c.logger.Info("content size: ", o.ContentSize)`
	`88`	`+ c.logger.Info("upload timeout: ", o.UploadTimeout)`
	`89`	`+ c.logger.Info("download timeout: ", o.DownloadTimeout)`
`86`	`90`
`87`	`91`	`rnd := random.PseudoGenerator(o.RndSeed)`
`88`	`92`
`@@ -237,6 +241,8 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, opts int`
`237`	`241`	`c.logger.Infof("data mismatch: found %d different bytes, ~%.2f%%", diff, float64(diff)/float64(txLen)*100)`
`238`	`242`	`}`
`239`	`243`	`rxCancel()`
	`244`	`+`
	`245`	`+ time.Sleep(o.IterationWait)`
`240`	`246`	`}`
`241`	`247`
`242`	`248`	`return nil`