# IGNITE-489 Remove dead code.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/bb5a2700 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/bb5a2700 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/bb5a2700 Branch: refs/heads/sprint-3 Commit: bb5a27008b3ce44481ae544b7f33ba493f2ab10f Parents: 9a51544 Author: sevdokimov <sevdoki...@gridgain.com> Authored: Wed Mar 25 15:21:06 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Wed Mar 25 15:21:06 2015 +0300 ---------------------------------------------------------------------- ...ridCachePartitionNotLoadedEventSelfTest.java | 43 +------------------- 1 file changed, 2 insertions(+), 41 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bb5a2700/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePartitionNotLoadedEventSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePartitionNotLoadedEventSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePartitionNotLoadedEventSelfTest.java index 21916f2..70a7076 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePartitionNotLoadedEventSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCachePartitionNotLoadedEventSelfTest.java @@ -20,13 +20,9 @@ package org.apache.ignite.internal.processors.cache.distributed; import org.apache.ignite.*; import org.apache.ignite.cache.*; import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.cluster.*; import org.apache.ignite.configuration.*; import org.apache.ignite.events.*; import org.apache.ignite.lang.*; -import org.apache.ignite.plugin.extensions.communication.*; -import org.apache.ignite.spi.*; -import org.apache.ignite.spi.communication.tcp.*; import org.apache.ignite.testframework.junits.common.*; import org.eclipse.jetty.util.*; @@ -62,8 +58,6 @@ public class GridCachePartitionNotLoadedEventSelfTest extends GridCommonAbstract cfg.setCacheConfiguration(cacheCfg); - cfg.setCommunicationSpi(new FilteredCommunicationSpi()); - return cfg; } @@ -101,13 +95,8 @@ public class GridCachePartitionNotLoadedEventSelfTest extends GridCommonAbstract assert jcache(0).containsKey(key); assert jcache(1).containsKey(key); -// ((FilteredCommunicationSpi)ignite(0).configuration().getCommunicationSpi()).stop(true); -// ((FilteredCommunicationSpi)ignite(1).configuration().getCommunicationSpi()).stop(true); - - stopGrid(0, false); - stopGrid(1, false); - - //startGrid(4); + stopGrid(0); + stopGrid(1); awaitPartitionMapExchange(); @@ -133,17 +122,10 @@ public class GridCachePartitionNotLoadedEventSelfTest extends GridCommonAbstract assert jcache(0).containsKey(key); -// ((FilteredCommunicationSpi)ignite(0).configuration().getCommunicationSpi()).stop(true); -// ((FilteredCommunicationSpi)ignite(1).configuration().getCommunicationSpi()).stop(true); - stopGrid(0, true); awaitPartitionMapExchange(); - // startGrid(4); - - awaitPartitionMapExchange(); - assert !jcache(1).containsKey(key); assert !lsnr.lostParts.isEmpty(); @@ -163,25 +145,4 @@ public class GridCachePartitionNotLoadedEventSelfTest extends GridCommonAbstract return true; } } - - /** - * - */ - private static class FilteredCommunicationSpi extends TcpCommunicationSpi { - /** */ - private volatile boolean stop; - - /** {@inheritDoc} */ - @Override public void sendMessage(ClusterNode node, Message msg) throws IgniteSpiException { - if (!stop) - super.sendMessage(node, msg); - } - - /** - * @param stop Filter. - */ - public void stop(boolean stop) { - this.stop = stop; - } - } }
