Add Redis provider with batching support

AsyncGenerator.yml

@@ -28,6 +28,61 @@
   registerPlugin:
   - type: AsyncGenerator.Core.Plugins.EmptyRegionRemover
     assemblyName: AsyncGenerator.Core
+- filePath: StackExchangeRedis\NHibernate.Caches.StackExchangeRedis\NHibernate.Caches.StackExchangeRedis.csproj
+  targetFramework: net461
+  concurrentRun: true
+  applyChanges: true
+  analyzation:
+    methodConversion:
+    - conversion: Ignore
+      hasAttributeName: ObsoleteAttribute
+    - conversion: Smart
+      containingTypeName: AbstractRegionStrategy
+    - conversion: Smart
+      containingTypeName: RedisKeyLocker
+    callForwarding: true
+    cancellationTokens:
+      guards: true
+      methodParameter:
+      - parameter: Required
+      requiresCancellationToken:
+      - containingType: NHibernate.Caches.StackExchangeRedis.RedisCache
+        name: GetMany
+      - containingType: NHibernate.Caches.StackExchangeRedis.RedisCache
+        name: PutMany
+      - containingType: NHibernate.Caches.StackExchangeRedis.AbstractRegionStrategy
+        name: Get
+      - containingType: NHibernate.Caches.StackExchangeRedis.AbstractRegionStrategy
+        name: GetMany
+      - containingType: NHibernate.Caches.StackExchangeRedis.AbstractRegionStrategy
+        name: Put
+      - containingType: NHibernate.Caches.StackExchangeRedis.AbstractRegionStrategy
+        name: PutMany
+      - containingType: NHibernate.Caches.StackExchangeRedis.AbstractRegionStrategy
+        name: Remove
+      - containingType: NHibernate.Caches.StackExchangeRedis.AbstractRegionStrategy
+        name: Unlock
+      - containingType: NHibernate.Caches.StackExchangeRedis.AbstractRegionStrategy
+        name: UnlockMany
+      - containingType: NHibernate.Caches.StackExchangeRedis.AbstractRegionStrategy
+        name: Clear
+      - containingType: NHibernate.Caches.StackExchangeRedis.RedisKeyLocker
+        name: Unlock
+      - containingType: NHibernate.Caches.StackExchangeRedis.RedisKeyLocker
+        name: UnlockMany
+    scanMethodBody: true
+    searchAsyncCounterpartsInInheritedTypes: true
+    scanForMissingAsyncMembers:
+    - all: true
+  transformation:
+    configureAwaitArgument: false
+    localFunctions: true
+    asyncLock:
+      type: NHibernate.Util.AsyncLock
+      methodName: LockAsync
+  registerPlugin:
+  - type: AsyncGenerator.Core.Plugins.EmptyRegionRemover
+    assemblyName: AsyncGenerator.Core
 - filePath: NHibernate.Caches.Common.Tests\NHibernate.Caches.Common.Tests.csproj
   targetFramework: net461
   concurrentRun: true
@@ -356,6 +411,54 @@
   registerPlugin:
   - type: AsyncGenerator.Core.Plugins.NUnitAsyncCounterpartsFinder
     assemblyName: AsyncGenerator.Core
