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/07/22 12:09:14 UTC
incubator-ignite git commit: ignite-752: fixed SPI test
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-752 023c4964c -> cdcd33beb
ignite-752: fixed SPI 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/cdcd33be
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/cdcd33be
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/cdcd33be
Branch: refs/heads/ignite-752
Commit: cdcd33beb77b0a0f423f15a9abdb1423bb5b4c42
Parents: 023c496
Author: Denis Magda <dm...@gridgain.com>
Authored: Wed Jul 22 13:09:07 2015 +0300
Committer: Denis Magda <dm...@gridgain.com>
Committed: Wed Jul 22 13:09:07 2015 +0300
----------------------------------------------------------------------
.../tcp/GridTcpCommunicationSpiRecoveryAckSelfTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cdcd33be/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryAckSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryAckSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryAckSelfTest.java
index 1a4ba22..ccb9717 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryAckSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationSpiRecoveryAckSelfTest.java
@@ -166,7 +166,8 @@ public class GridTcpCommunicationSpiRecoveryAckSelfTest<T extends CommunicationS
@Override public boolean apply() {
return recoveryDesc.messagesFutures().isEmpty();
}
- }, 10_000);
+ }, spi.failureDetectionThresholdEnabled() ? spi.failureDetectionThreshold() + 5000 :
+ 10_000);
assertEquals("Unexpected messages: " + recoveryDesc.messagesFutures(), 0,
recoveryDesc.messagesFutures().size());