andreacavalli/CavalliumDBEngine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

More customizable allocators

Browse Source
This commit is contained in:
Andrea Cavalli 2021-05-05 00:07:18 +02:00
parent 5b89be8ee0
commit 63beb1931e
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java
View File

@ -105,6 +105,7 @@ public class LLLocalDictionary implements LLDictionary {
* Default: true * Default: true
*/ */
private static final boolean USE_DIRECT_BUFFER_BOUNDS = true; private static final boolean USE_DIRECT_BUFFER_BOUNDS = true;
private static final int INITIAL_DIRECT_READ_BYTE_BUF_SIZE_BYTES = 4096;
static { static {
boolean assertionsEnabled = false; boolean assertionsEnabled = false;
@ -235,7 +236,7 @@ public class LLLocalDictionary implements LLDictionary {
ByteBuffer keyNioBuffer = LLUtils.toDirect(key); ByteBuffer keyNioBuffer = LLUtils.toDirect(key);
assert keyNioBuffer.isDirect(); assert keyNioBuffer.isDirect();
// Create a direct result buffer because RocksDB works only with direct buffers // Create a direct result buffer because RocksDB works only with direct buffers
ByteBuf resultBuf = alloc.directBuffer(); ByteBuf resultBuf = alloc.directBuffer(LLLocalDictionary.INITIAL_DIRECT_READ_BYTE_BUF_SIZE_BYTES);
try { try {
int valueSize; int valueSize;
int assertionReadData = -1; int assertionReadData = -1;

4
src/main/java/it/cavallium/dbengine/database/serialization/SerializerFixedBinaryLength.java
View File

@ -110,7 +110,7 @@ public interface SerializerFixedBinaryLength<A, B> extends Serializer<A, B> {
@Override @Override
public @NotNull ByteBuf serialize(@NotNull Integer deserialized) { public @NotNull ByteBuf serialize(@NotNull Integer deserialized) {
ByteBuf buf = allocator.directBuffer(Integer.BYTES); ByteBuf buf = allocator.buffer(Integer.BYTES);
return buf.writeInt(deserialized); return buf.writeInt(deserialized);
} }
@ -139,7 +139,7 @@ public interface SerializerFixedBinaryLength<A, B> extends Serializer<A, B> {
@Override @Override
public @NotNull ByteBuf serialize(@NotNull Long deserialized) { public @NotNull ByteBuf serialize(@NotNull Long deserialized) {
ByteBuf buf = allocator.directBuffer(Long.BYTES); ByteBuf buf = allocator.buffer(Long.BYTES);
return buf.writeLong(deserialized); return buf.writeLong(deserialized);
} }