Merge pull request #253 from ydb-platform/fix-force-initial-timeout

asmyasnikov · web-flow · commit 675c435e1c3d · 2022-05-12T17:47:51.000+03:00
Fixed repeater force initial timeout
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,5 @@
+* Fixed repeater initial force timeout from 500 to 0.5 second
+
 ## v3.25.1
 * Fixed bug with unexpected failing of call `Invoke` and `NewStream` on closed cluster
 * Fixed bug with releasing `internal/conn/conn.Pool` in cluster
diff --git a/internal/repeater/repeater.go b/internal/repeater/repeater.go
@@ -140,7 +140,7 @@ func (r *repeater) worker(ctx context.Context, interval time.Duration) {
 
 	// force returns backoff with delays [500ms...32s]
 	force := backoff.New(
-		backoff.WithSlotDuration(500*time.Second),
+		backoff.WithSlotDuration(500*time.Millisecond),
 		backoff.WithCeiling(6),
 		backoff.WithJitterLimit(1),
 	)

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,5 @@`
	`1`	`+* Fixed repeater initial force timeout from 500 to 0.5 second`
	`2`	`+`
`1`	`3`	`## v3.25.1`
`2`	`4`	* Fixed bug with unexpected failing of call `Invoke` and `NewStream` on closed cluster
`3`	`5`	* Fixed bug with releasing `internal/conn/conn.Pool` in cluster
Original file line number	Diff line number	Diff line change
`@@ -140,7 +140,7 @@ func (r *repeater) worker(ctx context.Context, interval time.Duration) {`
`140`	`140`
`141`	`141`	`// force returns backoff with delays [500ms...32s]`
`142`	`142`	`force := backoff.New(`
`143`		`- backoff.WithSlotDuration(500*time.Second),`
	`143`	`+ backoff.WithSlotDuration(500*time.Millisecond),`
`144`	`144`	`backoff.WithCeiling(6),`
`145`	`145`	`backoff.WithJitterLimit(1),`
`146`	`146`	`)`