IGNITE-28192 Extending logging

modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItTableScanTest.java

@@ -44,7 +44,9 @@
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map.Entry;
 import java.util.Set;
+import java.util.TreeSet;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Flow.Publisher;
 import java.util.concurrent.Flow.Subscription;

modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/PeekCursor.java

@@ -54,4 +54,12 @@ public interface PeekCursor<T> extends Cursor<T> {
      * up-to-date value in the storage.
      */
     @Nullable T peek();
+
+    @Nullable default T getLastLocked() {
+        return null;
+    }
+
+    default void locked(T peekedRow) {
+
+    }
 }

modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/index/impl/TestSortedIndexStorage.java

@@ -134,6 +134,9 @@ private class ScanCursor implements PeekCursor<IndexRow> {
         @Nullable
         private IndexRow currentRow;
 
+        @Nullable
+        private IndexRow lastLocked;
+
         @Nullable
         private IndexRow peekedRow = NO_PEEKED_ROW;
 
@@ -192,6 +195,20 @@ public IndexRow next() {
 
             return peekedRow;
         }
+
+        @Override
+        public @Nullable IndexRow getLastLocked() {
+            checkStorageClosedOrInProcessOfRebalance(true);
+
+            return lastLocked;
+        }
+
+        @Override
+        public void locked(IndexRow peekedRow) {
+            checkStorageClosedOrInProcessOfRebalance(true);
+
+            lastLocked = peekedRow;
+        }
     }
 
     /**