Browse Source

Add DefaultTimeout

pull/13573/head
liangshiwei 4 years ago
parent
commit
ecd834ca35
  1. 2
      framework/src/Volo.Abp.DistributedLocking.Dapr/Volo/Abp/DistributedLocking/Dapr/AbpDistributedLockDaprOptions.cs
  2. 4
      framework/src/Volo.Abp.DistributedLocking.Dapr/Volo/Abp/DistributedLocking/Dapr/DaprAbpDistributedLock.cs

2
framework/src/Volo.Abp.DistributedLocking.Dapr/Volo/Abp/DistributedLocking/Dapr/AbpDistributedLockDaprOptions.cs

@ -3,4 +3,6 @@
public class AbpDistributedLockDaprOptions public class AbpDistributedLockDaprOptions
{ {
public string StoreName { get; set; } public string StoreName { get; set; }
public TimeSpan DefaultTimeout { get; set;}
} }

4
framework/src/Volo.Abp.DistributedLocking.Dapr/Volo/Abp/DistributedLocking/Dapr/DaprAbpDistributedLock.cs

@ -28,7 +28,7 @@ public class DaprAbpDistributedLock : IAbpDistributedLock, ITransientDependency
{ {
if (timeout == default) if (timeout == default)
{ {
timeout = TimeSpan.FromSeconds(30); timeout = DistributedLockDaprOptions.DefaultTimeout;
} }
var daprClient = await DaprClientFactory.CreateAsync(); var daprClient = await DaprClientFactory.CreateAsync();
@ -37,7 +37,7 @@ public class DaprAbpDistributedLock : IAbpDistributedLock, ITransientDependency
DistributedLockDaprOptions.StoreName, DistributedLockDaprOptions.StoreName,
name, name,
DaprOptions.AppId, DaprOptions.AppId,
timeout.Seconds, (int)timeout.TotalSeconds,
cancellationToken); cancellationToken);
if (lockResponse == null || !lockResponse.Success) if (lockResponse == null || !lockResponse.Success)

Loading…
Cancel
Save