From c11a0cceac563c338045d6b963fc6f725361bf28 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Wed, 1 Oct 2014 19:20:49 +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/DiscoveryCluster.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/main/java/net/openhft/chronicle/map/DiscoveryCluster.java b/src/main/java/net/openhft/chronicle/map/DiscoveryCluster.java index 37bc7f66c..460f33585 100644 --- a/src/main/java/net/openhft/chronicle/map/DiscoveryCluster.java +++ b/src/main/java/net/openhft/chronicle/map/DiscoveryCluster.java @@ -139,11 +139,14 @@ public class DiscoveryCluster { @Override public boolean isIdentifierUnique(byte remoteIdentifier, SocketAddress remoteAddress) { final SocketAddress socketAddress = identifiers.putIfAbsent(remoteIdentifier, remoteAddress); + remoteNodes.activeIdentifierBitSet().set(remoteIdentifier); return socketAddress == null; } }; + remoteNodes.activeIdentifierBitSet().set(identifier); + final TcpReplicationConfig tcpConfig = TcpReplicationConfig .of(tcpPort, toInetSocketArray(knownHostPorts)) .heartBeatInterval(1, SECONDS).nonUniqueIdentifierListener(identifierListener);