diff --git a/pom.xml b/pom.xml index 26e3797..1c09f5e 100644 --- a/pom.xml +++ b/pom.xml @@ -291,7 +291,7 @@ org.warp common-utils - 1.1.5 + 1.1.6 io.net5 diff --git a/src/main/java/it/cavallium/dbengine/database/LLDictionary.java b/src/main/java/it/cavallium/dbengine/database/LLDictionary.java index 14ae768..e865b5a 100644 --- a/src/main/java/it/cavallium/dbengine/database/LLDictionary.java +++ b/src/main/java/it/cavallium/dbengine/database/LLDictionary.java @@ -10,12 +10,10 @@ import java.util.List; import java.util.Optional; import java.util.function.Function; import org.jetbrains.annotations.Nullable; -import org.warp.commonutils.concurrency.atomicity.NotAtomic; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; @SuppressWarnings("unused") -@NotAtomic public interface LLDictionary extends LLKeyValueDatabaseStructure { String getColumnName(); 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 fa9fe5b..6691c38 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java @@ -57,7 +57,6 @@ import org.rocksdb.Slice; import org.rocksdb.Snapshot; import org.rocksdb.WriteBatch; import org.rocksdb.WriteOptions; -import org.warp.commonutils.concurrency.atomicity.NotAtomic; import org.warp.commonutils.log.Logger; import org.warp.commonutils.log.LoggerFactory; import reactor.core.publisher.Flux; @@ -69,7 +68,6 @@ import reactor.util.function.Tuple3; import reactor.util.function.Tuple4; import reactor.util.function.Tuples; -@NotAtomic public class LLLocalDictionary implements LLDictionary { protected static final Logger logger = LoggerFactory.getLogger(LLLocalDictionary.class); diff --git a/src/main/java/it/cavallium/dbengine/database/serialization/CodecsArray.java b/src/main/java/it/cavallium/dbengine/database/serialization/CodecsArray.java index 1bd5432..c992646 100644 --- a/src/main/java/it/cavallium/dbengine/database/serialization/CodecsArray.java +++ b/src/main/java/it/cavallium/dbengine/database/serialization/CodecsArray.java @@ -1,8 +1,5 @@ package it.cavallium.dbengine.database.serialization; -import org.warp.commonutils.concurrency.atomicity.NotAtomic; - -@NotAtomic public class CodecsArray implements Codecs { private final Codec[] codecs; diff --git a/src/main/java/it/cavallium/dbengine/database/serialization/CodecsStandard.java b/src/main/java/it/cavallium/dbengine/database/serialization/CodecsStandard.java index 2162f67..ec126b8 100644 --- a/src/main/java/it/cavallium/dbengine/database/serialization/CodecsStandard.java +++ b/src/main/java/it/cavallium/dbengine/database/serialization/CodecsStandard.java @@ -2,9 +2,7 @@ package it.cavallium.dbengine.database.serialization; import it.unimi.dsi.fastutil.ints.Int2ObjectMap; import it.unimi.dsi.fastutil.ints.Int2ObjectOpenHashMap; -import org.warp.commonutils.concurrency.atomicity.NotAtomic; -@NotAtomic public class CodecsStandard implements Codecs { private final Int2ObjectMap> codecs; diff --git a/src/main/java/org/rocksdb/CappedWriteBatch.java b/src/main/java/org/rocksdb/CappedWriteBatch.java index b8f96c1..5a3f4de 100644 --- a/src/main/java/org/rocksdb/CappedWriteBatch.java +++ b/src/main/java/org/rocksdb/CappedWriteBatch.java @@ -12,9 +12,7 @@ import it.cavallium.dbengine.database.disk.RocksDBColumn; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.List; -import org.warp.commonutils.concurrency.atomicity.NotAtomic; -@NotAtomic public class CappedWriteBatch extends WriteBatch { /**