From 4d9fe081d0f56285a531e15887fd694405dc0634 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Wed, 29 Oct 2014 19:14:30 +0000 Subject: [PATCH] updated dependencies for release - and improved stateless client --- pom.xml | 22 +++++++++++++++---- .../chronicle/hash/ChronicleHashBuilder.java | 2 +- .../chronicle/map/StatelessChronicleMap.java | 11 +++++----- 3 files changed, 24 insertions(+), 11 deletions(-) diff --git a/pom.xml b/pom.xml index 252b46436..8bed293a8 100755 --- a/pom.xml +++ b/pom.xml @@ -17,13 +17,15 @@ ~ limitations under the License. --> - + net.openhft java-parent-pom 1.1.2 - + 4.0.0 @@ -46,7 +48,7 @@ net.openhft lang - 6.4.11-SNAPSHOT + 6.4.11 @@ -61,12 +63,18 @@ 2.2.0 + + + net.openhft + compiler + + net.openhft lang @@ -77,6 +85,11 @@ slf4j-api + + com.intellij + annotations + + @@ -118,7 +131,8 @@ org.apache.maven.plugins maven-scm-publish-plugin - ${project.build.directory}/scmpublish/javadoc + ${project.build.directory}/scmpublish/javadoc + Publishing javadoc for ${project.artifactId}:${project.version} ${project.reporting.outputDirectory} diff --git a/src/main/java/net/openhft/chronicle/hash/ChronicleHashBuilder.java b/src/main/java/net/openhft/chronicle/hash/ChronicleHashBuilder.java index 61b4481f2..ab5624b35 100644 --- a/src/main/java/net/openhft/chronicle/hash/ChronicleHashBuilder.java +++ b/src/main/java/net/openhft/chronicle/hash/ChronicleHashBuilder.java @@ -399,7 +399,7 @@ public interface ChronicleHashBuilder implements ChronicleMap, Closeable { // get the data back from the server Bytes in = blockingFetch0(sizeLocation, transactionId, startTime); final ThreadLocalCopies local = keyValueSerializer.threadLocalCopies(); - final Set> result = new HashSet>(); + final Map result = new HashMap(); for (; ; ) { @@ -594,10 +594,9 @@ class StatelessChronicleMap implements ChronicleMap, Closeable { final long size = in.readInt(); for (int i = 0; i < size; i++) { - - K k = keyValueSerializer.readKey(in, local); - V v = keyValueSerializer.readValue(in, local); - result.add(new Entry(k, v)); + final K k = keyValueSerializer.readKey(in, local); + final V v = keyValueSerializer.readValue(in, local); + result.put(k, v); } if (!hasMoreEntries) @@ -609,7 +608,7 @@ class StatelessChronicleMap implements ChronicleMap, Closeable { } - return result; + return result.entrySet(); } private void compact(Bytes in) {