Return-Path: X-Original-To: apmail-airavata-commits-archive@www.apache.org Delivered-To: apmail-airavata-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D9CAE105BC for ; Mon, 2 Mar 2015 20:27:47 +0000 (UTC) Received: (qmail 55401 invoked by uid 500); 2 Mar 2015 20:27:47 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 55283 invoked by uid 500); 2 Mar 2015 20:27:47 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 55104 invoked by uid 99); 2 Mar 2015 20:27:47 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Mar 2015 20:27:47 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 59872E0FCD; Mon, 2 Mar 2015 20:27:47 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: chathuri@apache.org To: commits@airavata.apache.org Date: Mon, 02 Mar 2015 20:27:52 -0000 Message-Id: In-Reply-To: <52de39f1f1ab46e88962ac6a645c3293@git.apache.org> References: <52de39f1f1ab46e88962ac6a645c3293@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [6/7] airavata git commit: adding CRUD operations to gateway - AIRAVATA-1608, AIRAVATA-1604 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 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 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 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 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 Map> getProcessMap(Map> 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 extends org.apache.thrift.ProcessFunction { + 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 extends org.apache.thrift.ProcessFunction { + 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 extends org.apache.thrift.ProcessFunction { + 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 extends org.apache.thrift.ProcessFunction { + 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 extends org.apache.thrift.ProcessFunction { + 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 extends org.apache.thrift.ProcessFunction { + 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 extends org.apache.thrift.ProcessFunction { public createProject() { super("createProject"); @@ -11714,6 +12295,12 @@ import org.slf4j.LoggerFactory; private static Map> getProcessMap(Map> 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 extends org.apache.thrift.AsyncProcessFunction { - public createProject() { - super("createProject"); + public static class addGateway extends org.apache.thrift.AsyncProcessFunction { + public addGateway() { + super("addGateway"); } - public createProject_args getEmptyArgsInstance() { - return new createProject_args(); + public addGateway_args getEmptyArgsInstance() { + return new addGateway_args(); } public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback() { 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 resultHandler) throws TException { - iface.createProject(args.project,resultHandler); + public void start(I iface, addGateway_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.addGateway(args.gateway,resultHandler); } } - public static class updateProject extends org.apache.thrift.AsyncProcessFunction { - public updateProject() { - super("updateProject"); + public static class updateGateway extends org.apache.thrift.AsyncProcessFunction { + public updateGateway() { + super("updateGateway"); } - public updateProject_args getEmptyArgsInstance() { - return new updateProject_args(); + public updateGateway_args getEmptyArgsInstance() { + return new updateGateway_args(); } public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback() { 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 resultHandler) throws TException { - iface.updateProject(args.projectId, args.updatedProject,resultHandler); + public void start(I iface, updateGateway_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.updateGateway(args.gatewayId, args.updatedGateway,resultHandler); } } - public static class getProject extends org.apache.thrift.AsyncProcessFunction { - public getProject() { - super("getProject"); + public static class getGateway extends org.apache.thrift.AsyncProcessFunction { + public getGateway() { + super("getGateway"); } - public getProject_args getEmptyArgsInstance() { - return new getProject_args(); + public getGateway_args getEmptyArgsInstance() { + return new getGateway_args(); } - public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback() { - public void onComplete(org.apache.airavata.model.workspace.Project o) { - getProject_result result = new getProject_result(); + return new AsyncMethodCallback() { + 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 resultHandler) throws TException { + iface.getGateway(args.gatewayId,resultHandler); + } + } + + public static class deleteGateway extends org.apache.thrift.AsyncProcessFunction { + public deleteGateway() { + super("deleteGateway"); + } + + public deleteGateway_args getEmptyArgsInstance() { + return new deleteGateway_args(); + } + + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback() { + 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 resultHandler) throws TException { - iface.getProject(args.projectId,resultHandler); + public void start(I iface, deleteGateway_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.deleteGateway(args.gatewayId,resultHandler); } } - public static class getAllUserProjects extends org.apache.thrift.AsyncProcessFunction> { - public getAllUserProjects() { - super("getAllUserProjects"); + public static class getAllGateways extends org.apache.thrift.AsyncProcessFunction> { + public getAllGateways() { + super("getAllGateways"); } - public getAllUserProjects_args getEmptyArgsInstance() { - return new getAllUserProjects_args(); + public getAllGateways_args getEmptyArgsInstance() { + return new getAllGateways_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - getAllUserProjects_result result = new getAllUserProjects_result(); + return new AsyncMethodCallback>() { + public void onComplete(List 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> resultHandler) throws TException { - iface.getAllUserProjects(args.userName,resultHandler); + public void start(I iface, getAllGateways_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.getAllGateways(resultHandler); } } - public static class searchProjectsByProjectName extends org.apache.thrift.AsyncProcessFunction> { - public searchProjectsByProjectName() { - super("searchProjectsByProjectName"); + public static class isGatewayExist extends org.apache.thrift.AsyncProcessFunction { + public isGatewayExist() { + super("isGatewayExist"); } - public searchProjectsByProjectName_args getEmptyArgsInstance() { - return new searchProjectsByProjectName_args(); + public isGatewayExist_args getEmptyArgsInstance() { + return new isGatewayExist_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); + return new AsyncMethodCallback() { + 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> resultHandler) throws TException { - iface.searchProjectsByProjectName(args.userName, args.projectName,resultHandler); + public void start(I iface, isGatewayExist_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.isGatewayExist(args.gatewayId,resultHandler); } } - public static class searchProjectsByProjectDesc extends org.apache.thrift.AsyncProcessFunction> { - public searchProjectsByProjectDesc() { - super("searchProjectsByProjectDesc"); + public static class createProject extends org.apache.thrift.AsyncProcessFunction { + public createProject() { + super("createProject"); } - public searchProjectsByProjectDesc_args getEmptyArgsInstance() { - return new searchProjectsByProjectDesc_args(); + public createProject_args getEmptyArgsInstance() { + return new createProject_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); + return new AsyncMethodCallback() { + 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> resultHandler) throws TException { - iface.searchProjectsByProjectDesc(args.userName, args.description,resultHandler); + public void start(I iface, createProject_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.createProject(args.project,resultHandler); } } - public static class searchExperimentsByName extends org.apache.thrift.AsyncProcessFunction> { - public searchExperimentsByName() { - super("searchExperimentsByName"); + public static class updateProject extends org.apache.thrift.AsyncProcessFunction { + public updateProject() { + super("updateProject"); } - public searchExperimentsByName_args getEmptyArgsInstance() { - return new searchExperimentsByName_args(); + public updateProject_args getEmptyArgsInstance() { + return new updateProject_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - searchExperimentsByName_result result = new searchExperimentsByName_result(); - result.success = o; + return new AsyncMethodCallback() { + 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> resultHandler) throws TException { - iface.searchExperimentsByName(args.userName, args.expName,resultHandler); + public void start(I iface, updateProject_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.updateProject(args.projectId, args.updatedProject,resultHandler); } } - public static class searchExperimentsByDesc extends org.apache.thrift.AsyncProcessFunction> { - public searchExperimentsByDesc() { - super("searchExperimentsByDesc"); + public static class getProject extends org.apache.thrift.AsyncProcessFunction { + public getProject() { + super("getProject"); } - public searchExperimentsByDesc_args getEmptyArgsInstance() { - return new searchExperimentsByDesc_args(); + public getProject_args getEmptyArgsInstance() { + return new getProject_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); + return new AsyncMethodCallback() { + 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> resultHandler) throws TException { - iface.searchExperimentsByDesc(args.userName, args.description,resultHandler); + public void start(I iface, getProject_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getProject(args.projectId,resultHandler); } } - public static class searchExperimentsByApplication extends org.apache.thrift.AsyncProcessFunction> { - public searchExperimentsByApplication() { - super("searchExperimentsByApplication"); + public static class getAllUserProjects extends org.apache.thrift.AsyncProcessFunction> { + public getAllUserProjects() { + super("getAllUserProjects"); } - public searchExperimentsByApplication_args getEmptyArgsInstance() { - return new searchExperimentsByApplication_args(); + public getAllUserProjects_args getEmptyArgsInstance() { + return new getAllUserProjects_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); + return new AsyncMethodCallback>() { + public void onComplete(List 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> resultHandler) throws TException { - iface.searchExperimentsByApplication(args.userName, args.applicationId,resultHandler); + public void start(I iface, getAllUserProjects_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.getAllUserProjects(args.userName,resultHandler); } } - public static class searchExperimentsByStatus extends org.apache.thrift.AsyncProcessFunction> { - public searchExperimentsByStatus() { - super("searchExperimentsByStatus"); + public static class searchProjectsByProjectName extends org.apache.thrift.AsyncProcessFunction> { + public searchProjectsByProjectName() { + super("searchProjectsByProjectName"); } - public searchExperimentsByStatus_args getEmptyArgsInstance() { - return new searchExperimentsByStatus_args(); + public searchProjectsByProjectName_args getEmptyArgsInstance() { + return new searchProjectsByProjectName_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); + return new AsyncMethodCallback>() { + public void onComplete(List 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> resultHandler) throws TException { - iface.searchExperimentsByStatus(args.userName, args.experimentState,resultHandler); + public void start(I iface, searchProjectsByProjectName_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.searchProjectsByProjectName(args.userName, args.projectName,resultHandler); } } - public static class searchExperimentsByCreationTime extends org.apache.thrift.AsyncProcessFunction> { - public searchExperimentsByCreationTime() { - super("searchExperimentsByCreationTime"); + public static class searchProjectsByProjectDesc extends org.apache.thrift.AsyncProcessFunction> { + public searchProjectsByProjectDesc() { + super("searchProjectsByProjectDesc"); } - public searchExperimentsByCreationTime_args getEmptyArgsInstance() { - return new searchExperimentsByCreationTime_args(); + public searchProjectsByProjectDesc_args getEmptyArgsInstance() { + return new searchProjectsByProjectDesc_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); + return new AsyncMethodCallback>() { + public void onComplete(List 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> 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> resultHandler) throws TException { + iface.searchProjectsByProjectDesc(args.userName, args.description,resultHandler); } } - public static class getAllExperimentsInProject extends org.apache.thrift.AsyncProcessFunction> { - public getAllExperimentsInProject() { - super("getAllExperimentsInProject"); + public static class searchExperimentsByName extends org.apache.thrift.AsyncProcessFunction> { + public searchExperimentsByName() { + super("searchExperimentsByName"); } - public getAllExperimentsInProject_args getEmptyArgsInstance() { - return new getAllExperimentsInProject_args(); + public searchExperimentsByName_args getEmptyArgsInstance() { + return new searchExperimentsByName_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - getAllExperimentsInProject_result result = new getAllExperimentsInProject_result(); + return new AsyncMethodCallback>() { + public void onComplete(List 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> resultHandler) throws TException { - iface.getAllExperimentsInProject(args.projectId,resultHandler); + public void start(I iface, searchExperimentsByName_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.searchExperimentsByName(args.userName, args.expName,resultHandler); } } - public static class getAllUserExperiments extends org.apache.thrift.AsyncProcessFunction> { - public getAllUserExperiments() { - super("getAllUserExperiments"); + public static class searchExperimentsByDesc extends org.apache.thrift.AsyncProcessFunction> { + public searchExperimentsByDesc() { + super("searchExperimentsByDesc"); } - public getAllUserExperiments_args getEmptyArgsInstance() { - return new getAllUserExperiments_args(); + public searchExperimentsByDesc_args getEmptyArgsInstance() { + return new searchExperimentsByDesc_args(); } - public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback>() { - public void onComplete(List o) { - getAllUserExperiments_result result = new getAllUserExperiments_result(); + return new AsyncMethodCallback>() { + public void onComplete(List 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> resultHandler) throws TException { - iface.getAllUserExperiments(args.userName,resultHandler); + public void start(I iface, searchExperimentsByDesc_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.searchExperimentsByDesc(args.userName, args.description,resultHandler); } } - public static class createExperiment extends org.apache.thrift.AsyncProcessFunction { - public createExperiment() { - super("createExperiment"); + public static class searchExperimentsByApplication extends org.apache.thrift.AsyncProcessFunction> { + public searchExperimentsByApplication() { + super("searchExperimentsByApplication"); } - public createExperiment_args getEmptyArgsInstance() { - return new createExperiment_args(); + public searchExperimentsByApplication_args getEmptyArgsInstance() { + return new searchExperimentsByApplication_args(); } - public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback() { - public void onComplete(String o) { - createExperiment_result result = new createExperiment_result(); + return new AsyncMethodCallback>() { + public void onComplete(List 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 resultHandler) throws TException { - iface.createExperiment(args.experiment,resultHandler); + public void start(I iface, searchExperimentsByApplication_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.searchExperimentsByApplication(args.userName, args.applicationId,resultHandler); } } - public static class getExperiment extends org.apache.thrift.AsyncProcessFunction { - public getExperiment() { - super("getExperiment"); + public static class searchExperimentsByStatus extends org.apache.thrift.AsyncProcessFunction> { + public searchExperimentsByStatus() { + super("searchExperimentsByStatus"); } - public getExperiment_args getEmptyArgsInstance() { - return new getExperiment_args(); + public searchExperimentsByStatus_args getEmptyArgsInstance() { + return new searchExperimentsByStatus_args(); } - public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback() { - public void onComplete(org.apache.airavata.model.workspace.experiment.Experiment o) { - getExperiment_result result = new getExperiment_result(); + return new AsyncMethodCallback>() { + public void onComplete(List 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 resultHandler) throws TException { - iface.getExperiment(args.airavataExperimentId,resultHandler); + public void start(I iface, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.searchExperimentsByStatus(args.userName, args.experimentState,resultHandler); } } - public static class updateExperiment extends org.apache.thrift.AsyncProcessFunction { - public updateExperiment() { - super("updateExperiment"); + public static class searchExperimentsByCreationTime extends org.apache.thrift.AsyncProcessFunction> { + public searchExperimentsByCreationTime() { + super("searchExperimentsByCreationTime"); } - public updateExperiment_args getEmptyArgsInstance() { - return new updateExperiment_args(); + public searchExperimentsByCreationTime_args getEmptyArgsInstance() { + return new searchExperimentsByCreationTime_args(); } - public AsyncMethodCallback getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback() { - public void onComplete(Void o) { - updateExperiment_result result = new updateExperiment_result(); + return new AsyncMethodCallback>() { + public void onComplete(List 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