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 2016/01/15 21:48:29 UTC
[3/4] airavata git commit: adding clone application interface
function to API
http://git-wip-us.apache.org/repos/asf/airavata/blob/113490ef/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
index 99b48b1..3deb9d1 100644
--- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
+++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-06")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-15")
public class Airavata {
public interface Iface {
@@ -1209,6 +1209,8 @@ public class Airavata {
*/
public String registerApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription applicationInterface) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+ public String cloneApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String existingAppInterfaceID, String newApplicationName, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException;
+
/**
* Fetch a Application Interface.
*
@@ -2444,6 +2446,8 @@ public class Airavata {
public void registerApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription applicationInterface, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void cloneApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String existingAppInterfaceID, String newApplicationName, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void getApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String appInterfaceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void updateApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String appInterfaceId, org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription applicationInterface, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -4699,6 +4703,44 @@ public class Airavata {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "registerApplicationInterface failed: unknown result");
}
+ public String cloneApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String existingAppInterfaceID, String newApplicationName, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ send_cloneApplicationInterface(authzToken, existingAppInterfaceID, newApplicationName, gatewayId);
+ return recv_cloneApplicationInterface();
+ }
+
+ public void send_cloneApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String existingAppInterfaceID, String newApplicationName, String gatewayId) throws org.apache.thrift.TException
+ {
+ cloneApplicationInterface_args args = new cloneApplicationInterface_args();
+ args.setAuthzToken(authzToken);
+ args.setExistingAppInterfaceID(existingAppInterfaceID);
+ args.setNewApplicationName(newApplicationName);
+ args.setGatewayId(gatewayId);
+ sendBase("cloneApplicationInterface", args);
+ }
+
+ public String recv_cloneApplicationInterface() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
+ {
+ cloneApplicationInterface_result result = new cloneApplicationInterface_result();
+ receiveBase(result, "cloneApplicationInterface");
+ 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;
+ }
+ if (result.ae != null) {
+ throw result.ae;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "cloneApplicationInterface failed: unknown result");
+ }
+
public org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription getApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String appInterfaceId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException
{
send_getApplicationInterface(authzToken, appInterfaceId);
@@ -9850,6 +9892,47 @@ public class Airavata {
}
}
+ public void cloneApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String existingAppInterfaceID, String newApplicationName, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ cloneApplicationInterface_call method_call = new cloneApplicationInterface_call(authzToken, existingAppInterfaceID, newApplicationName, gatewayId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class cloneApplicationInterface_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private org.apache.airavata.model.security.AuthzToken authzToken;
+ private String existingAppInterfaceID;
+ private String newApplicationName;
+ private String gatewayId;
+ public cloneApplicationInterface_call(org.apache.airavata.model.security.AuthzToken authzToken, String existingAppInterfaceID, String newApplicationName, String gatewayId, 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.authzToken = authzToken;
+ this.existingAppInterfaceID = existingAppInterfaceID;
+ this.newApplicationName = newApplicationName;
+ this.gatewayId = gatewayId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("cloneApplicationInterface", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ cloneApplicationInterface_args args = new cloneApplicationInterface_args();
+ args.setAuthzToken(authzToken);
+ args.setExistingAppInterfaceID(existingAppInterfaceID);
+ args.setNewApplicationName(newApplicationName);
+ args.setGatewayId(gatewayId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, 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_cloneApplicationInterface();
+ }
+ }
+
public void getApplicationInterface(org.apache.airavata.model.security.AuthzToken authzToken, String appInterfaceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getApplicationInterface_call method_call = new getApplicationInterface_call(authzToken, appInterfaceId, resultHandler, this, ___protocolFactory, ___transport);
@@ -12957,6 +13040,7 @@ public class Airavata {
processMap.put("getAllApplicationDeployments", new getAllApplicationDeployments());
processMap.put("getAppModuleDeployedResources", new getAppModuleDeployedResources());
processMap.put("registerApplicationInterface", new registerApplicationInterface());
+ processMap.put("cloneApplicationInterface", new cloneApplicationInterface());
processMap.put("getApplicationInterface", new getApplicationInterface());
processMap.put("updateApplicationInterface", new updateApplicationInterface());
processMap.put("deleteApplicationInterface", new deleteApplicationInterface());
@@ -14742,6 +14826,36 @@ public class Airavata {
}
}
+ public static class cloneApplicationInterface<I extends Iface> extends org.apache.thrift.ProcessFunction<I, cloneApplicationInterface_args> {
+ public cloneApplicationInterface() {
+ super("cloneApplicationInterface");
+ }
+
+ public cloneApplicationInterface_args getEmptyArgsInstance() {
+ return new cloneApplicationInterface_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public cloneApplicationInterface_result getResult(I iface, cloneApplicationInterface_args args) throws org.apache.thrift.TException {
+ cloneApplicationInterface_result result = new cloneApplicationInterface_result();
+ try {
+ result.success = iface.cloneApplicationInterface(args.authzToken, args.existingAppInterfaceID, args.newApplicationName, args.gatewayId);
+ } catch (org.apache.airavata.model.error.InvalidRequestException ire) {
+ result.ire = ire;
+ } catch (org.apache.airavata.model.error.AiravataClientException ace) {
+ result.ace = ace;
+ } catch (org.apache.airavata.model.error.AiravataSystemException ase) {
+ result.ase = ase;
+ } catch (org.apache.airavata.model.error.AuthorizationException ae) {
+ result.ae = ae;
+ }
+ return result;
+ }
+ }
+
public static class getApplicationInterface<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getApplicationInterface_args> {
public getApplicationInterface() {
super("getApplicationInterface");
@@ -17303,6 +17417,7 @@ public class Airavata {
processMap.put("getAllApplicationDeployments", new getAllApplicationDeployments());
processMap.put("getAppModuleDeployedResources", new getAppModuleDeployedResources());
processMap.put("registerApplicationInterface", new registerApplicationInterface());
+ processMap.put("cloneApplicationInterface", new cloneApplicationInterface());
processMap.put("getApplicationInterface", new getApplicationInterface());
processMap.put("updateApplicationInterface", new updateApplicationInterface());
processMap.put("deleteApplicationInterface", new deleteApplicationInterface());
@@ -21448,20 +21563,20 @@ public class Airavata {
}
}
- public static class getApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInterface_args, org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> {
- public getApplicationInterface() {
- super("getApplicationInterface");
+ public static class cloneApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneApplicationInterface_args, String> {
+ public cloneApplicationInterface() {
+ super("cloneApplicationInterface");
}
- public getApplicationInterface_args getEmptyArgsInstance() {
- return new getApplicationInterface_args();
+ public cloneApplicationInterface_args getEmptyArgsInstance() {
+ return new cloneApplicationInterface_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>() {
- public void onComplete(org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription o) {
- getApplicationInterface_result result = new getApplicationInterface_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ cloneApplicationInterface_result result = new cloneApplicationInterface_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -21474,7 +21589,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getApplicationInterface_result result = new getApplicationInterface_result();
+ cloneApplicationInterface_result result = new cloneApplicationInterface_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21515,27 +21630,26 @@ public class Airavata {
return false;
}
- public void start(I iface, getApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> resultHandler) throws TException {
- iface.getApplicationInterface(args.authzToken, args.appInterfaceId,resultHandler);
+ public void start(I iface, cloneApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.cloneApplicationInterface(args.authzToken, args.existingAppInterfaceID, args.newApplicationName, args.gatewayId,resultHandler);
}
}
- public static class updateApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationInterface_args, Boolean> {
- public updateApplicationInterface() {
- super("updateApplicationInterface");
+ public static class getApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInterface_args, org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> {
+ public getApplicationInterface() {
+ super("getApplicationInterface");
}
- public updateApplicationInterface_args getEmptyArgsInstance() {
- return new updateApplicationInterface_args();
+ public getApplicationInterface_args getEmptyArgsInstance() {
+ return new getApplicationInterface_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- updateApplicationInterface_result result = new updateApplicationInterface_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription o) {
+ getApplicationInterface_result result = new getApplicationInterface_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -21547,7 +21661,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateApplicationInterface_result result = new updateApplicationInterface_result();
+ getApplicationInterface_result result = new getApplicationInterface_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21588,25 +21702,25 @@ public class Airavata {
return false;
}
- public void start(I iface, updateApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateApplicationInterface(args.authzToken, args.appInterfaceId, args.applicationInterface,resultHandler);
+ public void start(I iface, getApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> resultHandler) throws TException {
+ iface.getApplicationInterface(args.authzToken, args.appInterfaceId,resultHandler);
}
}
- public static class deleteApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationInterface_args, Boolean> {
- public deleteApplicationInterface() {
- super("deleteApplicationInterface");
+ public static class updateApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationInterface_args, Boolean> {
+ public updateApplicationInterface() {
+ super("updateApplicationInterface");
}
- public deleteApplicationInterface_args getEmptyArgsInstance() {
- return new deleteApplicationInterface_args();
+ public updateApplicationInterface_args getEmptyArgsInstance() {
+ return new updateApplicationInterface_args();
}
public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Boolean>() {
public void onComplete(Boolean o) {
- deleteApplicationInterface_result result = new deleteApplicationInterface_result();
+ updateApplicationInterface_result result = new updateApplicationInterface_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -21620,223 +21734,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteApplicationInterface_result result = new deleteApplicationInterface_result();
- if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
- result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
- result.setIreIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
- result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
- result.setAceIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
- result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
- result.setAseIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AuthorizationException) {
- result.ae = (org.apache.airavata.model.error.AuthorizationException) e;
- result.setAeIsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, deleteApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteApplicationInterface(args.authzToken, args.appInterfaceId,resultHandler);
- }
- }
-
- public static class getAllApplicationInterfaceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationInterfaceNames_args, Map<String,String>> {
- public getAllApplicationInterfaceNames() {
- super("getAllApplicationInterfaceNames");
- }
-
- public getAllApplicationInterfaceNames_args getEmptyArgsInstance() {
- return new getAllApplicationInterfaceNames_args();
- }
-
- public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Map<String,String>>() {
- public void onComplete(Map<String,String> o) {
- getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result();
- if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
- result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
- result.setIreIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
- result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
- result.setAceIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
- result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
- result.setAseIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AuthorizationException) {
- result.ae = (org.apache.airavata.model.error.AuthorizationException) e;
- result.setAeIsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, getAllApplicationInterfaceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
- iface.getAllApplicationInterfaceNames(args.authzToken, args.gatewayId,resultHandler);
- }
- }
-
- public static class getAllApplicationInterfaces<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationInterfaces_args, List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>> {
- public getAllApplicationInterfaces() {
- super("getAllApplicationInterfaces");
- }
-
- public getAllApplicationInterfaces_args getEmptyArgsInstance() {
- return new getAllApplicationInterfaces_args();
- }
-
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> o) {
- getAllApplicationInterfaces_result result = new getAllApplicationInterfaces_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- getAllApplicationInterfaces_result result = new getAllApplicationInterfaces_result();
- if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
- result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
- result.setIreIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataClientException) {
- result.ace = (org.apache.airavata.model.error.AiravataClientException) e;
- result.setAceIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) {
- result.ase = (org.apache.airavata.model.error.AiravataSystemException) e;
- result.setAseIsSet(true);
- msg = result;
- }
- else if (e instanceof org.apache.airavata.model.error.AuthorizationException) {
- result.ae = (org.apache.airavata.model.error.AuthorizationException) e;
- result.setAeIsSet(true);
- msg = result;
- }
- else
- {
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
- }
- try {
- fcall.sendResponse(fb,msg,msgType,seqid);
- return;
- } catch (Exception ex) {
- LOGGER.error("Exception writing to internal frame buffer", ex);
- }
- fb.close();
- }
- };
- }
-
- protected boolean isOneway() {
- return false;
- }
-
- public void start(I iface, getAllApplicationInterfaces_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>> resultHandler) throws TException {
- iface.getAllApplicationInterfaces(args.authzToken, args.gatewayId,resultHandler);
- }
- }
-
- public static class getApplicationInputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInputs_args, List<org.apache.airavata.model.application.io.InputDataObjectType>> {
- public getApplicationInputs() {
- super("getApplicationInputs");
- }
-
- public getApplicationInputs_args getEmptyArgsInstance() {
- return new getApplicationInputs_args();
- }
-
- public AsyncMethodCallback<List<org.apache.airavata.model.application.io.InputDataObjectType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.application.io.InputDataObjectType>>() {
- public void onComplete(List<org.apache.airavata.model.application.io.InputDataObjectType> o) {
- getApplicationInputs_result result = new getApplicationInputs_result();
- result.success = o;
- try {
- fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- return;
- } catch (Exception e) {
- LOGGER.error("Exception writing to internal frame buffer", e);
- }
- fb.close();
- }
- public void onError(Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TBase msg;
- getApplicationInputs_result result = new getApplicationInputs_result();
+ updateApplicationInterface_result result = new updateApplicationInterface_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21877,26 +21775,27 @@ public class Airavata {
return false;
}
- public void start(I iface, getApplicationInputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.application.io.InputDataObjectType>> resultHandler) throws TException {
- iface.getApplicationInputs(args.authzToken, args.appInterfaceId,resultHandler);
+ public void start(I iface, updateApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateApplicationInterface(args.authzToken, args.appInterfaceId, args.applicationInterface,resultHandler);
}
}
- public static class getApplicationOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationOutputs_args, List<org.apache.airavata.model.application.io.OutputDataObjectType>> {
- public getApplicationOutputs() {
- super("getApplicationOutputs");
+ public static class deleteApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationInterface_args, Boolean> {
+ public deleteApplicationInterface() {
+ super("deleteApplicationInterface");
}
- public getApplicationOutputs_args getEmptyArgsInstance() {
- return new getApplicationOutputs_args();
+ public deleteApplicationInterface_args getEmptyArgsInstance() {
+ return new deleteApplicationInterface_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.application.io.OutputDataObjectType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.model.application.io.OutputDataObjectType>>() {
- public void onComplete(List<org.apache.airavata.model.application.io.OutputDataObjectType> o) {
- getApplicationOutputs_result result = new getApplicationOutputs_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteApplicationInterface_result result = new deleteApplicationInterface_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -21908,7 +21807,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getApplicationOutputs_result result = new getApplicationOutputs_result();
+ deleteApplicationInterface_result result = new deleteApplicationInterface_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -21949,25 +21848,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getApplicationOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.application.io.OutputDataObjectType>> resultHandler) throws TException {
- iface.getApplicationOutputs(args.authzToken, args.appInterfaceId,resultHandler);
+ public void start(I iface, deleteApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteApplicationInterface(args.authzToken, args.appInterfaceId,resultHandler);
}
}
- public static class getAvailableAppInterfaceComputeResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAvailableAppInterfaceComputeResources_args, Map<String,String>> {
- public getAvailableAppInterfaceComputeResources() {
- super("getAvailableAppInterfaceComputeResources");
+ public static class getAllApplicationInterfaceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationInterfaceNames_args, Map<String,String>> {
+ public getAllApplicationInterfaceNames() {
+ super("getAllApplicationInterfaceNames");
}
- public getAvailableAppInterfaceComputeResources_args getEmptyArgsInstance() {
- return new getAvailableAppInterfaceComputeResources_args();
+ public getAllApplicationInterfaceNames_args getEmptyArgsInstance() {
+ return new getAllApplicationInterfaceNames_args();
}
public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Map<String,String>>() {
public void onComplete(Map<String,String> o) {
- getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceComputeResources_result();
+ getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -21980,7 +21879,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceComputeResources_result();
+ getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22021,25 +21920,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getAvailableAppInterfaceComputeResources_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
- iface.getAvailableAppInterfaceComputeResources(args.authzToken, args.appInterfaceId,resultHandler);
+ public void start(I iface, getAllApplicationInterfaceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
+ iface.getAllApplicationInterfaceNames(args.authzToken, args.gatewayId,resultHandler);
}
}
- public static class registerComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerComputeResource_args, String> {
- public registerComputeResource() {
- super("registerComputeResource");
+ public static class getAllApplicationInterfaces<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationInterfaces_args, List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>> {
+ public getAllApplicationInterfaces() {
+ super("getAllApplicationInterfaces");
}
- public registerComputeResource_args getEmptyArgsInstance() {
- return new registerComputeResource_args();
+ public getAllApplicationInterfaces_args getEmptyArgsInstance() {
+ return new getAllApplicationInterfaces_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- registerComputeResource_result result = new registerComputeResource_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> o) {
+ getAllApplicationInterfaces_result result = new getAllApplicationInterfaces_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -22052,7 +21951,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerComputeResource_result result = new registerComputeResource_result();
+ getAllApplicationInterfaces_result result = new getAllApplicationInterfaces_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22093,25 +21992,25 @@ public class Airavata {
return false;
}
- public void start(I iface, registerComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.registerComputeResource(args.authzToken, args.computeResourceDescription,resultHandler);
+ public void start(I iface, getAllApplicationInterfaces_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription>> resultHandler) throws TException {
+ iface.getAllApplicationInterfaces(args.authzToken, args.gatewayId,resultHandler);
}
}
- public static class getComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getComputeResource_args, org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription> {
- public getComputeResource() {
- super("getComputeResource");
+ public static class getApplicationInputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInputs_args, List<org.apache.airavata.model.application.io.InputDataObjectType>> {
+ public getApplicationInputs() {
+ super("getApplicationInputs");
}
- public getComputeResource_args getEmptyArgsInstance() {
- return new getComputeResource_args();
+ public getApplicationInputs_args getEmptyArgsInstance() {
+ return new getApplicationInputs_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.application.io.InputDataObjectType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription>() {
- public void onComplete(org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription o) {
- getComputeResource_result result = new getComputeResource_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.application.io.InputDataObjectType>>() {
+ public void onComplete(List<org.apache.airavata.model.application.io.InputDataObjectType> o) {
+ getApplicationInputs_result result = new getApplicationInputs_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -22124,7 +22023,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getComputeResource_result result = new getComputeResource_result();
+ getApplicationInputs_result result = new getApplicationInputs_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22165,25 +22064,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription> resultHandler) throws TException {
- iface.getComputeResource(args.authzToken, args.computeResourceId,resultHandler);
+ public void start(I iface, getApplicationInputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.application.io.InputDataObjectType>> resultHandler) throws TException {
+ iface.getApplicationInputs(args.authzToken, args.appInterfaceId,resultHandler);
}
}
- public static class getAllComputeResourceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllComputeResourceNames_args, Map<String,String>> {
- public getAllComputeResourceNames() {
- super("getAllComputeResourceNames");
+ public static class getApplicationOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationOutputs_args, List<org.apache.airavata.model.application.io.OutputDataObjectType>> {
+ public getApplicationOutputs() {
+ super("getApplicationOutputs");
}
- public getAllComputeResourceNames_args getEmptyArgsInstance() {
- return new getAllComputeResourceNames_args();
+ public getApplicationOutputs_args getEmptyArgsInstance() {
+ return new getApplicationOutputs_args();
}
- public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.application.io.OutputDataObjectType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Map<String,String>>() {
- public void onComplete(Map<String,String> o) {
- getAllComputeResourceNames_result result = new getAllComputeResourceNames_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.application.io.OutputDataObjectType>>() {
+ public void onComplete(List<org.apache.airavata.model.application.io.OutputDataObjectType> o) {
+ getApplicationOutputs_result result = new getApplicationOutputs_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -22196,7 +22095,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllComputeResourceNames_result result = new getAllComputeResourceNames_result();
+ getApplicationOutputs_result result = new getApplicationOutputs_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22237,27 +22136,26 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllComputeResourceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
- iface.getAllComputeResourceNames(args.authzToken,resultHandler);
+ public void start(I iface, getApplicationOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.application.io.OutputDataObjectType>> resultHandler) throws TException {
+ iface.getApplicationOutputs(args.authzToken, args.appInterfaceId,resultHandler);
}
}
- public static class updateComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateComputeResource_args, Boolean> {
- public updateComputeResource() {
- super("updateComputeResource");
+ public static class getAvailableAppInterfaceComputeResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAvailableAppInterfaceComputeResources_args, Map<String,String>> {
+ public getAvailableAppInterfaceComputeResources() {
+ super("getAvailableAppInterfaceComputeResources");
}
- public updateComputeResource_args getEmptyArgsInstance() {
- return new updateComputeResource_args();
+ public getAvailableAppInterfaceComputeResources_args getEmptyArgsInstance() {
+ return new getAvailableAppInterfaceComputeResources_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- updateComputeResource_result result = new updateComputeResource_result();
+ return new AsyncMethodCallback<Map<String,String>>() {
+ public void onComplete(Map<String,String> o) {
+ getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceComputeResources_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22269,7 +22167,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateComputeResource_result result = new updateComputeResource_result();
+ getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceComputeResources_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22310,27 +22208,26 @@ public class Airavata {
return false;
}
- public void start(I iface, updateComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateComputeResource(args.authzToken, args.computeResourceId, args.computeResourceDescription,resultHandler);
+ public void start(I iface, getAvailableAppInterfaceComputeResources_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
+ iface.getAvailableAppInterfaceComputeResources(args.authzToken, args.appInterfaceId,resultHandler);
}
}
- public static class deleteComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteComputeResource_args, Boolean> {
- public deleteComputeResource() {
- super("deleteComputeResource");
+ public static class registerComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerComputeResource_args, String> {
+ public registerComputeResource() {
+ super("registerComputeResource");
}
- public deleteComputeResource_args getEmptyArgsInstance() {
- return new deleteComputeResource_args();
+ public registerComputeResource_args getEmptyArgsInstance() {
+ return new registerComputeResource_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- deleteComputeResource_result result = new deleteComputeResource_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ registerComputeResource_result result = new registerComputeResource_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22342,7 +22239,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteComputeResource_result result = new deleteComputeResource_result();
+ registerComputeResource_result result = new registerComputeResource_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22383,25 +22280,25 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteComputeResource(args.authzToken, args.computeResourceId,resultHandler);
+ public void start(I iface, registerComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerComputeResource(args.authzToken, args.computeResourceDescription,resultHandler);
}
}
- public static class registerStorageResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerStorageResource_args, String> {
- public registerStorageResource() {
- super("registerStorageResource");
+ public static class getComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getComputeResource_args, org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription> {
+ public getComputeResource() {
+ super("getComputeResource");
}
- public registerStorageResource_args getEmptyArgsInstance() {
- return new registerStorageResource_args();
+ public getComputeResource_args getEmptyArgsInstance() {
+ return new getComputeResource_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- registerStorageResource_result result = new registerStorageResource_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription o) {
+ getComputeResource_result result = new getComputeResource_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -22414,7 +22311,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerStorageResource_result result = new registerStorageResource_result();
+ getComputeResource_result result = new getComputeResource_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22455,25 +22352,25 @@ public class Airavata {
return false;
}
- public void start(I iface, registerStorageResource_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.registerStorageResource(args.authzToken, args.storageResourceDescription,resultHandler);
+ public void start(I iface, getComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription> resultHandler) throws TException {
+ iface.getComputeResource(args.authzToken, args.computeResourceId,resultHandler);
}
}
- public static class getStorageResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getStorageResource_args, org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription> {
- public getStorageResource() {
- super("getStorageResource");
+ public static class getAllComputeResourceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllComputeResourceNames_args, Map<String,String>> {
+ public getAllComputeResourceNames() {
+ super("getAllComputeResourceNames");
}
- public getStorageResource_args getEmptyArgsInstance() {
- return new getStorageResource_args();
+ public getAllComputeResourceNames_args getEmptyArgsInstance() {
+ return new getAllComputeResourceNames_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription>() {
- public void onComplete(org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription o) {
- getStorageResource_result result = new getStorageResource_result();
+ return new AsyncMethodCallback<Map<String,String>>() {
+ public void onComplete(Map<String,String> o) {
+ getAllComputeResourceNames_result result = new getAllComputeResourceNames_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -22486,7 +22383,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getStorageResource_result result = new getStorageResource_result();
+ getAllComputeResourceNames_result result = new getAllComputeResourceNames_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22527,26 +22424,27 @@ public class Airavata {
return false;
}
- public void start(I iface, getStorageResource_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription> resultHandler) throws TException {
- iface.getStorageResource(args.authzToken, args.storageResourceId,resultHandler);
+ public void start(I iface, getAllComputeResourceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
+ iface.getAllComputeResourceNames(args.authzToken,resultHandler);
}
}
- public static class getAllStorageResourceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllStorageResourceNames_args, Map<String,String>> {
- public getAllStorageResourceNames() {
- super("getAllStorageResourceNames");
+ public static class updateComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateComputeResource_args, Boolean> {
+ public updateComputeResource() {
+ super("updateComputeResource");
}
- public getAllStorageResourceNames_args getEmptyArgsInstance() {
- return new getAllStorageResourceNames_args();
+ public updateComputeResource_args getEmptyArgsInstance() {
+ return new updateComputeResource_args();
}
- public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Map<String,String>>() {
- public void onComplete(Map<String,String> o) {
- getAllStorageResourceNames_result result = new getAllStorageResourceNames_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ updateComputeResource_result result = new updateComputeResource_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22558,7 +22456,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllStorageResourceNames_result result = new getAllStorageResourceNames_result();
+ updateComputeResource_result result = new updateComputeResource_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22599,25 +22497,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getAllStorageResourceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
- iface.getAllStorageResourceNames(args.authzToken,resultHandler);
+ public void start(I iface, updateComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateComputeResource(args.authzToken, args.computeResourceId, args.computeResourceDescription,resultHandler);
}
}
- public static class updateStorageResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateStorageResource_args, Boolean> {
- public updateStorageResource() {
- super("updateStorageResource");
+ public static class deleteComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteComputeResource_args, Boolean> {
+ public deleteComputeResource() {
+ super("deleteComputeResource");
}
- public updateStorageResource_args getEmptyArgsInstance() {
- return new updateStorageResource_args();
+ public deleteComputeResource_args getEmptyArgsInstance() {
+ return new deleteComputeResource_args();
}
public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Boolean>() {
public void onComplete(Boolean o) {
- updateStorageResource_result result = new updateStorageResource_result();
+ deleteComputeResource_result result = new deleteComputeResource_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -22631,7 +22529,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateStorageResource_result result = new updateStorageResource_result();
+ deleteComputeResource_result result = new deleteComputeResource_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22672,27 +22570,26 @@ public class Airavata {
return false;
}
- public void start(I iface, updateStorageResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateStorageResource(args.authzToken, args.storageResourceId, args.storageResourceDescription,resultHandler);
+ public void start(I iface, deleteComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteComputeResource(args.authzToken, args.computeResourceId,resultHandler);
}
}
- public static class deleteStorageResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteStorageResource_args, Boolean> {
- public deleteStorageResource() {
- super("deleteStorageResource");
+ public static class registerStorageResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerStorageResource_args, String> {
+ public registerStorageResource() {
+ super("registerStorageResource");
}
- public deleteStorageResource_args getEmptyArgsInstance() {
- return new deleteStorageResource_args();
+ public registerStorageResource_args getEmptyArgsInstance() {
+ return new registerStorageResource_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- deleteStorageResource_result result = new deleteStorageResource_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ registerStorageResource_result result = new registerStorageResource_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22704,7 +22601,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteStorageResource_result result = new deleteStorageResource_result();
+ registerStorageResource_result result = new registerStorageResource_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22745,25 +22642,25 @@ public class Airavata {
return false;
}
- public void start(I iface, deleteStorageResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteStorageResource(args.authzToken, args.storageResourceId,resultHandler);
+ public void start(I iface, registerStorageResource_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerStorageResource(args.authzToken, args.storageResourceDescription,resultHandler);
}
}
- public static class addLocalSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addLocalSubmissionDetails_args, String> {
- public addLocalSubmissionDetails() {
- super("addLocalSubmissionDetails");
+ public static class getStorageResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getStorageResource_args, org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription> {
+ public getStorageResource() {
+ super("getStorageResource");
}
- public addLocalSubmissionDetails_args getEmptyArgsInstance() {
- return new addLocalSubmissionDetails_args();
+ public getStorageResource_args getEmptyArgsInstance() {
+ return new getStorageResource_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- addLocalSubmissionDetails_result result = new addLocalSubmissionDetails_result();
+ return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription>() {
+ public void onComplete(org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription o) {
+ getStorageResource_result result = new getStorageResource_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -22776,7 +22673,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addLocalSubmissionDetails_result result = new addLocalSubmissionDetails_result();
+ getStorageResource_result result = new getStorageResource_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22817,27 +22714,26 @@ public class Airavata {
return false;
}
- public void start(I iface, addLocalSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.addLocalSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.localSubmission,resultHandler);
+ public void start(I iface, getStorageResource_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.storageresource.StorageResourceDescription> resultHandler) throws TException {
+ iface.getStorageResource(args.authzToken, args.storageResourceId,resultHandler);
}
}
- public static class updateLocalSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateLocalSubmissionDetails_args, Boolean> {
- public updateLocalSubmissionDetails() {
- super("updateLocalSubmissionDetails");
+ public static class getAllStorageResourceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllStorageResourceNames_args, Map<String,String>> {
+ public getAllStorageResourceNames() {
+ super("getAllStorageResourceNames");
}
- public updateLocalSubmissionDetails_args getEmptyArgsInstance() {
- return new updateLocalSubmissionDetails_args();
+ public getAllStorageResourceNames_args getEmptyArgsInstance() {
+ return new getAllStorageResourceNames_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- updateLocalSubmissionDetails_result result = new updateLocalSubmissionDetails_result();
+ return new AsyncMethodCallback<Map<String,String>>() {
+ public void onComplete(Map<String,String> o) {
+ getAllStorageResourceNames_result result = new getAllStorageResourceNames_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22849,7 +22745,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateLocalSubmissionDetails_result result = new updateLocalSubmissionDetails_result();
+ getAllStorageResourceNames_result result = new getAllStorageResourceNames_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22890,26 +22786,27 @@ public class Airavata {
return false;
}
- public void start(I iface, updateLocalSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateLocalSubmissionDetails(args.authzToken, args.jobSubmissionInterfaceId, args.localSubmission,resultHandler);
+ public void start(I iface, getAllStorageResourceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
+ iface.getAllStorageResourceNames(args.authzToken,resultHandler);
}
}
- public static class getLocalJobSubmission<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getLocalJobSubmission_args, org.apache.airavata.model.appcatalog.computeresource.LOCALSubmission> {
- public getLocalJobSubmission() {
- super("getLocalJobSubmission");
+ public static class updateStorageResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateStorageResource_args, Boolean> {
+ public updateStorageResource() {
+ super("updateStorageResource");
}
- public getLocalJobSubmission_args getEmptyArgsInstance() {
- return new getLocalJobSubmission_args();
+ public updateStorageResource_args getEmptyArgsInstance() {
+ return new updateStorageResource_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALSubmission> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALSubmission>() {
- public void onComplete(org.apache.airavata.model.appcatalog.computeresource.LOCALSubmission o) {
- getLocalJobSubmission_result result = new getLocalJobSubmission_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ updateStorageResource_result result = new updateStorageResource_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22921,7 +22818,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getLocalJobSubmission_result result = new getLocalJobSubmission_result();
+ updateStorageResource_result result = new updateStorageResource_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -22962,26 +22859,27 @@ public class Airavata {
return false;
}
- public void start(I iface, getLocalJobSubmission_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALSubmission> resultHandler) throws TException {
- iface.getLocalJobSubmission(args.authzToken, args.jobSubmissionId,resultHandler);
+ public void start(I iface, updateStorageResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateStorageResource(args.authzToken, args.storageResourceId, args.storageResourceDescription,resultHandler);
}
}
- public static class addSSHJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSSHJobSubmissionDetails_args, String> {
- public addSSHJobSubmissionDetails() {
- super("addSSHJobSubmissionDetails");
+ public static class deleteStorageResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteStorageResource_args, Boolean> {
+ public deleteStorageResource() {
+ super("deleteStorageResource");
}
- public addSSHJobSubmissionDetails_args getEmptyArgsInstance() {
- return new addSSHJobSubmissionDetails_args();
+ public deleteStorageResource_args getEmptyArgsInstance() {
+ return new deleteStorageResource_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- addSSHJobSubmissionDetails_result result = new addSSHJobSubmissionDetails_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ deleteStorageResource_result result = new deleteStorageResource_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -22993,7 +22891,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addSSHJobSubmissionDetails_result result = new addSSHJobSubmissionDetails_result();
+ deleteStorageResource_result result = new deleteStorageResource_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -23034,25 +22932,25 @@ public class Airavata {
return false;
}
- public void start(I iface, addSSHJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.addSSHJobSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.sshJobSubmission,resultHandler);
+ public void start(I iface, deleteStorageResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteStorageResource(args.authzToken, args.storageResourceId,resultHandler);
}
}
- public static class addSSHForkJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSSHForkJobSubmissionDetails_args, String> {
- public addSSHForkJobSubmissionDetails() {
- super("addSSHForkJobSubmissionDetails");
+ public static class addLocalSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addLocalSubmissionDetails_args, String> {
+ public addLocalSubmissionDetails() {
+ super("addLocalSubmissionDetails");
}
- public addSSHForkJobSubmissionDetails_args getEmptyArgsInstance() {
- return new addSSHForkJobSubmissionDetails_args();
+ public addLocalSubmissionDetails_args getEmptyArgsInstance() {
+ return new addLocalSubmissionDetails_args();
}
public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<String>() {
public void onComplete(String o) {
- addSSHForkJobSubmissionDetails_result result = new addSSHForkJobSubmissionDetails_result();
+ addLocalSubmissionDetails_result result = new addLocalSubmissionDetails_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -23065,7 +22963,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addSSHForkJobSubmissionDetails_result result = new addSSHForkJobSubmissionDetails_result();
+ addLocalSubmissionDetails_result result = new addLocalSubmissionDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -23106,26 +23004,27 @@ public class Airavata {
return false;
}
- public void start(I iface, addSSHForkJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.addSSHForkJobSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.sshJobSubmission,resultHandler);
+ public void start(I iface, addLocalSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.addLocalSubmissionDetails(args.authzToken, args.computeResourceId, args.priorityOrder, args.localSubmission,resultHandler);
}
}
- public static class getSSHJobSubmission<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSSHJobSubmission_args, org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission> {
- public getSSHJobSubmission() {
- super("getSSHJobSubmission");
+ public static class updateLocalSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateLocalSubmissionDetails_args, Boolean> {
+ public updateLocalSubmissionDetails() {
+ super("updateLocalSubmissionDetails");
}
- public getSSHJobSubmission_args getEmptyArgsInstance() {
- return new getSSHJobSubmission_args();
+ public updateLocalSubmissionDetails_args getEmptyArgsInstance() {
+ return new updateLocalSubmissionDetails_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission>() {
- public void onComplete(org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission o) {
- getSSHJobSubmission_result result = new getSSHJobSubmission_result();
+ return new AsyncMethodCallback<Boolean>() {
+ public void onComplete(Boolean o) {
+ updateLocalSubmissionDetails_result result = new updateLocalSubmissionDetails_result();
result.success = o;
+ result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -23137,7 +23036,7 @@ public class Airavata {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getSSHJobSubmission_result result = new getSSHJobSubmission_result();
+ updateLocalSubmissionDetails_result result = new updateLocalSubmissionDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -23178,25 +23077,25 @@ public class Airavata {
return false;
}
- public void start(I iface, getSSHJobSubmission_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.SSHJobSubmission> resultHandler) throws TException {
- iface.getSSHJobSubmission(args.authzToken, args.jobSubmissionId,resultHandler);
+ public void start(I iface, updateLocalSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateLocalSubmissionDetails(args.authzToken, args.jobSubmissionInterfaceId, args.localSubmission,resultHandler);
}
}
- public static class addUNICOREJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUNICOREJobSubmissionDetails_args, String> {
- public addUNICOREJobSubmissionDetails() {
- super("addUNICOREJobSubmissionDetails");
+ public static class getLocalJobSubmission<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getLocalJobSubmission_args, org.apache.airavata.model.appcatalog.computeresource.LOCALSubmission> {
+ public getLocalJobSubmission() {
+ super("getLocalJobSubmission");
}
- public addUNICOREJobSubmissionDetails_args getEmptyArgsInstance() {
- return new addUNICOREJobSubmissionDetails_args();
+ public getLocalJobSubmission_args getEmptyArgsInstance() {
+ return new getLocalJobSubmission_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.LOCALSubmission> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<String>() {
- public void onComplete(String o) {
- addUNICOREJobSubmissionDetails_result result = new addUNICOREJobSubmissionDetails_result();
+ return new AsyncMethodCallback<org
<TRUNCATED>