From cad4d43786c6f6d3635fedee7f0035ca77a36391 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Fri, 26 Sep 2014 17:30:29 +0100 Subject: [PATCH] HCOLL-134 ( release draft cut of the code so that I can test it across my network ) --- ...roadcaster.java => NodeDiscoveryBroadcaster.java} | 10 +++++----- .../map/NodeDiscoveryHostPortBroadcasterTest.java | 12 ++++++------ 2 files changed, 11 insertions(+), 11 deletions(-) rename src/main/java/net/openhft/chronicle/map/{NodeDiscoveryHostPortBroadcaster.java => NodeDiscoveryBroadcaster.java} (97%) diff --git a/src/main/java/net/openhft/chronicle/map/NodeDiscoveryHostPortBroadcaster.java b/src/main/java/net/openhft/chronicle/map/NodeDiscoveryBroadcaster.java similarity index 97% rename from src/main/java/net/openhft/chronicle/map/NodeDiscoveryHostPortBroadcaster.java rename to src/main/java/net/openhft/chronicle/map/NodeDiscoveryBroadcaster.java index 2cdfcf79d..4f31215b3 100644 --- a/src/main/java/net/openhft/chronicle/map/NodeDiscoveryHostPortBroadcaster.java +++ b/src/main/java/net/openhft/chronicle/map/NodeDiscoveryBroadcaster.java @@ -16,8 +16,8 @@ import java.util.Set; import java.util.concurrent.ConcurrentSkipListSet; import java.util.concurrent.atomic.AtomicBoolean; -import static net.openhft.chronicle.map.NodeDiscoveryHostPortBroadcaster.BOOTSTRAP_BYTES; -import static net.openhft.chronicle.map.NodeDiscoveryHostPortBroadcaster.LOG; +import static net.openhft.chronicle.map.NodeDiscoveryBroadcaster.BOOTSTRAP_BYTES; +import static net.openhft.chronicle.map.NodeDiscoveryBroadcaster.LOG; /** * Broad cast the nodes host ports and identifiers over UDP, to make it easy to join a grid of remote nodes @@ -25,8 +25,8 @@ import static net.openhft.chronicle.map.NodeDiscoveryHostPortBroadcaster.LOG; * * @author Rob Austin. */ -public class NodeDiscoveryHostPortBroadcaster extends UdpChannelReplicator { - public static final Logger LOG = LoggerFactory.getLogger(NodeDiscoveryHostPortBroadcaster.class.getName +public class NodeDiscoveryBroadcaster extends UdpChannelReplicator { + public static final Logger LOG = LoggerFactory.getLogger(NodeDiscoveryBroadcaster.class.getName ()); private static final byte UNUSED = (byte) -1; @@ -46,7 +46,7 @@ public class NodeDiscoveryHostPortBroadcaster extends UdpChannelReplicator { * @param externalizable * @throws java.io.IOException */ - NodeDiscoveryHostPortBroadcaster( + NodeDiscoveryBroadcaster( @NotNull final UdpReplicationConfig replicationConfig, final int serializedEntrySize, final BytesExternalizable externalizable) diff --git a/src/test/java/net/openhft/chronicle/map/NodeDiscoveryHostPortBroadcasterTest.java b/src/test/java/net/openhft/chronicle/map/NodeDiscoveryHostPortBroadcasterTest.java index 847b9d6e3..4b02baf3a 100644 --- a/src/test/java/net/openhft/chronicle/map/NodeDiscoveryHostPortBroadcasterTest.java +++ b/src/test/java/net/openhft/chronicle/map/NodeDiscoveryHostPortBroadcasterTest.java @@ -25,10 +25,10 @@ public class NodeDiscoveryHostPortBroadcasterTest extends TestCase { BytesExternalizableImpl externalizable = new BytesExternalizableImpl(remoteNodes); - final NodeDiscoveryHostPortBroadcaster nodeDiscoveryHostPortBroadcaster - = new NodeDiscoveryHostPortBroadcaster(udpConfig, 1024, externalizable); + final NodeDiscoveryBroadcaster nodeDiscoveryBroadcaster + = new NodeDiscoveryBroadcaster(udpConfig, 1024, externalizable); - externalizable.setModificationNotifier(nodeDiscoveryHostPortBroadcaster); + externalizable.setModificationNotifier(nodeDiscoveryBroadcaster); Thread.sleep(1000); @@ -71,10 +71,10 @@ public class NodeDiscoveryHostPortBroadcasterTest extends TestCase { BytesExternalizableImpl externalizable = new BytesExternalizableImpl(remoteNodes); - final NodeDiscoveryHostPortBroadcaster nodeDiscoveryHostPortBroadcaster - = new NodeDiscoveryHostPortBroadcaster(udpConfig, 1024, externalizable); + final NodeDiscoveryBroadcaster nodeDiscoveryBroadcaster + = new NodeDiscoveryBroadcaster(udpConfig, 1024, externalizable); - externalizable.setModificationNotifier(nodeDiscoveryHostPortBroadcaster); + externalizable.setModificationNotifier(nodeDiscoveryBroadcaster); Thread.sleep(10000000);