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/05/14 19:53:29 UTC
[5/6] adding generated code for app catalog
http://git-wip-us.apache.org/repos/asf/airavata/blob/7d0ce7d5/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/appcatalog/ApplicationCatalogAPI.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/appcatalog/ApplicationCatalogAPI.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/appcatalog/ApplicationCatalogAPI.java
new file mode 100644
index 0000000..aef1ce1
--- /dev/null
+++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/appcatalog/ApplicationCatalogAPI.java
@@ -0,0 +1,19425 @@
+ /*
+ * 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.
+ */
+/**
+ * Autogenerated by Thrift Compiler (0.9.1)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.airavata.api.appcatalog;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings("all") public class ApplicationCatalogAPI {
+
+ public interface Iface {
+
+ /**
+ * Query Airavata to fetch the API version
+ */
+ public String GetAPIVersion() throws org.apache.thrift.TException;
+
+ /**
+ * Manage Computer Resources
+ *
+ * @param computeResourceDescription
+ */
+ public void addComputerResourceDescription(org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription computeResourceDescription) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public void addJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission jobSubmission) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ /**
+ * void addJobSubmissionProtocol(1: string computeResourceId, 2: computeResourceDescrption.GSISSHJobSubmission jobSubmission)
+ * throws (1: airavataErrors.InvalidRequestException ire,
+ * 2: airavataErrors.AiravataClientException ace,
+ * 3: airavataErrors.AiravataSystemException ase)
+ *
+ * void addJobSubmissionProtocol(1: string computeResourceId, 2: computeResourceDescrption.GlobusJobSubmission jobSubmission)
+ * throws (1: airavataErrors.InvalidRequestException ire,
+ * 2: airavataErrors.AiravataClientException ace,
+ * 3: airavataErrors.AiravataSystemException ase)
+ *
+ * void addDataMovementProtocol(1: string computeResourceId, 2: computeResourceDescrption.SCPDataMovement dataMovement)
+ * throws (1: airavataErrors.InvalidRequestException ire,
+ * 2: airavataErrors.AiravataClientException ace,
+ * 3: airavataErrors.AiravataSystemException ase)
+ */
+ public List<String> listComputeResourceDescriptions() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription getComputeResourceDescription(String computeResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission getSSHJobSubmissionProtocol(String sshJobSubmissionProtocolResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public org.apache.airavata.model.appcatalog.computeresource.GSISSHJobSubmission getGSISSHJobSubmissionProtocol(String gsisshJobSubmissionProtocolResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public org.apache.airavata.model.appcatalog.computeresource.GlobusJobSubmission getGlobusJobSubmissionProtocol(String globusJobSubmissionProtocolResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement getSCPDataMovementProtocol(String scpDataMovementResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public boolean isComputeResourceDescriptionRegistered(String hostName) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription getComputeResourceDescriptionFromHostName(String hostName) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ /**
+ * Manage Application Interfaces
+ *
+ * @param applicationInterface
+ */
+ public void addApplicationInterface(org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface applicationInterface) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public List<String> listApplicationInterfaceIds() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface getApplicationInterface(String applicationInterfaceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ /**
+ * Manage application deployments
+ *
+ * @param applicationInterfaceId
+ * @param applicationDeployment
+ */
+ public void addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment applicationDeployment) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public List<String> listApplicationDeploymentIds() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ public org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment getApplicationDeployment(String applicationDeploymentId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException;
+
+ }
+
+ public interface AsyncIface {
+
+ public void GetAPIVersion(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void addComputerResourceDescription(org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription computeResourceDescription, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void addJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission jobSubmission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void listComputeResourceDescriptions(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getComputeResourceDescription(String computeResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getSSHJobSubmissionProtocol(String sshJobSubmissionProtocolResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getGSISSHJobSubmissionProtocol(String gsisshJobSubmissionProtocolResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getGlobusJobSubmissionProtocol(String globusJobSubmissionProtocolResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getSCPDataMovementProtocol(String scpDataMovementResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void isComputeResourceDescriptionRegistered(String hostName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getComputeResourceDescriptionFromHostName(String hostName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void addApplicationInterface(org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface applicationInterface, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void listApplicationInterfaceIds(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getApplicationInterface(String applicationInterfaceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment applicationDeployment, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void listApplicationDeploymentIds(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getApplicationDeployment(String applicationDeploymentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ }
+
+ public static class Client extends org.apache.thrift.TServiceClient implements Iface {
+ public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
+ public Factory() {}
+ public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
+ return new Client(prot);
+ }
+ public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+ return new Client(iprot, oprot);
+ }
+ }
+
+ public Client(org.apache.thrift.protocol.TProtocol prot)
+ {
+ super(prot, prot);
+ }
+
+ public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+ super(iprot, oprot);
+ }
+
+ public String GetAPIVersion() throws org.apache.thrift.TException
+ {
+ send_GetAPIVersion();
+ return recv_GetAPIVersion();
+ }
+
+ public void send_GetAPIVersion() throws org.apache.thrift.TException
+ {
+ GetAPIVersion_args args = new GetAPIVersion_args();
+ sendBase("GetAPIVersion", args);
+ }
+
+ public String recv_GetAPIVersion() throws org.apache.thrift.TException
+ {
+ GetAPIVersion_result result = new GetAPIVersion_result();
+ receiveBase(result, "GetAPIVersion");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetAPIVersion failed: unknown result");
+ }
+
+ public void addComputerResourceDescription(org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription computeResourceDescription) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_addComputerResourceDescription(computeResourceDescription);
+ recv_addComputerResourceDescription();
+ }
+
+ public void send_addComputerResourceDescription(org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription computeResourceDescription) throws org.apache.thrift.TException
+ {
+ addComputerResourceDescription_args args = new addComputerResourceDescription_args();
+ args.setComputeResourceDescription(computeResourceDescription);
+ sendBase("addComputerResourceDescription", args);
+ }
+
+ public void recv_addComputerResourceDescription() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ addComputerResourceDescription_result result = new addComputerResourceDescription_result();
+ receiveBase(result, "addComputerResourceDescription");
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ return;
+ }
+
+ public void addJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission jobSubmission) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_addJobSubmissionProtocol(computeResourceId, jobSubmission);
+ recv_addJobSubmissionProtocol();
+ }
+
+ public void send_addJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission jobSubmission) throws org.apache.thrift.TException
+ {
+ addJobSubmissionProtocol_args args = new addJobSubmissionProtocol_args();
+ args.setComputeResourceId(computeResourceId);
+ args.setJobSubmission(jobSubmission);
+ sendBase("addJobSubmissionProtocol", args);
+ }
+
+ public void recv_addJobSubmissionProtocol() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ addJobSubmissionProtocol_result result = new addJobSubmissionProtocol_result();
+ receiveBase(result, "addJobSubmissionProtocol");
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ return;
+ }
+
+ public List<String> listComputeResourceDescriptions() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_listComputeResourceDescriptions();
+ return recv_listComputeResourceDescriptions();
+ }
+
+ public void send_listComputeResourceDescriptions() throws org.apache.thrift.TException
+ {
+ listComputeResourceDescriptions_args args = new listComputeResourceDescriptions_args();
+ sendBase("listComputeResourceDescriptions", args);
+ }
+
+ public List<String> recv_listComputeResourceDescriptions() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ listComputeResourceDescriptions_result result = new listComputeResourceDescriptions_result();
+ receiveBase(result, "listComputeResourceDescriptions");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listComputeResourceDescriptions failed: unknown result");
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription getComputeResourceDescription(String computeResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getComputeResourceDescription(computeResourceId);
+ return recv_getComputeResourceDescription();
+ }
+
+ public void send_getComputeResourceDescription(String computeResourceId) throws org.apache.thrift.TException
+ {
+ getComputeResourceDescription_args args = new getComputeResourceDescription_args();
+ args.setComputeResourceId(computeResourceId);
+ sendBase("getComputeResourceDescription", args);
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription recv_getComputeResourceDescription() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getComputeResourceDescription_result result = new getComputeResourceDescription_result();
+ receiveBase(result, "getComputeResourceDescription");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getComputeResourceDescription failed: unknown result");
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission getSSHJobSubmissionProtocol(String sshJobSubmissionProtocolResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getSSHJobSubmissionProtocol(sshJobSubmissionProtocolResourceId);
+ return recv_getSSHJobSubmissionProtocol();
+ }
+
+ public void send_getSSHJobSubmissionProtocol(String sshJobSubmissionProtocolResourceId) throws org.apache.thrift.TException
+ {
+ getSSHJobSubmissionProtocol_args args = new getSSHJobSubmissionProtocol_args();
+ args.setSshJobSubmissionProtocolResourceId(sshJobSubmissionProtocolResourceId);
+ sendBase("getSSHJobSubmissionProtocol", args);
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission recv_getSSHJobSubmissionProtocol() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getSSHJobSubmissionProtocol_result result = new getSSHJobSubmissionProtocol_result();
+ receiveBase(result, "getSSHJobSubmissionProtocol");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSSHJobSubmissionProtocol failed: unknown result");
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.GSISSHJobSubmission getGSISSHJobSubmissionProtocol(String gsisshJobSubmissionProtocolResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getGSISSHJobSubmissionProtocol(gsisshJobSubmissionProtocolResourceId);
+ return recv_getGSISSHJobSubmissionProtocol();
+ }
+
+ public void send_getGSISSHJobSubmissionProtocol(String gsisshJobSubmissionProtocolResourceId) throws org.apache.thrift.TException
+ {
+ getGSISSHJobSubmissionProtocol_args args = new getGSISSHJobSubmissionProtocol_args();
+ args.setGsisshJobSubmissionProtocolResourceId(gsisshJobSubmissionProtocolResourceId);
+ sendBase("getGSISSHJobSubmissionProtocol", args);
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.GSISSHJobSubmission recv_getGSISSHJobSubmissionProtocol() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getGSISSHJobSubmissionProtocol_result result = new getGSISSHJobSubmissionProtocol_result();
+ receiveBase(result, "getGSISSHJobSubmissionProtocol");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getGSISSHJobSubmissionProtocol failed: unknown result");
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.GlobusJobSubmission getGlobusJobSubmissionProtocol(String globusJobSubmissionProtocolResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getGlobusJobSubmissionProtocol(globusJobSubmissionProtocolResourceId);
+ return recv_getGlobusJobSubmissionProtocol();
+ }
+
+ public void send_getGlobusJobSubmissionProtocol(String globusJobSubmissionProtocolResourceId) throws org.apache.thrift.TException
+ {
+ getGlobusJobSubmissionProtocol_args args = new getGlobusJobSubmissionProtocol_args();
+ args.setGlobusJobSubmissionProtocolResourceId(globusJobSubmissionProtocolResourceId);
+ sendBase("getGlobusJobSubmissionProtocol", args);
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.GlobusJobSubmission recv_getGlobusJobSubmissionProtocol() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getGlobusJobSubmissionProtocol_result result = new getGlobusJobSubmissionProtocol_result();
+ receiveBase(result, "getGlobusJobSubmissionProtocol");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getGlobusJobSubmissionProtocol failed: unknown result");
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement getSCPDataMovementProtocol(String scpDataMovementResourceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getSCPDataMovementProtocol(scpDataMovementResourceId);
+ return recv_getSCPDataMovementProtocol();
+ }
+
+ public void send_getSCPDataMovementProtocol(String scpDataMovementResourceId) throws org.apache.thrift.TException
+ {
+ getSCPDataMovementProtocol_args args = new getSCPDataMovementProtocol_args();
+ args.setScpDataMovementResourceId(scpDataMovementResourceId);
+ sendBase("getSCPDataMovementProtocol", args);
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement recv_getSCPDataMovementProtocol() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getSCPDataMovementProtocol_result result = new getSCPDataMovementProtocol_result();
+ receiveBase(result, "getSCPDataMovementProtocol");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSCPDataMovementProtocol failed: unknown result");
+ }
+
+ public boolean isComputeResourceDescriptionRegistered(String hostName) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_isComputeResourceDescriptionRegistered(hostName);
+ return recv_isComputeResourceDescriptionRegistered();
+ }
+
+ public void send_isComputeResourceDescriptionRegistered(String hostName) throws org.apache.thrift.TException
+ {
+ isComputeResourceDescriptionRegistered_args args = new isComputeResourceDescriptionRegistered_args();
+ args.setHostName(hostName);
+ sendBase("isComputeResourceDescriptionRegistered", args);
+ }
+
+ public boolean recv_isComputeResourceDescriptionRegistered() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ isComputeResourceDescriptionRegistered_result result = new isComputeResourceDescriptionRegistered_result();
+ receiveBase(result, "isComputeResourceDescriptionRegistered");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isComputeResourceDescriptionRegistered failed: unknown result");
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription getComputeResourceDescriptionFromHostName(String hostName) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getComputeResourceDescriptionFromHostName(hostName);
+ return recv_getComputeResourceDescriptionFromHostName();
+ }
+
+ public void send_getComputeResourceDescriptionFromHostName(String hostName) throws org.apache.thrift.TException
+ {
+ getComputeResourceDescriptionFromHostName_args args = new getComputeResourceDescriptionFromHostName_args();
+ args.setHostName(hostName);
+ sendBase("getComputeResourceDescriptionFromHostName", args);
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription recv_getComputeResourceDescriptionFromHostName() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getComputeResourceDescriptionFromHostName_result result = new getComputeResourceDescriptionFromHostName_result();
+ receiveBase(result, "getComputeResourceDescriptionFromHostName");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getComputeResourceDescriptionFromHostName failed: unknown result");
+ }
+
+ public void addApplicationInterface(org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface applicationInterface) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_addApplicationInterface(applicationInterface);
+ recv_addApplicationInterface();
+ }
+
+ public void send_addApplicationInterface(org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface applicationInterface) throws org.apache.thrift.TException
+ {
+ addApplicationInterface_args args = new addApplicationInterface_args();
+ args.setApplicationInterface(applicationInterface);
+ sendBase("addApplicationInterface", args);
+ }
+
+ public void recv_addApplicationInterface() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ addApplicationInterface_result result = new addApplicationInterface_result();
+ receiveBase(result, "addApplicationInterface");
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ return;
+ }
+
+ public List<String> listApplicationInterfaceIds() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_listApplicationInterfaceIds();
+ return recv_listApplicationInterfaceIds();
+ }
+
+ public void send_listApplicationInterfaceIds() throws org.apache.thrift.TException
+ {
+ listApplicationInterfaceIds_args args = new listApplicationInterfaceIds_args();
+ sendBase("listApplicationInterfaceIds", args);
+ }
+
+ public List<String> recv_listApplicationInterfaceIds() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ listApplicationInterfaceIds_result result = new listApplicationInterfaceIds_result();
+ receiveBase(result, "listApplicationInterfaceIds");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listApplicationInterfaceIds failed: unknown result");
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface getApplicationInterface(String applicationInterfaceId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getApplicationInterface(applicationInterfaceId);
+ return recv_getApplicationInterface();
+ }
+
+ public void send_getApplicationInterface(String applicationInterfaceId) throws org.apache.thrift.TException
+ {
+ getApplicationInterface_args args = new getApplicationInterface_args();
+ args.setApplicationInterfaceId(applicationInterfaceId);
+ sendBase("getApplicationInterface", args);
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface recv_getApplicationInterface() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getApplicationInterface_result result = new getApplicationInterface_result();
+ receiveBase(result, "getApplicationInterface");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getApplicationInterface failed: unknown result");
+ }
+
+ public void addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment applicationDeployment) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_addApplicationDeployment(applicationInterfaceId, applicationDeployment);
+ recv_addApplicationDeployment();
+ }
+
+ public void send_addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment applicationDeployment) throws org.apache.thrift.TException
+ {
+ addApplicationDeployment_args args = new addApplicationDeployment_args();
+ args.setApplicationInterfaceId(applicationInterfaceId);
+ args.setApplicationDeployment(applicationDeployment);
+ sendBase("addApplicationDeployment", args);
+ }
+
+ public void recv_addApplicationDeployment() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ addApplicationDeployment_result result = new addApplicationDeployment_result();
+ receiveBase(result, "addApplicationDeployment");
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ return;
+ }
+
+ public List<String> listApplicationDeploymentIds() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_listApplicationDeploymentIds();
+ return recv_listApplicationDeploymentIds();
+ }
+
+ public void send_listApplicationDeploymentIds() throws org.apache.thrift.TException
+ {
+ listApplicationDeploymentIds_args args = new listApplicationDeploymentIds_args();
+ sendBase("listApplicationDeploymentIds", args);
+ }
+
+ public List<String> recv_listApplicationDeploymentIds() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ listApplicationDeploymentIds_result result = new listApplicationDeploymentIds_result();
+ receiveBase(result, "listApplicationDeploymentIds");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listApplicationDeploymentIds failed: unknown result");
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment getApplicationDeployment(String applicationDeploymentId) throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getApplicationDeployment(applicationDeploymentId);
+ return recv_getApplicationDeployment();
+ }
+
+ public void send_getApplicationDeployment(String applicationDeploymentId) throws org.apache.thrift.TException
+ {
+ getApplicationDeployment_args args = new getApplicationDeployment_args();
+ args.setApplicationDeploymentId(applicationDeploymentId);
+ sendBase("getApplicationDeployment", args);
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment recv_getApplicationDeployment() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getApplicationDeployment_result result = new getApplicationDeployment_result();
+ receiveBase(result, "getApplicationDeployment");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ if (result.ace != null) {
+ throw result.ace;
+ }
+ if (result.ase != null) {
+ throw result.ase;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getApplicationDeployment failed: unknown result");
+ }
+
+ }
+ public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
+ public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
+ private org.apache.thrift.async.TAsyncClientManager clientManager;
+ private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
+ public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
+ this.clientManager = clientManager;
+ this.protocolFactory = protocolFactory;
+ }
+ public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
+ return new AsyncClient(protocolFactory, clientManager, transport);
+ }
+ }
+
+ public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
+ super(protocolFactory, clientManager, transport);
+ }
+
+ public void GetAPIVersion(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetAPIVersion_call method_call = new GetAPIVersion_call(resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetAPIVersion_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public GetAPIVersion_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("GetAPIVersion", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetAPIVersion_args args = new GetAPIVersion_args();
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public String getResult() throws org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_GetAPIVersion();
+ }
+ }
+
+ public void addComputerResourceDescription(org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription computeResourceDescription, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ addComputerResourceDescription_call method_call = new addComputerResourceDescription_call(computeResourceDescription, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class addComputerResourceDescription_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription computeResourceDescription;
+ public addComputerResourceDescription_call(org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription computeResourceDescription, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.computeResourceDescription = computeResourceDescription;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addComputerResourceDescription", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ addComputerResourceDescription_args args = new addComputerResourceDescription_args();
+ args.setComputeResourceDescription(computeResourceDescription);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_addComputerResourceDescription();
+ }
+ }
+
+ public void addJobSubmissionProtocol(String computeResourceId, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission jobSubmission, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ addJobSubmissionProtocol_call method_call = new addJobSubmissionProtocol_call(computeResourceId, jobSubmission, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class addJobSubmissionProtocol_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String computeResourceId;
+ private org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission jobSubmission;
+ public addJobSubmissionProtocol_call(String computeResourceId, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission jobSubmission, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.computeResourceId = computeResourceId;
+ this.jobSubmission = jobSubmission;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addJobSubmissionProtocol", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ addJobSubmissionProtocol_args args = new addJobSubmissionProtocol_args();
+ args.setComputeResourceId(computeResourceId);
+ args.setJobSubmission(jobSubmission);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_addJobSubmissionProtocol();
+ }
+ }
+
+ public void listComputeResourceDescriptions(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ listComputeResourceDescriptions_call method_call = new listComputeResourceDescriptions_call(resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class listComputeResourceDescriptions_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public listComputeResourceDescriptions_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("listComputeResourceDescriptions", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ listComputeResourceDescriptions_args args = new listComputeResourceDescriptions_args();
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<String> getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_listComputeResourceDescriptions();
+ }
+ }
+
+ public void getComputeResourceDescription(String computeResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getComputeResourceDescription_call method_call = new getComputeResourceDescription_call(computeResourceId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getComputeResourceDescription_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String computeResourceId;
+ public getComputeResourceDescription_call(String computeResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.computeResourceId = computeResourceId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getComputeResourceDescription", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getComputeResourceDescription_args args = new getComputeResourceDescription_args();
+ args.setComputeResourceId(computeResourceId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getComputeResourceDescription();
+ }
+ }
+
+ public void getSSHJobSubmissionProtocol(String sshJobSubmissionProtocolResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getSSHJobSubmissionProtocol_call method_call = new getSSHJobSubmissionProtocol_call(sshJobSubmissionProtocolResourceId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getSSHJobSubmissionProtocol_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String sshJobSubmissionProtocolResourceId;
+ public getSSHJobSubmissionProtocol_call(String sshJobSubmissionProtocolResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.sshJobSubmissionProtocolResourceId = sshJobSubmissionProtocolResourceId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getSSHJobSubmissionProtocol", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getSSHJobSubmissionProtocol_args args = new getSSHJobSubmissionProtocol_args();
+ args.setSshJobSubmissionProtocolResourceId(sshJobSubmissionProtocolResourceId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getSSHJobSubmissionProtocol();
+ }
+ }
+
+ public void getGSISSHJobSubmissionProtocol(String gsisshJobSubmissionProtocolResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getGSISSHJobSubmissionProtocol_call method_call = new getGSISSHJobSubmissionProtocol_call(gsisshJobSubmissionProtocolResourceId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getGSISSHJobSubmissionProtocol_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String gsisshJobSubmissionProtocolResourceId;
+ public getGSISSHJobSubmissionProtocol_call(String gsisshJobSubmissionProtocolResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.gsisshJobSubmissionProtocolResourceId = gsisshJobSubmissionProtocolResourceId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getGSISSHJobSubmissionProtocol", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getGSISSHJobSubmissionProtocol_args args = new getGSISSHJobSubmissionProtocol_args();
+ args.setGsisshJobSubmissionProtocolResourceId(gsisshJobSubmissionProtocolResourceId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.GSISSHJobSubmission getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getGSISSHJobSubmissionProtocol();
+ }
+ }
+
+ public void getGlobusJobSubmissionProtocol(String globusJobSubmissionProtocolResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getGlobusJobSubmissionProtocol_call method_call = new getGlobusJobSubmissionProtocol_call(globusJobSubmissionProtocolResourceId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getGlobusJobSubmissionProtocol_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String globusJobSubmissionProtocolResourceId;
+ public getGlobusJobSubmissionProtocol_call(String globusJobSubmissionProtocolResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.globusJobSubmissionProtocolResourceId = globusJobSubmissionProtocolResourceId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getGlobusJobSubmissionProtocol", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getGlobusJobSubmissionProtocol_args args = new getGlobusJobSubmissionProtocol_args();
+ args.setGlobusJobSubmissionProtocolResourceId(globusJobSubmissionProtocolResourceId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.GlobusJobSubmission getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getGlobusJobSubmissionProtocol();
+ }
+ }
+
+ public void getSCPDataMovementProtocol(String scpDataMovementResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getSCPDataMovementProtocol_call method_call = new getSCPDataMovementProtocol_call(scpDataMovementResourceId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getSCPDataMovementProtocol_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String scpDataMovementResourceId;
+ public getSCPDataMovementProtocol_call(String scpDataMovementResourceId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.scpDataMovementResourceId = scpDataMovementResourceId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getSCPDataMovementProtocol", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getSCPDataMovementProtocol_args args = new getSCPDataMovementProtocol_args();
+ args.setScpDataMovementResourceId(scpDataMovementResourceId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.SCPDataMovement getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getSCPDataMovementProtocol();
+ }
+ }
+
+ public void isComputeResourceDescriptionRegistered(String hostName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ isComputeResourceDescriptionRegistered_call method_call = new isComputeResourceDescriptionRegistered_call(hostName, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class isComputeResourceDescriptionRegistered_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String hostName;
+ public isComputeResourceDescriptionRegistered_call(String hostName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.hostName = hostName;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isComputeResourceDescriptionRegistered", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ isComputeResourceDescriptionRegistered_args args = new isComputeResourceDescriptionRegistered_args();
+ args.setHostName(hostName);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_isComputeResourceDescriptionRegistered();
+ }
+ }
+
+ public void getComputeResourceDescriptionFromHostName(String hostName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getComputeResourceDescriptionFromHostName_call method_call = new getComputeResourceDescriptionFromHostName_call(hostName, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getComputeResourceDescriptionFromHostName_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String hostName;
+ public getComputeResourceDescriptionFromHostName_call(String hostName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.hostName = hostName;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getComputeResourceDescriptionFromHostName", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getComputeResourceDescriptionFromHostName_args args = new getComputeResourceDescriptionFromHostName_args();
+ args.setHostName(hostName);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getComputeResourceDescriptionFromHostName();
+ }
+ }
+
+ public void addApplicationInterface(org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface applicationInterface, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ addApplicationInterface_call method_call = new addApplicationInterface_call(applicationInterface, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class addApplicationInterface_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface applicationInterface;
+ public addApplicationInterface_call(org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface applicationInterface, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.applicationInterface = applicationInterface;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addApplicationInterface", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ addApplicationInterface_args args = new addApplicationInterface_args();
+ args.setApplicationInterface(applicationInterface);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_addApplicationInterface();
+ }
+ }
+
+ public void listApplicationInterfaceIds(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ listApplicationInterfaceIds_call method_call = new listApplicationInterfaceIds_call(resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class listApplicationInterfaceIds_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public listApplicationInterfaceIds_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("listApplicationInterfaceIds", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ listApplicationInterfaceIds_args args = new listApplicationInterfaceIds_args();
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<String> getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_listApplicationInterfaceIds();
+ }
+ }
+
+ public void getApplicationInterface(String applicationInterfaceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getApplicationInterface_call method_call = new getApplicationInterface_call(applicationInterfaceId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getApplicationInterface_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String applicationInterfaceId;
+ public getApplicationInterface_call(String applicationInterfaceId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.applicationInterfaceId = applicationInterfaceId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getApplicationInterface", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getApplicationInterface_args args = new getApplicationInterface_args();
+ args.setApplicationInterfaceId(applicationInterfaceId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ApplicationInterface getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getApplicationInterface();
+ }
+ }
+
+ public void addApplicationDeployment(String applicationInterfaceId, org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment applicationDeployment, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ addApplicationDeployment_call method_call = new addApplicationDeployment_call(applicationInterfaceId, applicationDeployment, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class addApplicationDeployment_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String applicationInterfaceId;
+ private org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment applicationDeployment;
+ public addApplicationDeployment_call(String applicationInterfaceId, org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment applicationDeployment, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.applicationInterfaceId = applicationInterfaceId;
+ this.applicationDeployment = applicationDeployment;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addApplicationDeployment", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ addApplicationDeployment_args args = new addApplicationDeployment_args();
+ args.setApplicationInterfaceId(applicationInterfaceId);
+ args.setApplicationDeployment(applicationDeployment);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_addApplicationDeployment();
+ }
+ }
+
+ public void listApplicationDeploymentIds(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ listApplicationDeploymentIds_call method_call = new listApplicationDeploymentIds_call(resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class listApplicationDeploymentIds_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public listApplicationDeploymentIds_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("listApplicationDeploymentIds", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ listApplicationDeploymentIds_args args = new listApplicationDeploymentIds_args();
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<String> getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_listApplicationDeploymentIds();
+ }
+ }
+
+ public void getApplicationDeployment(String applicationDeploymentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getApplicationDeployment_call method_call = new getApplicationDeployment_call(applicationDeploymentId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getApplicationDeployment_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String applicationDeploymentId;
+ public getApplicationDeployment_call(String applicationDeploymentId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.applicationDeploymentId = applicationDeploymentId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getApplicationDeployment", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getApplicationDeployment_args args = new getApplicationDeployment_args();
+ args.setApplicationDeploymentId(applicationDeploymentId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public org.apache.airavata.model.appcatalog.computeresource.ApplicationDeployment getResult() throws org.apache.airavata.api.error.InvalidRequestException, org.apache.airavata.api.error.AiravataClientException, org.apache.airavata.api.error.AiravataSystemException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_getApplicationDeployment();
+ }
+ }
+
+ }
+
+ public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor {
+ private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
+ public Processor(I iface) {
+ super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
+ }
+
+ protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ super(iface, getProcessMap(processMap));
+ }
+
+ private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ processMap.put("GetAPIVersion", new GetAPIVersion());
+ processMap.put("addComputerResourceDescription", new addComputerResourceDescription());
+ processMap.put("addJobSubmissionProtocol", new addJobSubmissionProtocol());
+ processMap.put("listComputeResourceDescriptions", new listComputeResourceDescriptions());
+ processMap.put("getComputeResourceDescription", new getComputeResourceDescription());
+ processMap.put("getSSHJobSubmissionProtocol", new getSSHJobSubmissionProtocol());
+ processMap.put("getGSISSHJobSubmissionProtocol", new getGSISSHJobSubmissionProtocol());
+ processMap.put("getGlobusJobSubmissionProtocol", new getGlobusJobSubmissionProtocol());
+ processMap.put("getSCPDataMovementProtocol", new getSCPDataMovementProtocol());
+ processMap.put("isComputeResourceDescriptionRegistered", new isComputeResourceDescriptionRegistered());
+ processMap.put("getComputeResourceDescriptionFromHostName", new getComputeResourceDescriptionFromHostName());
+ processMap.put("addApplicationInterface", new addApplicationInterface());
+ processMap.put("listApplicationInterfaceIds", new listApplicationInterfaceIds());
+ processMap.put("getApplicationInterface", new getApplicationInterface());
+ processMap.put("addApplicationDeployment", new addApplicationDeployment());
+ processMap.put("listApplicationDeploymentIds", new listApplicationDeploymentIds());
+ processMap.put("getApplicationDeployment", new getApplicationDeployment());
+ return processMap;
+ }
+
+ public static class GetAPIVersion<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetAPIVersion_args> {
+ public GetAPIVersion() {
+ super("GetAPIVersion");
+ }
+
+ public GetAPIVersion_args getEmptyArgsInstance() {
+ return new GetAPIVersion_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetAPIVersion_result getResult(I iface, GetAPIVersion_args args) throws org.apache.thrift.TException {
+ GetAPIVersion_result result = new GetAPIVersion_result();
+ result.success = iface.GetAPIVersion();
+ return result;
+ }
+ }
+
+ public static class addComputerResourceDescription<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addComputerResourceDescription_args> {
+ public addComputerResourceDescription() {
+ super("addComputerResourceDescription");
+ }
+
+ public addComputerResourceDescription_args getEmptyArgsInstance() {
+ return new addComputerResourceDescription_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public addComputerResourceDescription_result getResult(I iface, addComputerResourceDescription_args args) throws org.apache.thrift.TException {
+ addComputerResourceDescription_result result = new addComputerResourceDescription_result();
+ try {
+ iface.addComputerResourceDescription(args.computeResourceDescription);
+ } catch (org.apache.airavata.api.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.api.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.apache.airavata.api.error.AiravataSystemException ase) {
+ result.ase = ase;
+ }
+ return result;
+ }
+ }
+
+ public static class addJobSubmissionProtocol<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addJobSubmissionProtocol_args> {
+ public addJobSubmissionProtocol() {
+ super("addJobSubmissionProtocol");
+ }
+
+ public addJobSubmissionProtocol_args getEmptyArgsInstance() {
+ return new addJobSubmissionProtocol_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public addJobSubmissionProtocol_result getResult(I iface, addJobSubmissionProtocol_args args) throws org.apache.thrift.TException {
+ addJobSubmissionProtocol_result result = new addJobSubmissionProtocol_result();
+ try {
+ iface.addJobSubmissionProtocol(args.computeResourceId, args.jobSubmission);
+ } catch (org.apache.airavata.api.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.api.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.apache.airavata.api.error.AiravataSystemException ase) {
+ result.ase = ase;
+ }
+ return result;
+ }
+ }
+
+ public static class listComputeResourceDescriptions<I extends Iface> extends org.apache.thrift.ProcessFunction<I, listComputeResourceDescriptions_args> {
+ public listComputeResourceDescriptions() {
+ super("listComputeResourceDescriptions");
+ }
+
+ public listComputeResourceDescriptions_args getEmptyArgsInstance() {
+ return new listComputeResourceDescriptions_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public listComputeResourceDescriptions_result getResult(I iface, listComputeResourceDescriptions_args args) throws org.apache.thrift.TException {
+ listComputeResourceDescriptions_result result = new listComputeResourceDescriptions_result();
+ try {
+ result.success = iface.listComputeResourceDescriptions();
+ } catch (org.apache.airavata.api.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.api.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.a
<TRUNCATED>