+- filePath: StackExchangeRedis\NHibernate.Caches.StackExchangeRedis.Tests\NHibernate.Caches.StackExchangeRedis.Tests.csproj
+  targetFramework: net461
+  concurrentRun: true
+  applyChanges: true
+  analyzation:
+    methodConversion:
+    - conversion: Ignore
+      hasAttributeName: OneTimeSetUpAttribute
+    - conversion: Ignore
+      hasAttributeName: OneTimeTearDownAttribute
+    - conversion: Ignore
+      hasAttributeName: SetUpAttribute
+    - conversion: Ignore
+      hasAttributeName: TearDownAttribute
+    - conversion: Smart
+      hasAttributeName: TestAttribute
+    - conversion: Smart
+      hasAttributeName: TheoryAttribute
+    preserveReturnType:
+    - hasAttributeName: TestAttribute
+    - hasAttributeName: TheoryAttribute
+    typeConversion:
+    - conversion: Ignore
+      hasAttributeName: IgnoreAttribute
+    - conversion: Partial
+      hasAttributeName: TestFixtureAttribute
+    - conversion: Partial
+      anyBaseTypeRule: HasTestFixtureAttribute
+    ignoreSearchForMethodReferences:
+    - hasAttributeName: TheoryAttribute
+    - hasAttributeName: TestAttribute
+    cancellationTokens:
+      withoutCancellationToken:
+      - hasAttributeName: TestAttribute
+      - hasAttributeName: TheoryAttribute
+    exceptionHandling:
+      catchMethodBody:
+      - all: true
+        result: false
+    ignoreSearchForAsyncCounterparts:
+    - name: Disassemble
+    scanMethodBody: true
+    searchAsyncCounterpartsInInheritedTypes: true
+    scanForMissingAsyncMembers:
+    - all: true
+  registerPlugin:
+  - type: AsyncGenerator.Core.Plugins.NUnitAsyncCounterpartsFinder
+    assemblyName: AsyncGenerator.Core
 - filePath: SysCache\NHibernate.Caches.SysCache.Tests\NHibernate.Caches.SysCache.Tests.csproj
   targetFramework: net461
   concurrentRun: true

NHibernate.Caches.Common.Tests/Async/CacheFixture.cs

@@ -10,6 +10,7 @@
 
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using NHibernate.Cache;
 using NUnit.Framework;
@@ -61,6 +62,63 @@ public async Task TestRemoveAsync()
 			Assert.That(item, Is.Null, "item still exists in cache after remove");
 		}
 
+		[Test]
+		public async Task TestLockUnlockAsync()
+		{
+			if (!SupportsLocking)
+				Assert.Ignore("Test not supported by provider");
+
+			const string key = "keyTestLock";
+			const string value = "valueLock";
+
+			var cache = GetDefaultCache();
+
+			// add the item
+			await (cache.PutAsync(key, value, CancellationToken.None));
+
+			await (cache.LockAsync(key, CancellationToken.None));
+			Assert.ThrowsAsync<CacheException>(() => cache.LockAsync(key, CancellationToken.None));
+
+			await (Task.Delay(cache.Timeout / Timestamper.OneMs));
+
+			for (var i = 0; i < 2; i++)
+			{
+				var lockValue = await (cache.LockAsync(key, CancellationToken.None));
+				await (cache.UnlockAsync(key, lockValue, CancellationToken.None));
+			}
+		}
+
+		[Test]
+		public async Task TestConcurrentLockUnlockAsync()
+		{
+			if (!SupportsLocking)
+				Assert.Ignore("Test not supported by provider");
+
+			const string value = "value";
+			const string key = "keyToLock";
+
+			var cache = GetDefaultCache();
+
+			await (cache.PutAsync(key, value, CancellationToken.None));
+			Assert.That(await (cache.GetAsync(key, CancellationToken.None)), Is.EqualTo(value), "Unable to retrieved cached object for key");
+
+			// Simulate NHibernate ReadWriteCache behavior with multiple concurrent threads
+			// Thread 1
+			var lockValue = await (cache.LockAsync(key, CancellationToken.None));
+			// Thread 2
+			Assert.ThrowsAsync<CacheException>(() => cache.LockAsync(key, CancellationToken.None), "The key should be locked");
+			// Thread 3
+			Assert.ThrowsAsync<CacheException>(() => cache.LockAsync(key, CancellationToken.None), "The key should still be locked");
+
+			// Thread 1
+			await (cache.UnlockAsync(key, lockValue, CancellationToken.None));
+
+			Assert.DoesNotThrowAsync(async () => lockValue = await (cache.LockAsync(key, CancellationToken.None)), "The key should be unlocked");
+			await (cache.UnlockAsync(key, lockValue, CancellationToken.None));
+
+			await (cache.RemoveAsync(key, CancellationToken.None));
+		}
+
 		[Test]
 		public async Task TestClearAsync()
 		{
@@ -134,6 +192,108 @@ public async Task TestRegionsAsync()
 			Assert.That(get2, Is.EqualTo(s2), "Unexpected value in cache2");
 		}
 
