http://git-wip-us.apache.org/repos/asf/airavata/blob/2c6620f0/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 44b9230..4e471d5 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 @@ -1,21 +1,4 @@ /** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/** * Autogenerated by Thrift Compiler (0.9.1) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING @@ -49,7 +32,7 @@ import java.util.Arrays; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -@SuppressWarnings("all") public class Airavata { +public class Airavata { public interface Iface { @@ -484,6 +467,22 @@ import org.slf4j.LoggerFactory; public List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> searchExperiments(String gatewayId, String userName, Map<org.apache.airavata.model.workspace.experiment.ExperimentSearchFields,String> filters, int limit, int offset) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; /** + * Get Experiment Statisitics for the given gateway for a specific time period + * @param gatewayId + * Identifier of the requested gateway + * @param fromTime + * Starting date time + * @param toTime + * Ending data time + * + * + * @param gatewayId + * @param fromTime + * @param toTime + */ + public org.apache.airavata.model.workspace.experiment.ExperimentStatistics getExperimentStatistics(String gatewayId, 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 * * @param projectId @@ -559,7 +558,7 @@ import org.slf4j.LoggerFactory; * the ExperimentMetadata is a required field. * * @return - * The server-side generated airavata experiment globally unique identifier. + * The server-side generated.airavata.registry.core.experiment.globally unique identifier. * * @throws org.apache.airavata.model.error.InvalidRequestException * For any incorrect forming of the request itself. @@ -758,7 +757,7 @@ import org.slf4j.LoggerFactory; * should be shared public by default. * * @return - * The server-side generated airavata experiment globally unique identifier for the newly cloned experiment. + * The server-side generated.airavata.registry.core.experiment.globally unique identifier for the newly cloned experiment. * * @throws org.apache.airavata.model.error.InvalidRequestException * For any incorrect forming of the request itself. @@ -1879,6 +1878,8 @@ import org.slf4j.LoggerFactory; public void searchExperiments(String gatewayId, String userName, Map<org.apache.airavata.model.workspace.experiment.ExperimentSearchFields,String> filters, int limit, int offset, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getExperimentStatistics(String gatewayId, 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 getAllExperimentsInProjectWithPagination(String projectId, int limit, int offset, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -3146,6 +3147,40 @@ import org.slf4j.LoggerFactory; throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "searchExperiments failed: unknown result"); } + public org.apache.airavata.model.workspace.experiment.ExperimentStatistics getExperimentStatistics(String gatewayId, 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_getExperimentStatistics(gatewayId, fromTime, toTime); + return recv_getExperimentStatistics(); + } + + public void send_getExperimentStatistics(String gatewayId, long fromTime, long toTime) throws org.apache.thrift.TException + { + getExperimentStatistics_args args = new getExperimentStatistics_args(); + args.setGatewayId(gatewayId); + args.setFromTime(fromTime); + args.setToTime(toTime); + sendBase("getExperimentStatistics", args); + } + + public org.apache.airavata.model.workspace.experiment.ExperimentStatistics recv_getExperimentStatistics() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + getExperimentStatistics_result result = new getExperimentStatistics_result(); + receiveBase(result, "getExperimentStatistics"); + 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, "getExperimentStatistics 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); @@ -7456,6 +7491,44 @@ import org.slf4j.LoggerFactory; } } + public void getExperimentStatistics(String gatewayId, long fromTime, long toTime, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getExperimentStatistics_call method_call = new getExperimentStatistics_call(gatewayId, fromTime, toTime, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getExperimentStatistics_call extends org.apache.thrift.async.TAsyncMethodCall { + private String gatewayId; + private long fromTime; + private long toTime; + public getExperimentStatistics_call(String gatewayId, 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.gatewayId = gatewayId; + 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("getExperimentStatistics", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getExperimentStatistics_args args = new getExperimentStatistics_args(); + args.setGatewayId(gatewayId); + args.setFromTime(fromTime); + args.setToTime(toTime); + args.write(prot); + prot.writeMessageEnd(); + } + + public org.apache.airavata.model.workspace.experiment.ExperimentStatistics 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_getExperimentStatistics(); + } + } + 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); @@ -10743,6 +10816,7 @@ import org.slf4j.LoggerFactory; processMap.put("searchExperimentsByCreationTime", new searchExperimentsByCreationTime()); processMap.put("searchExperimentsByCreationTimeWithPagination", new searchExperimentsByCreationTimeWithPagination()); processMap.put("searchExperiments", new searchExperiments()); + processMap.put("getExperimentStatistics", new getExperimentStatistics()); processMap.put("getAllExperimentsInProject", new getAllExperimentsInProject()); processMap.put("getAllExperimentsInProjectWithPagination", new getAllExperimentsInProjectWithPagination()); processMap.put("getAllUserExperiments", new getAllUserExperiments()); @@ -11721,6 +11795,34 @@ import org.slf4j.LoggerFactory; } } + public static class getExperimentStatistics<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getExperimentStatistics_args> { + public getExperimentStatistics() { + super("getExperimentStatistics"); + } + + public getExperimentStatistics_args getEmptyArgsInstance() { + return new getExperimentStatistics_args(); + } + + protected boolean isOneway() { + return false; + } + + public getExperimentStatistics_result getResult(I iface, getExperimentStatistics_args args) throws org.apache.thrift.TException { + getExperimentStatistics_result result = new getExperimentStatistics_result(); + try { + result.success = iface.getExperimentStatistics(args.gatewayId, 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"); @@ -14499,6 +14601,7 @@ import org.slf4j.LoggerFactory; processMap.put("searchExperimentsByCreationTime", new searchExperimentsByCreationTime()); processMap.put("searchExperimentsByCreationTimeWithPagination", new searchExperimentsByCreationTimeWithPagination()); processMap.put("searchExperiments", new searchExperiments()); + processMap.put("getExperimentStatistics", new getExperimentStatistics()); processMap.put("getAllExperimentsInProject", new getAllExperimentsInProject()); processMap.put("getAllExperimentsInProjectWithPagination", new getAllExperimentsInProjectWithPagination()); processMap.put("getAllUserExperiments", new getAllUserExperiments()); @@ -16696,20 +16799,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 getExperimentStatistics<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatistics_args, org.apache.airavata.model.workspace.experiment.ExperimentStatistics> { + public getExperimentStatistics() { + super("getExperimentStatistics"); } - public getAllExperimentsInProject_args getEmptyArgsInstance() { - return new getAllExperimentsInProject_args(); + public getExperimentStatistics_args getEmptyArgsInstance() { + return new getExperimentStatistics_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatistics> 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<org.apache.airavata.model.workspace.experiment.ExperimentStatistics>() { + public void onComplete(org.apache.airavata.model.workspace.experiment.ExperimentStatistics o) { + getExperimentStatistics_result result = new getExperimentStatistics_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -16722,7 +16825,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(); + getExperimentStatistics_result result = new getExperimentStatistics_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -16738,11 +16841,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; @@ -16763,25 +16861,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, getExperimentStatistics_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.ExperimentStatistics> resultHandler) throws TException { + iface.getExperimentStatistics(args.gatewayId, args.fromTime, args.toTime,resultHandler); } } - public static class getAllExperimentsInProjectWithPagination<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllExperimentsInProjectWithPagination_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> { - public getAllExperimentsInProjectWithPagination() { - super("getAllExperimentsInProjectWithPagination"); + 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 getAllExperimentsInProjectWithPagination_args getEmptyArgsInstance() { - return new getAllExperimentsInProjectWithPagination_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) { - getAllExperimentsInProjectWithPagination_result result = new getAllExperimentsInProjectWithPagination_result(); + getAllExperimentsInProject_result result = new getAllExperimentsInProject_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -16794,7 +16892,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllExperimentsInProjectWithPagination_result result = new getAllExperimentsInProjectWithPagination_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); @@ -16835,298 +16933,26 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getAllExperimentsInProjectWithPagination_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException { - iface.getAllExperimentsInProjectWithPagination(args.projectId, args.limit, args.offset,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 getAllUserExperiments_args getEmptyArgsInstance() { - return new getAllUserExperiments_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.gatewayId, args.userName,resultHandler); - } - } - - public static class getAllUserExperimentsWithPagination<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserExperimentsWithPagination_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> { - public getAllUserExperimentsWithPagination() { - super("getAllUserExperimentsWithPagination"); - } - - public getAllUserExperimentsWithPagination_args getEmptyArgsInstance() { - return new getAllUserExperimentsWithPagination_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) { - getAllUserExperimentsWithPagination_result result = new getAllUserExperimentsWithPagination_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; - getAllUserExperimentsWithPagination_result result = new getAllUserExperimentsWithPagination_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, getAllUserExperimentsWithPagination_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException { - iface.getAllUserExperimentsWithPagination(args.gatewayId, args.userName, args.limit, args.offset,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.gatewayId, 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(); - 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; - 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); - 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, getExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.experiment.Experiment> resultHandler) throws TException { - iface.getExperiment(args.airavataExperimentId,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 updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> { - public updateExperiment() { - super("updateExperiment"); + public static class getAllExperimentsInProjectWithPagination<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllExperimentsInProjectWithPagination_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> { + public getAllExperimentsInProjectWithPagination() { + super("getAllExperimentsInProjectWithPagination"); } - public updateExperiment_args getEmptyArgsInstance() { - return new updateExperiment_args(); + public getAllExperimentsInProjectWithPagination_args getEmptyArgsInstance() { + return new getAllExperimentsInProjectWithPagination_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) { - updateExperiment_result result = new updateExperiment_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.Experiment> o) { + getAllExperimentsInProjectWithPagination_result result = new getAllExperimentsInProjectWithPagination_result(); + result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -17138,17 +16964,12 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateExperiment_result result = new updateExperiment_result(); + getAllExperimentsInProjectWithPagination_result result = new getAllExperimentsInProjectWithPagination_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); @@ -17159,6 +16980,11 @@ 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; @@ -17179,25 +17005,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, getAllExperimentsInProjectWithPagination_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException { + iface.getAllExperimentsInProjectWithPagination(args.projectId, args.limit, args.offset,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; @@ -17209,7 +17036,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(); + 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()); @@ -17229,25 +17072,26 @@ import org.slf4j.LoggerFactory; 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 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.gatewayId, args.userName,resultHandler); } } - public static class updateResourceScheduleing<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateResourceScheduleing_args, Void> { - public updateResourceScheduleing() { - super("updateResourceScheduleing"); + public static class getAllUserExperimentsWithPagination<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserExperimentsWithPagination_args, List<org.apache.airavata.model.workspace.experiment.Experiment>> { + public getAllUserExperimentsWithPagination() { + super("getAllUserExperimentsWithPagination"); } - public updateResourceScheduleing_args getEmptyArgsInstance() { - return new updateResourceScheduleing_args(); + public getAllUserExperimentsWithPagination_args getEmptyArgsInstance() { + return new getAllUserExperimentsWithPagination_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) { - updateResourceScheduleing_result result = new updateResourceScheduleing_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.Experiment> o) { + getAllUserExperimentsWithPagination_result result = new getAllUserExperimentsWithPagination_result(); + result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -17259,7 +17103,23 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateResourceScheduleing_result result = new updateResourceScheduleing_result(); + getAllUserExperimentsWithPagination_result result = new getAllUserExperimentsWithPagination_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()); @@ -17279,27 +17139,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, getAllUserExperimentsWithPagination_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.Experiment>> resultHandler) throws TException { + iface.getAllUserExperimentsWithPagination(args.gatewayId, args.userName, args.limit, args.offset,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; @@ -17311,17 +17170,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); @@ -17352,25 +17206,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.gatewayId, 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; @@ -17382,7 +17237,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); @@ -17403,11 +17258,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; @@ -17428,26 +17278,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; @@ -17459,7 +17308,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); @@ -17500,26 +17349,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.appcatalog.appinterface.OutputDataObjectType>> { - 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.appcatalog.appinterface.OutputDataObjectType>> 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.appcatalog.appinterface.OutputDataObjectType>>() { - public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> 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; @@ -17531,28 +17379,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(); - 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 + 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()); @@ -17572,26 +17399,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.appcatalog.appinterface.OutputDataObjectType>> 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 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 static class updateResourceScheduleing<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateResourceScheduleing_args, Void> { + public updateResourceScheduleing() { + super("updateResourceScheduleing"); } - public getIntermediateOutputs_args getEmptyArgsInstance() { - return new getIntermediateOutputs_args(); + public updateResourceScheduleing_args getEmptyArgsInstance() { + return new updateResourceScheduleing_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> 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.appcatalog.appinterface.OutputDataObjectType>>() { - public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> o) { - getIntermediateOutputs_result result = new getIntermediateOutputs_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; @@ -17603,28 +17429,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - 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); - 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 + 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()); @@ -17644,26 +17449,27 @@ import org.slf4j.LoggerFactory; return false; } - 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 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 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 validateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, validateExperiment_args, Boolean> { + public validateExperiment() { + super("validateExperiment"); } - public getJobStatuses_args getEmptyArgsInstance() { - return new getJobStatuses_args(); + public validateExperiment_args getEmptyArgsInstance() { + return new validateExperiment_args(); } - public AsyncMethodCallback<Map<String,org.apache.airavata.model.workspace.experiment.JobStatus>> 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,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<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; @@ -17675,7 +17481,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(); + 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); @@ -17716,26 +17522,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, validateExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.validateExperiment(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 launchExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, launchExperiment_args, Void> { + public launchExperiment() { + super("launchExperiment"); } - public getJobDetails_args getEmptyArgsInstance() { - return new getJobDetails_args(); + public launchExperiment_args getEmptyArgsInstance() { + return new launchExperiment_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.JobDetails>> 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.JobDetails>>() { - public void onComplete(List<org.apache.airavata.model.workspace.experiment.JobDetails> o) { - getJobDetails_result result = new getJobDetails_result(); - result.success = o; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + launchExperiment_result result = new launchExperiment_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -17747,7 +17552,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(); + 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); @@ -17768,6 +17573,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; @@ -17788,25 +17598,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, launchExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.launchExperiment(args.airavataExperimentId, args.airavataCredStoreToken,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 getExperimentStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatus_args, org.apache.airavata.model.workspace.experiment.ExperimentStatus> { + public getExperimentStatus() { + super("getExperimentStatus"); } - public getDataTransferDetails_args getEmptyArgsInstance() { - return new getDataTransferDetails_args(); + public getExperimentStatus_args getEmptyArgsInstance() { + return new getExperimentStatus_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.DataTransferDetails>> 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<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<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); @@ -17819,7 +17629,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(); + 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); @@ -17860,25 +17670,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, 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 cloneExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, cloneExperiment_args, String> { - public cloneExperiment() { - super("cloneExperiment"); + public static class getExperimentOutputs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentOutputs_args, List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> { + public getExperimentOutputs() { + super("getExperimentOutputs"); } - public cloneExperiment_args getEmptyArgsInstance() { - return new cloneExperiment_args(); + public getExperimentOutputs_args getEmptyArgsInstance() { + return new getExperimentOutputs_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - cloneExperiment_result result = new cloneExperiment_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>>() { + public void onComplete(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> o) { + getExperimentOutputs_result result = new getExperimentOutputs_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -17891,7 +17701,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(); + getExperimentOutputs_result result = new getExperimentOutputs_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -17932,25 +17742,26 @@ 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, getExperimentOutputs_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>> resultHandler) throws TException { + iface.getExperimentOutputs(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 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 terminateExperiment_args getEmptyArgsInstance() { - return new terminateExperiment_args(); + public getIntermediateOutputs_args getEmptyArgsInstance() { + return new getIntermediateOutputs_args(); } - public AsyncMethodCallback<Void> 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<Void>() { - public void onComplete(Void o) { - terminateExperiment_result result = new terminateExperiment_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); return; @@ -17962,7 +17773,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(); + 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); @@ -18003,25 +17814,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, args.tokenId,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 registerApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerApplicationModule_args, String> { - public registerApplicationModule() { - super("registerApplicationModule"); + 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 registerApplicationModule_args getEmptyArgsInstance() { - return new registerApplicationModule_args(); + public getJobStatuses_args getEmptyArgsInstance() { + return new getJobStatuses_args(); } - public AsyncMethodCallback<String> 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<String>() { - public void onComplete(String o) { - registerApplicationModule_result result = new registerApplicationModule_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); @@ -18034,12 +17845,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(); + 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); 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); @@ -18070,25 +17886,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.gatewayId, args.applicationModule,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 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 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 getApplicationModule_args getEmptyArgsInstance() { - return new getApplicationModule_args(); + public getJobDetails_args getEmptyArgsInstance() { + return new getJobDetails_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.JobDetails>> 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.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); @@ -18101,12 +17917,17 @@ 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(); + 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); 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); @@ -18137,27 +17958,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, 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 updateApplicationModule<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, up
<TRUNCATED>
