Merge branch 'async-support-test' of https://github.com/Microsoft/FASTER

into async-support-test
microsoft · Sep 4, 2019 · b2479ed · b2479ed
2 parents b16212f + 75b9cb2
commit b2479ed
Show file tree

Hide file tree

Showing 50 changed files with 1,957 additions and 327 deletions.
diff --git a/cs/benchmark/Functions.cs b/cs/benchmark/Functions.cs
@@ -54,9 +54,10 @@ public void SingleWriter(ref Key key, ref Value src, ref Value dst)
         }
 
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
-        public void ConcurrentWriter(ref Key key, ref Value src, ref Value dst)
+        public bool ConcurrentWriter(ref Key key, ref Value src, ref Value dst)
         {
             dst = src;
+            return true;
         }
 
         // RMW functions
@@ -67,9 +68,10 @@ public void InitialUpdater(ref Key key, ref Input input, ref Value value)
         }
 
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
-        public void InPlaceUpdater(ref Key key, ref Input input, ref Value value)
+        public bool InPlaceUpdater(ref Key key, ref Input input, ref Value value)
         {
             value.value += input.value;
+            return true;
         }
 
         [MethodImpl(MethodImplOptions.AggressiveInlining)]

diff --git a/cs/playground/ClassCache/Types.cs b/cs/playground/ClassCache/Types.cs
@@ -92,9 +92,10 @@ public void ConcurrentReader(ref CacheKey key, ref CacheInput input, ref CacheVa
             dst.value = value;
         }
 
-        public void ConcurrentWriter(ref CacheKey key, ref CacheValue src, ref CacheValue dst)
+        public bool ConcurrentWriter(ref CacheKey key, ref CacheValue src, ref CacheValue dst)
         {
             dst = src;
+            return true;
         }
 
         public void CopyUpdater(ref CacheKey key, ref CacheInput input, ref CacheValue oldValue, ref CacheValue newValue)
@@ -107,7 +108,7 @@ public void InitialUpdater(ref CacheKey key, ref CacheInput input, ref CacheValu
             throw new NotImplementedException();
         }
 
-        public void InPlaceUpdater(ref CacheKey key, ref CacheInput input, ref CacheValue value)
+        public bool InPlaceUpdater(ref CacheKey key, ref CacheInput input, ref CacheValue value)
         {
             throw new NotImplementedException();
         }

diff --git a/cs/playground/ClassCacheMT/Types.cs b/cs/playground/ClassCacheMT/Types.cs
@@ -92,9 +92,10 @@ public void ConcurrentReader(ref CacheKey key, ref CacheInput input, ref CacheVa
             dst.value = value;
         }
 
-        public void ConcurrentWriter(ref CacheKey key, ref CacheValue src, ref CacheValue dst)
+        public bool ConcurrentWriter(ref CacheKey key, ref CacheValue src, ref CacheValue dst)
         {
             dst = src;
+            return true;
         }
 
         public void CopyUpdater(ref CacheKey key, ref CacheInput input, ref CacheValue oldValue, ref CacheValue newValue)
@@ -107,7 +108,7 @@ public void InitialUpdater(ref CacheKey key, ref CacheInput input, ref CacheValu
             throw new NotImplementedException();
         }
 
-        public void InPlaceUpdater(ref CacheKey key, ref CacheInput input, ref CacheValue value)
+        public bool InPlaceUpdater(ref CacheKey key, ref CacheInput input, ref CacheValue value)
         {
             throw new NotImplementedException();
         }

