SemianiakaVY/BotSharp
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

_logger in DistributedLocker

Browse source
This commit is contained in:
Haiping Chen 2024-11-08 20:53:04 +00:00
parent 4f9cd09b40
commit 0d89528562
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/Infrastructure/BotSharp.Core/Infrastructures/DistributedLocker.cs
View file

@ -6,10 +6,12 @@ namespace BotSharp.Core.Infrastructures;
public class DistributedLocker
{
private readonly IConnectionMultiplexer _redis;
private readonly ILogger _logger;
public DistributedLocker(IConnectionMultiplexer redis)
public DistributedLocker(IConnectionMultiplexer redis, ILogger<DistributedLocker> logger)
{
_redis = redis;
_logger = logger;
}
public async Task<T> Lock<T>(string resource, Func<Task<T>> action, int timeoutInSeconds = 30)
@ -21,14 +23,14 @@ public class DistributedLocker
{
if (handle == null)
{
Serilog.Log.Logger.Error($"Acquire lock for {resource} failed due to after {timeout}s timeout.");
_logger.LogWarning($"Acquire lock for {resource} failed due to after {timeout}s timeout.");
}
return await action();
}
}
public void Lock(string resource, Action action, int timeoutInSeconds = 30)
public bool Lock(string resource, Action action, int timeoutInSeconds = 30)
{
var timeout = TimeSpan.FromSeconds(timeoutInSeconds);
@ -37,11 +39,13 @@ public class DistributedLocker
{
if (handle == null)
{
Serilog.Log.Logger.Error($"Acquire lock for {resource} failed due to after {timeout}s timeout.");
_logger.LogWarning($"Acquire lock for {resource} failed due to after {timeout}s timeout.");
return false;
}
else
{
action();
return true;
}
}
}