You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2014/07/07 20:32:16 UTC
[3/4] Adding missing API list interface functions
http://git-wip-us.apache.org/repos/asf/airavata/blob/0fde9bce/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 c400f27..3a37321 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
@@ -621,6 +621,26 @@ import org.slf4j.LoggerFactory;
public boolean deleteApplicationInterface(String appInterfaceId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
/**
+ * Fetch name and id of Application Interface documents.
+ *
+ *
+ * @return map<applicationId, applicationInterfaceNames>
+ * Returns a list of application interfaces with corresponsing id's
+ *
+ */
+ public Map<String,String> getAllApplicationInterfaceNames() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+
+ /**
+ * Fetch all Application Interface documents.
+ *
+ *
+ * @return map<applicationId, applicationInterfaceNames>
+ * Returns a list of application interfaces documents
+ *
+ */
+ public List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> getAllApplicationInterfaces() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException;
+
+ /**
* Fetch the list of Application Inputs.
*
* @param appInterfaceId
@@ -1265,6 +1285,10 @@ import org.slf4j.LoggerFactory;
public void deleteApplicationInterface(String appInterfaceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getAllApplicationInterfaceNames(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void getAllApplicationInterfaces(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void getApplicationInputs(String appInterfaceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getApplicationOutputs(String appInterfaceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -2529,6 +2553,68 @@ import org.slf4j.LoggerFactory;
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteApplicationInterface failed: unknown result");
}
+ public Map<String,String> getAllApplicationInterfaceNames() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getAllApplicationInterfaceNames();
+ return recv_getAllApplicationInterfaceNames();
+ }
+
+ public void send_getAllApplicationInterfaceNames() throws org.apache.thrift.TException
+ {
+ getAllApplicationInterfaceNames_args args = new getAllApplicationInterfaceNames_args();
+ sendBase("getAllApplicationInterfaceNames", args);
+ }
+
+ public Map<String,String> recv_getAllApplicationInterfaceNames() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result();
+ receiveBase(result, "getAllApplicationInterfaceNames");
+ 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, "getAllApplicationInterfaceNames failed: unknown result");
+ }
+
+ public List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> getAllApplicationInterfaces() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ send_getAllApplicationInterfaces();
+ return recv_getAllApplicationInterfaces();
+ }
+
+ public void send_getAllApplicationInterfaces() throws org.apache.thrift.TException
+ {
+ getAllApplicationInterfaces_args args = new getAllApplicationInterfaces_args();
+ sendBase("getAllApplicationInterfaces", args);
+ }
+
+ public List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> recv_getAllApplicationInterfaces() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
+ {
+ getAllApplicationInterfaces_result result = new getAllApplicationInterfaces_result();
+ receiveBase(result, "getAllApplicationInterfaces");
+ 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, "getAllApplicationInterfaces failed: unknown result");
+ }
+
public List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType> getApplicationInputs(String appInterfaceId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException
{
send_getApplicationInputs(appInterfaceId);
@@ -4850,6 +4936,64 @@ import org.slf4j.LoggerFactory;
}
}
+ public void getAllApplicationInterfaceNames(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getAllApplicationInterfaceNames_call method_call = new getAllApplicationInterfaceNames_call(resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getAllApplicationInterfaceNames_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public getAllApplicationInterfaceNames_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("getAllApplicationInterfaceNames", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getAllApplicationInterfaceNames_args args = new getAllApplicationInterfaceNames_args();
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public Map<String,String> getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.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_getAllApplicationInterfaceNames();
+ }
+ }
+
+ public void getAllApplicationInterfaces(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ getAllApplicationInterfaces_call method_call = new getAllApplicationInterfaces_call(resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class getAllApplicationInterfaces_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public getAllApplicationInterfaces_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("getAllApplicationInterfaces", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ getAllApplicationInterfaces_args args = new getAllApplicationInterfaces_args();
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.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_getAllApplicationInterfaces();
+ }
+ }
+
public void getApplicationInputs(String appInterfaceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
getApplicationInputs_call method_call = new getApplicationInputs_call(appInterfaceId, resultHandler, this, ___protocolFactory, ___transport);
@@ -6028,6 +6172,8 @@ import org.slf4j.LoggerFactory;
processMap.put("getApplicationInterface", new getApplicationInterface());
processMap.put("updateApplicationInterface", new updateApplicationInterface());
processMap.put("deleteApplicationInterface", new deleteApplicationInterface());
+ processMap.put("getAllApplicationInterfaceNames", new getAllApplicationInterfaceNames());
+ processMap.put("getAllApplicationInterfaces", new getAllApplicationInterfaces());
processMap.put("getApplicationInputs", new getApplicationInputs());
processMap.put("getApplicationOutputs", new getApplicationOutputs());
processMap.put("getAvailableAppInterfaceComputeResources", new getAvailableAppInterfaceComputeResources());
@@ -7097,6 +7243,62 @@ import org.slf4j.LoggerFactory;
}
}
+ public static class getAllApplicationInterfaceNames<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllApplicationInterfaceNames_args> {
+ public getAllApplicationInterfaceNames() {
+ super("getAllApplicationInterfaceNames");
+ }
+
+ public getAllApplicationInterfaceNames_args getEmptyArgsInstance() {
+ return new getAllApplicationInterfaceNames_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getAllApplicationInterfaceNames_result getResult(I iface, getAllApplicationInterfaceNames_args args) throws org.apache.thrift.TException {
+ getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result();
+ try {
+ result.success = iface.getAllApplicationInterfaceNames();
+ } 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;
+ }
+ return result;
+ }
+ }
+
+ public static class getAllApplicationInterfaces<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllApplicationInterfaces_args> {
+ public getAllApplicationInterfaces() {
+ super("getAllApplicationInterfaces");
+ }
+
+ public getAllApplicationInterfaces_args getEmptyArgsInstance() {
+ return new getAllApplicationInterfaces_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public getAllApplicationInterfaces_result getResult(I iface, getAllApplicationInterfaces_args args) throws org.apache.thrift.TException {
+ getAllApplicationInterfaces_result result = new getAllApplicationInterfaces_result();
+ try {
+ result.success = iface.getAllApplicationInterfaces();
+ } 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;
+ }
+ return result;
+ }
+ }
+
public static class getApplicationInputs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getApplicationInputs_args> {
public getApplicationInputs() {
super("getApplicationInputs");
@@ -8095,6 +8297,8 @@ import org.slf4j.LoggerFactory;
processMap.put("getApplicationInterface", new getApplicationInterface());
processMap.put("updateApplicationInterface", new updateApplicationInterface());
processMap.put("deleteApplicationInterface", new deleteApplicationInterface());
+ processMap.put("getAllApplicationInterfaceNames", new getAllApplicationInterfaceNames());
+ processMap.put("getAllApplicationInterfaces", new getAllApplicationInterfaces());
processMap.put("getApplicationInputs", new getApplicationInputs());
processMap.put("getApplicationOutputs", new getApplicationOutputs());
processMap.put("getAvailableAppInterfaceComputeResources", new getAvailableAppInterfaceComputeResources());
@@ -10602,20 +10806,20 @@ import org.slf4j.LoggerFactory;
}
}
- public static class getApplicationInputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInputs_args, List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> {
- public getApplicationInputs() {
- super("getApplicationInputs");
+ public static class getAllApplicationInterfaceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationInterfaceNames_args, Map<String,String>> {
+ public getAllApplicationInterfaceNames() {
+ super("getAllApplicationInterfaceNames");
}
- public getApplicationInputs_args getEmptyArgsInstance() {
- return new getApplicationInputs_args();
+ public getAllApplicationInterfaceNames_args getEmptyArgsInstance() {
+ return new getAllApplicationInterfaceNames_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> 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<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType> o) {
- getApplicationInputs_result result = new getApplicationInputs_result();
+ 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);
@@ -10628,7 +10832,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getApplicationInputs_result result = new getApplicationInputs_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);
@@ -10664,25 +10868,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getApplicationInputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> resultHandler) throws TException {
- iface.getApplicationInputs(args.appInterfaceId,resultHandler);
+ public void start(I iface, getAllApplicationInterfaceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
+ iface.getAllApplicationInterfaceNames(resultHandler);
}
}
- public static class getApplicationOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationOutputs_args, List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> {
- public getApplicationOutputs() {
- super("getApplicationOutputs");
+ 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 getApplicationOutputs_args getEmptyArgsInstance() {
- return new getApplicationOutputs_args();
+ public getAllApplicationInterfaces_args getEmptyArgsInstance() {
+ return new getAllApplicationInterfaces_args();
}
- public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> 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<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>>() {
- public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> o) {
- getApplicationOutputs_result result = new getApplicationOutputs_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);
@@ -10695,7 +10899,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getApplicationOutputs_result result = new getApplicationOutputs_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);
@@ -10731,25 +10935,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getApplicationOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> resultHandler) throws TException {
- iface.getApplicationOutputs(args.appInterfaceId,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(resultHandler);
}
}
- public static class getAvailableAppInterfaceComputeResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAvailableAppInterfaceComputeResources_args, List<String>> {
- public getAvailableAppInterfaceComputeResources() {
- super("getAvailableAppInterfaceComputeResources");
+ public static class getApplicationInputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInputs_args, List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> {
+ public getApplicationInputs() {
+ super("getApplicationInputs");
}
- public getAvailableAppInterfaceComputeResources_args getEmptyArgsInstance() {
- return new getAvailableAppInterfaceComputeResources_args();
+ public getApplicationInputs_args getEmptyArgsInstance() {
+ return new getApplicationInputs_args();
}
- public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<String>>() {
- public void onComplete(List<String> o) {
- getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceComputeResources_result();
+ return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType> o) {
+ getApplicationInputs_result result = new getApplicationInputs_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -10762,7 +10966,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceComputeResources_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);
@@ -10798,25 +11002,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getAvailableAppInterfaceComputeResources_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
- iface.getAvailableAppInterfaceComputeResources(args.appInterfaceId,resultHandler);
+ public void start(I iface, getApplicationInputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> resultHandler) throws TException {
+ iface.getApplicationInputs(args.appInterfaceId,resultHandler);
}
}
- public static class registerComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerComputeResource_args, String> {
- public registerComputeResource() {
- super("registerComputeResource");
+ public static class getApplicationOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationOutputs_args, List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> {
+ public getApplicationOutputs() {
+ super("getApplicationOutputs");
}
- public registerComputeResource_args getEmptyArgsInstance() {
- return new registerComputeResource_args();
+ public getApplicationOutputs_args getEmptyArgsInstance() {
+ return new getApplicationOutputs_args();
}
- public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> 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.OutputDataObjectType>>() {
+ public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> o) {
+ getApplicationOutputs_result result = new getApplicationOutputs_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -10829,7 +11033,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerComputeResource_result result = new registerComputeResource_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);
@@ -10865,25 +11069,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, registerComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
- iface.registerComputeResource(args.computeResourceDescription,resultHandler);
+ public void start(I iface, getApplicationOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> resultHandler) throws TException {
+ iface.getApplicationOutputs(args.appInterfaceId,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 getAvailableAppInterfaceComputeResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAvailableAppInterfaceComputeResources_args, List<String>> {
+ public getAvailableAppInterfaceComputeResources() {
+ super("getAvailableAppInterfaceComputeResources");
}
- public getComputeResource_args getEmptyArgsInstance() {
- return new getComputeResource_args();
+ public getAvailableAppInterfaceComputeResources_args getEmptyArgsInstance() {
+ return new getAvailableAppInterfaceComputeResources_args();
}
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.computeresource.ComputeResourceDescription> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<List<String>> 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<String>>() {
+ public void onComplete(List<String> o) {
+ getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceComputeResources_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -10896,7 +11100,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getComputeResource_result result = new getComputeResource_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);
@@ -10932,25 +11136,25 @@ import org.slf4j.LoggerFactory;
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.computeResourceId,resultHandler);
+ public void start(I iface, getAvailableAppInterfaceComputeResources_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException {
+ iface.getAvailableAppInterfaceComputeResources(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 registerComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerComputeResource_args, String> {
+ public registerComputeResource() {
+ super("registerComputeResource");
}
- public getAllComputeResourceNames_args getEmptyArgsInstance() {
- return new getAllComputeResourceNames_args();
+ public registerComputeResource_args getEmptyArgsInstance() {
+ return new registerComputeResource_args();
}
- public AsyncMethodCallback<Map<String,String>> 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<Map<String,String>>() {
- public void onComplete(Map<String,String> o) {
- getAllComputeResourceNames_result result = new getAllComputeResourceNames_result();
+ return new AsyncMethodCallback<String>() {
+ public void onComplete(String o) {
+ registerComputeResource_result result = new registerComputeResource_result();
result.success = o;
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
@@ -10963,7 +11167,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- getAllComputeResourceNames_result result = new getAllComputeResourceNames_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);
@@ -10999,95 +11203,26 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, getAllComputeResourceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
- iface.getAllComputeResourceNames(resultHandler);
- }
- }
-
- public static class updateComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateComputeResource_args, Boolean> {
- public updateComputeResource() {
- super("updateComputeResource");
- }
-
- public updateComputeResource_args getEmptyArgsInstance() {
- return new updateComputeResource_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) {
- 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;
- } 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;
- 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);
- 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
- {
- 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, updateComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateComputeResource(args.computeResourceId, args.computeResourceDescription,resultHandler);
+ public void start(I iface, registerComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException {
+ iface.registerComputeResource(args.computeResourceDescription,resultHandler);
}
}
- public static class deleteComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteComputeResource_args, Boolean> {
- public deleteComputeResource() {
- super("deleteComputeResource");
+ 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 deleteComputeResource_args getEmptyArgsInstance() {
- return new deleteComputeResource_args();
+ public getComputeResource_args getEmptyArgsInstance() {
+ return new getComputeResource_args();
}
- public AsyncMethodCallback<Boolean> 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<Boolean>() {
- public void onComplete(Boolean o) {
- deleteComputeResource_result result = new deleteComputeResource_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;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -11099,7 +11234,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteComputeResource_result result = new deleteComputeResource_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);
@@ -11135,27 +11270,26 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, deleteComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteComputeResource(args.computeResourceId,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.computeResourceId,resultHandler);
}
}
- public static class addLocalSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addLocalSubmissionDetails_args, Boolean> {
- public addLocalSubmissionDetails() {
- super("addLocalSubmissionDetails");
+ public static class getAllComputeResourceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllComputeResourceNames_args, Map<String,String>> {
+ public getAllComputeResourceNames() {
+ super("getAllComputeResourceNames");
}
- public addLocalSubmissionDetails_args getEmptyArgsInstance() {
- return new addLocalSubmissionDetails_args();
+ public getAllComputeResourceNames_args getEmptyArgsInstance() {
+ return new getAllComputeResourceNames_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) {
- addLocalSubmissionDetails_result result = new addLocalSubmissionDetails_result();
+ return new AsyncMethodCallback<Map<String,String>>() {
+ public void onComplete(Map<String,String> o) {
+ getAllComputeResourceNames_result result = new getAllComputeResourceNames_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -11167,7 +11301,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addLocalSubmissionDetails_result result = new addLocalSubmissionDetails_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);
@@ -11203,25 +11337,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addLocalSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.addLocalSubmissionDetails(args.computeResourceId, args.priorityOrder, args.localSubmission,resultHandler);
+ public void start(I iface, getAllComputeResourceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException {
+ iface.getAllComputeResourceNames(resultHandler);
}
}
- public static class updateLocalSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateLocalSubmissionDetails_args, Boolean> {
- public updateLocalSubmissionDetails() {
- super("updateLocalSubmissionDetails");
+ public static class updateComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateComputeResource_args, Boolean> {
+ public updateComputeResource() {
+ super("updateComputeResource");
}
- public updateLocalSubmissionDetails_args getEmptyArgsInstance() {
- return new updateLocalSubmissionDetails_args();
+ public updateComputeResource_args getEmptyArgsInstance() {
+ return new updateComputeResource_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) {
- updateLocalSubmissionDetails_result result = new updateLocalSubmissionDetails_result();
+ updateComputeResource_result result = new updateComputeResource_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11235,7 +11369,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateLocalSubmissionDetails_result result = new updateLocalSubmissionDetails_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);
@@ -11271,25 +11405,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, updateLocalSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateLocalSubmissionDetails(args.jobSubmissionInterfaceId, args.localSubmission,resultHandler);
+ public void start(I iface, updateComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateComputeResource(args.computeResourceId, args.computeResourceDescription,resultHandler);
}
}
- public static class addSSHJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSSHJobSubmissionDetails_args, Boolean> {
- public addSSHJobSubmissionDetails() {
- super("addSSHJobSubmissionDetails");
+ public static class deleteComputeResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteComputeResource_args, Boolean> {
+ public deleteComputeResource() {
+ super("deleteComputeResource");
}
- public addSSHJobSubmissionDetails_args getEmptyArgsInstance() {
- return new addSSHJobSubmissionDetails_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) {
- addSSHJobSubmissionDetails_result result = new addSSHJobSubmissionDetails_result();
+ deleteComputeResource_result result = new deleteComputeResource_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11303,7 +11437,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addSSHJobSubmissionDetails_result result = new addSSHJobSubmissionDetails_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);
@@ -11339,25 +11473,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addSSHJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.addSSHJobSubmissionDetails(args.computeResourceId, args.priorityOrder, args.sshJobSubmission,resultHandler);
+ public void start(I iface, deleteComputeResource_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deleteComputeResource(args.computeResourceId,resultHandler);
}
}
- public static class updateSSHJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateSSHJobSubmissionDetails_args, Boolean> {
- public updateSSHJobSubmissionDetails() {
- super("updateSSHJobSubmissionDetails");
+ public static class addLocalSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addLocalSubmissionDetails_args, Boolean> {
+ public addLocalSubmissionDetails() {
+ super("addLocalSubmissionDetails");
}
- public updateSSHJobSubmissionDetails_args getEmptyArgsInstance() {
- return new updateSSHJobSubmissionDetails_args();
+ public addLocalSubmissionDetails_args getEmptyArgsInstance() {
+ return new addLocalSubmissionDetails_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) {
- updateSSHJobSubmissionDetails_result result = new updateSSHJobSubmissionDetails_result();
+ addLocalSubmissionDetails_result result = new addLocalSubmissionDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11371,7 +11505,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateSSHJobSubmissionDetails_result result = new updateSSHJobSubmissionDetails_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);
@@ -11407,25 +11541,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, updateSSHJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateSSHJobSubmissionDetails(args.jobSubmissionInterfaceId, args.sshJobSubmission,resultHandler);
+ public void start(I iface, addLocalSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.addLocalSubmissionDetails(args.computeResourceId, args.priorityOrder, args.localSubmission,resultHandler);
}
}
- public static class addLocalDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addLocalDataMovementDetails_args, Boolean> {
- public addLocalDataMovementDetails() {
- super("addLocalDataMovementDetails");
+ public static class updateLocalSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateLocalSubmissionDetails_args, Boolean> {
+ public updateLocalSubmissionDetails() {
+ super("updateLocalSubmissionDetails");
}
- public addLocalDataMovementDetails_args getEmptyArgsInstance() {
- return new addLocalDataMovementDetails_args();
+ public updateLocalSubmissionDetails_args getEmptyArgsInstance() {
+ return new updateLocalSubmissionDetails_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) {
- addLocalDataMovementDetails_result result = new addLocalDataMovementDetails_result();
+ updateLocalSubmissionDetails_result result = new updateLocalSubmissionDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11439,7 +11573,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addLocalDataMovementDetails_result result = new addLocalDataMovementDetails_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);
@@ -11475,25 +11609,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addLocalDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.addLocalDataMovementDetails(args.computeResourceId, args.priorityOrder, args.localDataMovement,resultHandler);
+ public void start(I iface, updateLocalSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateLocalSubmissionDetails(args.jobSubmissionInterfaceId, args.localSubmission,resultHandler);
}
}
- public static class updateLocalDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateLocalDataMovementDetails_args, Boolean> {
- public updateLocalDataMovementDetails() {
- super("updateLocalDataMovementDetails");
+ public static class addSSHJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSSHJobSubmissionDetails_args, Boolean> {
+ public addSSHJobSubmissionDetails() {
+ super("addSSHJobSubmissionDetails");
}
- public updateLocalDataMovementDetails_args getEmptyArgsInstance() {
- return new updateLocalDataMovementDetails_args();
+ public addSSHJobSubmissionDetails_args getEmptyArgsInstance() {
+ return new addSSHJobSubmissionDetails_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) {
- updateLocalDataMovementDetails_result result = new updateLocalDataMovementDetails_result();
+ addSSHJobSubmissionDetails_result result = new addSSHJobSubmissionDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11507,7 +11641,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateLocalDataMovementDetails_result result = new updateLocalDataMovementDetails_result();
+ addSSHJobSubmissionDetails_result result = new addSSHJobSubmissionDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -11543,25 +11677,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, updateLocalDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateLocalDataMovementDetails(args.jobSubmissionInterfaceId, args.localDataMovement,resultHandler);
+ public void start(I iface, addSSHJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.addSSHJobSubmissionDetails(args.computeResourceId, args.priorityOrder, args.sshJobSubmission,resultHandler);
}
}
- public static class addSCPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSCPDataMovementDetails_args, Boolean> {
- public addSCPDataMovementDetails() {
- super("addSCPDataMovementDetails");
+ public static class updateSSHJobSubmissionDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateSSHJobSubmissionDetails_args, Boolean> {
+ public updateSSHJobSubmissionDetails() {
+ super("updateSSHJobSubmissionDetails");
}
- public addSCPDataMovementDetails_args getEmptyArgsInstance() {
- return new addSCPDataMovementDetails_args();
+ public updateSSHJobSubmissionDetails_args getEmptyArgsInstance() {
+ return new updateSSHJobSubmissionDetails_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) {
- addSCPDataMovementDetails_result result = new addSCPDataMovementDetails_result();
+ updateSSHJobSubmissionDetails_result result = new updateSSHJobSubmissionDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11575,7 +11709,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addSCPDataMovementDetails_result result = new addSCPDataMovementDetails_result();
+ updateSSHJobSubmissionDetails_result result = new updateSSHJobSubmissionDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -11611,25 +11745,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addSCPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.addSCPDataMovementDetails(args.computeResourceId, args.priorityOrder, args.scpDataMovement,resultHandler);
+ public void start(I iface, updateSSHJobSubmissionDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateSSHJobSubmissionDetails(args.jobSubmissionInterfaceId, args.sshJobSubmission,resultHandler);
}
}
- public static class updateSCPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateSCPDataMovementDetails_args, Boolean> {
- public updateSCPDataMovementDetails() {
- super("updateSCPDataMovementDetails");
+ public static class addLocalDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addLocalDataMovementDetails_args, Boolean> {
+ public addLocalDataMovementDetails() {
+ super("addLocalDataMovementDetails");
}
- public updateSCPDataMovementDetails_args getEmptyArgsInstance() {
- return new updateSCPDataMovementDetails_args();
+ public addLocalDataMovementDetails_args getEmptyArgsInstance() {
+ return new addLocalDataMovementDetails_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) {
- updateSCPDataMovementDetails_result result = new updateSCPDataMovementDetails_result();
+ addLocalDataMovementDetails_result result = new addLocalDataMovementDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11643,7 +11777,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateSCPDataMovementDetails_result result = new updateSCPDataMovementDetails_result();
+ addLocalDataMovementDetails_result result = new addLocalDataMovementDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -11679,25 +11813,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, updateSCPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateSCPDataMovementDetails(args.jobSubmissionInterfaceId, args.scpDataMovement,resultHandler);
+ public void start(I iface, addLocalDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.addLocalDataMovementDetails(args.computeResourceId, args.priorityOrder, args.localDataMovement,resultHandler);
}
}
- public static class addGridFTPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGridFTPDataMovementDetails_args, Boolean> {
- public addGridFTPDataMovementDetails() {
- super("addGridFTPDataMovementDetails");
+ public static class updateLocalDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateLocalDataMovementDetails_args, Boolean> {
+ public updateLocalDataMovementDetails() {
+ super("updateLocalDataMovementDetails");
}
- public addGridFTPDataMovementDetails_args getEmptyArgsInstance() {
- return new addGridFTPDataMovementDetails_args();
+ public updateLocalDataMovementDetails_args getEmptyArgsInstance() {
+ return new updateLocalDataMovementDetails_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) {
- addGridFTPDataMovementDetails_result result = new addGridFTPDataMovementDetails_result();
+ updateLocalDataMovementDetails_result result = new updateLocalDataMovementDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11711,7 +11845,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- addGridFTPDataMovementDetails_result result = new addGridFTPDataMovementDetails_result();
+ updateLocalDataMovementDetails_result result = new updateLocalDataMovementDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -11747,25 +11881,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, addGridFTPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.addGridFTPDataMovementDetails(args.computeResourceId, args.priorityOrder, args.gridFTPDataMovement,resultHandler);
+ public void start(I iface, updateLocalDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateLocalDataMovementDetails(args.jobSubmissionInterfaceId, args.localDataMovement,resultHandler);
}
}
- public static class updateGridFTPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGridFTPDataMovementDetails_args, Boolean> {
- public updateGridFTPDataMovementDetails() {
- super("updateGridFTPDataMovementDetails");
+ public static class addSCPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addSCPDataMovementDetails_args, Boolean> {
+ public addSCPDataMovementDetails() {
+ super("addSCPDataMovementDetails");
}
- public updateGridFTPDataMovementDetails_args getEmptyArgsInstance() {
- return new updateGridFTPDataMovementDetails_args();
+ public addSCPDataMovementDetails_args getEmptyArgsInstance() {
+ return new addSCPDataMovementDetails_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) {
- updateGridFTPDataMovementDetails_result result = new updateGridFTPDataMovementDetails_result();
+ addSCPDataMovementDetails_result result = new addSCPDataMovementDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11779,7 +11913,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- updateGridFTPDataMovementDetails_result result = new updateGridFTPDataMovementDetails_result();
+ addSCPDataMovementDetails_result result = new addSCPDataMovementDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -11815,25 +11949,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, updateGridFTPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.updateGridFTPDataMovementDetails(args.jobSubmissionInterfaceId, args.gridFTPDataMovement,resultHandler);
+ public void start(I iface, addSCPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.addSCPDataMovementDetails(args.computeResourceId, args.priorityOrder, args.scpDataMovement,resultHandler);
}
}
- public static class changeJobSubmissionPriority<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeJobSubmissionPriority_args, Boolean> {
- public changeJobSubmissionPriority() {
- super("changeJobSubmissionPriority");
+ public static class updateSCPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateSCPDataMovementDetails_args, Boolean> {
+ public updateSCPDataMovementDetails() {
+ super("updateSCPDataMovementDetails");
}
- public changeJobSubmissionPriority_args getEmptyArgsInstance() {
- return new changeJobSubmissionPriority_args();
+ public updateSCPDataMovementDetails_args getEmptyArgsInstance() {
+ return new updateSCPDataMovementDetails_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) {
- changeJobSubmissionPriority_result result = new changeJobSubmissionPriority_result();
+ updateSCPDataMovementDetails_result result = new updateSCPDataMovementDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11847,7 +11981,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- changeJobSubmissionPriority_result result = new changeJobSubmissionPriority_result();
+ updateSCPDataMovementDetails_result result = new updateSCPDataMovementDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -11883,25 +12017,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, changeJobSubmissionPriority_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.changeJobSubmissionPriority(args.jobSubmissionInterfaceId, args.newPriorityOrder,resultHandler);
+ public void start(I iface, updateSCPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateSCPDataMovementDetails(args.jobSubmissionInterfaceId, args.scpDataMovement,resultHandler);
}
}
- public static class changeDataMovementPriority<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeDataMovementPriority_args, Boolean> {
- public changeDataMovementPriority() {
- super("changeDataMovementPriority");
+ public static class addGridFTPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGridFTPDataMovementDetails_args, Boolean> {
+ public addGridFTPDataMovementDetails() {
+ super("addGridFTPDataMovementDetails");
}
- public changeDataMovementPriority_args getEmptyArgsInstance() {
- return new changeDataMovementPriority_args();
+ public addGridFTPDataMovementDetails_args getEmptyArgsInstance() {
+ return new addGridFTPDataMovementDetails_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) {
- changeDataMovementPriority_result result = new changeDataMovementPriority_result();
+ addGridFTPDataMovementDetails_result result = new addGridFTPDataMovementDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11915,7 +12049,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- changeDataMovementPriority_result result = new changeDataMovementPriority_result();
+ addGridFTPDataMovementDetails_result result = new addGridFTPDataMovementDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -11951,25 +12085,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, changeDataMovementPriority_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.changeDataMovementPriority(args.dataMovementInterfaceId, args.newPriorityOrder,resultHandler);
+ public void start(I iface, addGridFTPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.addGridFTPDataMovementDetails(args.computeResourceId, args.priorityOrder, args.gridFTPDataMovement,resultHandler);
}
}
- public static class changeJobSubmissionPriorities<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeJobSubmissionPriorities_args, Boolean> {
- public changeJobSubmissionPriorities() {
- super("changeJobSubmissionPriorities");
+ public static class updateGridFTPDataMovementDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGridFTPDataMovementDetails_args, Boolean> {
+ public updateGridFTPDataMovementDetails() {
+ super("updateGridFTPDataMovementDetails");
}
- public changeJobSubmissionPriorities_args getEmptyArgsInstance() {
- return new changeJobSubmissionPriorities_args();
+ public updateGridFTPDataMovementDetails_args getEmptyArgsInstance() {
+ return new updateGridFTPDataMovementDetails_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) {
- changeJobSubmissionPriorities_result result = new changeJobSubmissionPriorities_result();
+ updateGridFTPDataMovementDetails_result result = new updateGridFTPDataMovementDetails_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -11983,7 +12117,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- changeJobSubmissionPriorities_result result = new changeJobSubmissionPriorities_result();
+ updateGridFTPDataMovementDetails_result result = new updateGridFTPDataMovementDetails_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -12019,25 +12153,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, changeJobSubmissionPriorities_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.changeJobSubmissionPriorities(args.jobSubmissionPriorityMap,resultHandler);
+ public void start(I iface, updateGridFTPDataMovementDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.updateGridFTPDataMovementDetails(args.jobSubmissionInterfaceId, args.gridFTPDataMovement,resultHandler);
}
}
- public static class changeDataMovementPriorities<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeDataMovementPriorities_args, Boolean> {
- public changeDataMovementPriorities() {
- super("changeDataMovementPriorities");
+ public static class changeJobSubmissionPriority<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeJobSubmissionPriority_args, Boolean> {
+ public changeJobSubmissionPriority() {
+ super("changeJobSubmissionPriority");
}
- public changeDataMovementPriorities_args getEmptyArgsInstance() {
- return new changeDataMovementPriorities_args();
+ public changeJobSubmissionPriority_args getEmptyArgsInstance() {
+ return new changeJobSubmissionPriority_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) {
- changeDataMovementPriorities_result result = new changeDataMovementPriorities_result();
+ changeJobSubmissionPriority_result result = new changeJobSubmissionPriority_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -12051,7 +12185,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- changeDataMovementPriorities_result result = new changeDataMovementPriorities_result();
+ changeJobSubmissionPriority_result result = new changeJobSubmissionPriority_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -12087,25 +12221,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, changeDataMovementPriorities_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.changeDataMovementPriorities(args.dataMovementPriorityMap,resultHandler);
+ public void start(I iface, changeJobSubmissionPriority_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.changeJobSubmissionPriority(args.jobSubmissionInterfaceId, args.newPriorityOrder,resultHandler);
}
}
- public static class deleteJobSubmissionInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteJobSubmissionInterface_args, Boolean> {
- public deleteJobSubmissionInterface() {
- super("deleteJobSubmissionInterface");
+ public static class changeDataMovementPriority<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeDataMovementPriority_args, Boolean> {
+ public changeDataMovementPriority() {
+ super("changeDataMovementPriority");
}
- public deleteJobSubmissionInterface_args getEmptyArgsInstance() {
- return new deleteJobSubmissionInterface_args();
+ public changeDataMovementPriority_args getEmptyArgsInstance() {
+ return new changeDataMovementPriority_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) {
- deleteJobSubmissionInterface_result result = new deleteJobSubmissionInterface_result();
+ changeDataMovementPriority_result result = new changeDataMovementPriority_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -12119,7 +12253,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteJobSubmissionInterface_result result = new deleteJobSubmissionInterface_result();
+ changeDataMovementPriority_result result = new changeDataMovementPriority_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -12155,25 +12289,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, deleteJobSubmissionInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteJobSubmissionInterface(args.jobSubmissionInterfaceId,resultHandler);
+ public void start(I iface, changeDataMovementPriority_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.changeDataMovementPriority(args.dataMovementInterfaceId, args.newPriorityOrder,resultHandler);
}
}
- public static class deleteDataMovementInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteDataMovementInterface_args, Boolean> {
- public deleteDataMovementInterface() {
- super("deleteDataMovementInterface");
+ public static class changeJobSubmissionPriorities<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeJobSubmissionPriorities_args, Boolean> {
+ public changeJobSubmissionPriorities() {
+ super("changeJobSubmissionPriorities");
}
- public deleteDataMovementInterface_args getEmptyArgsInstance() {
- return new deleteDataMovementInterface_args();
+ public changeJobSubmissionPriorities_args getEmptyArgsInstance() {
+ return new changeJobSubmissionPriorities_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) {
- deleteDataMovementInterface_result result = new deleteDataMovementInterface_result();
+ changeJobSubmissionPriorities_result result = new changeJobSubmissionPriorities_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -12187,7 +12321,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deleteDataMovementInterface_result result = new deleteDataMovementInterface_result();
+ changeJobSubmissionPriorities_result result = new changeJobSubmissionPriorities_result();
if (e instanceof org.apache.airavata.model.error.InvalidRequestException) {
result.ire = (org.apache.airavata.model.error.InvalidRequestException) e;
result.setIreIsSet(true);
@@ -12223,25 +12357,25 @@ import org.slf4j.LoggerFactory;
return false;
}
- public void start(I iface, deleteDataMovementInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deleteDataMovementInterface(args.dataMovementInterfaceId,resultHandler);
+ public void start(I iface, changeJobSubmissionPriorities_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.changeJobSubmissionPriorities(args.jobSubmissionPriorityMap,resultHandler);
}
}
- public static class registerGatewayResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerGatewayResourceProfile_args, Boolean> {
- public registerGatewayResourceProfile() {
- super("registerGatewayResourceProfile");
+ public static class changeDataMovementPriorities<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, changeDataMovementPriorities_args, Boolean> {
+ public changeDataMovementPriorities() {
+ super("changeDataMovementPriorities");
}
- public registerGatewayResourceProfile_args getEmptyArgsInstance() {
- return new registerGatewayResourceProfile_args();
+ public changeDataMovementPriorities_args getEmptyArgsInstance() {
+ return new changeDataMovementPriorities_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) {
- registerGatewayResourceProfile_result result = new registerGatewayResourceProfile_result();
+ changeDataMovementPriorities_result result = new changeDataMovementPriorities_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -12255,74 +12389,7 @@ import org.slf4j.LoggerFactory;
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- registerGatewayResourceProfile_result result = new registerGatewayResourceProfile_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
- {
- 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, registerGatewayResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.registerGatewayResourceProfile(args.gatewayResourceProfile,resultHandler);
- }
- }
-
- public static class getGatewayResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getGatewayResourceProfile_args, org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile> {
- public getGatewayResourceProfile() {
- super("getGatewayResourceProfile");
- }
-
- public getGatewayResourceProfile_args getEmptyArgsInstance() {
- return new getGatewayResourceProfile_args();
- }
-
- public AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile>() {
- public void onComplete(org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile o) {
- getGatewayResourceProfile_result result = new getGatewayResourceProfil
<TRUNCATED>