Repository: ignite Updated Branches: refs/heads/master 31e88fc32 -> 584a88d42
IGNITE-8955 Fix of test after Checkpoint can't get write lock if massive eviction on node start started Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/584a88d4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/584a88d4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/584a88d4 Branch: refs/heads/master Commit: 584a88d4285a7db4d10dcdfa235633498f96e583 Parents: 31e88fc Author: Eduard Shangareev <eduard.shangar...@gmail.com> Authored: Thu Jul 12 19:26:48 2018 +0300 Committer: Dmitriy Pavlov <dpav...@apache.org> Committed: Thu Jul 12 19:26:48 2018 +0300 ---------------------------------------------------------------------- ...itePdsCheckpointSimulationWithRealCpDisabledTest.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/584a88d4/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/file/IgnitePdsCheckpointSimulationWithRealCpDisabledTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/file/IgnitePdsCheckpointSimulationWithRealCpDisabledTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/file/IgnitePdsCheckpointSimulationWithRealCpDisabledTest.java index 08ce6d7..0fbb255 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/file/IgnitePdsCheckpointSimulationWithRealCpDisabledTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/file/IgnitePdsCheckpointSimulationWithRealCpDisabledTest.java @@ -897,7 +897,16 @@ public class IgnitePdsCheckpointSimulationWithRealCpDisabledTest extends GridCom for (FullPageId fullId : pageIds) { long cpStart = System.nanoTime(); - Integer tag = mem.getForCheckpoint(fullId, tmpBuf, null); + Integer tag; + + while (true) { + tag = mem.getForCheckpoint(fullId, tmpBuf, null); + + if (tag != null && tag == PageMemoryImpl.TRY_AGAIN_TAG) + continue; + + break; + } if (tag == null) continue;
