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 2014/12/05 15:07:22 UTC
[21/52] [abbrv] incubator-ignite git commit: # Renaming
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/GridAbstractDiscoveryTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/GridAbstractDiscoveryTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/GridAbstractDiscoveryTest.java
deleted file mode 100644
index 62242d7..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/GridAbstractDiscoveryTest.java
+++ /dev/null
@@ -1,145 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery;
-
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.events.*;
-import org.gridgain.grid.kernal.managers.eventstorage.*;
-import org.gridgain.testframework.junits.spi.*;
-
-import javax.swing.*;
-import java.io.*;
-import java.util.*;
-
-/**
- * Base discovery test class.
- * @param <T> SPI implementation class.
- */
-@SuppressWarnings({"JUnitAbstractTestClassNamingConvention"})
-public abstract class GridAbstractDiscoveryTest<T extends DiscoverySpi> extends GridSpiAbstractTest<T> {
- /** */
- @SuppressWarnings({"ClassExplicitlyExtendsThread"})
- private class Pinger extends Thread {
- /** */
- private final Object mux = new Object();
-
- /** */
- @SuppressWarnings({"FieldAccessedSynchronizedAndUnsynchronized"})
- private boolean isCanceled;
-
- /** {@inheritDoc} */
- @SuppressWarnings({"UnusedCatchParameter"})
- @Override public void run() {
- Random rnd = new Random();
-
- while (isCanceled) {
- try {
- Collection<ClusterNode> nodes = getSpi().getRemoteNodes();
-
- pingNode(UUID.randomUUID(), false);
-
- for (ClusterNode item : nodes) {
- pingNode(item.id(), true);
- }
-
- pingNode(UUID.randomUUID(), false);
- }
- catch (Exception e) {
- error("Can't get SPI.", e);
- }
-
- synchronized (mux) {
- if (isCanceled) {
- try {
- mux.wait(getPingFrequency() * (1 + rnd.nextInt(10)));
- }
- catch (InterruptedException e) {
- //No-op.
- }
- }
- }
- }
- }
-
- /**
- * @param nodeId Node UUID.
- * @param exists Exists flag.
- * @throws Exception If failed.
- */
- private void pingNode(UUID nodeId, boolean exists) throws Exception {
- boolean flag = getSpi().pingNode(nodeId);
-
- info((flag != exists ? "***Error*** " : "") + "Ping " + (exists ? "exist" : "random") +
- " node [nodeId=" + nodeId + ", pingResult=" + flag + ']');
- }
-
- /** {@inheritDoc} */
- @Override public void interrupt() {
- synchronized (mux) {
- isCanceled = true;
-
- mux.notifyAll();
- }
-
- super.interrupt();
- }
- }
-
- /**
- * @return Ping frequency.
- */
- public abstract long getPingFrequency();
-
- /**
- * @return Pinger start flag.
- */
- public boolean isPingerStart() {
- return true;
- }
-
- /** */
- private class DiscoveryListener implements GridLocalEventListener {
- /** {@inheritDoc} */
- @Override public void onEvent(IgniteEvent evt) {
- info("Discovery event [event=" + evt + ']');
- }
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDiscovery() throws Exception {
- GridLocalEventListener discoLsnr = new DiscoveryListener();
-
- getSpiContext().addLocalEventListener(discoLsnr);
-
- Pinger pinger = null;
-
- if (isPingerStart()) {
- pinger = new Pinger();
-
- pinger.start();
- }
-
- JOptionPane.showMessageDialog(null, "Press OK to end test.");
-
- if (pinger != null)
- pinger.interrupt();
- }
-
- /** {@inheritDoc} */
- @Override protected Map<String, Serializable> getNodeAttributes() {
- Map<String, Serializable> attrs = new HashMap<>(1);
-
- attrs.put("testDiscoveryAttribute", new Date());
-
- return attrs;
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/GridDiscoveryMetricsHelperSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/GridDiscoveryMetricsHelperSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/GridDiscoveryMetricsHelperSelfTest.java
deleted file mode 100644
index 2829011..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/GridDiscoveryMetricsHelperSelfTest.java
+++ /dev/null
@@ -1,141 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery;
-
-import org.apache.ignite.cluster.*;
-import org.gridgain.testframework.junits.common.*;
-
-import java.io.*;
-import java.util.*;
-
-/**
- * Grid discovery metrics test.
- */
-@GridCommonTest(group = "Utils")
-public class GridDiscoveryMetricsHelperSelfTest extends GridCommonAbstractTest {
- /** */
- private static final int METRICS_COUNT = 500;
-
- /** */
- public GridDiscoveryMetricsHelperSelfTest() {
- super(false /*don't start grid*/);
- }
-
- /** */
- public void testMetricsSize() {
- byte[] data = new byte[DiscoveryMetricsHelper.METRICS_SIZE];
-
- // Test serialization.
- int off = DiscoveryMetricsHelper.serialize(data, 0, createMetrics());
-
- assert off == DiscoveryMetricsHelper.METRICS_SIZE;
-
- // Test deserialization.
- ClusterNodeMetrics res = DiscoveryMetricsHelper.deserialize(data, 0);
-
- assert res != null;
- }
-
- /** */
- public void testSerialization() {
- byte[] data = new byte[DiscoveryMetricsHelper.METRICS_SIZE];
-
- ClusterNodeMetrics metrics1 = createMetrics();
-
- // Test serialization.
- int off = DiscoveryMetricsHelper.serialize(data, 0, metrics1);
-
- assert off == DiscoveryMetricsHelper.METRICS_SIZE;
-
- // Test deserialization.
- ClusterNodeMetrics metrics2 = DiscoveryMetricsHelper.deserialize(data, 0);
-
- assert metrics2 != null;
-
- assert metrics1.equals(metrics2);
- }
-
- /**
- * @throws IOException If I/O error occurs.
- */
- public void testMultipleMetricsSerialization() throws IOException {
- Map<UUID, ClusterNodeMetrics> metrics = new HashMap<>(METRICS_COUNT);
-
- for (int i = 0; i < METRICS_COUNT; i++)
- metrics.put(UUID.randomUUID(), createMetrics());
-
- ByteArrayOutputStream bos = new ByteArrayOutputStream(1024 * 1024);
-
- ObjectOutputStream oos = new ObjectOutputStream(bos);
-
- oos.writeObject(metrics);
-
- oos.close();
-
- info(">>> Size of metrics map <UUID, GridNodeMetrics> in KB [metricsCount=" + METRICS_COUNT +
- ", size=" + bos.size() / 1024.0 + ']');
- }
-
- /**
- * @return Test metrics.
- */
- private ClusterNodeMetrics createMetrics() {
- DiscoveryNodeMetricsAdapter metrics = new DiscoveryNodeMetricsAdapter();
-
- metrics.setAvailableProcessors(1);
- metrics.setAverageActiveJobs(2);
- metrics.setAverageCancelledJobs(3);
- metrics.setAverageJobExecuteTime(4);
- metrics.setAverageJobWaitTime(5);
- metrics.setAverageRejectedJobs(6);
- metrics.setAverageWaitingJobs(7);
- metrics.setCurrentActiveJobs(8);
- metrics.setCurrentCancelledJobs(9);
- metrics.setCurrentIdleTime(10);
- metrics.setCurrentIdleTime(11);
- metrics.setCurrentJobExecuteTime(12);
- metrics.setCurrentJobWaitTime(13);
- metrics.setCurrentRejectedJobs(14);
- metrics.setCurrentWaitingJobs(15);
- metrics.setCurrentDaemonThreadCount(16);
- metrics.setHeapMemoryCommitted(17);
- metrics.setHeapMemoryInitialized(18);
- metrics.setHeapMemoryMaximum(19);
- metrics.setHeapMemoryUsed(20);
- metrics.setLastUpdateTime(21);
- metrics.setMaximumActiveJobs(22);
- metrics.setMaximumCancelledJobs(23);
- metrics.setMaximumJobExecuteTime(24);
- metrics.setMaximumJobWaitTime(25);
- metrics.setMaximumRejectedJobs(26);
- metrics.setMaximumWaitingJobs(27);
- metrics.setNonHeapMemoryCommitted(28);
- metrics.setNonHeapMemoryInitialized(29);
- metrics.setNonHeapMemoryMaximum(30);
- metrics.setNonHeapMemoryUsed(31);
- metrics.setMaximumThreadCount(32);
- metrics.setStartTime(33);
- metrics.setCurrentCpuLoad(34);
- metrics.setCurrentThreadCount(35);
- metrics.setTotalCancelledJobs(36);
- metrics.setTotalExecutedJobs(37);
- metrics.setTotalIdleTime(38);
- metrics.setTotalRejectedJobs(39);
- metrics.setTotalStartedThreadCount(40);
- metrics.setUpTime(41);
- metrics.setSentMessagesCount(42);
- metrics.setSentBytesCount(43);
- metrics.setReceivedMessagesCount(44);
- metrics.setReceivedBytesCount(45);
- metrics.setOutboundMessagesQueueSize(46);
-
- return metrics;
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/package.html
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/package.html b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/package.html
deleted file mode 100644
index 5cad80a..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/package.html
+++ /dev/null
@@ -1,15 +0,0 @@
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!--
- @html.file.header
- _________ _____ __________________ _____
- __ ____/___________(_)______ /__ ____/______ ____(_)_______
- _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
--->
-<html>
-<body>
- <!-- Package description. -->
- Contains internal tests or test related classes and interfaces.
-</body>
-</html>
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpClientDiscoverySelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpClientDiscoverySelfTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpClientDiscoverySelfTest.java
deleted file mode 100644
index 6d696e2..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpClientDiscoverySelfTest.java
+++ /dev/null
@@ -1,683 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.events.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.resources.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.vm.*;
-import org.gridgain.grid.util.*;
-import org.gridgain.grid.util.typedef.*;
-import org.gridgain.grid.util.typedef.internal.*;
-import org.gridgain.testframework.*;
-import org.gridgain.testframework.junits.common.*;
-
-import java.net.*;
-import java.util.*;
-import java.util.concurrent.*;
-import java.util.concurrent.atomic.*;
-
-import static java.util.concurrent.TimeUnit.*;
-import static org.apache.ignite.events.IgniteEventType.*;
-
-/**
- * Client-based discovery tests.
- */
-public class GridTcpClientDiscoverySelfTest extends GridCommonAbstractTest {
- /** */
- private static final TcpDiscoveryIpFinder IP_FINDER = new TcpDiscoveryVmIpFinder(true);
-
- /** */
- private static final AtomicInteger srvIdx = new AtomicInteger();
-
- /** */
- private static final AtomicInteger clientIdx = new AtomicInteger();
-
- /** */
- private static Collection<UUID> srvNodeIds;
-
- /** */
- private static Collection<UUID> clientNodeIds;
-
- /** */
- private static int clientsPerSrv;
-
- /** */
- private static CountDownLatch srvJoinedLatch;
-
- /** */
- private static CountDownLatch srvLeftLatch;
-
- /** */
- private static CountDownLatch srvFailedLatch;
-
- /** */
- private static CountDownLatch clientJoinedLatch;
-
- /** */
- private static CountDownLatch clientLeftLatch;
-
- /** */
- private static CountDownLatch clientFailedLatch;
-
- /** */
- private static CountDownLatch msgLatch;
-
- /** {@inheritDoc} */
- @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();
-
- disco.setIpFinder(IP_FINDER);
-
- cfg.setDiscoverySpi(disco);
- }
- else if (gridName.startsWith("client")) {
- TcpClientDiscoverySpi disco = new TcpClientDiscoverySpi();
-
- TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
-
- String addr = new ArrayList<>(IP_FINDER.getRegisteredAddresses()).
- get((clientIdx.get() - 1) / clientsPerSrv).toString();
-
- if (addr.startsWith("/"))
- addr = addr.substring(1);
-
- ipFinder.setAddresses(Arrays.asList(addr));
-
- disco.setIpFinder(ipFinder);
-
- cfg.setDiscoverySpi(disco);
- }
-
- return cfg;
- }
-
- /** {@inheritDoc} */
- @Override protected void beforeTest() throws Exception {
- Collection<InetSocketAddress> addrs = IP_FINDER.getRegisteredAddresses();
-
- if (!F.isEmpty(addrs))
- IP_FINDER.unregisterAddresses(addrs);
-
- srvIdx.set(0);
- clientIdx.set(0);
-
- srvNodeIds = new GridConcurrentHashSet<>();
- clientNodeIds = new GridConcurrentHashSet<>();
-
- clientsPerSrv = 2;
- }
-
- /** {@inheritDoc} */
- @Override protected void afterTest() throws Exception {
- stopAllClients(true);
- stopAllServers(true);
-
- assert G.allGrids().isEmpty();
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testClientNodeJoin() throws Exception {
- startServerNodes(3);
- startClientNodes(3);
-
- checkNodes(3, 3);
-
- srvJoinedLatch = new CountDownLatch(3);
- clientJoinedLatch = new CountDownLatch(3);
-
- attachListeners(3, 3);
-
- startClientNodes(1);
-
- await(srvJoinedLatch);
- await(clientJoinedLatch);
-
- checkNodes(3, 4);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testClientNodeLeave() throws Exception {
- startServerNodes(3);
- startClientNodes(3);
-
- checkNodes(3, 3);
-
- srvLeftLatch = new CountDownLatch(3);
- clientLeftLatch = new CountDownLatch(2);
-
- attachListeners(3, 3);
-
- stopGrid("client-2");
-
- await(srvLeftLatch);
- await(clientLeftLatch);
-
- checkNodes(3, 2);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testClientNodeFail() throws Exception {
- startServerNodes(3);
- startClientNodes(3);
-
- checkNodes(3, 3);
-
- srvFailedLatch = new CountDownLatch(3);
- clientFailedLatch = new CountDownLatch(2);
-
- attachListeners(3, 3);
-
- failClient(2);
-
- await(srvFailedLatch);
- await(clientFailedLatch);
-
- checkNodes(3, 2);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testServerNodeJoin() throws Exception {
- startServerNodes(3);
- startClientNodes(3);
-
- checkNodes(3, 3);
-
- srvJoinedLatch = new CountDownLatch(3);
- clientJoinedLatch = new CountDownLatch(3);
-
- attachListeners(3, 3);
-
- startServerNodes(1);
-
- await(srvJoinedLatch);
- await(clientJoinedLatch);
-
- checkNodes(4, 3);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testServerNodeLeave() throws Exception {
- startServerNodes(3);
- startClientNodes(3);
-
- checkNodes(3, 3);
-
- srvLeftLatch = new CountDownLatch(2);
- clientLeftLatch = new CountDownLatch(3);
-
- attachListeners(3, 3);
-
- stopGrid("server-2");
-
- await(srvLeftLatch);
- await(clientLeftLatch);
-
- checkNodes(2, 3);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testServerNodeFail() throws Exception {
- startServerNodes(3);
- startClientNodes(3);
-
- checkNodes(3, 3);
-
- srvFailedLatch = new CountDownLatch(2);
- clientFailedLatch = new CountDownLatch(3);
-
- attachListeners(3, 3);
-
- assert U.<Map>field(G.grid("server-2").configuration().getDiscoverySpi(), "clientMsgWorkers").isEmpty();
-
- failServer(2);
-
- await(srvFailedLatch);
- await(clientFailedLatch);
-
- checkNodes(2, 3);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testClientReconnect() throws Exception {
- clientsPerSrv = 1;
-
- startServerNodes(3);
- startClientNodes(3);
-
- checkNodes(3, 3);
-
- resetClientIpFinder(2);
-
- srvFailedLatch = new CountDownLatch(2);
- clientFailedLatch = new CountDownLatch(3);
-
- attachListeners(2, 3);
-
- failServer(2);
-
- await(srvFailedLatch);
- await(clientFailedLatch);
-
- checkNodes(2, 3);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testClientNodeJoinOneServer() throws Exception {
- startServerNodes(1);
-
- srvJoinedLatch = new CountDownLatch(1);
-
- attachListeners(1, 0);
-
- startClientNodes(1);
-
- await(srvJoinedLatch);
-
- checkNodes(1, 1);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testClientNodeLeaveOneServer() throws Exception {
- startServerNodes(1);
- startClientNodes(1);
-
- checkNodes(1, 1);
-
- srvLeftLatch = new CountDownLatch(1);
-
- attachListeners(1, 0);
-
- stopGrid("client-0");
-
- await(srvLeftLatch);
-
- checkNodes(1, 0);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testClientNodeFailOneServer() throws Exception {
- startServerNodes(1);
- startClientNodes(1);
-
- checkNodes(1, 1);
-
- srvFailedLatch = new CountDownLatch(1);
-
- attachListeners(1, 0);
-
- failClient(0);
-
- await(srvFailedLatch);
-
- checkNodes(1, 0);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testMetrics() throws Exception {
- startServerNodes(3);
- startClientNodes(3);
-
- checkNodes(3, 3);
-
- attachListeners(3, 3);
-
- assertTrue(checkMetrics(3, 3, 0));
-
- G.grid("client-0").compute().broadcast(F.noop());
-
- assertTrue(GridTestUtils.waitForCondition(new PA() {
- @Override public boolean apply() {
- return checkMetrics(3, 3, 1);
- }
- }, 10000));
-
- checkMetrics(3, 3, 1);
-
- G.grid("server-0").compute().broadcast(F.noop());
-
- assertTrue(GridTestUtils.waitForCondition(new PA() {
- @Override public boolean apply() {
- return checkMetrics(3, 3, 2);
- }
- }, 10000));
- }
-
- /**
- * @param srvCnt Number of Number of server nodes.
- * @param clientCnt Number of client nodes.
- * @param execJobsCnt Expected number of executed jobs.
- * @return Whether metrics are correct.
- */
- private boolean checkMetrics(int srvCnt, int clientCnt, int execJobsCnt) {
- for (int i = 0; i < srvCnt; i++) {
- Ignite g = G.grid("server-" + i);
-
- for (ClusterNode n : g.cluster().nodes()) {
- if (n.metrics().getTotalExecutedJobs() != execJobsCnt)
- return false;
- }
- }
-
- for (int i = 0; i < clientCnt; i++) {
- Ignite g = G.grid("client-" + i);
-
- for (ClusterNode n : g.cluster().nodes()) {
- if (n.metrics().getTotalExecutedJobs() != execJobsCnt)
- return false;
- }
- }
-
- return true;
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDataExchangeFromServer() throws Exception {
- testDataExchange("server-0");
- }
-
- /**
- * @throws Exception If failed.
- */
- // TODO: GG-9174
- public void _testDataExchangeFromClient() throws Exception {
- testDataExchange("client-0");
- }
-
- /**
- * @throws Exception If failed.
- */
- private void testDataExchange(String masterName) throws Exception {
- startServerNodes(2);
- startClientNodes(2);
-
- checkNodes(2, 2);
-
- IgniteMessaging msg = grid(masterName).message();
-
- UUID id = null;
-
- try {
- id = msg.remoteListen(null, new MessageListener());
-
- msgLatch = new CountDownLatch(4);
-
- msg.send(null, "Message 1");
-
- await(msgLatch);
-
- startServerNodes(1);
- startClientNodes(1);
-
- checkNodes(3, 3);
-
- msgLatch = new CountDownLatch(6);
-
- msg.send(null, "Message 2");
-
- await(msgLatch);
- }
- finally {
- if (id != null)
- msg.stopRemoteListen(id);
- }
- }
-
- /**
- * @param idx Index.
- * @throws Exception In case of error.
- */
- private void resetClientIpFinder(int idx) throws Exception {
- TcpClientDiscoverySpi disco =
- (TcpClientDiscoverySpi)G.grid("client-" + idx).configuration().getDiscoverySpi();
-
- TcpDiscoveryVmIpFinder ipFinder = (TcpDiscoveryVmIpFinder)disco.getIpFinder();
-
- String addr = IP_FINDER.getRegisteredAddresses().iterator().next().toString();
-
- if (addr.startsWith("/"))
- addr = addr.substring(1);
-
- ipFinder.setAddresses(Arrays.asList(addr));
- }
-
- /**
- * @param cnt Number of nodes.
- * @throws Exception In case of error.
- */
- private void startServerNodes(int cnt) throws Exception {
- for (int i = 0; i < cnt; i++) {
- Ignite g = startGrid("server-" + srvIdx.getAndIncrement());
-
- srvNodeIds.add(g.cluster().localNode().id());
- }
- }
-
- /**
- * @param cnt Number of nodes.
- * @throws Exception In case of error.
- */
- private void startClientNodes(int cnt) throws Exception {
- for (int i = 0; i < cnt; i++) {
- Ignite g = startGrid("client-" + clientIdx.getAndIncrement());
-
- clientNodeIds.add(g.cluster().localNode().id());
- }
- }
-
- /**
- * @param idx Index.
- */
- private void failServer(int idx) {
- ((TcpDiscoverySpi)G.grid("server-" + idx).configuration().getDiscoverySpi()).simulateNodeFailure();
- }
-
- /**
- * @param idx Index.
- */
- private void failClient(int idx) {
- ((TcpClientDiscoverySpi)G.grid("client-" + idx).configuration().getDiscoverySpi()).simulateNodeFailure();
- }
-
- /**
- * @param srvCnt Number of server nodes.
- * @param clientCnt Number of client nodes.
- */
- private void attachListeners(int srvCnt, int clientCnt) throws Exception {
- if (srvJoinedLatch != null) {
- for (int i = 0; i < srvCnt; i++) {
- G.grid("server-" + i).events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- info("Joined event fired on server: " + evt);
-
- srvJoinedLatch.countDown();
-
- return true;
- }
- }, EVT_NODE_JOINED);
- }
- }
-
- if (srvLeftLatch != null) {
- for (int i = 0; i < srvCnt; i++) {
- G.grid("server-" + i).events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- info("Left event fired on server: " + evt);
-
- srvLeftLatch.countDown();
-
- return true;
- }
- }, EVT_NODE_LEFT);
- }
- }
-
- if (srvFailedLatch != null) {
- for (int i = 0; i < srvCnt; i++) {
- G.grid("server-" + i).events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- info("Failed event fired on server: " + evt);
-
- srvFailedLatch.countDown();
-
- return true;
- }
- }, EVT_NODE_FAILED);
- }
- }
-
- if (clientJoinedLatch != null) {
- for (int i = 0; i < clientCnt; i++) {
- G.grid("client-" + i).events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- info("Joined event fired on client: " + evt);
-
- clientJoinedLatch.countDown();
-
- return true;
- }
- }, EVT_NODE_JOINED);
- }
- }
-
- if (clientLeftLatch != null) {
- for (int i = 0; i < clientCnt; i++) {
- G.grid("client-" + i).events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- info("Left event fired on client: " + evt);
-
- clientLeftLatch.countDown();
-
- return true;
- }
- }, EVT_NODE_LEFT);
- }
- }
-
- if (clientFailedLatch != null) {
- for (int i = 0; i < clientCnt; i++) {
- G.grid("client-" + i).events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- info("Failed event fired on client: " + evt);
-
- clientFailedLatch.countDown();
-
- return true;
- }
- }, EVT_NODE_FAILED);
- }
- }
- }
-
- /**
- * @param srvCnt Number of server nodes.
- * @param clientCnt Number of client nodes.
- */
- private void checkNodes(int srvCnt, int clientCnt) {
- for (int i = 0; i < srvCnt; i++) {
- Ignite g = G.grid("server-" + i);
-
- assertTrue(srvNodeIds.contains(g.cluster().localNode().id()));
-
- assertFalse(g.cluster().localNode().isClient());
-
- checkRemoteNodes(g, srvCnt + clientCnt - 1);
- }
-
- for (int i = 0; i < clientCnt; i++) {
- Ignite g = G.grid("client-" + i);
-
- assertTrue(clientNodeIds.contains(g.cluster().localNode().id()));
-
- assertTrue(g.cluster().localNode().isClient());
-
- checkRemoteNodes(g, srvCnt + clientCnt - 1);
- }
- }
-
- /**
- * @param ignite Grid.
- * @param expCnt Expected nodes count.
- */
- @SuppressWarnings("TypeMayBeWeakened")
- private void checkRemoteNodes(Ignite ignite, int expCnt) {
- Collection<ClusterNode> nodes = ignite.cluster().forRemotes().nodes();
-
- assertEquals(expCnt, nodes.size());
-
- for (ClusterNode node : nodes) {
- UUID id = node.id();
-
- if (clientNodeIds.contains(id))
- assertTrue(node.isClient());
- else if (srvNodeIds.contains(id))
- assertFalse(node.isClient());
- else
- assert false : "Unexpected node ID: " + id;
- }
- }
-
- /**
- * @param latch Latch.
- * @throws InterruptedException If interrupted.
- */
- private void await(CountDownLatch latch) throws InterruptedException {
- assertTrue("Latch count: " + latch.getCount(), latch.await(10000, MILLISECONDS));
- }
-
- /**
- */
- private static class MessageListener implements IgniteBiPredicate<UUID, Object> {
- @IgniteLocalNodeIdResource
- private UUID nodeId;
-
- /** {@inheritDoc} */
- @Override public boolean apply(UUID uuid, Object msg) {
- X.println(">>> Received [locNodeId=" + nodeId + ", msg=" + msg + ']');
-
- msgLatch.countDown();
-
- return true;
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryConcurrentStartTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryConcurrentStartTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryConcurrentStartTest.java
deleted file mode 100644
index 1048160..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryConcurrentStartTest.java
+++ /dev/null
@@ -1,110 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.apache.ignite.configuration.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.vm.*;
-import org.gridgain.testframework.junits.common.*;
-
-import java.util.*;
-
-/**
- * Test for {@link TcpDiscoverySpi}.
- */
-public class GridTcpDiscoveryConcurrentStartTest extends GridCommonAbstractTest {
- /** */
- private static final int TOP_SIZE = 1;
-
- /** */
- private static TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
-
- /** */
- private static volatile boolean client;
-
- /** {@inheritDoc} */
- @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);
- }
- else {
- TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
-
- discoSpi.setIpFinder(ipFinder);
-
- cfg.setDiscoverySpi(discoSpi);
- }
-
- cfg.setLocalHost("127.0.0.1");
-
- cfg.setCacheConfiguration();
-
- return cfg;
- }
-
- /** {@inheritDoc} */
- @Override protected long getTestTimeout() {
- return Long.MAX_VALUE;
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testConcurrentStart() throws Exception {
- for (int i = 0; i < 50; i++) {
- try {
- startGridsMultiThreaded(TOP_SIZE);
- }
- finally {
- stopAllGrids();
- }
- }
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testConcurrentStartClients() throws Exception {
- for (int i = 0; i < 50; i++) {
- try {
- client = false;
-
- startGrid();
-
- client = true;
-
- startGridsMultiThreaded(TOP_SIZE);
- }
- finally {
- stopAllGrids();
- }
- }
- }
-
- /** {@inheritDoc} */
- @Override protected void afterTestsStopped() throws Exception {
- stopAllGrids();
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryMarshallerCheckSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryMarshallerCheckSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryMarshallerCheckSelfTest.java
deleted file mode 100644
index b3991c2..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryMarshallerCheckSelfTest.java
+++ /dev/null
@@ -1,94 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.marshaller.jdk.*;
-import org.apache.ignite.marshaller.optimized.*;
-import org.apache.ignite.spi.*;
-import org.gridgain.grid.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.vm.*;
-import org.gridgain.testframework.junits.common.*;
-
-/**
- * Test for {@link TcpDiscoverySpi}.
- */
-public class GridTcpDiscoveryMarshallerCheckSelfTest extends GridCommonAbstractTest {
- /** */
- private static boolean sameMarsh;
-
- /** */
- private static boolean flag;
-
- /** */
- private static TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
-
- /** {@inheritDoc} */
- @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
- IgniteConfiguration cfg = super.getConfiguration(gridName);
-
- TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
-
- discoSpi.setIpFinder(ipFinder);
-
- cfg.setDiscoverySpi(discoSpi);
-
- cfg.setLocalHost("127.0.0.1");
-
- if (flag)
- cfg.setMarshaller(new IgniteJdkMarshaller());
- else
- cfg.setMarshaller(sameMarsh ? new IgniteJdkMarshaller() : new IgniteOptimizedMarshaller());
-
- // Flip flag.
- flag = !flag;
-
- return cfg;
- }
-
- /** {@inheritDoc} */
- @Override protected void afterTest() throws Exception {
- stopAllGrids();
-
- flag = false;
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testMarshallerInConsistency() throws Exception {
- sameMarsh = false;
-
- startGrid(1);
-
- try {
- startGrid(2);
-
- fail("Expected SPI exception was not thrown.");
- }
- catch (GridException e) {
- Throwable ex = e.getCause().getCause();
-
- assertTrue(ex instanceof IgniteSpiException);
- assertTrue(ex.getMessage().contains("Local node's marshaller differs from remote node's marshaller"));
- }
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testMarshallerConsistency() throws Exception {
- sameMarsh = true;
-
- startGrid(1);
- startGrid(2);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryMultiThreadedTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryMultiThreadedTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryMultiThreadedTest.java
deleted file mode 100644
index 6f046a7..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoveryMultiThreadedTest.java
+++ /dev/null
@@ -1,199 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.apache.ignite.*;
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.lang.*;
-import org.gridgain.grid.kernal.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.vm.*;
-import org.gridgain.grid.util.typedef.*;
-import org.gridgain.testframework.junits.common.*;
-
-import java.util.concurrent.*;
-import java.util.concurrent.atomic.*;
-
-import static org.apache.ignite.events.IgniteEventType.*;
-
-/**
- * Test for {@link TcpDiscoverySpi}.
- */
-public class GridTcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest {
- /** */
- private static final int GRID_CNT = 5;
-
- /** */
- private static final int CLIENT_GRID_CNT = 5;
-
- /** */
- private static final ThreadLocal<Boolean> clientFlagPerThread = new ThreadLocal<>();
-
- /** */
- private static volatile boolean clientFlagGlobal;
-
- /**
- * @return Client node flag.
- */
- private static boolean client() {
- Boolean client = clientFlagPerThread.get();
-
- return client != null ? client : clientFlagGlobal;
- }
-
- /** */
- private TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
-
- /**
- * @throws Exception If fails.
- */
- public GridTcpDiscoveryMultiThreadedTest() throws Exception {
- super(false);
- }
-
- /** {@inheritDoc} */
- @SuppressWarnings({"IfMayBeConditional"})
- @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
- IgniteConfiguration cfg = super.getConfiguration(gridName);
-
- if (client()) {
- TcpClientDiscoverySpi spi = new TcpClientDiscoverySpi();
-
- spi.setIpFinder(ipFinder);
-
- cfg.setDiscoverySpi(spi);
- }
- else {
- TcpDiscoverySpi spi = new TcpDiscoverySpi();
-
- spi.setIpFinder(ipFinder);
-
- cfg.setDiscoverySpi(spi);
- }
-
- cfg.setCacheConfiguration();
-
- cfg.setIncludeEventTypes(EVT_TASK_FAILED, EVT_TASK_FINISHED, EVT_JOB_MAPPED);
-
- cfg.setIncludeProperties();
-
- cfg.setLocalHost("127.0.0.1");
-
- return cfg;
- }
-
- /** {@inheritDoc} */
- @Override protected void afterTest() throws Exception {
- super.afterTest();
-
- stopAllGrids();
- }
-
- /** {@inheritDoc} */
- @Override protected long getTestTimeout() {
- return 5 * 60 * 1000;
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testMultiThreaded() throws Exception {
- execute();
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testTopologyVersion() throws Exception {
- startGridsMultiThreaded(GRID_CNT);
-
- long prev = 0;
-
- for (Ignite g : G.allGrids()) {
- GridKernal kernal = (GridKernal)g;
-
- long ver = kernal.context().discovery().topologyVersion();
-
- info("Top ver: " + ver);
-
- if (prev == 0)
- prev = ver;
- }
-
- info("Test finished.");
- }
-
- /**
- * @throws Exception If failed.
- */
- private void execute() throws Exception {
- info("Test timeout: " + (getTestTimeout() / (60 * 1000)) + " min.");
-
- startGridsMultiThreaded(GRID_CNT);
-
- clientFlagGlobal = true;
-
- startGridsMultiThreaded(GRID_CNT, CLIENT_GRID_CNT);
-
- final AtomicBoolean done = new AtomicBoolean();
-
- final AtomicInteger clientIdx = new AtomicInteger(GRID_CNT);
-
- IgniteFuture<?> fut1 = multithreadedAsync(
- new Callable<Object>() {
- @Override public Object call() throws Exception {
- clientFlagPerThread.set(true);
-
- int idx = clientIdx.getAndIncrement();
-
- while (!done.get()) {
- stopGrid(idx);
- startGrid(idx);
- }
-
- return null;
- }
- },
- CLIENT_GRID_CNT
- );
-
- final BlockingQueue<Integer> srvIdx = new LinkedBlockingQueue<>();
-
- for (int i = 0; i < GRID_CNT; i++)
- srvIdx.add(i);
-
- IgniteFuture<?> fut2 = multithreadedAsync(
- new Callable<Object>() {
- @Override public Object call() throws Exception {
- clientFlagPerThread.set(false);
-
- while (!done.get()) {
- int idx = srvIdx.take();
-
- stopGrid(idx);
- startGrid(idx);
-
- srvIdx.add(idx);
- }
-
- return null;
- }
- },
- GRID_CNT - 1
- );
-
- Thread.sleep(getTestTimeout() - 60 * 1000);
-
- done.set(true);
-
- fut1.get();
- fut2.get();
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySelfTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySelfTest.java
deleted file mode 100644
index cfb7b92..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySelfTest.java
+++ /dev/null
@@ -1,983 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.apache.ignite.*;
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.events.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.spi.*;
-import org.gridgain.grid.*;
-import org.gridgain.grid.kernal.*;
-import org.gridgain.grid.kernal.processors.port.*;
-import org.gridgain.grid.spi.discovery.*;
-import org.gridgain.grid.spi.discovery.tcp.internal.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.multicast.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.vm.*;
-import org.gridgain.grid.spi.discovery.tcp.messages.*;
-import org.gridgain.grid.util.typedef.*;
-import org.gridgain.grid.util.typedef.internal.*;
-import org.gridgain.testframework.*;
-import org.gridgain.testframework.junits.common.*;
-import org.jetbrains.annotations.*;
-
-import java.io.*;
-import java.net.*;
-import java.util.*;
-import java.util.concurrent.*;
-import java.util.concurrent.atomic.*;
-
-import static java.util.concurrent.TimeUnit.*;
-import static org.apache.ignite.events.IgniteEventType.*;
-import static org.apache.ignite.spi.IgnitePortProtocol.*;
-
-/**
- * Test for {@link TcpDiscoverySpi}.
- */
-public class GridTcpDiscoverySelfTest extends GridCommonAbstractTest {
- /** */
- private TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
-
- /** */
- private Map<String, TcpDiscoverySpi> discoMap = new HashMap<>();
-
- /** */
- private UUID nodeId;
-
- /**
- * @throws Exception If fails.
- */
- public GridTcpDiscoverySelfTest() throws Exception {
- super(false);
- }
-
- /** {@inheritDoc} */
- @SuppressWarnings({"IfMayBeConditional", "deprecation"})
- @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
- IgniteConfiguration cfg = super.getConfiguration(gridName);
-
- TcpDiscoverySpi spi;
-
- if (gridName.contains("FailBeforeNodeAddedSentSpi"))
- spi = new FailBeforeNodeAddedSentSpi();
- else if (gridName.contains("FailBeforeNodeLeftSentSpi"))
- spi = new FailBeforeNodeLeftSentSpi();
- else
- spi = new TcpDiscoverySpi();
-
- discoMap.put(gridName, spi);
-
- spi.setIpFinder(ipFinder);
-
- spi.setNetworkTimeout(2500);
-
- spi.setHeartbeatFrequency(1000);
-
- spi.setMaxMissedHeartbeats(3);
-
- spi.setIpFinderCleanFrequency(5000);
-
- spi.setJoinTimeout(5000);
-
- cfg.setDiscoverySpi(spi);
-
- cfg.setCacheConfiguration();
-
- cfg.setIncludeEventTypes(EVT_TASK_FAILED, EVT_TASK_FINISHED, EVT_JOB_MAPPED);
-
- cfg.setIncludeProperties();
-
- if (!gridName.contains("LoopbackProblemTest"))
- cfg.setLocalHost("127.0.0.1");
-
- if (gridName.contains("testFailureDetectionOnNodePing")) {
- spi.setReconnectCount(1); // To make test faster: on Windows 1 connect takes 1 second.
- spi.setHeartbeatFrequency(40000);
- }
-
- cfg.setRestEnabled(false);
-
- if (nodeId != null)
- cfg.setNodeId(nodeId);
-
- if (gridName.contains("NonSharedIpFinder")) {
- TcpDiscoveryVmIpFinder finder = new TcpDiscoveryVmIpFinder();
-
- finder.setAddresses(Arrays.asList("127.0.0.1:47501"));
-
- spi.setIpFinder(finder);
- }
- else if (gridName.contains("MulticastIpFinder")) {
- TcpDiscoveryMulticastIpFinder finder = new TcpDiscoveryMulticastIpFinder();
-
- finder.setAddressRequestAttempts(10);
- finder.setMulticastGroup(GridTestUtils.getNextMulticastGroup(getClass()));
- finder.setMulticastPort(GridTestUtils.getNextMulticastPort(getClass()));
-
- spi.setIpFinder(finder);
-
- // Loopback multicast discovery is not working on Mac OS
- // (possibly due to http://bugs.sun.com/bugdatabase/view_bug.do?bug_id=7122846).
- if (U.isMacOs())
- spi.setLocalAddress(F.first(U.allLocalIps()));
- }
-
- return cfg;
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testSingleNodeStartStop() throws Exception {
- try {
- startGrid(1);
- }
- finally {
- stopGrid(1);
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testThreeNodesStartStop() throws Exception {
- try {
- startGrid(1);
- startGrid(2);
- startGrid(3);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any errors occur.
- */
- public void testNodeConnectMessageSize() throws Exception {
- try {
- Ignite g1 = startGrid(1);
-
- final AtomicInteger gridNameIdx = new AtomicInteger(1);
-
- GridTestUtils.runMultiThreaded(new Callable<Object>() {
- @Nullable @Override public Object call() throws Exception {
- startGrid(gridNameIdx.incrementAndGet());
-
- return null;
- }
- }, 4, "grid-starter");
-
- Collection<TcpDiscoveryNode> nodes = discoMap.get(g1.name()).ring().allNodes();
-
- ByteArrayOutputStream bos = new ByteArrayOutputStream();
-
- g1.configuration().getMarshaller().marshal(nodes, bos);
-
- info(">>> Approximate node connect message size [topSize=" + nodes.size() +
- ", msgSize=" + bos.size() / 1024.0 + "KB]");
- }
- finally {
- stopAllGrids(false);
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testPing() throws Exception {
- try {
- startGrid(1);
- startGrid(2);
- startGrid(3);
-
- info("Nodes were started");
-
- for (Map.Entry<String, TcpDiscoverySpi> e : discoMap.entrySet()) {
- DiscoverySpi spi = e.getValue();
-
- for (Ignite g : G.allGrids()) {
- boolean res = spi.pingNode(g.cluster().localNode().id());
-
- assert res : e.getKey() + " failed to ping " + g.cluster().localNode().id() + " of " + g.name();
-
- info(e.getKey() + " pinged " + g.cluster().localNode().id() + " of " + g.name());
- }
- }
-
- info("All nodes pinged successfully.");
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testFailureDetectionOnNodePing1() throws Exception {
- try {
- Ignite g1 = startGrid("testFailureDetectionOnNodePingCoordinator");
- startGrid("testFailureDetectionOnNodePing2");
- Ignite g3 = startGrid("testFailureDetectionOnNodePing3");
-
- testFailureDetectionOnNodePing(g1, g3);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testFailureDetectionOnNodePing2() throws Exception {
- try {
- startGrid("testFailureDetectionOnNodePingCoordinator");
- Ignite g2 = startGrid("testFailureDetectionOnNodePing2");
- Ignite g3 = startGrid("testFailureDetectionOnNodePing3");
-
- testFailureDetectionOnNodePing(g3, g2);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testFailureDetectionOnNodePing3() throws Exception {
- try {
- Ignite g1 = startGrid("testFailureDetectionOnNodePingCoordinator");
- Ignite g2 = startGrid("testFailureDetectionOnNodePing2");
- startGrid("testFailureDetectionOnNodePing3");
-
- testFailureDetectionOnNodePing(g2, g1);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- private void testFailureDetectionOnNodePing(Ignite pingingNode, Ignite failedNode) throws Exception {
- final CountDownLatch cnt = new CountDownLatch(1);
-
- pingingNode.events().localListen(
- new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- cnt.countDown();
-
- return true;
- }
- },
- IgniteEventType.EVT_NODE_FAILED
- );
-
- info("Nodes were started");
-
- discoMap.get(failedNode.name()).simulateNodeFailure();
-
- TcpDiscoverySpi spi = discoMap.get(pingingNode.name());
-
- boolean res = spi.pingNode(failedNode.cluster().localNode().id());
-
- assertFalse("Ping is ok for node " + failedNode.cluster().localNode().id() + ", but had to fail.", res);
-
- // Heartbeat interval is 40 seconds, but we should detect node failure faster.
- assert cnt.await(7, SECONDS);
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testNodeAdded() throws Exception {
- try {
- final Ignite g1 = startGrid(1);
-
- final CountDownLatch cnt = new CountDownLatch(2);
-
- g1.events().localListen(
- new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- info("Node joined: " + evt.message());
-
- IgniteDiscoveryEvent discoEvt = (IgniteDiscoveryEvent)evt;
-
- TcpDiscoveryNode node = ((TcpDiscoveryNode)discoMap.get(g1.name()).
- getNode(discoEvt.eventNode().id()));
-
- assert node != null && node.visible();
-
- cnt.countDown();
-
- return true;
- }
- },
- IgniteEventType.EVT_NODE_JOINED
- );
-
- startGrid(2);
- startGrid(3);
-
- info("Nodes were started");
-
- assert cnt.await(1, SECONDS);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testOrdinaryNodeLeave() throws Exception {
- try {
- Ignite g1 = startGrid(1);
- startGrid(2);
- startGrid(3);
-
- final CountDownLatch cnt = new CountDownLatch(2);
-
- g1.events().localListen(
- new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- cnt.countDown();
-
- return true;
- }
- },
- EVT_NODE_LEFT
- );
-
- info("Nodes were started");
-
- stopGrid(3);
- stopGrid(2);
-
- boolean res = cnt.await(1, SECONDS);
-
- assert res;
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testCoordinatorNodeLeave() throws Exception {
- try {
- startGrid(1);
- Ignite g2 = startGrid(2);
-
- final CountDownLatch cnt = new CountDownLatch(1);
-
- g2.events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- cnt.countDown();
-
- return true;
- }
- }, EVT_NODE_LEFT);
-
- info("Nodes were started");
-
- stopGrid(1);
-
- assert cnt.await(1, SECONDS);
-
- // Start new grid, ensure that added to topology
- final CountDownLatch cnt2 = new CountDownLatch(1);
-
- g2.events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- cnt2.countDown();
-
- return true;
- }
- }, EVT_NODE_JOINED);
-
- startGrid(3);
-
- assert cnt2.await(1, SECONDS);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testOrdinaryNodeFailure() throws Exception {
- try {
- Ignite g1 = startGrid(1);
- Ignite g2 = startGrid(2);
- Ignite g3 = startGrid(3);
-
- final CountDownLatch cnt = new CountDownLatch(2);
-
- g1.events().localListen(
- new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- cnt.countDown();
-
- return true;
- }
- },
- IgniteEventType.EVT_NODE_FAILED
- );
-
- info("Nodes were started");
-
- discoMap.get(g2.name()).simulateNodeFailure();
- discoMap.get(g3.name()).simulateNodeFailure();
-
- assert cnt.await(25, SECONDS);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testCoordinatorNodeFailure() throws Exception {
- try {
- Ignite g1 = startGrid(1);
- Ignite g2 = startGrid(2);
-
- final CountDownLatch cnt = new CountDownLatch(1);
-
- g2.events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- cnt.countDown();
-
- return true;
- }
- }, IgniteEventType.EVT_NODE_FAILED);
-
- info("Nodes were started");
-
- discoMap.get(g1.name()).simulateNodeFailure();
-
- assert cnt.await(20, SECONDS);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testMetricsSending() throws Exception {
- final AtomicBoolean stopping = new AtomicBoolean();
-
- try {
- final CountDownLatch latch1 = new CountDownLatch(1);
-
- final Ignite g1 = startGrid(1);
-
- IgnitePredicate<IgniteEvent> lsnr1 = new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- info(evt.message());
-
- latch1.countDown();
-
- return true;
- }
- };
-
- g1.events().localListen(lsnr1, EVT_NODE_METRICS_UPDATED);
-
- assert latch1.await(10, SECONDS);
-
- g1.events().stopLocalListen(lsnr1);
-
- final CountDownLatch latch1_1 = new CountDownLatch(1);
- final CountDownLatch latch1_2 = new CountDownLatch(1);
- final CountDownLatch latch2_1 = new CountDownLatch(1);
- final CountDownLatch latch2_2 = new CountDownLatch(1);
-
- final Ignite g2 = startGrid(2);
-
- g2.events().localListen(
- new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- if (stopping.get())
- return true;
-
- info(evt.message());
-
- UUID id = ((IgniteDiscoveryEvent) evt).eventNode().id();
-
- if (id.equals(g1.cluster().localNode().id()))
- latch2_1.countDown();
- else if (id.equals(g2.cluster().localNode().id()))
- latch2_2.countDown();
- else
- assert false : "Event fired for unknown node.";
-
- return true;
- }
- },
- EVT_NODE_METRICS_UPDATED
- );
-
- g1.events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- if (stopping.get())
- return true;
-
- info(evt.message());
-
- UUID id = ((IgniteDiscoveryEvent) evt).eventNode().id();
-
- if (id.equals(g1.cluster().localNode().id()))
- latch1_1.countDown();
- else if (id.equals(g2.cluster().localNode().id()))
- latch1_2.countDown();
- else
- assert false : "Event fired for unknown node.";
-
- return true;
- }
- }, EVT_NODE_METRICS_UPDATED);
-
- assert latch1_1.await(10, SECONDS);
- assert latch1_2.await(10, SECONDS);
- assert latch2_1.await(10, SECONDS);
- assert latch2_2.await(10, SECONDS);
- }
- finally {
- stopping.set(true);
-
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testFailBeforeNodeAddedSent() throws Exception {
- try {
- Ignite g1 = startGrid(1);
-
- final CountDownLatch joinCnt = new CountDownLatch(2);
- final CountDownLatch failCnt = new CountDownLatch(1);
-
- g1.events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- if (evt.type() == EVT_NODE_JOINED)
- joinCnt.countDown();
- else if (evt.type() == EVT_NODE_FAILED)
- failCnt.countDown();
- else
- assert false : "Unexpected event type: " + evt;
-
- return true;
- }
- }, EVT_NODE_JOINED, EVT_NODE_FAILED);
-
- startGrid("FailBeforeNodeAddedSentSpi");
-
- startGrid(3);
-
- assert joinCnt.await(10, SECONDS);
- assert failCnt.await(10, SECONDS);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testFailBeforeNodeLeftSent() throws Exception {
- try {
- startGrid(1);
- startGrid(2);
-
- startGrid("FailBeforeNodeLeftSentSpi");
-
- Ignite g3 = startGrid(3);
-
- final CountDownLatch cnt = new CountDownLatch(1);
-
- g3.events().localListen(new IgnitePredicate<IgniteEvent>() {
- @Override public boolean apply(IgniteEvent evt) {
- cnt.countDown();
-
- return true;
- }
- }, EVT_NODE_FAILED);
-
- stopGrid(1);
-
- assert cnt.await(20, SECONDS);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testIpFinderCleaning() throws Exception {
- try {
- ipFinder.registerAddresses(Arrays.asList(new InetSocketAddress("host1", 1024),
- new InetSocketAddress("host2", 1024)));
-
- Ignite g1 = startGrid(1);
-
- long timeout = (long)(discoMap.get(g1.name()).getIpFinderCleanFrequency() * 1.5);
-
- Thread.sleep(timeout);
-
- assert ipFinder.getRegisteredAddresses().size() == 1 : "ipFinder=" + ipFinder.getRegisteredAddresses();
-
- // Check that missing addresses are returned back.
- ipFinder.unregisterAddresses(ipFinder.getRegisteredAddresses()); // Unregister valid address.
-
- ipFinder.registerAddresses(Arrays.asList(new InetSocketAddress("host1", 1024),
- new InetSocketAddress("host2", 1024)));
-
- Thread.sleep(timeout);
-
- assert ipFinder.getRegisteredAddresses().size() == 1 : "ipFinder=" + ipFinder.getRegisteredAddresses();
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testNonSharedIpFinder() throws Exception {
- try {
- GridTestUtils.runMultiThreadedAsync(new Callable<Object>() {
- @Override public Object call() throws Exception {
- Thread.sleep(4000);
-
- return startGrid("NonSharedIpFinder-2");
- }
- }, 1, "grid-starter");
-
- // This node should wait until any node "from ipFinder" appears, see log messages.
- Ignite g = startGrid("NonSharedIpFinder-1");
-
- assert g.cluster().localNode().order() == 2;
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testMulticastIpFinder() throws Exception {
- try {
- for (int i = 0; i < 5; i++) {
- Ignite g = startGrid("MulticastIpFinder-" + i);
-
- assertEquals(i + 1, g.cluster().nodes().size());
-
- TcpDiscoverySpi spi = (TcpDiscoverySpi)g.configuration().getDiscoverySpi();
-
- TcpDiscoveryMulticastIpFinder ipFinder = (TcpDiscoveryMulticastIpFinder)spi.getIpFinder();
-
- boolean found = false;
-
- for (GridPortRecord rec : ((GridKernal) g).context().ports().records()) {
- if ((rec.protocol() == UDP) && rec.port() == ipFinder.getMulticastPort()) {
- found = true;
-
- break;
- }
- }
-
- assertTrue("GridTcpDiscoveryMulticastIpFinder should register port." , found);
- }
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testInvalidAddressIpFinder() throws Exception {
- ipFinder.setShared(false);
-
- ipFinder.setAddresses(Collections.singletonList("some-host"));
-
- try {
- GridTestUtils.assertThrows(
- log,
- new Callable<Object>() {
- @Nullable @Override public Object call() throws Exception {
- startGrid(1);
-
- return null;
- }
- },
- GridException.class,
- null);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testJoinTimeout() throws Exception {
- try {
- // This start will fail as expected.
- Throwable t = GridTestUtils.assertThrows(log, new Callable<Object>() {
- @Override public Object call() throws Exception {
- startGrid("NonSharedIpFinder-1");
-
- return null;
- }
- }, GridException.class, null);
-
- assert X.hasCause(t, IgniteSpiException.class) : "Unexpected exception: " + t;
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDirtyIpFinder() throws Exception {
- try {
- // Dirty IP finder
- for (int i = 47500; i < 47520; i++)
- ipFinder.registerAddresses(Arrays.asList(new InetSocketAddress("127.0.0.1", i),
- new InetSocketAddress("unknown-host", i)));
-
- assert ipFinder.isShared();
-
- startGrid(1);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testDuplicateId() throws Exception {
- try {
- // Random ID.
- startGrid(1);
-
- nodeId = UUID.randomUUID();
-
- startGrid(2);
-
- // Duplicate ID.
- GridTestUtils.assertThrows(
- log,
- new Callable<Object>() {
- @Nullable @Override public Object call() throws Exception {
- // Exception will be thrown and output to log.
- startGrid(3);
-
- return null;
- }
- },
- GridException.class,
- null);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testLoopbackProblemFirstNodeOnLoopback() throws Exception {
- // On Windows and Mac machines two nodes can reside on the same port
- // (if one node has localHost="127.0.0.1" and another has localHost="0.0.0.0").
- // So two nodes do not even discover each other.
- if (U.isWindows() || U.isMacOs())
- return;
-
- try {
- startGridNoOptimize(1);
-
- GridTestUtils.assertThrows(
- log,
- new Callable<Object>() {
- @Nullable @Override public Object call() throws Exception {
- // Exception will be thrown because we start node which does not use loopback address,
- // but the first node does.
- startGridNoOptimize("LoopbackProblemTest");
-
- return null;
- }
- },
- GridException.class,
- null);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testLoopbackProblemSecondNodeOnLoopback() throws Exception {
- if (U.isWindows() || U.isMacOs())
- return;
-
- try {
- startGridNoOptimize("LoopbackProblemTest");
-
- GridTestUtils.assertThrows(
- log,
- new Callable<Object>() {
- @Nullable @Override public Object call() throws Exception {
- // Exception will be thrown because we start node which uses loopback address,
- // but the first node does not.
- startGridNoOptimize(1);
-
- return null;
- }
- },
- GridException.class,
- null);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testGridStartTime() throws Exception {
- try {
- startGridsMultiThreaded(5);
-
- Long startTime = null;
-
- GridKernal firstGrid = null;
-
- Collection<GridKernal> grids = new ArrayList<>();
-
- for (int i = 0; i < 5 ; i++) {
- GridKernal grid = (GridKernal)grid(i);
-
- assertTrue(grid.context().discovery().gridStartTime() > 0);
-
- if (i > 0)
- assertEquals(startTime, (Long)grid.context().discovery().gridStartTime());
- else
- startTime = grid.context().discovery().gridStartTime();
-
- if (grid.localNode().order() == 1)
- firstGrid = grid;
- else
- grids.add(grid);
- }
-
- assertNotNull(firstGrid);
-
- stopGrid(firstGrid.name());
-
- for (GridKernal grid : grids)
- assertEquals(startTime, (Long)grid.context().discovery().gridStartTime());
-
- grids.add((GridKernal) startGrid(5));
-
- for (GridKernal grid : grids)
- assertEquals(startTime, (Long)grid.context().discovery().gridStartTime());
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * Starts new grid with given index. Method optimize is not invoked.
- *
- * @param idx Index of the grid to start.
- * @return Started grid.
- * @throws Exception If anything failed.
- */
- private Ignite startGridNoOptimize(int idx) throws Exception {
- return startGridNoOptimize(getTestGridName(idx));
- }
-
- /**
- * Starts new grid with given name. Method optimize is not invoked.
- *
- * @param gridName Grid name.
- * @return Started grid.
- * @throws Exception If failed.
- */
- private Ignite startGridNoOptimize(String gridName) throws Exception {
- return G.start(getConfiguration(gridName));
- }
-
- /**
- *
- */
- private static class FailBeforeNodeAddedSentSpi extends TcpDiscoverySpi {
- /** */
- private int i;
-
- /** {@inheritDoc} */
- @Override void onBeforeMessageSentAcrossRing(Serializable msg) {
- if (msg instanceof TcpDiscoveryNodeAddedMessage)
- if (++i == 2) {
- simulateNodeFailure();
-
- throw new RuntimeException("Avoid message sending: " + msg.getClass());
- }
- }
- }
-
- /**
- *
- */
- private static class FailBeforeNodeLeftSentSpi extends TcpDiscoverySpi {
- /** {@inheritDoc} */
- @Override void onBeforeMessageSentAcrossRing(Serializable msg) {
- if (msg instanceof TcpDiscoveryNodeLeftMessage) {
- simulateNodeFailure();
-
- throw new RuntimeException("Avoid message sending: " + msg.getClass());
- }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySnapshotHistoryTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySnapshotHistoryTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySnapshotHistoryTest.java
deleted file mode 100644
index 3edfac4..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySnapshotHistoryTest.java
+++ /dev/null
@@ -1,166 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.apache.ignite.*;
-import org.apache.ignite.configuration.*;
-import org.gridgain.grid.spi.discovery.*;
-import org.gridgain.grid.util.typedef.internal.*;
-import org.gridgain.testframework.junits.common.*;
-
-import static org.gridgain.grid.spi.discovery.tcp.TcpDiscoverySpi.*;
-
-/**
- * Tests for topology snapshots history.
- */
-public class GridTcpDiscoverySnapshotHistoryTest extends GridCommonAbstractTest {
- /** */
- public GridTcpDiscoverySnapshotHistoryTest() {
- super(false);
- }
-
- /** {@inheritDoc} */
- @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
- IgniteConfiguration cfg = super.getConfiguration(gridName);
-
- cfg.setDiscoverySpi(new TcpDiscoverySpi());
- cfg.setCacheConfiguration();
- cfg.setLocalHost("127.0.0.1");
- cfg.setRestEnabled(false);
-
- return cfg;
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testHistorySupported() throws Exception {
- try {
- final Ignite g = startGrid();
-
- DiscoverySpi spi = g.configuration().getDiscoverySpi();
-
- DiscoverySpiHistorySupport ann = U.getAnnotation(spi.getClass(), DiscoverySpiHistorySupport.class);
-
- assertNotNull("Spi does not have annotation for history support", ann);
-
- assertTrue("History support is disabled for current spi", ann.value());
- }
- finally {
- stopGrid();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testSettingNewTopologyHistorySize() throws Exception {
- try {
- final Ignite g = startGrid();
-
- TcpDiscoverySpi spi = (TcpDiscoverySpi)g.configuration().getDiscoverySpi();
-
- assertEquals(DFLT_TOP_HISTORY_SIZE, spi.getTopHistorySize());
-
- spi.setTopHistorySize(DFLT_TOP_HISTORY_SIZE + 1);
-
- assertEquals(DFLT_TOP_HISTORY_SIZE + 1, spi.getTopHistorySize());
-
- spi.setTopHistorySize(1);
-
- assertEquals(DFLT_TOP_HISTORY_SIZE + 1, spi.getTopHistorySize());
- }
- finally {
- stopGrid();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testNodeAdded() throws Exception {
- try {
- // Add grid #1
- final Ignite g1 = startGrid(1);
-
- assertTopVer(1, g1);
-
- assertEquals(1, g1.cluster().topologyVersion());
-
- // Add grid # 2
- final Ignite g2 = startGrid(2);
-
- assertTopVer(2, g1, g2);
-
- for (int i = 1; i <= 2; i++)
- assertEquals(i, g2.cluster().topology(i).size());
-
- // Add grid # 3
- final Ignite g3 = startGrid(3);
-
- assertTopVer(3, g1, g2, g3);
-
- for (int i = 1; i <= 3; i++)
- assertEquals(i, g3.cluster().topology(i).size());
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * @throws Exception If any error occurs.
- */
- public void testNodeAddedAndRemoved() throws Exception {
- try {
- // Add grid #1
- final Ignite g1 = startGrid(1);
-
- assertTopVer(1, g1);
-
- assertEquals(1, g1.cluster().topologyVersion());
-
- // Add grid #2
- final Ignite g2 = startGrid(2);
-
- assertTopVer(2, g1, g2);
-
- for (int i = 1; i <= 2; i++)
- assertEquals(i, g2.cluster().topology(i).size());
-
- // Add grid #3
- final Ignite g3 = startGrid(3);
-
- assertTopVer(3, g1, g2, g3);
-
- for (int i = 1; i <= 3; i++)
- assertEquals(i, g3.cluster().topology(i).size());
-
- // Stop grid #3
- stopGrid(g3.name());
-
- assertTopVer(4, g1, g2);
- }
- finally {
- stopAllGrids();
- }
- }
-
- /**
- * Check if specified grid instances have unexpected topology version.
- *
- * @param expTopVer Expected topology version.
- * @param ignites Grid instances for checking topology version.
- */
- private static void assertTopVer(long expTopVer, Ignite... ignites) {
- for (Ignite g : ignites)
- assertEquals("Grid has wrong topology version.", expTopVer, g.cluster().topologyVersion());
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiConfigSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiConfigSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiConfigSelfTest.java
deleted file mode 100644
index 9eba118..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiConfigSelfTest.java
+++ /dev/null
@@ -1,37 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.gridgain.testframework.junits.spi.*;
-
-/**
- *
- */
-@GridSpiTest(spi = TcpDiscoverySpi.class, group = "Discovery SPI")
-public class GridTcpDiscoverySpiConfigSelfTest extends GridSpiAbstractConfigTest<TcpDiscoverySpi> {
- /**
- * @throws Exception If failed.
- */
- public void testNegativeConfig() throws Exception {
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "ipFinder", null);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "ipFinderCleanFrequency", 0);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "localPort", 1023);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "localPortRange", 0);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "networkTimeout", 0);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "socketTimeout", 0);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "ackTimeout", 0);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "maxAckTimeout", 0);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "reconnectCount", 0);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "heartbeatFrequency", 0);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "threadPriority", -1);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "maxMissedHeartbeats", 0);
- checkNegativeSpiProperty(new TcpDiscoverySpi(), "statisticsPrintFrequency", 0);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiRandomStartStopTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiRandomStartStopTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiRandomStartStopTest.java
deleted file mode 100644
index 275c7c8..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiRandomStartStopTest.java
+++ /dev/null
@@ -1,37 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.gridgain.grid.spi.discovery.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.vm.*;
-import org.gridgain.testframework.junits.spi.*;
-
-/**
- * Random start stop test for {@link TcpDiscoverySpi}.
- */
-@GridSpiTest(spi = TcpDiscoverySpi.class, group = "Discovery SPI")
-public class GridTcpDiscoverySpiRandomStartStopTest extends
- GridAbstractDiscoveryRandomStartStopTest<TcpDiscoverySpi> {
- /** */
- private TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
-
- /** {@inheritDoc} */
- @Override protected int getMaxInterval() {
- return 10;
- }
-
- /** {@inheritDoc} */
- @Override protected void spiConfigure(TcpDiscoverySpi spi) throws Exception {
- super.spiConfigure(spi);
-
- spi.setIpFinder(ipFinder);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiSelfTest.java
deleted file mode 100644
index 3aaa8e9..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiSelfTest.java
+++ /dev/null
@@ -1,35 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.gridgain.grid.spi.discovery.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.vm.*;
-import org.gridgain.testframework.junits.spi.*;
-
-/**
- * TCP discovery spi test.
- */
-@SuppressWarnings({"JUnitTestCaseWithNoTests"})
-@GridSpiTest(spi = TcpDiscoverySpi.class, group = "Discovery SPI")
-public class GridTcpDiscoverySpiSelfTest extends GridAbstractDiscoverySelfTest<TcpDiscoverySpi> {
- /** */
- private TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
-
- /** {@inheritDoc} */
- @Override protected DiscoverySpi getSpi(int idx) {
- TcpDiscoverySpi spi = new TcpDiscoverySpi();
-
- spi.setMetricsProvider(createMetricsProvider());
- spi.setIpFinder(ipFinder);
-
- return spi;
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1ef8f69b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiStartStopSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiStartStopSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiStartStopSelfTest.java
deleted file mode 100644
index cb198de..0000000
--- a/modules/core/src/test/java/org/gridgain/grid/spi/discovery/tcp/GridTcpDiscoverySpiStartStopSelfTest.java
+++ /dev/null
@@ -1,74 +0,0 @@
-/* @java.file.header */
-
-/* _________ _____ __________________ _____
- * __ ____/___________(_)______ /__ ____/______ ____(_)_______
- * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \
- * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / /
- * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/
- */
-
-package org.gridgain.grid.spi.discovery.tcp;
-
-import org.apache.ignite.cluster.*;
-import org.gridgain.grid.kernal.managers.security.*;
-import org.gridgain.grid.security.*;
-import org.gridgain.grid.spi.*;
-import org.gridgain.grid.spi.discovery.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.*;
-import org.gridgain.grid.spi.discovery.tcp.ipfinder.vm.*;
-import org.gridgain.testframework.junits.spi.*;
-
-import java.util.*;
-
-/**
- * Grid TCP discovery SPI start stop self test.
- */
-@GridSpiTest(spi = TcpDiscoverySpi.class, group = "Discovery SPI")
-public class GridTcpDiscoverySpiStartStopSelfTest extends GridSpiStartStopAbstractTest<TcpDiscoverySpi> {
- /**
- * @return IP finder.
- */
- @GridSpiTestConfig
- public TcpDiscoveryIpFinder getIpFinder() {
- return new TcpDiscoveryVmIpFinder(true);
- }
-
- /**
- * @return Discovery data collector.
- */
- @GridSpiTestConfig
- public DiscoverySpiDataExchange getDataExchange() {
- return new DiscoverySpiDataExchange() {
- @Override public List<Object> collect(UUID nodeId) {
- return null;
- }
-
- @Override public void onExchange(List<Object> data) {
- // No-op.
- }
- };
- }
-
- /**
- * Discovery SPI authenticator.
- *
- * @return Authenticator.
- */
- @GridSpiTestConfig
- public DiscoverySpiNodeAuthenticator getAuthenticator() {
- return new DiscoverySpiNodeAuthenticator() {
- @Override public GridSecurityContext authenticateNode(ClusterNode n, GridSecurityCredentials cred) {
- GridSecuritySubjectAdapter subj = new GridSecuritySubjectAdapter(
- GridSecuritySubjectType.REMOTE_NODE, n.id());
-
- subj.permissions(new GridAllowAllPermissionSet());
-
- return new GridSecurityContext(subj);
- }
-
- @Override public boolean isGlobalNodeAuthentication() {
- return false;
- }
- };
- }
-}