Skip to content

Commit 44dce15

Browse files
committed
Fixed regression
1 parent 54614c0 commit 44dce15

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/DotNext.Threading/Threading/Leases/LeaseProvider.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -70,11 +70,11 @@ protected LeaseProvider(TimeSpan ttl, TimeProvider? provider = null)
7070
{
7171
CreatedAt = provider.GetUtcNow(),
7272
Identity = state.Identity.BumpVersion(),
73-
Metadata = await updater.Invoke(state.Metadata, token).ConfigureAwait(false),
73+
Metadata = await updater.Invoke(state.Metadata, cts.Token).ConfigureAwait(false),
7474
};
7575

7676
var ts = new Timestamp(provider);
77-
if (!await TryUpdateStateAsync(state, token).ConfigureAwait(false))
77+
if (!await TryUpdateStateAsync(state, cts.Token).ConfigureAwait(false))
7878
return null;
7979

8080
remainingTime = TimeToLive - ts.GetElapsedTime(provider);
@@ -151,7 +151,7 @@ private async ValueTask<AcquisitionResult> AcquireAsync<TUpdater>(TUpdater updat
151151
return new AcquisitionResult(in state, remainingTime, provider);
152152
}
153153

154-
await Task.Delay(remainingTime, provider, token).ConfigureAwait(false);
154+
await Task.Delay(remainingTime, provider, cts.Token).ConfigureAwait(false);
155155
}
156156
}
157157
catch (OperationCanceledException e) when (e.CausedBy(cts, LifetimeToken))

src/cluster/DotNext.AspNetCore.Cluster/Net/Cluster/Consensus/Raft/Http/RaftHttpCluster.Messaging.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,7 @@ private async Task ReceiveMessageAsync(RaftClusterMember sender,
227227
var tokenSource = CombineTokens([token, leadershipToken]);
228228
try
229229
{
230-
await ReceiveMessageAsync(sender, message, response, token).ConfigureAwait(false);
230+
await ReceiveMessageAsync(sender, message, response, tokenSource.Token).ConfigureAwait(false);
231231
}
232232
catch (OperationCanceledException)
233233
{

0 commit comments

Comments
 (0)