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

Bugfix

Browse Source
This commit is contained in:
Andrea Cavalli 2021-04-13 03:07:44 +02:00
parent 41ba665a54
commit c1a7e782f6
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionaryHashed.java
View File

@ -57,10 +57,13 @@ public class DatabaseMapDictionaryHashed<T, U, TH> implements DatabaseStageMap<T
@Override @Override
public @NotNull Entry<T, U> deserialize(byte @NotNull [] serialized) { public @NotNull Entry<T, U> deserialize(byte @NotNull [] serialized) {
int keySuffixLength = Ints.fromBytes(serialized[0], serialized[1], serialized[2], serialized[3]); int keySuffixLength = Ints.fromBytes(serialized[0], serialized[1], serialized[2], serialized[3]);
T keySuffix = keySuffixSerializer.deserialize(Arrays.copyOfRange(serialized, 4, keySuffixLength)); T keySuffix = keySuffixSerializer.deserialize(Arrays.copyOfRange(serialized,
Integer.BYTES,
Integer.BYTES + keySuffixLength
));
U value = valueSerializer.deserialize(Arrays.copyOfRange(serialized, U value = valueSerializer.deserialize(Arrays.copyOfRange(serialized,
4 + keySuffixLength, Integer.BYTES + keySuffixLength,
serialized.length - (4 + keySuffixLength) serialized.length
)); ));
return Map.entry(keySuffix, value); return Map.entry(keySuffix, value);
} }
@ -69,11 +72,11 @@ public class DatabaseMapDictionaryHashed<T, U, TH> implements DatabaseStageMap<T
public byte @NotNull [] serialize(@NotNull Entry<T, U> deserialized) { public byte @NotNull [] serialize(@NotNull Entry<T, U> deserialized) {
byte[] keySuffix = keySuffixSerializer.serialize(deserialized.getKey()); byte[] keySuffix = keySuffixSerializer.serialize(deserialized.getKey());
byte[] value = valueSerializer.serialize(deserialized.getValue()); byte[] value = valueSerializer.serialize(deserialized.getValue());
byte[] result = new byte[4 + keySuffix.length + value.length]; byte[] result = new byte[Integer.BYTES + keySuffix.length + value.length];
byte[] keySuffixLen = Ints.toByteArray(keySuffix.length); byte[] keySuffixLen = Ints.toByteArray(keySuffix.length);
System.arraycopy(keySuffixLen, 0, result, 0, 4); System.arraycopy(keySuffixLen, 0, result, 0, Integer.BYTES);
System.arraycopy(keySuffix, 0, result, 4, keySuffix.length); System.arraycopy(keySuffix, 0, result, Integer.BYTES, keySuffix.length);
System.arraycopy(value, 0, result, 4 + keySuffix.length, value.length); System.arraycopy(value, 0, result, Integer.BYTES + keySuffix.length, value.length);
return result; return result;
} }
} }