http://git-wip-us.apache.org/repos/asf/airavata/blob/9c1f44d0/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 9e312dc..eb9a6f0 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 @@ -146,6 +146,16 @@ import org.slf4j.LoggerFactory; public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> searchExperimentsByStatus(String userName, org.apache.airavata.model.workspace.experiment.ExperimentState experimentState) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; /** + * Search Experiments by experiment status + * + * + * @param userName + * @param fromTime + * @param toTime + */ + public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> searchExperimentsByCreationTime(String userName, long fromTime, long toTime) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + + /** * Get all Experiments within a Project * * @@ -1285,6 +1295,8 @@ import org.slf4j.LoggerFactory; public void searchExperimentsByStatus(String userName, org.apache.airavata.model.workspace.experiment.ExperimentState experimentState, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void searchExperimentsByCreationTime(String userName, long fromTime, long toTime, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getAllExperimentsInProject(String projectId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getAllUserExperiments(String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -1796,6 +1808,40 @@ import org.slf4j.LoggerFactory; throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "searchExperimentsByStatus failed: unknown result"); } + public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> searchExperimentsByCreationTime(String userName, long fromTime, long toTime) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_searchExperimentsByCreationTime(userName, fromTime, toTime); + return recv_searchExperimentsByCreationTime(); + } + + public void send_searchExperimentsByCreationTime(String userName, long fromTime, long toTime) throws org.apache.thrift.TException + { + searchExperimentsByCreationTime_args args = new searchExperimentsByCreationTime_args(); + args.setUserName(userName); + args.setFromTime(fromTime); + args.setToTime(toTime); + sendBase("searchExperimentsByCreationTime", args); + } + + public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> recv_searchExperimentsByCreationTime() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); + receiveBase(result, "searchExperimentsByCreationTime"); + 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, "searchExperimentsByCreationTime failed: unknown result"); + } + public List<org.apache.airavata.model.workspace.experiment.Experiment> getAllExperimentsInProject(String projectId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.ProjectNotFoundException, org.apache.thrift.TException { send_getAllExperimentsInProject(projectId); @@ -4241,6 +4287,44 @@ import org.slf4j.LoggerFactory; } } + public void searchExperimentsByCreationTime(String userName, long fromTime, long toTime, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + searchExperimentsByCreationTime_call method_call = new searchExperimentsByCreationTime_call(userName, fromTime, toTime, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class searchExperimentsByCreationTime_call extends org.apache.thrift.async.TAsyncMethodCall { + private String userName; + private long fromTime; + private long toTime; + public searchExperimentsByCreationTime_call(String userName, long fromTime, long toTime, 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.userName = userName; + this.fromTime = fromTime; + this.toTime = toTime; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("searchExperimentsByCreationTime", org.apache.thrift.protocol.TMessageType.CALL, 0)); + searchExperimentsByCreationTime_args args = new searchExperimentsByCreationTime_args(); + args.setUserName(userName); + args.setFromTime(fromTime); + args.setToTime(toTime); + args.write(prot); + prot.writeMessageEnd(); + } + + public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> 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_searchExperimentsByCreationTime(); + } + } + public void getAllExperimentsInProject(String projectId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getAllExperimentsInProject_call method_call = new getAllExperimentsInProject_call(projectId, resultHandler, this, ___protocolFactory, ___transport); @@ -6412,6 +6496,7 @@ import org.slf4j.LoggerFactory; processMap.put("searchExperimentsByDesc", new searchExperimentsByDesc()); processMap.put("searchExperimentsByApplication", new searchExperimentsByApplication()); processMap.put("searchExperimentsByStatus", new searchExperimentsByStatus()); + processMap.put("searchExperimentsByCreationTime", new searchExperimentsByCreationTime()); processMap.put("getAllExperimentsInProject", new getAllExperimentsInProject()); processMap.put("getAllUserExperiments", new getAllUserExperiments()); processMap.put("createExperiment", new createExperiment()); @@ -6791,6 +6876,34 @@ import org.slf4j.LoggerFactory; } } + public static class searchExperimentsByCreationTime<I extends Iface> extends org.apache.thrift.ProcessFunction<I, searchExperimentsByCreationTime_args> { + public searchExperimentsByCreationTime() { + super("searchExperimentsByCreationTime"); + } + + public searchExperimentsByCreationTime_args getEmptyArgsInstance() { + return new searchExperimentsByCreationTime_args(); + } + + protected boolean isOneway() { + return false; + } + + public searchExperimentsByCreationTime_result getResult(I iface, searchExperimentsByCreationTime_args args) throws org.apache.thrift.TException { + searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); + try { + result.success = iface.searchExperimentsByCreationTime(args.userName, args.fromTime, args.toTime); + } 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 getAllExperimentsInProject<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllExperimentsInProject_args> { public getAllExperimentsInProject() { super("getAllExperimentsInProject"); @@ -8625,6 +8738,7 @@ import org.slf4j.LoggerFactory; processMap.put("searchExperimentsByDesc", new searchExperimentsByDesc()); processMap.put("searchExperimentsByApplication", new searchExperimentsByApplication()); processMap.put("searchExperimentsByStatus", new searchExperimentsByStatus()); + processMap.put("searchExperimentsByCreationTime", new searchExperimentsByCreationTime()); processMap.put("getAllExperimentsInProject", new getAllExperimentsInProject()); processMap.put("getAllUserExperiments", new getAllUserExperiments()); processMap.put("createExperiment", new createExperiment()); @@ -9438,20 +9552,20 @@ import org.slf4j.LoggerFactory; } } - public static class getAllExperimentsInProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllExperimentsInProject_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> { - public getAllExperimentsInProject() { - super("getAllExperimentsInProject"); + public static class searchExperimentsByCreationTime<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByCreationTime_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> { + public searchExperimentsByCreationTime() { + super("searchExperimentsByCreationTime"); } - public getAllExperimentsInProject_args getEmptyArgsInstance() { - return new getAllExperimentsInProject_args(); + public searchExperimentsByCreationTime_args getEmptyArgsInstance() { + return new searchExperimentsByCreationTime_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>>() { - public void onComplete(List<org.apache.airavata.model.workspace.experiment.Experiment> o) { - getAllExperimentsInProject_result result = new getAllExperimentsInProject_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> o) { + searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -9464,7 +9578,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllExperimentsInProject_result result = new getAllExperimentsInProject_result(); + searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -9480,11 +9594,6 @@ import org.slf4j.LoggerFactory; result.setAseIsSet(true); msg = result; } - else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { - result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; - result.setPnfeIsSet(true); - msg = result; - } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -9505,159 +9614,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getAllExperimentsInProject_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException { - iface.getAllExperimentsInProject(args.projectId,resultHandler); + public void start(I iface, searchExperimentsByCreationTime_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException { + iface.searchExperimentsByCreationTime(args.userName, args.fromTime, args.toTime,resultHandler); } } - public static class getAllUserExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserExperiments_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> { - public getAllUserExperiments() { - super("getAllUserExperiments"); + public static class getAllExperimentsInProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllExperimentsInProject_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> { + public getAllExperimentsInProject() { + super("getAllExperimentsInProject"); } - public getAllUserExperiments_args getEmptyArgsInstance() { - return new getAllUserExperiments_args(); + public getAllExperimentsInProject_args getEmptyArgsInstance() { + return new getAllExperimentsInProject_args(); } public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>>() { public void onComplete(List<org.apache.airavata.model.workspace.experiment.Experiment> o) { - getAllUserExperiments_result result = new getAllUserExperiments_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; - getAllUserExperiments_result result = new getAllUserExperiments_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, getAllUserExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException { - iface.getAllUserExperiments(args.userName,resultHandler); - } - } - - public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> { - public createExperiment() { - super("createExperiment"); - } - - public createExperiment_args getEmptyArgsInstance() { - return new createExperiment_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) { - createExperiment_result result = new createExperiment_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; - createExperiment_result result = new createExperiment_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, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.createExperiment(args.experiment,resultHandler); - } - } - - public static class getExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperiment_args, org.apache.airavata.model.workspace.experiment.Experiment> { - public getExperiment() { - super("getExperiment"); - } - - public getExperiment_args getEmptyArgsInstance() { - return new getExperiment_args(); - } - - public AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment>() { - public void onComplete(org.apache.airavata.model.workspace.experiment.Experiment o) { - getExperiment_result result = new getExperiment_result(); + getAllExperimentsInProject_result result = new getAllExperimentsInProject_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -9670,17 +9645,12 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getExperiment_result result = new getExperiment_result(); + getAllExperimentsInProject_result result = new getAllExperimentsInProject_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); @@ -9691,75 +9661,9 @@ import org.slf4j.LoggerFactory; 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, getExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment> resultHandler) throws TException { - iface.getExperiment(args.airavataExperimentId,resultHandler); - } - } - - public static class updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> { - public updateExperiment() { - super("updateExperiment"); - } - - public updateExperiment_args getEmptyArgsInstance() { - return new updateExperiment_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) { - updateExperiment_result result = new updateExperiment_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; - updateExperiment_result result = new updateExperiment_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); + else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { + result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; + result.setPnfeIsSet(true); msg = result; } else @@ -9782,25 +9686,26 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, updateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.updateExperiment(args.airavataExperimentId, args.experiment,resultHandler); + public void start(I iface, getAllExperimentsInProject_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException { + iface.getAllExperimentsInProject(args.projectId,resultHandler); } } - public static class updateExperimentConfiguration<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperimentConfiguration_args, Void> { - public updateExperimentConfiguration() { - super("updateExperimentConfiguration"); + public static class getAllUserExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserExperiments_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> { + public getAllUserExperiments() { + super("getAllUserExperiments"); } - public updateExperimentConfiguration_args getEmptyArgsInstance() { - return new updateExperimentConfiguration_args(); + public getAllUserExperiments_args getEmptyArgsInstance() { + return new getAllUserExperiments_args(); } - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - updateExperimentConfiguration_result result = new updateExperimentConfiguration_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.Experiment> o) { + getAllUserExperiments_result result = new getAllUserExperiments_result(); + result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -9812,57 +9717,23 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateExperimentConfiguration_result result = new updateExperimentConfiguration_result(); - { - 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()); + getAllUserExperiments_result result = new getAllUserExperiments_result(); + if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { + result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; + result.setIreIsSet(true); + msg = result; } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); + else if (e instanceof org.apache.airavata.model.error.AiravataClientException) { + result.ace = (org.apache.airavata.model.error.AiravataClientException) e; + result.setAceIsSet(true); + msg = result; } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, updateExperimentConfiguration_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.updateExperimentConfiguration(args.airavataExperimentId, args.userConfiguration,resultHandler); - } - } - - public static class updateResourceScheduleing<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateResourceScheduleing_args, Void> { - public updateResourceScheduleing() { - super("updateResourceScheduleing"); - } - - public updateResourceScheduleing_args getEmptyArgsInstance() { - return new updateResourceScheduleing_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) { - updateResourceScheduleing_result result = new updateResourceScheduleing_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); + else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) { + result.ase = (org.apache.airavata.model.error.AiravataSystemException) e; + result.setAseIsSet(true); + msg = result; } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - updateResourceScheduleing_result result = new updateResourceScheduleing_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()); @@ -9882,27 +9753,26 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, updateResourceScheduleing_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.updateResourceScheduleing(args.airavataExperimentId, args.resourceScheduling,resultHandler); + public void start(I iface, getAllUserExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException { + iface.getAllUserExperiments(args.userName,resultHandler); } } - public static class validateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, validateExperiment_args, Boolean> { - public validateExperiment() { - super("validateExperiment"); + public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> { + public createExperiment() { + super("createExperiment"); } - public validateExperiment_args getEmptyArgsInstance() { - return new validateExperiment_args(); + public createExperiment_args getEmptyArgsInstance() { + return new createExperiment_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) { - validateExperiment_result result = new validateExperiment_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + createExperiment_result result = new createExperiment_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -9914,17 +9784,12 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - validateExperiment_result result = new validateExperiment_result(); + createExperiment_result result = new createExperiment_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); @@ -9955,25 +9820,26 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, validateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.validateExperiment(args.airavataExperimentId,resultHandler); + public void start(I iface, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.createExperiment(args.experiment,resultHandler); } } - public static class launchExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, launchExperiment_args, Void> { - public launchExperiment() { - super("launchExperiment"); + public static class getExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperiment_args, org.apache.airavata.model.workspace.experiment.Experiment> { + public getExperiment() { + super("getExperiment"); } - public launchExperiment_args getEmptyArgsInstance() { - return new launchExperiment_args(); + public getExperiment_args getEmptyArgsInstance() { + return new getExperiment_args(); } - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - launchExperiment_result result = new launchExperiment_result(); + return new AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment>() { + public void onComplete(org.apache.airavata.model.workspace.experiment.Experiment o) { + getExperiment_result result = new getExperiment_result(); + result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -9985,7 +9851,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - launchExperiment_result result = new launchExperiment_result(); + getExperiment_result result = new getExperiment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -10006,11 +9872,6 @@ import org.slf4j.LoggerFactory; result.setAseIsSet(true); msg = result; } - else if (e instanceof org.apache.airavata.model.error.LaunchValidationException) { - result.lve = (org.apache.airavata.model.error.LaunchValidationException) e; - result.setLveIsSet(true); - msg = result; - } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -10031,26 +9892,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, launchExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.launchExperiment(args.airavataExperimentId, args.airavataCredStoreToken,resultHandler); + public void start(I iface, getExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment> resultHandler) throws TException { + iface.getExperiment(args.airavataExperimentId,resultHandler); } } - public static class getExperimentStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatus_args, org.apache.airavata.model.workspace.experiment.ExperimentStatus> { - public getExperimentStatus() { - super("getExperimentStatus"); + public static class updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> { + public updateExperiment() { + super("updateExperiment"); } - public getExperimentStatus_args getEmptyArgsInstance() { - return new getExperimentStatus_args(); + public updateExperiment_args getEmptyArgsInstance() { + return new updateExperiment_args(); } - public AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus> 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<org.apache.airavata.model.workspace.experiment.ExperimentStatus>() { - public void onComplete(org.apache.airavata.model.workspace.experiment.ExperimentStatus o) { - getExperimentStatus_result result = new getExperimentStatus_result(); - result.success = o; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateExperiment_result result = new updateExperiment_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -10062,7 +9922,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getExperimentStatus_result result = new getExperimentStatus_result(); + updateExperiment_result result = new updateExperiment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -10103,26 +9963,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getExperimentStatus_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus> resultHandler) throws TException { - iface.getExperimentStatus(args.airavataExperimentId,resultHandler); + public void start(I iface, updateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateExperiment(args.airavataExperimentId, args.experiment,resultHandler); } } - public static class getExperimentOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentOutputs_args, List<org.apache.airavata.model.workspace.experiment.DataObjectType>> { - public getExperimentOutputs() { - super("getExperimentOutputs"); + public static class updateExperimentConfiguration<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperimentConfiguration_args, Void> { + public updateExperimentConfiguration() { + super("updateExperimentConfiguration"); } - public getExperimentOutputs_args getEmptyArgsInstance() { - return new getExperimentOutputs_args(); + public updateExperimentConfiguration_args getEmptyArgsInstance() { + return new updateExperimentConfiguration_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>> 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<List<org.apache.airavata.model.workspace.experiment.DataObjectType>>() { - public void onComplete(List<org.apache.airavata.model.workspace.experiment.DataObjectType> o) { - getExperimentOutputs_result result = new getExperimentOutputs_result(); - result.success = o; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateExperimentConfiguration_result result = new updateExperimentConfiguration_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -10134,7 +9993,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getExperimentOutputs_result result = new getExperimentOutputs_result(); + updateExperimentConfiguration_result result = new updateExperimentConfiguration_result(); { 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()); @@ -10154,26 +10013,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getExperimentOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>> resultHandler) throws TException { - iface.getExperimentOutputs(args.airavataExperimentId,resultHandler); + public void start(I iface, updateExperimentConfiguration_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateExperimentConfiguration(args.airavataExperimentId, args.userConfiguration,resultHandler); } } - 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 updateResourceScheduleing<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateResourceScheduleing_args, Void> { + public updateResourceScheduleing() { + super("updateResourceScheduleing"); } - public getJobStatuses_args getEmptyArgsInstance() { - return new getJobStatuses_args(); + public updateResourceScheduleing_args getEmptyArgsInstance() { + return new updateResourceScheduleing_args(); } - public AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> 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<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; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateResourceScheduleing_result result = new updateResourceScheduleing_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -10185,7 +10043,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(); + updateResourceScheduleing_result result = new updateResourceScheduleing_result(); { 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()); @@ -10205,26 +10063,27 @@ 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, updateResourceScheduleing_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateResourceScheduleing(args.airavataExperimentId, args.resourceScheduling,resultHandler); } } - public static class cloneExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneExperiment_args, String> { - public cloneExperiment() { - super("cloneExperiment"); + public static class validateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, validateExperiment_args, Boolean> { + public validateExperiment() { + super("validateExperiment"); } - public cloneExperiment_args getEmptyArgsInstance() { - return new cloneExperiment_args(); + public validateExperiment_args getEmptyArgsInstance() { + return new validateExperiment_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - cloneExperiment_result result = new cloneExperiment_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + validateExperiment_result result = new validateExperiment_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -10236,7 +10095,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(); + validateExperiment_result result = new validateExperiment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -10277,25 +10136,25 @@ import org.slf4j.LoggerFactory; 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 void start(I iface, validateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.validateExperiment(args.airavataExperimentId,resultHandler); } } - public static class terminateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, terminateExperiment_args, Void> { - public terminateExperiment() { - super("terminateExperiment"); + public static class launchExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, launchExperiment_args, Void> { + public launchExperiment() { + super("launchExperiment"); } - public terminateExperiment_args getEmptyArgsInstance() { - return new terminateExperiment_args(); + public launchExperiment_args getEmptyArgsInstance() { + return new launchExperiment_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(); + launchExperiment_result result = new launchExperiment_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -10307,7 +10166,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - terminateExperiment_result result = new terminateExperiment_result(); + launchExperiment_result result = new launchExperiment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -10328,6 +10187,11 @@ import org.slf4j.LoggerFactory; result.setAseIsSet(true); msg = result; } + else if (e instanceof org.apache.airavata.model.error.LaunchValidationException) { + result.lve = (org.apache.airavata.model.error.LaunchValidationException) e; + result.setLveIsSet(true); + msg = result; + } else { msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; @@ -10348,25 +10212,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, launchExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.launchExperiment(args.airavataExperimentId, args.airavataCredStoreToken,resultHandler); } } - public static class registerApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationModule_args, String> { - public registerApplicationModule() { - super("registerApplicationModule"); + public static class getExperimentStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatus_args, org.apache.airavata.model.workspace.experiment.ExperimentStatus> { + public getExperimentStatus() { + super("getExperimentStatus"); } - public registerApplicationModule_args getEmptyArgsInstance() { - return new registerApplicationModule_args(); + public getExperimentStatus_args getEmptyArgsInstance() { + return new getExperimentStatus_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus> 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(); + return new AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus>() { + public void onComplete(org.apache.airavata.model.workspace.experiment.ExperimentStatus o) { + getExperimentStatus_result result = new getExperimentStatus_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -10379,12 +10243,17 @@ 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(); + getExperimentStatus_result result = new getExperimentStatus_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); @@ -10415,25 +10284,25 @@ import org.slf4j.LoggerFactory; 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 void start(I iface, getExperimentStatus_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatus> resultHandler) throws TException { + iface.getExperimentStatus(args.airavataExperimentId,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 static class getExperimentOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentOutputs_args, List<org.apache.airavata.model.workspace.experiment.DataObjectType>> { + public getExperimentOutputs() { + super("getExperimentOutputs"); } - public getApplicationModule_args getEmptyArgsInstance() { - return new getApplicationModule_args(); + public getExperimentOutputs_args getEmptyArgsInstance() { + return new getExperimentOutputs_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>> 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(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.DataObjectType> o) { + getExperimentOutputs_result result = new getExperimentOutputs_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -10446,23 +10315,58 @@ import org.slf4j.LoggerFactory; 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); - msg = result; + getExperimentOutputs_result result = new getExperimentOutputs_result(); + { + 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()); } - else if (e instanceof org.apache.airavata.model.error.AiravataClientException) { - result.ace = (org.apache.airavata.model.error.AiravataClientException) e; - result.setAceIsSet(true); - msg = result; + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); } - else if (e instanceof org.apache.airavata.model.error.AiravataSystemException) { - result.ase = (org.apache.airavata.model.error.AiravataSystemException) e; - result.setAseIsSet(true); - msg = result; + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, getExperimentOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataObjectType>> resultHandler) throws TException { + iface.getExperimentOutputs(args.airavataExperimentId,resultHandler); + } + } + + 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 getJobStatuses_args getEmptyArgsInstance() { + return new getJobStatuses_args(); + } + + 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<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); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); } - else + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + getJobStatuses_result result = new getJobStatuses_result(); { 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()); @@ -10482,27 +10386,26 @@ 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, 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 updateApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationModule_args, Boolean> { - public updateApplicationModule() { - super("updateApplicationModule"); + public static class cloneExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneExperiment_args, String> { + public cloneExperiment() { + super("cloneExperiment"); } - public updateApplicationModule_args getEmptyArgsInstance() { - return new updateApplicationModule_args(); + public cloneExperiment_args getEmptyArgsInstance() { + return new cloneExperiment_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) { - updateApplicationModule_result result = new updateApplicationModule_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + cloneExperiment_result result = new cloneExperiment_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -10514,12 +10417,17 @@ 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(); + 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); @@ -10550,27 +10458,25 @@ import org.slf4j.LoggerFactory; 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 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 deleteApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteApplicationModule_args, Boolean> { - public deleteApplicationModule() { - super("deleteApplicationModule"); + public static class terminateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, terminateExperiment_args, Void> { + public terminateExperiment() { + super("terminateExperiment"); } - public deleteApplicationModule_args getEmptyArgsInstance() { - return new deleteApplicationModule_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) { - deleteApplicationModule_result result = new deleteApplicationModule_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; @@ -10582,12 +10488,17 @@ 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(); + 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.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); @@ -10618,25 +10529,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, terminateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.terminateExperiment(args.airavataExperimentId,resultHandler); } } - public static class registerApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationDeployment_args, String> { - public registerApplicationDeployment() { - super("registerApplicationDeployment"); + public static class registerApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationModule_args, String> { + public registerApplicationModule() { + super("registerApplicationModule"); } - public registerApplicationDeployment_args getEmptyArgsInstance() { - return new registerApplicationDeployment_args(); + public registerApplicationModule_args getEmptyArgsInstance() { + return new registerApplicationModule_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) { - registerApplicationDeployment_result result = new registerApplicationDeployment_result(); + registerApplicationModule_result result = new registerApplicationModule_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -10649,7 +10560,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(); + 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); @@ -10685,25 +10596,25 @@ 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, registerApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.registerApplicationModule(args.applicationModule,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 getApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getApplicationModule_args, org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule> { + public getApplicationModule() { + super("getApplicationModule"); } - public getApplicationDeployment_args getEmptyArgsInstance() { - return new getApplicationDeployment_args(); + public getApplicationModule_args getEmptyArgsInstance() { + return new getApplicationModule_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription> 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<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<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); @@ -10716,7 +10627,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(); + 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); @@ -10752,25 +10663,25 @@ 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, 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 updateApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationDeployment_args, Boolean> { - public updateApplicationDeployment() { - super("updateApplicationDeployment"); + public static class updateApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateApplicationModule_args, Boolean> { + public updateApplicationModule() { + super("updateApplicationModule"); } - public updateApplicationDeployment_args getEmptyArgsInstance() { - return new updateApplicationDeployment_args(); + public updateApplicationModule_args getEmptyArgsInstance() { + return new updateApplicationModule_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) { - updateApplicationDeployment_result result = new updateApplicationDeployment_result(); + updateApplicationModule_result result = new updateApplicationModule_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -10784,7 +10695,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(); + 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); @@ -10820,25 +10731,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, updateApplicationModule_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateApplicationModule(args.appModuleId, args.applicationModule,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 { @@ -10852,7 +10763,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); @@ -10888,25 +10799,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 getAppModuleDeployedResources<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAppModuleDeployedResources_args, List<String>> { - public getAppModuleDeployedResources() { - super("getAppModuleDeployedResources"); + public static class registerApplicationDeployment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationDeployment_args, String> { + public registerApplicationDeployment() { + super("registerApplicationDeployment"); } - public getAppModuleDeployedResources_args getEmptyArgsInstance() { - return new getAppModuleDeployedResources_args(); + public registerApplicationDeployment_args getEmptyArgsInstance() { + return new registerApplicationDeployment_args(); } - public AsyncMethodCallback<List<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<List<String>>() { - public void onComplete(List<String> o) { - getAppModuleDeployedResources_result result = new getAppModuleDeployedResources_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); @@ -10919,7 +10830,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(); + 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); @@ -10955,25 +10866,25 @@ 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 void start(I iface, registerApplicationDeployment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.registerApplicationDeployment(args.applicationDeployment,resultHandler); } } - public static class registerApplicationInterface<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationInterface_args, String> { - public registerApplicationInterface() { - super("registerApplicationInterface"); + 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 registerApplicationInterface_args getEmptyArgsInstance() { - return new registerApplicationInterface_args(); + public getApplicationDeployment_args getEmptyArgsInstance() { + return new getApplicationDeployment_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription
<TRUNCATED>
