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/UploadTask.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/UploadTask.java')
-rw-r--r-- | dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/UploadTask.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/UploadTask.java b/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/UploadTask.java index 84b9b47a..fc13f113 100644 --- a/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/UploadTask.java +++ b/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/UploadTask.java @@ -157,6 +157,8 @@ public class UploadTask extends TransferTask { private long virtualSpeed = 0; private long nextQueryDebug; + private AtomicInteger hashCompleteCounter; + @Override protected TransferEvent getTransferEvent() { final long now = System.currentTimeMillis(); @@ -206,7 +208,8 @@ public class UploadTask extends TransferTask { if (transferConnectionError != null && (error == null || transferConnectionError.equals("Out of disk space"))) { error = transferConnectionError; } - TransferEvent event = new TransferEvent(state, blocks, speed, virtualSpeed, timeRemaining, error); + TransferEvent event = new TransferEvent(state, blocks, speed, virtualSpeed, timeRemaining, error, + hashCompleteCounter.get()); return event; } @@ -214,4 +217,8 @@ public class UploadTask extends TransferTask { protected TransferThread createNewThread() { return new UploadThread(); } + + public void setHashCounter(AtomicInteger completeCounter) { + this.hashCompleteCounter = completeCounter; + } } |