Inline Reference.DataAdapter.getShort

enterprise/kernel/src/main/java/org/neo4j/kernel/impl/store/format/highlimit/Reference.java

@@ -64,8 +64,6 @@ public interface DataAdapter<SOURCE>
     {
         byte getByte( SOURCE source );
 
-        short getShort( SOURCE source );
-
         void putByte( byte oneByte, SOURCE source ) throws IOException;
     }
 
@@ -77,12 +75,6 @@ public byte getByte( PageCursor source )
             return source.getByte();
         }
 
-        @Override
-        public short getShort( PageCursor cursor )
-        {
-            return cursor.getShort();
-        }
-
         @Override
         public void putByte( byte oneByte, PageCursor source )
         {
@@ -254,8 +246,8 @@ public static <SOURCE> long decode( SOURCE source, DataAdapter<SOURCE> adapter )
         // up 16 places to make room for the next two bytes of payload.
         //
         // <6>
-        // Then we read the next two bytes (with unsigned mask) and save for the sign-bit manipulation, we now have a
-        // complete 3-byte reference.
+        // Then we read the next two bytes (with unsigned mask) and save for the sign-component manipulation, we now
+        // have a complete 3-byte reference.
         //
         // <7>
         // The size marks determines how many more bytes the reference takes up, so we loop through them and shift the
@@ -269,7 +261,7 @@ public static <SOURCE> long decode( SOURCE source, DataAdapter<SOURCE> adapter )
         int signShift = 8 - sizeMarks - (sizeMarks == 5 ? 1 : 2); // <3>
         long signComponent = ~((header >>> signShift) & 1) + 1; // <4>
         long register = (header & ((1 << signShift) - 1)) << 16; // <5>
-        register += adapter.getShort( source ) & 0xFFFFL; // <6>
+        register += ((adapter.getByte( source ) & 0xFF) << 8) + (adapter.getByte( source ) & 0xFF); // <6>
 
         while ( sizeMarks > 0 ) // <7>
         {

enterprise/kernel/src/main/java/org/neo4j/kernel/impl/store/format/highlimit/SecondaryPageCursorReadDataAdapter.java

@@ -71,14 +71,6 @@ public byte getByte( PageCursor primaryCursor /*same as the one we have*/ )
         return primaryCursor.getByte();
     }
 
-    @Override
-    public short getShort( PageCursor cursor )
-    {
-        byte highByte = getByte( cursor );
-        byte lowByte = getByte( cursor );
-        return (short) (((highByte & 0xFF) << 8) | (lowByte & 0xFF));
-    }
-
     @Override
     public void putByte( byte oneByte, PageCursor primaryCursor )
     {

enterprise/kernel/src/main/java/org/neo4j/kernel/impl/store/format/highlimit/SecondaryPageCursorWriteDataAdapter.java

@@ -53,12 +53,6 @@ public byte getByte( PageCursor source )
         throw new UnsupportedOperationException();
     }
 
-    @Override
-    public short getShort( PageCursor cursor )
-    {
-        throw new UnsupportedOperationException();
-    }
-
     @Override
     public void putByte( byte oneByte, PageCursor cursor ) throws IOException
     {

enterprise/kernel/src/test/java/org/neo4j/kernel/impl/store/format/highlimit/SecondaryPageCursorReadDataAdapterTest.java

@@ -42,7 +42,7 @@ public class SecondaryPageCursorReadDataAdapterTest
     public final RandomRule random = new RandomRule();
 
     @Test
-    public void getShortEntirelyFromPrimaryCursor() throws Exception
+    public void getBytesEntirelyFromPrimaryCursor() throws Exception
     {
         int secondaryPageId = 42;
         int secondaryCursorOffset = 0;
@@ -58,13 +58,20 @@ public void getShortEntirelyFromPrimaryCursor() throws Exception
                 newPagedFile( secondaryCursor ), secondaryPageId, secondaryCursorOffset, primaryCursorEndOffset,
                 PagedFile.PF_SHARED_READ_LOCK );
 
-        short read = adapter.getShort( primaryCursor );
+        short read = getShort( adapter, primaryCursor );
 
         assertEquals( value, read );
     }
 
+    private short getShort( SecondaryPageCursorReadDataAdapter adapter, PageCursor cursor )
+    {
+        int a = adapter.getByte( cursor ) & 0xFF;
+        int b = adapter.getByte( cursor ) & 0xFF;
+        return (short) ((a << 8) + b);
+    }
+
     @Test
-    public void getShortEntirelyFromSecondaryCursor() throws Exception
+    public void getBytesEntirelyFromSecondaryCursor() throws Exception
     {
         int secondaryPageId = 42;
         int secondaryCursorOffset = 0;
@@ -80,13 +87,13 @@ public void getShortEntirelyFromSecondaryCursor() throws Exception
                 newPagedFile( secondaryCursor ), secondaryPageId, secondaryCursorOffset, primaryCursorEndOffset,
                 PagedFile.PF_SHARED_READ_LOCK );
 
-        short read = adapter.getShort( primaryCursor );
+        short read = getShort( adapter, primaryCursor );
 
         assertEquals( value, read );
     }
 
     @Test
-    public void getShortFromPrimaryAndSecondaryCursor() throws Exception
+    public void getBytesFromPrimaryAndSecondaryCursor() throws Exception
     {
         int secondaryPageId = 42;
         int secondaryCursorOffset = 0;
@@ -107,7 +114,7 @@ public void getShortFromPrimaryAndSecondaryCursor() throws Exception
                 newPagedFile( secondaryCursor ), secondaryPageId, secondaryCursorOffset, primaryCursorEndOffset,
                 PagedFile.PF_SHARED_READ_LOCK );
 
-        short read = adapter.getShort( primaryCursor );
+        short read = getShort( adapter, primaryCursor );
 
         assertEquals( value, read );
     }