andreacavalli
/
data-generator
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Optimization

This commit is contained in:
Andrea Cavalli 2023-03-27 23:30:34 +02:00
parent bc34559de0
commit 9da2c8f5d9
1 changed files with 12 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
data-generator-runtime/src/main/java/it/cavallium/stream/SafeDataInputStream.java
View File

@ -25,10 +25,6 @@
package it.cavallium.stream; package it.cavallium.stream;
import java.nio.ByteBuffer;
import java.nio.charset.CharacterCodingException;
import java.nio.charset.CharsetDecoder;
import java.nio.charset.CodingErrorAction;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
@ -45,11 +41,9 @@ public class SafeDataInputStream extends SafeFilterInputStream implements SafeDa
} }
/** /**
* working arrays initialized on demand by readUTF * working data initialized on demand by readUTF
*/ */
private byte[] bytearr; private byte[] bytearr;
private char[] chararr;
private CharsetDecoder utfdec;
@Override @Override
public final int read(byte[] b) { public final int read(byte[] b) {
@ -454,18 +448,18 @@ public class SafeDataInputStream extends SafeFilterInputStream implements SafeDa
* @see SafeDataInputStream#readUnsignedShort() * @see SafeDataInputStream#readUnsignedShort()
*/ */
public static String readUTF(SafeDataInputStream in) { public static String readUTF(SafeDataInputStream in) {
if (in.bytearr == null) in.bytearr = new byte[80];
if (in.chararr == null) in.chararr = new char[80];
if (in.utfdec == null) in.utfdec = StandardCharsets.UTF_8.newDecoder()
.onUnmappableCharacter(CodingErrorAction.REPORT)
.onMalformedInput(CodingErrorAction.REPORT);
int utflen = in.readUnsignedShort(); int utflen = in.readUnsignedShort();
var data = new byte[utflen]; byte[] data;
in.readFully(data); if (utflen <= 80) {
try { if (in.bytearr == null) {
return in.utfdec.reset().decode(ByteBuffer.wrap(data)).toString(); data = in.bytearr = new byte[80];
} catch (CharacterCodingException e) { } else {
throw new IllegalArgumentException("malformed input string", e); data = in.bytearr;
}
} else {
data = new byte[utflen];
} }
in.readFully(data, 0, utflen);
return new String(data, StandardCharsets.UTF_8);
} }
} }