You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/05/19 21:39:53 UTC
[01/11] incubator-ignite git commit: # IGNITE-709 Refactoring:
extract GridCommonAbstractTest.createClientDiscovery() method.
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-23 72d6ea5d1 -> fcf02fef4
# IGNITE-709 Refactoring: extract GridCommonAbstractTest.createClientDiscovery() method.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/9bbc1fe9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/9bbc1fe9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/9bbc1fe9
Branch: refs/heads/ignite-23
Commit: 9bbc1fe921482654700137ea6153f2b4206ef9de
Parents: 5c8591c
Author: sevdokimov <se...@gridgain.com>
Authored: Mon May 18 14:17:13 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Mon May 18 14:17:13 2015 +0300
----------------------------------------------------------------------
.../IgniteClientDataStructuresAbstractTest.java | 19 ++----------
...ientModesTcpClientDiscoveryAbstractTest.java | 21 ++-----------
...pClientDiscoveryMarshallerCheckSelfTest.java | 18 +-----------
.../tcp/TcpDiscoveryConcurrentStartTest.java | 20 ++-----------
.../junits/common/GridCommonAbstractTest.java | 31 ++++++++++++++++++++
5 files changed, 38 insertions(+), 71 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9bbc1fe9/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteClientDataStructuresAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteClientDataStructuresAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteClientDataStructuresAbstractTest.java
index 8aef0a6..36f1910 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteClientDataStructuresAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteClientDataStructuresAbstractTest.java
@@ -20,7 +20,6 @@ package org.apache.ignite.internal.processors.cache.datastructures;
import org.apache.ignite.*;
import org.apache.ignite.configuration.*;
import org.apache.ignite.internal.*;
-import org.apache.ignite.internal.util.typedef.*;
import org.apache.ignite.internal.util.typedef.internal.*;
import org.apache.ignite.spi.discovery.tcp.*;
import org.apache.ignite.spi.discovery.tcp.ipfinder.*;
@@ -28,7 +27,6 @@ import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
import org.apache.ignite.testframework.*;
import org.apache.ignite.testframework.junits.common.*;
-import java.util.*;
import java.util.concurrent.*;
/**
@@ -50,21 +48,8 @@ public abstract class IgniteClientDataStructuresAbstractTest extends GridCommonA
if (gridName.equals(getTestGridName(NODE_CNT - 1))) {
cfg.setClientMode(true);
- if (clientDiscovery()) {
- TcpDiscoveryVmIpFinder clientFinder = new TcpDiscoveryVmIpFinder();
-
- String firstSrvAddr = F.first(ipFinder.getRegisteredAddresses()).toString();
-
- if (firstSrvAddr.startsWith("/"))
- firstSrvAddr = firstSrvAddr.substring(1);
-
- clientFinder.setAddresses(Collections.singletonList(firstSrvAddr));
-
- TcpClientDiscoverySpi discoverySpi = new TcpClientDiscoverySpi();
- discoverySpi.setIpFinder(clientFinder);
-
- cfg.setDiscoverySpi(discoverySpi);
- }
+ if (clientDiscovery())
+ cfg.setDiscoverySpi(createClientDiscovery(ipFinder));
}
cfg.setLocalHost("127.0.0.1");
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9bbc1fe9/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheClientModesTcpClientDiscoveryAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheClientModesTcpClientDiscoveryAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheClientModesTcpClientDiscoveryAbstractTest.java
index d24afed..127c150 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheClientModesTcpClientDiscoveryAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheClientModesTcpClientDiscoveryAbstractTest.java
@@ -19,11 +19,7 @@ package org.apache.ignite.internal.processors.cache.distributed;
import org.apache.ignite.cache.*;
import org.apache.ignite.configuration.*;
-import org.apache.ignite.internal.util.typedef.*;
import org.apache.ignite.spi.discovery.tcp.*;
-import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
-
-import java.util.*;
import static org.apache.ignite.cache.CacheMode.*;
@@ -41,21 +37,8 @@ public abstract class GridCacheClientModesTcpClientDiscoveryAbstractTest extends
@Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
IgniteConfiguration cfg = super.getConfiguration(gridName);
- if (cfg.isClientMode() != null && cfg.isClientMode()) {
- TcpDiscoveryVmIpFinder clientFinder = new TcpDiscoveryVmIpFinder();
-
- String firstSrvAddr = F.first(ipFinder.getRegisteredAddresses()).toString();
-
- if (firstSrvAddr.startsWith("/"))
- firstSrvAddr = firstSrvAddr.substring(1);
-
- clientFinder.setAddresses(Collections.singletonList(firstSrvAddr));
-
- TcpClientDiscoverySpi discoverySpi = new TcpClientDiscoverySpi();
- discoverySpi.setIpFinder(clientFinder);
-
- cfg.setDiscoverySpi(discoverySpi);
- }
+ if (cfg.isClientMode() != null && cfg.isClientMode())
+ cfg.setDiscoverySpi(createClientDiscovery(ipFinder));
cfg.setLocalHost("127.0.0.1");
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9bbc1fe9/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoveryMarshallerCheckSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoveryMarshallerCheckSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoveryMarshallerCheckSelfTest.java
index fa63e3c..78435fd 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoveryMarshallerCheckSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoveryMarshallerCheckSelfTest.java
@@ -19,7 +19,6 @@ package org.apache.ignite.spi.discovery.tcp;
import org.apache.ignite.*;
import org.apache.ignite.configuration.*;
-import org.apache.ignite.internal.util.typedef.*;
import org.apache.ignite.marshaller.jdk.*;
import org.apache.ignite.marshaller.optimized.*;
import org.apache.ignite.spi.*;
@@ -27,8 +26,6 @@ import org.apache.ignite.spi.discovery.tcp.ipfinder.*;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
import org.apache.ignite.testframework.junits.common.*;
-import java.util.*;
-
/**
* Test for {@link org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi}.
*/
@@ -52,20 +49,7 @@ public class TcpClientDiscoveryMarshallerCheckSelfTest extends GridCommonAbstrac
cfg.setMarshaller(new JdkMarshaller());
}
else {
- TcpClientDiscoverySpi disco = new TcpClientDiscoverySpi();
-
- TcpDiscoveryVmIpFinder clientIpFinder = new TcpDiscoveryVmIpFinder();
-
- String addr = F.first(ipFinder.getRegisteredAddresses()).toString();
-
- if (addr.startsWith("/"))
- addr = addr.substring(1);
-
- clientIpFinder.setAddresses(Collections.singleton(addr));
-
- disco.setIpFinder(clientIpFinder);
-
- cfg.setDiscoverySpi(disco);
+ cfg.setDiscoverySpi(createClientDiscovery(ipFinder));
cfg.setMarshaller(new OptimizedMarshaller());
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9bbc1fe9/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryConcurrentStartTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryConcurrentStartTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryConcurrentStartTest.java
index b5d02f0..f79c24b 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryConcurrentStartTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryConcurrentStartTest.java
@@ -22,8 +22,6 @@ import org.apache.ignite.spi.discovery.tcp.ipfinder.*;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
import org.apache.ignite.testframework.junits.common.*;
-import java.util.*;
-
/**
* Test for {@link TcpDiscoverySpi}.
*/
@@ -41,22 +39,8 @@ public class TcpDiscoveryConcurrentStartTest extends GridCommonAbstractTest {
@Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
IgniteConfiguration cfg = super.getConfiguration(gridName);
- if (client) {
- TcpDiscoveryVmIpFinder clientIpFinder = new TcpDiscoveryVmIpFinder();
-
- String addr = new ArrayList<>(ipFinder.getRegisteredAddresses()).iterator().next().toString();
-
- if (addr.startsWith("/"))
- addr = addr.substring(1);
-
- clientIpFinder.setAddresses(Arrays.asList(addr));
-
- TcpClientDiscoverySpi discoSpi = new TcpClientDiscoverySpi();
-
- discoSpi.setIpFinder(clientIpFinder);
-
- cfg.setDiscoverySpi(discoSpi);
- }
+ if (client)
+ cfg.setDiscoverySpi(createClientDiscovery(ipFinder));
else {
TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9bbc1fe9/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java
index 3c54efe..c8a256f 100644
--- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java
@@ -34,12 +34,16 @@ import org.apache.ignite.internal.processors.cache.local.*;
import org.apache.ignite.internal.util.typedef.*;
import org.apache.ignite.internal.util.typedef.internal.*;
import org.apache.ignite.lang.*;
+import org.apache.ignite.spi.discovery.tcp.*;
+import org.apache.ignite.spi.discovery.tcp.ipfinder.*;
+import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
import org.apache.ignite.testframework.junits.*;
import org.jetbrains.annotations.*;
import javax.cache.*;
import javax.cache.integration.*;
import javax.net.ssl.*;
+import java.net.*;
import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.atomic.*;
@@ -849,6 +853,33 @@ public abstract class GridCommonAbstractTest extends GridAbstractTest {
}
/**
+ * Create TcpClientDiscoverySpi configured to connect to last started server.
+ *
+ * @param srvIpFinder IpFinder that was provided to servers. Used to obtain addreses to connect.
+ */
+ protected static TcpClientDiscoverySpi createClientDiscovery(TcpDiscoveryIpFinder srvIpFinder) {
+ TcpDiscoveryVmIpFinder clientFinder = new TcpDiscoveryVmIpFinder();
+
+ Collection<InetSocketAddress> srvAddrs = srvIpFinder.getRegisteredAddresses();
+
+ if (srvAddrs.isEmpty())
+ throw new IgniteException("Failed to create client IpFinder, no server addresses registered.");
+
+ String firstSrvAddr = F.first(srvAddrs).toString();
+
+ if (firstSrvAddr.startsWith("/"))
+ firstSrvAddr = firstSrvAddr.substring(1);
+
+ clientFinder.setAddresses(Collections.singletonList(firstSrvAddr));
+
+ TcpClientDiscoverySpi res = new TcpClientDiscoverySpi();
+
+ res.setIpFinder(clientFinder);
+
+ return res;
+ }
+
+ /**
* In ATOMIC cache with CLOCK mode if key is updated from different nodes at same time
* only one update wins others are ignored (can happen in test event when updates are executed from
* different nodes sequentially), this delay is used to avoid lost updates.
[09/11] incubator-ignite git commit: # IGNITE-709 Bug fix: client
with wrong Ignite version got "Join timeout" instead of correct exception
Posted by sb...@apache.org.
# IGNITE-709 Bug fix: client with wrong Ignite version got "Join timeout" instead of correct exception
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/ecf34cae
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/ecf34cae
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/ecf34cae
Branch: refs/heads/ignite-23
Commit: ecf34cae4157c28a5979120072cd3c1f6a213be7
Parents: a48dd26
Author: sevdokimov <se...@gridgain.com>
Authored: Tue May 19 20:07:32 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Tue May 19 20:07:32 2015 +0300
----------------------------------------------------------------------
.../discovery/tcp/TcpClientDiscoverySpi.java | 6 +-
.../spi/discovery/tcp/TcpDiscoverySpi.java | 23 +++--
.../internal/GridReleaseTypeSelfTest.java | 92 ++++++++++++++------
3 files changed, 78 insertions(+), 43 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ecf34cae/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
index 9a0a460..7097e1b 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
@@ -1499,7 +1499,11 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp
* Router want to ping this client.
*/
private void processPingRequest() {
- sockWriter.sendMessage(new TcpDiscoveryPingResponse(getLocalNodeId()));
+ TcpDiscoveryPingResponse res = new TcpDiscoveryPingResponse(getLocalNodeId());
+
+ res.client(true);
+
+ sockWriter.sendMessage(res);
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ecf34cae/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
index 1a8e626..f80f00f 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
@@ -2654,9 +2654,6 @@ public class TcpDiscoverySpi extends TcpDiscoverySpiAdapter implements TcpDiscov
else if (msg instanceof TcpDiscoveryClientPingRequest)
processClientPingRequest((TcpDiscoveryClientPingRequest)msg);
- else if (msg instanceof TcpDiscoveryPingResponse)
- processPingResponse((TcpDiscoveryPingResponse)msg);
-
else
assert false : "Unknown message type: " + msg.getClass().getSimpleName();
@@ -4516,16 +4513,6 @@ public class TcpDiscoverySpi extends TcpDiscoverySpiAdapter implements TcpDiscov
/**
* @param msg Message.
*/
- private void processPingResponse(final TcpDiscoveryPingResponse msg) {
- ClientMessageWorker clientWorker = clientMsgWorkers.get(msg.creatorNodeId());
-
- if (clientWorker != null)
- clientWorker.pingResult(true);
- }
-
- /**
- * @param msg Message.
- */
private void processCustomMessage(TcpDiscoveryCustomEventMessage msg) {
if (isLocalNodeCoordinator()) {
boolean sndNext;
@@ -5065,6 +5052,16 @@ public class TcpDiscoverySpi extends TcpDiscoverySpiAdapter implements TcpDiscov
continue;
}
+ if (msg instanceof TcpDiscoveryPingResponse) {
+ assert msg.client() : msg;
+
+ ClientMessageWorker clientWorker = clientMsgWorkers.get(msg.creatorNodeId());
+
+ if (clientWorker != null)
+ clientWorker.pingResult(true);
+
+ continue;
+ }
msgWorker.addMessage(msg);
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ecf34cae/modules/core/src/test/java/org/apache/ignite/internal/GridReleaseTypeSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridReleaseTypeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridReleaseTypeSelfTest.java
index 284aa0c..4733ae5 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridReleaseTypeSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridReleaseTypeSelfTest.java
@@ -27,7 +27,6 @@ import org.apache.ignite.testframework.junits.common.*;
import java.io.*;
import java.util.*;
-import java.util.concurrent.atomic.*;
/**
* Test grids starting with non compatible release types.
@@ -36,32 +35,36 @@ public class GridReleaseTypeSelfTest extends GridCommonAbstractTest {
/** IP finder. */
private static final TcpDiscoveryIpFinder IP_FINDER = new TcpDiscoveryVmIpFinder(true);
- /** Counter. */
- private static final AtomicInteger cnt = new AtomicInteger();
-
/** */
- private String firstNodeVer;
+ private String nodeVer;
/** */
- private String secondNodeVer;
+ private boolean clientMode;
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
IgniteConfiguration cfg = super.getConfiguration(gridName);
- final int idx = cnt.getAndIncrement();
+ TcpDiscoverySpiAdapter discoSpi;
- // Override node attributes in discovery spi.
- TcpDiscoverySpi discoSpi = new TcpDiscoverySpi() {
- @Override public void setNodeAttributes(Map<String, Object> attrs, IgniteProductVersion ver) {
- super.setNodeAttributes(attrs, ver);
+ if (clientMode) {
+ discoSpi = new TcpClientDiscoverySpi() {
+ @Override public void setNodeAttributes(Map<String, Object> attrs, IgniteProductVersion ver) {
+ super.setNodeAttributes(attrs, ver);
- if (idx % 2 == 0)
- attrs.put(IgniteNodeAttributes.ATTR_BUILD_VER, firstNodeVer);
- else
- attrs.put(IgniteNodeAttributes.ATTR_BUILD_VER, secondNodeVer);
- }
- };
+ attrs.put(IgniteNodeAttributes.ATTR_BUILD_VER, nodeVer);
+ }
+ };
+ }
+ else {
+ discoSpi = new TcpDiscoverySpi() {
+ @Override public void setNodeAttributes(Map<String, Object> attrs, IgniteProductVersion ver) {
+ super.setNodeAttributes(attrs, ver);
+
+ attrs.put(IgniteNodeAttributes.ATTR_BUILD_VER, nodeVer);
+ }
+ };
+ }
discoSpi.setIpFinder(IP_FINDER);
@@ -70,15 +73,27 @@ public class GridReleaseTypeSelfTest extends GridCommonAbstractTest {
return cfg;
}
+ /** {@inheritDoc} */
+ @Override protected void afterTest() throws Exception {
+ clientMode = false;
+
+ stopAllGrids();
+ }
+
/**
* @throws Exception If failed.
*/
public void testOsEditionDoesNotSupportRollingUpdates() throws Exception {
- firstNodeVer = "1.0.0";
- secondNodeVer = "1.0.1";
+ nodeVer = "1.0.0";
+
+ startGrid(0);
try {
- startGrids(2);
+ nodeVer = "1.0.1";
+
+ startGrid(1);
+
+ fail("Exception has not been thrown.");
}
catch (IgniteCheckedException e) {
StringWriter errors = new StringWriter();
@@ -87,17 +102,36 @@ public class GridReleaseTypeSelfTest extends GridCommonAbstractTest {
String stackTrace = errors.toString();
- assertTrue(
- "Caught exception does not contain specified string.",
- stackTrace.contains("Local node and remote node have different version numbers")
- );
-
- return;
+ if (!stackTrace.contains("Local node and remote node have different version numbers"))
+ throw e;
}
- finally {
- stopAllGrids();
+ }
+
+ /**
+ * @throws Exception If failed.
+ */
+ public void testOsEditionDoesNotSupportRollingUpdatesClientMode() throws Exception {
+ nodeVer = "1.0.0";
+
+ startGrid(0);
+
+ try {
+ nodeVer = "1.0.1";
+ clientMode = true;
+
+ startGrid(1);
+
+ fail("Exception has not been thrown.");
}
+ catch (IgniteCheckedException e) {
+ StringWriter errors = new StringWriter();
+
+ e.printStackTrace(new PrintWriter(errors));
- fail("Exception has not been thrown.");
+ String stackTrace = errors.toString();
+
+ if (!stackTrace.contains("Local node and remote node have different version numbers"))
+ throw e;
+ }
}
}
[04/11] incubator-ignite git commit: # IGNITE-709 Add additional
tests.
Posted by sb...@apache.org.
# IGNITE-709 Add additional tests.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/feee7d42
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/feee7d42
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/feee7d42
Branch: refs/heads/ignite-23
Commit: feee7d4219963560ae9d839df3ac29812b025cab
Parents: 0d8f73e
Author: sevdokimov <se...@gridgain.com>
Authored: Mon May 18 18:38:06 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Mon May 18 18:38:06 2015 +0300
----------------------------------------------------------------------
.../discovery/tcp/TcpDiscoverySpiAdapter.java | 2 +-
.../GridDiscoveryManagerAliveCacheSelfTest.java | 12 +-
.../GridDiscoveryManagerAttributesSelfTest.java | 120 +++++++++++--------
.../discovery/GridDiscoveryManagerSelfTest.java | 44 +++++--
.../tcp/TcpClientDiscoverySpiSelfTest.java | 2 -
.../testframework/junits/GridAbstractTest.java | 3 +-
.../testsuites/IgniteKernalSelfTestSuite.java | 6 +-
7 files changed, 124 insertions(+), 65 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/feee7d42/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
index a89dbcc..e80272e 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
@@ -45,7 +45,7 @@ import java.util.concurrent.atomic.*;
/**
* Base class for TCP discovery SPIs.
*/
-abstract class TcpDiscoverySpiAdapter extends IgniteSpiAdapter implements DiscoverySpi {
+public abstract class TcpDiscoverySpiAdapter extends IgniteSpiAdapter implements DiscoverySpi {
/** Default port to listen (value is <tt>47500</tt>). */
public static final int DFLT_PORT = 47500;
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/feee7d42/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAliveCacheSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAliveCacheSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAliveCacheSelfTest.java
index b36c6f1..da1e1d7 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAliveCacheSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAliveCacheSelfTest.java
@@ -86,7 +86,12 @@ public class GridDiscoveryManagerAliveCacheSelfTest extends GridCommonAbstractTe
cCfg.setRebalanceMode(SYNC);
cCfg.setWriteSynchronizationMode(FULL_SYNC);
- TcpDiscoverySpi disc = new TcpDiscoverySpi();
+ TcpDiscoverySpiAdapter disc;
+
+ if (((gridName.charAt(gridName.length() - 1) - '0') & 1) == 0)
+ disc = new TcpDiscoverySpi();
+ else
+ disc = new TcpClientDiscoverySpi();
disc.setIpFinder(IP_FINDER);
@@ -148,7 +153,12 @@ public class GridDiscoveryManagerAliveCacheSelfTest extends GridCommonAbstractTe
*/
@SuppressWarnings("BusyWait")
private void awaitDiscovery(long nodesCnt) throws InterruptedException {
+ Thread.sleep(50);
+
for (Ignite g : alive) {
+ if (g.configuration().getDiscoverySpi() instanceof TcpClientDiscoverySpi)
+ ((TcpClientDiscoverySpi)g.configuration().getDiscoverySpi()).waitForMessagePrecessed();
+
while (g.cluster().nodes().size() != nodesCnt)
Thread.sleep(10);
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/feee7d42/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java
index 538ea39..77e6d52 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java
@@ -19,6 +19,7 @@ package org.apache.ignite.internal.managers.discovery;
import org.apache.ignite.*;
import org.apache.ignite.configuration.*;
+import org.apache.ignite.spi.discovery.*;
import org.apache.ignite.spi.discovery.tcp.*;
import org.apache.ignite.spi.discovery.tcp.ipfinder.*;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
@@ -29,7 +30,7 @@ import static org.apache.ignite.configuration.DeploymentMode.*;
/**
* Tests for node attributes consistency checks.
*/
-public class GridDiscoveryManagerAttributesSelfTest extends GridCommonAbstractTest {
+public abstract class GridDiscoveryManagerAttributesSelfTest extends GridCommonAbstractTest {
/** */
private static final String PREFER_IPV4 = "java.net.preferIPv4Stack";
@@ -46,18 +47,34 @@ public class GridDiscoveryManagerAttributesSelfTest extends GridCommonAbstractTe
@Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
IgniteConfiguration cfg = super.getConfiguration(gridName);
- TcpDiscoverySpi disc = new TcpDiscoverySpi();
-
- disc.setIpFinder(IP_FINDER);
+ if (gridName.equals(getTestGridName(1)))
+ cfg.setClientMode(true);
cfg.setIncludeProperties(PREFER_IPV4);
cfg.setDeploymentMode(mode);
cfg.setPeerClassLoadingEnabled(p2pEnabled);
- cfg.setDiscoverySpi(disc);
+ cfg.setDiscoverySpi(createDiscovery(cfg));
return cfg;
}
+ /** {@inheritDoc} */
+ @Override protected void afterTest() throws Exception {
+ stopAllGrids();
+ }
+
+ /**
+ * @return Discovery SPI.
+ * @param cfg DiscoverySpi
+ */
+ protected DiscoverySpi createDiscovery(IgniteConfiguration cfg) {
+ TcpDiscoverySpi disc = new TcpDiscoverySpi();
+
+ disc.setIpFinder(IP_FINDER);
+
+ return disc;
+ }
+
/**
* @throws Exception If failed.
*/
@@ -83,44 +100,34 @@ public class GridDiscoveryManagerAttributesSelfTest extends GridCommonAbstractTe
* @throws Exception If failed.
*/
public void testPreferIpV4StackDifferentValues() throws Exception {
- try {
- System.setProperty(PREFER_IPV4, "true");
+ System.setProperty(PREFER_IPV4, "true");
- for (int i = 0; i < 2; i++) {
- Ignite g = startGrid(i);
+ for (int i = 0; i < 2; i++) {
+ Ignite g = startGrid(i);
- assert "true".equals(g.cluster().localNode().attribute(PREFER_IPV4));
- }
+ assert "true".equals(g.cluster().localNode().attribute(PREFER_IPV4));
+ }
- System.setProperty(PREFER_IPV4, "false");
+ System.setProperty(PREFER_IPV4, "false");
- startGrid(2);
- }
- finally {
- stopAllGrids();
- }
+ startGrid(2);
}
/**
* @throws Exception If failed.
*/
public void testDifferentDeploymentModes() throws Exception {
- try {
- startGrid(1);
+ startGrid(0);
- mode = CONTINUOUS;
+ mode = CONTINUOUS;
- try {
- startGrid(2);
+ try {
+ startGrid(1);
- fail();
- }
- catch (IgniteCheckedException e) {
- assertTrue(e.getCause().getMessage().startsWith("Remote node has deployment mode different from"));
- }
+ fail();
}
- finally {
- stopAllGrids();
+ catch (IgniteCheckedException e) {
+ assertTrue(e.getCause().getMessage().startsWith("Remote node has deployment mode different from"));
}
}
@@ -128,23 +135,18 @@ public class GridDiscoveryManagerAttributesSelfTest extends GridCommonAbstractTe
* @throws Exception If failed.
*/
public void testDifferentPeerClassLoadingEnabledFlag() throws Exception {
- try {
- startGrid(1);
+ startGrid(0);
- p2pEnabled = true;
+ p2pEnabled = true;
- try {
- startGrid(2);
+ try {
+ startGrid(1);
- fail();
- }
- catch (IgniteCheckedException e) {
- assertTrue(e.getCause().getMessage().startsWith("Remote node has peer class loading enabled flag " +
- "different from"));
- }
+ fail();
}
- finally {
- stopAllGrids();
+ catch (IgniteCheckedException e) {
+ assertTrue(e.getCause().getMessage().startsWith("Remote node has peer class loading enabled flag " +
+ "different from"));
}
}
@@ -153,19 +155,35 @@ public class GridDiscoveryManagerAttributesSelfTest extends GridCommonAbstractTe
* @throws Exception If failed.
*/
private void testPreferIpV4Stack(boolean preferIpV4) throws Exception {
- try {
- String val = String.valueOf(preferIpV4);
+ String val = String.valueOf(preferIpV4);
- System.setProperty(PREFER_IPV4, val);
+ System.setProperty(PREFER_IPV4, val);
- for (int i = 0; i < 2; i++) {
- Ignite g = startGrid(i);
+ for (int i = 0; i < 2; i++) {
+ Ignite g = startGrid(i);
- assert val.equals(g.cluster().localNode().attribute(PREFER_IPV4));
- }
+ assert val.equals(g.cluster().localNode().attribute(PREFER_IPV4));
}
- finally {
- stopAllGrids();
+ }
+
+ /**
+ *
+ */
+ public static class RegularDiscovery extends GridDiscoveryManagerAttributesSelfTest {
+ // No-op.
+ }
+
+ /**
+ *
+ */
+ public static class ClientDiscovery extends GridDiscoveryManagerAttributesSelfTest {
+ /** {@inheritDoc}
+ * @param cfg*/
+ @Override protected DiscoverySpi createDiscovery(IgniteConfiguration cfg) {
+ if (Boolean.TRUE.equals(cfg.isClientMode()))
+ return createClientDiscovery(IP_FINDER);
+
+ return super.createDiscovery(cfg);
}
}
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/feee7d42/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerSelfTest.java
index be5b9c6..2fdc084 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerSelfTest.java
@@ -23,6 +23,7 @@ import org.apache.ignite.internal.*;
import org.apache.ignite.internal.processors.affinity.*;
import org.apache.ignite.internal.util.typedef.*;
import org.apache.ignite.lang.*;
+import org.apache.ignite.spi.discovery.*;
import org.apache.ignite.spi.discovery.tcp.*;
import org.apache.ignite.spi.discovery.tcp.ipfinder.*;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*;
@@ -33,7 +34,7 @@ import static org.apache.ignite.cache.CacheMode.*;
/**
*
*/
-public class GridDiscoveryManagerSelfTest extends GridCommonAbstractTest {
+public abstract class GridDiscoveryManagerSelfTest extends GridCommonAbstractTest {
/** */
private static final String CACHE_NAME = "cache";
@@ -50,12 +51,6 @@ public class GridDiscoveryManagerSelfTest extends GridCommonAbstractTest {
@Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
IgniteConfiguration cfg = super.getConfiguration(gridName);
- TcpDiscoverySpi disc = new TcpDiscoverySpi();
-
- disc.setIpFinder(IP_FINDER);
-
- cfg.setDiscoverySpi(disc);
-
CacheConfiguration ccfg1 = defaultCacheConfiguration();
ccfg1.setName(CACHE_NAME);
@@ -76,10 +71,24 @@ public class GridDiscoveryManagerSelfTest extends GridCommonAbstractTest {
cfg.setCacheConfiguration(ccfg1, ccfg2);
}
+ cfg.setDiscoverySpi(createDiscovery(cfg));
+
return cfg;
}
/**
+ * @return Discovery SPI.
+ * @param cfg DiscoverySpi
+ */
+ protected DiscoverySpi createDiscovery(IgniteConfiguration cfg) {
+ TcpDiscoverySpi disc = new TcpDiscoverySpi();
+
+ disc.setIpFinder(IP_FINDER);
+
+ return disc;
+ }
+
+ /**
* @throws Exception If failed.
*/
public void testHasNearCache() throws Exception {
@@ -187,4 +196,25 @@ public class GridDiscoveryManagerSelfTest extends GridCommonAbstractTest {
assertTrue(g0.context().discovery().hasNearCache(null, four));
assertFalse(g0.context().discovery().hasNearCache(null, five));
}
+
+ /**
+ *
+ */
+ public static class RegularDiscovery extends GridDiscoveryManagerSelfTest {
+ // No-op.
+ }
+
+ /**
+ *
+ */
+ public static class ClientDiscovery extends GridDiscoveryManagerSelfTest {
+ /** {@inheritDoc}
+ * @param cfg*/
+ @Override protected DiscoverySpi createDiscovery(IgniteConfiguration cfg) {
+ if (Boolean.TRUE.equals(cfg.isClientMode()))
+ return createClientDiscovery(IP_FINDER);
+
+ return super.createDiscovery(cfg);
+ }
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/feee7d42/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
index ba8200e..d534d6a 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
@@ -102,8 +102,6 @@ public class TcpClientDiscoverySpiSelfTest extends GridCommonAbstractTest {
@Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
IgniteConfiguration cfg = super.getConfiguration(gridName);
- cfg.setLocalHost("127.0.0.1");
-
if (gridName.startsWith("server")) {
TcpDiscoverySpi disco = new TcpDiscoverySpi();
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/feee7d42/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
index 37a5dc5..dd7073d 100644
--- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
@@ -676,7 +676,8 @@ public abstract class GridAbstractTest extends TestCase {
protected IgniteConfiguration optimize(IgniteConfiguration cfg) throws IgniteCheckedException {
// TODO: IGNITE-605: propose another way to avoid network overhead in tests.
if (cfg.getLocalHost() == null) {
- if (cfg.getDiscoverySpi() instanceof TcpDiscoverySpi)
+ if (cfg.getDiscoverySpi() instanceof TcpDiscoverySpi
+ || cfg.getDiscoverySpi() instanceof TcpClientDiscoverySpi)
cfg.setLocalHost("127.0.0.1");
else
cfg.setLocalHost(getTestResources().getLocalHost());
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/feee7d42/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteKernalSelfTestSuite.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteKernalSelfTestSuite.java b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteKernalSelfTestSuite.java
index 20c32b2..f0080d5 100644
--- a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteKernalSelfTestSuite.java
+++ b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteKernalSelfTestSuite.java
@@ -55,9 +55,11 @@ public class IgniteKernalSelfTestSuite extends TestSuite {
suite.addTestSuite(GridCacheMessageSelfTest.class);
suite.addTestSuite(GridDeploymentManagerStopSelfTest.class);
suite.addTestSuite(GridManagerStopSelfTest.class);
- suite.addTestSuite(GridDiscoveryManagerAttributesSelfTest.class);
+ suite.addTestSuite(GridDiscoveryManagerAttributesSelfTest.RegularDiscovery.class);
+ suite.addTestSuite(GridDiscoveryManagerAttributesSelfTest.ClientDiscovery.class);
suite.addTestSuite(GridDiscoveryManagerAliveCacheSelfTest.class);
- suite.addTestSuite(GridDiscoveryManagerSelfTest.class);
+ suite.addTestSuite(GridDiscoveryManagerSelfTest.RegularDiscovery.class);
+ suite.addTestSuite(GridDiscoveryManagerSelfTest.ClientDiscovery.class);
suite.addTestSuite(GridDiscoveryEventSelfTest.class);
suite.addTestSuite(GridPortProcessorSelfTest.class);
suite.addTestSuite(GridHomePathSelfTest.class);
[06/11] incubator-ignite git commit: # IGNITE-709 Fix hang sests: set
joinTimeout for discovery SPI.
Posted by sb...@apache.org.
# IGNITE-709 Fix hang sests: set joinTimeout for discovery SPI.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/c3744ba8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/c3744ba8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/c3744ba8
Branch: refs/heads/ignite-23
Commit: c3744ba8fc571f0ec385b1e3cd1f972973250cb5
Parents: 7d64902
Author: sevdokimov <se...@gridgain.com>
Authored: Mon May 18 20:04:28 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Mon May 18 20:04:28 2015 +0300
----------------------------------------------------------------------
.../apache/ignite/testframework/junits/GridAbstractTest.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c3744ba8/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
index dd7073d..294595d 100644
--- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
@@ -676,9 +676,11 @@ public abstract class GridAbstractTest extends TestCase {
protected IgniteConfiguration optimize(IgniteConfiguration cfg) throws IgniteCheckedException {
// TODO: IGNITE-605: propose another way to avoid network overhead in tests.
if (cfg.getLocalHost() == null) {
- if (cfg.getDiscoverySpi() instanceof TcpDiscoverySpi
- || cfg.getDiscoverySpi() instanceof TcpClientDiscoverySpi)
+ if (cfg.getDiscoverySpi() instanceof TcpDiscoverySpiAdapter) {
cfg.setLocalHost("127.0.0.1");
+
+ ((TcpDiscoverySpiAdapter)cfg.getDiscoverySpi()).setJoinTimeout(5000);
+ }
else
cfg.setLocalHost(getTestResources().getLocalHost());
}
[08/11] incubator-ignite git commit: # IGNITE-709 Add temporary code
to understand fail of the test.
Posted by sb...@apache.org.
# IGNITE-709 Add temporary code to understand fail of the test.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/a48dd264
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/a48dd264
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/a48dd264
Branch: refs/heads/ignite-23
Commit: a48dd2648d1c83bd2cb63309718e0212fbc0994b
Parents: 8972acd
Author: sevdokimov <se...@gridgain.com>
Authored: Tue May 19 14:00:16 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Tue May 19 14:00:16 2015 +0300
----------------------------------------------------------------------
.../discovery/GridDiscoveryManagerAttributesSelfTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a48dd264/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java
index 77e6d52..2698eca 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManagerAttributesSelfTest.java
@@ -127,7 +127,8 @@ public abstract class GridDiscoveryManagerAttributesSelfTest extends GridCommonA
fail();
}
catch (IgniteCheckedException e) {
- assertTrue(e.getCause().getMessage().startsWith("Remote node has deployment mode different from"));
+ if (!e.getCause().getMessage().startsWith("Remote node has deployment mode different from"))
+ throw e;
}
}
@@ -145,8 +146,8 @@ public abstract class GridDiscoveryManagerAttributesSelfTest extends GridCommonA
fail();
}
catch (IgniteCheckedException e) {
- assertTrue(e.getCause().getMessage().startsWith("Remote node has peer class loading enabled flag " +
- "different from"));
+ if (!e.getCause().getMessage().startsWith("Remote node has peer class loading enabled flag different from"))
+ throw e;
}
}
[02/11] incubator-ignite git commit: # IGNITE-709 Bug fix: check
(joinTimeout > 0)
Posted by sb...@apache.org.
# IGNITE-709 Bug fix: check (joinTimeout > 0)
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/f265cb68
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/f265cb68
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/f265cb68
Branch: refs/heads/ignite-23
Commit: f265cb68d108d5b3617f5d6f893f477ca2308bff
Parents: 9bbc1fe
Author: sevdokimov <se...@gridgain.com>
Authored: Mon May 18 17:14:23 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Mon May 18 17:14:23 2015 +0300
----------------------------------------------------------------------
.../apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java | 4 ++--
.../apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java | 1 -
2 files changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f265cb68/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
index 6062ce5..5573f51 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
@@ -507,7 +507,7 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp
else {
U.warn(log, "No addresses registered in the IP finder (will retry in 2000ms): " + ipFinder);
- if ((U.currentTimeMillis() - startTime) > joinTimeout)
+ if (joinTimeout > 0 && (U.currentTimeMillis() - startTime) > joinTimeout)
return null;
Thread.sleep(2000);
@@ -581,7 +581,7 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp
U.warn(log, "Failed to connect to any address from IP finder (will retry to join topology " +
"in 2000ms): " + addrs0);
- if ((U.currentTimeMillis() - startTime) > joinTimeout)
+ if (joinTimeout > 0 && (U.currentTimeMillis() - startTime) > joinTimeout)
return null;
Thread.sleep(2000);
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f265cb68/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
index 3c3b984..a89dbcc 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
@@ -150,7 +150,6 @@ abstract class TcpDiscoverySpiAdapter extends IgniteSpiAdapter implements Discov
assertParameter(netTimeout > 0, "networkTimeout > 0");
assertParameter(sockTimeout > 0, "sockTimeout > 0");
assertParameter(ackTimeout > 0, "ackTimeout > 0");
- assertParameter(joinTimeout >= 0, "joinTimeout >= 0");
}
/**
[07/11] incubator-ignite git commit: # IGNITE-709 Bug fix: don't
override joinTimeout in GridAbstractTest.optimize()
Posted by sb...@apache.org.
# IGNITE-709 Bug fix: don't override joinTimeout in GridAbstractTest.optimize()
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/8972acdb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/8972acdb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/8972acdb
Branch: refs/heads/ignite-23
Commit: 8972acdbfa28e45bcb0dfaf6feb13d548445976b
Parents: c3744ba
Author: sevdokimov <se...@gridgain.com>
Authored: Tue May 19 12:06:11 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Tue May 19 12:06:11 2015 +0300
----------------------------------------------------------------------
.../org/apache/ignite/testframework/junits/GridAbstractTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8972acdb/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
index 294595d..be849f0 100644
--- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/GridAbstractTest.java
@@ -679,7 +679,8 @@ public abstract class GridAbstractTest extends TestCase {
if (cfg.getDiscoverySpi() instanceof TcpDiscoverySpiAdapter) {
cfg.setLocalHost("127.0.0.1");
- ((TcpDiscoverySpiAdapter)cfg.getDiscoverySpi()).setJoinTimeout(5000);
+ if (((TcpDiscoverySpiAdapter)cfg.getDiscoverySpi()).getJoinTimeout() == 0)
+ ((TcpDiscoverySpiAdapter)cfg.getDiscoverySpi()).setJoinTimeout(8000);
}
else
cfg.setLocalHost(getTestResources().getLocalHost());
[05/11] incubator-ignite git commit: IGNITE-709 Fix javadoc problems.
Posted by sb...@apache.org.
IGNITE-709 Fix javadoc problems.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7d649029
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7d649029
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7d649029
Branch: refs/heads/ignite-23
Commit: 7d64902957a7214474e8f54a3b1bbdcffe5e3357
Parents: feee7d4
Author: sevdokimov <se...@gridgain.com>
Authored: Mon May 18 19:48:30 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Mon May 18 19:48:30 2015 +0300
----------------------------------------------------------------------
.../ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7d649029/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
index e80272e..cb0085d 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiAdapter.java
@@ -219,7 +219,8 @@ public abstract class TcpDiscoverySpiAdapter extends IgniteSpiAdapter implements
* Note that when running Ignite on Amazon EC2, socket timeout must be set to a value
* significantly greater than the default (e.g. to {@code 30000}).
* <p>
- * If not specified, default is {@link #DFLT_SOCK_TIMEOUT}.
+ * If not specified, default is {@link TcpDiscoverySpi#DFLT_SOCK_TIMEOUT},
+ * {@link TcpClientDiscoverySpi#DFLT_SOCK_TIMEOUT}.
*
* @param sockTimeout Socket connection timeout.
*/
@@ -234,7 +235,8 @@ public abstract class TcpDiscoverySpiAdapter extends IgniteSpiAdapter implements
* If acknowledgement is not received within this timeout, sending is considered as failed
* and SPI tries to repeat message sending.
* <p>
- * If not specified, default is {@link #DFLT_ACK_TIMEOUT}.
+ * If not specified, default is {@link TcpDiscoverySpi#DFLT_ACK_TIMEOUT},
+ * {@link TcpClientDiscoverySpi#DFLT_ACK_TIMEOUT}.
*
* @param ackTimeout Acknowledgement timeout.
*/
@@ -1106,7 +1108,7 @@ public abstract class TcpDiscoverySpiAdapter extends IgniteSpiAdapter implements
}
/**
- *
+ * Allow to connect to addresses parallel.
*/
protected class SocketMultiConnector implements AutoCloseable {
/** */
[11/11] incubator-ignite git commit: Merge remote-tracking branch
'remotes/origin/ignite-709_2' into ignite-23
Posted by sb...@apache.org.
Merge remote-tracking branch 'remotes/origin/ignite-709_2' into ignite-23
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/fcf02fef
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/fcf02fef
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/fcf02fef
Branch: refs/heads/ignite-23
Commit: fcf02fef4daf124b1283f0d9c111d1c0bda6deec
Parents: 632a01a ecf34ca
Author: sboikov <se...@inria.fr>
Authored: Tue May 19 22:15:20 2015 +0300
Committer: sboikov <se...@inria.fr>
Committed: Tue May 19 22:15:20 2015 +0300
----------------------------------------------------------------------
.../discovery/tcp/TcpClientDiscoverySpi.java | 17 ++-
.../spi/discovery/tcp/TcpDiscoverySpi.java | 23 ++--
.../discovery/tcp/TcpDiscoverySpiAdapter.java | 11 +-
.../internal/GridReleaseTypeSelfTest.java | 92 +++++++++-----
.../GridDiscoveryManagerAliveCacheSelfTest.java | 12 +-
.../GridDiscoveryManagerAttributesSelfTest.java | 121 +++++++++++--------
.../discovery/GridDiscoveryManagerSelfTest.java | 44 +++++--
.../IgniteClientDataStructuresAbstractTest.java | 19 +--
...ientModesTcpClientDiscoveryAbstractTest.java | 21 +---
...pClientDiscoveryMarshallerCheckSelfTest.java | 18 +--
.../tcp/TcpClientDiscoverySpiSelfTest.java | 2 -
.../tcp/TcpDiscoveryConcurrentStartTest.java | 20 +--
.../testframework/junits/GridAbstractTest.java | 6 +-
.../junits/common/GridCommonAbstractTest.java | 31 +++++
.../testsuites/IgniteKernalSelfTestSuite.java | 6 +-
15 files changed, 251 insertions(+), 192 deletions(-)
----------------------------------------------------------------------
[10/11] incubator-ignite git commit: # ignite-23
Posted by sb...@apache.org.
# ignite-23
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/632a01ab
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/632a01ab
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/632a01ab
Branch: refs/heads/ignite-23
Commit: 632a01abe99ab9de6324e7c004c97476352a20af
Parents: 72d6ea5
Author: sboikov <se...@inria.fr>
Authored: Tue May 19 22:14:59 2015 +0300
Committer: sboikov <se...@inria.fr>
Committed: Tue May 19 22:14:59 2015 +0300
----------------------------------------------------------------------
.../dht/preloader/GridDhtPartitionsExchangeFuture.java | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/632a01ab/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
index 102176e..94ca540 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
@@ -1224,12 +1224,7 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT
boolean set = false;
- for (Iterator<ClusterNode> it = rmtNodes.iterator(); it.hasNext(); ) {
- if (it.next().id().equals(nodeId))
- it.remove();
- }
-
- ClusterNode newOldest = CU.oldest(rmtNodes);
+ ClusterNode newOldest = CU.oldestAliveCacheServerNode(cctx, exchId.topologyVersion());
if (newOldest != null) {
// If local node is now oldest.
[03/11] incubator-ignite git commit: # IGNITE-709 Remove duplicated
address resolving.
Posted by sb...@apache.org.
# IGNITE-709 Remove duplicated address resolving.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/0d8f73e5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/0d8f73e5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/0d8f73e5
Branch: refs/heads/ignite-23
Commit: 0d8f73e52c87adf8e696926ce9015ff7bec498c2
Parents: f265cb6
Author: sevdokimov <se...@gridgain.com>
Authored: Mon May 18 17:40:30 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Mon May 18 17:40:30 2015 +0300
----------------------------------------------------------------------
.../ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java | 7 -------
1 file changed, 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/0d8f73e5/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
index 5573f51..9a0a460 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
@@ -229,13 +229,6 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp
assertParameter(threadPri > 0, "threadPri > 0");
- try {
- locHost = U.resolveLocalHost(locAddr);
- }
- catch (IOException e) {
- throw new IgniteSpiException("Unknown local address: " + locAddr, e);
- }
-
if (log.isDebugEnabled()) {
log.debug(configInfo("localHost", locHost.getHostAddress()));
log.debug(configInfo("threadPri", threadPri));