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

Zero out last allocated tier in VanillaChronicleHash.allocateTierBulk()

Browse Source
This commit is contained in:
leventov
2015-10-07 16:14:28 +03:00
parent 70fb0dd2fa
commit 03a761ebbf
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/hash/impl/VanillaChronicleHash.java
+7 -4
View File
@@ -620,12 +620,15 @@ public abstract class VanillaChronicleHash<K, KI, MKI extends MetaBytesInterop<K
}
// Link newly allocated tiers into free tiers list
for (long tierIndex = firstTierIndex;
tierIndex < firstTierIndex + numberOfTiersInBulk - 1; tierIndex++) {
long lastTierIndex = firstTierIndex + numberOfTiersInBulk - 1;
for (long tierIndex = firstTierIndex; tierIndex <= lastTierIndex; tierIndex++) {
long tierOffset = tierBytesOffset(tierIndex);
zeroOutNewlyMappedTier(bytes, tierOffset);
long tierCountersAreaOffset = tierOffset + segmentHashLookupOuterSize;
TierCountersArea.nextTierIndex(bytes.address() + tierCountersAreaOffset, tierIndex + 1);
if (tierIndex < lastTierIndex) {
TierCountersArea.nextTierIndex(bytes.address() + tierCountersAreaOffset,
tierIndex + 1);
}
}
// TODO HCOLL-397 insert msync here!
@@ -676,7 +679,7 @@ public abstract class VanillaChronicleHash<K, KI, MKI extends MetaBytesInterop<K
int bulkIndex = (int) (extraTierIndex >> log2NumberOfTiersInBulk);
if (bulkIndex >= tierBulkOffsets.size())
mapTiers(bulkIndex);
TierBulkData tierBulkData = tierBulkOffsets.get((int) bulkIndex);
TierBulkData tierBulkData = tierBulkOffsets.get(bulkIndex);
long tierIndexOffsetWithinBulk = extraTierIndex & (numberOfTiersInBulk - 1);
return tierAddr(tierBulkData, tierIndexOffsetWithinBulk);
}