diff --git a/cs/playground/ClassSample/Program.cs b/cs/playground/ClassSample/Program.cs
@@ -75,13 +75,13 @@ public class MyFunctions : IFunctions<MyKey, MyValue, MyInput, MyOutput, MyConte
     {
         public void InitialUpdater(ref MyKey key, ref MyInput input, ref MyValue value) => value.value = input.value;
         public void CopyUpdater(ref MyKey key, ref MyInput input, ref MyValue oldValue, ref MyValue newValue) => newValue = oldValue;
-        public void InPlaceUpdater(ref MyKey key, ref MyInput input, ref MyValue value) => value.value += input.value;
+        public bool InPlaceUpdater(ref MyKey key, ref MyInput input, ref MyValue value) { value.value += input.value; return true; }
 
 
         public void SingleReader(ref MyKey key, ref MyInput input, ref MyValue value, ref MyOutput dst) => dst.value = value;
         public void SingleWriter(ref MyKey key, ref MyValue src, ref MyValue dst) => dst = src;
         public void ConcurrentReader(ref MyKey key, ref MyInput input, ref MyValue value, ref MyOutput dst) => dst.value = value;
-        public void ConcurrentWriter(ref MyKey key, ref MyValue src, ref MyValue dst) => dst = src;
+        public bool ConcurrentWriter(ref MyKey key, ref MyValue src, ref MyValue dst) { dst = src; return true; }
 
         public void ReadCompletionCallback(ref MyKey key, ref MyInput input, ref MyOutput output, MyContext ctx, Status status) { }
         public void UpsertCompletionCallback(ref MyKey key, ref MyValue value, MyContext ctx) { }

diff --git a/cs/playground/FixedLenStructSample/Functions.cs b/cs/playground/FixedLenStructSample/Functions.cs
@@ -20,9 +20,10 @@ public void ConcurrentReader(ref FixedLenKey key, ref string input, ref FixedLen
             dst = value.ToString();
         }
 
-        public void ConcurrentWriter(ref FixedLenKey key, ref FixedLenValue src, ref FixedLenValue dst)
+        public bool ConcurrentWriter(ref FixedLenKey key, ref FixedLenValue src, ref FixedLenValue dst)
         {
             src.CopyTo(ref dst);
+            return true;
         }
 
         public void CopyUpdater(ref FixedLenKey key, ref string input, ref FixedLenValue oldValue, ref FixedLenValue newValue)
@@ -37,8 +38,9 @@ public void InitialUpdater(ref FixedLenKey key, ref string input, ref FixedLenVa
         {
         }
 
-        public void InPlaceUpdater(ref FixedLenKey key, ref string input, ref FixedLenValue value)
+        public bool InPlaceUpdater(ref FixedLenKey key, ref string input, ref FixedLenValue value)
         {
+            return true;
         }
 
         public void ReadCompletionCallback(ref FixedLenKey key, ref string input, ref string output, Empty ctx, Status status)

diff --git a/cs/playground/PeriodicCompaction/Types.cs b/cs/playground/PeriodicCompaction/Types.cs
@@ -92,9 +92,10 @@ public void ConcurrentReader(ref CacheKey key, ref CacheInput input, ref CacheVa
             dst.value = value;
         }
 
-        public void ConcurrentWriter(ref CacheKey key, ref CacheValue src, ref CacheValue dst)
+        public bool ConcurrentWriter(ref CacheKey key, ref CacheValue src, ref CacheValue dst)
         {
             dst = src;
+            return true;
         }
 
         public void CopyUpdater(ref CacheKey key, ref CacheInput input, ref CacheValue oldValue, ref CacheValue newValue)
@@ -107,7 +108,7 @@ public void InitialUpdater(ref CacheKey key, ref CacheInput input, ref CacheValu
             throw new NotImplementedException();
         }
 
-        public void InPlaceUpdater(ref CacheKey key, ref CacheInput input, ref CacheValue value)
+        public bool InPlaceUpdater(ref CacheKey key, ref CacheInput input, ref CacheValue value)
         {
             throw new NotImplementedException();
         }

diff --git a/cs/playground/StructSample/Functions.cs b/cs/playground/StructSample/Functions.cs
@@ -19,12 +19,12 @@ public class Sample1Funcs : IFunctions<long, long, long, long, Empty>
 
         // Write functions
         public void SingleWriter(ref long key, ref long src, ref long dst) => dst = src;
-        public void ConcurrentWriter(ref long key, ref long src, ref long dst) => dst = src;
+        public bool ConcurrentWriter(ref long key, ref long src, ref long dst) { dst = src; return true; }
 
         // RMW functions
         public void InitialUpdater(ref long key, ref long input, ref long value) => value = input;
         public void CopyUpdater(ref long key, ref long input, ref long oldv, ref long newv) => newv = oldv + input;
-        public void InPlaceUpdater(ref long key, ref long input, ref long value) => value += input;
+        public bool InPlaceUpdater(ref long key, ref long input, ref long value) { value += input; return true; }
 
         // Completion callbacks
         public void ReadCompletionCallback(ref long key, ref long input, ref long output, Empty ctx, Status s) { }
@@ -46,7 +46,7 @@ public class Sample2Funcs : IFunctions<Key, Value, Input, Output, Empty>
 
         // Write functions
         public void SingleWriter(ref Key key, ref Value src, ref Value dst) => dst = src;
-        public void ConcurrentWriter(ref Key key, ref Value src, ref Value dst) => dst = src;
+        public bool ConcurrentWriter(ref Key key, ref Value src, ref Value dst) { dst = src; return true; }
 
         // RMW functions
         public void InitialUpdater(ref Key key, ref Input input, ref Value value)
@@ -59,10 +59,11 @@ public void CopyUpdater(ref Key key, ref Input input, ref Value oldValue, ref Va
             newValue.vfield1 = oldValue.vfield1 + input.ifield1;
             newValue.vfield2 = oldValue.vfield2 + input.ifield2;
         }
-        public void InPlaceUpdater(ref Key key, ref Input input, ref Value value)
+        public bool InPlaceUpdater(ref Key key, ref Input input, ref Value value)
         {
             value.vfield1 += input.ifield1;
             value.vfield2 += input.ifield2;
+            return true;
         }
 
         // Completion callbacks

diff --git a/cs/playground/StructSampleCore/Functions.cs b/cs/playground/StructSampleCore/Functions.cs
@@ -19,12 +19,12 @@ public class Sample1Funcs : IFunctions<long, long, long, long, Empty>
 
         // Write functions
         public void SingleWriter(ref long key, ref long src, ref long dst) => dst = src;
-        public void ConcurrentWriter(ref long key, ref long src, ref long dst) => dst = src;
+        public bool ConcurrentWriter(ref long key, ref long src, ref long dst) { dst = src; return true; }
 
         // RMW functions
         public void InitialUpdater(ref long key, ref long input, ref long value) => value = input;
         public void CopyUpdater(ref long key, ref long input, ref long oldv, ref long newv) => newv = oldv + input;
-        public void InPlaceUpdater(ref long key, ref long input, ref long value) => value += input;
+        public bool InPlaceUpdater(ref long key, ref long input, ref long value) { value += input; return true; }
 
         // Completion callbacks
         public void ReadCompletionCallback(ref long key, ref long input, ref long output, Empty ctx, Status s) { }
@@ -46,7 +46,7 @@ public class Sample2Funcs : IFunctions<Key, Value, Input, Output, Empty>
 
         // Write functions
         public void SingleWriter(ref Key key, ref Value src, ref Value dst) => dst = src;
-        public void ConcurrentWriter(ref Key key, ref Value src, ref Value dst) => dst = src;
+        public bool ConcurrentWriter(ref Key key, ref Value src, ref Value dst) { dst = src; return true; }
 
         // RMW functions
         public void InitialUpdater(ref Key key, ref Input input, ref Value value)
@@ -59,10 +59,11 @@ public void CopyUpdater(ref Key key, ref Input input, ref Value oldValue, ref Va
             newValue.vfield1 = oldValue.vfield1 + input.ifield1;
             newValue.vfield2 = oldValue.vfield2 + input.ifield2;
         }
-        public void InPlaceUpdater(ref Key key, ref Input input, ref Value value)
+        public bool InPlaceUpdater(ref Key key, ref Input input, ref Value value)
         {
             value.vfield1 += input.ifield1;
             value.vfield2 += input.ifield2;
+            return true;
         }
 
         // Completion callbacks

diff --git a/cs/playground/SumStore/SumStoreTypes.cs b/cs/playground/SumStore/SumStoreTypes.cs
@@ -84,9 +84,10 @@ public void SingleWriter(ref AdId key, ref NumClicks src, ref NumClicks dst)
             dst = src;
         }
 
-        public void ConcurrentWriter(ref AdId key, ref NumClicks src, ref NumClicks dst)
+        public bool ConcurrentWriter(ref AdId key, ref NumClicks src, ref NumClicks dst)
         {
             dst = src;
+            return true;
         }
 
         // RMW functions
@@ -95,9 +96,10 @@ public void InitialUpdater(ref AdId key, ref Input input, ref NumClicks value)
             value = input.numClicks;
         }
 
