@@ -4,7 +4,6 @@ namespace CFLookup
44{
55 public sealed class RedisJobLock : IAsyncDisposable
66 {
7- private readonly ILogger _logger ;
87 private readonly TimeSpan _expiryTime ;
98 private string _lockKey { get ; }
109
@@ -13,9 +12,8 @@ public sealed class RedisJobLock : IAsyncDisposable
1312 private readonly CancellationTokenSource _cts ;
1413 private Task ? _refreshLockTask ;
1514
16- private RedisJobLock ( IDatabase database , string lockName , ILogger logger , TimeSpan expiryTime )
15+ private RedisJobLock ( IDatabase database , string lockName , TimeSpan expiryTime )
1716 {
18- _logger = logger ;
1917 _expiryTime = expiryTime ;
2018 _redisDatabase = database ;
2119
@@ -28,11 +26,10 @@ private RedisJobLock(IDatabase database, string lockName, ILogger logger, TimeSp
2826 public async static Task < RedisJobLock ? > CreateAsync (
2927 IDatabase database ,
3028 string lockName ,
31- ILogger logger ,
3229 TimeSpan expiryTime
3330 )
3431 {
35- var distributedLock = new RedisJobLock ( database , lockName , logger , expiryTime ) ;
32+ var distributedLock = new RedisJobLock ( database , lockName , expiryTime ) ;
3633
3734 var lockAcquired = await database . LockTakeAsync (
3835 distributedLock . _lockKey ,
@@ -42,11 +39,11 @@ TimeSpan expiryTime
4239 if ( lockAcquired )
4340 {
4441 distributedLock . StartRenewalTask ( ) ;
45- logger . LogDebug ( "Lock acquired for key {LockKey} by owner {LockOwner}" , distributedLock . _lockKey , distributedLock . _lockOwner ) ;
42+ // logger.LogDebug("Lock acquired for key {LockKey} by owner {LockOwner}", distributedLock._lockKey, distributedLock._lockOwner);
4643 return distributedLock ;
4744 }
4845
49- logger . LogDebug ( "Failed to acquire lock for key {LockKey}" , distributedLock . _lockKey ) ;
46+ // logger.LogDebug("Failed to acquire lock for key {LockKey}", distributedLock._lockKey);
5047 return null ;
5148 }
5249
@@ -66,11 +63,11 @@ private void StartRenewalTask()
6663
6764 if ( renewed )
6865 {
69- _logger . LogDebug ( "Renewed lock for key {LockKey}" , _lockKey ) ;
66+ // _logger.LogDebug("Renewed lock for key {LockKey}", _lockKey);
7067 }
7168 else
7269 {
73- _logger . LogError ( "Failed to renew lock for key {LockKey}. Lock has been lost." , _lockKey ) ;
70+ // _logger.LogError("Failed to renew lock for key {LockKey}. Lock has been lost.", _lockKey);
7471 break ;
7572 }
7673 }
@@ -80,7 +77,7 @@ private void StartRenewalTask()
8077 }
8178 catch ( Exception ex )
8279 {
83- _logger . LogError ( ex , "Failed to renew lock for key {LockKey} due to exception." , _lockKey ) ;
80+ // _logger.LogError(ex, "Failed to renew lock for key {LockKey} due to exception.", _lockKey);
8481 break ;
8582 }
8683 }
@@ -94,7 +91,7 @@ public async ValueTask DisposeAsync()
9491 return ;
9592 }
9693
97- _logger . LogDebug ( $ "Releasing lock { _lockKey } / { _lockOwner } ") ;
94+ // _logger.LogDebug($"Releasing lock {_lockKey} / {_lockOwner}");
9895
9996 if ( ! _cts . IsCancellationRequested )
10097 {
@@ -104,11 +101,11 @@ public async ValueTask DisposeAsync()
104101 var released = await _redisDatabase . LockReleaseAsync ( _lockKey , _lockOwner ) ;
105102 if ( ! released )
106103 {
107- _logger . LogWarning ( "Failed to release lock for key {LockKey}, it may have expired already" , _lockKey ) ;
104+ // _logger.LogWarning("Failed to release lock for key {LockKey}, it may have expired already", _lockKey);
108105 }
109106 else
110107 {
111- _logger . LogDebug ( "Released lock for key {LockKey}" , _lockKey ) ;
108+ // _logger.LogDebug("Released lock for key {LockKey}", _lockKey);
112109 }
113110
114111 try
@@ -117,7 +114,7 @@ public async ValueTask DisposeAsync()
117114 }
118115 catch ( Exception ex )
119116 {
120- _logger . LogError ( ex , "Failed to refresh lock for key {LockKey}" , _lockKey ) ;
117+ // _logger.LogError(ex, "Failed to refresh lock for key {LockKey}", _lockKey);
121118 }
122119
123120 _cts . Dispose ( ) ;
0 commit comments