Make AbstractTransferWorker thread safe.

iterate-ch · Jul 5, 2018 · e63970a · e63970a
1 parent 884ab2b
commit e63970a
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/core/src/main/java/ch/cyberduck/core/worker/AbstractTransferWorker.java b/core/src/main/java/ch/cyberduck/core/worker/AbstractTransferWorker.java
@@ -53,9 +53,9 @@
 import org.apache.log4j.Logger;
 
 import java.text.MessageFormat;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.Future;
 
 public abstract class AbstractTransferWorker extends TransferWorker<Boolean> {
@@ -106,7 +106,7 @@ public AbstractTransferWorker(final Transfer transfer, final TransferOptions opt
                                   final ConnectionCallback connectionCallback, final PasswordCallback passwordCallback,
                                   final NotificationService notification,
                                   final Cache<TransferItem> cache) {
-        this(transfer, options, prompt, meter, error, progress, stream, connectionCallback, passwordCallback, notification, cache, new HashMap<TransferItem, TransferStatus>());
+        this(transfer, options, prompt, meter, error, progress, stream, connectionCallback, passwordCallback, notification, cache, new ConcurrentHashMap<TransferItem, TransferStatus>());
     }
 
     public AbstractTransferWorker(final Transfer transfer, final TransferOptions options,
@@ -220,8 +220,8 @@ public void message(final String message) {
             transfer.post(source, destination, table, connectionCallback);
             if(transfer.isReset()) {
                 notification.notify(transfer.isComplete() ?
-                        String.format("%s complete", StringUtils.capitalize(transfer.getType().name())) :
-                        "Transfer incomplete", transfer.getName());
+                    String.format("%s complete", StringUtils.capitalize(transfer.getType().name())) :
+                    "Transfer incomplete", transfer.getName());
             }
             sleep.release(lock);
             table.clear();