Jika/oc2r
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compress blob storage entries.

Browse Source
This commit is contained in:
Florian Nücke
2020-12-15 04:19:14 +01:00
parent a29015324e
commit dd6e60a675
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/li/cil/oc2/common/serialization/BlobStorage.java
View File

@@ -21,6 +21,8 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;
/**
* This class facilitates storing binary chunks of data in an efficient, parallelized fashion.
@@ -234,7 +236,9 @@ public final class BlobStorage {
try {
final Path path = dataDirectory.resolve(handle.toString());
try (final OutputStream output = Files.newOutputStream(path, StandardOpenOption.CREATE, StandardOpenOption.TRUNCATE_EXISTING)) {
copyData(input, output);
final GZIPOutputStream zipped = new GZIPOutputStream(output);
copyData(input, zipped);
zipped.finish();
}
} catch (final Throwable e) {
LOGGER.error(e);
@@ -253,8 +257,9 @@ public final class BlobStorage {
if (!Files.exists(path)) {
return;
}
try (final InputStream input = Files.newInputStream(path, StandardOpenOption.CREATE, StandardOpenOption.TRUNCATE_EXISTING)) {
copyData(input, output);
try (final InputStream input = Files.newInputStream(path, StandardOpenOption.READ)) {
final GZIPInputStream zipped = new GZIPInputStream(input);
copyData(zipped, output);
}
} catch (final Throwable e) {
LOGGER.error(e);