summaryrefslogtreecommitdiffstats
path: root/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/AsyncHashGenerator.java
diff options
context:
space:
mode:
Diffstat (limited to 'dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/AsyncHashGenerator.java')
-rw-r--r--dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/AsyncHashGenerator.java7
1 files changed, 7 insertions, 0 deletions
diff --git a/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/AsyncHashGenerator.java b/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/AsyncHashGenerator.java
index 8ef12e12..07efc449 100644
--- a/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/AsyncHashGenerator.java
+++ b/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/AsyncHashGenerator.java
@@ -57,6 +57,8 @@ public class AsyncHashGenerator extends Thread {
private AtomicInteger pendingHashes = new AtomicInteger();
private volatile boolean isCanceled = false;
+
+ private AtomicInteger completeCount = new AtomicInteger();
static {
LOGGER.info("Using " + HASH_WORK_POOL.getMaximumPoolSize() + " hash workers.");
@@ -225,6 +227,7 @@ public class AsyncHashGenerator extends Thread {
wasLastChunk = true;
}
}
+ completeCount.set(finishedChunks);
}
if (chunkIndex + 1 == chunkList.size()) {
LOGGER.debug("Hashed last chunk #" + chunkIndex + ", total=" + chunkList.size() + ", finished=" + finishedChunks);
@@ -320,4 +323,8 @@ public class AsyncHashGenerator extends Thread {
return true;
}
+ public AtomicInteger getCompleteCounter() {
+ return completeCount;
+ }
+
}