You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2015/01/22 16:04:33 UTC
[02/10] airavata git commit: Revert "Revert "removing previous
airavata client API - AIRAVATA-1371""
http://git-wip-us.apache.org/repos/asf/airavata/blob/6e5e336f/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/DocumentCreatorNew.java
----------------------------------------------------------------------
diff --git a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/DocumentCreatorNew.java b/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/DocumentCreatorNew.java
deleted file mode 100644
index 1936593..0000000
--- a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/DocumentCreatorNew.java
+++ /dev/null
@@ -1,823 +0,0 @@
-///*
-// *
-// * Licensed to the Apache Software Foundation (ASF) under one
-// * or more contributor license agreements. See the NOTICE file
-// * distributed with this work for additional information
-// * regarding copyright ownership. The ASF licenses this file
-// * to you under the Apache License, Version 2.0 (the
-// * "License"); you may not use this file except in compliance
-// * with the License. You may obtain a copy of the License at
-// *
-// * http://www.apache.org/licenses/LICENSE-2.0
-// *
-// * Unless required by applicable law or agreed to in writing,
-// * software distributed under the License is distributed on an
-// * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// * KIND, either express or implied. See the License for the
-// * specific language governing permissions and limitations
-// * under the License.
-// *
-//*/
-//package org.apache.airavata.client.tools;
-//
-//import org.airavata.appcatalog.cpi.AppCatalog;
-//import org.airavata.appcatalog.cpi.AppCatalogException;
-//import org.apache.airavata.api.Airavata;
-//import org.apache.airavata.common.utils.ClientSettings;
-//import org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription;
-//import org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule;
-//import org.apache.airavata.model.appcatalog.appdeployment.ApplicationParallelismType;
-//import org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription;
-//import org.apache.airavata.model.appcatalog.appinterface.DataType;
-//import org.apache.airavata.model.appcatalog.computeresource.*;
-//import org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference;
-//import org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile;
-//import org.apache.airavata.model.error.AiravataClientException;
-//import org.apache.airavata.model.error.AiravataSystemException;
-//import org.apache.airavata.model.error.InvalidRequestException;
-//import org.apache.thrift.TException;
-//
-//import java.io.File;
-//import java.util.*;
-//
-///**
-// * This class has been moved to integration-tests module, use that instead of this
-// */
-//@Deprecated
-//public class DocumentCreatorNew {
-//
-// private AppCatalog appcatalog = null;
-// private String trestleshpcHostAddress = "trestles.sdsc.edu";
-// private String lonestarHostAddress = "lonestar.tacc.utexas.edu";
-// private String stampedeHostAddress = "stampede.tacc.xsede.org";
-// private String gridftpAddress = "gsiftp://trestles-dm1.sdsc.edu:2811";
-// private String gramAddress = "trestles-login1.sdsc.edu:2119/jobmanager-pbstest2";
-// private String bigRed2HostAddress = "bigred2.uits.iu.edu";
-//
-// //App Module Id's
-// private static String echoModuleId;
-// private static String amberModuleId;
-// private static String autoDockModuleId;
-// private static String espressoModuleId;
-// private static String gromacsModuleId;
-// private static String lammpsModuleId;
-// private static String nwChemModuleId;
-// private static String trinityModuleId;
-// private static String wrfModuleId;
-// private Airavata.Client client;
-// private GatewayResourceProfile gatewayResourceProfile;
-//
-// public DocumentCreatorNew(Airavata.Client client) throws AppCatalogException {
-// this.client = client;
-// }
-//
-// public String createLocalHostDocs() throws AppCatalogException, InvalidRequestException, AiravataClientException, AiravataSystemException, TException {
-// //Define compute resource host
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(
-// "localhost", new ArrayList<String>(Arrays.asList(new String[]{"127.0.0.1"})), new ArrayList<String>(Arrays.asList(new String[]{"127.0.0.1"})));
-//// host.setIsEmpty(true);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-// LOCALSubmission localSubmission = new LOCALSubmission();
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.FORK, null, null, null);
-// localSubmission.setResourceJobManager(resourceJobManager);
-// client.addLocalSubmissionDetails(host.getComputeResourceId(), 1, localSubmission);
-//
-// LOCALDataMovement localDataMovement = new LOCALDataMovement();
-// client.addLocalDataMovementDetails(host.getComputeResourceId(), 1, localDataMovement);
-//
-// //Define application module
-// ApplicationModule module = DocumentCreatorUtils.createApplicationModule("echo", "1.0.0", "Local host echo applications");
-// module.setAppModuleId(client.registerApplicationModule(module));
-//
-// //Define application interfaces
-// ApplicationInterfaceDescription application = new ApplicationInterfaceDescription();
-//// application.setIsEmpty(false);
-// application.setApplicationName("SimpleEcho0");
-// application.addToApplicationModules(module.getAppModuleId());
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("echo_input", "echo_input", "Echo Input Data", null, DataType.STRING));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("echo_output", null, DataType.STRING));
-// application.setApplicationInterfaceId(client.registerApplicationInterface(application));
-//
-// //Define application deployment
-// ApplicationDeploymentDescription deployment = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), module.getAppModuleId(), "/bin/echo", ApplicationParallelismType.SERIAL, "Local echo app depoyment");
-// deployment.setAppDeploymentId(client.registerApplicationDeployment(deployment));
-//
-// //Define gateway profile
-// ComputeResourcePreference computeResourcePreference = DocumentCreatorUtils.createComputeResourcePreference(
-// host.getComputeResourceId(), "/tmp", null,
-// false, null,
-// null, null);
-// gatewayResourceProfile = new GatewayResourceProfile();
-//// gatewayResourceProfile.setGatewayID("default");
-// gatewayResourceProfile.setGatewayName(ClientSettings.getSetting("default.registry.gateway", "php_reference_gateway"));
-// gatewayResourceProfile.addToComputeResourcePreferences(computeResourcePreference);
-// String gatewayId = client.registerGatewayResourceProfile(gatewayResourceProfile);
-// gatewayResourceProfile.setGatewayID(gatewayId);
-// client.addGatewayComputeResourcePreference(gatewayResourceProfile.getGatewayID(), host.getComputeResourceId(), computeResourcePreference);
-// return host.getComputeResourceId() + "," + application.getApplicationInterfaceId();
-// }
-//
-// private GatewayResourceProfile getGatewayResourceProfile() throws InvalidRequestException, AiravataClientException, AiravataSystemException, TException {
-//// if (gatewayResourceProfile==null){
-//// try {
-//// gatewayResourceProfile = client.getGatewayResourceProfile(ga);
-//// } catch (Exception e) {
-////
-//// }
-// if (gatewayResourceProfile == null) {
-// gatewayResourceProfile = new GatewayResourceProfile();
-//// gatewayResourceProfile.setGatewayID("default");
-// gatewayResourceProfile.setGatewayName("default");
-// gatewayResourceProfile.setGatewayID(client.registerGatewayResourceProfile(gatewayResourceProfile));
-// }
-//// }
-// return gatewayResourceProfile;
-//
-// }
-//
-// public String createSSHHostDocs() throws AppCatalogException, InvalidRequestException, AiravataClientException, AiravataSystemException, TException {
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription("gw111.iu.xsede.org", null, null);
-// host.addToIpAddresses("gw111.iu.xsede.org");
-// host.addToHostAliases("gw111.iu.xsede.org");
-// host.setResourceDescription("gw111 ssh access");
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-//
-// SSHJobSubmission jobSubmission = new SSHJobSubmission();
-// jobSubmission.setSshPort(22);
-// jobSubmission.setSecurityProtocol(SecurityProtocol.SSH_KEYS);
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.FORK, null, null, null);
-// jobSubmission.setResourceJobManager(resourceJobManager);
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, jobSubmission);
-//
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.SSH_KEYS);
-// scpDataMovement.setSshPort(22);
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-//
-// ApplicationModule module = DocumentCreatorUtils.createApplicationModule("echo", "1.1", null);
-// module.setAppModuleId(client.registerApplicationModule(module));
-// ;
-//
-// ApplicationDeploymentDescription deployment = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), module.getAppModuleId(), "/bin/echo", ApplicationParallelismType.SERIAL, "SSHEchoApplication");
-// client.registerApplicationDeployment(deployment);
-//
-// ApplicationInterfaceDescription application = new ApplicationInterfaceDescription();
-//// application.setIsEmpty(false);
-// application.setApplicationName("SSHEcho1");
-// application.addToApplicationModules(module.getAppModuleId());
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("echo_input", "echo_input", null, null, DataType.STRING));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("echo_output", null, DataType.STRING));
-// client.registerApplicationInterface(application);
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), "/tmp", null, false, null, null, null));
-// return host.getComputeResourceId() + "," + application.getApplicationInterfaceId();
-// }
-//
-// //
-//// public void createGramDocs() {
-////// /*
-////// creating host descriptor for gram
-////// */
-////// HostDescription host = new HostDescription(GlobusHostType.type);
-////// host.getType().setHostAddress(trestleshpcHostAddress);
-////// host.getType().setHostName(trestleshpcHostAddress);
-////// ((GlobusHostType) host.getType()).setGlobusGateKeeperEndPointArray(new String[]{gramAddress});
-////// ((GlobusHostType) host.getType()).setGridFTPEndPointArray(new String[]{gridftpAddress});
-////// try {
-////// airavataAPI.getApplicationManager().saveHostDescription(host);
-////// } catch (AiravataAPIInvocationException e) {
-////// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-////// }
-//////
-//////
-////// /*
-////// * Service Description creation and saving
-////// */
-////// String serviceName = "SimpleEcho1";
-////// ServiceDescription serv = new ServiceDescription();
-////// serv.getType().setName(serviceName);
-//////
-////// List<InputParameterType> inputList = new ArrayList<InputParameterType>();
-////// List<OutputParameterType> outputList = new ArrayList<OutputParameterType>();
-//////
-////// InputParameterType input = InputParameterType.Factory.newInstance();
-////// input.setParameterName("echo_input");
-////// ParameterType parameterType = input.addNewParameterType();
-////// parameterType.setType(DataType.STRING);
-////// parameterType.setName("String");
-//////
-////// OutputParameterType output = OutputParameterType.Factory.newInstance();
-////// output.setParameterName("echo_output");
-////// ParameterType parameterType1 = output.addNewParameterType();
-////// parameterType1.setType(DataType.STRING);
-////// parameterType1.setName("String");
-//////
-////// inputList.add(input);
-////// outputList.add(output);
-//////
-////// InputParameterType[] inputParamList = inputList.toArray(new InputParameterType[inputList.size()]);
-////// OutputParameterType[] outputParamList = outputList.toArray(new OutputParameterType[outputList.size()]);
-//////
-////// serv.getType().setInputParametersArray(inputParamList);
-////// serv.getType().setOutputParametersArray(outputParamList);
-////// try {
-////// airavataAPI.getApplicationManager().saveServiceDescription(serv);
-////// } catch (AiravataAPIInvocationException e) {
-////// e.printStackTrace();
-////// }
-//////
-////// /*
-////// Application descriptor creation and saving
-////// */
-////// ApplicationDescription appDesc = new ApplicationDescription(HpcApplicationDeploymentType.type);
-////// HpcApplicationDeploymentType app = (HpcApplicationDeploymentType) appDesc.getType();
-////// ApplicationDeploymentDescriptionType.ApplicationName name = ApplicationDeploymentDescriptionType.ApplicationName.Factory.newInstance();
-////// name.setStringValue("EchoLocal");
-////// app.setApplicationName(name);
-////// ProjectAccountType projectAccountType = app.addNewProjectAccount();
-////// projectAccountType.setProjectAccountNumber("sds128");
-//////
-////// QueueType queueType = app.addNewQueue();
-////// queueType.setQueueName("normal");
-//////
-////// app.setCpuCount(1);
-////// app.setJobType(JobTypeType.SERIAL);
-////// app.setNodeCount(1);
-////// app.setProcessorsPerNode(1);
-//////
-////// /*
-////// * Use bat file if it is compiled on Windows
-////// */
-////// app.setExecutableLocation("/bin/echo");
-//////
-////// /*
-////// * Default tmp location
-////// */
-////// String tempDir = "/home/ogce/scratch";
-////// app.setScratchWorkingDirectory(tempDir);
-////// app.setMaxMemory(10);
-//////
-//////
-////// try {
-////// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, trestleshpcHostAddress, appDesc);
-////// } catch (AiravataAPIInvocationException e) {
-////// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-////// }
-//// }
-////
-// public String createPBSDocsForOGCE_Echo() throws AppCatalogException, InvalidRequestException, AiravataClientException, AiravataSystemException, TException {
-//
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(trestleshpcHostAddress, null, null);
-// host.addToIpAddresses(trestleshpcHostAddress);
-// host.addToHostAliases(trestleshpcHostAddress);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-// SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.PBS, "/opt/torque/bin/", null, null);
-// sshJobSubmission.setResourceJobManager(resourceJobManager);
-// sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
-// sshJobSubmission.setSshPort(22);
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);
-//
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.GSI);
-// scpDataMovement.setSshPort(22);
-//
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-//
-// ApplicationModule module1 = DocumentCreatorUtils.createApplicationModule("echo", "1.2", null);
-// module1.setAppModuleId(client.registerApplicationModule(module1));
-//
-// ApplicationInterfaceDescription application = new ApplicationInterfaceDescription();
-//// application.setIsEmpty(false);
-// application.setApplicationName("SimpleEcho2");
-// application.addToApplicationModules(module1.getAppModuleId());
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("echo_input", "echo_input", "echo_input", null, DataType.STRING));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("echo_output", null, DataType.STRING));
-//
-// application.setApplicationInterfaceId(client.registerApplicationInterface(application));
-//
-// ApplicationDeploymentDescription deployment = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), module1.getAppModuleId(), "/home/ogce/echo.sh", ApplicationParallelismType.SERIAL, "Echo application");
-// deployment.setAppDeploymentId(client.registerApplicationDeployment(deployment));
-//
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), "/oasis/scratch/trestles/ogce/temp_project/", "sds128", false, null, null, null));
-// return host.getComputeResourceId() + "," + application.getApplicationInterfaceId();
-// }
-//
-// public String createPBSDocsForOGCE_WRF() throws AppCatalogException, InvalidRequestException, AiravataClientException, AiravataSystemException, TException {
-//
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(trestleshpcHostAddress, null, null);
-// host.addToIpAddresses(trestleshpcHostAddress);
-// host.addToHostAliases(trestleshpcHostAddress);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-// SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.PBS, "/opt/torque/bin/", null, null);
-// sshJobSubmission.setResourceJobManager(resourceJobManager);
-// sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
-// sshJobSubmission.setSshPort(22);
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);
-//
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.GSI);
-// scpDataMovement.setSshPort(22);
-//
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-//
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), "/oasis/scratch/trestles/ogce/temp_project/", "sds128", false, null, null, null));
-//
-// ApplicationModule module2 = DocumentCreatorUtils.createApplicationModule("wrf", "1.0.0", null);
-// module2.setAppModuleId(client.registerApplicationModule(module2));
-// ApplicationInterfaceDescription application2 = new ApplicationInterfaceDescription();
-//// application2.setIsEmpty(false);
-// application2.setApplicationName("WRF");
-// application2.addToApplicationModules(module2.getAppModuleId());
-// application2.addToApplicationInputs(DocumentCreatorUtils.createAppInput("WRF_Namelist", "WRF_Namelist", null, null, DataType.URI));
-// application2.addToApplicationInputs(DocumentCreatorUtils.createAppInput("WRF_Boundary_File", "WRF_Boundary_File", null, null, DataType.URI));
-// application2.addToApplicationInputs(DocumentCreatorUtils.createAppInput("WRF_Input_File", "WRF_Input_File", null, null, DataType.URI));
-//
-// application2.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("WRF_Output", null, DataType.URI));
-// application2.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("WRF_Execution_Log", null, DataType.URI));
-// application2.setApplicationInterfaceId(client.registerApplicationInterface(application2));
-//
-// ApplicationDeploymentDescription deployment2 = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), module2.getAppModuleId(), "/home/ogce/production/app_wrappers/wrf_wrapper.sh", ApplicationParallelismType.MPI, "WRF");
-// deployment2.setAppDeploymentId(client.registerApplicationDeployment(deployment2));
-// return host.getComputeResourceId() + "," + application2.getApplicationInterfaceId();
-// }
-//
-// public String createSlumWRFDocs() throws AppCatalogException, TException {
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(stampedeHostAddress, null, null);
-// host.addToHostAliases(stampedeHostAddress);
-// host.addToIpAddresses(stampedeHostAddress);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.SLURM, "/usr/bin/", null, "push");
-// SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
-// sshJobSubmission.setResourceJobManager(resourceJobManager);
-// sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
-// sshJobSubmission.setSshPort(2222);
-//
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.GSI);
-// scpDataMovement.setSshPort(22);
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-//
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), "/home1/01437/ogce", "TG-STA110014S", false, null, null, null));
-//
-// ApplicationModule module2 = DocumentCreatorUtils.createApplicationModule("wrf", "1.0.0", null);
-// module2.setAppModuleId(client.registerApplicationModule(module2));
-// ApplicationInterfaceDescription application2 = new ApplicationInterfaceDescription();
-// // application2.setIsEmpty(false);
-// application2.setApplicationName("WRF");
-// application2.addToApplicationModules(module2.getAppModuleId());
-// application2.addToApplicationInputs(DocumentCreatorUtils.createAppInput("WRF_Namelist", "WRF_Namelist", null, null, DataType.URI));
-// application2.addToApplicationInputs(DocumentCreatorUtils.createAppInput("WRF_Boundary_File", "WRF_Boundary_File", null, null, DataType.URI));
-// application2.addToApplicationInputs(DocumentCreatorUtils.createAppInput("WRF_Input_File", "WRF_Input_File", null, null, DataType.URI));
-//
-// application2.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("WRF_Output", null, DataType.URI));
-// application2.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("WRF_Execution_Log", null, DataType.URI));
-// application2.setApplicationInterfaceId(client.registerApplicationInterface(application2));
-//
-// ApplicationDeploymentDescription deployment2 = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), module2.getAppModuleId(), "/home1/01437/ogce/production/app_wrappers/wrf_wrapper.sh", ApplicationParallelismType.MPI, "WRF");
-// deployment2.setAppDeploymentId(client.registerApplicationDeployment(deployment2));
-// return host.getComputeResourceId() + "," + application2.getApplicationInterfaceId();
-//
-// }
-//
-// public String createSlurmDocs() throws AppCatalogException, InvalidRequestException, AiravataClientException, AiravataSystemException, TException {
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(stampedeHostAddress, null, null);
-// host.addToHostAliases(stampedeHostAddress);
-// host.addToIpAddresses(stampedeHostAddress);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.SLURM, "/usr/bin/", null, "push");
-// SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
-// sshJobSubmission.setResourceJobManager(resourceJobManager);
-// sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
-// sshJobSubmission.setSshPort(2222);
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);
-//
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.GSI);
-// scpDataMovement.setSshPort(22);
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-//
-// ApplicationModule module = DocumentCreatorUtils.createApplicationModule("echo", "1.3", null);
-// module.setAppModuleId(client.registerApplicationModule(module));
-//
-// ApplicationInterfaceDescription application = new ApplicationInterfaceDescription();
-//// application.setIsEmpty(false);
-// application.setApplicationName("SimpleEcho3");
-// application.addToApplicationModules(module.getAppModuleId());
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("echo_input", "echo_input", null, null, DataType.STRING));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("echo_output", null, DataType.STRING));
-// application.setApplicationInterfaceId(client.registerApplicationInterface(application));
-//
-// ApplicationDeploymentDescription deployment = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), module.getAppModuleId(), "/bin/echo", ApplicationParallelismType.SERIAL, "EchoLocal");
-// deployment.setAppDeploymentId(client.registerApplicationDeployment(deployment));
-//
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), "/home1/01437/ogce", "TG-STA110014S", false, null, null, null));
-// return host.getComputeResourceId() + "," + application.getApplicationInterfaceId();
-// }
-//
-// public String createSGEDocs() throws AppCatalogException, InvalidRequestException, AiravataClientException, AiravataSystemException, TException {
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(lonestarHostAddress, null, null);
-// host.addToHostAliases(lonestarHostAddress);
-// host.addToIpAddresses(lonestarHostAddress);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.UGE, "/opt/sge6.2/bin/lx24-amd64/", null, null);
-// SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
-// sshJobSubmission.setResourceJobManager(resourceJobManager);
-// sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
-// sshJobSubmission.setSshPort(22);
-//
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);
-//
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.GSI);
-// scpDataMovement.setSshPort(22);
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-//
-// ApplicationModule module = DocumentCreatorUtils.createApplicationModule("echo", "1.4", null);
-// module.setAppModuleId(client.registerApplicationModule(module));
-//
-// ApplicationInterfaceDescription application = new ApplicationInterfaceDescription();
-//// application.setIsEmpty(false);
-// application.setApplicationName("SimpleEcho4");
-// application.addToApplicationModules(module.getAppModuleId());
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("echo_input", "echo_input", null, null, DataType.STRING));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("echo_output", null, DataType.STRING));
-// application.setApplicationInterfaceId(client.registerApplicationInterface(application));
-//
-// ApplicationDeploymentDescription deployment = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), module.getAppModuleId(), "/bin/echo", ApplicationParallelismType.SERIAL, "EchoLocal");
-// deployment.setAppDeploymentId(client.registerApplicationDeployment(deployment));
-//
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), "/home1/01437/ogce", "TG-STA110014S", false, null, null, null));
-// return host.getComputeResourceId() + "," + application.getApplicationInterfaceId();
-// }
-//
-//// public void createEchoHostDocs() {
-//// String serviceName = "Echo";
-//// ServiceDescription serviceDescription = new ServiceDescription();
-//// List<InputParameterType> inputParameters = new ArrayList<InputParameterType>();
-//// List<OutputParameterType> outputParameters = new ArrayList<OutputParameterType>();
-//// serviceDescription.getType().setName(serviceName);
-//// serviceDescription.getType().setDescription("Echo service");
-//// // Creating input parameters
-//// InputParameterType parameter = InputParameterType.Factory.newInstance();
-//// parameter.setParameterName("echo_input");
-//// parameter.setParameterDescription("echo input");
-//// ParameterType parameterType = parameter.addNewParameterType();
-//// parameterType.setType(DataType.STRING);
-//// parameterType.setName("String");
-//// inputParameters.add(parameter);
-////
-//// // Creating output parameters
-//// OutputParameterType outputParameter = OutputParameterType.Factory.newInstance();
-//// outputParameter.setParameterName("echo_output");
-//// outputParameter.setParameterDescription("Echo output");
-//// ParameterType outputParaType = outputParameter.addNewParameterType();
-//// outputParaType.setType(DataType.STRING);
-//// outputParaType.setName("String");
-//// outputParameters.add(outputParameter);
-////
-//// // Setting input and output parameters to serviceDescriptor
-//// serviceDescription.getType().setInputParametersArray(inputParameters.toArray(new InputParameterType[] {}));
-//// serviceDescription.getType().setOutputParametersArray(outputParameters.toArray(new OutputParameterType[] {}));
-////
-//// try {
-//// airavataAPI.getApplicationManager().saveServiceDescription(serviceDescription);
-//// } catch (AiravataAPIInvocationException e) {
-//// e.printStackTrace(); // To change body of catch statement use File |
-//// // Settings | File Templates.
-//// }
-//// // Localhost
-//// ApplicationDescription applicationDeploymentDescription = new ApplicationDescription();
-//// ApplicationDeploymentDescriptionType applicationDeploymentDescriptionType = applicationDeploymentDescription.getType();
-//// applicationDeploymentDescriptionType.addNewApplicationName().setStringValue(serviceName);
-//// applicationDeploymentDescriptionType.setExecutableLocation("/bin/echo");
-//// applicationDeploymentDescriptionType.setScratchWorkingDirectory("/tmp");
-////
-//// try {
-//// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, "localhost", applicationDeploymentDescription);
-//// } catch (AiravataAPIInvocationException e) {
-//// e.printStackTrace(); // To change body of catch statement use File |
-//// // Settings | File Templates.
-//// }
-//// // Stampede
-//// /*
-//// * Application descriptor creation and saving
-//// */
-//// ApplicationDescription appDesc1 = new ApplicationDescription(HpcApplicationDeploymentType.type);
-//// HpcApplicationDeploymentType app1 = (HpcApplicationDeploymentType) appDesc1.getType();
-//// ApplicationDeploymentDescriptionType.ApplicationName name = ApplicationDeploymentDescriptionType.ApplicationName.Factory.newInstance();
-//// name.setStringValue(serviceName);
-//// app1.setApplicationName(name);
-//// ProjectAccountType projectAccountType = app1.addNewProjectAccount();
-//// projectAccountType.setProjectAccountNumber("TG-STA110014S");
-////
-//// QueueType queueType = app1.addNewQueue();
-//// queueType.setQueueName("normal");
-////
-//// app1.setCpuCount(1);
-//// app1.setJobType(JobTypeType.SERIAL);
-//// app1.setNodeCount(1);
-//// app1.setProcessorsPerNode(1);
-//// app1.setMaxWallTime(10);
-//// /*
-//// * Use bat file if it is compiled on Windows
-//// */
-//// app1.setExecutableLocation("/bin/echo");
-////
-//// /*
-//// * Default tmp location
-//// */
-//// String tempDir = "/home1/01437/ogce";
-////
-//// app1.setScratchWorkingDirectory(tempDir);
-//// app1.setInstalledParentPath("/usr/bin/");
-////
-//// try {
-//// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, stampedeHostAddress, appDesc1);
-//// } catch (AiravataAPIInvocationException e) {
-//// e.printStackTrace(); // To change body of catch statement use File |
-//// // Settings | File Templates.
-//// }
-//// // Trestles
-//// /*
-//// * Application descriptor creation and saving
-//// */
-//// ApplicationDescription appDesc2 = new ApplicationDescription(HpcApplicationDeploymentType.type);
-//// HpcApplicationDeploymentType app2 = (HpcApplicationDeploymentType) appDesc2.getType();
-//// ApplicationDeploymentDescriptionType.ApplicationName name2 = ApplicationDeploymentDescriptionType.ApplicationName.Factory.newInstance();
-//// name2.setStringValue(serviceName);
-//// app2.setApplicationName(name);
-//// ProjectAccountType projectAccountType2 = app2.addNewProjectAccount();
-//// projectAccountType2.setProjectAccountNumber("sds128");
-////
-//// QueueType queueType2 = app2.addNewQueue();
-//// queueType2.setQueueName("normal");
-////
-//// app2.setCpuCount(1);
-//// app2.setJobType(JobTypeType.SERIAL);
-//// app2.setNodeCount(1);
-//// app2.setProcessorsPerNode(1);
-//// app2.setMaxWallTime(10);
-//// /*
-//// * Use bat file if it is compiled on Windows
-//// */
-//// app2.setExecutableLocation("/bin/echo");
-////
-//// /*
-//// * Default tmp location
-//// */
-//// String tempDir2 = "/home/ogce/scratch";
-////
-//// app2.setScratchWorkingDirectory(tempDir2);
-//// app2.setInstalledParentPath("/opt/torque/bin/");
-////
-//// try {
-//// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, trestleshpcHostAddress, appDesc2);
-//// } catch (AiravataAPIInvocationException e) {
-//// e.printStackTrace(); // To change body of catch statement use File |
-//// // Settings | File Templates.
-//// }
-//// // Lonestar
-//// /*
-//// * Application descriptor creation and saving
-//// */
-//// ApplicationDescription appDesc3 = new ApplicationDescription(HpcApplicationDeploymentType.type);
-//// HpcApplicationDeploymentType app3 = (HpcApplicationDeploymentType) appDesc3.getType();
-//// ApplicationDeploymentDescriptionType.ApplicationName name3 = ApplicationDeploymentDescriptionType.ApplicationName.Factory.newInstance();
-//// name3.setStringValue(serviceName);
-//// app3.setApplicationName(name);
-//// ProjectAccountType projectAccountType3 = app3.addNewProjectAccount();
-//// projectAccountType3.setProjectAccountNumber("TG-STA110014S");
-////
-//// QueueType queueType3 = app3.addNewQueue();
-//// queueType3.setQueueName("normal");
-////
-//// app3.setCpuCount(1);
-//// app3.setJobType(JobTypeType.SERIAL);
-//// app3.setNodeCount(1);
-//// app3.setProcessorsPerNode(1);
-//// app3.setMaxWallTime(10);
-//// /*
-//// * Use bat file if it is compiled on Windows
-//// */
-//// app3.setExecutableLocation("/bin/echo");
-////
-//// /*
-//// * Default tmp location
-//// */
-//// String tempDir3 = "/home1/01437/ogce";
-////
-//// app3.setScratchWorkingDirectory(tempDir3);
-//// app3.setInstalledParentPath("/opt/sge6.2/bin/lx24-amd64/");
-////
-//// try {
-//// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, lonestarHostAddress, appDesc3);
-//// } catch (AiravataAPIInvocationException e) {
-//// e.printStackTrace(); // To change body of catch statement use File |
-//// // Settings | File Templates.
-//// }
-////
-//// }
-//
-// public String createBigRedDocs() throws InvalidRequestException, AiravataClientException, AiravataSystemException, TException, AppCatalogException {
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription("bigred2", null, null);
-// host.addToHostAliases(bigRed2HostAddress);
-// host.addToIpAddresses(bigRed2HostAddress);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-//
-// Map<JobManagerCommand, String> commands = new HashMap<JobManagerCommand, String>();
-// commands.put(JobManagerCommand.SUBMISSION, "aprun -n");
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.UGE, "/opt/torque/torque-4.2.3.1/bin/", commands, null);
-// SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
-// sshJobSubmission.setResourceJobManager(resourceJobManager);
-// sshJobSubmission.setSecurityProtocol(SecurityProtocol.SSH_KEYS);
-// sshJobSubmission.setSshPort(22);
-//
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);
-//
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.SSH_KEYS);
-// scpDataMovement.setSshPort(22);
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-//
-// ApplicationModule module = DocumentCreatorUtils.createApplicationModule("echo", "1.5", null);
-// module.setAppModuleId(client.registerApplicationModule(module));
-//
-// ApplicationInterfaceDescription application = new ApplicationInterfaceDescription();
-// application.setApplicationName("SimpleEchoBR");
-// application.addToApplicationModules(module.getAppModuleId());
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("echo_input", "echo_input", null, null, DataType.STRING));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("echo_output", null, DataType.STRING));
-// application.setApplicationInterfaceId(client.registerApplicationInterface(application));
-//
-// ApplicationDeploymentDescription deployment = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), module.getAppModuleId(), "/N/u/lginnali/BigRed2/myjob/test.sh", ApplicationParallelismType.SERIAL, "EchoLocal");
-// deployment.setAppDeploymentId(client.registerApplicationDeployment(deployment));
-//
-// String date = (new Date()).toString();
-// date = date.replaceAll(" ", "_");
-// date = date.replaceAll(":", "_");
-// String tempDir = "/N/u/lginnali/BigRed2/myjob";
-// tempDir = tempDir + File.separator + "SimpleEcho" + "_" + date + "_" + UUID.randomUUID();
-//
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), tempDir, "TG-STA110014S", false, null, null, null));
-//
-//
-// return host.getComputeResourceId() + "," + application.getApplicationInterfaceId();
-// }
-//
-// public String createBigRedAmberDocs() throws InvalidRequestException, AiravataClientException, AiravataSystemException, TException, AppCatalogException {
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription("bigred2", null, null);
-// host.addToHostAliases(bigRed2HostAddress);
-// host.addToIpAddresses(bigRed2HostAddress);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-//
-// Map<JobManagerCommand, String> commands = new HashMap<JobManagerCommand, String>();
-// commands.put(JobManagerCommand.SUBMISSION, "aprun -n 4");
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.UGE, "/opt/torque/torque-4.2.3.1/bin/", commands, null);
-// SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
-// sshJobSubmission.setResourceJobManager(resourceJobManager);
-// sshJobSubmission.setSecurityProtocol(SecurityProtocol.SSH_KEYS);
-// sshJobSubmission.setSshPort(22);
-//
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);
-//
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.SSH_KEYS);
-// scpDataMovement.setSshPort(22);
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-//
-//
-// ApplicationModule amodule = DocumentCreatorUtils.createApplicationModule("Amber", "12.0", null);
-// amodule.setAppModuleId(client.registerApplicationModule(amodule));
-//
-//
-// ApplicationInterfaceDescription application = new ApplicationInterfaceDescription();
-// application.setApplicationName("AmberBR2");
-// application.addToApplicationModules(amodule.getAppModuleId());
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("AMBER_HEAT_RST", "AMBER_HEAT_RST", null, null, DataType.URI));
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("AMBER_PROD_IN", "AMBER_PROD_IN", null, null, DataType.URI));
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("AMBER_PRMTOP", "AMBER_PRMTOP", null, null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.info", null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.mdcrd", null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.out", null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.rst", null, DataType.URI));
-// application.setApplicationInterfaceId(client.registerApplicationInterface(application));
-//
-// ApplicationDeploymentDescription deployment = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), amodule.getAppModuleId(), "/N/u/cgateway/BigRed2/sandbox/amber_wrapper.sh", ApplicationParallelismType.SERIAL, "AmberBR2");
-// deployment.setAppDeploymentId(client.registerApplicationDeployment(deployment));
-//
-//
-// String date = (new Date()).toString();
-// date = date.replaceAll(" ", "_");
-// date = date.replaceAll(":", "_");
-// String tempDir = "/N/u/cgateway/BigRed2/sandbox/jobs";
-// tempDir = tempDir + File.separator +
-// "Amber";
-//
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), tempDir, null, false, null, null, null));
-//
-//
-// return host.getComputeResourceId() + "," + application.getApplicationInterfaceId();
-// }
-//
-// public String createStampedeAmberDocs() throws InvalidRequestException, AiravataClientException, AiravataSystemException, TException, AppCatalogException {
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(stampedeHostAddress, null, null);
-// host.addToHostAliases(stampedeHostAddress);
-// host.addToIpAddresses(stampedeHostAddress);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.SLURM, "/usr/bin/", null, "push");
-// SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
-// sshJobSubmission.setResourceJobManager(resourceJobManager);
-// sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
-// sshJobSubmission.setSshPort(2222);
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);
-//
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.GSI);
-// scpDataMovement.setSshPort(22);
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-// ApplicationModule amodule = DocumentCreatorUtils.createApplicationModule("Amber", "12.0", null);
-// amodule.setAppModuleId(client.registerApplicationModule(amodule));
-//
-//
-// ApplicationInterfaceDescription application = new ApplicationInterfaceDescription();
-// application.setApplicationName("AmberBR2");
-// application.addToApplicationModules(amodule.getAppModuleId());
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("AMBER_HEAT_RST", "AMBER_HEAT_RST", null, null, DataType.URI));
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("AMBER_PROD_IN", "AMBER_PROD_IN", null, null, DataType.URI));
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("AMBER_PRMTOP", "AMBER_PRMTOP", null, null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.info", null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.mdcrd", null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.out", null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.rst", null, DataType.URI));
-// application.setApplicationInterfaceId(client.registerApplicationInterface(application));
-//
-// ApplicationDeploymentDescription deployment = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), amodule.getAppModuleId(), "/home1/01437/ogce/production/app_wrappers/amber_wrapper.sh", ApplicationParallelismType.SERIAL, "AmberStampede");
-// deployment.setAppDeploymentId(client.registerApplicationDeployment(deployment));
-//
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), "/home1/01437/ogce", "TG-STA110014S", false, null, null, null));
-//
-//
-// return host.getComputeResourceId() + "," + application.getApplicationInterfaceId();
-//
-// }
-//
-// public String createTrestlesAmberDocs() throws InvalidRequestException, AiravataClientException, AiravataSystemException, TException, AppCatalogException {
-// ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(trestleshpcHostAddress, null, null);
-// host.addToIpAddresses(trestleshpcHostAddress);
-// host.addToHostAliases(trestleshpcHostAddress);
-// host.setComputeResourceId(client.registerComputeResource(host));
-//
-// SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
-// ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.PBS, "/opt/torque/bin/", null, null);
-// sshJobSubmission.setResourceJobManager(resourceJobManager);
-// sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
-// sshJobSubmission.setSshPort(22);
-// client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);
-//
-// SCPDataMovement scpDataMovement = new SCPDataMovement();
-// scpDataMovement.setSecurityProtocol(SecurityProtocol.GSI);
-// scpDataMovement.setSshPort(22);
-// client.addSCPDataMovementDetails(host.getComputeResourceId(), 1, scpDataMovement);
-//
-// ApplicationModule amodule = DocumentCreatorUtils.createApplicationModule("Amber", "12.0", null);
-// amodule.setAppModuleId(client.registerApplicationModule(amodule));
-//
-//
-// ApplicationInterfaceDescription application = new ApplicationInterfaceDescription();
-// application.setApplicationName("AmberTrestles");
-// application.addToApplicationModules(amodule.getAppModuleId());
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("AMBER_HEAT_RST", "AMBER_HEAT_RST", null, null, DataType.URI));
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("AMBER_PROD_IN", "AMBER_PROD_IN", null, null, DataType.URI));
-// application.addToApplicationInputs(DocumentCreatorUtils.createAppInput("AMBER_PRMTOP", "AMBER_PRMTOP", null, null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.info", null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.mdcrd", null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.out", null, DataType.URI));
-// application.addToApplicationOutputs(DocumentCreatorUtils.createAppOutput("AMBER_Prod.rst", null, DataType.URI));
-// application.setApplicationInterfaceId(client.registerApplicationInterface(application));
-//
-// ApplicationDeploymentDescription deployment = DocumentCreatorUtils.createApplicationDeployment(host.getComputeResourceId(), amodule.getAppModuleId(), "/home/ogce/production/app_wrappers/amber_wrapper.sh", ApplicationParallelismType.SERIAL, "AmberStampede");
-// deployment.setAppDeploymentId(client.registerApplicationDeployment(deployment));
-//
-// client.addGatewayComputeResourcePreference(getGatewayResourceProfile().getGatewayID(), host.getComputeResourceId(), DocumentCreatorUtils.createComputeResourcePreference(host.getComputeResourceId(), "/oasis/scratch/trestles/ogce/temp_project/", "sds128", false, null, null, null));
-//
-//
-// return host.getComputeResourceId() + "," + application.getApplicationInterfaceId();
-//
-// }
-//
-//
-//}
-//
http://git-wip-us.apache.org/repos/asf/airavata/blob/6e5e336f/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/DocumentCreatorUtils.java
----------------------------------------------------------------------
diff --git a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/DocumentCreatorUtils.java b/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/DocumentCreatorUtils.java
deleted file mode 100644
index d27d8cf..0000000
--- a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/DocumentCreatorUtils.java
+++ /dev/null
@@ -1,165 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.client.tools;
-
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import org.airavata.appcatalog.cpi.AppCatalogException;
-import org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription;
-import org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule;
-import org.apache.airavata.model.appcatalog.appdeployment.ApplicationParallelismType;
-import org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType;
-import org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType;
-import org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription;
-import org.apache.airavata.model.appcatalog.computeresource.DataMovementInterface;
-import org.apache.airavata.model.appcatalog.computeresource.DataMovementProtocol;
-import org.apache.airavata.model.appcatalog.computeresource.JobManagerCommand;
-import org.apache.airavata.model.appcatalog.computeresource.JobSubmissionInterface;
-import org.apache.airavata.model.appcatalog.computeresource.JobSubmissionProtocol;
-import org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager;
-import org.apache.airavata.model.appcatalog.computeresource.ResourceJobManagerType;
-import org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference;
-
-/**
- * This class has been moved to integration-tests module, use that instead of this
- */
-@Deprecated
-public class DocumentCreatorUtils {
-
- public static ComputeResourcePreference createComputeResourcePreference(String computeResourceId, String scratchLocation,
- String allocationProjectNumber, boolean overridebyAiravata,
- String preferredBatchQueue, String preferredJobSubmissionProtocol,
- String preferredDataMovementProtocol) throws AppCatalogException {
- ComputeResourcePreference computeResourcePreference = new ComputeResourcePreference();
- computeResourcePreference.setComputeResourceId(computeResourceId);
- computeResourcePreference.setOverridebyAiravata(overridebyAiravata);
- computeResourcePreference.setAllocationProjectNumber(allocationProjectNumber);
- computeResourcePreference.setPreferredBatchQueue(preferredBatchQueue);
- computeResourcePreference.setPreferredDataMovementProtocol(DataMovementProtocol.valueOf(preferredDataMovementProtocol));
- computeResourcePreference.setPreferredJobSubmissionProtocol(JobSubmissionProtocol.valueOf(preferredJobSubmissionProtocol));
- computeResourcePreference.setScratchLocation(scratchLocation);
- return computeResourcePreference;
- }
-
- public static ApplicationDeploymentDescription createApplicationDeployment(
- String computeResourceId, String appModuleId,
- String executablePath, ApplicationParallelismType parallelism, String appDeploymentDescription) {
- ApplicationDeploymentDescription deployment = new ApplicationDeploymentDescription();
-// deployment.setIsEmpty(false);
- deployment.setAppDeploymentDescription(appDeploymentDescription);
- deployment.setAppModuleId(appModuleId);
- deployment.setComputeHostId(computeResourceId);
- deployment.setExecutablePath(executablePath);
- deployment.setParallelism(parallelism);
- return deployment;
- }
-
- public static ApplicationModule createApplicationModule(String appModuleName,
- String appModuleVersion, String appModuleDescription) {
- ApplicationModule module = new ApplicationModule();
- module.setAppModuleDescription(appModuleDescription);
- module.setAppModuleName(appModuleName);
- module.setAppModuleVersion(appModuleVersion);
- return module;
- }
-
- public static DataMovementInterface createDataMovementInterface(
- String dataMovementInterfaceId,
- DataMovementProtocol dataMovementProtocolType, int priorityOrder) {
- DataMovementInterface dataMovementInterface = new DataMovementInterface();
- dataMovementInterface.setDataMovementInterfaceId(dataMovementInterfaceId);
- dataMovementInterface.setDataMovementProtocol(dataMovementProtocolType);
- dataMovementInterface.setPriorityOrder(priorityOrder);
- return dataMovementInterface;
- }
-
- public static JobSubmissionInterface createJobSubmissionInterface(
- String jobSubmissionInterfaceId,
- JobSubmissionProtocol jobSubmissionProtocolType, int priorityOrder) {
- JobSubmissionInterface jobSubmissionInterface = new JobSubmissionInterface();
- jobSubmissionInterface.setJobSubmissionInterfaceId(jobSubmissionInterfaceId);
- jobSubmissionInterface.setJobSubmissionProtocol(jobSubmissionProtocolType);
- jobSubmissionInterface.setPriorityOrder(priorityOrder);
- return jobSubmissionInterface;
- }
-
- public static ComputeResourceDescription createComputeResourceDescription(
- String hostName, List<String> hostAliases, List<String> ipAddresses) {
- ComputeResourceDescription host = new ComputeResourceDescription();
- host.setHostName(hostName);
- host.setIpAddresses(ipAddresses);
- host.setHostAliases(hostAliases);
- return host;
- }
-
- public static ResourceJobManager createResourceJobManager(
- ResourceJobManagerType resourceJobManagerType,
- String jobManagerBinPath,
- Map<JobManagerCommand, String> jobManagerCommands,
- String pushMonitoringEndpoint) {
- ResourceJobManager resourceJobManager=new ResourceJobManager();;
- resourceJobManager.setResourceJobManagerType(resourceJobManagerType);
- resourceJobManager.setJobManagerBinPath(jobManagerBinPath);
- resourceJobManager.setJobManagerCommands(jobManagerCommands);
- resourceJobManager.setPushMonitoringEndpoint(pushMonitoringEndpoint);
- return resourceJobManager;
- }
-
- public static InputDataObjectType createAppInput (String inputName, String argumentName, String description, String value, org.apache.airavata.model.appcatalog.appinterface.DataType type ){
- InputDataObjectType input = new InputDataObjectType();
-// input.setIsEmpty(false);
- if (inputName!=null) {
- input.setName(inputName);
- }
- if (value!=null) {
- input.setValue(value);
- }
- if (type!=null) {
- input.setType(type);
- }
- if (argumentName!=null) {
- input.setApplicationArgument(argumentName);
- }
- if (description!=null) {
- input.setUserFriendlyDescription(description);
- }
- return input;
- }
-
- public static OutputDataObjectType createAppOutput (String inputName, String value, org.apache.airavata.model.appcatalog.appinterface.DataType type ){
- OutputDataObjectType outputDataObjectType = new OutputDataObjectType();
-// outputDataObjectType.setIsEmpty(false);
- if (inputName!=null) {
- outputDataObjectType.setName(inputName);
- }
- if (value!=null) {
- outputDataObjectType.setValue(value);
- }
- if (type!=null) {
- outputDataObjectType.setType(type);
- }
- return outputDataObjectType;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/6e5e336f/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/NameValuePairType.java
----------------------------------------------------------------------
diff --git a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/NameValuePairType.java b/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/NameValuePairType.java
deleted file mode 100644
index 5bf5cb5..0000000
--- a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/NameValuePairType.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.client.tools;
-
-public class NameValuePairType {
-
- private String name;
- private String value;
- private String description;
- public String getName() {
- return name;
- }
- public void setName(String name) {
- this.name = name;
- }
- public String getValue() {
- return value;
- }
- public void setValue(String value) {
- this.value = value;
- }
- public String getDescription() {
- return description;
- }
- public void setDescription(String description) {
- this.description = description;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/6e5e336f/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java
----------------------------------------------------------------------
diff --git a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java b/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java
deleted file mode 100644
index 6a1a4ed..0000000
--- a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java
+++ /dev/null
@@ -1,61 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.client.tools;
-
-import org.apache.airavata.client.api.AiravataAPI;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public abstract class PeriodicExecutorThread extends Thread {
-
- private AiravataAPI airavataAPI;
- public static final int URL_UPDATE_INTERVAL = 1000 * 60 * 60 * 3;
- public static final int JCR_AVAIALABILITY_WAIT_INTERVAL = 1000 * 10;
-
- private static final Logger log = LoggerFactory.getLogger(PeriodicExecutorThread.class);
-
- public PeriodicExecutorThread(AiravataAPI airavataAPI) {
- this.airavataAPI = airavataAPI;
- }
-
- public void run() {
- while (true) {
- try {
- updateRegistry(airavataAPI);
- Thread.sleep(URL_UPDATE_INTERVAL);
- } catch (InterruptedException e) {
- break;
- } catch (Exception e) {
- try {
- Thread.sleep(JCR_AVAIALABILITY_WAIT_INTERVAL);
- } catch (InterruptedException e1) {
- e1.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
- return;
- }
- log.error(e.getMessage());
- log.error("Workflow Interpreter Service URL update thread is interrupted");
- }
- }
- }
-
- protected abstract void updateRegistry(AiravataAPI airavataAPI) throws Exception;
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/6e5e336f/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/UltrascanDocumentCreator.java
----------------------------------------------------------------------
diff --git a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/UltrascanDocumentCreator.java b/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/UltrascanDocumentCreator.java
deleted file mode 100644
index f4fceeb..0000000
--- a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/UltrascanDocumentCreator.java
+++ /dev/null
@@ -1,444 +0,0 @@
-///**
-// * Licensed to the Apache Software Foundation (ASF) under one
-// * or more contributor license agreements. See the NOTICE file
-// * distributed with this work for additional information
-// * regarding copyright ownership. The ASF licenses this file
-// * to you under the Apache License, Version 2.0 (the
-// * "License"); you may not use this file except in compliance
-// * with the License. You may obtain a copy of the License at
-// *
-// * http://www.apache.org/licenses/LICENSE-2.0
-// *
-// * Unless required by applicable law or agreed to in writing,
-// * software distributed under the License is distributed on an
-// * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// * KIND, either express or implied. See the License for the
-// * specific language governing permissions and limitations
-// * under the License.
-// */
-//
-//package org.apache.airavata.client.tools;
-//
-//import java.io.File;
-//import java.util.ArrayList;
-//import java.util.Date;
-//import java.util.List;
-//import java.util.UUID;
-//
-//import org.apache.airavata.client.api.AiravataAPI;
-//import org.apache.airavata.client.api.exception.AiravataAPIInvocationException;
-//import org.apache.airavata.commons.gfac.type.ApplicationDescription;
-//import org.apache.airavata.commons.gfac.type.HostDescription;
-//import org.apache.airavata.commons.gfac.type.ServiceDescription;
-//import org.apache.airavata.schemas.gfac.ApplicationDeploymentDescriptionType;
-//import org.apache.airavata.schemas.gfac.DataType;
-//import org.apache.airavata.schemas.gfac.GsisshHostType;
-//import org.apache.airavata.schemas.gfac.HpcApplicationDeploymentType;
-//import org.apache.airavata.schemas.gfac.InputParameterType;
-//import org.apache.airavata.schemas.gfac.JobTypeType;
-//import org.apache.airavata.schemas.gfac.OutputParameterType;
-//import org.apache.airavata.schemas.gfac.ParameterType;
-//import org.apache.airavata.schemas.gfac.ProjectAccountType;
-//import org.apache.airavata.schemas.gfac.QueueType;
-//
-//public class UltrascanDocumentCreator {
-//
-// private AiravataAPI airavataAPI = null;
-// private String hpcHostAddress = "trestles.sdsc.edu";
-// private String gsiSshHostNameTrestles = "gsissh-trestles";
-// private String gsiSshHostNameStampede = "gsissh-stampede";
-//
-//
-// public UltrascanDocumentCreator(AiravataAPI airavataAPI) {
-// this.airavataAPI = airavataAPI;
-// }
-//
-// public void createEchoPBSDocsforTestles() {
-// HostDescription host = new HostDescription(GsisshHostType.type);
-// host.getType().setHostAddress(hpcHostAddress);
-// host.getType().setHostName(gsiSshHostNameTrestles);
-// ((GsisshHostType) host.getType()).setPort(22);
-// ((GsisshHostType) host.getType()).setInstalledPath("/opt/torque/bin/");
-//
-// try {
-// airavataAPI.getApplicationManager().saveHostDescription(host);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-// /*
-// * Service Description creation and saving
-// */
-// String serviceName = "US3EchoTrestles";
-// ServiceDescription serv = new ServiceDescription();
-// serv.getType().setName(serviceName);
-//
-// List<InputParameterType> inputList = new ArrayList<InputParameterType>();
-// List<OutputParameterType> outputList = new ArrayList<OutputParameterType>();
-//
-//
-// InputParameterType input = InputParameterType.Factory.newInstance();
-// input.setParameterName("echo_input");
-// ParameterType parameterType = input.addNewParameterType();
-// parameterType.setType(DataType.STRING);
-// parameterType.setName("String");
-//
-// OutputParameterType output = OutputParameterType.Factory.newInstance();
-// output.setParameterName("echo_output");
-// ParameterType parameterType1 = output.addNewParameterType();
-// parameterType1.setType(DataType.STRING);
-// parameterType1.setName("String");
-//
-// inputList.add(input);
-// outputList.add(output);
-//
-// InputParameterType[] inputParamList = inputList.toArray(new InputParameterType[inputList.size()]);
-// OutputParameterType[] outputParamList = outputList.toArray(new OutputParameterType[outputList.size()]);
-//
-// serv.getType().setInputParametersArray(inputParamList);
-// serv.getType().setOutputParametersArray(outputParamList);
-// try {
-// airavataAPI.getApplicationManager().saveServiceDescription(serv);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-//
-// /*
-// Application descriptor creation and saving
-// */
-// ApplicationDescription appDesc = new ApplicationDescription(HpcApplicationDeploymentType.type);
-// HpcApplicationDeploymentType app = (HpcApplicationDeploymentType) appDesc.getType();
-// ApplicationDeploymentDescriptionType.ApplicationName name = ApplicationDeploymentDescriptionType.ApplicationName.Factory.newInstance();
-// name.setStringValue(serviceName);
-// app.setApplicationName(name);
-// ProjectAccountType projectAccountType = app.addNewProjectAccount();
-// projectAccountType.setProjectAccountNumber("uot111");
-//
-// QueueType queueType = app.addNewQueue();
-// queueType.setQueueName("normal");
-//
-// app.setCpuCount(1);
-// app.setJobType(JobTypeType.SERIAL);
-// app.setNodeCount(1);
-// app.setProcessorsPerNode(1);
-// app.setMaxWallTime(10);
-// /*
-// * Use bat file if it is compiled on Windows
-// */
-// app.setExecutableLocation("/bin/echo");
-//
-// /*
-// * Default tmp location
-// */
-// String tempDir = "/oasis/projects/nsf/uot111/us3/airavata-workdirs/";
-//
-// app.setScratchWorkingDirectory(tempDir);
-// app.setInstalledParentPath("/opt/torque/bin/");
-//
-// try {
-// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, gsiSshHostNameTrestles, appDesc);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-// }
-//
-// public void createMPIPBSDocsTrestles() {
-// HostDescription host = new HostDescription(GsisshHostType.type);
-// host.getType().setHostAddress(hpcHostAddress);
-// host.getType().setHostName(gsiSshHostNameTrestles);
-// ((GsisshHostType) host.getType()).setPort(22);
-// ((GsisshHostType) host.getType()).setInstalledPath("/opt/torque/bin/");
-//
-// try {
-// airavataAPI.getApplicationManager().saveHostDescription(host);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-// /*
-// * Service Description creation and saving
-// */
-// String serviceName = "US3AppTrestles";
-// ServiceDescription serv = new ServiceDescription();
-// serv.getType().setName(serviceName);
-//
-// List<InputParameterType> inputList = new ArrayList<InputParameterType>();
-// List<OutputParameterType> outputList = new ArrayList<OutputParameterType>();
-//
-//
-// InputParameterType input = InputParameterType.Factory.newInstance();
-// input.setParameterName("input");
-// ParameterType parameterType = input.addNewParameterType();
-// parameterType.setType(DataType.URI);
-// parameterType.setName("URI");
-//
-// OutputParameterType output = OutputParameterType.Factory.newInstance();
-// output.setParameterName("output");
-// ParameterType parameterType1 = output.addNewParameterType();
-// parameterType1.setType(DataType.URI);
-// parameterType1.setName("URI");
-//
-// OutputParameterType output1 = OutputParameterType.Factory.newInstance();
-// output1.setParameterName("stdout");
-// ParameterType parameterType2 = output1.addNewParameterType();
-// parameterType2.setType(DataType.STD_OUT);
-// parameterType2.setName("StdOut");
-//
-// OutputParameterType output2 = OutputParameterType.Factory.newInstance();
-// output2.setParameterName("stderr");
-// ParameterType parameterType3 = output2.addNewParameterType();
-// parameterType3.setType(DataType.STD_ERR);
-// parameterType3.setName("StdErr");
-//
-// inputList.add(input);
-// outputList.add(output);
-// outputList.add(output1);
-// outputList.add(output2);
-//
-// InputParameterType[] inputParamList = inputList.toArray(new InputParameterType[inputList.size()]);
-// OutputParameterType[] outputParamList = outputList.toArray(new OutputParameterType[outputList.size()]);
-//
-// serv.getType().setInputParametersArray(inputParamList);
-// serv.getType().setOutputParametersArray(outputParamList);
-// try {
-// airavataAPI.getApplicationManager().saveServiceDescription(serv);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-//
-// /*
-// Application descriptor creation and saving
-// */
-// ApplicationDescription appDesc = new ApplicationDescription(HpcApplicationDeploymentType.type);
-// HpcApplicationDeploymentType app = (HpcApplicationDeploymentType) appDesc.getType();
-// ApplicationDeploymentDescriptionType.ApplicationName name = ApplicationDeploymentDescriptionType.ApplicationName.Factory.newInstance();
-// name.setStringValue(serviceName);
-// app.setApplicationName(name);
-// ProjectAccountType projectAccountType = app.addNewProjectAccount();
-// projectAccountType.setProjectAccountNumber("uot111");
-//
-// QueueType queueType = app.addNewQueue();
-// queueType.setQueueName("normal");
-//
-// app.setCpuCount(1);
-// app.setJobType(JobTypeType.MPI);
-// app.setNodeCount(32);
-// app.setProcessorsPerNode(2);
-// app.setMaxWallTime(10);
-// /*
-// * Use bat file if it is compiled on Windows
-// */
-// app.setExecutableLocation("/home/us3/trestles/bin/us_mpi_analysis");
-//
-// /*
-// * Default tmp location
-// */
-// String tempDir = "/oasis/projects/nsf/uot111/us3/airavata-workdirs/";
-// app.setScratchWorkingDirectory(tempDir);
-// app.setInstalledParentPath("/opt/torque/bin/");
-// app.setJobSubmitterCommand("/opt/mvapich2/pgi/ib/bin/mpiexec");
-// try {
-// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, gsiSshHostNameTrestles, appDesc);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-// }
-// public void createMPISLURMDocsStampede() {
-// HostDescription host = new HostDescription(GsisshHostType.type);
-// host.getType().setHostAddress("stampede.tacc.xsede.org");
-// host.getType().setHostName("gsissh-stampede");
-// ((GsisshHostType) host.getType()).setJobManager("slurm");
-// ((GsisshHostType) host.getType()).setInstalledPath("/usr/bin/");
-// ((GsisshHostType) host.getType()).setPort(2222);
-//
-// try {
-// airavataAPI.getApplicationManager().saveHostDescription(host);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-// /*
-// * Service Description creation and saving
-// */
-// String serviceName = "US3AppStampede";
-// ServiceDescription serv = new ServiceDescription();
-// serv.getType().setName(serviceName);
-//
-// List<InputParameterType> inputList = new ArrayList<InputParameterType>();
-// List<OutputParameterType> outputList = new ArrayList<OutputParameterType>();
-//
-//
-// InputParameterType input = InputParameterType.Factory.newInstance();
-// input.setParameterName("input");
-// ParameterType parameterType = input.addNewParameterType();
-// parameterType.setType(DataType.URI);
-// parameterType.setName("URI");
-//
-// OutputParameterType output = OutputParameterType.Factory.newInstance();
-// output.setParameterName("output");
-// ParameterType parameterType1 = output.addNewParameterType();
-// parameterType1.setType(DataType.URI);
-// parameterType1.setName("URI");
-//
-// OutputParameterType output1 = OutputParameterType.Factory.newInstance();
-// output1.setParameterName("stdout");
-// ParameterType parameterType2 = output1.addNewParameterType();
-// parameterType2.setType(DataType.STD_OUT);
-// parameterType2.setName("StdOut");
-//
-// OutputParameterType output2 = OutputParameterType.Factory.newInstance();
-// output2.setParameterName("stderr");
-// ParameterType parameterType3 = output2.addNewParameterType();
-// parameterType3.setType(DataType.STD_ERR);
-// parameterType3.setName("StdErr");
-//
-// inputList.add(input);
-// outputList.add(output);
-// outputList.add(output1);
-// outputList.add(output2);
-//
-// InputParameterType[] inputParamList = inputList.toArray(new InputParameterType[inputList.size()]);
-// OutputParameterType[] outputParamList = outputList.toArray(new OutputParameterType[outputList.size()]);
-//
-// serv.getType().setInputParametersArray(inputParamList);
-// serv.getType().setOutputParametersArray(outputParamList);
-// try {
-// airavataAPI.getApplicationManager().saveServiceDescription(serv);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-//
-// /*
-// Application descriptor creation and saving
-// */
-// ApplicationDescription appDesc = new ApplicationDescription(HpcApplicationDeploymentType.type);
-// HpcApplicationDeploymentType app = (HpcApplicationDeploymentType) appDesc.getType();
-// ApplicationDeploymentDescriptionType.ApplicationName name = ApplicationDeploymentDescriptionType.ApplicationName.Factory.newInstance();
-// name.setStringValue(serviceName);
-// app.setApplicationName(name);
-// ProjectAccountType projectAccountType = app.addNewProjectAccount();
-// projectAccountType.setProjectAccountNumber("TG-MCB070039N");
-//
-// QueueType queueType = app.addNewQueue();
-// queueType.setQueueName("normal");
-//
-// app.setCpuCount(1);
-// app.setJobType(JobTypeType.MPI);
-// app.setNodeCount(32);
-// app.setProcessorsPerNode(2);
-// app.setMaxWallTime(10);
-// /*
-// * Use bat file if it is compiled on Windows
-// */
-// app.setExecutableLocation("/home1/01623/us3/bin/us_mpi_analysis");
-//
-// /*
-// * Default tmp location
-// */
-// String tempDir = "/home1/01623/us3";
-// app.setScratchWorkingDirectory(tempDir);
-// app.setInstalledParentPath("/usr/bin/");
-// app.setJobSubmitterCommand("/usr/local/bin/ibrun");
-// try {
-// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, gsiSshHostNameStampede, appDesc);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-// }
-// public void createEchoSlurmDocsofStampede() {
-// HostDescription host = new HostDescription(GsisshHostType.type);
-// host.getType().setHostAddress("stampede.tacc.xsede.org");
-// host.getType().setHostName("stampede-host");
-// ((GsisshHostType) host.getType()).setJobManager("slurm");
-// ((GsisshHostType) host.getType()).setInstalledPath("/usr/bin/");
-// ((GsisshHostType) host.getType()).setPort(2222);
-// ((GsisshHostType) host.getType()).setMonitorMode("push");
-//// ((GsisshHostType) host.getType()).setMo(2222);
-//
-//
-// try {
-// airavataAPI.getApplicationManager().saveHostDescription(host);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-// /*
-// * Service Description creation and saving
-// */
-// String serviceName = "US3EchoStampede";
-// ServiceDescription serv = new ServiceDescription();
-// serv.getType().setName(serviceName);
-//
-// List<InputParameterType> inputList = new ArrayList<InputParameterType>();
-// List<OutputParameterType> outputList = new ArrayList<OutputParameterType>();
-//
-//
-// InputParameterType input = InputParameterType.Factory.newInstance();
-// input.setParameterName("echo_input");
-// ParameterType parameterType = input.addNewParameterType();
-// parameterType.setType(DataType.STRING);
-// parameterType.setName("String");
-//
-// OutputParameterType output = OutputParameterType.Factory.newInstance();
-// output.setParameterName("echo_output");
-// ParameterType parameterType1 = output.addNewParameterType();
-// parameterType1.setType(DataType.STRING);
-// parameterType1.setName("String");
-//
-// inputList.add(input);
-// outputList.add(output);
-//
-// InputParameterType[] inputParamList = inputList.toArray(new InputParameterType[inputList.size()]);
-// OutputParameterType[] outputParamList = outputList.toArray(new OutputParameterType[outputList.size()]);
-//
-// serv.getType().setInputParametersArray(inputParamList);
-// serv.getType().setOutputParametersArray(outputParamList);
-// try {
-// airavataAPI.getApplicationManager().saveServiceDescription(serv);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-//
-// /*
-// Application descriptor creation and saving
-// */
-// ApplicationDescription appDesc = new ApplicationDescription(HpcApplicationDeploymentType.type);
-// HpcApplicationDeploymentType app = (HpcApplicationDeploymentType) appDesc.getType();
-// ApplicationDeploymentDescriptionType.ApplicationName name = ApplicationDeploymentDescriptionType.ApplicationName.Factory.newInstance();
-// name.setStringValue(serviceName);
-// app.setApplicationName(name);
-// ProjectAccountType projectAccountType = app.addNewProjectAccount();
-// projectAccountType.setProjectAccountNumber("TG-MCB070039N");
-//
-// QueueType queueType = app.addNewQueue();
-// queueType.setQueueName("normal");
-//
-// app.setCpuCount(1);
-// app.setJobType(JobTypeType.SERIAL);
-// app.setNodeCount(1);
-// app.setProcessorsPerNode(1);
-// app.setMaxWallTime(10);
-// /*
-// * Use bat file if it is compiled on Windows
-// */
-// app.setExecutableLocation("/bin/echo");
-//
-// /*
-// * Default tmp location
-// */
-// String tempDir = "/home1/01623/us3";
-//
-// app.setScratchWorkingDirectory(tempDir);
-// app.setInstalledParentPath("/usr/bin/");
-//
-// try {
-// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, gsiSshHostNameStampede, appDesc);
-// } catch (AiravataAPIInvocationException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
-// }
-//
-// public AiravataAPI getAiravataAPI() {
-// return airavataAPI;
-// }
-//
-// public void setAiravataAPI(AiravataAPI airavataAPI) {
-// this.airavataAPI = airavataAPI;
-// }
-//}