[airavata-mft] branch master updated: Using random path for chunk files

[dimuthuupe]

This is an automated email from the ASF dual-hosted git repository.

dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata-mft.git


The following commit(s) were added to refs/heads/master by this push:
     new c2311f7  Using random path for chunk files
c2311f7 is described below

commit c2311f74a13e385da6fbf79a783656bc2ae61bfb
Author: DImuthuUpe <dimuthu.upeks...@gmail.com>
AuthorDate: Tue Mar 7 09:55:32 2023 -0500

    Using random path for chunk files
---
 .../src/main/java/org/apache/airavata/mft/agent/TransportMediator.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/agent/service/src/main/java/org/apache/airavata/mft/agent/TransportMediator.java
 
b/agent/service/src/main/java/org/apache/airavata/mft/agent/TransportMediator.java
index f009772..b67298d 100644
--- 
a/agent/service/src/main/java/org/apache/airavata/mft/agent/TransportMediator.java
+++ 
b/agent/service/src/main/java/org/apache/airavata/mft/agent/TransportMediator.java
@@ -30,6 +30,7 @@ import java.io.File;
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.util.Optional;
+import java.util.UUID;
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicLong;
@@ -277,7 +278,7 @@ public class TransportMediator {
                     InputStream inputStream = 
downloader.downloadChunk(chunkIdx, startPos, endPos);
                     uploader.uploadChunk(chunkIdx, startPos, endPos, 
inputStream);
                 } else {
-                    String tempFile = tempDataDir + File.separator + 
transferId + "-" + chunkIdx;
+                    String tempFile = tempDataDir + File.separator + 
UUID.randomUUID().toString() + "-" + chunkIdx;
                     downloader.downloadChunk(chunkIdx, startPos, endPos, 
tempFile);
                     uploader.uploadChunk(chunkIdx, startPos, endPos, tempFile);
                     new File(tempFile).delete();