You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by se...@apache.org on 2015/05/14 17:22:02 UTC
[38/42] incubator-ignite git commit: # IGNITE-709 Added
testClientAndRouterFail() test
# IGNITE-709 Added testClientAndRouterFail() 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/4d5b8998
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4d5b8998
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4d5b8998
Branch: refs/heads/ignite-836_2
Commit: 4d5b8998cba39b61afd5d2fd7684bc78d6bc3faa
Parents: 85a49ec
Author: sevdokimov <se...@gridgain.com>
Authored: Thu May 14 16:30:18 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Thu May 14 16:30:18 2015 +0300
----------------------------------------------------------------------
.../tcp/TcpClientDiscoverySpiSelfTest.java | 33 ++++++++++++++++++++
1 file changed, 33 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4d5b8998/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 119fc53..6544369 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
@@ -597,6 +597,39 @@ public class TcpClientDiscoverySpiSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ public void testClientAndRouterFail() throws Exception {
+ startServerNodes(2);
+ startClientNodes(2);
+
+ checkNodes(2, 2);
+
+ srvFailedLatch = new CountDownLatch(2);
+ clientFailedLatch = new CountDownLatch(2);
+
+ attachListeners(1, 1);
+
+ ((TcpDiscoverySpi)G.ignite("server-1").configuration().getDiscoverySpi()).addSendMessageListener(new IgniteInClosure<TcpDiscoveryAbstractMessage>() {
+ @Override public void apply(TcpDiscoveryAbstractMessage msg) {
+ try {
+ Thread.sleep(1000000);
+ }
+ catch (InterruptedException ignored) {
+ Thread.interrupted();
+ }
+ }
+ });
+ failClient(1);
+ failServer(1);
+
+ await(srvFailedLatch);
+ await(clientFailedLatch);
+
+ checkNodes(1, 1);
+ }
+
+ /**
+ * @throws Exception If failed.
+ */
public void testMetrics() throws Exception {
startServerNodes(3);
startClientNodes(3);