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

fixed https://github.com/OpenHFT/Chronicle-Map/issues/212

Browse Source
This commit is contained in:
Rob Austin
2020-03-25 15:08:04 +00:00
parent f76cb3bfcf
commit 2b6f416bb8
3 changed files with 57 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java
+5 -1
View File
@@ -204,7 +204,7 @@ public final class ChronicleMapBuilder<K, V> implements
private int maxChunksPerEntry = -1;
private int alignment = UNDEFINED_ALIGNMENT_CONFIG;
private long entries = -1L;
double maxBloatFactor = 1.0;
private double maxBloatFactor = 1.0;
private boolean allowSegmentTiering = true;
private double nonTieredSegmentsPercentile = 0.99999;
private boolean aligned64BitMemoryOperationsAtomic = OS.is64Bit();
@@ -1338,6 +1338,10 @@ public final class ChronicleMapBuilder<K, V> implements
return this;
}
public double maxBloatFactor() {
return maxBloatFactor;
}
@Override
public ChronicleMapBuilder<K, V> allowSegmentTiering(boolean allowSegmentTiering) {
this.allowSegmentTiering = allowSegmentTiering;
src/main/java/net/openhft/chronicle/map/VanillaChronicleMap.java
+4 -3
View File
@@ -58,7 +58,7 @@ public class VanillaChronicleMap<K, V, R>
ExternalMapQueryContext<K, V, ?>>
implements AbstractChronicleMap<K, V> {
private final double maxBloatFactor;
private double maxBloatFactor;
public SizeMarshaller valueSizeMarshaller;
public SizedReader<V> valueReader;
@@ -102,7 +102,7 @@ public class VanillaChronicleMap<K, V, R>
valueSizeMarshaller = valueBuilder.sizeMarshaller();
valueReader = valueBuilder.reader();
valueDataAccess = valueBuilder.dataAccess();
maxBloatFactor = builder.maxBloatFactor;
maxBloatFactor = builder.maxBloatFactor();
constantlySizedEntry = builder.constantlySizedEntries();
@@ -131,6 +131,7 @@ public class VanillaChronicleMap<K, V, R>
alignment = wireIn.read(() -> "alignment").int32();
worstAlignment = wireIn.read(() -> "worstAlignment").int32();
maxBloatFactor = wireIn.read(() -> "maxBloatFactor").float64();
}
@Override
@@ -146,13 +147,13 @@ public class VanillaChronicleMap<K, V, R>
wireOut.write(() -> "alignment").int32(alignment);
wireOut.write(() -> "worstAlignment").int32(worstAlignment);
wireOut.write(() -> "maxBloatFactor").float64(maxBloatFactor);
}
void initTransientsFromBuilder(ChronicleMapBuilder<K, V> builder) {
name = builder.name();
putReturnsNull = builder.putReturnsNull();
removeReturnsNull = builder.removeReturnsNull();
entryOperations = (MapEntryOperations<K, V, R>) builder.entryOperations;
methods = (MapMethods<K, V, R>) builder.methods;
defaultEntryOperationsAndMethods = entryOperations == DefaultSpi.mapEntryOperations() &&