[C#] Quite a few new tests to make FasterLog and FasterKV functionally covered

azure-pipelines.yml

@@ -7,6 +7,7 @@ jobs:
   pool:
     vmImage: windows-latest
   displayName: 'C# (Windows)'
+  timeoutInMinutes: 75 
 
   strategy:
     maxParallel: 2

cs/test/AsyncLargeObjectTests.cs

@@ -38,6 +38,7 @@ public void TearDown()
 
         [TestCase(CheckpointType.FoldOver)]
         [TestCase(CheckpointType.Snapshot)]
+        [Category("FasterKV")]
         public async Task LargeObjectTest(CheckpointType checkpointType)
         {
             MyInput input = default;

cs/test/AsyncTests.cs

@@ -26,6 +26,7 @@ public class RecoveryTests
 
         [TestCase(CheckpointType.FoldOver)]
         [TestCase(CheckpointType.Snapshot)]
+        [Category("FasterKV")]
         public async Task AsyncRecoveryTest1(CheckpointType checkpointType)
         {
             log = Devices.CreateLogDevice(TestContext.CurrentContext.TestDirectory + "/SimpleRecoveryTest2.log", deleteOnClose: true);
@@ -75,7 +76,7 @@ public async Task AsyncRecoveryTest1(CheckpointType checkpointType)
             fht1.TakeFullCheckpoint(out _);
             await fht1.CompleteCheckpointAsync();
 
-            s2.CompletePending(true);
+            s2.CompletePending(true,false);
 
             fht1.TakeFullCheckpoint(out Guid token);
             await fht1.CompleteCheckpointAsync();
@@ -97,7 +98,7 @@ public async Task AsyncRecoveryTest1(CheckpointType checkpointType)
                     var status = s3.Read(ref inputArray[key], ref inputArg, ref output, Empty.Default, s3.SerialNo);
 
                     if (status == Status.PENDING)
-                        s3.CompletePending(true);
+                        s3.CompletePending(true,true);
                     else
                     {
                         Assert.IsTrue(output.value.numClicks == key);
@@ -111,7 +112,10 @@ public async Task AsyncRecoveryTest1(CheckpointType checkpointType)
         }
     }
 
-    public class SimpleFunctions : IFunctions<AdId, NumClicks, AdInput, Output, Empty>
+
+
+
+public class SimpleFunctions : IFunctions<AdId, NumClicks, AdInput, Output, Empty>
     {
         public void RMWCompletionCallback(ref AdId key, ref AdInput input, Empty ctx, Status status)
         {

cs/test/BasicDiskFASTERTests.cs

@@ -23,19 +23,22 @@ internal class BasicStorageFASTERTests
         public const string TEST_CONTAINER = "test";
 
         [Test]
+        [Category("FasterKV")]
         public void LocalStorageWriteRead()
         {
             TestDeviceWriteRead(Devices.CreateLogDevice(TestContext.CurrentContext.TestDirectory + "/BasicDiskFASTERTests.log", deleteOnClose: true));
         }
 
         [Test]
+        [Category("FasterKV")]
         public void PageBlobWriteRead()
         {
             if ("yes".Equals(Environment.GetEnvironmentVariable("RunAzureTests")))
                 TestDeviceWriteRead(new AzureStorageDevice(EMULATED_STORAGE_STRING, TEST_CONTAINER, "PageBlobWriteRead", "BasicDiskFASTERTests"));
         }
 
         [Test]
+        [Category("FasterKV")]
         public void TieredWriteRead()
         {
             IDevice tested;
@@ -56,6 +59,7 @@ public void TieredWriteRead()
         }
 
         [Test]
+        [Category("FasterKV")]
         public void ShardedWriteRead()
         {
             IDevice localDevice1 = Devices.CreateLogDevice(TestContext.CurrentContext.TestDirectory + "/BasicDiskFASTERTests1.log", deleteOnClose: true, capacity: 1 << 30);