ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [07/30] incubator-ignite git commit: # IGNITE-489 Remove dead code.
Date Thu, 26 Mar 2015 16:07:13 GMT
# 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/ignite-341
Commit: bb5a27008b3ce44481ae544b7f33ba493f2ab10f
Parents: 9a51544
Author: sevdokimov <sevdokimov@gridgain.com>
Authored: Wed Mar 25 15:21:06 2015 +0300
Committer: sevdokimov <sevdokimov@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;
-        }
-    }
 }


Mime
View raw message