http://git-wip-us.apache.org/repos/asf/airavata/blob/658e5e9e/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 e253126..8ea9fa4 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 @@ -58,6 +58,18 @@ import org.slf4j.LoggerFactory; */ public String getAPIVersion() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + public String addGateway(org.apache.airavata.model.workspace.Gateway gateway) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + + public void updateGateway(String gatewayId, org.apache.airavata.model.workspace.Gateway updatedGateway) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + + public org.apache.airavata.model.workspace.Gateway getGateway(String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + + public boolean deleteGateway(String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + + public List<org.apache.airavata.model.workspace.Gateway> getAllGateways() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + + public boolean isGatewayExist(String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; + /** * Create a Project * @@ -1430,6 +1442,18 @@ import org.slf4j.LoggerFactory; public void getAPIVersion(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void addGateway(org.apache.airavata.model.workspace.Gateway gateway, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void updateGateway(String gatewayId, org.apache.airavata.model.workspace.Gateway updatedGateway, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void deleteGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getAllGateways(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void isGatewayExist(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void createProject(org.apache.airavata.model.workspace.Project project, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void updateProject(String projectId, org.apache.airavata.model.workspace.Project updatedProject, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -1691,6 +1715,195 @@ import org.slf4j.LoggerFactory; throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAPIVersion failed: unknown result"); } + public String addGateway(org.apache.airavata.model.workspace.Gateway gateway) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_addGateway(gateway); + return recv_addGateway(); + } + + public void send_addGateway(org.apache.airavata.model.workspace.Gateway gateway) throws org.apache.thrift.TException + { + addGateway_args args = new addGateway_args(); + args.setGateway(gateway); + sendBase("addGateway", args); + } + + public String recv_addGateway() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + addGateway_result result = new addGateway_result(); + receiveBase(result, "addGateway"); + 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, "addGateway failed: unknown result"); + } + + public void updateGateway(String gatewayId, org.apache.airavata.model.workspace.Gateway updatedGateway) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_updateGateway(gatewayId, updatedGateway); + recv_updateGateway(); + } + + public void send_updateGateway(String gatewayId, org.apache.airavata.model.workspace.Gateway updatedGateway) throws org.apache.thrift.TException + { + updateGateway_args args = new updateGateway_args(); + args.setGatewayId(gatewayId); + args.setUpdatedGateway(updatedGateway); + sendBase("updateGateway", args); + } + + public void recv_updateGateway() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + updateGateway_result result = new updateGateway_result(); + receiveBase(result, "updateGateway"); + if (result.ire != null) { + throw result.ire; + } + if (result.ace != null) { + throw result.ace; + } + if (result.ase != null) { + throw result.ase; + } + return; + } + + public org.apache.airavata.model.workspace.Gateway getGateway(String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_getGateway(gatewayId); + return recv_getGateway(); + } + + public void send_getGateway(String gatewayId) throws org.apache.thrift.TException + { + getGateway_args args = new getGateway_args(); + args.setGatewayId(gatewayId); + sendBase("getGateway", args); + } + + public org.apache.airavata.model.workspace.Gateway recv_getGateway() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + getGateway_result result = new getGateway_result(); + receiveBase(result, "getGateway"); + 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, "getGateway failed: unknown result"); + } + + public boolean deleteGateway(String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_deleteGateway(gatewayId); + return recv_deleteGateway(); + } + + public void send_deleteGateway(String gatewayId) throws org.apache.thrift.TException + { + deleteGateway_args args = new deleteGateway_args(); + args.setGatewayId(gatewayId); + sendBase("deleteGateway", args); + } + + public boolean recv_deleteGateway() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + deleteGateway_result result = new deleteGateway_result(); + receiveBase(result, "deleteGateway"); + 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, "deleteGateway failed: unknown result"); + } + + public List<org.apache.airavata.model.workspace.Gateway> getAllGateways() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_getAllGateways(); + return recv_getAllGateways(); + } + + public void send_getAllGateways() throws org.apache.thrift.TException + { + getAllGateways_args args = new getAllGateways_args(); + sendBase("getAllGateways", args); + } + + public List<org.apache.airavata.model.workspace.Gateway> recv_getAllGateways() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + getAllGateways_result result = new getAllGateways_result(); + receiveBase(result, "getAllGateways"); + 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, "getAllGateways failed: unknown result"); + } + + public boolean isGatewayExist(String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + send_isGatewayExist(gatewayId); + return recv_isGatewayExist(); + } + + public void send_isGatewayExist(String gatewayId) throws org.apache.thrift.TException + { + isGatewayExist_args args = new isGatewayExist_args(); + args.setGatewayId(gatewayId); + sendBase("isGatewayExist", args); + } + + public boolean recv_isGatewayExist() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException + { + isGatewayExist_result result = new isGatewayExist_result(); + receiveBase(result, "isGatewayExist"); + 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, "isGatewayExist failed: unknown result"); + } + public String createProject(org.apache.airavata.model.workspace.Project project) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException { send_createProject(project); @@ -5118,6 +5331,198 @@ import org.slf4j.LoggerFactory; } } + public void addGateway(org.apache.airavata.model.workspace.Gateway gateway, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + addGateway_call method_call = new addGateway_call(gateway, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class addGateway_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.airavata.model.workspace.Gateway gateway; + public addGateway_call(org.apache.airavata.model.workspace.Gateway gateway, 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.gateway = gateway; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addGateway", org.apache.thrift.protocol.TMessageType.CALL, 0)); + addGateway_args args = new addGateway_args(); + args.setGateway(gateway); + args.write(prot); + prot.writeMessageEnd(); + } + + public String getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.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_addGateway(); + } + } + + public void updateGateway(String gatewayId, org.apache.airavata.model.workspace.Gateway updatedGateway, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + updateGateway_call method_call = new updateGateway_call(gatewayId, updatedGateway, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class updateGateway_call extends org.apache.thrift.async.TAsyncMethodCall { + private String gatewayId; + private org.apache.airavata.model.workspace.Gateway updatedGateway; + public updateGateway_call(String gatewayId, org.apache.airavata.model.workspace.Gateway updatedGateway, 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.updatedGateway = updatedGateway; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateGateway", org.apache.thrift.protocol.TMessageType.CALL, 0)); + updateGateway_args args = new updateGateway_args(); + args.setGatewayId(gatewayId); + args.setUpdatedGateway(updatedGateway); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_updateGateway(); + } + } + + public void getGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getGateway_call method_call = new getGateway_call(gatewayId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getGateway_call extends org.apache.thrift.async.TAsyncMethodCall { + private String gatewayId; + public getGateway_call(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.gatewayId = gatewayId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getGateway", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getGateway_args args = new getGateway_args(); + args.setGatewayId(gatewayId); + args.write(prot); + prot.writeMessageEnd(); + } + + public org.apache.airavata.model.workspace.Gateway 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_getGateway(); + } + } + + public void deleteGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + deleteGateway_call method_call = new deleteGateway_call(gatewayId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class deleteGateway_call extends org.apache.thrift.async.TAsyncMethodCall { + private String gatewayId; + public deleteGateway_call(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.gatewayId = gatewayId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteGateway", org.apache.thrift.protocol.TMessageType.CALL, 0)); + deleteGateway_args args = new deleteGateway_args(); + args.setGatewayId(gatewayId); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean 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_deleteGateway(); + } + } + + public void getAllGateways(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getAllGateways_call method_call = new getAllGateways_call(resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getAllGateways_call extends org.apache.thrift.async.TAsyncMethodCall { + public getAllGateways_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllGateways", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getAllGateways_args args = new getAllGateways_args(); + args.write(prot); + prot.writeMessageEnd(); + } + + public List<org.apache.airavata.model.workspace.Gateway> 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_getAllGateways(); + } + } + + public void isGatewayExist(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isGatewayExist_call method_call = new isGatewayExist_call(gatewayId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class isGatewayExist_call extends org.apache.thrift.async.TAsyncMethodCall { + private String gatewayId; + public isGatewayExist_call(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.gatewayId = gatewayId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isGatewayExist", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isGatewayExist_args args = new isGatewayExist_args(); + args.setGatewayId(gatewayId); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean 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_isGatewayExist(); + } + } + public void createProject(org.apache.airavata.model.workspace.Project project, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); createProject_call method_call = new createProject_call(project, resultHandler, this, ___protocolFactory, ___transport); @@ -8607,6 +9012,12 @@ import org.slf4j.LoggerFactory; private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { processMap.put("getAPIVersion", new getAPIVersion()); + processMap.put("addGateway", new addGateway()); + processMap.put("updateGateway", new updateGateway()); + processMap.put("getGateway", new getGateway()); + processMap.put("deleteGateway", new deleteGateway()); + processMap.put("getAllGateways", new getAllGateways()); + processMap.put("isGatewayExist", new isGatewayExist()); processMap.put("createProject", new createProject()); processMap.put("updateProject", new updateProject()); processMap.put("getProject", new getProject()); @@ -8742,6 +9153,176 @@ import org.slf4j.LoggerFactory; } } + public static class addGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addGateway_args> { + public addGateway() { + super("addGateway"); + } + + public addGateway_args getEmptyArgsInstance() { + return new addGateway_args(); + } + + protected boolean isOneway() { + return false; + } + + public addGateway_result getResult(I iface, addGateway_args args) throws org.apache.thrift.TException { + addGateway_result result = new addGateway_result(); + try { + result.success = iface.addGateway(args.gateway); + } 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 updateGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateGateway_args> { + public updateGateway() { + super("updateGateway"); + } + + public updateGateway_args getEmptyArgsInstance() { + return new updateGateway_args(); + } + + protected boolean isOneway() { + return false; + } + + public updateGateway_result getResult(I iface, updateGateway_args args) throws org.apache.thrift.TException { + updateGateway_result result = new updateGateway_result(); + try { + iface.updateGateway(args.gatewayId, args.updatedGateway); + } 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 getGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getGateway_args> { + public getGateway() { + super("getGateway"); + } + + public getGateway_args getEmptyArgsInstance() { + return new getGateway_args(); + } + + protected boolean isOneway() { + return false; + } + + public getGateway_result getResult(I iface, getGateway_args args) throws org.apache.thrift.TException { + getGateway_result result = new getGateway_result(); + try { + result.success = iface.getGateway(args.gatewayId); + } catch (org.apache.airavata.model.error.InvalidRequestException ire) { + result.ire = ire; + } catch (org.apache.airavata.model.error.AiravataClientException ace) { + result.ace = ace; + } catch (org.apache.airavata.model.error.AiravataSystemException ase) { + result.ase = ase; + } + return result; + } + } + + public static class deleteGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteGateway_args> { + public deleteGateway() { + super("deleteGateway"); + } + + public deleteGateway_args getEmptyArgsInstance() { + return new deleteGateway_args(); + } + + protected boolean isOneway() { + return false; + } + + public deleteGateway_result getResult(I iface, deleteGateway_args args) throws org.apache.thrift.TException { + deleteGateway_result result = new deleteGateway_result(); + try { + result.success = iface.deleteGateway(args.gatewayId); + result.setSuccessIsSet(true); + } 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 getAllGateways<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllGateways_args> { + public getAllGateways() { + super("getAllGateways"); + } + + public getAllGateways_args getEmptyArgsInstance() { + return new getAllGateways_args(); + } + + protected boolean isOneway() { + return false; + } + + public getAllGateways_result getResult(I iface, getAllGateways_args args) throws org.apache.thrift.TException { + getAllGateways_result result = new getAllGateways_result(); + try { + result.success = iface.getAllGateways(); + } 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 isGatewayExist<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isGatewayExist_args> { + public isGatewayExist() { + super("isGatewayExist"); + } + + public isGatewayExist_args getEmptyArgsInstance() { + return new isGatewayExist_args(); + } + + protected boolean isOneway() { + return false; + } + + public isGatewayExist_result getResult(I iface, isGatewayExist_args args) throws org.apache.thrift.TException { + isGatewayExist_result result = new isGatewayExist_result(); + try { + result.success = iface.isGatewayExist(args.gatewayId); + result.setSuccessIsSet(true); + } 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 createProject<I extends Iface> extends org.apache.thrift.ProcessFunction<I, createProject_args> { public createProject() { super("createProject"); @@ -11714,6 +12295,12 @@ import org.slf4j.LoggerFactory; private static <I extends AsyncIface> Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { processMap.put("getAPIVersion", new getAPIVersion()); + processMap.put("addGateway", new addGateway()); + processMap.put("updateGateway", new updateGateway()); + processMap.put("getGateway", new getGateway()); + processMap.put("deleteGateway", new deleteGateway()); + processMap.put("getAllGateways", new getAllGateways()); + processMap.put("isGatewayExist", new isGatewayExist()); processMap.put("createProject", new createProject()); processMap.put("updateProject", new updateProject()); processMap.put("getProject", new getProject()); @@ -11888,20 +12475,20 @@ import org.slf4j.LoggerFactory; } } - public static class createProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createProject_args, String> { - public createProject() { - super("createProject"); + public static class addGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addGateway_args, String> { + public addGateway() { + super("addGateway"); } - public createProject_args getEmptyArgsInstance() { - return new createProject_args(); + public addGateway_args getEmptyArgsInstance() { + return new addGateway_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) { - createProject_result result = new createProject_result(); + addGateway_result result = new addGateway_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -11914,7 +12501,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - createProject_result result = new createProject_result(); + addGateway_result result = new addGateway_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -11950,25 +12537,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, createProject_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.createProject(args.project,resultHandler); + public void start(I iface, addGateway_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.addGateway(args.gateway,resultHandler); } } - public static class updateProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateProject_args, Void> { - public updateProject() { - super("updateProject"); + public static class updateGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGateway_args, Void> { + public updateGateway() { + super("updateGateway"); } - public updateProject_args getEmptyArgsInstance() { - return new updateProject_args(); + public updateGateway_args getEmptyArgsInstance() { + return new updateGateway_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) { - updateProject_result result = new updateProject_result(); + updateGateway_result result = new updateGateway_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -11980,7 +12567,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateProject_result result = new updateProject_result(); + updateGateway_result result = new updateGateway_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -11996,11 +12583,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; @@ -12021,25 +12603,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, updateProject_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.updateProject(args.projectId, args.updatedProject,resultHandler); + public void start(I iface, updateGateway_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateGateway(args.gatewayId, args.updatedGateway,resultHandler); } } - public static class getProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getProject_args, org.apache.airavata.model.workspace.Project> { - public getProject() { - super("getProject"); + public static class getGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getGateway_args, org.apache.airavata.model.workspace.Gateway> { + public getGateway() { + super("getGateway"); } - public getProject_args getEmptyArgsInstance() { - return new getProject_args(); + public getGateway_args getEmptyArgsInstance() { + return new getGateway_args(); } - public AsyncMethodCallback<org.apache.airavata.model.workspace.Project> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.workspace.Gateway> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.workspace.Project>() { - public void onComplete(org.apache.airavata.model.workspace.Project o) { - getProject_result result = new getProject_result(); + return new AsyncMethodCallback<org.apache.airavata.model.workspace.Gateway>() { + public void onComplete(org.apache.airavata.model.workspace.Gateway o) { + getGateway_result result = new getGateway_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12052,7 +12634,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getProject_result result = new getProject_result(); + getGateway_result result = new getGateway_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12068,9 +12650,72 @@ 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); + 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, getGateway_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Gateway> resultHandler) throws TException { + iface.getGateway(args.gatewayId,resultHandler); + } + } + + public static class deleteGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteGateway_args, Boolean> { + public deleteGateway() { + super("deleteGateway"); + } + + public deleteGateway_args getEmptyArgsInstance() { + return new deleteGateway_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) { + deleteGateway_result result = new deleteGateway_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + deleteGateway_result result = new deleteGateway_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 @@ -12093,25 +12738,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getProject_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Project> resultHandler) throws TException { - iface.getProject(args.projectId,resultHandler); + public void start(I iface, deleteGateway_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteGateway(args.gatewayId,resultHandler); } } - public static class getAllUserProjects<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserProjects_args, List<org.apache.airavata.model.workspace.Project>> { - public getAllUserProjects() { - super("getAllUserProjects"); + public static class getAllGateways<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGateways_args, List<org.apache.airavata.model.workspace.Gateway>> { + public getAllGateways() { + super("getAllGateways"); } - public getAllUserProjects_args getEmptyArgsInstance() { - return new getAllUserProjects_args(); + public getAllGateways_args getEmptyArgsInstance() { + return new getAllGateways_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Gateway>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { - public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { - getAllUserProjects_result result = new getAllUserProjects_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Gateway>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Gateway> o) { + getAllGateways_result result = new getAllGateways_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12124,7 +12769,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllUserProjects_result result = new getAllUserProjects_result(); + getAllGateways_result result = new getAllGateways_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12160,26 +12805,27 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, getAllUserProjects_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { - iface.getAllUserProjects(args.userName,resultHandler); + public void start(I iface, getAllGateways_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Gateway>> resultHandler) throws TException { + iface.getAllGateways(resultHandler); } } - public static class searchProjectsByProjectName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectName_args, List<org.apache.airavata.model.workspace.Project>> { - public searchProjectsByProjectName() { - super("searchProjectsByProjectName"); + public static class isGatewayExist<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isGatewayExist_args, Boolean> { + public isGatewayExist() { + super("isGatewayExist"); } - public searchProjectsByProjectName_args getEmptyArgsInstance() { - return new searchProjectsByProjectName_args(); + public isGatewayExist_args getEmptyArgsInstance() { + return new isGatewayExist_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { - public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { - searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + isGatewayExist_result result = new isGatewayExist_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -12191,7 +12837,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); + isGatewayExist_result result = new isGatewayExist_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12227,25 +12873,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, searchProjectsByProjectName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { - iface.searchProjectsByProjectName(args.userName, args.projectName,resultHandler); + public void start(I iface, isGatewayExist_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.isGatewayExist(args.gatewayId,resultHandler); } } - public static class searchProjectsByProjectDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectDesc_args, List<org.apache.airavata.model.workspace.Project>> { - public searchProjectsByProjectDesc() { - super("searchProjectsByProjectDesc"); + public static class createProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createProject_args, String> { + public createProject() { + super("createProject"); } - public searchProjectsByProjectDesc_args getEmptyArgsInstance() { - return new searchProjectsByProjectDesc_args(); + public createProject_args getEmptyArgsInstance() { + return new createProject_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { - public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { - searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + createProject_result result = new createProject_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12258,7 +12904,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); + createProject_result result = new createProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12294,26 +12940,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, searchProjectsByProjectDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { - iface.searchProjectsByProjectDesc(args.userName, args.description,resultHandler); + public void start(I iface, createProject_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.createProject(args.project,resultHandler); } } - public static class searchExperimentsByName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByName_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> { - public searchExperimentsByName() { - super("searchExperimentsByName"); + public static class updateProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateProject_args, Void> { + public updateProject() { + super("updateProject"); } - public searchExperimentsByName_args getEmptyArgsInstance() { - return new searchExperimentsByName_args(); + public updateProject_args getEmptyArgsInstance() { + return new updateProject_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> 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.ExperimentSummary>>() { - public void onComplete(List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> o) { - searchExperimentsByName_result result = new searchExperimentsByName_result(); - result.success = o; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateProject_result result = new updateProject_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -12325,7 +12970,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByName_result result = new searchExperimentsByName_result(); + updateProject_result result = new updateProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12341,6 +12986,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; @@ -12361,25 +13011,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, searchExperimentsByName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException { - iface.searchExperimentsByName(args.userName, args.expName,resultHandler); + public void start(I iface, updateProject_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateProject(args.projectId, args.updatedProject,resultHandler); } } - public static class searchExperimentsByDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByDesc_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> { - public searchExperimentsByDesc() { - super("searchExperimentsByDesc"); + public static class getProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getProject_args, org.apache.airavata.model.workspace.Project> { + public getProject() { + super("getProject"); } - public searchExperimentsByDesc_args getEmptyArgsInstance() { - return new searchExperimentsByDesc_args(); + public getProject_args getEmptyArgsInstance() { + return new getProject_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.workspace.Project> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>>() { - public void onComplete(List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> o) { - searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); + return new AsyncMethodCallback<org.apache.airavata.model.workspace.Project>() { + public void onComplete(org.apache.airavata.model.workspace.Project o) { + getProject_result result = new getProject_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12392,7 +13042,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); + getProject_result result = new getProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12408,6 +13058,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; @@ -12428,25 +13083,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, searchExperimentsByDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException { - iface.searchExperimentsByDesc(args.userName, args.description,resultHandler); + public void start(I iface, getProject_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Project> resultHandler) throws TException { + iface.getProject(args.projectId,resultHandler); } } - public static class searchExperimentsByApplication<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByApplication_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> { - public searchExperimentsByApplication() { - super("searchExperimentsByApplication"); + public static class getAllUserProjects<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserProjects_args, List<org.apache.airavata.model.workspace.Project>> { + public getAllUserProjects() { + super("getAllUserProjects"); } - public searchExperimentsByApplication_args getEmptyArgsInstance() { - return new searchExperimentsByApplication_args(); + public getAllUserProjects_args getEmptyArgsInstance() { + return new getAllUserProjects_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>>() { - public void onComplete(List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> o) { - searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { + getAllUserProjects_result result = new getAllUserProjects_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12459,7 +13114,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); + getAllUserProjects_result result = new getAllUserProjects_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12495,25 +13150,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, searchExperimentsByApplication_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException { - iface.searchExperimentsByApplication(args.userName, args.applicationId,resultHandler); + public void start(I iface, getAllUserProjects_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { + iface.getAllUserProjects(args.userName,resultHandler); } } - public static class searchExperimentsByStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByStatus_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> { - public searchExperimentsByStatus() { - super("searchExperimentsByStatus"); + public static class searchProjectsByProjectName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectName_args, List<org.apache.airavata.model.workspace.Project>> { + public searchProjectsByProjectName() { + super("searchProjectsByProjectName"); } - public searchExperimentsByStatus_args getEmptyArgsInstance() { - return new searchExperimentsByStatus_args(); + public searchProjectsByProjectName_args getEmptyArgsInstance() { + return new searchProjectsByProjectName_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>>() { - public void onComplete(List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> o) { - searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { + searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12526,7 +13181,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); + searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12562,25 +13217,25 @@ import org.slf4j.LoggerFactory; return false; } - public void start(I iface, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException { - iface.searchExperimentsByStatus(args.userName, args.experimentState,resultHandler); + public void start(I iface, searchProjectsByProjectName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { + iface.searchProjectsByProjectName(args.userName, args.projectName,resultHandler); } } - 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 static class searchProjectsByProjectDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectDesc_args, List<org.apache.airavata.model.workspace.Project>> { + public searchProjectsByProjectDesc() { + super("searchProjectsByProjectDesc"); } - public searchExperimentsByCreationTime_args getEmptyArgsInstance() { - return new searchExperimentsByCreationTime_args(); + public searchProjectsByProjectDesc_args getEmptyArgsInstance() { + return new searchProjectsByProjectDesc_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - 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(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { + searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12593,7 +13248,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); + searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12629,25 +13284,25 @@ import org.slf4j.LoggerFactory; return false; } - 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 void start(I iface, searchProjectsByProjectDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { + iface.searchProjectsByProjectDesc(args.userName, args.description,resultHandler); } } - 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 searchExperimentsByName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByName_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> { + public searchExperimentsByName() { + super("searchExperimentsByName"); } - public getAllExperimentsInProject_args getEmptyArgsInstance() { - return new getAllExperimentsInProject_args(); + public searchExperimentsByName_args getEmptyArgsInstance() { + return new searchExperimentsByName_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) { + searchExperimentsByName_result result = new searchExperimentsByName_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12660,7 +13315,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(); + searchExperimentsByName_result result = new searchExperimentsByName_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12676,11 +13331,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; @@ -12701,25 +13351,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, searchExperimentsByName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException { + iface.searchExperimentsByName(args.userName, args.expName,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 searchExperimentsByDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByDesc_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> { + public searchExperimentsByDesc() { + super("searchExperimentsByDesc"); } - public getAllUserExperiments_args getEmptyArgsInstance() { - return new getAllUserExperiments_args(); + public searchExperimentsByDesc_args getEmptyArgsInstance() { + return new searchExperimentsByDesc_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) { - getAllUserExperiments_result result = new getAllUserExperiments_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> o) { + searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12732,7 +13382,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllUserExperiments_result result = new getAllUserExperiments_result(); + searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12768,25 +13418,25 @@ import org.slf4j.LoggerFactory; 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 void start(I iface, searchExperimentsByDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException { + iface.searchExperimentsByDesc(args.userName, args.description,resultHandler); } } - public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> { - public createExperiment() { - super("createExperiment"); + public static class searchExperimentsByApplication<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByApplication_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> { + public searchExperimentsByApplication() { + super("searchExperimentsByApplication"); } - public createExperiment_args getEmptyArgsInstance() { - return new createExperiment_args(); + public searchExperimentsByApplication_args getEmptyArgsInstance() { + return new searchExperimentsByApplication_args(); } - public AsyncMethodCallback<String> 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<String>() { - public void onComplete(String o) { - createExperiment_result result = new createExperiment_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> o) { + searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12799,7 +13449,7 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - createExperiment_result result = new createExperiment_result(); + searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -12835,25 +13485,25 @@ import org.slf4j.LoggerFactory; 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 void start(I iface, searchExperimentsByApplication_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException { + iface.searchExperimentsByApplication(args.userName, args.applicationId,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 static class searchExperimentsByStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByStatus_args, List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> { + public searchExperimentsByStatus() { + super("searchExperimentsByStatus"); } - public getExperiment_args getEmptyArgsInstance() { - return new getExperiment_args(); + public searchExperimentsByStatus_args getEmptyArgsInstance() { + return new searchExperimentsByStatus_args(); } - public AsyncMethodCallback<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<org.apache.airavata.model.workspace.experiment.Experiment>() { - public void onComplete(org.apache.airavata.model.workspace.experiment.Experiment o) { - getExperiment_result result = new getExperiment_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>>() { + public void onComplete(List<org.apache.airavata.model.workspace.experiment.ExperimentSummary> o) { + searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -12866,17 +13516,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(); + searchExperimentsByStatus_result result = new searchExperimentsByStatus_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); @@ -12907,25 +13552,26 @@ import org.slf4j.LoggerFactory; 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, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.experiment.ExperimentSummary>> resultHandler) throws TException { + iface.searchExperimentsByStatus(args.userName, args.experimentState,resultHandler); } } - public static class updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> { - public updateExperiment() { - super("updateExperiment"); + 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 updateExperiment_args getEmptyArgsInstance() { - return new updateExperiment_args(); + public searchExperimentsByCreationTime_args getEmptyArgsInstance() { + return new searchExperimentsByCreationTime_args(); } - public AsyncMethodCallback<Void> 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<Void>() { - public void onComplete(Void o) { - updateExperiment_result result = new updateExperiment_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); return; @@ -12937,17 +13583,12 @@ import org.slf4j.LoggerFactory; public void onError(Exception e) { byte msgType = org.apache
<TRUNCATED>
