diff --git a/pom.xml b/pom.xml index 0cfce38..e4ff73d 100644 --- a/pom.xml +++ b/pom.xml @@ -81,8 +81,8 @@ common-utils - io.net5 - netty-buffer + io.netty + netty5-buffer org.yaml @@ -352,9 +352,9 @@ 1.1.8 - io.net5 - netty-buffer - 5.0.0.Final-SNAPSHOT + io.netty + netty5-buffer + 5.0.0.Alpha1 org.yaml diff --git a/src/main/java/io/net5/buffer/api/pool/MetricUtils.java b/src/main/java/io/net5/buffer/api/pool/MetricUtils.java index 6ce30db..2e21da4 100644 --- a/src/main/java/io/net5/buffer/api/pool/MetricUtils.java +++ b/src/main/java/io/net5/buffer/api/pool/MetricUtils.java @@ -1,4 +1,4 @@ -package io.net5.buffer.api.pool; +package io.netty5.buffer.api.pool; import java.lang.invoke.MethodHandle; import java.lang.invoke.MethodHandles; @@ -19,7 +19,7 @@ public class MetricUtils { MethodHandle handle = null; try { // Find the class - var pooledBufferClass = Class.forName("io.net5.buffer.api.pool.PooledBufferAllocatorMetric"); + var pooledBufferClass = Class.forName("io.netty5.buffer.api.pool.PooledBufferAllocatorMetric"); // Find the handle of the method handle = lookup.findVirtual(pooledBufferClass, "arenaMetrics", MethodType.methodType(List.class)); } catch (NoSuchMethodException | IllegalAccessException | ClassNotFoundException ignored) { diff --git a/src/main/java/io/net5/buffer/api/pool/PooledBufferAllocatorMetricUtils.java b/src/main/java/io/net5/buffer/api/pool/PooledBufferAllocatorMetricUtils.java index 4fcc39f..3a57890 100644 --- a/src/main/java/io/net5/buffer/api/pool/PooledBufferAllocatorMetricUtils.java +++ b/src/main/java/io/net5/buffer/api/pool/PooledBufferAllocatorMetricUtils.java @@ -1,4 +1,4 @@ -package io.net5.buffer.api.pool; +package io.netty5.buffer.api.pool; import java.util.List; diff --git a/src/main/java/it/cavallium/dbengine/client/CompositeDatabase.java b/src/main/java/it/cavallium/dbengine/client/CompositeDatabase.java index 4e8160a..1013223 100644 --- a/src/main/java/it/cavallium/dbengine/client/CompositeDatabase.java +++ b/src/main/java/it/cavallium/dbengine/client/CompositeDatabase.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.client; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; diff --git a/src/main/java/it/cavallium/dbengine/client/Hits.java b/src/main/java/it/cavallium/dbengine/client/Hits.java index 4b0b92e..b88c9be 100644 --- a/src/main/java/it/cavallium/dbengine/client/Hits.java +++ b/src/main/java/it/cavallium/dbengine/client/Hits.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.client; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.query.current.data.TotalHitsCount; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.database.collections.ValueGetter; import it.cavallium.dbengine.database.collections.ValueTransformer; import java.util.Map.Entry; diff --git a/src/main/java/it/cavallium/dbengine/client/LuceneIndex.java b/src/main/java/it/cavallium/dbengine/client/LuceneIndex.java index df20520..8ce1b43 100644 --- a/src/main/java/it/cavallium/dbengine/client/LuceneIndex.java +++ b/src/main/java/it/cavallium/dbengine/client/LuceneIndex.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.client; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.query.ClientQueryParams; import it.cavallium.dbengine.client.query.current.data.Query; import it.cavallium.dbengine.client.query.current.data.TotalHitsCount; diff --git a/src/main/java/it/cavallium/dbengine/client/LuceneIndexImpl.java b/src/main/java/it/cavallium/dbengine/client/LuceneIndexImpl.java index 85efadb..ce11170 100644 --- a/src/main/java/it/cavallium/dbengine/client/LuceneIndexImpl.java +++ b/src/main/java/it/cavallium/dbengine/client/LuceneIndexImpl.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.client; -import io.net5.buffer.api.Resource; +import io.netty5.buffer.api.Resource; import it.cavallium.dbengine.client.query.ClientQueryParams; import it.cavallium.dbengine.client.query.current.data.Query; import it.cavallium.dbengine.client.query.current.data.TotalHitsCount; diff --git a/src/main/java/it/cavallium/dbengine/client/MappedSerializer.java b/src/main/java/it/cavallium/dbengine/client/MappedSerializer.java index 880f90f..e899eaf 100644 --- a/src/main/java/it/cavallium/dbengine/client/MappedSerializer.java +++ b/src/main/java/it/cavallium/dbengine/client/MappedSerializer.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.client; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.serialization.SerializationException; import it.cavallium.dbengine.database.serialization.Serializer; import org.jetbrains.annotations.NotNull; diff --git a/src/main/java/it/cavallium/dbengine/client/MappedSerializerFixedLength.java b/src/main/java/it/cavallium/dbengine/client/MappedSerializerFixedLength.java index d4fe711..343951a 100644 --- a/src/main/java/it/cavallium/dbengine/client/MappedSerializerFixedLength.java +++ b/src/main/java/it/cavallium/dbengine/client/MappedSerializerFixedLength.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.client; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.serialization.SerializationException; import it.cavallium.dbengine.database.serialization.SerializerFixedBinaryLength; import org.jetbrains.annotations.NotNull; diff --git a/src/main/java/it/cavallium/dbengine/database/LLDatabaseConnection.java b/src/main/java/it/cavallium/dbengine/database/LLDatabaseConnection.java index 14b1fd9..84ff03f 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLDatabaseConnection.java +++ b/src/main/java/it/cavallium/dbengine/database/LLDatabaseConnection.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import it.cavallium.dbengine.lucene.LuceneHacks; import it.cavallium.dbengine.lucene.LuceneRocksDBManager; import it.cavallium.dbengine.rpc.current.data.Column; diff --git a/src/main/java/it/cavallium/dbengine/database/LLDelta.java b/src/main/java/it/cavallium/dbengine/database/LLDelta.java index 312a0ea..0b1ad66 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLDelta.java +++ b/src/main/java/it/cavallium/dbengine/database/LLDelta.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.database; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import java.util.StringJoiner; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; diff --git a/src/main/java/it/cavallium/dbengine/database/LLDictionary.java b/src/main/java/it/cavallium/dbengine/database/LLDictionary.java index 6e1041a..39364f0 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLDictionary.java +++ b/src/main/java/it/cavallium/dbengine/database/LLDictionary.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.BadBlock; import it.cavallium.dbengine.database.serialization.KVSerializationFunction; import it.cavallium.dbengine.database.serialization.SerializationFunction; diff --git a/src/main/java/it/cavallium/dbengine/database/LLEntry.java b/src/main/java/it/cavallium/dbengine/database/LLEntry.java index 27d253f..86699fd 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLEntry.java +++ b/src/main/java/it/cavallium/dbengine/database/LLEntry.java @@ -1,11 +1,11 @@ package it.cavallium.dbengine.database; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import java.util.Objects; import java.util.StringJoiner; import org.apache.logging.log4j.LogManager; diff --git a/src/main/java/it/cavallium/dbengine/database/LLKeyValueDatabase.java b/src/main/java/it/cavallium/dbengine/database/LLKeyValueDatabase.java index 0691b77..b9bd47c 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLKeyValueDatabase.java +++ b/src/main/java/it/cavallium/dbengine/database/LLKeyValueDatabase.java @@ -3,7 +3,7 @@ package it.cavallium.dbengine.database; import com.google.common.primitives.Ints; import com.google.common.primitives.Longs; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import it.cavallium.dbengine.client.MemoryStats; import it.cavallium.dbengine.database.collections.DatabaseInt; import it.cavallium.dbengine.database.collections.DatabaseLong; diff --git a/src/main/java/it/cavallium/dbengine/database/LLMultiDatabaseConnection.java b/src/main/java/it/cavallium/dbengine/database/LLMultiDatabaseConnection.java index 06a9879..2afbd4a 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLMultiDatabaseConnection.java +++ b/src/main/java/it/cavallium/dbengine/database/LLMultiDatabaseConnection.java @@ -2,7 +2,7 @@ package it.cavallium.dbengine.database; import com.google.common.collect.Multimap; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import it.cavallium.dbengine.client.ConnectionSettings.ConnectionPart; import it.cavallium.dbengine.client.ConnectionSettings.ConnectionPart.ConnectionPartLucene; import it.cavallium.dbengine.client.ConnectionSettings.ConnectionPart.ConnectionPartRocksDB; diff --git a/src/main/java/it/cavallium/dbengine/database/LLMultiLuceneIndex.java b/src/main/java/it/cavallium/dbengine/database/LLMultiLuceneIndex.java index f1a9019..e635170 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLMultiLuceneIndex.java +++ b/src/main/java/it/cavallium/dbengine/database/LLMultiLuceneIndex.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database; import com.google.common.collect.Multimap; -import io.net5.buffer.api.Resource; +import io.netty5.buffer.api.Resource; import it.cavallium.dbengine.rpc.current.data.IndicizerAnalyzers; import it.cavallium.dbengine.rpc.current.data.IndicizerSimilarities; import it.cavallium.dbengine.client.query.current.data.Query; diff --git a/src/main/java/it/cavallium/dbengine/database/LLRange.java b/src/main/java/it/cavallium/dbengine/database/LLRange.java index 9338a57..b46cafb 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLRange.java +++ b/src/main/java/it/cavallium/dbengine/database/LLRange.java @@ -1,12 +1,12 @@ package it.cavallium.dbengine.database; -import static io.net5.buffer.Unpooled.wrappedBuffer; +import static io.netty5.buffer.Unpooled.wrappedBuffer; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import java.util.StringJoiner; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; diff --git a/src/main/java/it/cavallium/dbengine/database/LLSearchResultShard.java b/src/main/java/it/cavallium/dbengine/database/LLSearchResultShard.java index 168b8a4..f8af0a3 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLSearchResultShard.java +++ b/src/main/java/it/cavallium/dbengine/database/LLSearchResultShard.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.client.query.current.data.TotalHitsCount; import java.util.Objects; import org.apache.logging.log4j.LogManager; diff --git a/src/main/java/it/cavallium/dbengine/database/LLSingleton.java b/src/main/java/it/cavallium/dbengine/database/LLSingleton.java index 4eb2b18..d93b3d8 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLSingleton.java +++ b/src/main/java/it/cavallium/dbengine/database/LLSingleton.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.serialization.SerializationFunction; import it.unimi.dsi.fastutil.bytes.ByteList; import java.util.function.Function; diff --git a/src/main/java/it/cavallium/dbengine/database/LLUtils.java b/src/main/java/it/cavallium/dbengine/database/LLUtils.java index 760d216..3c78125 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLUtils.java +++ b/src/main/java/it/cavallium/dbengine/database/LLUtils.java @@ -1,23 +1,23 @@ package it.cavallium.dbengine.database; -import static io.net5.buffer.api.StandardAllocationTypes.OFF_HEAP; +import static io.netty5.buffer.api.StandardAllocationTypes.OFF_HEAP; import static org.apache.commons.lang3.ArrayUtils.EMPTY_BYTE_ARRAY; import com.google.common.primitives.Ints; import com.google.common.primitives.Longs; -import io.net5.buffer.api.AllocatorControl; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.CompositeBuffer; -import io.net5.buffer.api.MemoryManager; -import io.net5.buffer.api.ReadableComponent; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.WritableComponent; -import io.net5.buffer.api.bytebuffer.ByteBufferMemoryManager; -import io.net5.buffer.api.internal.Statics; -import io.net5.buffer.api.unsafe.UnsafeMemoryManager; -import io.net5.util.IllegalReferenceCountException; +import io.netty5.buffer.api.AllocatorControl; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.CompositeBuffer; +import io.netty5.buffer.api.MemoryManager; +import io.netty5.buffer.api.ReadableComponent; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.WritableComponent; +import io.netty5.buffer.api.bytebuffer.ByteBufferMemoryManager; +import io.netty5.buffer.api.internal.Statics; +import io.netty5.buffer.api.unsafe.UnsafeMemoryManager; +import io.netty5.util.IllegalReferenceCountException; import it.cavallium.dbengine.database.disk.UpdateAtomicResultCurrent; import it.cavallium.dbengine.database.disk.UpdateAtomicResultDelta; import it.cavallium.dbengine.database.disk.UpdateAtomicResultPrevious; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseEmpty.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseEmpty.java index 67a3aa2..8cec46c 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseEmpty.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseEmpty.java @@ -1,9 +1,9 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.serialization.SerializationException; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java index 3f0ca54..54418a1 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java @@ -1,9 +1,9 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.Delta; import it.cavallium.dbengine.database.LLDictionary; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionaryDeep.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionaryDeep.java index e9e21a4..3fdd5af 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionaryDeep.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionaryDeep.java @@ -1,12 +1,12 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.client.BadBlock; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionaryHashed.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionaryHashed.java index 53e4543..53fe6d3 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionaryHashed.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionaryHashed.java @@ -1,16 +1,16 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.BadBlock; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.LLUtils; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.database.UpdateMode; import it.cavallium.dbengine.database.serialization.Serializer; import it.cavallium.dbengine.database.serialization.SerializerFixedBinaryLength; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSetDictionary.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSetDictionary.java index c471707..850454d 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSetDictionary.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSetDictionary.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.LLUtils; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSetDictionaryHashed.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSetDictionaryHashed.java index 5180ce1..c0fc89c 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSetDictionaryHashed.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSetDictionaryHashed.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.LLUtils; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingle.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingle.java index 0ba2763..dfc061d 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingle.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingle.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.client.BadBlock; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.Delta; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingleBucket.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingleBucket.java index 191c88f..3ddcbfc 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingleBucket.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingleBucket.java @@ -1,13 +1,13 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.BadBlock; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.Delta; import it.cavallium.dbengine.database.LLUtils; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.database.UpdateReturnMode; import it.cavallium.dbengine.database.serialization.SerializationFunction; import it.unimi.dsi.fastutil.objects.ObjectArraySet; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingleMapped.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingleMapped.java index 3472cdc..229c7e0 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingleMapped.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseSingleMapped.java @@ -1,9 +1,9 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.client.BadBlock; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.client.Mapper; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStage.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStage.java index c769573..a4f1275 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStage.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStage.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Resource; +import io.netty5.buffer.api.Resource; import it.cavallium.dbengine.client.BadBlock; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.Delta; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageEntry.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageEntry.java index c5df267..573f853 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageEntry.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageEntry.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Resource; +import io.netty5.buffer.api.Resource; import it.cavallium.dbengine.client.BadBlock; import reactor.core.publisher.Flux; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageWithEntry.java b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageWithEntry.java index 3d7106c..a4effc6 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageWithEntry.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/DatabaseStageWithEntry.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Resource; +import io.netty5.buffer.api.Resource; import it.cavallium.dbengine.client.BadBlock; import reactor.core.publisher.Mono; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetter.java b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetter.java index af71741..d4b502b 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetter.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetter.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import org.jetbrains.annotations.Nullable; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterHashMap.java b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterHashMap.java index ccf62b8..f899f7f 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterHashMap.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterHashMap.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.LLUtils; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterHashSet.java b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterHashSet.java index f679b7f..0753c42 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterHashSet.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterHashSet.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.LLUtils; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterMap.java b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterMap.java index 81c7bc1..c0400d0 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterMap.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterMap.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.LLUtils; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterMapDeep.java b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterMapDeep.java index bc54694..5a80b17 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterMapDeep.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterMapDeep.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.LLUtils; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSet.java b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSet.java index d3bfbbb..a45bfc0 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSet.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSet.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.collections.DatabaseEmpty.Nothing; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSingle.java b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSingle.java index 0cf9f58..3644e0c 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSingle.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSingle.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.CompositeSnapshot; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.serialization.Serializer; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSingleBytes.java b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSingleBytes.java index 162082f..346ed85 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSingleBytes.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/SubStageGetterSingleBytes.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.serialization.Serializer; public class SubStageGetterSingleBytes extends SubStageGetterSingle> { diff --git a/src/main/java/it/cavallium/dbengine/database/collections/ValueWithHashSerializer.java b/src/main/java/it/cavallium/dbengine/database/collections/ValueWithHashSerializer.java index adef940..056f16a 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/ValueWithHashSerializer.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/ValueWithHashSerializer.java @@ -1,9 +1,9 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.CompositeBuffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.CompositeBuffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.serialization.SerializationException; import it.cavallium.dbengine.database.serialization.Serializer; diff --git a/src/main/java/it/cavallium/dbengine/database/collections/ValuesSetSerializer.java b/src/main/java/it/cavallium/dbengine/database/collections/ValuesSetSerializer.java index 5a81bae..c58c1e1 100644 --- a/src/main/java/it/cavallium/dbengine/database/collections/ValuesSetSerializer.java +++ b/src/main/java/it/cavallium/dbengine/database/collections/ValuesSetSerializer.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.serialization.SerializationException; import it.cavallium.dbengine.database.serialization.Serializer; import it.unimi.dsi.fastutil.objects.ObjectArraySet; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/AbstractRocksDBColumn.java b/src/main/java/it/cavallium/dbengine/database/disk/AbstractRocksDBColumn.java index 5ff1ea3..34d551f 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/AbstractRocksDBColumn.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/AbstractRocksDBColumn.java @@ -1,16 +1,16 @@ package it.cavallium.dbengine.database.disk; -import static io.net5.buffer.api.StandardAllocationTypes.OFF_HEAP; +import static io.netty5.buffer.api.StandardAllocationTypes.OFF_HEAP; import static it.cavallium.dbengine.database.LLUtils.INITIAL_DIRECT_READ_BYTE_BUF_SIZE_BYTES; import static java.util.Objects.requireNonNull; import static org.rocksdb.KeyMayExist.KeyMayExistEnum.kExistsWithValue; import io.micrometer.core.instrument.Gauge; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.WritableComponent; -import io.net5.util.internal.PlatformDependent; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.WritableComponent; +import io.netty5.util.internal.PlatformDependent; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.RepeatedElementList; import it.cavallium.dbengine.rpc.current.data.DatabaseOptions; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/CachedIndexSearcherManager.java b/src/main/java/it/cavallium/dbengine/database/disk/CachedIndexSearcherManager.java index 0656d92..96ecb71 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/CachedIndexSearcherManager.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/CachedIndexSearcherManager.java @@ -5,7 +5,7 @@ import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterrupti import com.google.common.cache.CacheBuilder; import com.google.common.cache.CacheLoader; import com.google.common.cache.LoadingCache; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLSnapshot; import java.io.IOException; import java.time.Duration; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/IndexSearcherManager.java b/src/main/java/it/cavallium/dbengine/database/disk/IndexSearcherManager.java index bc3e133..8584a3f 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/IndexSearcherManager.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/IndexSearcherManager.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLSnapshot; import java.io.IOException; import java.util.function.Function; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLIndexSearcher.java b/src/main/java/it/cavallium/dbengine/database/disk/LLIndexSearcher.java index b49fe1d..597db38 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLIndexSearcher.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLIndexSearcher.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.internal.ResourceSupport; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.apache.lucene.index.IndexReader; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLIndexSearchers.java b/src/main/java/it/cavallium/dbengine/database/disk/LLIndexSearchers.java index 4ebc0bd..81b8d7d 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLIndexSearchers.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLIndexSearchers.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.unimi.dsi.fastutil.objects.Object2IntOpenHashMap; import java.io.IOException; import java.io.UncheckedIOException; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDatabaseConnection.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDatabaseConnection.java index 54e71d0..ef3d212 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDatabaseConnection.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDatabaseConnection.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database.disk; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import it.cavallium.dbengine.database.LLDatabaseConnection; import it.cavallium.dbengine.database.LLLuceneIndex; import it.cavallium.dbengine.lucene.LuceneHacks; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java index 6c517a8..f4bb958 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.disk; -import static io.net5.buffer.api.StandardAllocationTypes.OFF_HEAP; +import static io.netty5.buffer.api.StandardAllocationTypes.OFF_HEAP; import static it.cavallium.dbengine.database.LLUtils.MARKER_ROCKSDB; import static it.cavallium.dbengine.database.LLUtils.asReadOnlyDirect; import static it.cavallium.dbengine.database.LLUtils.fromByteArray; @@ -10,9 +10,9 @@ import static java.util.Objects.requireNonNullElse; import io.micrometer.core.instrument.Counter; import io.micrometer.core.instrument.Timer; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.BadBlock; import it.cavallium.dbengine.database.ColumnUtils; import it.cavallium.dbengine.database.LLDelta; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalEntryReactiveRocksIterator.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalEntryReactiveRocksIterator.java index 66e35e5..b1d70ca 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalEntryReactiveRocksIterator.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalEntryReactiveRocksIterator.java @@ -1,9 +1,9 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLEntry; import it.cavallium.dbengine.database.LLRange; import it.cavallium.dbengine.netty.NullableBuffer; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedEntryReactiveRocksIterator.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedEntryReactiveRocksIterator.java index 9e59a09..8fad084 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedEntryReactiveRocksIterator.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedEntryReactiveRocksIterator.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLEntry; import it.cavallium.dbengine.database.LLRange; import org.rocksdb.ReadOptions; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedKeyReactiveRocksIterator.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedKeyReactiveRocksIterator.java index a08e14f..8549dae 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedKeyReactiveRocksIterator.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedKeyReactiveRocksIterator.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLRange; import org.rocksdb.ReadOptions; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedReactiveRocksIterator.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedReactiveRocksIterator.java index 69d527b..8e18121 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedReactiveRocksIterator.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalGroupedReactiveRocksIterator.java @@ -2,11 +2,11 @@ package it.cavallium.dbengine.database.disk; import static it.cavallium.dbengine.database.LLUtils.MARKER_ROCKSDB; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.database.LLRange; import it.cavallium.dbengine.database.LLUtils; import it.unimi.dsi.fastutil.objects.ObjectArrayList; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyPrefixReactiveRocksIterator.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyPrefixReactiveRocksIterator.java index 7fc6622..fd4ba5d 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyPrefixReactiveRocksIterator.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyPrefixReactiveRocksIterator.java @@ -2,11 +2,11 @@ package it.cavallium.dbengine.database.disk; import static it.cavallium.dbengine.database.LLUtils.MARKER_ROCKSDB; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.database.LLRange; import it.cavallium.dbengine.database.LLUtils; import org.apache.logging.log4j.LogManager; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyReactiveRocksIterator.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyReactiveRocksIterator.java index e26c52f..c9094f6 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyReactiveRocksIterator.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyReactiveRocksIterator.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLRange; import org.rocksdb.ColumnFamilyHandle; import org.rocksdb.ReadOptions; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java index c8b8442..5f3c320 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java @@ -1,13 +1,13 @@ package it.cavallium.dbengine.database.disk; -import static io.net5.buffer.api.StandardAllocationTypes.OFF_HEAP; +import static io.netty5.buffer.api.StandardAllocationTypes.OFF_HEAP; import static it.cavallium.dbengine.database.LLUtils.MARKER_ROCKSDB; import io.micrometer.core.instrument.MeterRegistry; import io.micrometer.core.instrument.Tag; import io.micrometer.core.instrument.Timer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.util.internal.PlatformDependent; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.util.internal.PlatformDependent; import it.cavallium.dbengine.client.MemoryStats; import it.cavallium.dbengine.database.ColumnUtils; import it.cavallium.dbengine.database.LLKeyValueDatabase; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java index a7fb232..8f45a51 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java @@ -12,7 +12,7 @@ import com.google.common.collect.Multimap; import io.micrometer.core.instrument.Counter; import io.micrometer.core.instrument.MeterRegistry; import io.micrometer.core.instrument.Timer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.query.QueryParser; import it.cavallium.dbengine.client.query.current.data.Query; import it.cavallium.dbengine.client.query.current.data.QueryParams; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalMultiLuceneIndex.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalMultiLuceneIndex.java index 1ec7e75..83c8812 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalMultiLuceneIndex.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalMultiLuceneIndex.java @@ -4,7 +4,7 @@ import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterrupti import com.google.common.collect.Multimap; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.query.QueryParser; import it.cavallium.dbengine.client.query.current.data.Query; import it.cavallium.dbengine.client.query.current.data.QueryParams; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalReactiveRocksIterator.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalReactiveRocksIterator.java index 4622343..d5fe867 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalReactiveRocksIterator.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalReactiveRocksIterator.java @@ -3,11 +3,11 @@ package it.cavallium.dbengine.database.disk; import static it.cavallium.dbengine.database.LLUtils.MARKER_ROCKSDB; import static it.cavallium.dbengine.database.disk.LLLocalDictionary.getRocksIterator; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.database.LLRange; import it.cavallium.dbengine.database.LLUtils; import org.apache.logging.log4j.LogManager; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalSingleton.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalSingleton.java index e7c0bb0..24226d1 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalSingleton.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalSingleton.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.Delta; import it.cavallium.dbengine.database.LLSingleton; import it.cavallium.dbengine.database.LLSnapshot; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLTempLMDBEnv.java b/src/main/java/it/cavallium/dbengine/database/disk/LLTempLMDBEnv.java index ed26fd0..d54eb7d 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLTempLMDBEnv.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLTempLMDBEnv.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.io.Closeable; import java.io.File; import java.io.IOException; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/MemorySegmentUtils.java b/src/main/java/it/cavallium/dbengine/database/disk/MemorySegmentUtils.java index 4dcc3ae..f12e8f7 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/MemorySegmentUtils.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/MemorySegmentUtils.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.disk; -import io.net5.util.internal.PlatformDependent; +import io.netty5.util.internal.PlatformDependent; import java.lang.invoke.MethodHandle; import java.lang.invoke.MethodHandles; import java.lang.invoke.MethodHandles.Lookup; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java b/src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java index 8708320..cab32b5 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/OptimisticRocksDBColumn.java @@ -3,10 +3,10 @@ package it.cavallium.dbengine.database.disk; import static it.cavallium.dbengine.database.LLUtils.MARKER_ROCKSDB; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.MemoryManager; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.MemoryManager; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLDelta; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.serialization.SerializationFunction; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/PessimisticRocksDBColumn.java b/src/main/java/it/cavallium/dbengine/database/disk/PessimisticRocksDBColumn.java index 7179adc..b24682a 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/PessimisticRocksDBColumn.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/PessimisticRocksDBColumn.java @@ -3,10 +3,10 @@ package it.cavallium.dbengine.database.disk; import static it.cavallium.dbengine.database.LLUtils.MARKER_ROCKSDB; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.MemoryManager; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.MemoryManager; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLDelta; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.serialization.SerializationFunction; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/ReleasableSlice.java b/src/main/java/it/cavallium/dbengine/database/disk/ReleasableSlice.java index dab03b7..7617114 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/ReleasableSlice.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/ReleasableSlice.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Buffer; +import io.netty5.buffer.api.Buffer; import it.cavallium.dbengine.database.SafeCloseable; import org.rocksdb.AbstractSlice; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/RocksDBColumn.java b/src/main/java/it/cavallium/dbengine/database/disk/RocksDBColumn.java index 6c5b1cd..8e1072f 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/RocksDBColumn.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/RocksDBColumn.java @@ -1,9 +1,9 @@ package it.cavallium.dbengine.database.disk; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.serialization.SerializationFunction; import java.io.IOException; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/StandardRocksDBColumn.java b/src/main/java/it/cavallium/dbengine/database/disk/StandardRocksDBColumn.java index 2085afe..4952321 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/StandardRocksDBColumn.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/StandardRocksDBColumn.java @@ -3,9 +3,9 @@ package it.cavallium.dbengine.database.disk; import static it.cavallium.dbengine.database.LLUtils.MARKER_ROCKSDB; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLDelta; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.serialization.SerializationFunction; diff --git a/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultCurrent.java b/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultCurrent.java index 51ca635..1fdfa9d 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultCurrent.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultCurrent.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; public final record UpdateAtomicResultCurrent(Send current) implements UpdateAtomicResult {} diff --git a/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultDelta.java b/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultDelta.java index 04c2b8f..a39425e 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultDelta.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultDelta.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLDelta; public final record UpdateAtomicResultDelta(Send delta) implements UpdateAtomicResult {} diff --git a/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultPrevious.java b/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultPrevious.java index e14bb5c..8d2ed36 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultPrevious.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/UpdateAtomicResultPrevious.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.disk; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; public final record UpdateAtomicResultPrevious(Send previous) implements UpdateAtomicResult {} diff --git a/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryDatabaseConnection.java b/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryDatabaseConnection.java index 7b8d4c8..0b09bc1 100644 --- a/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryDatabaseConnection.java +++ b/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryDatabaseConnection.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database.memory; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import it.cavallium.dbengine.database.LLDatabaseConnection; import it.cavallium.dbengine.database.LLKeyValueDatabase; import it.cavallium.dbengine.database.LLLuceneIndex; diff --git a/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryDictionary.java b/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryDictionary.java index 224328c..cb85b8b 100644 --- a/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryDictionary.java +++ b/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryDictionary.java @@ -1,9 +1,9 @@ package it.cavallium.dbengine.database.memory; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Resource; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Resource; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.BadBlock; import it.cavallium.dbengine.database.LLDelta; import it.cavallium.dbengine.database.LLDictionary; diff --git a/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryKeyValueDatabase.java b/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryKeyValueDatabase.java index 2e19020..9fd1e34 100644 --- a/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryKeyValueDatabase.java +++ b/src/main/java/it/cavallium/dbengine/database/memory/LLMemoryKeyValueDatabase.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database.memory; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import it.cavallium.dbengine.client.MemoryStats; import it.cavallium.dbengine.database.LLDictionary; import it.cavallium.dbengine.database.LLKeyValueDatabase; diff --git a/src/main/java/it/cavallium/dbengine/database/memory/LLMemorySingleton.java b/src/main/java/it/cavallium/dbengine/database/memory/LLMemorySingleton.java index 53857d4..df594c7 100644 --- a/src/main/java/it/cavallium/dbengine/database/memory/LLMemorySingleton.java +++ b/src/main/java/it/cavallium/dbengine/database/memory/LLMemorySingleton.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.memory; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLDelta; import it.cavallium.dbengine.database.LLDictionaryResultType; import it.cavallium.dbengine.database.LLSingleton; diff --git a/src/main/java/it/cavallium/dbengine/database/remote/LLQuicConnection.java b/src/main/java/it/cavallium/dbengine/database/remote/LLQuicConnection.java index 51fae28..77f80cf 100644 --- a/src/main/java/it/cavallium/dbengine/database/remote/LLQuicConnection.java +++ b/src/main/java/it/cavallium/dbengine/database/remote/LLQuicConnection.java @@ -2,9 +2,9 @@ package it.cavallium.dbengine.database.remote; import com.google.common.collect.Multimap; import io.micrometer.core.instrument.MeterRegistry; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import io.netty.handler.ssl.util.InsecureTrustManagerFactory; import io.netty.incubator.codec.quic.QuicSslContextBuilder; import it.cavallium.dbengine.client.MemoryStats; diff --git a/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataInputOwned.java b/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataInputOwned.java index 476dd8d..a4787c2 100644 --- a/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataInputOwned.java +++ b/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataInputOwned.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.database.serialization; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.SafeCloseable; import java.io.DataInput; import java.nio.charset.StandardCharsets; diff --git a/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataInputShared.java b/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataInputShared.java index 22d1dd1..ae48e26 100644 --- a/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataInputShared.java +++ b/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataInputShared.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.database.serialization; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.ReadableComponent; -import io.net5.buffer.api.ReadableComponentProcessor; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.adaptor.ByteBufAdaptor; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.ReadableComponent; +import io.netty5.buffer.api.ReadableComponentProcessor; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.adaptor.ByteBufAdaptor; import it.cavallium.dbengine.database.SafeCloseable; import java.io.DataInput; import java.lang.invoke.MethodHandle; diff --git a/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataOutput.java b/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataOutput.java index 07182ae..adda9f6 100644 --- a/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataOutput.java +++ b/src/main/java/it/cavallium/dbengine/database/serialization/BufferDataOutput.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.database.serialization; -import io.net5.buffer.api.Buffer; +import io.netty5.buffer.api.Buffer; import java.io.DataOutput; import java.nio.charset.StandardCharsets; import org.jetbrains.annotations.NotNull; diff --git a/src/main/java/it/cavallium/dbengine/database/serialization/CodecSerializer.java b/src/main/java/it/cavallium/dbengine/database/serialization/CodecSerializer.java index 351749e..512c0df 100644 --- a/src/main/java/it/cavallium/dbengine/database/serialization/CodecSerializer.java +++ b/src/main/java/it/cavallium/dbengine/database/serialization/CodecSerializer.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.serialization; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import java.io.IOError; import java.io.IOException; import org.jetbrains.annotations.NotNull; diff --git a/src/main/java/it/cavallium/dbengine/database/serialization/Serializer.java b/src/main/java/it/cavallium/dbengine/database/serialization/Serializer.java index b8da051..6e27621 100644 --- a/src/main/java/it/cavallium/dbengine/database/serialization/Serializer.java +++ b/src/main/java/it/cavallium/dbengine/database/serialization/Serializer.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.database.serialization; -import io.net5.buffer.ByteBufUtil; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; -import io.net5.util.internal.StringUtil; +import io.netty5.buffer.ByteBufUtil; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; +import io.netty5.util.internal.StringUtil; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.netty.NullableBuffer; import java.nio.charset.StandardCharsets; diff --git a/src/main/java/it/cavallium/dbengine/database/serialization/SerializerFixedBinaryLength.java b/src/main/java/it/cavallium/dbengine/database/serialization/SerializerFixedBinaryLength.java index 002ac28..45383e2 100644 --- a/src/main/java/it/cavallium/dbengine/database/serialization/SerializerFixedBinaryLength.java +++ b/src/main/java/it/cavallium/dbengine/database/serialization/SerializerFixedBinaryLength.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.database.serialization; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLUtils; import java.nio.charset.StandardCharsets; import java.util.Objects; diff --git a/src/main/java/it/cavallium/dbengine/lucene/ByteArrayCodec.java b/src/main/java/it/cavallium/dbengine/lucene/ByteArrayCodec.java index 1f2f917..fda59da 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/ByteArrayCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/ByteArrayCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.function.Function; public class ByteArrayCodec implements LMDBCodec { diff --git a/src/main/java/it/cavallium/dbengine/lucene/BytesRefCodec.java b/src/main/java/it/cavallium/dbengine/lucene/BytesRefCodec.java index 2cd0160..de7d2d4 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/BytesRefCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/BytesRefCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.function.Function; import org.apache.lucene.util.BytesRef; diff --git a/src/main/java/it/cavallium/dbengine/lucene/DoubleCodec.java b/src/main/java/it/cavallium/dbengine/lucene/DoubleCodec.java index ffa36e8..91f7b0b 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/DoubleCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/DoubleCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.function.Function; public class DoubleCodec implements LMDBCodec { diff --git a/src/main/java/it/cavallium/dbengine/lucene/FloatCodec.java b/src/main/java/it/cavallium/dbengine/lucene/FloatCodec.java index d626c7d..ab59078 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/FloatCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/FloatCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.function.Function; public class FloatCodec implements LMDBCodec { diff --git a/src/main/java/it/cavallium/dbengine/lucene/IntCodec.java b/src/main/java/it/cavallium/dbengine/lucene/IntCodec.java index 51db990..2d15ecc 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/IntCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/IntCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.function.Function; public class IntCodec implements LMDBCodec { diff --git a/src/main/java/it/cavallium/dbengine/lucene/LLFieldDocCodec.java b/src/main/java/it/cavallium/dbengine/lucene/LLFieldDocCodec.java index 0ebd3d8..3d530fb 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LLFieldDocCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LLFieldDocCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.ArrayList; import java.util.function.Function; diff --git a/src/main/java/it/cavallium/dbengine/lucene/LLScoreDocCodec.java b/src/main/java/it/cavallium/dbengine/lucene/LLScoreDocCodec.java index be1cdd8..80cf662 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LLScoreDocCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LLScoreDocCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.function.Function; public class LLScoreDocCodec implements LMDBSortedCodec { diff --git a/src/main/java/it/cavallium/dbengine/lucene/LLSlotDocCodec.java b/src/main/java/it/cavallium/dbengine/lucene/LLSlotDocCodec.java index 0506e98..4d8c933 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LLSlotDocCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LLSlotDocCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import it.cavallium.dbengine.database.SafeCloseable; import it.cavallium.dbengine.database.disk.LLTempLMDBEnv; import java.io.Closeable; diff --git a/src/main/java/it/cavallium/dbengine/lucene/LMDBArray.java b/src/main/java/it/cavallium/dbengine/lucene/LMDBArray.java index 7655e21..818d4d1 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LMDBArray.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LMDBArray.java @@ -2,8 +2,8 @@ package it.cavallium.dbengine.lucene; import static org.lmdbjava.DbiFlags.MDB_CREATE; -import io.net5.buffer.ByteBuf; -import io.net5.buffer.PooledByteBufAllocator; +import io.netty5.buffer.ByteBuf; +import io.netty5.buffer.PooledByteBufAllocator; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.SafeCloseable; import it.cavallium.dbengine.database.disk.LLTempLMDBEnv; diff --git a/src/main/java/it/cavallium/dbengine/lucene/LMDBCodec.java b/src/main/java/it/cavallium/dbengine/lucene/LMDBCodec.java index 35841f7..f241230 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LMDBCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LMDBCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.function.Function; public interface LMDBCodec { diff --git a/src/main/java/it/cavallium/dbengine/lucene/LMDBPriorityQueue.java b/src/main/java/it/cavallium/dbengine/lucene/LMDBPriorityQueue.java index cbfc3fe..ff03abe 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LMDBPriorityQueue.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LMDBPriorityQueue.java @@ -2,8 +2,8 @@ package it.cavallium.dbengine.lucene; import static org.lmdbjava.DbiFlags.*; -import io.net5.buffer.ByteBuf; -import io.net5.buffer.PooledByteBufAllocator; +import io.netty5.buffer.ByteBuf; +import io.netty5.buffer.PooledByteBufAllocator; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.SafeCloseable; import it.cavallium.dbengine.database.disk.LLTempLMDBEnv; diff --git a/src/main/java/it/cavallium/dbengine/lucene/LMDBSortedCodec.java b/src/main/java/it/cavallium/dbengine/lucene/LMDBSortedCodec.java index c5ea59d..5042df2 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LMDBSortedCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LMDBSortedCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.Comparator; import java.util.function.Function; diff --git a/src/main/java/it/cavallium/dbengine/lucene/LongCodec.java b/src/main/java/it/cavallium/dbengine/lucene/LongCodec.java index b984685..12e562b 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LongCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LongCodec.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.util.function.Function; public class LongCodec implements LMDBCodec { diff --git a/src/main/java/it/cavallium/dbengine/lucene/LuceneRocksDBManager.java b/src/main/java/it/cavallium/dbengine/lucene/LuceneRocksDBManager.java index 47ac2a8..fa5ec7d 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LuceneRocksDBManager.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LuceneRocksDBManager.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import it.cavallium.dbengine.lucene.directory.RocksDBInstance; import it.cavallium.dbengine.lucene.directory.RocksdbFileStore; import java.io.IOException; diff --git a/src/main/java/it/cavallium/dbengine/lucene/SortFieldCodec.java b/src/main/java/it/cavallium/dbengine/lucene/SortFieldCodec.java index b10fa6d..c2ddf6e 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/SortFieldCodec.java +++ b/src/main/java/it/cavallium/dbengine/lucene/SortFieldCodec.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.lucene; -import io.net5.buffer.ByteBuf; -import io.net5.buffer.PooledByteBufAllocator; +import io.netty5.buffer.ByteBuf; +import io.netty5.buffer.PooledByteBufAllocator; import java.io.IOException; import java.util.function.Function; import org.apache.lucene.search.SortField; diff --git a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksDBSliceInputStream.java b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksDBSliceInputStream.java index da63912..034968d 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksDBSliceInputStream.java +++ b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksDBSliceInputStream.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.lucene.directory; -import io.net5.buffer.Unpooled; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.BufferRef; -import io.net5.buffer.api.adaptor.ByteBufAdaptor; +import io.netty5.buffer.Unpooled; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferRef; +import io.netty5.buffer.api.adaptor.ByteBufAdaptor; import org.apache.lucene.store.IndexInput; import java.io.EOFException; diff --git a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbDirectory.java b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbDirectory.java index 743c823..60414b3 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbDirectory.java +++ b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbDirectory.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.lucene.directory; import com.google.common.util.concurrent.Striped; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import java.io.FileNotFoundException; import java.io.IOException; import java.nio.file.Path; diff --git a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbFileStore.java b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbFileStore.java index cde585c..fa488b6 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbFileStore.java +++ b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbFileStore.java @@ -2,10 +2,10 @@ package it.cavallium.dbengine.lucene.directory; import com.google.common.primitives.Longs; import com.google.common.util.concurrent.Striped; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.ReadableComponent; -import io.net5.buffer.api.WritableComponent; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.ReadableComponent; +import io.netty5.buffer.api.WritableComponent; import java.io.IOException; import java.nio.ByteBuffer; import java.nio.charset.StandardCharsets; diff --git a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbInputStream.java b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbInputStream.java index 86961b6..e034364 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbInputStream.java +++ b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbInputStream.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.lucene.directory; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; import java.io.EOFException; import java.io.IOException; import org.apache.lucene.store.IndexInput; diff --git a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbOutputStream.java b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbOutputStream.java index 18218eb..e1dc41d 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbOutputStream.java +++ b/src/main/java/it/cavallium/dbengine/lucene/directory/RocksdbOutputStream.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.lucene.directory; -import io.net5.buffer.ByteBuf; -import io.net5.buffer.ByteBufAllocator; -import io.net5.buffer.api.Buffer; +import io.netty5.buffer.ByteBuf; +import io.netty5.buffer.ByteBufAllocator; +import io.netty5.buffer.api.Buffer; import org.apache.lucene.store.BufferedChecksum; import org.apache.lucene.store.IndexOutput; import org.apache.lucene.util.Accountable; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/AdaptiveLocalSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/AdaptiveLocalSearcher.java index b13b6a9..aa36b56 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/AdaptiveLocalSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/AdaptiveLocalSearcher.java @@ -3,8 +3,8 @@ package it.cavallium.dbengine.lucene.searcher; import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterruptibleScheduler; import static it.cavallium.dbengine.lucene.searcher.GlobalQueryRewrite.NO_REWRITE; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.database.disk.LLIndexSearcher; import it.cavallium.dbengine.database.disk.LLIndexSearchers; import it.cavallium.dbengine.database.disk.LLTempLMDBEnv; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/AdaptiveMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/AdaptiveMultiSearcher.java index 35de5ca..9c24f40 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/AdaptiveMultiSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/AdaptiveMultiSearcher.java @@ -3,7 +3,7 @@ package it.cavallium.dbengine.lucene.searcher; import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterruptibleScheduler; import static it.cavallium.dbengine.lucene.searcher.GlobalQueryRewrite.NO_REWRITE; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.disk.LLIndexSearchers; import it.cavallium.dbengine.database.disk.LLTempLMDBEnv; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/CountMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/CountMultiSearcher.java index c5a6220..e538ff8 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/CountMultiSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/CountMultiSearcher.java @@ -2,7 +2,7 @@ package it.cavallium.dbengine.lucene.searcher; import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterruptibleScheduler; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.query.current.data.TotalHitsCount; import it.cavallium.dbengine.database.LLKeyScore; import it.cavallium.dbengine.database.LLUtils; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/DecimalBucketMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/DecimalBucketMultiSearcher.java index 5309fd3..1af74ca 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/DecimalBucketMultiSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/DecimalBucketMultiSearcher.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene.searcher; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.disk.LLIndexSearchers; import it.cavallium.dbengine.lucene.collector.Buckets; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/LocalSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/LocalSearcher.java index c5a1b80..437eef8 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/LocalSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/LocalSearcher.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene.searcher; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.disk.LLIndexSearcher; import org.jetbrains.annotations.Nullable; import reactor.core.publisher.Mono; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/LuceneSearchResult.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/LuceneSearchResult.java index 2611754..4a23092 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/LuceneSearchResult.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/LuceneSearchResult.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.lucene.searcher; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; import it.cavallium.dbengine.client.query.current.data.TotalHitsCount; import it.cavallium.dbengine.database.LLKeyScore; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.internal.ResourceSupport; import java.util.Objects; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/MultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/MultiSearcher.java index a999164..3a2dc4c 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/MultiSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/MultiSearcher.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.lucene.searcher; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.disk.LLIndexSearcher; import it.cavallium.dbengine.database.disk.LLIndexSearchers; import org.jetbrains.annotations.Nullable; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/PagedLocalSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/PagedLocalSearcher.java index f4c7ed6..3c50415 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/PagedLocalSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/PagedLocalSearcher.java @@ -4,8 +4,8 @@ import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterrupti import static it.cavallium.dbengine.lucene.searcher.CurrentPageInfo.EMPTY_STATUS; import static it.cavallium.dbengine.lucene.searcher.PaginationInfo.MAX_SINGLE_SEARCH_LIMIT; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.database.LLKeyScore; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.disk.LLIndexSearcher; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/ScoredPagedMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/ScoredPagedMultiSearcher.java index c5d6fc7..b2a794a 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/ScoredPagedMultiSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/ScoredPagedMultiSearcher.java @@ -4,7 +4,7 @@ import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterrupti import static it.cavallium.dbengine.lucene.searcher.GlobalQueryRewrite.NO_REWRITE; import static it.cavallium.dbengine.lucene.searcher.PaginationInfo.MAX_SINGLE_SEARCH_LIMIT; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLKeyScore; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.disk.LLIndexSearchers; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedByScoreFullMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedByScoreFullMultiSearcher.java index 85ff21c..7251f13 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedByScoreFullMultiSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedByScoreFullMultiSearcher.java @@ -2,7 +2,7 @@ package it.cavallium.dbengine.lucene.searcher; import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterruptibleScheduler; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLKeyScore; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.disk.LLIndexSearchers; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedScoredFullMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedScoredFullMultiSearcher.java index 6b2a875..4dc54fc 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedScoredFullMultiSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedScoredFullMultiSearcher.java @@ -2,7 +2,7 @@ package it.cavallium.dbengine.lucene.searcher; import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterruptibleScheduler; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLKeyScore; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.disk.LLIndexSearchers; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/StandardSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/StandardSearcher.java index 3c676f2..e115964 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/StandardSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/StandardSearcher.java @@ -3,7 +3,7 @@ package it.cavallium.dbengine.lucene.searcher; import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterruptibleScheduler; import static java.util.Objects.requireNonNull; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.LLKeyScore; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.disk.LLIndexSearchers; diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/UnsortedStreamingMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/UnsortedStreamingMultiSearcher.java index 9c64140..3b186c9 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/searcher/UnsortedStreamingMultiSearcher.java +++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/UnsortedStreamingMultiSearcher.java @@ -2,7 +2,7 @@ package it.cavallium.dbengine.lucene.searcher; import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterruptibleScheduler; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.query.current.data.TotalHitsCount; import it.cavallium.dbengine.database.LLKeyScore; import it.cavallium.dbengine.database.LLUtils; diff --git a/src/main/java/it/cavallium/dbengine/netty/JMXNettyMonitoring.java b/src/main/java/it/cavallium/dbengine/netty/JMXNettyMonitoring.java index 5cf1131..5fae52f 100644 --- a/src/main/java/it/cavallium/dbengine/netty/JMXNettyMonitoring.java +++ b/src/main/java/it/cavallium/dbengine/netty/JMXNettyMonitoring.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine.netty; -import io.net5.buffer.api.pool.BufferAllocatorMetric; +import io.netty5.buffer.api.pool.BufferAllocatorMetric; public class JMXNettyMonitoring implements JMXNettyMonitoringMBean { diff --git a/src/main/java/it/cavallium/dbengine/netty/JMXNettyMonitoringManager.java b/src/main/java/it/cavallium/dbengine/netty/JMXNettyMonitoringManager.java index 3c5ee9d..3b13bd9 100644 --- a/src/main/java/it/cavallium/dbengine/netty/JMXNettyMonitoringManager.java +++ b/src/main/java/it/cavallium/dbengine/netty/JMXNettyMonitoringManager.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.netty; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.DefaultBufferAllocators; -import io.net5.buffer.api.pool.MetricUtils; -import io.net5.buffer.api.pool.PoolArenaMetric; -import io.net5.buffer.api.pool.PooledBufferAllocator; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.DefaultBufferAllocators; +import io.netty5.buffer.api.pool.MetricUtils; +import io.netty5.buffer.api.pool.PoolArenaMetric; +import io.netty5.buffer.api.pool.PooledBufferAllocator; import java.lang.management.ManagementFactory; import java.util.Map; import java.util.Map.Entry; diff --git a/src/main/java/it/cavallium/dbengine/netty/JMXPoolArenaNettyMonitoring.java b/src/main/java/it/cavallium/dbengine/netty/JMXPoolArenaNettyMonitoring.java index d42e573..13e15cb 100644 --- a/src/main/java/it/cavallium/dbengine/netty/JMXPoolArenaNettyMonitoring.java +++ b/src/main/java/it/cavallium/dbengine/netty/JMXPoolArenaNettyMonitoring.java @@ -1,7 +1,7 @@ package it.cavallium.dbengine.netty; -import io.net5.buffer.api.pool.PoolArenaMetric; +import io.netty5.buffer.api.pool.PoolArenaMetric; public class JMXPoolArenaNettyMonitoring implements JMXPoolArenaNettyMonitoringMBean { diff --git a/src/main/java/it/cavallium/dbengine/netty/JMXPooledNettyMonitoring.java b/src/main/java/it/cavallium/dbengine/netty/JMXPooledNettyMonitoring.java index 266d985..b94dad3 100644 --- a/src/main/java/it/cavallium/dbengine/netty/JMXPooledNettyMonitoring.java +++ b/src/main/java/it/cavallium/dbengine/netty/JMXPooledNettyMonitoring.java @@ -1,8 +1,8 @@ package it.cavallium.dbengine.netty; -import io.net5.buffer.api.pool.BufferAllocatorMetric; -import io.net5.buffer.api.pool.PooledBufferAllocator; -import io.net5.buffer.api.pool.PooledBufferAllocatorMetricUtils; +import io.netty5.buffer.api.pool.BufferAllocatorMetric; +import io.netty5.buffer.api.pool.PooledBufferAllocator; +import io.netty5.buffer.api.pool.PooledBufferAllocatorMetricUtils; import java.lang.reflect.Field; public class JMXPooledNettyMonitoring extends JMXNettyMonitoring implements JMXNettyMonitoringMBean { diff --git a/src/main/java/it/cavallium/dbengine/netty/NullableBuffer.java b/src/main/java/it/cavallium/dbengine/netty/NullableBuffer.java index d8f5775..985ebfa 100644 --- a/src/main/java/it/cavallium/dbengine/netty/NullableBuffer.java +++ b/src/main/java/it/cavallium/dbengine/netty/NullableBuffer.java @@ -1,10 +1,10 @@ package it.cavallium.dbengine.netty; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Drop; -import io.net5.buffer.api.Owned; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Drop; +import io.netty5.buffer.api.Owned; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.internal.ResourceSupport; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.jetbrains.annotations.Nullable; diff --git a/src/main/java/org/lmdbjava/Net5ByteBufProxy.java b/src/main/java/org/lmdbjava/Net5ByteBufProxy.java index 7eea25d..e87d1c0 100644 --- a/src/main/java/org/lmdbjava/Net5ByteBufProxy.java +++ b/src/main/java/org/lmdbjava/Net5ByteBufProxy.java @@ -20,15 +20,15 @@ package org.lmdbjava; -import static io.net5.buffer.PooledByteBufAllocator.DEFAULT; +import static io.netty5.buffer.PooledByteBufAllocator.DEFAULT; import static java.lang.Class.forName; import static org.lmdbjava.UnsafeAccess.UNSAFE; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import java.lang.reflect.Field; -import io.net5.buffer.ByteBuf; -import io.net5.buffer.PooledByteBufAllocator; +import io.netty5.buffer.ByteBuf; +import io.netty5.buffer.PooledByteBufAllocator; import jnr.ffi.Pointer; /** @@ -50,7 +50,7 @@ public final class Net5ByteBufProxy extends BufferProxy { private static final int BUFFER_RETRIES = 10; private static final String FIELD_NAME_ADDRESS = "memoryAddress"; private static final String FIELD_NAME_LENGTH = "length"; - private static final String NAME = "io.net5.buffer.PooledUnsafeDirectByteBuf"; + private static final String NAME = "io.netty5.buffer.PooledUnsafeDirectByteBuf"; private final long lengthOffset; private final long addressOffset; diff --git a/src/main/java/org/rocksdb/CappedWriteBatch.java b/src/main/java/org/rocksdb/CappedWriteBatch.java index 259d236..70affa5 100644 --- a/src/main/java/org/rocksdb/CappedWriteBatch.java +++ b/src/main/java/org/rocksdb/CappedWriteBatch.java @@ -3,10 +3,10 @@ package org.rocksdb; import static it.cavallium.dbengine.database.LLUtils.asReadOnlyDirect; import static it.cavallium.dbengine.database.LLUtils.isDirect; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; -import io.net5.buffer.api.Send; -import io.net5.util.internal.PlatformDependent; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.Send; +import io.netty5.util.internal.PlatformDependent; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.disk.RocksDBColumn; import java.nio.ByteBuffer; diff --git a/src/test/java/it/cavallium/dbengine/DbTestUtils.java b/src/test/java/it/cavallium/dbengine/DbTestUtils.java index d0a3ae2..c4e5d52 100644 --- a/src/test/java/it/cavallium/dbengine/DbTestUtils.java +++ b/src/test/java/it/cavallium/dbengine/DbTestUtils.java @@ -2,13 +2,13 @@ package it.cavallium.dbengine; import static org.junit.jupiter.api.Assertions.assertEquals; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.MemoryManager; -import io.net5.buffer.api.Send; -import io.net5.buffer.api.pool.MetricUtils; -import io.net5.buffer.api.pool.PoolArenaMetric; -import io.net5.buffer.api.pool.PooledBufferAllocator; -import io.net5.util.internal.PlatformDependent; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.MemoryManager; +import io.netty5.buffer.api.Send; +import io.netty5.buffer.api.pool.MetricUtils; +import io.netty5.buffer.api.pool.PoolArenaMetric; +import io.netty5.buffer.api.pool.PooledBufferAllocator; +import io.netty5.util.internal.PlatformDependent; import it.cavallium.dbengine.client.LuceneIndex; import it.cavallium.dbengine.client.LuceneIndexImpl; import it.cavallium.dbengine.database.LLDatabaseConnection; diff --git a/src/test/java/it/cavallium/dbengine/SwappableLuceneSearcher.java b/src/test/java/it/cavallium/dbengine/SwappableLuceneSearcher.java index c932d7c..f9275d6 100644 --- a/src/test/java/it/cavallium/dbengine/SwappableLuceneSearcher.java +++ b/src/test/java/it/cavallium/dbengine/SwappableLuceneSearcher.java @@ -3,7 +3,7 @@ package it.cavallium.dbengine; import static java.util.Objects.requireNonNull; import static java.util.Objects.requireNonNullElseGet; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.database.disk.LLIndexSearcher; import it.cavallium.dbengine.database.disk.LLIndexSearchers; import it.cavallium.dbengine.lucene.searcher.GlobalQueryRewrite; diff --git a/src/test/java/it/cavallium/dbengine/TemporaryDbGenerator.java b/src/test/java/it/cavallium/dbengine/TemporaryDbGenerator.java index 3b9ca3a..85e63d1 100644 --- a/src/test/java/it/cavallium/dbengine/TemporaryDbGenerator.java +++ b/src/test/java/it/cavallium/dbengine/TemporaryDbGenerator.java @@ -1,6 +1,6 @@ package it.cavallium.dbengine; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.api.BufferAllocator; import it.cavallium.dbengine.DbTestUtils.TempDb; import it.cavallium.dbengine.DbTestUtils.TestAllocator; import reactor.core.publisher.Mono; diff --git a/src/test/java/it/cavallium/dbengine/TestAllocator.java b/src/test/java/it/cavallium/dbengine/TestAllocator.java index 5b1f9f7..21965c0 100644 --- a/src/test/java/it/cavallium/dbengine/TestAllocator.java +++ b/src/test/java/it/cavallium/dbengine/TestAllocator.java @@ -4,7 +4,7 @@ import static it.cavallium.dbengine.DbTestUtils.destroyAllocator; import static it.cavallium.dbengine.DbTestUtils.ensureNoLeaks; import static it.cavallium.dbengine.DbTestUtils.newAllocator; -import io.net5.buffer.api.Buffer; +import io.netty5.buffer.api.Buffer; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.BeforeEach; diff --git a/src/test/java/it/cavallium/dbengine/TestDictionaryMapDeep.java b/src/test/java/it/cavallium/dbengine/TestDictionaryMapDeep.java index f5b82f5..d916678 100644 --- a/src/test/java/it/cavallium/dbengine/TestDictionaryMapDeep.java +++ b/src/test/java/it/cavallium/dbengine/TestDictionaryMapDeep.java @@ -12,7 +12,7 @@ import static it.cavallium.dbengine.DbTestUtils.tempDictionary; import static it.cavallium.dbengine.SyncUtils.*; import static org.assertj.core.api.Assertions.*; -import io.net5.buffer.api.internal.ResourceSupport; +import io.netty5.buffer.api.internal.ResourceSupport; import it.cavallium.dbengine.DbTestUtils.TestAllocator; import it.cavallium.dbengine.database.LLUtils; import it.cavallium.dbengine.database.UpdateMode; diff --git a/src/test/java/it/cavallium/dbengine/TestLLDictionary.java b/src/test/java/it/cavallium/dbengine/TestLLDictionary.java index c1dd45e..7fd3f07 100644 --- a/src/test/java/it/cavallium/dbengine/TestLLDictionary.java +++ b/src/test/java/it/cavallium/dbengine/TestLLDictionary.java @@ -7,8 +7,8 @@ import static it.cavallium.dbengine.SyncUtils.run; import static it.cavallium.dbengine.SyncUtils.runVoid; import static org.junit.jupiter.api.Assertions.assertEquals; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.DbTestUtils.TempDb; import it.cavallium.dbengine.DbTestUtils.TestAllocator; import it.cavallium.dbengine.database.LLDictionary; diff --git a/src/test/java/it/cavallium/dbengine/TestLLDictionaryLeaks.java b/src/test/java/it/cavallium/dbengine/TestLLDictionaryLeaks.java index f52fff0..0dbd6c0 100644 --- a/src/test/java/it/cavallium/dbengine/TestLLDictionaryLeaks.java +++ b/src/test/java/it/cavallium/dbengine/TestLLDictionaryLeaks.java @@ -7,8 +7,8 @@ import static it.cavallium.dbengine.SyncUtils.*; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertThrows; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.DbTestUtils.TempDb; import it.cavallium.dbengine.DbTestUtils.TestAllocator; import it.cavallium.dbengine.database.LLDictionary; diff --git a/src/test/java/it/cavallium/dbengine/TestLMDB.java b/src/test/java/it/cavallium/dbengine/TestLMDB.java index d3aecbf..43d6830 100644 --- a/src/test/java/it/cavallium/dbengine/TestLMDB.java +++ b/src/test/java/it/cavallium/dbengine/TestLMDB.java @@ -2,7 +2,7 @@ package it.cavallium.dbengine; import static org.junit.jupiter.api.Assertions.assertEquals; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import it.cavallium.dbengine.database.disk.LLTempLMDBEnv; import it.cavallium.dbengine.lucene.LMDBSortedCodec; import it.cavallium.dbengine.lucene.LMDBPriorityQueue; diff --git a/src/test/java/it/cavallium/dbengine/TestLMDBHitQueue.java b/src/test/java/it/cavallium/dbengine/TestLMDBHitQueue.java index 83c925a..64f987e 100644 --- a/src/test/java/it/cavallium/dbengine/TestLMDBHitQueue.java +++ b/src/test/java/it/cavallium/dbengine/TestLMDBHitQueue.java @@ -3,7 +3,7 @@ package it.cavallium.dbengine; import static org.junit.jupiter.api.Assertions.assertEquals; import com.google.common.collect.Lists; -import io.net5.buffer.ByteBuf; +import io.netty5.buffer.ByteBuf; import it.cavallium.dbengine.database.SafeCloseable; import it.cavallium.dbengine.database.disk.LLTempLMDBEnv; import it.cavallium.dbengine.lucene.LLScoreDoc; diff --git a/src/test/java/it/cavallium/dbengine/TestLuceneSearches.java b/src/test/java/it/cavallium/dbengine/TestLuceneSearches.java index f5c1a95..f2f9ee8 100644 --- a/src/test/java/it/cavallium/dbengine/TestLuceneSearches.java +++ b/src/test/java/it/cavallium/dbengine/TestLuceneSearches.java @@ -8,7 +8,7 @@ import static it.cavallium.dbengine.SyncUtils.*; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.fail; -import io.net5.buffer.PooledByteBufAllocator; +import io.netty5.buffer.PooledByteBufAllocator; import it.cavallium.dbengine.DbTestUtils.TempDb; import it.cavallium.dbengine.DbTestUtils.TestAllocator; import it.cavallium.dbengine.client.HitKey; diff --git a/src/test/java/it/cavallium/dbengine/UnsortedUnscoredSimpleMultiSearcher.java b/src/test/java/it/cavallium/dbengine/UnsortedUnscoredSimpleMultiSearcher.java index 999f397..3efa77c 100644 --- a/src/test/java/it/cavallium/dbengine/UnsortedUnscoredSimpleMultiSearcher.java +++ b/src/test/java/it/cavallium/dbengine/UnsortedUnscoredSimpleMultiSearcher.java @@ -3,7 +3,7 @@ package it.cavallium.dbengine; import static it.cavallium.dbengine.client.UninterruptibleScheduler.uninterruptibleScheduler; import static it.cavallium.dbengine.lucene.searcher.GlobalQueryRewrite.NO_REWRITE; -import io.net5.buffer.api.Send; +import io.netty5.buffer.api.Send; import it.cavallium.dbengine.client.query.current.data.TotalHitsCount; import it.cavallium.dbengine.database.LLKeyScore; import it.cavallium.dbengine.database.LLUtils; diff --git a/src/test/java/it/cavallium/dbengine/database/collections/TestRanges.java b/src/test/java/it/cavallium/dbengine/database/collections/TestRanges.java index eeb7c66..a2c93ee 100644 --- a/src/test/java/it/cavallium/dbengine/database/collections/TestRanges.java +++ b/src/test/java/it/cavallium/dbengine/database/collections/TestRanges.java @@ -1,15 +1,15 @@ package it.cavallium.dbengine.database.collections; -import io.net5.buffer.Unpooled; -import io.net5.buffer.api.Buffer; -import io.net5.buffer.api.BufferAllocator; +import io.netty5.buffer.Unpooled; +import io.netty5.buffer.api.Buffer; +import io.netty5.buffer.api.BufferAllocator; import it.cavallium.dbengine.database.LLUtils; import java.util.Arrays; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.Test; -import static io.net5.buffer.Unpooled.*; +import static io.netty5.buffer.Unpooled.*; public class TestRanges {