Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

updated dependencies for release - and improved stateless client

Browse Source
This commit is contained in:
Rob Austin
2014-10-29 19:14:30 +00:00
parent 44b8683115
commit 4d9fe081d0
3 changed files with 24 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/hash/ChronicleHashBuilder.java
+1 -1
View File
@@ -399,7 +399,7 @@ public interface ChronicleHashBuilder<K, C extends ChronicleHash,
* consider to be a ClientProxy to {@link ChronicleMap} or {@link ChronicleSet} running on
* another host
*
* @param statelessBuilder Stateless Client Config
* @param statelessBuilder Stateless Client Config, {@code null} demotes no statelessBuilder
* @return this builder back
*/
B stateless(StatelessBuilder statelessBuilder);
src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java
+5 -6
View File
@@ -584,7 +584,7 @@ class StatelessChronicleMap<K, V> implements ChronicleMap<K, V>, Closeable {
// get the data back from the server
Bytes in = blockingFetch0(sizeLocation, transactionId, startTime);
final ThreadLocalCopies local = keyValueSerializer.threadLocalCopies();
final Set<Map.Entry<K, V>> result = new HashSet<Map.Entry<K, V>>();
final Map<K, V> result = new HashMap<K, V>();
for (; ; ) {
@@ -594,10 +594,9 @@ class StatelessChronicleMap<K, V> implements ChronicleMap<K, V>, 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<K, V> implements ChronicleMap<K, V>, Closeable {
}
return result;
return result.entrySet();
}
private void compact(Bytes in) {