Skip to content

Commit cfce96c

Browse files
committed
IGNITE-26722 after review #1.0
1 parent 2b1d565 commit cfce96c

File tree

2 files changed

+1
-8
lines changed
  • modules
    • core/src/test/java/org/apache/ignite/internal/util
    • page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/compaction

2 files changed

+1
-8
lines changed

modules/core/src/test/java/org/apache/ignite/internal/util/IgniteUtilsTest.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,6 @@
5050
import java.util.concurrent.CompletableFuture;
5151
import java.util.concurrent.ExecutionException;
5252
import java.util.concurrent.TimeUnit;
53-
import java.util.concurrent.atomic.AtomicReference;
5453
import org.apache.ignite.internal.testframework.BaseIgniteAbstractTest;
5554
import org.apache.ignite.internal.util.worker.IgniteWorker;
5655
import org.junit.jupiter.api.Test;
@@ -218,11 +217,4 @@ void testByteBufferToByteArray() {
218217
ByteBuffer smallDirectBuffer = bigDirectBuffer.position(1).limit(4).slice();
219218
assertArrayEquals(new byte[] {1, 2, 3}, byteBufferToByteArray(smallDirectBuffer));
220219
}
221-
222-
@Test
223-
void test() {
224-
AtomicReference<Integer> reference = new AtomicReference<>();
225-
226-
assertTrue(reference.compareAndSet(null, null));
227-
}
228220
}

modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/compaction/Compactor.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -524,6 +524,7 @@ public void resume() {
524524
}
525525
}
526526

527+
/** Must be called before each IO operation to provide other IO components with resources. */
527528
private void pauseCompactionIfNeeded() {
528529
CountDownLatch latch = pauseLatchRef.get();
529530

0 commit comments

Comments
 (0)