Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Added ResourceConfiguration as parameter in NodeKind #672

Closed
wants to merge 2 commits into from
Closed

Added ResourceConfiguration as parameter in NodeKind #672

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
b49ae23
Added ResourceConfiguration as parameter in NodeKind
Oct 17, 2023
45a5449
Added ResourceConfiguration as parameter in NodeKind
Oct 25, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
85 changes: 44 additions & 41 deletions bundles/sirix-core/src/main/java/io/sirix/page/PageKind.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,36 +28,39 @@

package io.sirix.page;

import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.UncheckedIOException;
import java.time.Instant;
import java.util.BitSet;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Optional;
import java.util.UUID;

import org.checkerframework.checker.nullness.qual.NonNull;


import io.sirix.BinaryEncodingVersion;
import io.sirix.access.ResourceConfiguration;
import io.sirix.access.User;
import io.sirix.node.Utils;
import io.sirix.page.delegates.BitmapReferencesPage;
import io.sirix.api.PageReadOnlyTrx;
import io.sirix.index.IndexType;
import io.sirix.node.interfaces.DeweyIdSerializer;
import io.sirix.node.interfaces.RecordSerializer;
import io.sirix.page.delegates.BitmapReferencesPage;
import io.sirix.page.delegates.FullReferencesPage;
import io.sirix.page.interfaces.Page;
import io.sirix.settings.Constants;
import it.unimi.dsi.fastutil.ints.Int2IntMap;
import it.unimi.dsi.fastutil.ints.Int2IntOpenHashMap;
import it.unimi.dsi.fastutil.ints.Int2LongMap;
import it.unimi.dsi.fastutil.ints.Int2LongOpenHashMap;
import net.openhft.chronicle.bytes.Bytes;
import net.openhft.chronicle.bytes.BytesIn;
import net.openhft.chronicle.bytes.BytesOut;
import org.checkerframework.checker.nullness.qual.NonNull;
import io.sirix.BinaryEncodingVersion;
import io.sirix.access.ResourceConfiguration;
import io.sirix.api.PageReadOnlyTrx;
import io.sirix.index.IndexType;
import io.sirix.page.delegates.FullReferencesPage;
import io.sirix.page.delegates.ReferencesPage4;
import io.sirix.page.interfaces.Page;
import io.sirix.settings.Constants;

import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.UncheckedIOException;
import java.nio.ByteBuffer;
import java.time.Instant;
import java.util.*;

