From 25debcb987f13412d7c7effc75c80abbc4ee1594 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Mon, 6 Oct 2014 19:00:02 +0100 Subject: [PATCH] HCOLL-134 ( release draft cut of the code so that I can test it across my network ) --- src/main/java/net/openhft/chronicle/map/NodeDiscovery.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java b/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java index b3824fc1a..5df0388f4 100644 --- a/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java +++ b/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java @@ -39,7 +39,6 @@ public class NodeDiscovery { final UdpReplicationConfig udpConfig = UdpReplicationConfig .simple(Inet4Address.getByName("255.255.255.255"), udpBroadcastPort); - final KnownNodes knownNodes = new KnownNodes(); final Set knownHostPorts = new ConcurrentSkipListSet(); final DirectBitSet knownAndProposedIdentifiers = new ATSDirectBitSet(new ByteBufferBytes(ByteBuffer.allocate @@ -97,7 +96,7 @@ public class NodeDiscovery { externalizable.sendBootStrap(ourHostPort); // once the count down latch is trigger we know we go something back from one of the nodes - if (countDownLatch.get().await(50, TimeUnit.MILLISECONDS)) + if (countDownLatch.get().await(500, TimeUnit.MILLISECONDS)) break; } @@ -131,7 +130,7 @@ public class NodeDiscovery { externalizable.sendBootStrap(proposedNodes); // once the count down latch is trigger we know we go something back from one of the nodes - if (countDownLatch.get().await(50, TimeUnit.MILLISECONDS)) { + if (countDownLatch.get().await(500, TimeUnit.MILLISECONDS)) { if (useAnotherIdentifier.get()) { // given that another node host proposed the same identifier, we will choose a different one. LOG.info("Another node is using identifier=" + identifier + ", " +