Add ExpandableArrayBuffer. Closes #95

AdaptiveConsulting · Aug 7, 2022 · ea2580a · ea2580a
1 parent 000f58e
commit ea2580a
Show file tree

Hide file tree

Showing 4 changed files with 617 additions and 142 deletions.
diff --git a/src/Adaptive.Agrona/Concurrent/UnsafeBuffer.cs b/src/Adaptive.Agrona/Concurrent/UnsafeBuffer.cs
@@ -455,16 +455,6 @@ public void PutInt(int index, int value)
             *(int*) (_pBuffer + index) = value;
         }
 
-        public int PutIntAscii(int index, int value)
-        {
-            throw new NotImplementedException();
-        }
-
-        public int PutLongAscii(int index, long value)
-        {
-            throw new NotImplementedException();
-        }
-
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
         public int GetIntVolatile(int index)
         {
@@ -597,8 +587,9 @@ public short GetShort(int index)
         public short GetShort(int index, ByteOrder byteOrder)
         {
             BoundsCheck0(index, BitUtil.SIZE_OF_SHORT);
-
-            return *(short*) (_pBuffer + index);
+
+            var value = *(short*)(_pBuffer + index);
+            return EndianessConverter.ApplyInt16(byteOrder, value);
         }
 
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
@@ -614,6 +605,7 @@ public void PutShort(int index, short value, ByteOrder byteOrder)
         {
             BoundsCheck0(index, BitUtil.SIZE_OF_SHORT);
 
+            value = EndianessConverter.ApplyInt16(byteOrder, value);
             *(short*) (_pBuffer + index) = value;
         }