TcpDiscoverySelfTest.testDiscoveryEventsDiscard fix
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/881d5a88 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/881d5a88 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/881d5a88 Branch: refs/heads/sql-store Commit: 881d5a885fa169196dc4e91fa2da60f00a80474e Parents: 5500a18 Author: Anton Vinogradov <[email protected]> Authored: Mon Feb 1 13:38:22 2016 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Mon Feb 1 13:38:22 2016 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/881d5a88/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java index 4f329e1..2d5b2c5 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java @@ -72,6 +72,7 @@ import org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMultic import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage; import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryCustomEventMessage; +import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryHeartbeatMessage; import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeAddFinishedMessage; import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeAddedMessage; import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeFailedMessage; @@ -1857,7 +1858,7 @@ public class TcpDiscoverySelfTest extends GridCommonAbstractTest { long timeout) throws IOException, IgniteCheckedException { boolean add = msgIds.add(msg.id()); - if (checkDuplicates && !add) { + if (checkDuplicates && !add && !(msg instanceof TcpDiscoveryHeartbeatMessage)) { log.error("Send duplicated message: " + msg); failed = true;
