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

Remove unspecified API use in ReplicatedChronicleMap.writeExternalEntry()

Browse Source
This commit is contained in:
leventov
2015-12-17 18:56:55 +03:00
parent 27c8148007
commit e259be092a
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
+5 -3
View File
@@ -30,7 +30,6 @@ import net.openhft.chronicle.hash.replication.TimeProvider;
import net.openhft.chronicle.map.impl.CompiledReplicatedMapIterationContext;
import net.openhft.chronicle.map.impl.CompiledReplicatedMapQueryContext;
import net.openhft.chronicle.map.replication.MapRemoteOperations;
import net.openhft.chronicle.map.replication.MapRemoteQueryContext;
import net.openhft.chronicle.values.Values;
import org.jetbrains.annotations.NotNull;
import org.slf4j.Logger;
@@ -408,22 +407,25 @@ public class ReplicatedChronicleMap<K, V, R> extends VanillaChronicleMap<K, V, R
Data key;
Data value;
long valueSize;
boolean isDeleted;
if (entry instanceof MapEntry) {
isDeleted = false;
MapEntry mapEntry = (MapEntry) entry;
key = mapEntry.key();
value = mapEntry.value();
valueSize = value.size();
} else {
isDeleted = true;
MapAbsentEntry mapAbsentEntry = (MapAbsentEntry) entry;
key = mapAbsentEntry.absentKey();
value = ((CompiledReplicatedMapIterationContext) mapAbsentEntry.context()).dummyValue();
value = null;
valueSize = Math.max(0, valueSizeMarshaller.minStorableSize());
}
destination.writeLong(bootstrapTime);
keySizeMarshaller.writeSize(destination, key.size());
valueSizeMarshaller.writeSize(destination, value.size());
valueSizeMarshaller.writeSize(destination, valueSize);
destination.writeStopBit(entry.originTimestamp());
if (entry.originIdentifier() == 0)