ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-comm-balance
Date Fri, 23 Sep 2016 14:32:35 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-comm-balance d6240f907 -> 2518c8168


ignite-comm-balance


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

Branch: refs/heads/ignite-comm-balance
Commit: 2518c816894f78a5fed0708b27893914e4110c62
Parents: d6240f9
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Sep 23 14:35:33 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Sep 23 17:32:20 2016 +0300

----------------------------------------------------------------------
 .../ignite/internal/util/nio/GridNioServer.java |  82 ++++++++----
 .../util/nio/GridSelectorNioSessionImpl.java    |  18 +++
 .../communication/tcp/TcpCommunicationSpi.java  |   2 +-
 .../IgniteCommunicationBalanceTest.java         |  39 +++---
 .../testsuites/IgniteCacheTestSuite2.java       | 128 +++++++++++++++++--
 5 files changed, 220 insertions(+), 49 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/2518c816/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 326d0ad..33e227a 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
@@ -604,7 +604,12 @@ public class GridNioServer<T> {
         assert to >= 0 && to < clientWorkers.size() : to;
         assert from != to;
 
-        clientWorkers.get(from).offer(new SessionMoveFuture((GridSelectorNioSessionImpl)ses,
to));
+        GridSelectorNioSessionImpl ses0 = (GridSelectorNioSessionImpl)ses;
+
+        SessionMoveFuture fut = new SessionMoveFuture(ses0, to);
+
+        if (!ses0.offerMove(clientWorkers.get(from), fut))
+            fut.onDone(false);
     }
 
     /**
@@ -990,6 +995,7 @@ public class GridNioServer<T> {
                 metricsLsnr.onBytesReceived(cnt);
 
             ses.bytesReceived(cnt);
+
             onRead(cnt);
 
             readBuf.flip();
@@ -1343,15 +1349,22 @@ public class GridNioServer<T> {
         /** Worker index. */
         private final int idx;
 
-        /** Sessions assigned to this worker. */
-        private final GridConcurrentHashSet<GridSelectorNioSessionImpl> workerSessions
=
-            new GridConcurrentHashSet<>();
+        /** */
+        private long bytesRcvd;
 
-        private volatile long bytesRcvd;
-        private volatile long bytesSent;
+        /** */
+        private long bytesSent;
+
+        /** */
         private volatile long bytesRcvd0;
+
+        /** */
         private volatile long bytesSent0;
 
+        /** Sessions assigned to this worker. */
+        private final GridConcurrentHashSet<GridSelectorNioSessionImpl> workerSessions
=
+            new GridConcurrentHashSet<>();
+
         /**
          * @param idx Index of this worker in server's array.
          * @param gridName Grid name.
@@ -1468,7 +1481,7 @@ public class GridNioServer<T> {
             List<GridNioFuture> sesReqs = null;
 
             for (GridNioServer.NioOperationFuture changeReq : changeReqs) {
-                if (changeReq.session() == ses) {
+                if (changeReq.session() == ses && !(changeReq instanceof SessionMoveFuture))
{
                     boolean rmv = changeReqs.remove(changeReq);
 
                     assert rmv : changeReq;
@@ -2070,17 +2083,26 @@ public class GridNioServer<T> {
          */
         protected abstract void processWrite(SelectionKey key) throws IOException;
 
