From c0da0f5c2f48087e5782cc7f0263ff3fb161184f Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Tue, 7 Oct 2014 18:51:51 +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 | 6 +++--- .../java/net/openhft/chronicle/map/NodeDiscoveryTest.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java b/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java index c094fa6a1..5b58e36ff 100644 --- a/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java +++ b/src/main/java/net/openhft/chronicle/map/NodeDiscovery.java @@ -822,21 +822,21 @@ class DiscoveryNodeBytesMarshallable implements BytesMarshallable { return; } - LOG.info("Received Proposal"); + // the host and port the message came from this.sourceAddressAndPort.readMarshallable(in); if (sourceAddressAndPort.equals(ourAddressAndPort)) return; + LOG.info("Received Proposal"); + this.remoteNode.readMarshallable(in); this.proposedIdentifiersWithHost.readMarshallable(in); NodeDiscoveryEventListener listener = nodeDiscoveryEventListener.get(); if (listener != null) listener.onRemoteNodeEvent(remoteNode, proposedIdentifiersWithHost); - - onChange(); } diff --git a/src/test/java/net/openhft/chronicle/map/NodeDiscoveryTest.java b/src/test/java/net/openhft/chronicle/map/NodeDiscoveryTest.java index 9239118be..e7fd74ddb 100644 --- a/src/test/java/net/openhft/chronicle/map/NodeDiscoveryTest.java +++ b/src/test/java/net/openhft/chronicle/map/NodeDiscoveryTest.java @@ -14,7 +14,7 @@ public class NodeDiscoveryTest { final ChronicleMap map = nodeDiscovery.discoverMap(); - Thread.sleep(1000000); + Thread.sleep(1000000); }