Browse Source

Change DaprAbpDistributedLock implementation

pull/14015/head
Halil İbrahim Kalkan 4 years ago
parent
commit
1e75e6c1a7
  1. 2
      framework/src/Volo.Abp.DistributedLocking.Abstractions/Volo/Abp/DistributedLocking/IAbpDistributedLock.cs
  2. 4
      framework/src/Volo.Abp.DistributedLocking.Dapr/Volo/Abp/DistributedLocking/Dapr/AbpDistributedLockDaprOptions.cs
  3. 7
      framework/src/Volo.Abp.DistributedLocking.Dapr/Volo/Abp/DistributedLocking/Dapr/DaprAbpDistributedLock.cs

2
framework/src/Volo.Abp.DistributedLocking.Abstractions/Volo/Abp/DistributedLocking/IAbpDistributedLock.cs

@ -14,7 +14,7 @@ public interface IAbpDistributedLock
/// Returns null if the lock could not be handled.
/// </summary>
/// <param name="name">The name of the lock</param>
/// <param name="timeout">Timeout value</param>
/// <param name="timeout">How long to wait before giving up on the acquisition attempt. Defaults to 0</param>
/// <param name="cancellationToken">Cancellation token</param>
[ItemCanBeNull]
Task<IAbpDistributedLockHandle> TryAcquireAsync(

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

@ -6,10 +6,10 @@ public class AbpDistributedLockDaprOptions
public string? Owner { get; set; }
public TimeSpan DefaultTimeout { get; set; }
public TimeSpan DefaultExpirationTimeout { get; set; }
public AbpDistributedLockDaprOptions()
{
DefaultTimeout = TimeSpan.FromSeconds(30);
DefaultExpirationTimeout = TimeSpan.FromMinutes(2);
}
}

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

@ -26,11 +26,6 @@ public class DaprAbpDistributedLock : IAbpDistributedLock, ITransientDependency
TimeSpan timeout = default,
CancellationToken cancellationToken = default)
{
if (timeout == default)
{
timeout = DistributedLockDaprOptions.DefaultTimeout;
}
name = DistributedLockKeyNormalizer.NormalizeKey(name);
var daprClient = DaprClientFactory.Create();
@ -38,7 +33,7 @@ public class DaprAbpDistributedLock : IAbpDistributedLock, ITransientDependency
DistributedLockDaprOptions.StoreName,
name,
DistributedLockDaprOptions.Owner ?? Guid.NewGuid().ToString(),
(int)timeout.TotalSeconds,
(int)DistributedLockDaprOptions.DefaultExpirationTimeout.TotalSeconds,
cancellationToken);
if (lockResponse == null || !lockResponse.Success)

Loading…
Cancel
Save