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

CE-23 minor code cleanup

Browse Source
This commit is contained in:
Rob Austin
2015-04-16 18:13:12 +01:00
parent 3cd55bf3ed
commit af1b96ab58
1 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/MapWireHandler.java
+2 -9
View File
@@ -230,12 +230,9 @@ public class MapWireHandler<K, V> implements WireHandler, Consumer<WireHandlers>
}
final StringBuilder cspText = new StringBuilder();
public long tid;
private final AtomicLong cid = new AtomicLong();
/**
* create a new cid if one does not already exist for this csp
*
@@ -337,7 +334,6 @@ public class MapWireHandler<K, V> implements WireHandler, Consumer<WireHandlers>
write(b -> outWire.write(reply).type("set-proxy").writeValue()
.marshallable(w -> {
CharSequence root = cspText.subSequence(0, cspText
.length() - "#map".length());
@@ -413,14 +409,11 @@ public class MapWireHandler<K, V> implements WireHandler, Consumer<WireHandlers>
final Map data = new HashMap();
writeVoid(b -> {
while (valueIn.hasNext()) {
valueIn.sequence(v -> valueIn.marshallable(wire -> data.put(
wire.read(getAndPut.params()[0]).bytes(),
wire.read(getAndPut.params()[1]).bytes())));
wire.read(put.params()[0]).bytes(),
wire.read(put.params()[1]).bytes())));
}
b.delegate.putAll(data);
});