Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 5 additions & 6 deletions dump/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -14,10 +14,11 @@

<dependencies>
<dependency>
<groupId>com.google.code.findbugs</groupId>
<artifactId>jsr305</artifactId>
<version>3.0.2</version>
<groupId>org.jspecify</groupId>
<artifactId>jspecify</artifactId>
<version>1.0.0</version>
</dependency>

<dependency>
<groupId>net.sf.trove4j</groupId>
<artifactId>trove4j</artifactId>
Expand All @@ -37,10 +38,8 @@
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>33.2.1-jre</version>
<version>33.5.0-jre</version>
</dependency>

</dependencies>

</project>

49 changes: 24 additions & 25 deletions dump/src/util/dump/Dump.java
Original file line number Diff line number Diff line change
Expand Up @@ -40,9 +40,8 @@
import java.util.stream.Stream;
import java.util.stream.StreamSupport;

import javax.annotation.Nonnull;
import javax.annotation.Nullable;

import org.jspecify.annotations.NonNull;
import org.jspecify.annotations.Nullable;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

Expand Down Expand Up @@ -612,7 +611,7 @@ public File getDumpFile() {
return _dumpFile;
}

@Nonnull
@NonNull
public DumpReader<E> getDumpReader() {
assertOpen();
try {
Expand Down Expand Up @@ -659,7 +658,7 @@ public boolean isClosed() {
*/
@SuppressWarnings("resource")
@Override
@Nonnull
@NonNull
public DumpIterator<E> iterator() {
assertOpen();
try {
Expand Down Expand Up @@ -1100,21 +1099,6 @@ private void appendNextItemPos( byte[] bytes, byte[] nextItemPos ) {
}
}

private int getVersionFromDump() {
String dumpVersionString = _metaData.get("externalizationVersion");
return dumpVersionString == null ? 0 : Integer.parseInt(dumpVersionString);
}

private int getVersionFromCode() {
externalizationVersion version = _beanClass.getAnnotation(externalizationVersion.class);
return version == null ? 0 : version.version();
}

private ExternalizableBean.OnIncompatibleVersion getOnIncompatibleVersion() {
externalizationVersion version = _beanClass.getAnnotation(externalizationVersion.class);
return version == null ? ExternalizableBean.OnIncompatibleVersion.RenameDump : version.onIncompatibleVersion();
}

private void checkVersion() throws IOException {
int codeVersion = getVersionFromCode();
int dumpVersion = getVersionFromDump();
Expand Down Expand Up @@ -1199,6 +1183,21 @@ private long getNextItemPos( byte[] bytes ) {
return l;
}

private ExternalizableBean.OnIncompatibleVersion getOnIncompatibleVersion() {
externalizationVersion version = _beanClass.getAnnotation(externalizationVersion.class);
return version == null ? ExternalizableBean.OnIncompatibleVersion.RenameDump : version.onIncompatibleVersion();
}

private int getVersionFromCode() {
externalizationVersion version = _beanClass.getAnnotation(externalizationVersion.class);
return version == null ? 0 : version.version();
}

private int getVersionFromDump() {
String dumpVersionString = _metaData.get("externalizationVersion");
return dumpVersionString == null ? 0 : Integer.parseInt(dumpVersionString);
}

private void initInstantiationData() {
StringWriter sw = new StringWriter();
PrintWriter pw = new PrintWriter(sw);
Expand Down Expand Up @@ -1290,7 +1289,7 @@ public ElementAndPosition( D element, long position ) {
}

@Override
public int compareTo( @Nonnull ElementAndPosition<D> o ) {
public int compareTo( @NonNull ElementAndPosition<D> o ) {
return Long.compare(_position, o._position);
}

Expand Down Expand Up @@ -1332,13 +1331,13 @@ public void flush() throws IOException {
}

@Override
public void write( @Nonnull byte[] b ) throws IOException {
public void write( @NonNull byte[] b ) throws IOException {
_out.write(b);
_n += b.length;
}

@Override
public void write( @Nonnull byte[] b, int off, int len ) throws IOException {
public void write( @NonNull byte[] b, int off, int len ) throws IOException {
_out.write(b, off, len);
_n += len;
}
Expand Down Expand Up @@ -1553,7 +1552,7 @@ public boolean markSupported() {
* or an I/O error occurs.
*/
@Override
public/*synchronized*/int read( @Nonnull byte[] b, int off, int len ) throws IOException {
public/*synchronized*/int read( @NonNull byte[] b, int off, int len ) throws IOException {
// we don't share instances of this class or synchronize access on a different level, so this method is not synchronized
getBufIfOpen(); // Check for closed stream
if ( (off | len | (off + len) | (b.length - (off + len))) < 0 ) {
Expand Down Expand Up @@ -1773,7 +1772,7 @@ public boolean hasNext() {
}

@Override
@Nonnull
@NonNull
public DumpIterator<E> iterator() {
return this;
}
Expand Down
7 changes: 3 additions & 4 deletions dump/src/util/dump/DumpReader.java
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,8 @@
import java.io.OptionalDataException;
import java.util.Iterator;

import javax.annotation.Nonnull;
import javax.annotation.Nullable;

import org.jspecify.annotations.NonNull;
import org.jspecify.annotations.Nullable;
import util.dump.stream.ExternalizableObjectStreamProvider;
import util.dump.stream.ObjectStreamProvider;

Expand Down Expand Up @@ -169,7 +168,7 @@ public boolean hasNext() {
}

@Override
public @Nonnull Iterator<E> iterator() {
public @NonNull Iterator<E> iterator() {
return this;
}

Expand Down
3 changes: 1 addition & 2 deletions dump/src/util/dump/DumpWriter.java
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,7 @@
import java.io.OutputStream;
import java.lang.reflect.Method;

import javax.annotation.Nullable;

import org.jspecify.annotations.Nullable;
import util.dump.stream.ExternalizableObjectStreamProvider;
import util.dump.stream.ObjectStreamProvider;

Expand Down
9 changes: 4 additions & 5 deletions dump/src/util/dump/ExternalizationHelper.java
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,7 @@
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;

import javax.annotation.Nonnull;

import org.jspecify.annotations.NonNull;
import org.slf4j.LoggerFactory;

import util.dump.ExternalizableBean.externalizationPadding;
Expand Down Expand Up @@ -853,7 +852,7 @@ static void writeUUID( ObjectOutput out, UUID uuid ) throws IOException {
}
}

@Nonnull
@NonNull
private static ThrowingSupplier<Object> getGenericReader( ObjectInput in, Class genericType, ClassConfig config, Class[] lastNonDefaultClass ) {
if ( Externalizable.class.isAssignableFrom(genericType) ) {
return () -> readExternalizable(in, genericType, lastNonDefaultClass, config);
Expand Down Expand Up @@ -1099,7 +1098,7 @@ public int size() {
}

@Override
public void write( @Nonnull byte[] bytes, int start, int length ) {
public void write( @NonNull byte[] bytes, int start, int length ) {
if ( (start < 0) || (start > bytes.length) || (length < 0) || (start + length > bytes.length) || (start + length < 0) ) {
throw new IndexOutOfBoundsException();
}
Expand Down Expand Up @@ -1462,7 +1461,7 @@ static class FieldInfo implements Comparable<FieldInfo> {
Class _defaultGenericType1;

@Override
public int compareTo( @Nonnull FieldInfo o ) {
public int compareTo( @NonNull FieldInfo o ) {
int fieldIndex = _fieldIndex & 0xFF;
int otherFieldIndex = o._fieldIndex & 0xFF;
return Integer.compare(fieldIndex, otherFieldIndex);
Expand Down
13 changes: 6 additions & 7 deletions dump/src/util/dump/sort/InfiniteSorter.java
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,8 @@
import java.util.Iterator;
import java.util.List;

import javax.annotation.Nonnull;
import javax.annotation.Nullable;

import org.jspecify.annotations.NonNull;
import org.jspecify.annotations.Nullable;
import util.dump.Dump;
import util.dump.DumpInput;
import util.dump.DumpReader;
Expand Down Expand Up @@ -81,7 +80,7 @@ public InfiniteSorter() {
init(DEFAULT_MAX_ELEMENTS_IN_MEMORY, -1, null, TempFileProvider.DEFAULT_PROVIDER);
}

public InfiniteSorter( @Nonnull File tempDir ) {
public InfiniteSorter( @NonNull File tempDir ) {
init(DEFAULT_MAX_ELEMENTS_IN_MEMORY, -1, null, new TempFileProvider(tempDir));
}

Expand All @@ -93,11 +92,11 @@ public InfiniteSorter( int maxElementsInMemory, int bufferSize ) {
init(maxElementsInMemory, bufferSize, null, TempFileProvider.DEFAULT_PROVIDER);
}

public InfiniteSorter( int maxElementsInMemory, int bufferSize, @Nonnull File tempDir ) {
public InfiniteSorter( int maxElementsInMemory, int bufferSize, @NonNull File tempDir ) {
init(maxElementsInMemory, -1, null, new TempFileProvider(tempDir));
}

public InfiniteSorter( int maxElementsInMemory, int bufferSize, @Nonnull File tempDir, @Nullable ObjectStreamProvider objectStreamProvider,
public InfiniteSorter( int maxElementsInMemory, int bufferSize, @NonNull File tempDir, @Nullable ObjectStreamProvider objectStreamProvider,
@Nullable Comparator<E> comparator ) {
init(maxElementsInMemory, bufferSize, comparator, new TempFileProvider(tempDir));
this._objectStreamProvider = objectStreamProvider;
Expand Down Expand Up @@ -198,7 +197,7 @@ public TempFileProvider getTempFileProvider() {
return _tempFileProvider;
}

public @Nonnull Iterator<E> iterator() {
public @NonNull Iterator<E> iterator() {
try {
return getSortedElements().iterator();
}
Expand Down
7 changes: 3 additions & 4 deletions dump/src/util/dump/sort/SortedInputMerger.java
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,8 @@
import java.util.List;
import java.util.NoSuchElementException;

import javax.annotation.Nonnull;
import javax.annotation.Nullable;

import org.jspecify.annotations.NonNull;
import org.jspecify.annotations.Nullable;
import util.dump.DumpInput;
import util.dump.DumpReader;

Expand Down Expand Up @@ -146,7 +145,7 @@ public boolean hasNext() {
}

@Override
public @Nonnull Iterator<E> iterator() {
public @NonNull Iterator<E> iterator() {
return this;
}

Expand Down
3 changes: 2 additions & 1 deletion dump/src/util/dump/stream/AesCrypter.java
Original file line number Diff line number Diff line change
Expand Up @@ -7,13 +7,14 @@
import java.security.SecureRandom;
import java.security.spec.AlgorithmParameterSpec;

import javax.annotation.Nullable;
import javax.crypto.Cipher;
import javax.crypto.NoSuchPaddingException;
import javax.crypto.SecretKey;
import javax.crypto.spec.GCMParameterSpec;
import javax.crypto.spec.SecretKeySpec;

import org.jspecify.annotations.Nullable;


public class AesCrypter implements ByteArrayPacker {

Expand Down
2 changes: 1 addition & 1 deletion dump/src/util/dump/stream/ByteArrayPacker.java
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
import java.io.Externalizable;
import java.io.IOException;

import javax.annotation.Nullable;
import org.jspecify.annotations.Nullable;


public interface ByteArrayPacker {
Expand Down
3 changes: 1 addition & 2 deletions dump/src/util/dump/stream/Compression.java
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,6 @@
import java.util.Map;
import java.util.zip.GZIPInputStream;

import javax.annotation.Nullable;

import com.github.luben.zstd.Zstd;
import com.github.luben.zstd.ZstdDictCompress;
import com.github.luben.zstd.ZstdDictDecompress;
Expand All @@ -21,6 +19,7 @@
import net.jpountz.lz4.LZ4Compressor;
import net.jpountz.lz4.LZ4Factory;
import net.jpountz.lz4.LZ4FastDecompressor;
import org.jspecify.annotations.Nullable;
import util.dump.cache.LRUCache;
import util.dump.io.IOUtils;

Expand Down
5 changes: 2 additions & 3 deletions dump/test/util/dump/InfiniteSorterTest.java
Original file line number Diff line number Diff line change
@@ -1,11 +1,10 @@
package util.dump;

import javax.annotation.Nonnull;

import java.io.File;
import java.io.IOException;

import junit.framework.Assert;
import org.jspecify.annotations.NonNull;

import org.junit.Test;

Expand Down Expand Up @@ -91,7 +90,7 @@ public Bean( long id ) {
}

@Override
public int compareTo( @Nonnull Bean o ) {
public int compareTo( @NonNull Bean o ) {
return (Long.compare(_id, o._id));
}
}
Expand Down
7 changes: 6 additions & 1 deletion dumpsearch/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,12 @@
</parent>

<dependencies>
<dependency>
<groupId>org.jspecify</groupId>
<artifactId>jspecify</artifactId>
<version>1.0.0</version>
</dependency>

<dependency>
<groupId>mkr</groupId>
<artifactId>util-dump</artifactId>
Expand Down Expand Up @@ -44,6 +50,5 @@
<version>8.4.0</version>
</dependency>
</dependencies>

</project>

Loading