http://git-wip-us.apache.org/repos/asf/airavata/blob/25cf3c97/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 8ea9fa4..6419290 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 @@ -372,6 +372,8 @@ import org.slf4j.LoggerFactory; public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getExperimentOutputs(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getIntermediateOutputs(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + public Map<String,org.apache.airavata.model.workspace.experiment.JobStatus> getJobStatuses(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; public List<org.apache.airavata.model.workspace.experiment.JobDetails> getJobDetails(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; @@ -1498,6 +1500,8 @@ import org.slf4j.LoggerFactory; public void getExperimentOutputs(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getIntermediateOutputs(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getJobStatuses(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getJobDetails(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -2618,6 +2622,41 @@ import org.slf4j.LoggerFactory; throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getExperimentOutputs failed: unknown result"); } + public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getIntermediateOutputs(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_getIntermediateOutputs(airavataExperimentId); + return recv_getIntermediateOutputs(); + } + + public void send_getIntermediateOutputs(String airavataExperimentId) throws org.apache.thrift.TException + { + getIntermediateOutputs_args args = new getIntermediateOutputs_args(); + args.setAiravataExperimentId(airavataExperimentId); + sendBase("getIntermediateOutputs", args); + } + + public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> recv_getIntermediateOutputs() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + getIntermediateOutputs_result result = new getIntermediateOutputs_result(); + receiveBase(result, "getIntermediateOutputs"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ire != null) { + throw result.ire; + } + if (result.enf != null) { + throw result.enf; + } + 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, "getIntermediateOutputs failed: unknown result"); + } + public Map<String,org.apache.airavata.model.workspace.experiment.JobStatus> getJobStatuses(String airavataExperimentId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException { send_getJobStatuses(airavataExperimentId); @@ -6266,6 +6305,38 @@ import org.slf4j.LoggerFactory; } } + public void getIntermediateOutputs(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getIntermediateOutputs_call method_call = new getIntermediateOutputs_call(airavataExperimentId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getIntermediateOutputs_call extends org.apache.thrift.async.TAsyncMethodCall { + private String airavataExperimentId; + public getIntermediateOutputs_call(String airavataExperimentId, 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.airavataExperimentId = airavataExperimentId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getIntermediateOutputs", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getIntermediateOutputs_args args = new getIntermediateOutputs_args(); + args.setAiravataExperimentId(airavataExperimentId); + args.write(prot); + prot.writeMessageEnd(); + } + + public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.ExperimentNotFoundException, 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_getIntermediateOutputs(); + } + } + public void getJobStatuses(String airavataExperimentId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getJobStatuses_call method_call = new getJobStatuses_call(airavataExperimentId, resultHandler, this, ___protocolFactory, ___transport); @@ -9040,6 +9111,7 @@ import org.slf4j.LoggerFactory; processMap.put("launchExperiment", new launchExperiment()); processMap.put("getExperimentStatus", new getExperimentStatus()); processMap.put("getExperimentOutputs", new getExperimentOutputs()); + processMap.put("getIntermediateOutputs", new getIntermediateOutputs()); processMap.put("getJobStatuses", new getJobStatuses()); processMap.put("getJobDetails", new getJobDetails()); processMap.put("getDataTransferDetails", new getDataTransferDetails()); @@ -9944,6 +10016,36 @@ import org.slf4j.LoggerFactory; } } + public static class getIntermediateOutputs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getIntermediateOutputs_args> { + public getIntermediateOutputs() { + super("getIntermediateOutputs"); + } + + public getIntermediateOutputs_args getEmptyArgsInstance() { + return new getIntermediateOutputs_args(); + } + + protected boolean isOneway() { + return false; + } + + public getIntermediateOutputs_result getResult(I iface, getIntermediateOutputs_args args) throws org.apache.thrift.TException { + getIntermediateOutputs_result result = new getIntermediateOutputs_result(); + try { + result.success = iface.getIntermediateOutputs(args.airavataExperimentId); + } catch (org.apache.airavata.model.error.InvalidRequestException ire) { + result.ire = ire; + } catch (org.apache.airavata.model.error.ExperimentNotFoundException enf) { + result.enf = enf; + } 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 getJobStatuses<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobStatuses_args> { public getJobStatuses() { super("getJobStatuses"); @@ -12323,6 +12425,7 @@ import org.slf4j.LoggerFactory; processMap.put("launchExperiment", new launchExperiment()); processMap.put("getExperimentStatus", new getExperimentStatus()); processMap.put("getExperimentOutputs", new getExperimentOutputs()); + processMap.put("getIntermediateOutputs", new getIntermediateOutputs()); processMap.put("getJobStatuses", new getJobStatuses()); processMap.put("getJobDetails", new getJobDetails()); processMap.put("getDataTransferDetails", new getDataTransferDetails()); @@ -14366,20 +14469,20 @@ import org.slf4j.LoggerFactory; } } - public static class getJobStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobStatuses_args, Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> { - public getJobStatuses() { - super("getJobStatuses"); + public static class getIntermediateOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getIntermediateOutputs_args, List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> { + public getIntermediateOutputs() { + super("getIntermediateOutputs"); } - public getJobStatuses_args getEmptyArgsInstance() { - return new getJobStatuses_args(); + public getIntermediateOutputs_args getEmptyArgsInstance() { + return new getIntermediateOutputs_args(); } - public AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> 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<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>>() { - public void onComplete(Map<String,org.apache.airavata.model.workspace.experiment.JobStatus> o) { - getJobStatuses_result result = new getJobStatuses_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>>() { + public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> o) { + getIntermediateOutputs_result result = new getIntermediateOutputs_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -14392,7 +14495,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getJobStatuses_result result = new getJobStatuses_result(); + getIntermediateOutputs_result result = new getIntermediateOutputs_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -14433,25 +14536,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getJobStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> resultHandler) throws TException { - iface.getJobStatuses(args.airavataExperimentId,resultHandler); + public void start(I iface, getIntermediateOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> resultHandler) throws TException { + iface.getIntermediateOutputs(args.airavataExperimentId,resultHandler); } } - public static class getJobDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobDetails_args, List<org.apache.airavata.model.workspace.experiment.JobDetails>> { - public getJobDetails() { - super("getJobDetails"); + public static class getJobStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobStatuses_args, Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> { + public getJobStatuses() { + super("getJobStatuses"); } - public getJobDetails_args getEmptyArgsInstance() { - return new getJobDetails_args(); + public getJobStatuses_args getEmptyArgsInstance() { + return new getJobStatuses_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>>() { - public void onComplete(List<org.apache.airavata.model.workspace.experiment.JobDetails> o) { - getJobDetails_result result = new getJobDetails_result(); + return new AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>>() { + public void onComplete(Map<String,org.apache.airavata.model.workspace.experiment.JobStatus> o) { + getJobStatuses_result result = new getJobStatuses_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -14464,7 +14567,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getJobDetails_result result = new getJobDetails_result(); + getJobStatuses_result result = new getJobStatuses_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -14505,25 +14608,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getJobDetails_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>> resultHandler) throws TException { - iface.getJobDetails(args.airavataExperimentId,resultHandler); + public void start(I iface, getJobStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> resultHandler) throws TException { + iface.getJobStatuses(args.airavataExperimentId,resultHandler); } } - public static class getDataTransferDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getDataTransferDetails_args, List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> { - public getDataTransferDetails() { - super("getDataTransferDetails"); + public static class getJobDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobDetails_args, List<org.apache.airavata.model.workspace.experiment.JobDetails>> { + public getJobDetails() { + super("getJobDetails"); } - public getDataTransferDetails_args getEmptyArgsInstance() { - return new getDataTransferDetails_args(); + public getJobDetails_args getEmptyArgsInstance() { + return new getJobDetails_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>>() { - public void onComplete(List<org.apache.airavata.model.workspace.experiment.DataTransferDetails> o) { - getDataTransferDetails_result result = new getDataTransferDetails_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.JobDetails> o) { + getJobDetails_result result = new getJobDetails_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -14536,7 +14639,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getDataTransferDetails_result result = new getDataTransferDetails_result(); + getJobDetails_result result = new getJobDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -14577,25 +14680,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getDataTransferDetails_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> resultHandler) throws TException { - iface.getDataTransferDetails(args.airavataExperimentId,resultHandler); + public void start(I iface, getJobDetails_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>> resultHandler) throws TException { + iface.getJobDetails(args.airavataExperimentId,resultHandler); } } - public static class cloneExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneExperiment_args, String> { - public cloneExperiment() { - super("cloneExperiment"); + public static class getDataTransferDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getDataTransferDetails_args, List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> { + public getDataTransferDetails() { + super("getDataTransferDetails"); } - public cloneExperiment_args getEmptyArgsInstance() { - return new cloneExperiment_args(); + public getDataTransferDetails_args getEmptyArgsInstance() { + return new getDataTransferDetails_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - cloneExperiment_result result = new cloneExperiment_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.DataTransferDetails> o) { + getDataTransferDetails_result result = new getDataTransferDetails_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -14608,78 +14711,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - cloneExperiment_result result = new cloneExperiment_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.ExperimentNotFoundException) { - result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e; - result.setEnfIsSet(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, cloneExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.cloneExperiment(args.existingExperimentID, args.newExperimentName,resultHandler); - } - } - - public static class terminateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, terminateExperiment_args, Void> { - public terminateExperiment() { - super("terminateExperiment"); - } - - public terminateExperiment_args getEmptyArgsInstance() { - return new terminateExperiment_args(); - } - - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - terminateExperiment_result result = new terminateExperiment_result(); - 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; - terminateExperiment_result result = new terminateExperiment_result(); + getDataTransferDetails_result result = new getDataTransferDetails_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -14720,25 +14752,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, terminateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.terminateExperiment(args.airavataExperimentId,resultHandler); + public void start(I iface, getDataTransferDetails_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> resultHandler) throws TException { + iface.getDataTransferDetails(args.airavataExperimentId,resultHandler); } } - public static class registerApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationModule_args, String> { - public registerApplicationModule() { - super("registerApplicationModule"); + public static class cloneExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneExperiment_args, String> { + public cloneExperiment() { + super("cloneExperiment"); } - public registerApplicationModule_args getEmptyArgsInstance() { - return new registerApplicationModule_args(); + public cloneExperiment_args getEmptyArgsInstance() { + return new cloneExperiment_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) { - registerApplicationModule_result result = new registerApplicationModule_result(); + cloneExperiment_result result = new cloneExperiment_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -14751,77 +14783,15 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - registerApplicationModule_result result = new registerApplicationModule_result(); + cloneExperiment_result result = new cloneExperiment_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, registerApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.registerApplicationModule(args.applicationModule,resultHandler); - } - } - - public static class getApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationModule_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> { - public getApplicationModule() { - super("getApplicationModule"); - } - - public getApplicationModule_args getEmptyArgsInstance() { - return new getApplicationModule_args(); - } - - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>() { - public void onComplete(org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule o) { - getApplicationModule_result result = new getApplicationModule_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; - getApplicationModule_result result = new getApplicationModule_result(); - if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { - result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; - result.setIreIsSet(true); + else if (e instanceof org.apache.airavata.model.error.ExperimentNotFoundException) { + result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e; + result.setEnfIsSet(true); msg = result; } else if (e instanceof org.apache.airavata.model.error.AiravataClientException) { @@ -14854,27 +14824,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> resultHandler) throws TException { - iface.getApplicationModule(args.appModuleId,resultHandler); + public void start(I iface, cloneExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.cloneExperiment(args.existingExperimentID, args.newExperimentName,resultHandler); } } - public static class updateApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationModule_args, Boolean> { - public updateApplicationModule() { - super("updateApplicationModule"); + public static class terminateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, terminateExperiment_args, Void> { + public terminateExperiment() { + super("terminateExperiment"); } - public updateApplicationModule_args getEmptyArgsInstance() { - return new updateApplicationModule_args(); + public terminateExperiment_args getEmptyArgsInstance() { + return new terminateExperiment_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateApplicationModule_result result = new updateApplicationModule_result(); - result.success = o; - result.setSuccessIsSet(true); + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + terminateExperiment_result result = new terminateExperiment_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -14886,77 +14854,15 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateApplicationModule_result result = new updateApplicationModule_result(); + terminateExperiment_result result = new terminateExperiment_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, updateApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateApplicationModule(args.appModuleId, args.applicationModule,resultHandler); - } - } - - public static class getAllAppModules<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllAppModules_args, List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> { - public getAllAppModules() { - super("getAllAppModules"); - } - - public getAllAppModules_args getEmptyArgsInstance() { - return new getAllAppModules_args(); - } - - public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>>() { - public void onComplete(List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> o) { - getAllAppModules_result result = new getAllAppModules_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; - getAllAppModules_result result = new getAllAppModules_result(); - if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { - result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; - result.setIreIsSet(true); + else if (e instanceof org.apache.airavata.model.error.ExperimentNotFoundException) { + result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e; + result.setEnfIsSet(true); msg = result; } else if (e instanceof org.apache.airavata.model.error.AiravataClientException) { @@ -14989,27 +14895,26 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getAllAppModules_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> resultHandler) throws TException { - iface.getAllAppModules(resultHandler); + public void start(I iface, terminateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.terminateExperiment(args.airavataExperimentId,resultHandler); } } - public static class deleteApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationModule_args, Boolean> { - public deleteApplicationModule() { - super("deleteApplicationModule"); + public static class registerApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationModule_args, String> { + public registerApplicationModule() { + super("registerApplicationModule"); } - public deleteApplicationModule_args getEmptyArgsInstance() { - return new deleteApplicationModule_args(); + public registerApplicationModule_args getEmptyArgsInstance() { + return new registerApplicationModule_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) { - deleteApplicationModule_result result = new deleteApplicationModule_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + registerApplicationModule_result result = new registerApplicationModule_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -15021,7 +14926,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteApplicationModule_result result = new deleteApplicationModule_result(); + registerApplicationModule_result result = new registerApplicationModule_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15057,25 +14962,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, deleteApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteApplicationModule(args.appModuleId,resultHandler); + public void start(I iface, registerApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.registerApplicationModule(args.applicationModule,resultHandler); } } - public static class registerApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationDeployment_args, String> { - public registerApplicationDeployment() { - super("registerApplicationDeployment"); + public static class getApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationModule_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> { + public getApplicationModule() { + super("getApplicationModule"); } - public registerApplicationDeployment_args getEmptyArgsInstance() { - return new registerApplicationDeployment_args(); + public getApplicationModule_args getEmptyArgsInstance() { + return new getApplicationModule_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - registerApplicationDeployment_result result = new registerApplicationDeployment_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>() { + public void onComplete(org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule o) { + getApplicationModule_result result = new getApplicationModule_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -15088,7 +14993,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - registerApplicationDeployment_result result = new registerApplicationDeployment_result(); + getApplicationModule_result result = new getApplicationModule_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15124,26 +15029,27 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, registerApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.registerApplicationDeployment(args.applicationDeployment,resultHandler); + public void start(I iface, getApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> resultHandler) throws TException { + iface.getApplicationModule(args.appModuleId,resultHandler); } } - public static class getApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationDeployment_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> { - public getApplicationDeployment() { - super("getApplicationDeployment"); + public static class updateApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationModule_args, Boolean> { + public updateApplicationModule() { + super("updateApplicationModule"); } - public getApplicationDeployment_args getEmptyArgsInstance() { - return new getApplicationDeployment_args(); + public updateApplicationModule_args getEmptyArgsInstance() { + return new updateApplicationModule_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> 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.appdeployment.ApplicationDeploymentDescription>() { - public void onComplete(org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription o) { - getApplicationDeployment_result result = new getApplicationDeployment_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + updateApplicationModule_result result = new updateApplicationModule_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -15155,7 +15061,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getApplicationDeployment_result result = new getApplicationDeployment_result(); + updateApplicationModule_result result = new updateApplicationModule_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15191,27 +15097,26 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> resultHandler) throws TException { - iface.getApplicationDeployment(args.appDeploymentId,resultHandler); + public void start(I iface, updateApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateApplicationModule(args.appModuleId, args.applicationModule,resultHandler); } } - public static class updateApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationDeployment_args, Boolean> { - public updateApplicationDeployment() { - super("updateApplicationDeployment"); + public static class getAllAppModules<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllAppModules_args, List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> { + public getAllAppModules() { + super("getAllAppModules"); } - public updateApplicationDeployment_args getEmptyArgsInstance() { - return new updateApplicationDeployment_args(); + public getAllAppModules_args getEmptyArgsInstance() { + return new getAllAppModules_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateApplicationDeployment_result result = new updateApplicationDeployment_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>>() { + public void onComplete(List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> o) { + getAllAppModules_result result = new getAllAppModules_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -15223,7 +15128,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateApplicationDeployment_result result = new updateApplicationDeployment_result(); + getAllAppModules_result result = new getAllAppModules_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15259,25 +15164,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, updateApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateApplicationDeployment(args.appDeploymentId, args.applicationDeployment,resultHandler); + public void start(I iface, getAllAppModules_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule>> resultHandler) throws TException { + iface.getAllAppModules(resultHandler); } } - public static class deleteApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationDeployment_args, Boolean> { - public deleteApplicationDeployment() { - super("deleteApplicationDeployment"); + public static class deleteApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationModule_args, Boolean> { + public deleteApplicationModule() { + super("deleteApplicationModule"); } - public deleteApplicationDeployment_args getEmptyArgsInstance() { - return new deleteApplicationDeployment_args(); + public deleteApplicationModule_args getEmptyArgsInstance() { + return new deleteApplicationModule_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) { - deleteApplicationDeployment_result result = new deleteApplicationDeployment_result(); + deleteApplicationModule_result result = new deleteApplicationModule_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -15291,7 +15196,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteApplicationDeployment_result result = new deleteApplicationDeployment_result(); + deleteApplicationModule_result result = new deleteApplicationModule_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15327,25 +15232,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, deleteApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteApplicationDeployment(args.appDeploymentId,resultHandler); + public void start(I iface, deleteApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteApplicationModule(args.appModuleId,resultHandler); } } - public static class getAllApplicationDeployments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationDeployments_args, List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> { - public getAllApplicationDeployments() { - super("getAllApplicationDeployments"); + public static class registerApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationDeployment_args, String> { + public registerApplicationDeployment() { + super("registerApplicationDeployment"); } - public getAllApplicationDeployments_args getEmptyArgsInstance() { - return new getAllApplicationDeployments_args(); + public registerApplicationDeployment_args getEmptyArgsInstance() { + return new registerApplicationDeployment_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> 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<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>>() { - public void onComplete(List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> o) { - getAllApplicationDeployments_result result = new getAllApplicationDeployments_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + registerApplicationDeployment_result result = new registerApplicationDeployment_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -15358,7 +15263,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllApplicationDeployments_result result = new getAllApplicationDeployments_result(); + registerApplicationDeployment_result result = new registerApplicationDeployment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15394,25 +15299,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getAllApplicationDeployments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> resultHandler) throws TException { - iface.getAllApplicationDeployments(resultHandler); + public void start(I iface, registerApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.registerApplicationDeployment(args.applicationDeployment,resultHandler); } } - public static class getAppModuleDeployedResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAppModuleDeployedResources_args, List<String>> { - public getAppModuleDeployedResources() { - super("getAppModuleDeployedResources"); + public static class getApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationDeployment_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> { + public getApplicationDeployment() { + super("getApplicationDeployment"); } - public getAppModuleDeployedResources_args getEmptyArgsInstance() { - return new getAppModuleDeployedResources_args(); + public getApplicationDeployment_args getEmptyArgsInstance() { + return new getApplicationDeployment_args(); } - public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> 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) { - getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>() { + public void onComplete(org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription o) { + getApplicationDeployment_result result = new getApplicationDeployment_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -15425,7 +15330,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_result(); + getApplicationDeployment_result result = new getApplicationDeployment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15461,93 +15366,27 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getAppModuleDeployedResources_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { - iface.getAppModuleDeployedResources(args.appModuleId,resultHandler); - } - } - - public static class registerApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationInterface_args, String> { - public registerApplicationInterface() { - super("registerApplicationInterface"); - } - - public registerApplicationInterface_args getEmptyArgsInstance() { - return new registerApplicationInterface_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) { - registerApplicationInterface_result result = new registerApplicationInterface_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; - registerApplicationInterface_result result = new registerApplicationInterface_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, registerApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.registerApplicationInterface(args.applicationInterface,resultHandler); + public void start(I iface, getApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> resultHandler) throws TException { + iface.getApplicationDeployment(args.appDeploymentId,resultHandler); } } - 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 updateApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationDeployment_args, Boolean> { + public updateApplicationDeployment() { + super("updateApplicationDeployment"); } - public getApplicationInterface_args getEmptyArgsInstance() { - return new getApplicationInterface_args(); + public updateApplicationDeployment_args getEmptyArgsInstance() { + return new updateApplicationDeployment_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> 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.appinterface.ApplicationInterfaceDescription>() { - public void onComplete(org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription o) { - getApplicationInterface_result result = new getApplicationInterface_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + updateApplicationDeployment_result result = new updateApplicationDeployment_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -15559,7 +15398,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getApplicationInterface_result result = new getApplicationInterface_result(); + updateApplicationDeployment_result result = new updateApplicationDeployment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15595,25 +15434,25 @@ import org.slf4j.LoggerFactory; 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.appInterfaceId,resultHandler); + public void start(I iface, updateApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateApplicationDeployment(args.appDeploymentId, args.applicationDeployment,resultHandler); } } - public static class updateApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationInterface_args, Boolean> { - public updateApplicationInterface() { - super("updateApplicationInterface"); + public static class deleteApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationDeployment_args, Boolean> { + public deleteApplicationDeployment() { + super("deleteApplicationDeployment"); } - public updateApplicationInterface_args getEmptyArgsInstance() { - return new updateApplicationInterface_args(); + public deleteApplicationDeployment_args getEmptyArgsInstance() { + return new deleteApplicationDeployment_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) { - updateApplicationInterface_result result = new updateApplicationInterface_result(); + deleteApplicationDeployment_result result = new deleteApplicationDeployment_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -15627,7 +15466,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateApplicationInterface_result result = new updateApplicationInterface_result(); + deleteApplicationDeployment_result result = new deleteApplicationDeployment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15663,27 +15502,26 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, updateApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateApplicationInterface(args.appInterfaceId, args.applicationInterface,resultHandler); + public void start(I iface, deleteApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteApplicationDeployment(args.appDeploymentId,resultHandler); } } - public static class deleteApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationInterface_args, Boolean> { - public deleteApplicationInterface() { - super("deleteApplicationInterface"); + public static class getAllApplicationDeployments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationDeployments_args, List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> { + public getAllApplicationDeployments() { + super("getAllApplicationDeployments"); } - public deleteApplicationInterface_args getEmptyArgsInstance() { - return new deleteApplicationInterface_args(); + public getAllApplicationDeployments_args getEmptyArgsInstance() { + return new getAllApplicationDeployments_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> 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(); + return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>>() { + public void onComplete(List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> o) { + getAllApplicationDeployments_result result = new getAllApplicationDeployments_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -15695,7 +15533,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteApplicationInterface_result result = new deleteApplicationInterface_result(); + getAllApplicationDeployments_result result = new getAllApplicationDeployments_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15731,25 +15569,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, deleteApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteApplicationInterface(args.appInterfaceId,resultHandler); + public void start(I iface, getAllApplicationDeployments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription>> resultHandler) throws TException { + iface.getAllApplicationDeployments(resultHandler); } } - public static class getAllApplicationInterfaceNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllApplicationInterfaceNames_args, Map<String,String>> { - public getAllApplicationInterfaceNames() { - super("getAllApplicationInterfaceNames"); + public static class getAppModuleDeployedResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAppModuleDeployedResources_args, List<String>> { + public getAppModuleDeployedResources() { + super("getAppModuleDeployedResources"); } - public getAllApplicationInterfaceNames_args getEmptyArgsInstance() { - return new getAllApplicationInterfaceNames_args(); + public getAppModuleDeployedResources_args getEmptyArgsInstance() { + return new getAppModuleDeployedResources_args(); } - public AsyncMethodCallback<Map<String,String>> 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<Map<String,String>>() { - public void onComplete(Map<String,String> o) { - getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result(); + return new AsyncMethodCallback<List<String>>() { + public void onComplete(List<String> o) { + getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -15762,7 +15600,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllApplicationInterfaceNames_result result = new getAllApplicationInterfaceNames_result(); + getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15798,25 +15636,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getAllApplicationInterfaceNames_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { - iface.getAllApplicationInterfaceNames(resultHandler); + public void start(I iface, getAppModuleDeployedResources_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { + iface.getAppModuleDeployedResources(args.appModuleId,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 static class registerApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationInterface_args, String> { + public registerApplicationInterface() { + super("registerApplicationInterface"); } - public getAllApplicationInterfaces_args getEmptyArgsInstance() { - return new getAllApplicationInterfaces_args(); + public registerApplicationInterface_args getEmptyArgsInstance() { + return new registerApplicationInterface_args(); } - public AsyncMethodCallback<List<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<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(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + registerApplicationInterface_result result = new registerApplicationInterface_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -15829,7 +15667,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllApplicationInterfaces_result result = new getAllApplicationInterfaces_result(); + registerApplicationInterface_result result = new registerApplicationInterface_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -15865,25 +15703,25 @@ import org.slf4j.LoggerFactory; 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(resultHandler); + public void start(I iface, registerApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.registerApplicationInterface(args.applicationInterface,resultHandler); } } - 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 getApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationInterface_args, org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> { + public getApplicationInterface() { + super("getApplicationInterface"); } - public getApplicationInputs_args getEmptyArgsInstance() { - return new getApplicationInputs_args(); + public getApplicationInterface_args getEmptyArgsInstance() { + return new getApplicationInterface_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>> 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<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<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; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -15896,7 +15734,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(); + 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); @@ -15932,26 +15770,27 @@ 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, getApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.appinterface.ApplicationInterfaceDescription> resultHandler) throws TException { + iface.getApplicationInterface(args.appInterfaceId,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 updateApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationInterface_args, Boolean> { + public updateApplicationInterface() { + super("updateApplicationInterface"); } - public getApplicationOutputs_args getEmptyArgsInstance() { - return new getApplicationOutputs_args(); + public updateApplicationInterface_args getEmptyArgsInstance() { + return new updateApplicationInterface_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.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.appcatalog.appinterface.OutputDataObjectType>>() { - public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> o) { - getApplicationOutputs_result result = new getApplicationOutputs_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + updateApplicationInterface_result result = new updateApplicationInterface_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -15963,7 +15802,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(); + 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); @@ -15999,26 +15838,27 @@ 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, updateApplicationInterface_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateApplicationInterface(args.appInterfaceId, args.applicationInterface,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 deleteApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationInterface_args, Boolean> { + public deleteApplicationInterface() { + super("deleteApplicationInterface"); } - public getAvailableAppInterfaceComputeResources_args getEmptyArgsInstance() { - return new getAvailableAppInterfaceComputeResources_args(); + public deleteApplicationInterface_args getEmptyArgsInstance() { + return new deleteApplicationInterface_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) { - getAvailableAppInterfaceComputeResources_result result = new getAvailableAppInterfaceComputeResources_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; @@ -16030,7 +15870,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 getAvailableAppInterfaceCompu
<TRUNCATED>
