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 2014/11/14 05:01:40 UTC
[2/4] airavata git commit: removing gfac-config from pom and fixing
build issues
http://git-wip-us.apache.org/repos/asf/airavata/blob/405d31d8/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
index 6e5e707..1936593 100644
--- 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
@@ -1,823 +1,823 @@
-/*
- *
- * 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.
-//// }
+///*
+// *
+// * 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);
////
-//// /*
-//// * Service Description creation and saving
-//// */
-//// String serviceName = "SimpleEcho1";
-//// ServiceDescription serv = new ServiceDescription();
-//// serv.getType().setName(serviceName);
+//// // Setting input and output parameters to serviceDescriptor
+//// serviceDescription.getType().setInputParametersArray(inputParameters.toArray(new InputParameterType[] {}));
+//// serviceDescription.getType().setOutputParametersArray(outputParameters.toArray(new OutputParameterType[] {}));
////
-//// List<InputParameterType> inputList = new ArrayList<InputParameterType>();
-//// List<OutputParameterType> outputList = new ArrayList<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");
////
-//// InputParameterType input = InputParameterType.Factory.newInstance();
-//// input.setParameterName("echo_input");
-//// ParameterType parameterType = input.addNewParameterType();
-//// parameterType.setType(DataType.STRING);
-//// parameterType.setName("String");
+//// 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");
////
-//// OutputParameterType output = OutputParameterType.Factory.newInstance();
-//// output.setParameterName("echo_output");
-//// ParameterType parameterType1 = output.addNewParameterType();
-//// parameterType1.setType(DataType.STRING);
-//// parameterType1.setName("String");
+//// QueueType queueType = app1.addNewQueue();
+//// queueType.setQueueName("normal");
////
-//// inputList.add(input);
-//// outputList.add(output);
+//// 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");
////
-//// InputParameterType[] inputParamList = inputList.toArray(new InputParameterType[inputList.size()]);
-//// OutputParameterType[] outputParamList = outputList.toArray(new OutputParameterType[outputList.size()]);
+//// /*
+//// * Default tmp location
+//// */
+//// String tempDir = "/home1/01437/ogce";
////
-//// serv.getType().setInputParametersArray(inputParamList);
-//// serv.getType().setOutputParametersArray(outputParamList);
-//// try {
-//// airavataAPI.getApplicationManager().saveServiceDescription(serv);
-//// } catch (AiravataAPIInvocationException e) {
-//// e.printStackTrace();
-//// }
+//// app1.setScratchWorkingDirectory(tempDir);
+//// app1.setInstalledParentPath("/usr/bin/");
////
-//// /*
-//// 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");
+//// 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 queueType = app.addNewQueue();
-//// queueType.setQueueName("normal");
+//// QueueType queueType2 = app2.addNewQueue();
+//// queueType2.setQueueName("normal");
////
-//// app.setCpuCount(1);
-//// app.setJobType(JobTypeType.SERIAL);
-//// app.setNodeCount(1);
-//// app.setProcessorsPerNode(1);
+//// 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");
////
-//// /*
-//// * Use bat file if it is compiled on Windows
-//// */
-//// app.setExecutableLocation("/bin/echo");
+//// /*
+//// * Default tmp location
+//// */
+//// String tempDir2 = "/home/ogce/scratch";
////
-//// /*
-//// * Default tmp location
-//// */
-//// String tempDir = "/home/ogce/scratch";
-//// app.setScratchWorkingDirectory(tempDir);
-//// app.setMaxMemory(10);
+//// 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");
////
-//// try {
-//// airavataAPI.getApplicationManager().saveApplicationDescription(serviceName, trestleshpcHostAddress, appDesc);
-//// } catch (AiravataAPIInvocationException e) {
-//// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-//// }
+//// 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 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));
-
<TRUNCATED>