ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [46/51] incubator-ignite git commit: ignite-709
Date Fri, 10 Apr 2015 12:12:57 GMT
ignite-709


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

Branch: refs/heads/ignite-709
Commit: c412dd0f832845e1a8b64f3a48d8fe0dc6e042fd
Parents: 5701ff0
Author: Denis Magda <dmagda@gridgain.com>
Authored: Fri Apr 10 13:01:34 2015 +0300
Committer: Denis Magda <dmagda@gridgain.com>
Committed: Fri Apr 10 13:01:34 2015 +0300

----------------------------------------------------------------------
 ...acheTcpClientDiscoveryMultithreadedTest.java |  7 +++
 ...acheTcpClientDiscoveryMultiThreadedTest.java | 60 ++++++++++++++++++++
 2 files changed, 67 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c412dd0f/modules/core/src/test/java/org/apache/ignite/internal/processors/GridCacheTcpClientDiscoveryMultithreadedTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/GridCacheTcpClientDiscoveryMultithreadedTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/GridCacheTcpClientDiscoveryMultithreadedTest.java
new file mode 100644
index 0000000..94f6ae7
--- /dev/null
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/GridCacheTcpClientDiscoveryMultithreadedTest.java
@@ -0,0 +1,7 @@
+package org.apache.ignite.internal.processors;
+
+/**
+ * Created by GridAdmin1234 on 4/10/2015.
+ */
+public class GridCacheTcpClientDiscoveryMultithreadedTest {
+}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c412dd0f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheTcpClientDiscoveryMultiThreadedTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheTcpClientDiscoveryMultiThreadedTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheTcpClientDiscoveryMultiThreadedTest.java
new file mode 100644
index 0000000..1c7ce3d
--- /dev/null
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheTcpClientDiscoveryMultiThreadedTest.java
@@ -0,0 +1,60 @@
+/*
+ * 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;
+
+import org.apache.ignite.configuration.CacheConfiguration;
+import org.apache.ignite.configuration.IgniteConfiguration;
+import org.apache.ignite.internal.processors.cache.GridCacheAbstractSelfTest;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ * Tests TcpClientDiscovery SPI with multiple client nodes that interact with a cache concurrently.
+ */
+public class GridCacheTcpClientDiscoveryMultiThreadedTest extends GridCacheAbstractSelfTest
{
+    /** Server nodes count. */
+    private final static int SERVER_NODES_COUNT = 3;
+
+    /** Client nodes count. */
+    private final static int CLIENT_NODES_COUNT = 5;
+
+    /** Grids counter. */
+    private static AtomicInteger gridsCounter;
+
+    /** {@inheritDoc} */
+    @Override protected int gridCount() {
+        return SERVER_NODES_COUNT + CLIENT_NODES_COUNT;
+    }
+    
+    /** {@inheritDoc} */
+    @Override protected void beforeTestsStarted() throws Exception {
+        gridsCounter = new AtomicInteger();
+        
+        startGridsMultiThreaded(gridCount());
+    }
+
+    /** {@inheritDoc} */
+    @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception
{
+        return super.getConfiguration(gridName);
+    }
+
+    /** {@inheritDoc} */
+    @Override protected CacheConfiguration cacheConfiguration(String gridName) throws Exception
{
+        return super.cacheConfiguration(gridName);
+    }
+}


Mime
View raw message