broken
parent
3f23240ded
commit
2aea192c1a
|
@ -30,6 +30,9 @@ public class ChunkedCompressedChecksumFileReader {
|
||||||
public FileHeader readChunk(Tracer trace, Span sp) throws IOException {
|
public FileHeader readChunk(Tracer trace, Span sp) throws IOException {
|
||||||
Span gf = trace.spanBuilder("Chunk Read").startSpan();
|
Span gf = trace.spanBuilder("Chunk Read").startSpan();
|
||||||
FileHeader header = readHeader();
|
FileHeader header = readHeader();
|
||||||
|
gf.setAttribute("Read Uncompressed", header.getUncompressed());
|
||||||
|
gf.setAttribute("Read Compressed", header.getCompressed());
|
||||||
|
gf.setAttribute("Read Hash", header.getHash());
|
||||||
try (Scope scope = gf.makeCurrent()) {
|
try (Scope scope = gf.makeCurrent()) {
|
||||||
if (header.getUncompressed() == 0)
|
if (header.getUncompressed() == 0)
|
||||||
return header;
|
return header;
|
||||||
|
|
|
@ -19,7 +19,7 @@ import java.util.concurrent.TimeUnit;
|
||||||
public class FileUtil {
|
public class FileUtil {
|
||||||
|
|
||||||
// do not change it breaks stuff
|
// do not change it breaks stuff
|
||||||
protected static final int READER_SIZE = 8192;
|
protected static final int READER_SIZE = 131072;
|
||||||
public static final long SEED = 691;
|
public static final long SEED = 691;
|
||||||
|
|
||||||
private static final LZ4Factory LZ_FACTORY = LZ4Factory.fastestInstance();
|
private static final LZ4Factory LZ_FACTORY = LZ4Factory.fastestInstance();
|
||||||
|
|
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Loading…
Reference in New Issue