Repository: ignite Updated Branches: refs/heads/ignite-1537 db93b8a10 -> 679cda5d2
ignite-1.5 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/679cda5d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/679cda5d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/679cda5d Branch: refs/heads/ignite-1537 Commit: 679cda5d2d97c69653e2fc97c3f93477db36acf7 Parents: db93b8a Author: sboikov <[email protected]> Authored: Thu Dec 24 11:53:21 2015 +0300 Committer: sboikov <[email protected]> Committed: Thu Dec 24 11:53:21 2015 +0300 ---------------------------------------------------------------------- .../TcpDiscoveryMulticastIpFinderSelfTest.java | 21 ++++++++++++++++---- 1 file changed, 17 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/679cda5d/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinderSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinderSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinderSelfTest.java index b39be56..90fdb0a 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinderSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinderSelfTest.java @@ -101,11 +101,11 @@ public class TcpDiscoveryMulticastIpFinderSelfTest assertEquals(1, addrs1.size()); assertEquals(2, addrs2.size()); - assertEquals(3, addrs3.size()); + assertTrue("Unexpected number of addresses: " + addrs3, addrs3.size() == 2 || addrs3.size() == 3); - assertEquals(3, ipFinder1.getRegisteredAddresses().size()); - assertEquals(3, ipFinder2.getRegisteredAddresses().size()); - assertEquals(3, ipFinder3.getRegisteredAddresses().size()); + checkRequestAddresses(ipFinder1, 3); + checkRequestAddresses(ipFinder2, 3); + checkRequestAddresses(ipFinder3, 3); } finally { if (ipFinder1 != null) @@ -118,4 +118,17 @@ public class TcpDiscoveryMulticastIpFinderSelfTest ipFinder3.close(); } } + + /** + * @param ipFinder IP finder. + * @param exp Expected number of addresses. + */ + private void checkRequestAddresses(TcpDiscoveryMulticastIpFinder ipFinder, int exp) { + for (int i = 0; i < 10; i++) { + if (ipFinder.getRegisteredAddresses().size() == exp) + return; + } + + assertEquals(exp, ipFinder.getRegisteredAddresses().size()); + } } \ No newline at end of file
