patch for concurrent uploads
git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngineSmartExecutor@114756 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
parent
747b23f636
commit
f9c1eff739
|
@ -594,13 +594,16 @@ public class QueueJobManager {
|
||||||
AnalysisLogger.getLogger().info("Unnecessary to Uploading Files");
|
AnalysisLogger.getLogger().info("Unnecessary to Uploading Files");
|
||||||
|
|
||||||
AnalysisLogger.getLogger().info("Loading files");
|
AnalysisLogger.getLogger().info("Loading files");
|
||||||
|
//patch for concurrent uploads
|
||||||
|
String tempdir = ""+UUID.randomUUID()+"/";
|
||||||
for (File sfile : files) {
|
for (File sfile : files) {
|
||||||
if (sfile.getName().startsWith("."))
|
if (sfile.getName().startsWith("."))
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
String localf = sfile.getAbsolutePath();
|
String localf = sfile.getAbsolutePath();
|
||||||
String filename = sfile.getName();
|
String filename = sfile.getName();
|
||||||
String remotef = remoteDir + sfile.getName();
|
|
||||||
|
String remotef = remoteDir + tempdir+sfile.getName();
|
||||||
if (uploadFiles) {
|
if (uploadFiles) {
|
||||||
client.put(true).LFile(localf).RFile(remotef);
|
client.put(true).LFile(localf).RFile(remotef);
|
||||||
AnalysisLogger.getLogger().info("Uploading File "+localf+" as remote file "+remotef);
|
AnalysisLogger.getLogger().info("Uploading File "+localf+" as remote file "+remotef);
|
||||||
|
|
Loading…
Reference in New Issue