Repository: ignite
Updated Branches:
  refs/heads/ignite-comm-opts2 4030ef886 -> fb58fc4fd


conn


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fb58fc4f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fb58fc4f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fb58fc4f

Branch: refs/heads/ignite-comm-opts2
Commit: fb58fc4fd17509a798bedfd02c391411989088e4
Parents: 4030ef8
Author: sboikov <sboi...@gridgain.com>
Authored: Tue Sep 20 14:54:25 2016 +0300
Committer: sboikov <sboi...@gridgain.com>
Committed: Tue Sep 20 15:16:16 2016 +0300

----------------------------------------------------------------------
 .../ignite/internal/util/nio/GridNioServer.java |   3 +-
 .../communication/tcp/TcpCommunicationSpi.java  | 115 +++++++++-------
 ...acheConnectionRecovery10ConnectionsTest.java |  35 +++++
 .../IgniteCacheMessageWriteTimeoutTest.java     |   4 +-
 .../ignite/testsuites/IgniteCacheTestSuite.java |   2 +
 .../testsuites/IgniteCacheTestSuite2.java       | 130 +++++++++++++++++--
 6 files changed, 229 insertions(+), 60 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/fb58fc4f/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
index 578c73e..83ed513e 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
@@ -1473,7 +1473,8 @@ public class GridNioServer<T> {
                                     MessageReader reader = 
ses.meta(GridDirectParser.READER_META_KEY);
 
                                     sb.append("    Connection info [")
-                                        
.append("rmtAddr=").append(ses.remoteAddress())
+                                        .append("in=").append(ses.accepted())
+                                        .append(", 
rmtAddr=").append(ses.remoteAddress())
                                         .append(", 
locAddr=").append(ses.localAddress());
 
                                     GridNioRecoveryDescriptor outDesc = 
ses.outRecoveryDescriptor();

http://git-wip-us.apache.org/repos/asf/ignite/blob/fb58fc4f/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
index 2d1a2b2..ee30420 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
@@ -339,6 +339,9 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
     /** */
     private ConnectGateway connectGate;
 
+    /** */
+    private ConnectionPolicy connPlc;
+
     /** Server listener. */
     private final GridNioServerListener<Message> srvLsnr =
         new GridNioServerListenerAdapter<Message>() {
@@ -374,7 +377,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
                     if (nodeClients != null) {
                         for (GridCommunicationClient client : nodeClients) {
                             if (client instanceof 
GridTcpNioCommunicationClient &&
-                                ((GridTcpNioCommunicationClient) 
client).session() == ses) {
+                                
((GridTcpNioCommunicationClient)client).session() == ses) {
                                 client.close();
 
                                 removeNodeClient(id, client);
@@ -1615,6 +1618,12 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
             nioSrvr.dumpStats();
     }
 
+    /** */
+    private final ThreadLocal<Integer> threadConnIdx = new ThreadLocal<>();
+
+    /** */
+    private final AtomicInteger connIdx = new AtomicInteger();
+
     /** {@inheritDoc} */
     @Override public Map<String, Object> getNodeAttributes() throws 
IgniteSpiException {
         initFailureDetectionTimeout();
@@ -1649,6 +1658,53 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
                 "Specified 'unackedMsgsBufSize' is too low, it should be at 
least 'ackSndThreshold * 5'.");
         }
 
+        if (connectionsPerNode > 1) {
+            int idxMode = IgniteSystemProperties.getInteger("CONN_IDX_MODE", 
0);
+
+            switch (idxMode) {
+                case 0: {
+                    connPlc = new ConnectionPolicy() {
+                        @Override public int connectionIndex() {
+                            return (int)(Thread.currentThread().getId() % 
connectionsPerNode);
+                        }
+                    };
+
+                    break;
+                }
+
+                case 1: {
+                    connPlc = new ConnectionPolicy() {
+                        @Override public int connectionIndex() {
+                            Integer threadIdx = threadConnIdx.get();
+
+                            if (threadIdx != null)
+                                return threadIdx;
+
+                            for (;;) {
+                                int idx = connIdx.get();
+                                int nextIdx = idx == connectionsPerNode - 1 ? 
0 : idx + 1;
+
+                                if (connIdx.compareAndSet(idx, nextIdx)) {
+                                    threadConnIdx.set(idx);
+
+                                    return idx;
+                                }
+                            }
+                        }
+                    };
+
+                    break;
+                }
+            }
+        }
+        else {
+            connPlc = new ConnectionPolicy() {
+                @Override public int connectionIndex() {
+                    return 0;
+                }
+            };
+        }
+
         try {
             locHost = U.resolveLocalHost(locAddr);
         }
@@ -2161,51 +2217,6 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
         sendMessage0(node, msg, ackC);
     }
 
-    /** */
-    private final int idxMode = 
IgniteSystemProperties.getInteger("CONN_IDX_MODE", 0);
-
-    /** */
-    private final ThreadLocal<Integer> threadConnIdx = new ThreadLocal<>();
-
-    /** */
-    private final AtomicInteger connIdx = new AtomicInteger();
-
-    /**
-     * TODO
-     * @return
-     */
-    private int connectionIndex() {
-        switch (idxMode) {
-            case 0: {
-                return (int)(Thread.currentThread().getId() % 
connectionsPerNode);
-            }
-
-            case 1: {
-                Integer threadIdx = threadConnIdx.get();
-
-                if (threadIdx != null)
-                    return threadIdx;
-
-                for (;;) {
-                    int idx = connIdx.get();
-                    int nextIdx = idx == connectionsPerNode - 1 ? 0 : idx + 1;
-
-                    if (connIdx.compareAndSet(idx, nextIdx)) {
-                        threadConnIdx.set(idx);
-
-                        return idx;
-                    }
-                }
-            }
-
-            case 2:
-                return ThreadLocalRandom.current().nextInt(connectionsPerNode);
-
-            default:
-                throw new IgniteException("Invalid connection index mode: " + 
idxMode);
-        }
-    }
-
     /**
      * @param node Destination node.
      * @param msg Message to send.
@@ -2233,7 +2244,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
         else {
             GridCommunicationClient client = null;
 
-            int connIdx = useMultipleConnections(node) ? connectionIndex() : 0;
+            int connIdx = useMultipleConnections(node) ? 
connPlc.connectionIndex() : 0;
 
             try {
                 boolean retry;
@@ -4310,4 +4321,14 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
             return S.toString(ConnectionKey.class, this);
         }
     }
+
+    /**
+     *
+     */
+    interface ConnectionPolicy {
+        /**
+         * @return Thread connection index.
+         */
+        int connectionIndex();
+    }
 }

http://git-wip-us.apache.org/repos/asf/ignite/blob/fb58fc4f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheConnectionRecovery10ConnectionsTest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheConnectionRecovery10ConnectionsTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheConnectionRecovery10ConnectionsTest.java
new file mode 100644
index 0000000..919aea6
--- /dev/null
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheConnectionRecovery10ConnectionsTest.java
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.processors.cache.distributed;
+
+import org.apache.ignite.configuration.IgniteConfiguration;
+import org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi;
+
+/**
+ *
+ */
+public class IgniteCacheConnectionRecovery10ConnectionsTest extends 
IgniteCacheConnectionRecoveryTest {
+    /** {@inheritDoc} */
+    @Override protected IgniteConfiguration getConfiguration(String gridName) 
throws Exception {
+        IgniteConfiguration cfg = super.getConfiguration(gridName);
+
+        
((TcpCommunicationSpi)cfg.getCommunicationSpi()).setConnectionsPerNode(10);
+
+        return cfg;
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/fb58fc4f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheMessageWriteTimeoutTest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheMessageWriteTimeoutTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheMessageWriteTimeoutTest.java
index 6256225..5b51af8 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheMessageWriteTimeoutTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheMessageWriteTimeoutTest.java
@@ -50,8 +50,8 @@ public class IgniteCacheMessageWriteTimeoutTest extends 
GridCommonAbstractTest {
         // Try provoke connection close on socket writeTimeout.
         commSpi.setSharedMemoryPort(-1);
         commSpi.setMessageQueueLimit(10);
-        commSpi.setSocketReceiveBuffer(32);
-        commSpi.setSocketSendBuffer(32);
+        commSpi.setSocketReceiveBuffer(40);
+        commSpi.setSocketSendBuffer(40);
         commSpi.setSocketWriteTimeout(100);
         commSpi.setUnacknowledgedMessagesBufferSize(1000);
         commSpi.setConnectTimeout(10_000);

http://git-wip-us.apache.org/repos/asf/ignite/blob/fb58fc4f/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
 
b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
index 2fd84ab..2ce6e57 100755
--- 
a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
@@ -126,6 +126,7 @@ import 
org.apache.ignite.internal.processors.cache.distributed.CacheTxNearUpdate
 import 
org.apache.ignite.internal.processors.cache.distributed.GridCacheEntrySetIterationPreloadingSelfTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheAtomicMessageRecovery10ConnectionsTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheAtomicMessageRecoveryTest;
+import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheConnectionRecovery10ConnectionsTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheConnectionRecoveryTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheMessageRecoveryIdleConnectionTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheMessageWriteTimeoutTest;
@@ -288,6 +289,7 @@ public class IgniteCacheTestSuite extends TestSuite {
         suite.addTestSuite(IgniteCacheMessageWriteTimeoutTest.class);
         suite.addTestSuite(IgniteCacheMessageRecoveryIdleConnectionTest.class);
         suite.addTestSuite(IgniteCacheConnectionRecoveryTest.class);
+        
suite.addTestSuite(IgniteCacheConnectionRecovery10ConnectionsTest.class);
         GridTestUtils.addTestIfNeeded(suite, 
GridCacheOffHeapTieredEvictionAtomicSelfTest.class, ignoredTests);
         GridTestUtils.addTestIfNeeded(suite, 
GridCacheOffHeapTieredEvictionSelfTest.class, ignoredTests);
         GridTestUtils.addTestIfNeeded(suite, 
GridCacheOffHeapTieredAtomicSelfTest.class, ignoredTests);

http://git-wip-us.apache.org/repos/asf/ignite/blob/fb58fc4f/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite2.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite2.java
 
b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite2.java
index ac50323..dc412a9 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite2.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite2.java
@@ -43,15 +43,10 @@ import 
org.apache.ignite.internal.processors.cache.distributed.CacheLockReleaseN
 import 
org.apache.ignite.internal.processors.cache.distributed.GridCachePartitionNotLoadedEventSelfTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.GridCachePartitionedNearDisabledTxMultiThreadedSelfTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.GridCacheTransformEventSelfTest;
-import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheAtomicMessageRecoveryTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheClientNodeChangingTopologyTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheClientNodePartitionsExchangeTest;
-import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheConnectionRecoveryTest;
-import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheMessageRecoveryIdleConnectionTest;
-import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheMessageWriteTimeoutTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheNearOffheapGetSelfTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheServerNodeConcurrentStart;
-import 
org.apache.ignite.internal.processors.cache.distributed.IgniteCacheTxMessageRecoveryTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.dht.GridCacheAtomicExpiredEntriesPreloadSelfTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.dht.GridCacheColocatedOptimisticTransactionSelfTest;
 import 
org.apache.ignite.internal.processors.cache.distributed.dht.GridCacheColocatedPreloadRestartSelfTest;
@@ -146,11 +141,126 @@ public class IgniteCacheTestSuite2 extends TestSuite {
     public static TestSuite suite() throws Exception {
         TestSuite suite = new TestSuite("IgniteCache Test Suite part 2");
 
-        suite.addTestSuite(IgniteCacheMessageWriteTimeoutTest.class);
-        suite.addTestSuite(IgniteCacheAtomicMessageRecoveryTest.class);
-        suite.addTestSuite(IgniteCacheTxMessageRecoveryTest.class);
-        suite.addTestSuite(IgniteCacheMessageRecoveryIdleConnectionTest.class);
-        suite.addTestSuite(IgniteCacheConnectionRecoveryTest.class);
+        // Local cache.
+        suite.addTestSuite(GridCacheLocalBasicApiSelfTest.class);
+        suite.addTestSuite(GridCacheLocalBasicStoreSelfTest.class);
+        suite.addTestSuite(GridCacheLocalAtomicBasicStoreSelfTest.class);
+        suite.addTestSuite(GridCacheLocalGetAndTransformStoreSelfTest.class);
+        
suite.addTestSuite(GridCacheLocalAtomicGetAndTransformStoreSelfTest.class);
+        suite.addTestSuite(GridCacheLocalLoadAllSelfTest.class);
+        suite.addTestSuite(GridCacheLocalLockSelfTest.class);
+        suite.addTestSuite(GridCacheLocalMultithreadedSelfTest.class);
+        suite.addTestSuite(GridCacheLocalTxSingleThreadedSelfTest.class);
+        suite.addTestSuite(GridCacheLocalTxTimeoutSelfTest.class);
+        suite.addTestSuite(GridCacheLocalEventSelfTest.class);
+        suite.addTestSuite(GridCacheLocalEvictionEventSelfTest.class);
+        suite.addTestSuite(GridCacheVariableTopologySelfTest.class);
+        suite.addTestSuite(GridCacheLocalTxMultiThreadedSelfTest.class);
+        suite.addTestSuite(GridCacheTransformEventSelfTest.class);
+        suite.addTestSuite(GridCacheLocalIsolatedNodesSelfTest.class);
+
+        // Partitioned cache.
+        suite.addTestSuite(GridCachePartitionedGetSelfTest.class);
+        suite.addTest(new TestSuite(GridCachePartitionedBasicApiTest.class));
+        suite.addTest(new TestSuite(GridCacheNearMultiGetSelfTest.class));
+        suite.addTest(new TestSuite(NoneRebalanceModeSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheNearJobExecutionSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheReplicatedJobExecutionTest.class));
+        suite.addTest(new TestSuite(GridCacheNearOneNodeSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheNearMultiNodeSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheAtomicNearMultiNodeSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheNearReadersSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheNearReaderPreloadSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheAtomicNearReadersSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedAffinitySelfTest.class));
+        suite.addTest(new 
TestSuite(RendezvousAffinityFunctionExcludeNeighborsSelfTest.class));
+        suite.addTest(new 
TestSuite(FairAffinityFunctionExcludeNeighborsSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheRendezvousAffinityClientSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedProjectionAffinitySelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedBasicOpSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedBasicStoreSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedGetAndTransformStoreSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedAtomicGetAndTransformStoreSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedBasicStoreMultiNodeSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedNearDisabledBasicStoreMultiNodeSelfTest.class));
+        suite.addTest(new TestSuite(GridCachePartitionedEventSelfTest.class));
+        suite.addTest(new TestSuite(GridCachePartitionedLockSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedNearDisabledLockSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedMultiNodeLockSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedMultiNodeSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedMultiThreadedPutGetSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedNodeFailureSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedExplicitLockNodeFailureSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedTxSingleThreadedSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheColocatedTxSingleThreadedSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedTxTimeoutSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheFinishPartitionsSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheDhtEntrySelfTest.class));
+        suite.addTest(new TestSuite(GridCacheDhtMappingSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedTxMultiThreadedSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedNearDisabledTxMultiThreadedSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheDhtPreloadSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheDhtPreloadOffHeapSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheDhtPreloadBigDataSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheDhtPreloadPutGetSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheDhtPreloadDisabledSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheDhtPreloadMultiThreadedSelfTest.class));
+        suite.addTest(new 
TestSuite(CacheDhtLocalPartitionAfterRemoveSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheColocatedPreloadRestartSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheNearPreloadRestartSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheDhtPreloadStartStopSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheDhtPreloadUnloadSelfTest.class));
+        suite.addTest(new 
TestSuite(RendezvousAffinityFunctionBackupFilterSelfTest.class));
+        suite.addTest(new 
TestSuite(FairAffinityFunctionBackupFilterSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedPreloadLifecycleSelfTest.class));
+        suite.addTest(new 
TestSuite(CacheLoadingConcurrentGridStartSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheDhtPreloadDelayedSelfTest.class));
+        suite.addTest(new TestSuite(GridPartitionedBackupLoadSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedLoadCacheSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionNotLoadedEventSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheDhtEvictionsDisabledSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheNearEvictionEventSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheAtomicNearEvictionEventSelfTest.class));
+        suite.addTest(new TestSuite(GridCacheDhtEvictionSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheReplicatedEvictionSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheDhtEvictionNearReadersSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheDhtAtomicEvictionNearReadersSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedTopologyChangeSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedPreloadEventsSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedUnloadEventsSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCachePartitionedAffinityHashIdResolverSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheColocatedOptimisticTransactionSelfTest.class));
+        suite.addTestSuite(GridCacheAtomicMessageCountSelfTest.class);
+        suite.addTest(new 
TestSuite(GridCacheNearPartitionedClearSelfTest.class));
+        suite.addTest(new TestSuite(IgniteCacheNearOffheapGetSelfTest.class));
+
+        suite.addTest(new 
TestSuite(GridCacheDhtExpiredEntriesPreloadSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheNearExpiredEntriesPreloadSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheAtomicExpiredEntriesPreloadSelfTest.class));
+
+        suite.addTest(new TestSuite(GridCacheOffheapUpdateSelfTest.class));
+
+        suite.addTest(new TestSuite(GridCacheNearPrimarySyncSelfTest.class));
+        suite.addTest(new 
TestSuite(GridCacheColocatedPrimarySyncSelfTest.class));
+
+        suite.addTest(new TestSuite(IgniteCachePartitionMapUpdateTest.class));
+        suite.addTest(new 
TestSuite(IgniteCacheClientNodePartitionsExchangeTest.class));
+        suite.addTest(new 
TestSuite(IgniteCacheClientNodeChangingTopologyTest.class));
+        suite.addTest(new 
TestSuite(IgniteCacheServerNodeConcurrentStart.class));
+
+        suite.addTest(new 
TestSuite(IgniteCacheEntryProcessorNodeJoinTest.class));
+        suite.addTest(new 
TestSuite(IgniteAtomicCacheEntryProcessorNodeJoinTest.class));
+        suite.addTest(new TestSuite(GridCacheNearTxForceKeyTest.class));
+        suite.addTest(new TestSuite(CrossCacheTxRandomOperationsTest.class));
+        suite.addTest(new TestSuite(IgniteDynamicCacheAndNodeStop.class));
+        suite.addTest(new TestSuite(CacheLockReleaseNodeLeaveTest.class));
+        suite.addTest(new TestSuite(NearCacheSyncUpdateTest.class));
+        suite.addTest(new TestSuite(CacheConfigurationLeakTest.class));
+        suite.addTest(new TestSuite(CacheEnumOperationsSingleNodeTest.class));
+        suite.addTest(new TestSuite(CacheEnumOperationsTest.class));
+        suite.addTest(new TestSuite(IgniteCacheIncrementTxTest.class));
+
+        suite.addTest(new TestSuite(IgniteNoCustomEventsOnNodeStart.class));
 
         return suite;
     }

Reply via email to