IGNITE-1992: [Test failed] CacheStopAndDestroySelfTest.testLocalClose test fails periodicaly. This closes #261
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e02edcd3 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e02edcd3 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e02edcd3 Branch: refs/heads/ignite-1282 Commit: e02edcd36d79f1e107c2ebe5096238f2f2a62a23 Parents: b9e4e03 Author: Andrey Gura <ag...@gridgain.com> Authored: Wed Nov 25 18:34:42 2015 +0300 Committer: Denis Magda <dma...@gridgain.com> Committed: Wed Nov 25 18:34:42 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/CacheStopAndDestroySelfTest.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e02edcd3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheStopAndDestroySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheStopAndDestroySelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheStopAndDestroySelfTest.java index 29828af..061a374 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheStopAndDestroySelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheStopAndDestroySelfTest.java @@ -30,6 +30,7 @@ import org.apache.ignite.configuration.CacheConfiguration; import org.apache.ignite.configuration.IgniteConfiguration; import org.apache.ignite.configuration.NearCacheConfiguration; import org.apache.ignite.internal.managers.communication.GridIoMessage; +import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion; import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxPrepareRequest; import org.apache.ignite.internal.util.typedef.internal.U; import org.apache.ignite.lang.IgniteInClosure; @@ -67,9 +68,6 @@ public class CacheStopAndDestroySelfTest extends GridCommonAbstractTest { /** local cache name. */ protected static String CACHE_NAME_LOC = "cache_local"; - /** */ - private static volatile boolean stop; - /** {@inheritDoc} */ @Override protected void beforeTest() throws Exception { super.beforeTest(); @@ -674,6 +672,10 @@ public class CacheStopAndDestroySelfTest extends GridCommonAbstractTest { // Local creation after closed. + AffinityTopologyVersion topVer = grid(1).context().cache().context().exchange().lastTopologyFuture().get(); + + grid(0).context().cache().context().exchange().affinityReadyFuture(topVer).get(); + grid(0).getOrCreateCache(getLocalConfig()); grid(0).cache(CACHE_NAME_LOC).put(KEY_VAL, KEY_VAL + "recreated0");