-        protected void onRead(int cnt) { // TODO
+        /**
+         * @param cnt
+         */
+        final void onRead(int cnt) {
             bytesRcvd += cnt;
             bytesRcvd0 += cnt;
         }
 
-        protected void onWrite(int cnt) {
+        /**
+         * @param cnt
+         */
+        final void onWrite(int cnt) {
             bytesSent += cnt;
             bytesSent0 += cnt;
         }
 
-        protected void reset0() {
+        /**
+         *
+         */
+        final void reset0() {
             bytesSent0 = 0;
             bytesRcvd0 = 0;
 
@@ -2266,7 +2288,7 @@ public class GridNioServer<T> {
         /** Register read key selection. */
         REGISTER,
 
-        /** */
+        /** Move session between workers. */
         MOVE,
 
         /** Register write key selection. */
@@ -3001,16 +3023,22 @@ public class GridNioServer<T> {
                 for (int i = 0; i < clientWorkers.size(); i++) {
                     GridNioServer.AbstractNioClientWorker worker = clientWorkers.get(i);
 
-                    if ((i & 1) == 0) {
+                    int sesCnt = worker.workerSessions.size();
+
+                    if (i % 2 == 0) {
                         // Reader.
                         long bytesRcvd0 = worker.bytesRcvd0;
-
-                        if ((maxRcvd0 == -1 || bytesRcvd0 > maxRcvd0) && bytesRcvd0
> 0 &&
-                            worker.workerSessions.size() > 1) {
+//
+//                        if (print)
+//                            log.info("Reader [idx=" + i +
+//                                ", secCnt=" + sesCnt +
+//                                ", received=" + bytesRcvd0 +
+//                                ", sent=" + worker.bytesSent0 +
+//                                ']');
+
+                        if ((maxRcvd0 == -1 || bytesRcvd0 > maxRcvd0) && bytesRcvd0
> 0 && sesCnt > 1) {
                             maxRcvd0 = bytesRcvd0;
                             maxRcvdIdx = i;
-
-                            continue;
                         }
 
                         if (minRcvd0 == -1 || bytesRcvd0 < minRcvd0) {
@@ -3021,13 +3049,17 @@ public class GridNioServer<T> {
                     else {
                         // Writer.
                         long bytesSent0 = worker.bytesSent0;
-
-                        if ((maxSent0 == -1 || bytesSent0 > maxSent0) && bytesSent0
> 0 &&
-                            worker.workerSessions.size() > 1) {
+//
+//                        if (print)
+//                            log.info("Writer [idx=" + i +
+//                                ", secCnt=" + sesCnt +
+//                                ", received=" + worker.bytesRcvd0 +
+//                                ", sent=" + bytesSent0 +
+//                                ']');
+
+                        if ((maxSent0 == -1 || bytesSent0 > maxSent0) && bytesSent0
> 0 && sesCnt > 1) {
                             maxSent0 = bytesSent0;
                             maxSentIdx = i;
-
-                            continue;
                         }
 
                         if (minSent0 == -1 || bytesSent0 < minSent0) {
@@ -3117,8 +3149,10 @@ public class GridNioServer<T> {
                                 ", from=" + maxRcvdIdx + ", to=" + minRcvdIdx + ']');
 
                         if (print)
-                            log.info("Will move session to less loaded reader [diff=" + rcvdDiff
+ ", ses=" + ses +
-                                ", from=" + maxSentIdx + ", to=" + minSentIdx + ']');
+                            log.info("Will move session to less loaded reader [diff=" + rcvdDiff
+
+                                ", from=" + maxSentIdx +
+                                ", to=" + minSentIdx +
+                                ", ses=" + ses + ']');
 
                         srv.readerMoveCnt.incrementAndGet();
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/2518c816/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
index 0c2033b..dc01611 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridSelectorNioSessionImpl.java
@@ -159,6 +159,24 @@ class GridSelectorNioSessionImpl extends GridNioSessionImpl {
     }
 
     /**
+     * @param from
+     * @param fut
+     * @return
+     */
+    boolean offerMove(GridNioWorker from, GridNioFuture fut) {
+        synchronized (this) {
+            GridNioWorker worker0 = worker;
+
+            if (worker0 != from)
+                return false;
+
+            worker.offer(fut);
+        }
+
+        return true;
+    }
+
+    /**
      * @param fut
      */
     void offerStateChange(GridNioFuture fut) {

http://git-wip-us.apache.org/repos/asf/ignite/blob/2518c816/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 146638c..d3f5bfb 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
@@ -3109,7 +3109,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
                             rcvCnt = buf.getLong(1);
                         }
 
-                       if (log.isDebugEnabled())
+                        if (log.isDebugEnabled())
                             log.debug("Received handshake message [rmtNode=" + rmtNodeId
+ ", rcvCnt=" + rcvCnt + ']');
 
                         if (rcvCnt == -1) {

http://git-wip-us.apache.org/repos/asf/ignite/blob/2518c816/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteCommunicationBalanceTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteCommunicationBalanceTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteCommunicationBalanceTest.java
index efe7f65..39fd6a2 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteCommunicationBalanceTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteCommunicationBalanceTest.java
@@ -30,7 +30,6 @@ import org.apache.ignite.IgniteCheckedException;
 import org.apache.ignite.IgniteCompute;
 import org.apache.ignite.cluster.ClusterNode;
 import org.apache.ignite.configuration.IgniteConfiguration;
-import org.apache.ignite.internal.IgniteKernal;
 import org.apache.ignite.internal.util.lang.GridAbsPredicate;
 import org.apache.ignite.internal.util.lang.GridAbsPredicateX;
 import org.apache.ignite.internal.util.nio.GridNioServer;
@@ -38,7 +37,6 @@ import org.apache.ignite.internal.util.nio.GridNioSession;
 import org.apache.ignite.internal.util.typedef.G;
 import org.apache.ignite.internal.util.typedef.internal.U;
 import org.apache.ignite.lang.IgniteCallable;
-import org.apache.ignite.lang.IgniteRunnable;
 import org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi;
 import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
 import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder;
@@ -98,16 +96,18 @@ public class IgniteCommunicationBalanceTest extends GridCommonAbstractTest
{
      * @throws Exception If failed.
      */
     public void testBalance1() throws Exception {
-        System.setProperty(GridNioServer.IGNITE_NIO_SES_BALANCER_BALANCE_PERIOD, "500");
+        System.setProperty(GridNioServer.IGNITE_NIO_SES_BALANCER_BALANCE_PERIOD, "5000");
 
         try {
             selectors = 4;
 
-            startGridsMultiThreaded(4);
+            final int SRVS = 4;
+
+            startGridsMultiThreaded(SRVS);
 
             client = true;
 
-            Ignite client = startGrid(4);
+            final Ignite client = startGrid(SRVS);
 
             for (int i = 0; i < 4; i++) {
                 ClusterNode node = client.cluster().node(ignite(i).cluster().localNode().id());
@@ -127,30 +127,37 @@ public class IgniteCommunicationBalanceTest extends GridCommonAbstractTest
{
             int prevNodeIdx = -1;
 
             for (int iter = 0; iter < 10; iter++) {
-                int nodeIdx = rnd.nextInt(4);
+                int nodeIdx = rnd.nextInt(SRVS);
 
                 while (prevNodeIdx == nodeIdx)
-                    nodeIdx = rnd.nextInt(4);
+                    nodeIdx = rnd.nextInt(SRVS);
 
                 prevNodeIdx = nodeIdx;
 
                 log.info("Iteration [iter=" + iter + ", node=" + nodeIdx + ']');
 
-                ClusterNode node = client.cluster().node(ignite(nodeIdx).cluster().localNode().id());
-
-                final IgniteCompute compute = client.compute(client.cluster().forNode(node));
-
-                for (int i = 0; i < 20_000; i++)
-                    compute.call(new DummyCallable(new byte[512]));
-
                 final long readMoveCnt = readMoveCnt1;
                 final long writeMoveCnt = writeMoveCnt1;
 
+                final int nodeIdx0 = nodeIdx;
+
                 GridTestUtils.waitForCondition(new GridAbsPredicate() {
                     @Override public boolean apply() {
+                        byte[] data = new byte[100_000];
+
+                        for (int j = 0; j < 10; j++) {
+                            for (int i = 0; i < SRVS; i++) {
+                                ClusterNode node = client.cluster().node(ignite(i).cluster().localNode().id());
+
+                                IgniteCompute compute = client.compute(client.cluster().forNode(node));
+
+                                compute.call(new DummyCallable(i == nodeIdx0 ? data : null));
+                            }
+                        }
+
                         return srv.readerMoveCount() > readMoveCnt && srv.writerMoveCount()
> writeMoveCnt;
                     }
-                }, 10_000);
+                }, 30_000);
 
                 waitNioBalanceStop(Collections.singletonList(client), 30_000);
 
@@ -180,7 +187,7 @@ public class IgniteCommunicationBalanceTest extends GridCommonAbstractTest
{
      * @throws Exception If failed.
      */
     public void testBalance2() throws Exception {
-        System.setProperty(GridNioServer.IGNITE_NIO_SES_BALANCER_BALANCE_PERIOD, "500");
+        System.setProperty(GridNioServer.IGNITE_NIO_SES_BALANCER_BALANCE_PERIOD, "1000");
 
         try {
             startGridsMultiThreaded(5);

http://git-wip-us.apache.org/repos/asf/ignite/blob/2518c816/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 3db219a..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
@@ -22,8 +22,6 @@ import org.apache.ignite.cache.affinity.fair.FairAffinityFunctionBackupFilterSel
 import org.apache.ignite.cache.affinity.fair.FairAffinityFunctionExcludeNeighborsSelfTest;
 import org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunctionBackupFilterSelfTest;
 import org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunctionExcludeNeighborsSelfTest;
-import org.apache.ignite.internal.managers.communication.IgniteCommunicationBalanceMultipleConnectionsTest;
-import org.apache.ignite.internal.managers.communication.IgniteCommunicationBalanceTest;
 import org.apache.ignite.internal.processors.cache.CacheConfigurationLeakTest;
 import org.apache.ignite.internal.processors.cache.CacheDhtLocalPartitionAfterRemoveSelfTest;
 import org.apache.ignite.internal.processors.cache.CacheEnumOperationsSingleNodeTest;
@@ -143,12 +141,126 @@ public class IgniteCacheTestSuite2 extends TestSuite {
     public static TestSuite suite() throws Exception {
         TestSuite suite = new TestSuite("IgniteCache Test Suite part 2");
 
-        suite.addTestSuite(IgniteCommunicationBalanceTest.class);
-        suite.addTestSuite(IgniteCommunicationBalanceMultipleConnectionsTest.class);
-        suite.addTestSuite(IgniteCommunicationBalanceTest.class);
-        suite.addTestSuite(IgniteCommunicationBalanceMultipleConnectionsTest.class);
-        suite.addTestSuite(IgniteCommunicationBalanceTest.class);
-        suite.addTestSuite(IgniteCommunicationBalanceMultipleConnectionsTest.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;
     }


Mime
View raw message