Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 886A9200BC8 for ; Tue, 8 Nov 2016 19:40:08 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 873E1160B0A; Tue, 8 Nov 2016 18:40:08 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 37A2B160B16 for ; Tue, 8 Nov 2016 19:40:06 +0100 (CET) Received: (qmail 99582 invoked by uid 500); 8 Nov 2016 18:40:05 -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 99371 invoked by uid 99); 8 Nov 2016 18:40:05 -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; Tue, 08 Nov 2016 18:40:05 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id F3B76E3A9C; Tue, 8 Nov 2016 18:40:04 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: scnakandala@apache.org To: commits@airavata.apache.org Date: Tue, 08 Nov 2016 18:40:10 -0000 Message-Id: <9fc52d716d924205ac9298c861ad9c43@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [7/9] airavata git commit: Implementing cluster status monitoring archived-at: Tue, 08 Nov 2016 18:40:08 -0000 http://git-wip-us.apache.org/repos/asf/airavata/blob/914799c1/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 76cd150..4441999 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 @@ -2862,6 +2862,8 @@ public class Airavata { public List getAllWorkflows(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException; + public List getLatestQueueStatuses(org.apache.airavata.model.security.AuthzToken authzToken) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException; + /** * * API Methods Related for Work-Flow Submission Features. @@ -3224,6 +3226,8 @@ public class Airavata { public void getAllWorkflows(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getLatestQueueStatuses(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getWorkflow(org.apache.airavata.model.security.AuthzToken authzToken, String workflowTemplateId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void deleteWorkflow(org.apache.airavata.model.security.AuthzToken authzToken, String workflowTemplateId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -8720,6 +8724,41 @@ public class Airavata { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllWorkflows failed: unknown result"); } + public List getLatestQueueStatuses(org.apache.airavata.model.security.AuthzToken authzToken) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException + { + send_getLatestQueueStatuses(authzToken); + return recv_getLatestQueueStatuses(); + } + + public void send_getLatestQueueStatuses(org.apache.airavata.model.security.AuthzToken authzToken) throws org.apache.thrift.TException + { + getLatestQueueStatuses_args args = new getLatestQueueStatuses_args(); + args.setAuthzToken(authzToken); + sendBase("getLatestQueueStatuses", args); + } + + public List recv_getLatestQueueStatuses() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException + { + getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); + receiveBase(result, "getLatestQueueStatuses"); + 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; + } + if (result.ae != null) { + throw result.ae; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLatestQueueStatuses failed: unknown result"); + } + public org.apache.airavata.model.WorkflowModel getWorkflow(org.apache.airavata.model.security.AuthzToken authzToken, String workflowTemplateId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException { send_getWorkflow(authzToken, workflowTemplateId); @@ -14976,6 +15015,38 @@ public class Airavata { } } + public void getLatestQueueStatuses(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getLatestQueueStatuses_call method_call = new getLatestQueueStatuses_call(authzToken, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getLatestQueueStatuses_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.airavata.model.security.AuthzToken authzToken; + public getLatestQueueStatuses_call(org.apache.airavata.model.security.AuthzToken authzToken, 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.authzToken = authzToken; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getLatestQueueStatuses", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getLatestQueueStatuses_args args = new getLatestQueueStatuses_args(); + args.setAuthzToken(authzToken); + 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.airavata.model.error.AuthorizationException, 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_getLatestQueueStatuses(); + } + } + public void getWorkflow(org.apache.airavata.model.security.AuthzToken authzToken, String workflowTemplateId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getWorkflow_call method_call = new getWorkflow_call(authzToken, workflowTemplateId, resultHandler, this, ___protocolFactory, ___transport); @@ -15835,6 +15906,7 @@ public class Airavata { processMap.put("deleteUserComputeResourcePreference", new deleteUserComputeResourcePreference()); processMap.put("deleteUserStoragePreference", new deleteUserStoragePreference()); processMap.put("getAllWorkflows", new getAllWorkflows()); + processMap.put("getLatestQueueStatuses", new getLatestQueueStatuses()); processMap.put("getWorkflow", new getWorkflow()); processMap.put("deleteWorkflow", new deleteWorkflow()); processMap.put("registerWorkflow", new registerWorkflow()); @@ -20353,6 +20425,36 @@ public class Airavata { } } + public static class getLatestQueueStatuses extends org.apache.thrift.ProcessFunction { + public getLatestQueueStatuses() { + super("getLatestQueueStatuses"); + } + + public getLatestQueueStatuses_args getEmptyArgsInstance() { + return new getLatestQueueStatuses_args(); + } + + protected boolean isOneway() { + return false; + } + + public getLatestQueueStatuses_result getResult(I iface, getLatestQueueStatuses_args args) throws org.apache.thrift.TException { + getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); + try { + result.success = iface.getLatestQueueStatuses(args.authzToken); + } 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; + } catch (org.apache.airavata.model.error.AuthorizationException ae) { + result.ae = ae; + } + return result; + } + } + public static class getWorkflow extends org.apache.thrift.ProcessFunction { public getWorkflow() { super("getWorkflow"); @@ -21090,6 +21192,7 @@ public class Airavata { processMap.put("deleteUserComputeResourcePreference", new deleteUserComputeResourcePreference()); processMap.put("deleteUserStoragePreference", new deleteUserStoragePreference()); processMap.put("getAllWorkflows", new getAllWorkflows()); + processMap.put("getLatestQueueStatuses", new getLatestQueueStatuses()); processMap.put("getWorkflow", new getWorkflow()); processMap.put("deleteWorkflow", new deleteWorkflow()); processMap.put("registerWorkflow", new registerWorkflow()); @@ -31821,20 +31924,20 @@ public class Airavata { } } - public static class getWorkflow extends org.apache.thrift.AsyncProcessFunction { - public getWorkflow() { - super("getWorkflow"); + public static class getLatestQueueStatuses extends org.apache.thrift.AsyncProcessFunction> { + public getLatestQueueStatuses() { + super("getLatestQueueStatuses"); } - public getWorkflow_args getEmptyArgsInstance() { - return new getWorkflow_args(); + public getLatestQueueStatuses_args getEmptyArgsInstance() { + return new getLatestQueueStatuses_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.WorkflowModel o) { - getWorkflow_result result = new getWorkflow_result(); + return new AsyncMethodCallback>() { + public void onComplete(List o) { + getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -31847,7 +31950,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getWorkflow_result result = new getWorkflow_result(); + getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -31888,96 +31991,25 @@ public class Airavata { return false; } - public void start(I iface, getWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.getWorkflow(args.authzToken, args.workflowTemplateId,resultHandler); + public void start(I iface, getLatestQueueStatuses_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.getLatestQueueStatuses(args.authzToken,resultHandler); } } - public static class deleteWorkflow extends org.apache.thrift.AsyncProcessFunction { - public deleteWorkflow() { - super("deleteWorkflow"); - } - - public deleteWorkflow_args getEmptyArgsInstance() { - return new deleteWorkflow_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) { - deleteWorkflow_result result = new deleteWorkflow_result(); - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - deleteWorkflow_result result = new deleteWorkflow_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { - result.ae = (org.apache.airavata.model.error.AuthorizationException) e; - result.setAeIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, deleteWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.deleteWorkflow(args.authzToken, args.workflowTemplateId,resultHandler); - } - } - - public static class registerWorkflow extends org.apache.thrift.AsyncProcessFunction { - public registerWorkflow() { - super("registerWorkflow"); + public static class getWorkflow extends org.apache.thrift.AsyncProcessFunction { + public getWorkflow() { + super("getWorkflow"); } - public registerWorkflow_args getEmptyArgsInstance() { - return new registerWorkflow_args(); + public getWorkflow_args getEmptyArgsInstance() { + return new getWorkflow_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) { - registerWorkflow_result result = new registerWorkflow_result(); + return new AsyncMethodCallback() { + public void onComplete(org.apache.airavata.model.WorkflowModel o) { + getWorkflow_result result = new getWorkflow_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -31990,7 +32022,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - registerWorkflow_result result = new registerWorkflow_result(); + getWorkflow_result result = new getWorkflow_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32031,314 +32063,25 @@ public class Airavata { return false; } - public void start(I iface, registerWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.registerWorkflow(args.authzToken, args.gatewayId, args.workflow,resultHandler); + public void start(I iface, getWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getWorkflow(args.authzToken, args.workflowTemplateId,resultHandler); } } - public static class updateWorkflow extends org.apache.thrift.AsyncProcessFunction { - public updateWorkflow() { - super("updateWorkflow"); + public static class deleteWorkflow extends org.apache.thrift.AsyncProcessFunction { + public deleteWorkflow() { + super("deleteWorkflow"); } - public updateWorkflow_args getEmptyArgsInstance() { - return new updateWorkflow_args(); + public deleteWorkflow_args getEmptyArgsInstance() { + return new deleteWorkflow_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) { - updateWorkflow_result result = new updateWorkflow_result(); - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - updateWorkflow_result result = new updateWorkflow_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { - result.ae = (org.apache.airavata.model.error.AuthorizationException) e; - result.setAeIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, updateWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.updateWorkflow(args.authzToken, args.workflowTemplateId, args.workflow,resultHandler); - } - } - - public static class getWorkflowTemplateId extends org.apache.thrift.AsyncProcessFunction { - public getWorkflowTemplateId() { - super("getWorkflowTemplateId"); - } - - public getWorkflowTemplateId_args getEmptyArgsInstance() { - return new getWorkflowTemplateId_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) { - getWorkflowTemplateId_result result = new getWorkflowTemplateId_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - getWorkflowTemplateId_result result = new getWorkflowTemplateId_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { - result.ae = (org.apache.airavata.model.error.AuthorizationException) e; - result.setAeIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, getWorkflowTemplateId_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.getWorkflowTemplateId(args.authzToken, args.workflowName,resultHandler); - } - } - - public static class isWorkflowExistWithName extends org.apache.thrift.AsyncProcessFunction { - public isWorkflowExistWithName() { - super("isWorkflowExistWithName"); - } - - public isWorkflowExistWithName_args getEmptyArgsInstance() { - return new isWorkflowExistWithName_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) { - isWorkflowExistWithName_result result = new isWorkflowExistWithName_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; - isWorkflowExistWithName_result result = new isWorkflowExistWithName_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { - result.ae = (org.apache.airavata.model.error.AuthorizationException) e; - result.setAeIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, isWorkflowExistWithName_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.isWorkflowExistWithName(args.authzToken, args.workflowName,resultHandler); - } - } - - public static class registerDataProduct extends org.apache.thrift.AsyncProcessFunction { - public registerDataProduct() { - super("registerDataProduct"); - } - - public registerDataProduct_args getEmptyArgsInstance() { - return new registerDataProduct_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) { - registerDataProduct_result result = new registerDataProduct_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - registerDataProduct_result result = new registerDataProduct_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { - result.ae = (org.apache.airavata.model.error.AuthorizationException) e; - result.setAeIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, registerDataProduct_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.registerDataProduct(args.authzToken, args.dataProductModel,resultHandler); - } - } - - public static class getDataProduct extends org.apache.thrift.AsyncProcessFunction { - public getDataProduct() { - super("getDataProduct"); - } - - public getDataProduct_args getEmptyArgsInstance() { - return new getDataProduct_args(); - } - - 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.data.replica.DataProductModel o) { - getDataProduct_result result = new getDataProduct_result(); - result.success = o; + deleteWorkflow_result result = new deleteWorkflow_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32350,7 +32093,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getDataProduct_result result = new getDataProduct_result(); + deleteWorkflow_result result = new deleteWorkflow_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32391,25 +32134,25 @@ public class Airavata { return false; } - public void start(I iface, getDataProduct_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.getDataProduct(args.authzToken, args.dataProductUri,resultHandler); + public void start(I iface, deleteWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.deleteWorkflow(args.authzToken, args.workflowTemplateId,resultHandler); } } - public static class registerReplicaLocation extends org.apache.thrift.AsyncProcessFunction { - public registerReplicaLocation() { - super("registerReplicaLocation"); + public static class registerWorkflow extends org.apache.thrift.AsyncProcessFunction { + public registerWorkflow() { + super("registerWorkflow"); } - public registerReplicaLocation_args getEmptyArgsInstance() { - return new registerReplicaLocation_args(); + public registerWorkflow_args getEmptyArgsInstance() { + return new registerWorkflow_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) { - registerReplicaLocation_result result = new registerReplicaLocation_result(); + registerWorkflow_result result = new registerWorkflow_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -32422,7 +32165,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - registerReplicaLocation_result result = new registerReplicaLocation_result(); + registerWorkflow_result result = new registerWorkflow_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32463,26 +32206,25 @@ public class Airavata { return false; } - public void start(I iface, registerReplicaLocation_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.registerReplicaLocation(args.authzToken, args.replicaLocationModel,resultHandler); + public void start(I iface, registerWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.registerWorkflow(args.authzToken, args.gatewayId, args.workflow,resultHandler); } } - public static class getParentDataProduct extends org.apache.thrift.AsyncProcessFunction { - public getParentDataProduct() { - super("getParentDataProduct"); + public static class updateWorkflow extends org.apache.thrift.AsyncProcessFunction { + public updateWorkflow() { + super("updateWorkflow"); } - public getParentDataProduct_args getEmptyArgsInstance() { - return new getParentDataProduct_args(); + public updateWorkflow_args getEmptyArgsInstance() { + return new updateWorkflow_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.data.replica.DataProductModel o) { - getParentDataProduct_result result = new getParentDataProduct_result(); - result.success = o; + return new AsyncMethodCallback() { + public void onComplete(Void o) { + updateWorkflow_result result = new updateWorkflow_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32494,7 +32236,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getParentDataProduct_result result = new getParentDataProduct_result(); + updateWorkflow_result result = new updateWorkflow_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32535,25 +32277,25 @@ public class Airavata { return false; } - public void start(I iface, getParentDataProduct_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.getParentDataProduct(args.authzToken, args.productUri,resultHandler); + public void start(I iface, updateWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.updateWorkflow(args.authzToken, args.workflowTemplateId, args.workflow,resultHandler); } } - public static class getChildDataProducts extends org.apache.thrift.AsyncProcessFunction> { - public getChildDataProducts() { - super("getChildDataProducts"); + public static class getWorkflowTemplateId extends org.apache.thrift.AsyncProcessFunction { + public getWorkflowTemplateId() { + super("getWorkflowTemplateId"); } - public getChildDataProducts_args getEmptyArgsInstance() { - return new getChildDataProducts_args(); + public getWorkflowTemplateId_args getEmptyArgsInstance() { + return new getWorkflowTemplateId_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) { - getChildDataProducts_result result = new getChildDataProducts_result(); + return new AsyncMethodCallback() { + public void onComplete(String o) { + getWorkflowTemplateId_result result = new getWorkflowTemplateId_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -32566,7 +32308,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getChildDataProducts_result result = new getChildDataProducts_result(); + getWorkflowTemplateId_result result = new getWorkflowTemplateId_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32607,25 +32349,25 @@ public class Airavata { return false; } - public void start(I iface, getChildDataProducts_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { - iface.getChildDataProducts(args.authzToken, args.productUri,resultHandler); + public void start(I iface, getWorkflowTemplateId_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getWorkflowTemplateId(args.authzToken, args.workflowName,resultHandler); } } - public static class shareResourceWithUsers extends org.apache.thrift.AsyncProcessFunction { - public shareResourceWithUsers() { - super("shareResourceWithUsers"); + public static class isWorkflowExistWithName extends org.apache.thrift.AsyncProcessFunction { + public isWorkflowExistWithName() { + super("isWorkflowExistWithName"); } - public shareResourceWithUsers_args getEmptyArgsInstance() { - return new shareResourceWithUsers_args(); + public isWorkflowExistWithName_args getEmptyArgsInstance() { + return new isWorkflowExistWithName_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) { - shareResourceWithUsers_result result = new shareResourceWithUsers_result(); + isWorkflowExistWithName_result result = new isWorkflowExistWithName_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -32639,7 +32381,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - shareResourceWithUsers_result result = new shareResourceWithUsers_result(); + isWorkflowExistWithName_result result = new isWorkflowExistWithName_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32680,27 +32422,26 @@ public class Airavata { return false; } - public void start(I iface, shareResourceWithUsers_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.shareResourceWithUsers(args.authzToken, args.resourceId, args.resourceType, args.userPermissionList,resultHandler); + public void start(I iface, isWorkflowExistWithName_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.isWorkflowExistWithName(args.authzToken, args.workflowName,resultHandler); } } - public static class revokeSharingOfResourceFromUsers extends org.apache.thrift.AsyncProcessFunction { - public revokeSharingOfResourceFromUsers() { - super("revokeSharingOfResourceFromUsers"); + public static class registerDataProduct extends org.apache.thrift.AsyncProcessFunction { + public registerDataProduct() { + super("registerDataProduct"); } - public revokeSharingOfResourceFromUsers_args getEmptyArgsInstance() { - return new revokeSharingOfResourceFromUsers_args(); + public registerDataProduct_args getEmptyArgsInstance() { + return new registerDataProduct_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(Boolean o) { - revokeSharingOfResourceFromUsers_result result = new revokeSharingOfResourceFromUsers_result(); + return new AsyncMethodCallback() { + public void onComplete(String o) { + registerDataProduct_result result = new registerDataProduct_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32712,7 +32453,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - revokeSharingOfResourceFromUsers_result result = new revokeSharingOfResourceFromUsers_result(); + registerDataProduct_result result = new registerDataProduct_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32753,25 +32494,25 @@ public class Airavata { return false; } - public void start(I iface, revokeSharingOfResourceFromUsers_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.revokeSharingOfResourceFromUsers(args.authzToken, args.resourceId, args.resourceType, args.userPermissionList,resultHandler); + public void start(I iface, registerDataProduct_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.registerDataProduct(args.authzToken, args.dataProductModel,resultHandler); } } - public static class getAllAccessibleUsers extends org.apache.thrift.AsyncProcessFunction> { - public getAllAccessibleUsers() { - super("getAllAccessibleUsers"); + public static class getDataProduct extends org.apache.thrift.AsyncProcessFunction { + public getDataProduct() { + super("getDataProduct"); } - public getAllAccessibleUsers_args getEmptyArgsInstance() { - return new getAllAccessibleUsers_args(); + public getDataProduct_args getEmptyArgsInstance() { + return new getDataProduct_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) { - getAllAccessibleUsers_result result = new getAllAccessibleUsers_result(); + return new AsyncMethodCallback() { + public void onComplete(org.apache.airavata.model.data.replica.DataProductModel o) { + getDataProduct_result result = new getDataProduct_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -32784,7 +32525,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllAccessibleUsers_result result = new getAllAccessibleUsers_result(); + getDataProduct_result result = new getDataProduct_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32825,27 +32566,26 @@ public class Airavata { return false; } - public void start(I iface, getAllAccessibleUsers_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { - iface.getAllAccessibleUsers(args.authzToken, args.resourceId, args.resourceType, args.permissionType,resultHandler); + public void start(I iface, getDataProduct_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getDataProduct(args.authzToken, args.dataProductUri,resultHandler); } } - public static class createGroup extends org.apache.thrift.AsyncProcessFunction { - public createGroup() { - super("createGroup"); + public static class registerReplicaLocation extends org.apache.thrift.AsyncProcessFunction { + public registerReplicaLocation() { + super("registerReplicaLocation"); } - public createGroup_args getEmptyArgsInstance() { - return new createGroup_args(); + public registerReplicaLocation_args getEmptyArgsInstance() { + return new registerReplicaLocation_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(Boolean o) { - createGroup_result result = new createGroup_result(); + return new AsyncMethodCallback() { + public void onComplete(String o) { + registerReplicaLocation_result result = new registerReplicaLocation_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32857,7 +32597,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - createGroup_result result = new createGroup_result(); + registerReplicaLocation_result result = new registerReplicaLocation_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32898,27 +32638,26 @@ public class Airavata { return false; } - public void start(I iface, createGroup_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.createGroup(args.authzToken, args.groupModel,resultHandler); + public void start(I iface, registerReplicaLocation_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.registerReplicaLocation(args.authzToken, args.replicaLocationModel,resultHandler); } } - public static class updateGroup extends org.apache.thrift.AsyncProcessFunction { - public updateGroup() { - super("updateGroup"); + public static class getParentDataProduct extends org.apache.thrift.AsyncProcessFunction { + public getParentDataProduct() { + super("getParentDataProduct"); } - public updateGroup_args getEmptyArgsInstance() { - return new updateGroup_args(); + public getParentDataProduct_args getEmptyArgsInstance() { + return new getParentDataProduct_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(Boolean o) { - updateGroup_result result = new updateGroup_result(); + return new AsyncMethodCallback() { + public void onComplete(org.apache.airavata.model.data.replica.DataProductModel o) { + getParentDataProduct_result result = new getParentDataProduct_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32930,7 +32669,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateGroup_result result = new updateGroup_result(); + getParentDataProduct_result result = new getParentDataProduct_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32971,25 +32710,97 @@ public class Airavata { return false; } - public void start(I iface, updateGroup_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.updateGroup(args.authzToken, args.groupModel,resultHandler); + public void start(I iface, getParentDataProduct_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.getParentDataProduct(args.authzToken, args.productUri,resultHandler); } } - public static class deleteGroup extends org.apache.thrift.AsyncProcessFunction { - public deleteGroup() { - super("deleteGroup"); + public static class getChildDataProducts extends org.apache.thrift.AsyncProcessFunction> { + public getChildDataProducts() { + super("getChildDataProducts"); } - public deleteGroup_args getEmptyArgsInstance() { - return new deleteGroup_args(); + public getChildDataProducts_args getEmptyArgsInstance() { + return new getChildDataProducts_args(); + } + + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback>() { + public void onComplete(List o) { + getChildDataProducts_result result = new getChildDataProducts_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + getChildDataProducts_result result = new getChildDataProducts_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { + result.ae = (org.apache.airavata.model.error.AuthorizationException) e; + result.setAeIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, getChildDataProducts_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.getChildDataProducts(args.authzToken, args.productUri,resultHandler); + } + } + + public static class shareResourceWithUsers extends org.apache.thrift.AsyncProcessFunction { + public shareResourceWithUsers() { + super("shareResourceWithUsers"); + } + + public shareResourceWithUsers_args getEmptyArgsInstance() { + return new shareResourceWithUsers_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) { - deleteGroup_result result = new deleteGroup_result(); + shareResourceWithUsers_result result = new shareResourceWithUsers_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -33003,7 +32814,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteGroup_result result = new deleteGroup_result(); + shareResourceWithUsers_result result = new shareResourceWithUsers_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -33044,26 +32855,27 @@ public class Airavata { return false; } - public void start(I iface, deleteGroup_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { - iface.deleteGroup(args.authzToken, args.groupId, args.ownerId, args.gatewayId,resultHandler); + public void start(I iface, shareResourceWithUsers_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.shareResourceWithUsers(args.authzToken, args.resourceId, args.resourceType, args.userPermissionList,resultHandler); } } - public static class getGroup extends org.apache.thrift.AsyncProcessFunction { - public getGroup() { - super("getGroup"); + public static class revokeSharingOfResourceFromUsers extends org.apache.thrift.AsyncProcessFunction { + public revokeSharingOfResourceFromUsers() { + super("revokeSharingOfResourceFromUsers"); } - public getGroup_args getEmptyArgsInstance() { - return new getGroup_args(); + public revokeSharingOfResourceFromUsers_args getEmptyArgsInstance() { + return new revokeSharingOfResourceFromUsers_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.group.GroupModel o) { - getGroup_result result = new getGroup_result(); + return new AsyncMethodCallback() { + public void onComplete(Boolean o) { + revokeSharingOfResourceFromUsers_result result = new revokeSharingOfResourceFromUsers_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -33075,7 +32887,370 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getGroup_result result = new getGroup_result(); + revokeSharingOfResourceFromUsers_result result = new revokeSharingOfResourceFromUsers_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { + result.ae = (org.apache.airavata.model.error.AuthorizationException) e; + result.setAeIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, revokeSharingOfResourceFromUsers_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.revokeSharingOfResourceFromUsers(args.authzToken, args.resourceId, args.resourceType, args.userPermissionList,resultHandler); + } + } + + public static class getAllAccessibleUsers extends org.apache.thrift.AsyncProcessFunction> { + public getAllAccessibleUsers() { + super("getAllAccessibleUsers"); + } + + public getAllAccessibleUsers_args getEmptyArgsInstance() { + return new getAllAccessibleUsers_args(); + } + + public AsyncMethodCallback> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback>() { + public void onComplete(List o) { + getAllAccessibleUsers_result result = new getAllAccessibleUsers_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + getAllAccessibleUsers_result result = new getAllAccessibleUsers_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { + result.ae = (org.apache.airavata.model.error.AuthorizationException) e; + result.setAeIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, getAllAccessibleUsers_args args, org.apache.thrift.async.AsyncMethodCallback> resultHandler) throws TException { + iface.getAllAccessibleUsers(args.authzToken, args.resourceId, args.resourceType, args.permissionType,resultHandler); + } + } + + public static class createGroup extends org.apache.thrift.AsyncProcessFunction { + public createGroup() { + super("createGroup"); + } + + public createGroup_args getEmptyArgsInstance() { + return new createGroup_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) { + createGroup_result result = new createGroup_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; + createGroup_result result = new createGroup_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { + result.ae = (org.apache.airavata.model.error.AuthorizationException) e; + result.setAeIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, createGroup_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.createGroup(args.authzToken, args.groupModel,resultHandler); + } + } + + public static class updateGroup extends org.apache.thrift.AsyncProcessFunction { + public updateGroup() { + super("updateGroup"); + } + + public updateGroup_args getEmptyArgsInstance() { + return new updateGroup_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) { + updateGroup_result result = new updateGroup_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; + updateGroup_result result = new updateGroup_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { + result.ae = (org.apache.airavata.model.error.AuthorizationException) e; + result.setAeIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, updateGroup_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.updateGroup(args.authzToken, args.groupModel,resultHandler); + } + } + + public static class deleteGroup extends org.apache.thrift.AsyncProcessFunction { + public deleteGroup() { + super("deleteGroup"); + } + + public deleteGroup_args getEmptyArgsInstance() { + return new deleteGroup_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) { + deleteGroup_result result = new deleteGroup_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; + deleteGroup_result result = new deleteGroup_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 if (e instanceof org.apache.airavata.model.error.AuthorizationException) { + result.ae = (org.apache.airavata.model.error.AuthorizationException) e; + result.setAeIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, deleteGroup_args args, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws TException { + iface.deleteGroup(args.authzToken, args.groupId, args.ownerId, args.gatewayId,resultHandler); + } + } + + public static class getGroup extends org.apache.thrift.AsyncProcessFunction { + public getGroup() { + super("getGroup"); + } + + public getGroup_args getEmptyArgsInstance() { + return new getGroup_args(); + } + + 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.group.GroupModel o) { + getGroup_result result = new getGroup_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + getGroup_result result = new getGroup_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -87895,7 +88070,1437 @@ public class Airavata { @Override public String toString() { - StringBuilder sb = new StringBuilder("validateExperiment_args("); + StringBuilder sb = new StringBuilder("validateExperiment_args("); + boolean first = true; + + sb.append("authzToken:"); + if (this.authzToken == null) { + sb.append("null"); + } else { + sb.append(this.authzToken); + } + first = false; + if (!first) sb.append(", "); + sb.append("airavataExperimentId:"); + if (this.airavataExperimentId == null) { + sb.append("null"); + } else { + sb.append(this.airavataExperimentId); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (authzToken == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'authzToken' was not present! Struct: " + toString()); + } + if (airavataExperimentId == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'airavataExperimentId' was not present! Struct: " + toString()); + } + // check for sub-struct validity + if (authzToken != null) { + authzToken.validate(); + } + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class validateExperiment_argsStandardSchemeFactory implements SchemeFactory { + public validateExperiment_argsStandardScheme getScheme() { + return new validateExperiment_argsStandardScheme(); + } + } + + private static class validateExperiment_argsStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, validateExperiment_args struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // AUTHZ_TOKEN + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.authzToken = new org.apache.airavata.model.security.AuthzToken(); + struct.authzToken.read(iprot); + struct.setAuthzTokenIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // AIRAVATA_EXPERIMENT_ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.airavataExperimentId = iprot.readString(); + struct.setAiravataExperimentIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, validateExperiment_args struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.authzToken != null) { + oprot.writeFieldBegin(AUTHZ_TOKEN_FIELD_DESC); + struct.authzToken.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.airavataExperimentId != null) { + oprot.writeFieldBegin(AIRAVATA_EXPERIMENT_ID_FIELD_DESC); + oprot.writeString(struct.airavataExperimentId); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class validateExperiment_argsTupleSchemeFactory implements SchemeFactory { + public validateExperiment_argsTupleScheme getScheme() { + return new validateExperiment_argsTupleScheme(); + } +