Acquire AllRelationshiCursor in the StorageLayer

neo4j · May 8, 2017 · 59fd133 · 59fd133
1 parent 2caa415
commit 59fd133
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 1 deletion.
diff --git a/...nity/kernel/src/main/java/org/neo4j/kernel/impl/api/StateHandlingStatementOperations.java b/...nity/kernel/src/main/java/org/neo4j/kernel/impl/api/StateHandlingStatementOperations.java
@@ -185,7 +185,7 @@ private Cursor<RelationshipItem> relationshipCursor( KernelStatement statement,
     public Cursor<RelationshipItem> relationshipCursorGetAll( KernelStatement statement )
     {
         ReadableTransactionState state = statement.hasTxStateWithChanges() ? statement.txState() : null;
-        return statement.getStoreStatement().relationshipsGetAllCursor( state );
+        return storeLayer.relationshipsGetAllCursor( statement.getStoreStatement(), state );
     }
 
     @Override

diff --git a/community/kernel/src/main/java/org/neo4j/kernel/impl/api/store/StorageLayer.java b/community/kernel/src/main/java/org/neo4j/kernel/impl/api/store/StorageLayer.java
@@ -416,6 +416,13 @@ public Cursor<RelationshipItem> relationshipCursor( StorageStatement statement,
         return statement.acquireSingleRelationshipCursor( relationshipId, state );
     }
 
+    @Override
+    public Cursor<RelationshipItem> relationshipsGetAllCursor( StorageStatement statement,
+            ReadableTransactionState state )
+    {
+        return statement.relationshipsGetAllCursor( state );
+    }
+
     @Override
     public Cursor<RelationshipItem> nodeGetRelationships( StorageStatement statement, NodeItem nodeItem,
             Direction direction, ReadableTransactionState state )

diff --git a/community/kernel/src/main/java/org/neo4j/storageengine/api/StoreReadLayer.java b/community/kernel/src/main/java/org/neo4j/storageengine/api/StoreReadLayer.java
@@ -275,6 +275,8 @@ <EXCEPTION extends Exception> void relationshipVisit( long relationshipId,
     Cursor<RelationshipItem> relationshipCursor( StorageStatement storeStatement, long relationshipId,
             ReadableTransactionState state );
 
+    Cursor<RelationshipItem> relationshipsGetAllCursor( StorageStatement storeStatement, ReadableTransactionState state );
+
     Cursor<RelationshipItem> nodeGetRelationships( StorageStatement statement, NodeItem nodeItem, Direction direction,
             ReadableTransactionState state );