-        public void InPlaceUpdater(ref AdId key, ref Input input, ref NumClicks value)
+        public bool InPlaceUpdater(ref AdId key, ref Input input, ref NumClicks value)
         {
             Interlocked.Add(ref value.numClicks, input.numClicks.numClicks);
+            return true;
         }
 
         public void CopyUpdater(ref AdId key, ref Input input, ref NumClicks oldValue, ref NumClicks newValue)

diff --git a/cs/playground/VarLenStructSample/Functions.cs b/cs/playground/VarLenStructSample/Functions.cs
@@ -65,18 +65,20 @@ public void SingleWriter(ref VarLenType key, ref VarLenType src, ref VarLenType
             src.CopyTo(ref dst);
         }
 
-        public void ConcurrentWriter(ref VarLenType key, ref VarLenType src, ref VarLenType dst)
+        public bool ConcurrentWriter(ref VarLenType key, ref VarLenType src, ref VarLenType dst)
         {
             src.CopyTo(ref dst);
+            return true;
         }
 
         // RMW functions
         public void InitialUpdater(ref VarLenType key, ref int[] input, ref VarLenType value)
         {
         }
 
-        public void InPlaceUpdater(ref VarLenType key, ref int[] input, ref VarLenType value)
+        public bool InPlaceUpdater(ref VarLenType key, ref int[] input, ref VarLenType value)
         {
+            return true;
         }
 
         public void CopyUpdater(ref VarLenType key, ref int[] input, ref VarLenType oldValue, ref VarLenType newValue)