diff --git a/pom.xml b/pom.xml index e503c710c..27d2dfc31 100644 --- a/pom.xml +++ b/pom.xml @@ -46,7 +46,7 @@ net.openhft lang - 6.4.13 + 6.4.14-SNAPSHOT diff --git a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java index 6d82740d9..537eb4b59 100644 --- a/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java @@ -820,7 +820,7 @@ final class ReplicatedChronicleMap, /** * called from a remote node when it wishes to propagate a remove event */ - private void remotePut(@NotNull final Bytes inBytes, long hash2, + void remotePut(@NotNull final Bytes inBytes, long hash2, final byte identifier, final long timestamp, long valuePos, long valueLimit) { diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java index 76cc3de9a..6f912692b 100644 --- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java +++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java @@ -1096,7 +1096,7 @@ final class TcpReplicator extends AbstractChannelReplicator implements Closeable * @param attached * @throws InterruptedException */ - private void entriesFromBuffer(Attached attached) throws InterruptedException, IOException { + void entriesFromBuffer(Attached attached) throws InterruptedException, IOException { for (; ; ) { out.limit(in.position()); diff --git a/src/test/java/net/openhft/chronicle/map/example/StringsMapMain.java b/src/test/java/net/openhft/chronicle/map/example/StringsMapMain.java index 46034b158..b4729d9a9 100644 --- a/src/test/java/net/openhft/chronicle/map/example/StringsMapMain.java +++ b/src/test/java/net/openhft/chronicle/map/example/StringsMapMain.java @@ -81,12 +81,17 @@ public class StringsMapMain { long t1 = System.nanoTime(); map.put(key, value); long t2 = System.nanoTime(); - map.getUsing(key, value2); + if (stateless) { + value.setLength(0); + value.append(map.get(key)); + } else { + map.getUsing(key, value); + } long t3 = System.nanoTime(); puts += t2 - t1; gets += t3 - t2; - if (t2 - t1 > lastAveragePut * 100 || t3 - t2 > lastAverageGet * 100) - System.out.printf("Took put/get took %.1f/%.1f us%n", (t2 - t1) / 1e3, (t3 - t2) / 1e3); +// if (t2 - t1 > lastAveragePut * 100 || t3 - t2 > lastAverageGet * 100) +// System.out.printf("Took put/get took %.1f/%.1f us%n", (t2 - t1) / 1e3, (t3 - t2) / 1e3); } lastAveragePut = puts / entries; lastAverageGet = gets / entries;