dont inc delay (#845)

tg123 · web-flow · commit 608a176280b0 · 2022-04-28T09:31:50.000-07:00
diff --git a/src/KubernetesClient/LeaderElection/LeaderElector.cs b/src/KubernetesClient/LeaderElection/LeaderElector.cs
@@ -195,7 +195,7 @@ private async Task AcquireAsync(CancellationToken cancellationToken)
                 {
                     var acq = TryAcquireOrRenew(cancellationToken);
 
-                    if (await Task.WhenAny(acq, Task.Delay(delay, cancellationToken))
+                    if (await Task.WhenAny(acq, Task.Delay((int)(delay * JitterFactor * (new Random().NextDouble() + 1)), cancellationToken))
                         .ConfigureAwait(false) == acq)
                     {
                         if (await acq.ConfigureAwait(false))
@@ -208,8 +208,6 @@ private async Task AcquireAsync(CancellationToken cancellationToken)
                     }
 
                     // else timeout
-
-                    delay = (int)(delay * JitterFactor);
                 }
                 finally
                 {

Original file line number	Diff line number	Diff line change
`@@ -195,7 +195,7 @@ private async Task AcquireAsync(CancellationToken cancellationToken)`
`195`	`195`	`{`
`196`	`196`	`var acq = TryAcquireOrRenew(cancellationToken);`
`197`	`197`
`198`		`- if (await Task.WhenAny(acq, Task.Delay(delay, cancellationToken))`
	`198`	`+ if (await Task.WhenAny(acq, Task.Delay((int)(delay * JitterFactor * (new Random().NextDouble() + 1)), cancellationToken))`
`199`	`199`	`.ConfigureAwait(false) == acq)`
`200`	`200`	`{`
`201`	`201`	`if (await acq.ConfigureAwait(false))`
`@@ -208,8 +208,6 @@ private async Task AcquireAsync(CancellationToken cancellationToken)`
`208`	`208`	`}`
`209`	`209`
`210`	`210`	`// else timeout`
`211`		`-`
`212`		`- delay = (int)(delay * JitterFactor);`
`213`	`211`	`}`
`214`	`212`	`finally`
`215`	`213`	`{`