gCubeSystem
/
dataminer-pool-manager
15
0
Fork 0
Code Issues Pull Requests Releases 2 Wiki Activity

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/dataminer-pool-manager@157810 82a268e6-3cf1-43bd-a215-b396298e98cf

This commit is contained in:
Nunzio Andrea Galante 2017-10-27 21:30:20 +00:00
parent f00127bc61
commit 56c111f010
3 changed files with 36 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/StagingJob.java
View File

@ -85,7 +85,7 @@ public class StagingJob extends DMPMJob ***REMOVED***
b.deleteFiles(this.algorithm/*, env*/);; b.deleteFiles(this.algorithm/*, env*/);;
int ret = this.executeAnsibleWorker(createWorker(this.algorithm, this.stagingCluster, false, "root")); int ret = this.executeAnsibleWorker(createWorker(this.algorithm, this.stagingCluster, false, "root"));
System.out.println("Return code= "+ret);
if (ret != 0) ***REMOVED*** if (ret != 0) ***REMOVED***
this.getStatus(2); this.getStatus(2);
@ -100,7 +100,7 @@ public class StagingJob extends DMPMJob ***REMOVED***
***REMOVED***System.out.println("2 - Checking existing in env: "+ this.env); ***REMOVED***System.out.println("2 - Checking existing in env: "+ this.env);
if (b.checkMethod(a.getStagingHost(), SecurityTokenProvider.instance.get())&&(b.algoExists(this.algorithm/*, env*/))) ***REMOVED*** if (b.checkMethod(a.getStagingHost(), SecurityTokenProvider.instance.get())&&(b.algoExists(this.algorithm))) ***REMOVED***
System.out.println("Interface check ok!"); System.out.println("Interface check ok!");
System.out.println("Both the files exist at the correct path!"); System.out.println("Both the files exist at the correct path!");

40
src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/CheckMethod.java
View File

@ -13,7 +13,7 @@ import java.util.LinkedList;
***REMOVED*** ***REMOVED***
import java.util.Vector; import java.util.Vector;
***REMOVED***
***REMOVED*** ***REMOVED***
import com.jcraft.jsch.Channel; import com.jcraft.jsch.Channel;
@ -78,15 +78,18 @@ public class CheckMethod ***REMOVED***
***REMOVED*** ***REMOVED***
***REMOVED*** ***REMOVED***
***REMOVED*** ***REMOVED***
fileWriter.close(); fileWriter.close();
return true;
***REMOVED*** catch (Exception a) ***REMOVED*** ***REMOVED*** catch (Exception a) ***REMOVED***
a.getMessage(); a.getMessage();
return false; return false;
***REMOVED*** ***REMOVED***
return true;
***REMOVED*** ***REMOVED***
public boolean algoExists(Algorithm a/*, String env*/) throws Exception***REMOVED*** public boolean algoExists(Algorithm a/*, String env*/) throws Exception***REMOVED***
ServiceConfiguration p = new ServiceConfiguration(); ServiceConfiguration p = new ServiceConfiguration();
@ -101,6 +104,7 @@ public class CheckMethod ***REMOVED***
if ((this.doesExist(file.getPath()/*,env*/)) && (this.doesExist(file2.getPath()/*,env*/)))***REMOVED*** if ((this.doesExist(file.getPath()/*,env*/)) && (this.doesExist(file2.getPath()/*,env*/)))***REMOVED***
this.copyFromDmToSVN(file/*,env*/); this.copyFromDmToSVN(file/*,env*/);
this.copyFromDmToSVN(file2/*,env*/); this.copyFromDmToSVN(file2/*,env*/);
System.out.println("Files have been copied to SVN");
return true; return true;
@ -474,20 +478,40 @@ public class CheckMethod ***REMOVED***
***REMOVED*** File aa = new File("/home/gcube/wps_algorithms/algorithms/RBLACKBOX_interface.jar"); ***REMOVED*** File aa = new File("/home/gcube/wps_algorithms/algorithms/RBLACKBOX_interface.jar");
***REMOVED*** a.copyFromDmToSVN(aa, "Dev"); ***REMOVED*** a.copyFromDmToSVN(aa, "Dev");
***REMOVED***
System.out.println(a.checkMethod("dm-pool-manager-proto.d4science.org",
"2eceaf27-0e22-4dbe-8075-e09eff199bf9-98187548"));
***REMOVED***System.out.println(a.checkMethod("dataminer-ghost-t.pre.d4science.org",
***REMOVED*** "2eceaf27-0e22-4dbe-8075-e09eff199bf9-98187548"));
***REMOVED*** Algorithm al = new Algorithm(); ***REMOVED***System.out.println(a.checkMethod("dataminer-proto-ghost.d4science.org",
***REMOVED*** al.setName("RBLACKBOX"); ***REMOVED*** "***REMOVED***"));
System.out.println(a.checkMethod("dataminer-ghost-d.dev.d4science.org",
"***REMOVED***"));
***REMOVED***Algorithm aa = new Algorithm();
***REMOVED***aa.setName("UDPIPE_WRAPPER");
***REMOVED***System.out.println(a.algoExists(aa));
***REMOVED******REMOVED***
***REMOVED***ServiceConfiguration bp = new ServiceConfiguration();
***REMOVED******REMOVED***
***REMOVED***SecurityTokenProvider.instance.set("***REMOVED***");
***REMOVED******REMOVED***
***REMOVED***if (a.checkMethod(bp.getStagingHost(), SecurityTokenProvider.instance.get())&&a.algoExists(aa)); ***REMOVED***
***REMOVED***System.out.println("ciao");
***REMOVED***
***REMOVED******REMOVED***
***REMOVED***
***REMOVED***Algorithm al = new Algorithm();
***REMOVED*** al.setName("UDPIPE_WRAPPER");
***REMOVED*** a.deleteFiles(al); ***REMOVED*** a.deleteFiles(al);
***REMOVED*** ***REMOVED***
***REMOVED*** ***REMOVED***

3
src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SVNUpdater.java
View File

@ -155,10 +155,11 @@ public String getDependencyFileProd(String language/*, String env*/)***REMOVED**
***REMOVED*** ***REMOVED***
public void updateSVNProdAlgorithmList(Algorithm algorithm, String targetVRE, String category, String algorithm_type, String user/*, String env*/) ***REMOVED*** public void updateSVNProdAlgorithmList(Algorithm algorithm, String targetVRE, String category, String algorithm_type, String user/*, String env*/) ***REMOVED***
this.updateSVNAlgorithmList(this.configuration.getSVNProdAlgorithmsList(), algorithm, targetVRE, category, algorithm_type, user); this.updateSVNAlgorithmList(this.configuration.getSVNProdAlgorithmsList(), algorithm, targetVRE, category, algorithm_type, user);
***REMOVED*** ***REMOVED***
public void updateAlgorithmFiles(File a) throws SVNException***REMOVED*** public void updateAlgorithmFiles(File a) throws SVNException***REMOVED***
***REMOVED***this.updateAlgorithmList(this.configuration.getSVNMainAlgoRepo(), a); ***REMOVED***this.updateAlgorithmList(this.configuration.getSVNMainAlgoRepo(), a);
this.updateAlgorithmList(this.configuration.getStageRepository(), a); this.updateAlgorithmList(this.configuration.getStageRepository(), a);