Add IRedisLock.ThrownExceptions

RedLock.Tests/RedisLockTests.cs

@@ -466,5 +466,19 @@ public void TimeLock()
 				}
 			}
 		}
+
+        [Test]
+        public void TestThrownExceptions()
+        {
+            using (var redisLockFactory = new RedisLockFactory(AllInactiveEndPoints.First()))
+            {
+                var resource = $"testredislock-{Guid.NewGuid()}";
+
+                using (var redisLock = redisLockFactory.Create(resource, TimeSpan.MaxValue))
+                {
+                    Assert.IsTrue(redisLock.HasError());
+                }
+            }
+        }
 	}
 }

RedLock/IRedisLock.cs

@@ -7,5 +7,6 @@ public interface IRedisLock : IDisposable
 		string LockId { get; }
 		bool IsAcquired { get; }
 		int ExtendCount { get; }
-	}
+        System.Collections.Generic.IEnumerable<Exception> ThrownExceptions { get; }
+    }
 }

RedLock/IRedisLockExtensions.cs

@@ -0,0 +1,16 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace RedLock
+{
+    public static class IRedisLockExtensions
+    {
+        public static bool HasError(this IRedisLock redisLock)
+        {
+            return redisLock.ThrownExceptions.Any();
+        }
+    }
+}

RedLock/RedLock.csproj

@@ -47,6 +47,7 @@
   <ItemGroup>
     <Compile Include="App_Packages\LibLog.4.2\LibLog.cs" />
     <Compile Include="IRedisLock.cs" />
+    <Compile Include="IRedisLockExtensions.cs" />
     <Compile Include="IRedisLockFactory.cs" />
     <Compile Include="RedisConnection.cs" />
     <Compile Include="RedisLockEndPoint.cs" />

RedLock/RedisLock.cs

@@ -59,6 +59,10 @@ public class RedisLock : IRedisLock
 		private readonly TimeSpan minimumExpiryTime = TimeSpan.FromMilliseconds(10);
 		private readonly TimeSpan minimumRetryTime = TimeSpan.FromMilliseconds(10);
 
+        private List<Exception> thrownExceptions;
+        public IEnumerable<Exception> ThrownExceptions { get { return thrownExceptions ?? Enumerable.Empty<Exception>(); } }
+        private readonly object thrownExceptionsLock = new object();
+
 		private RedisLock(
 			ICollection<RedisConnection> redisCaches,
 			string resource,
@@ -408,6 +412,7 @@ private bool LockInstance(RedisConnection cache)
 			catch (Exception ex)
 			{
 				Logger.Debug($"Error locking lock instance {host}: {ex.Message}");
+                RecordException(ex);
 			}
 
 			Logger.Trace(() => $"LockInstance exit {host}: {redisKey}, {LockId}, {result}");
@@ -433,7 +438,8 @@ private async Task<bool> LockInstanceAsync(RedisConnection cache)
 			catch (Exception ex)
 			{
 				Logger.Debug($"Error locking lock instance {host}: {ex.Message}");
-			}
+                RecordException(ex);
+            }
 
 			Logger.Trace(() => $"LockInstanceAsync exit {host}: {redisKey}, {LockId}, {result}");
 
@@ -459,7 +465,8 @@ private bool ExtendInstance(RedisConnection cache)
 			catch (Exception ex)
 			{
 				Logger.Debug($"Error extending lock instance {host}: {ex.Message}");
-			}
+                RecordException(ex);
+            }
 
 			Logger.Trace(() => $"ExtendInstance exit {host}: {redisKey}, {LockId}, {result}");
 
@@ -483,7 +490,8 @@ private bool UnlockInstance(RedisConnection cache)
 			catch (Exception ex)
 			{
 				Logger.Debug($"Error unlocking lock instance {host}: {ex.Message}");
-			}
+                RecordException(ex);
+            }
 
 			Logger.Trace(() => $"UnlockInstance exit {host}: {redisKey}, {LockId}, {result}");
 
@@ -508,13 +516,24 @@ private async Task<bool> UnlockInstanceAsync(RedisConnection cache)
 			catch (Exception ex)
 			{
 				Logger.Debug($"Error unlocking lock instance {host}: {ex.Message}");
-			}
+                RecordException(ex);
+            }
 
 			Logger.Trace(() => $"UnlockInstanceAsync exit {host}: {redisKey}, {LockId}, {result}");
 
 			return result;
 		}
 
+        private void RecordException(Exception ex)
+        {
+            lock(thrownExceptionsLock)
+            {
+                if (thrownExceptions == null)
+                    thrownExceptions = new List<Exception>();
+                thrownExceptions.Add(ex);
+            }
+        }
+
 		private static string GetRedisKey(string redisKeyFormat, string resource)
 		{
 			return string.Format(redisKeyFormat, resource);