/**
* All Page types.
*/
Expand All @@ -69,7 +72,7 @@ public enum PageKind {
KEYVALUELEAFPAGE((byte) 1, KeyValueLeafPage.class) {
@Override
@NonNull
public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?> source,
public Page deserializePage(final ResourceConfiguration resourceconfig , final BytesIn<?> source,
final SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());

Expand All @@ -78,7 +81,7 @@ public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?>
final long recordPageKey = Utils.getVarLong(source);
final int revision = source.readInt();
final IndexType indexType = IndexType.getType(source.readByte());
final ResourceConfiguration resourceConfig = pageReadTrx.getResourceSession().getResourceConfig();
// final ResourceConfiguration resourceConfig = pageReadTrx.getResourceSession().getResourceConfig();
final boolean areDeweyIDsStored = resourceConfig.areDeweyIDsStored;
final RecordSerializer recordPersister = resourceConfig.recordPersister;
final byte[][] slots = new byte[Constants.NDP_NODE_COUNT][];
Expand Down Expand Up @@ -158,7 +161,7 @@ public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?>
}

@Override
public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<?> sink, final Page page,
public void serializePage(final ResourceConfiguration resourceconfig, final BytesOut<?> sink, final Page page,
final SerializationType type) {
KeyValueLeafPage keyValueLeafPage = (KeyValueLeafPage) page;

Expand Down Expand Up @@ -288,7 +291,7 @@ public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<
NAMEPAGE((byte) 2, NamePage.class) {
@Override
@NonNull
public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?> source,
public Page deserializePage(final ResourceConfiguration resourceConfig, final BytesIn<?> source,
final SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());

Expand All @@ -308,7 +311,7 @@ public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?>
}

@Override
public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<?> sink, final Page page,
public void serializePage(final ResourceConfiguration resourceConfig, final BytesOut<?> sink, final Page page,
final SerializationType type) {
NamePage namePage = (NamePage) page;
sink.writeByte(NAMEPAGE.id);
Expand Down Expand Up @@ -346,7 +349,7 @@ public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<
UBERPAGE((byte) 3, UberPage.class) {
@Override
@NonNull
public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?> source,
public Page deserializePage(final ResourceConfiguration resourceConfig, final BytesIn<?> source,
final SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());

Expand All @@ -361,7 +364,7 @@ public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?>
}

@Override
public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<?> sink, final Page page,
public void serializePage(final ResourceConfiguration resourceConfig, final BytesOut<?> sink, final Page page,
final SerializationType type) {
UberPage uberPage = (UberPage) page;

Expand All @@ -383,7 +386,7 @@ public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<
INDIRECTPAGE((byte) 4, IndirectPage.class) {
@Override
@NonNull
public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?> source,
public Page deserializePage(final ResourceConfiguration resourceConfig, final BytesIn<?> source,
final SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());

Expand All @@ -397,7 +400,7 @@ public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?>
}

@Override
public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<?> sink, final Page page,
public void serializePage(final ResourceConfiguration resourceConfig, final BytesOut<?> sink, final Page page,
final SerializationType type) {
IndirectPage indirectPage = (IndirectPage) page;
Page delegate = indirectPage.delegate();
Expand All @@ -421,7 +424,7 @@ public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<
REVISIONROOTPAGE((byte) 5, RevisionRootPage.class) {
@Override
@NonNull
public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?> source,
public Page deserializePage(final ResourceConfiguration resourceConfig, final BytesIn<?> source,
final SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());

Expand Down Expand Up @@ -466,7 +469,7 @@ public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?>
}

@Override
public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<?> sink, final Page page,
public void serializePage(final ResourceConfiguration resourceConfig, final BytesOut<?> sink, final Page page,
final SerializationType type) {
RevisionRootPage revisionRootPage = (RevisionRootPage) page;
sink.writeByte(REVISIONROOTPAGE.id);
Expand Down Expand Up @@ -532,7 +535,7 @@ public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<
PATHSUMMARYPAGE((byte) 6, PathSummaryPage.class) {
@Override
@NonNull
public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?> source,
public Page deserializePage(final ResourceConfiguration resourceConfig, final BytesIn<?> source,
final @NonNull SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());

Expand All @@ -558,7 +561,7 @@ public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?>
}

@Override
public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<?> sink, final Page page,
public void serializePage(final ResourceConfiguration resourceConfig, final BytesOut<?> sink, final Page page,
final @NonNull SerializationType type) {
PathSummaryPage pathSummaryPage = (PathSummaryPage) page;
sink.writeByte(PATHSUMMARYPAGE.id);
Expand Down Expand Up @@ -593,7 +596,7 @@ public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<
*/
CASPAGE((byte) 8, CASPage.class) {
@NonNull
public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?> source,
public Page deserializePage(final ResourceConfiguration resourceConfig, final BytesIn<?> source,
final SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());

Expand All @@ -612,7 +615,7 @@ public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?>
}

@Override
public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<?> sink, final Page page,
public void serializePage(final ResourceConfiguration resourceConfig, final BytesOut<?> sink, final Page page,
final SerializationType type) {
CASPage casPage = (CASPage) page;
Page delegate = casPage.delegate();
Expand Down Expand Up @@ -647,7 +650,7 @@ public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<
OVERFLOWPAGE((byte) 9, OverflowPage.class) {
@Override
@NonNull
public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?> source,
public Page deserializePage(final ResourceConfiguration resourceConfig, final BytesIn<?> source,
final SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());

Expand All @@ -663,7 +666,7 @@ public Page deserializePage(final PageReadOnlyTrx pageReadTrx, final BytesIn<?>
}

@Override
public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<?> sink, final Page page,
public void serializePage(final ResourceConfiguration resourceConfig, final BytesOut<?> sink, final Page page,
@NonNull SerializationType type) {
OverflowPage overflowPage = (OverflowPage) page;
sink.writeByte(OVERFLOWPAGE.id);
Expand All @@ -683,7 +686,7 @@ public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, final BytesOut<
*/
PATHPAGE((byte) 10, PathPage.class) {
@Override
public Page deserializePage(@NonNull PageReadOnlyTrx pageReadTrx, BytesIn<?> source,
public Page deserializePage(@NonNull ResourceConfiguration resourceConfig, BytesIn<?> source,
@NonNull SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());
switch (binaryVersion) {
Expand All @@ -701,7 +704,7 @@ public Page deserializePage(@NonNull PageReadOnlyTrx pageReadTrx, BytesIn<?> sou
}

@Override
public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, BytesOut<?> sink, @NonNull Page page,
public void serializePage(final ResourceConfiguration resourceConfig, BytesOut<?> sink, @NonNull Page page,
@NonNull SerializationType type) {
PathPage pathPage = (PathPage) page;
Page delegate = pathPage.delegate();
Expand Down Expand Up @@ -734,7 +737,7 @@ public void serializePage(final PageReadOnlyTrx pageReadOnlyTrx, BytesOut<?> sin
*/
DEWEYIDPAGE((byte) 11, DeweyIDPage.class) {
@Override
public Page deserializePage(@NonNull PageReadOnlyTrx pageReadTrx, BytesIn<?> source,
public Page deserializePage(@NonNull ResourceConfiguration resourceConfig, BytesIn<?> source,
@NonNull SerializationType type) {
final BinaryEncodingVersion binaryVersion = BinaryEncodingVersion.fromByte(source.readByte());

Expand All @@ -750,7 +753,7 @@ public Page deserializePage(@NonNull PageReadOnlyTrx pageReadTrx, BytesIn<?> sou
}

@Override
public void serializePage(@NonNull PageReadOnlyTrx pageReadOnlyTrx, BytesOut<?> sink, @NonNull Page page,
public void serializePage(@NonNull ResourceConfiguration resourceConfig, BytesOut<?> sink, @NonNull Page page,
@NonNull SerializationType type) {
DeweyIDPage deweyIDPage = (DeweyIDPage) page;
Page delegate = deweyIDPage.delegate();
Expand Down
Loading