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 09:24:23 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-comm-balance de50ab3ef -> c2dcb255d


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/c2dcb255
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c2dcb255
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c2dcb255

Branch: refs/heads/ignite-comm-balance
Commit: c2dcb255d0ef4a9ef3f67652612cb9303fff5e7a
Parents: de50ab3
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Sep 23 12:24:14 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Sep 23 12:24:14 2016 +0300

----------------------------------------------------------------------
 .../ignite/internal/util/nio/GridNioServer.java |  21 +-
 .../internal/util/nio/GridNioSessionImpl.java   |  29 --
 .../IgniteCommunicationBalanceTest.java         |  33 +-
 .../ignite/testsuites/IgniteCacheTestSuite.java | 305 ++++++++++---------
 4 files changed, 188 insertions(+), 200 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/c2dcb255/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 7352b5c..7b546ef 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
@@ -633,6 +633,9 @@ public class GridNioServer<T> {
      *
      */
     public void dumpStats() {
+        U.warn(log, "Server statistics [readerSesBalanceCnt=" + readerMoveCount() +
+            ", writerSesBalanceCnt=" + writerMoveCount() + ']');
+
         for (int i = 0; i < clientWorkers.size(); i++)
             clientWorkers.get(i).offer(new NioOperationFuture<Void>(null, NioOperation.DUMP_STATS));
     }
@@ -987,7 +990,6 @@ public class GridNioServer<T> {
                 metricsLsnr.onBytesReceived(cnt);
 
             ses.bytesReceived(cnt);
-            ses.onBytesRead(cnt, readBuf.capacity());
             onRead(cnt);
 
             readBuf.flip();
@@ -1303,7 +1305,6 @@ public class GridNioServer<T> {
                     metricsLsnr.onBytesSent(cnt);
 
                 ses.bytesSent(cnt);
-                ses.onBytesWritten(cnt, buf.capacity());
                 onWrite(cnt);
             }
             else {
@@ -1527,6 +1528,8 @@ public class GridNioServer<T> {
                                         ses);
 
                                     ses.key(key);
+
+                                    f.onDone(true);
                                 }
                                 else {
                                     assert f.movedSocketChannel() == null : f;
@@ -1536,12 +1539,16 @@ public class GridNioServer<T> {
 
                                         SelectionKey key = ses.key();
 
+                                        assert key.channel() != null : key;
+
                                         f.movedSocketChannel((SocketChannel)key.channel());
 
                                         key.cancel();
 
                                         clientWorkers.get(f.toIndex()).offer(f);
                                     }
+                                    else
+                                        f.onDone(false);
                                 }
 
                                 break;
@@ -1656,8 +1663,6 @@ public class GridNioServer<T> {
                                         .append(", bytesSent=").append(ses.bytesSent())
                                         .append(", bytesSent0=").append(ses.bytesSent0())
                                         .append(", opQueueSize=").append(ses.writeQueueSize())
-                                        .append(", writeStats=").append(Arrays.toString(ses.writeStats()))
-                                        .append(", readStats=").append(Arrays.toString(ses.readStats()))
                                         .append(", msgWriter=").append(writer != null ? writer.toString()
: "null")
                                         .append(", msgReader=").append(reader != null ? reader.toString()
: "null");
 
@@ -2487,7 +2492,7 @@ public class GridNioServer<T> {
     /**
      *
      */
-    private static class SessionMoveFuture<R> extends NioOperationFuture<R> {
+    private static class SessionMoveFuture extends NioOperationFuture<Boolean> {
         /** */
         private final int toIdx;
 
@@ -2526,6 +2531,8 @@ public class GridNioServer<T> {
          * @param movedSockCh Moved session socket channel.
          */
         void movedSocketChannel(SocketChannel movedSockCh) {
+            assert movedSockCh != null;
+
             this.movedSockCh = movedSockCh;
         }
 
@@ -3073,7 +3080,7 @@ public class GridNioServer<T> {
 
                         srv.writerMoveCnt.incrementAndGet();
 
-                        clientWorkers.get(maxSentIdx).offer(new SessionMoveFuture(ses, minSentIdx));
+                        srv.moveSession(ses, maxSentIdx, minSentIdx);
                     }
                     else {
                         if (log.isDebugEnabled())
@@ -3115,7 +3122,7 @@ public class GridNioServer<T> {
 
                         srv.readerMoveCnt.incrementAndGet();
 
-                        clientWorkers.get(maxRcvdIdx).offer(new SessionMoveFuture(ses, minRcvdIdx));
+                        srv.moveSession(ses, maxRcvdIdx, minRcvdIdx);
                     }
                     else {
                         if (log.isDebugEnabled())

http://git-wip-us.apache.org/repos/asf/ignite/blob/c2dcb255/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
index 3f5d367..a8d1afa 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioSessionImpl.java
@@ -45,9 +45,6 @@ public class GridNioSessionImpl implements GridNioSession {
     /** Session close timestamp. */
     private final AtomicLong closeTime = new AtomicLong();
 
-    private final long[] writesStat = new long[25];
-    private final long[] readsStat = new long[25];
-
     /** Sent bytes counter. */
     private volatile long bytesSent;
 
@@ -267,32 +264,6 @@ public class GridNioSessionImpl implements GridNioSession {
         lastSndTime = U.currentTimeMillis();
     }
 
-    public void onBytesWritten(int cnt, int bufCap) {
-        int idx = (int)Math.floor(((cnt * 1.0) / bufCap) * writesStat.length);
-
-        if (idx >= writesStat.length)
-            idx = writesStat.length - 1;
-
-        writesStat[idx]++;
-    }
-
-    public void onBytesRead(int cnt, int bufCap) {
-        int idx = (int)Math.floor(((cnt * 1.0) / bufCap) * readsStat.length);
-
-        if (idx >= readsStat.length)
-            idx = readsStat.length - 1;
-
-        readsStat[idx]++;
-    }
-
-    public long[] readStats() {
-        return readsStat;
-    }
-
-    public long[] writeStats() {
-        return writesStat;
-    }
-
     /**
      * Adds given amount ob bytes to the received bytes counter.
      * <p>

http://git-wip-us.apache.org/repos/asf/ignite/blob/c2dcb255/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 ddd979b..f6fd2c1 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
@@ -37,6 +37,7 @@ import org.apache.ignite.internal.util.nio.GridNioServer;
 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;
@@ -104,7 +105,7 @@ public class IgniteCommunicationBalanceTest extends GridCommonAbstractTest
{
             for (int i = 0; i < 4; i++) {
                 ClusterNode node = client.cluster().node(ignite(i).cluster().localNode().id());
 
-                client.compute(client.cluster().forNode(node)).run(new DummyRunnable(null));
+                client.compute(client.cluster().forNode(node)).call(new DummyCallable(null));
             }
 
             waitNioBalanceStop(Collections.singletonList(client), 10_000);
@@ -117,16 +118,22 @@ public class IgniteCommunicationBalanceTest extends GridCommonAbstractTest
{
             long writeMoveCnt1 = srv.writerMoveCount();
 
             for (int iter = 0; iter < 10; iter++) {
-                log.info("Iteration: " + iter);
-
                 int nodeIdx = rnd.nextInt(4);
 
+                log.info("Iteration [iter=" + iter + ", node=" + nodeIdx + ']');
+
                 ClusterNode node = client.cluster().node(ignite(nodeIdx).cluster().localNode().id());
 
-                IgniteCompute compute = client.compute(client.cluster().forNode(node));
+                final IgniteCompute compute = client.compute(client.cluster().forNode(node));
 
-                for (int i = 0; i < 10_000; i++)
-                    compute.run(new DummyRunnable(null));
+                GridTestUtils.runMultiThreaded(new Callable<Void>() {
+                    @Override public Void call() throws Exception {
+                        for (int i = 0; i < 5_000; i++)
+                            compute.call(new DummyCallable(null));
+
+                        return null;
+                    }
+                }, 10, "send-thread");
 
                 final long readMoveCnt = readMoveCnt1;
                 final long writeMoveCnt = writeMoveCnt1;
@@ -189,7 +196,7 @@ public class IgniteCommunicationBalanceTest extends GridCommonAbstractTest
{
 
                             IgniteCompute compute = node.compute(node.cluster().forNode(sntToNode));
 
-                            compute.run(new DummyRunnable(new byte[rnd.nextInt(1024)]));
+                            compute.call(new DummyCallable(new byte[rnd.nextInt(1024)]));
                         }
 
                         return null;
@@ -281,7 +288,7 @@ public class IgniteCommunicationBalanceTest extends GridCommonAbstractTest
{
                     ThreadLocalRandom rnd = ThreadLocalRandom.current();
 
                     while (System.currentTimeMillis() < stopTime)
-                        ignite(rnd.nextInt(NODES)).compute().broadcast(new DummyRunnable(null));
+                        ignite(rnd.nextInt(NODES)).compute().broadcast(new DummyCallable(null));
 
                     return null;
                 }
@@ -295,20 +302,20 @@ public class IgniteCommunicationBalanceTest extends GridCommonAbstractTest
{
     /**
      *
      */
-    private static class DummyRunnable implements IgniteRunnable {
+    private static class DummyCallable implements IgniteCallable<Object> {
         /** */
         private byte[] data;
 
         /**
          * @param data Data.
          */
-        public DummyRunnable(byte[] data) {
+        DummyCallable(byte[] data) {
             this.data = data;
         }
 
         /** {@inheritDoc} */
-        @Override public void run() {
-            // No-op.
+        @Override public Object call() throws Exception {
+            return new byte[ThreadLocalRandom.current().nextInt(1024)];
         }
     }
 
@@ -350,7 +357,7 @@ public class IgniteCommunicationBalanceTest extends GridCommonAbstractTest
{
 
             if (ses != null) {
                 System.out.println("[" + Thread.currentThread().getName() + "] Move session
" +
-                    "[w1=" + w1 + ", w2=" + w2 + ", ses=" + ses + ']');
+                    "[w1=" + w1 + ", w2=" + w2 + ", sesHash=" + System.identityHashCode(ses)
+ ", ses=" + ses + ']');
 
                 srv.moveSession(ses, w1, w2);
             }

http://git-wip-us.apache.org/repos/asf/ignite/blob/c2dcb255/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 5b24a13..0cbc7a5 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
@@ -171,157 +171,160 @@ public class IgniteCacheTestSuite extends TestSuite {
     public static TestSuite suite(Set<Class> ignoredTests) throws Exception {
         TestSuite suite = new TestSuite("IgniteCache Test Suite");
 
-        suite.addTestSuite(IgniteCacheEntryListenerAtomicTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerAtomicReplicatedTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerAtomicLocalTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerTxTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerTxOffheapTieredTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerTxOffheapValuesTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerTxReplicatedTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerTxLocalTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerEagerTtlDisabledTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerAtomicOffheapTieredTest.class);
-        suite.addTestSuite(IgniteCacheEntryListenerAtomicOffheapValuesTest.class);
-
-        suite.addTestSuite(IgniteClientAffinityAssignmentSelfTest.class);
-
-        suite.addTestSuite(IgniteCacheAtomicInvokeTest.class);
-        suite.addTestSuite(IgniteCacheAtomicNearEnabledInvokeTest.class);
-        suite.addTestSuite(IgniteCacheAtomicPrimaryWriteOrderInvokeTest.class);
-        suite.addTestSuite(IgniteCacheAtomicPrimaryWriteOrderWithStoreInvokeTest.class);
-        suite.addTestSuite(IgniteCacheAtomicLocalInvokeTest.class);
-        suite.addTestSuite(IgniteCacheAtomicLocalWithStoreInvokeTest.class);
-        suite.addTestSuite(IgniteCacheTxInvokeTest.class);
-        suite.addTestSuite(CacheEntryProcessorNonSerializableTest.class);
-        suite.addTestSuite(IgniteCacheEntryProcessorCallTest.class);
-        GridTestUtils.addTestIfNeeded(suite, CacheEntryProcessorCopySelfTest.class, ignoredTests);
-        suite.addTestSuite(IgniteCacheTxNearEnabledInvokeTest.class);
-        suite.addTestSuite(IgniteCacheTxLocalInvokeTest.class);
-        suite.addTestSuite(IgniteCrossCacheTxStoreSelfTest.class);
-
-        suite.addTestSuite(IgnitePutAllLargeBatchSelfTest.class);
-        suite.addTestSuite(IgnitePutAllUpdateNonPreloadedPartitionSelfTest.class);
-
-        // User's class loader tests.
-        GridTestUtils.addTestIfNeeded(suite, IgniteCacheAtomicExecutionContextTest.class,
ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, IgniteCachePartitionedExecutionContextTest.class,
ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, IgniteCacheReplicatedExecutionContextTest.class,
ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, IgniteCacheTxExecutionContextTest.class, ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, IgniteCacheContinuousExecutionContextTest.class,
ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, IgniteCacheIsolatedExecutionContextTest.class,
ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, IgniteCacheP2PDisableExecutionContextTest.class,
ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, IgniteCachePrivateExecutionContextTest.class,
ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, IgniteCacheSharedExecutionContextTest.class,
ignoredTests);
-
-        // Warmup closure tests.
-        suite.addTestSuite(IgniteWarmupClosureSelfTest.class);
-
-        // Affinity tests.
-        suite.addTestSuite(FairAffinityFunctionNodesSelfTest.class);
-        suite.addTestSuite(FairAffinityFunctionSelfTest.class);
-        suite.addTestSuite(FairAffinityDynamicCacheSelfTest.class);
-        suite.addTestSuite(GridCacheAffinityBackupsSelfTest.class);
-        suite.addTestSuite(IgniteCacheAffinitySelfTest.class);
-        suite.addTestSuite(AffinityClientNodeSelfTest.class);
-        suite.addTestSuite(LocalAffinityFunctionTest.class);
-        suite.addTestSuite(AffinityHistoryCleanupTest.class);
-
-        // Swap tests.
-        suite.addTestSuite(GridCacheSwapPreloadSelfTest.class);
-        suite.addTestSuite(GridCacheSwapReloadSelfTest.class);
-
-        // Common tests.
-        suite.addTestSuite(CacheNamesSelfTest.class);
-        suite.addTestSuite(CacheNamesWithSpecialCharactersTest.class);
-        suite.addTestSuite(GridCacheConcurrentMapSelfTest.class);
-        suite.addTestSuite(GridCacheAffinityMapperSelfTest.class);
-        suite.addTestSuite(CacheAffinityCallSelfTest.class);
-        GridTestUtils.addTestIfNeeded(suite, GridCacheAffinityRoutingSelfTest.class, ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, GridCacheMvccSelfTest.class, ignoredTests);
-        suite.addTestSuite(GridCacheMvccPartitionedSelfTest.class);
-        suite.addTestSuite(GridCacheMvccManagerSelfTest.class);
-        suite.addTestSuite(GridCacheP2PUndeploySelfTest.class);
-        suite.addTestSuite(GridCacheConfigurationValidationSelfTest.class);
-        suite.addTestSuite(GridCacheConfigurationConsistencySelfTest.class);
-        suite.addTestSuite(GridCacheJdbcBlobStoreSelfTest.class);
-        suite.addTestSuite(GridCacheJdbcBlobStoreMultithreadedSelfTest.class);
-        suite.addTestSuite(CacheJdbcPojoStoreTest.class);
-        suite.addTestSuite(CacheJdbcPojoStoreOptimizedMarshallerSelfTest.class);
-        suite.addTestSuite(CacheJdbcPojoStoreBinaryMarshallerSelfTest.class);
-        suite.addTestSuite(CacheJdbcPojoStoreMultitreadedSelfTest.class);
-        suite.addTestSuite(GridCacheBalancingStoreSelfTest.class);
-        suite.addTestSuite(GridCacheAffinityApiSelfTest.class);
-        suite.addTestSuite(GridCacheStoreValueBytesSelfTest.class);
-        GridTestUtils.addTestIfNeeded(suite, DataStreamProcessorSelfTest.class, ignoredTests);
-        GridTestUtils.addTestIfNeeded(suite, DataStreamerUpdateAfterLoadTest.class, ignoredTests);
-        suite.addTestSuite(DataStreamerMultiThreadedSelfTest.class);
-        suite.addTestSuite(DataStreamerMultinodeCreateCacheTest.class);
-        suite.addTestSuite(DataStreamerImplSelfTest.class);
-        suite.addTestSuite(DataStreamerTimeoutTest.class);
-        GridTestUtils.addTestIfNeeded(suite, GridCacheEntryMemorySizeSelfTest.class, ignoredTests);
-        suite.addTestSuite(GridCacheClearAllSelfTest.class);
-        suite.addTestSuite(GridCacheObjectToStringSelfTest.class);
-        suite.addTestSuite(GridCacheLoadOnlyStoreAdapterSelfTest.class);
-        suite.addTestSuite(GridCacheGetStoreErrorSelfTest.class);
-        suite.addTestSuite(StoreResourceInjectionSelfTest.class);
-        suite.addTestSuite(CacheFutureExceptionSelfTest.class);
-        suite.addTestSuite(GridCacheAsyncOperationsLimitSelfTest.class);
-        suite.addTestSuite(IgniteCacheManyAsyncOperationsTest.class);
-        suite.addTestSuite(GridCacheTtlManagerSelfTest.class);
-        suite.addTestSuite(GridCacheLifecycleAwareSelfTest.class);
-        suite.addTestSuite(IgniteCacheAtomicStopBusySelfTest.class);
-        suite.addTestSuite(IgniteCacheTransactionalStopBusySelfTest.class);
-        suite.addTestSuite(GridCacheAtomicNearCacheSelfTest.class);
-        suite.addTestSuite(CacheAtomicNearUpdateTopologyChangeTest.class);
-        suite.addTestSuite(CacheTxNearUpdateTopologyChangeTest.class);
-        suite.addTestSuite(GridCacheStorePutxSelfTest.class);
-        suite.addTestSuite(GridCacheOffHeapMultiThreadedUpdateSelfTest.class);
-        suite.addTestSuite(GridCacheOffHeapAtomicMultiThreadedUpdateSelfTest.class);
-        suite.addTestSuite(GridCacheOffHeapValuesEvictionSelfTest.class);
-        suite.addTestSuite(GridCacheColocatedTxStoreExceptionSelfTest.class);
-        suite.addTestSuite(GridCacheReplicatedTxStoreExceptionSelfTest.class);
-        suite.addTestSuite(GridCacheLocalTxStoreExceptionSelfTest.class);
-        suite.addTestSuite(GridCacheNearTxStoreExceptionSelfTest.class);
-        suite.addTestSuite(GridCacheMissingCommitVersionSelfTest.class);
-        suite.addTestSuite(GridCacheEntrySetIterationPreloadingSelfTest.class);
-        suite.addTestSuite(GridCacheMixedPartitionExchangeSelfTest.class);
-        suite.addTestSuite(IgniteCacheAtomicMessageRecoveryTest.class);
-        suite.addTestSuite(IgniteCacheAtomicMessageRecovery10ConnectionsTest.class);
-        suite.addTestSuite(IgniteCacheTxMessageRecoveryTest.class);
-        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);
-        GridTestUtils.addTestIfNeeded(suite, GridCacheOffHeapTieredSelfTest.class, ignoredTests);
-        suite.addTestSuite(GridCacheGlobalLoadTest.class);
-        suite.addTestSuite(GridCachePartitionedLocalStoreSelfTest.class);
-        suite.addTestSuite(GridCacheReplicatedLocalStoreSelfTest.class);
-        suite.addTestSuite(GridCachePartitionedOffHeapLocalStoreSelfTest.class);
-        suite.addTestSuite(GridCacheTxPartitionedLocalStoreSelfTest.class);
-        suite.addTestSuite(IgniteCacheSystemTransactionsSelfTest.class);
-        suite.addTestSuite(CacheDeferredDeleteSanitySelfTest.class);
-
-        suite.addTest(IgniteCacheTcpClientDiscoveryTestSuite.suite());
-
-        // Heuristic exception handling.
-        suite.addTestSuite(GridCacheColocatedTxExceptionSelfTest.class);
-        suite.addTestSuite(GridCacheReplicatedTxExceptionSelfTest.class);
-        suite.addTestSuite(GridCacheLocalTxExceptionSelfTest.class);
-        suite.addTestSuite(GridCacheNearTxExceptionSelfTest.class);
-        suite.addTestSuite(GridCacheStopSelfTest.class);
-
-        suite.addTestSuite(IgniteCacheNearLockValueSelfTest.class);
-
-        suite.addTestSuite(CachePutEventListenerErrorSelfTest.class);
-
-        suite.addTestSuite(IgniteTxConfigCacheSelfTest.class);
-
-        suite.addTestSuite(CacheTxFastFinishTest.class);
-
-        suite.addTestSuite(IgniteVariousConnectionNumberTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerAtomicTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerAtomicReplicatedTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerAtomicLocalTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerTxTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerTxOffheapTieredTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerTxOffheapValuesTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerTxReplicatedTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerTxLocalTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerEagerTtlDisabledTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerAtomicOffheapTieredTest.class);
+//        suite.addTestSuite(IgniteCacheEntryListenerAtomicOffheapValuesTest.class);
+//
+//        suite.addTestSuite(IgniteClientAffinityAssignmentSelfTest.class);
+//
+//        suite.addTestSuite(IgniteCacheAtomicInvokeTest.class);
+//        suite.addTestSuite(IgniteCacheAtomicNearEnabledInvokeTest.class);
+//        suite.addTestSuite(IgniteCacheAtomicPrimaryWriteOrderInvokeTest.class);
+//        suite.addTestSuite(IgniteCacheAtomicPrimaryWriteOrderWithStoreInvokeTest.class);
+//        suite.addTestSuite(IgniteCacheAtomicLocalInvokeTest.class);
+//        suite.addTestSuite(IgniteCacheAtomicLocalWithStoreInvokeTest.class);
+//        suite.addTestSuite(IgniteCacheTxInvokeTest.class);
+//        suite.addTestSuite(CacheEntryProcessorNonSerializableTest.class);
+//        suite.addTestSuite(IgniteCacheEntryProcessorCallTest.class);
+//        GridTestUtils.addTestIfNeeded(suite, CacheEntryProcessorCopySelfTest.class, ignoredTests);
+//        suite.addTestSuite(IgniteCacheTxNearEnabledInvokeTest.class);
+//        suite.addTestSuite(IgniteCacheTxLocalInvokeTest.class);
+//        suite.addTestSuite(IgniteCrossCacheTxStoreSelfTest.class);
+//
+//        suite.addTestSuite(IgnitePutAllLargeBatchSelfTest.class);
+//        suite.addTestSuite(IgnitePutAllUpdateNonPreloadedPartitionSelfTest.class);
+//
+//        // User's class loader tests.
+//        GridTestUtils.addTestIfNeeded(suite, IgniteCacheAtomicExecutionContextTest.class,
ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, IgniteCachePartitionedExecutionContextTest.class,
ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, IgniteCacheReplicatedExecutionContextTest.class,
ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, IgniteCacheTxExecutionContextTest.class, ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, IgniteCacheContinuousExecutionContextTest.class,
ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, IgniteCacheIsolatedExecutionContextTest.class,
ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, IgniteCacheP2PDisableExecutionContextTest.class,
ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, IgniteCachePrivateExecutionContextTest.class,
ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, IgniteCacheSharedExecutionContextTest.class,
ignoredTests);
+//
+//        // Warmup closure tests.
+//        suite.addTestSuite(IgniteWarmupClosureSelfTest.class);
+//
+//        // Affinity tests.
+//        suite.addTestSuite(FairAffinityFunctionNodesSelfTest.class);
+//        suite.addTestSuite(FairAffinityFunctionSelfTest.class);
+//        suite.addTestSuite(FairAffinityDynamicCacheSelfTest.class);
+//        suite.addTestSuite(GridCacheAffinityBackupsSelfTest.class);
+//        suite.addTestSuite(IgniteCacheAffinitySelfTest.class);
+//        suite.addTestSuite(AffinityClientNodeSelfTest.class);
+//        suite.addTestSuite(LocalAffinityFunctionTest.class);
+//        suite.addTestSuite(AffinityHistoryCleanupTest.class);
+//
+//        // Swap tests.
+//        suite.addTestSuite(GridCacheSwapPreloadSelfTest.class);
+//        suite.addTestSuite(GridCacheSwapReloadSelfTest.class);
+//
+//        // Common tests.
+//        suite.addTestSuite(CacheNamesSelfTest.class);
+//        suite.addTestSuite(CacheNamesWithSpecialCharactersTest.class);
+//        suite.addTestSuite(GridCacheConcurrentMapSelfTest.class);
+//        suite.addTestSuite(GridCacheAffinityMapperSelfTest.class);
+//        suite.addTestSuite(CacheAffinityCallSelfTest.class);
+//        GridTestUtils.addTestIfNeeded(suite, GridCacheAffinityRoutingSelfTest.class, ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, GridCacheMvccSelfTest.class, ignoredTests);
+//        suite.addTestSuite(GridCacheMvccPartitionedSelfTest.class);
+//        suite.addTestSuite(GridCacheMvccManagerSelfTest.class);
+//        suite.addTestSuite(GridCacheP2PUndeploySelfTest.class);
+//        suite.addTestSuite(GridCacheConfigurationValidationSelfTest.class);
+//        suite.addTestSuite(GridCacheConfigurationConsistencySelfTest.class);
+//        suite.addTestSuite(GridCacheJdbcBlobStoreSelfTest.class);
+//        suite.addTestSuite(GridCacheJdbcBlobStoreMultithreadedSelfTest.class);
+//        suite.addTestSuite(CacheJdbcPojoStoreTest.class);
+//        suite.addTestSuite(CacheJdbcPojoStoreOptimizedMarshallerSelfTest.class);
+//        suite.addTestSuite(CacheJdbcPojoStoreBinaryMarshallerSelfTest.class);
+//        suite.addTestSuite(CacheJdbcPojoStoreMultitreadedSelfTest.class);
+//        suite.addTestSuite(GridCacheBalancingStoreSelfTest.class);
+//        suite.addTestSuite(GridCacheAffinityApiSelfTest.class);
+//        suite.addTestSuite(GridCacheStoreValueBytesSelfTest.class);
+//        GridTestUtils.addTestIfNeeded(suite, DataStreamProcessorSelfTest.class, ignoredTests);
+//        GridTestUtils.addTestIfNeeded(suite, DataStreamerUpdateAfterLoadTest.class, ignoredTests);
+//        suite.addTestSuite(DataStreamerMultiThreadedSelfTest.class);
+//        suite.addTestSuite(DataStreamerMultinodeCreateCacheTest.class);
+//        suite.addTestSuite(DataStreamerImplSelfTest.class);
+//        suite.addTestSuite(DataStreamerTimeoutTest.class);
+//        GridTestUtils.addTestIfNeeded(suite, GridCacheEntryMemorySizeSelfTest.class, ignoredTests);
+//        suite.addTestSuite(GridCacheClearAllSelfTest.class);
+//        suite.addTestSuite(GridCacheObjectToStringSelfTest.class);
+//        suite.addTestSuite(GridCacheLoadOnlyStoreAdapterSelfTest.class);
+//        suite.addTestSuite(GridCacheGetStoreErrorSelfTest.class);
+//        suite.addTestSuite(StoreResourceInjectionSelfTest.class);
+//        suite.addTestSuite(CacheFutureExceptionSelfTest.class);
+//        suite.addTestSuite(GridCacheAsyncOperationsLimitSelfTest.class);
+//        suite.addTestSuite(IgniteCacheManyAsyncOperationsTest.class);
+//        suite.addTestSuite(GridCacheTtlManagerSelfTest.class);
+//        suite.addTestSuite(GridCacheLifecycleAwareSelfTest.class);
+//        suite.addTestSuite(IgniteCacheAtomicStopBusySelfTest.class);
+//        suite.addTestSuite(IgniteCacheTransactionalStopBusySelfTest.class);
+//        suite.addTestSuite(GridCacheAtomicNearCacheSelfTest.class);
+//        suite.addTestSuite(CacheAtomicNearUpdateTopologyChangeTest.class);
+//        suite.addTestSuite(CacheTxNearUpdateTopologyChangeTest.class);
+//        suite.addTestSuite(GridCacheStorePutxSelfTest.class);
+//        suite.addTestSuite(GridCacheOffHeapMultiThreadedUpdateSelfTest.class);
+//        suite.addTestSuite(GridCacheOffHeapAtomicMultiThreadedUpdateSelfTest.class);
+//        suite.addTestSuite(GridCacheOffHeapValuesEvictionSelfTest.class);
+//        suite.addTestSuite(GridCacheColocatedTxStoreExceptionSelfTest.class);
+//        suite.addTestSuite(GridCacheReplicatedTxStoreExceptionSelfTest.class);
+//        suite.addTestSuite(GridCacheLocalTxStoreExceptionSelfTest.class);
+//        suite.addTestSuite(GridCacheNearTxStoreExceptionSelfTest.class);
+//        suite.addTestSuite(GridCacheMissingCommitVersionSelfTest.class);
+//        suite.addTestSuite(GridCacheEntrySetIterationPreloadingSelfTest.class);
+//        suite.addTestSuite(GridCacheMixedPartitionExchangeSelfTest.class);
+//        suite.addTestSuite(IgniteCacheAtomicMessageRecoveryTest.class);
+//        suite.addTestSuite(IgniteCacheAtomicMessageRecovery10ConnectionsTest.class);
+//        suite.addTestSuite(IgniteCacheTxMessageRecoveryTest.class);
+//        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);
+//        GridTestUtils.addTestIfNeeded(suite, GridCacheOffHeapTieredSelfTest.class, ignoredTests);
+//        suite.addTestSuite(GridCacheGlobalLoadTest.class);
+//        suite.addTestSuite(GridCachePartitionedLocalStoreSelfTest.class);
+//        suite.addTestSuite(GridCacheReplicatedLocalStoreSelfTest.class);
+//        suite.addTestSuite(GridCachePartitionedOffHeapLocalStoreSelfTest.class);
+//        suite.addTestSuite(GridCacheTxPartitionedLocalStoreSelfTest.class);
+//        suite.addTestSuite(IgniteCacheSystemTransactionsSelfTest.class);
+//        suite.addTestSuite(CacheDeferredDeleteSanitySelfTest.class);
+//
+//        suite.addTest(IgniteCacheTcpClientDiscoveryTestSuite.suite());
+//
+//        // Heuristic exception handling.
+//        suite.addTestSuite(GridCacheColocatedTxExceptionSelfTest.class);
+//        suite.addTestSuite(GridCacheReplicatedTxExceptionSelfTest.class);
+//        suite.addTestSuite(GridCacheLocalTxExceptionSelfTest.class);
+//        suite.addTestSuite(GridCacheNearTxExceptionSelfTest.class);
+//        suite.addTestSuite(GridCacheStopSelfTest.class);
+//
+//        suite.addTestSuite(IgniteCacheNearLockValueSelfTest.class);
+//
+//        suite.addTestSuite(CachePutEventListenerErrorSelfTest.class);
+//
+//        suite.addTestSuite(IgniteTxConfigCacheSelfTest.class);
+//
+//        suite.addTestSuite(CacheTxFastFinishTest.class);
+//
+//        suite.addTestSuite(IgniteVariousConnectionNumberTest.class);
+        suite.addTestSuite(IgniteCommunicationBalanceTest.class);
+        suite.addTestSuite(IgniteCommunicationBalanceTest.class);
+        suite.addTestSuite(IgniteCommunicationBalanceTest.class);
         suite.addTestSuite(IgniteCommunicationBalanceTest.class);
 
         return suite;


Mime
View raw message