Specify chunk size when splitting.

This commit is contained in:
CalDescent 2021-06-22 07:44:34 +01:00
parent 1613375cc0
commit 808b36e088
2 changed files with 4 additions and 3 deletions

View File

@ -110,7 +110,7 @@ public class DataResource {
} }
LOGGER.info("Whole file digest: {}", dataFile.base58Digest()); LOGGER.info("Whole file digest: {}", dataFile.base58Digest());
int chunkCount = dataFile.split(); int chunkCount = dataFile.split(DataFile.CHUNK_SIZE);
if (chunkCount > 0) { if (chunkCount > 0) {
LOGGER.info(String.format("Successfully split into %d chunk%s", chunkCount, (chunkCount == 1 ? "" : "s"))); LOGGER.info(String.format("Successfully split into %d chunk%s", chunkCount, (chunkCount == 1 ? "" : "s")));
return "true"; return "true";
@ -146,7 +146,7 @@ public class DataResource {
} }
LOGGER.info("Whole file digest: {}", dataFile.base58Digest()); LOGGER.info("Whole file digest: {}", dataFile.base58Digest());
int chunkCount = dataFile.split(); int chunkCount = dataFile.split(DataFile.CHUNK_SIZE);
if (chunkCount > 0) { if (chunkCount > 0) {
LOGGER.info(String.format("Successfully split into %d chunk%s", chunkCount, (chunkCount == 1 ? "" : "s"))); LOGGER.info(String.format("Successfully split into %d chunk%s", chunkCount, (chunkCount == 1 ? "" : "s")));
return "true"; return "true";

View File

@ -170,10 +170,11 @@ public class DataFile {
} }
public int split() { public int split() {
public int split(int chunkSize) {
try { try {
File file = this.getFile(); File file = this.getFile();
byte[] buffer = new byte[CHUNK_SIZE]; byte[] buffer = new byte[chunkSize];
this.chunks = new ArrayList<>(); this.chunks = new ArrayList<>();
if (file != null) { if (file != null) {