diff --git a/src/main/java/net/openhft/chronicle/hash/impl/CompactOffHeapLinearHashTable.java b/src/main/java/net/openhft/chronicle/hash/impl/CompactOffHeapLinearHashTable.java index 7d8339699..267304918 100644 --- a/src/main/java/net/openhft/chronicle/hash/impl/CompactOffHeapLinearHashTable.java +++ b/src/main/java/net/openhft/chronicle/hash/impl/CompactOffHeapLinearHashTable.java @@ -136,12 +136,6 @@ public abstract class CompactOffHeapLinearHashTable { public abstract long readEntry(long addr, long pos); public abstract void writeEntryVolatile(long addr, long pos, long key, long value); - - public void putValueVolatile(long addr, long pos, long value) { - checkValueForPut(value); - long currentEntry = readEntry(addr, pos); - writeEntryVolatile(addr, pos, key(currentEntry), value); - } public abstract void writeEntry(long addr, long pos, long newEntry); @@ -176,17 +170,4 @@ public abstract class CompactOffHeapLinearHashTable { clearEntry(addr, posToRemove); return posToRemove; } - - public void insert(long addr, long key, long value) { - long startPos = hlPos(key); - long pos = startPos; - do { - if (empty(readEntry(addr, pos))) { - writeEntry(addr, pos, entry(key, value)); - return; - } - pos = step(pos); - } while (pos != startPos); - throw new AssertionError("HashLookup overflow should never occur"); - } } diff --git a/src/main/java/net/openhft/chronicle/hash/impl/stage/entry/HashLookupPos.java b/src/main/java/net/openhft/chronicle/hash/impl/stage/entry/HashLookupPos.java index 427c2cc3a..2b1c868ab 100644 --- a/src/main/java/net/openhft/chronicle/hash/impl/stage/entry/HashLookupPos.java +++ b/src/main/java/net/openhft/chronicle/hash/impl/stage/entry/HashLookupPos.java @@ -16,8 +16,6 @@ package net.openhft.chronicle.hash.impl.stage.entry; -import net.openhft.chronicle.hash.impl.CompactOffHeapLinearHashTable; -import net.openhft.chronicle.hash.impl.VanillaChronicleHashHolder; import net.openhft.sg.Stage; import net.openhft.sg.StageRef; import net.openhft.sg.Staged; @@ -26,6 +24,7 @@ import net.openhft.sg.Staged; public abstract class HashLookupPos { @StageRef HashLookupSearch hls; + @StageRef SegmentStages s; public long hashLookupPos = -1; @@ -52,13 +51,4 @@ public abstract class HashLookupPos { } public abstract void closeHashLookupPos(); - - @StageRef VanillaChronicleHashHolder hh; - @StageRef SegmentStages s; - - public void putValueVolatile(long newValue) { - CompactOffHeapLinearHashTable hashLookup = hh.h().hashLookup; - hashLookup.checkValueForPut(newValue); - hashLookup.putValueVolatile(s.tierBaseAddr, hashLookupPos, newValue); - } }