diff options
author | Simon Rettberg | 2022-03-22 11:21:54 +0100 |
---|---|---|
committer | Simon Rettberg | 2022-03-22 11:21:54 +0100 |
commit | 499d11c1718ebc5807c0a054fa99ad1027a2baea (patch) | |
tree | afb2b741acaf906e5f53e6a0ff9cc82dade54dfe /dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/AsyncHashGenerator.java | |
parent | [client] Fix closing upload activity panel (diff) | |
download | tutor-module-499d11c1718ebc5807c0a054fa99ad1027a2baea.tar.gz tutor-module-499d11c1718ebc5807c0a054fa99ad1027a2baea.tar.xz tutor-module-499d11c1718ebc5807c0a054fa99ad1027a2baea.zip |
[client] Show local unhashed vs. hashed chunks in detailed progress view
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.java | 7 |
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; + } + } |