+		[Test]
+		public async Task TestPutManyAsync()
+		{
+			var keys = new object[10];
+			var values = new object[10];
+			for (var i = 0; i < keys.Length; i++)
+			{
+				keys[i] = $"keyTestPut{i}";
+				values[i] = $"valuePut{i}";
+			}
+
+			var cache = GetDefaultCache();
+			// Due to async version, it may already be there.
+			foreach (var key in keys)
+				await (cache.RemoveAsync(key, CancellationToken.None));
+
+			Assert.That(await (cache.GetManyAsync(keys, CancellationToken.None)), Is.EquivalentTo(new object[10]), "cache returned items we didn't add !?!");
+
+			await (cache.PutManyAsync(keys, values, CancellationToken.None));
+			var items = await (cache.GetManyAsync(keys, CancellationToken.None));
+
+			for (var i = 0; i < items.Length; i++)
+			{
+				var item = items[i];
+				Assert.That(item, Is.Not.Null, "unable to retrieve cached item");
+				Assert.That(item, Is.EqualTo(values[i]), "didn't return the item we added");
+			}
+		}
+
+		[Test]
+		public async Task TestLockUnlockManyAsync()
+		{
+			if (!SupportsLocking)
+				Assert.Ignore("Test not supported by provider");
+
+			var keys = new object[10];
+			var values = new object[10];
+			for (var i = 0; i < keys.Length; i++)
+			{
+				keys[i] = $"keyTestLock{i}";
+				values[i] = $"valueLock{i}";
+			}
+
+			var cache = GetDefaultCache();
+
+			// add the item
+			await (cache.PutManyAsync(keys, values, CancellationToken.None));
+			await (cache.LockManyAsync(keys, CancellationToken.None));
+			Assert.ThrowsAsync<CacheException>(() => cache.LockManyAsync(keys, CancellationToken.None), "all items should be locked");
+
+			await (Task.Delay(cache.Timeout / Timestamper.OneMs));
+
+			for (var i = 0; i < 2; i++)
+			{
+				Assert.DoesNotThrowAsync(async () =>
+				{
+					await (cache.UnlockManyAsync(keys, await (cache.LockManyAsync(keys, CancellationToken.None)), CancellationToken.None));
+				}, "the items should be unlocked");
+			}
+
+			// Test partial locks by locking the first 5 keys and afterwards try to lock last 6 keys.
+			var lockValue = await (cache.LockManyAsync(keys.Take(5).ToArray(), CancellationToken.None));
+
+			Assert.ThrowsAsync<CacheException>(() => cache.LockManyAsync(keys.Skip(4).ToArray(), CancellationToken.None), "the fifth key should be locked");
+
+			Assert.DoesNotThrowAsync(async () =>
+			{
+				await (cache.UnlockManyAsync(keys, await (cache.LockManyAsync(keys.Skip(5).ToArray(), CancellationToken.None)), CancellationToken.None));
+			}, "the last 5 keys should not be locked.");
+
+			// Unlock the first 5 keys
+			await (cache.UnlockManyAsync(keys, lockValue, CancellationToken.None));
+
+			Assert.DoesNotThrowAsync(async () =>
+			{
+				lockValue = await (cache.LockManyAsync(keys, CancellationToken.None));
+				await (cache.UnlockManyAsync(keys, lockValue, CancellationToken.None));
+			}, "the first 5 keys should not be locked.");
+		}
+
+		[Test]
+		public void TestNullKeyPutManyAsync()
+		{
+			var cache = GetDefaultCache();
+			Assert.ThrowsAsync<ArgumentNullException>(() => cache.PutManyAsync(null, null, CancellationToken.None));
+		}
+
+		[Test]
+		public void TestNullValuePutManyAsync()
+		{
+			var cache = GetDefaultCache();
+			Assert.ThrowsAsync<ArgumentNullException>(() => cache.PutManyAsync(new object[] { "keyTestNullValuePut" }, null, CancellationToken.None));
+		}
+
+		[Test]
+		public async Task TestNullKeyGetManyAsync()
+		{
+			var cache = GetDefaultCache();
+			await (cache.PutAsync("keyTestNullKeyGet", "value", CancellationToken.None));
+			Assert.ThrowsAsync<ArgumentNullException>(() => cache.GetManyAsync(null, CancellationToken.None));
+		}
+
 		[Test]
 		public async Task TestNonEqualObjectsWithEqualHashCodeAndToStringAsync()
 		{