summaryrefslogtreecommitdiffstats
path: root/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/UploadTask.java
diff options
context:
space:
mode:
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.java9
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;
+ }
}