Skip to content

Commit fb0bf12

Browse files
Apply suggestions from code review
Co-authored-by: Ramon Smits <[email protected]>
1 parent 0d7b585 commit fb0bf12

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/ServiceControl.Infrastructure/AsyncTimer.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,9 @@ public TimerJob(Func<CancellationToken, Task<TimerJobExecutionResult>> callback,
5151
catch (Exception ex)
5252
{
5353
consecutiveFailures++;
54-
var backoffDelay = TimeSpan.FromSeconds(int.Min(6, consecutiveFailures) * 10);
54+
const int MaxDelayDurationInSeconds = 60;
55+
var delayInSeconds = consecutiveFailures * 10;
56+
var backoffDelay = TimeSpan.FromSeconds(int.Min(MaxDelayDurationInSeconds, delayInSeconds));
5557

5658
await Task.Delay(backoffDelay, token).ConfigureAwait(false);
5759

@@ -75,6 +77,7 @@ public async Task Stop(CancellationToken cancellationToken)
7577

7678
await tokenSource.CancelAsync().ConfigureAwait(false);
7779
tokenSource.Dispose();
80+
tokenSource = null;
7881

7982
if (task == null)
8083
{

0 commit comments

Comments
 (0)