conn
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/79ca4aab Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/79ca4aab Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/79ca4aab Branch: refs/heads/ignite-comm-balance Commit: 79ca4aabab4e9d5f69271fbcd6885299c37cb9bf Parents: 04a4d45 Author: sboikov <sboi...@gridgain.com> Authored: Thu Sep 22 11:51:38 2016 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Sep 22 11:51:38 2016 +0300 ---------------------------------------------------------------------- ...GridTcpCommunicationSpiRecoverySelfTest.java | 21 +++++++++++++++++--- 1 file changed, 18 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/79ca4aab/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoverySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoverySelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoverySelfTest.java index fbbc5de..3d33fff 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoverySelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoverySelfTest.java @@ -327,7 +327,12 @@ public class GridTcpCommunicationSpiRecoverySelfTest<T extends CommunicationSpi> assertTrue("Failed to wait for session close", ses0.closeTime() != 0); - ses1.resumeReads().get(); + try { + ses1.resumeReads().get(); + } + catch (IgniteCheckedException ignore) { + // Can fail is ses1 was closed. + } for (int j = 0; j < 100; j++) { spi0.sendMessage(node1, new GridTestMessage(node0.id(), msgId.incrementAndGet(), 0)); @@ -437,7 +442,12 @@ public class GridTcpCommunicationSpiRecoverySelfTest<T extends CommunicationSpi> assertTrue("Failed to wait for session close", ses0.closeTime() != 0); - ses1.resumeReads().get(); + try { + ses1.resumeReads().get(); + } + catch (IgniteCheckedException ignore) { + // Can fail is ses1 was closed. + } // Wait when session is closed, then try to open new connection from node1. GridTestUtils.waitForCondition(new GridAbsPredicate() { @@ -554,7 +564,12 @@ public class GridTcpCommunicationSpiRecoverySelfTest<T extends CommunicationSpi> assertTrue("Failed to wait for session close", ses0.closeTime() != 0); - ses1.resumeReads().get(); + try { + ses1.resumeReads().get(); + } + catch (IgniteCheckedException ignore) { + // Can fail is ses1 was closed. + } sndFut.get();
