http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/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 a2424c4..f23a761 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 @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class Airavata { public interface Iface { @@ -98,6 +98,22 @@ public class Airavata { public String addGateway(org.apache.airavata.model.security.AuthzToken authzToken, 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.airavata.model.error.AuthorizationException, org.apache.thrift.TException; /** + * Get all users in the gateway + * + * @param gatewayId + * The gateway data model. + * + * @return users + * list of usernames of the users in the gateway + * + * + * + * @param authzToken + * @param gatewayId + */ + public List<String> getAllUsersInGateway(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; + + /** * Update previously registered Gateway metadata. * * @param gatewayId @@ -2695,6 +2711,8 @@ public class Airavata { public void addGateway(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.airavata.model.workspace.Gateway gateway, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getAllUsersInGateway(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void updateGateway(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.airavata.model.workspace.Gateway updatedGateway, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getGateway(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -3111,6 +3129,42 @@ public class Airavata { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addGateway failed: unknown result"); } + public List<String> getAllUsersInGateway(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 + { + send_getAllUsersInGateway(authzToken, gatewayId); + return recv_getAllUsersInGateway(); + } + + public void send_getAllUsersInGateway(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId) throws org.apache.thrift.TException + { + getAllUsersInGateway_args args = new getAllUsersInGateway_args(); + args.setAuthzToken(authzToken); + args.setGatewayId(gatewayId); + sendBase("getAllUsersInGateway", args); + } + + public List<String> recv_getAllUsersInGateway() 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 + { + getAllUsersInGateway_result result = new getAllUsersInGateway_result(); + receiveBase(result, "getAllUsersInGateway"); + 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, "getAllUsersInGateway failed: unknown result"); + } + public void updateGateway(org.apache.airavata.model.security.AuthzToken authzToken, 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.airavata.model.error.AuthorizationException, org.apache.thrift.TException { send_updateGateway(authzToken, gatewayId, updatedGateway); @@ -8485,6 +8539,41 @@ public class Airavata { } } + public void getAllUsersInGateway(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getAllUsersInGateway_call method_call = new getAllUsersInGateway_call(authzToken, gatewayId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getAllUsersInGateway_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.airavata.model.security.AuthzToken authzToken; + private String gatewayId; + public getAllUsersInGateway_call(org.apache.airavata.model.security.AuthzToken authzToken, 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.authzToken = authzToken; + 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("getAllUsersInGateway", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getAllUsersInGateway_args args = new getAllUsersInGateway_args(); + args.setAuthzToken(authzToken); + args.setGatewayId(gatewayId); + args.write(prot); + prot.writeMessageEnd(); + } + + public List<String> 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_getAllUsersInGateway(); + } + } + public void updateGateway(org.apache.airavata.model.security.AuthzToken authzToken, 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(authzToken, gatewayId, updatedGateway, resultHandler, this, ___protocolFactory, ___transport); @@ -13869,6 +13958,7 @@ public class Airavata { processMap.put("getAPIVersion", new getAPIVersion()); processMap.put("isUserExists", new isUserExists()); processMap.put("addGateway", new addGateway()); + processMap.put("getAllUsersInGateway", new getAllUsersInGateway()); processMap.put("updateGateway", new updateGateway()); processMap.put("getGateway", new getGateway()); processMap.put("deleteGateway", new deleteGateway()); @@ -14106,6 +14196,36 @@ public class Airavata { } } + public static class getAllUsersInGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllUsersInGateway_args> { + public getAllUsersInGateway() { + super("getAllUsersInGateway"); + } + + public getAllUsersInGateway_args getEmptyArgsInstance() { + return new getAllUsersInGateway_args(); + } + + protected boolean isOneway() { + return false; + } + + public getAllUsersInGateway_result getResult(I iface, getAllUsersInGateway_args args) throws org.apache.thrift.TException { + getAllUsersInGateway_result result = new getAllUsersInGateway_result(); + try { + result.success = iface.getAllUsersInGateway(args.authzToken, 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; + } catch (org.apache.airavata.model.error.AuthorizationException ae) { + result.ae = ae; + } + return result; + } + } + public static class updateGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateGateway_args> { public updateGateway() { super("updateGateway"); @@ -18463,6 +18583,7 @@ public class Airavata { processMap.put("getAPIVersion", new getAPIVersion()); processMap.put("isUserExists", new isUserExists()); processMap.put("addGateway", new addGateway()); + processMap.put("getAllUsersInGateway", new getAllUsersInGateway()); processMap.put("updateGateway", new updateGateway()); processMap.put("getGateway", new getGateway()); processMap.put("deleteGateway", new deleteGateway()); @@ -18826,91 +18947,20 @@ public class Airavata { } } - public static class updateGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGateway_args, Void> { - public updateGateway() { - super("updateGateway"); + public static class getAllUsersInGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUsersInGateway_args, List<String>> { + public getAllUsersInGateway() { + super("getAllUsersInGateway"); } - public updateGateway_args getEmptyArgsInstance() { - return new updateGateway_args(); + public getAllUsersInGateway_args getEmptyArgsInstance() { + return new getAllUsersInGateway_args(); } - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - updateGateway_result result = new updateGateway_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; - 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); - 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, updateGateway_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.updateGateway(args.authzToken, args.gatewayId, args.updatedGateway,resultHandler); - } - } - - public static class getGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getGateway_args, org.apache.airavata.model.workspace.Gateway> { - public getGateway() { - super("getGateway"); - } - - public getGateway_args getEmptyArgsInstance() { - return new getGateway_args(); - } - - public AsyncMethodCallback<org.apache.airavata.model.workspace.Gateway> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.workspace.Gateway>() { - public void onComplete(org.apache.airavata.model.workspace.Gateway o) { - getGateway_result result = new getGateway_result(); + return new AsyncMethodCallback<List<String>>() { + public void onComplete(List<String> o) { + getAllUsersInGateway_result result = new getAllUsersInGateway_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -18923,7 +18973,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getGateway_result result = new getGateway_result(); + getAllUsersInGateway_result result = new getAllUsersInGateway_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -18964,27 +19014,25 @@ public class Airavata { return false; } - public void start(I iface, getGateway_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Gateway> resultHandler) throws TException { - iface.getGateway(args.authzToken, args.gatewayId,resultHandler); + public void start(I iface, getAllUsersInGateway_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { + iface.getAllUsersInGateway(args.authzToken, args.gatewayId,resultHandler); } } - public static class deleteGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteGateway_args, Boolean> { - public deleteGateway() { - super("deleteGateway"); + public static class updateGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateGateway_args, Void> { + public updateGateway() { + super("updateGateway"); } - public deleteGateway_args getEmptyArgsInstance() { - return new deleteGateway_args(); + public updateGateway_args getEmptyArgsInstance() { + return new updateGateway_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - deleteGateway_result result = new deleteGateway_result(); - result.success = o; - result.setSuccessIsSet(true); + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateGateway_result result = new updateGateway_result(); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -18996,7 +19044,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteGateway_result result = new deleteGateway_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); @@ -19037,25 +19085,25 @@ public class Airavata { return false; } - public void start(I iface, deleteGateway_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteGateway(args.authzToken, args.gatewayId,resultHandler); + public void start(I iface, updateGateway_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateGateway(args.authzToken, args.gatewayId, args.updatedGateway,resultHandler); } } - public static class getAllGateways<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGateways_args, List<org.apache.airavata.model.workspace.Gateway>> { - public getAllGateways() { - super("getAllGateways"); + public static class getGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getGateway_args, org.apache.airavata.model.workspace.Gateway> { + public getGateway() { + super("getGateway"); } - public getAllGateways_args getEmptyArgsInstance() { - return new getAllGateways_args(); + public getGateway_args getEmptyArgsInstance() { + return new getGateway_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Gateway>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.workspace.Gateway> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Gateway>>() { - public void onComplete(List<org.apache.airavata.model.workspace.Gateway> o) { - getAllGateways_result result = new getAllGateways_result(); + return new AsyncMethodCallback<org.apache.airavata.model.workspace.Gateway>() { + public void onComplete(org.apache.airavata.model.workspace.Gateway o) { + getGateway_result result = new getGateway_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19068,7 +19116,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllGateways_result result = new getAllGateways_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); @@ -19109,25 +19157,25 @@ public class Airavata { return false; } - public void start(I iface, getAllGateways_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Gateway>> resultHandler) throws TException { - iface.getAllGateways(args.authzToken,resultHandler); + public void start(I iface, getGateway_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Gateway> resultHandler) throws TException { + iface.getGateway(args.authzToken, args.gatewayId,resultHandler); } } - public static class isGatewayExist<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isGatewayExist_args, Boolean> { - public isGatewayExist() { - super("isGatewayExist"); + public static class deleteGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteGateway_args, Boolean> { + public deleteGateway() { + super("deleteGateway"); } - public isGatewayExist_args getEmptyArgsInstance() { - return new isGatewayExist_args(); + public deleteGateway_args getEmptyArgsInstance() { + return new deleteGateway_args(); } public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Boolean>() { public void onComplete(Boolean o) { - isGatewayExist_result result = new isGatewayExist_result(); + deleteGateway_result result = new deleteGateway_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -19141,7 +19189,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - isGatewayExist_result result = new isGatewayExist_result(); + 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); @@ -19182,25 +19230,25 @@ public class Airavata { return false; } - public void start(I iface, isGatewayExist_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.isGatewayExist(args.authzToken, args.gatewayId,resultHandler); + public void start(I iface, deleteGateway_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteGateway(args.authzToken, args.gatewayId,resultHandler); } } - public static class createNotification<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createNotification_args, String> { - public createNotification() { - super("createNotification"); + public static class getAllGateways<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGateways_args, List<org.apache.airavata.model.workspace.Gateway>> { + public getAllGateways() { + super("getAllGateways"); } - public createNotification_args getEmptyArgsInstance() { - return new createNotification_args(); + public getAllGateways_args getEmptyArgsInstance() { + return new getAllGateways_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Gateway>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - createNotification_result result = new createNotification_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Gateway>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Gateway> o) { + getAllGateways_result result = new getAllGateways_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19213,7 +19261,152 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - createNotification_result result = new createNotification_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); + 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, getAllGateways_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Gateway>> resultHandler) throws TException { + iface.getAllGateways(args.authzToken,resultHandler); + } + } + + public static class isGatewayExist<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isGatewayExist_args, Boolean> { + public isGatewayExist() { + super("isGatewayExist"); + } + + public isGatewayExist_args getEmptyArgsInstance() { + return new isGatewayExist_args(); + } + + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + 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; + } 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; + 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); + 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, isGatewayExist_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.isGatewayExist(args.authzToken, args.gatewayId,resultHandler); + } + } + + public static class createNotification<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createNotification_args, String> { + public createNotification() { + super("createNotification"); + } + + public createNotification_args getEmptyArgsInstance() { + return new createNotification_args(); + } + + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + createNotification_result result = new createNotification_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; + createNotification_result result = new createNotification_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32927,28 +33120,25 @@ public class Airavata { } - public static class updateGateway_args implements org.apache.thrift.TBase<updateGateway_args, updateGateway_args._Fields>, java.io.Serializable, Cloneable, Comparable<updateGateway_args> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("updateGateway_args"); + public static class getAllUsersInGateway_args implements org.apache.thrift.TBase<getAllUsersInGateway_args, getAllUsersInGateway_args._Fields>, java.io.Serializable, Cloneable, Comparable<getAllUsersInGateway_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getAllUsersInGateway_args"); private static final org.apache.thrift.protocol.TField AUTHZ_TOKEN_FIELD_DESC = new org.apache.thrift.protocol.TField("authzToken", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final org.apache.thrift.protocol.TField GATEWAY_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("gatewayId", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField UPDATED_GATEWAY_FIELD_DESC = new org.apache.thrift.protocol.TField("updatedGateway", org.apache.thrift.protocol.TType.STRUCT, (short)3); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new updateGateway_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new updateGateway_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getAllUsersInGateway_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getAllUsersInGateway_argsTupleSchemeFactory()); } public org.apache.airavata.model.security.AuthzToken authzToken; // required public String gatewayId; // required - public org.apache.airavata.model.workspace.Gateway updatedGateway; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { AUTHZ_TOKEN((short)1, "authzToken"), - GATEWAY_ID((short)2, "gatewayId"), - UPDATED_GATEWAY((short)3, "updatedGateway"); + GATEWAY_ID((short)2, "gatewayId"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -32967,8 +33157,6 @@ public class Airavata { return AUTHZ_TOKEN; case 2: // GATEWAY_ID return GATEWAY_ID; - case 3: // UPDATED_GATEWAY - return UPDATED_GATEWAY; default: return null; } @@ -33016,57 +33204,49 @@ public class Airavata { new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.security.AuthzToken.class))); tmpMap.put(_Fields.GATEWAY_ID, new org.apache.thrift.meta_data.FieldMetaData("gatewayId", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.UPDATED_GATEWAY, new org.apache.thrift.meta_data.FieldMetaData("updatedGateway", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.workspace.Gateway.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(updateGateway_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getAllUsersInGateway_args.class, metaDataMap); } - public updateGateway_args() { + public getAllUsersInGateway_args() { } - public updateGateway_args( + public getAllUsersInGateway_args( org.apache.airavata.model.security.AuthzToken authzToken, - String gatewayId, - org.apache.airavata.model.workspace.Gateway updatedGateway) + String gatewayId) { this(); this.authzToken = authzToken; this.gatewayId = gatewayId; - this.updatedGateway = updatedGateway; } /** * Performs a deep copy on <i>other</i>. */ - public updateGateway_args(updateGateway_args other) { + public getAllUsersInGateway_args(getAllUsersInGateway_args other) { if (other.isSetAuthzToken()) { this.authzToken = new org.apache.airavata.model.security.AuthzToken(other.authzToken); } if (other.isSetGatewayId()) { this.gatewayId = other.gatewayId; } - if (other.isSetUpdatedGateway()) { - this.updatedGateway = new org.apache.airavata.model.workspace.Gateway(other.updatedGateway); - } } - public updateGateway_args deepCopy() { - return new updateGateway_args(this); + public getAllUsersInGateway_args deepCopy() { + return new getAllUsersInGateway_args(this); } @Override public void clear() { this.authzToken = null; this.gatewayId = null; - this.updatedGateway = null; } public org.apache.airavata.model.security.AuthzToken getAuthzToken() { return this.authzToken; } - public updateGateway_args setAuthzToken(org.apache.airavata.model.security.AuthzToken authzToken) { + public getAllUsersInGateway_args setAuthzToken(org.apache.airavata.model.security.AuthzToken authzToken) { this.authzToken = authzToken; return this; } @@ -33090,7 +33270,7 @@ public class Airavata { return this.gatewayId; } - public updateGateway_args setGatewayId(String gatewayId) { + public getAllUsersInGateway_args setGatewayId(String gatewayId) { this.gatewayId = gatewayId; return this; } @@ -33110,30 +33290,6 @@ public class Airavata { } } - public org.apache.airavata.model.workspace.Gateway getUpdatedGateway() { - return this.updatedGateway; - } - - public updateGateway_args setUpdatedGateway(org.apache.airavata.model.workspace.Gateway updatedGateway) { - this.updatedGateway = updatedGateway; - return this; - } - - public void unsetUpdatedGateway() { - this.updatedGateway = null; - } - - /** Returns true if field updatedGateway is set (has been assigned a value) and false otherwise */ - public boolean isSetUpdatedGateway() { - return this.updatedGateway != null; - } - - public void setUpdatedGatewayIsSet(boolean value) { - if (!value) { - this.updatedGateway = null; - } - } - public void setFieldValue(_Fields field, Object value) { switch (field) { case AUTHZ_TOKEN: @@ -33152,14 +33308,6 @@ public class Airavata { } break; - case UPDATED_GATEWAY: - if (value == null) { - unsetUpdatedGateway(); - } else { - setUpdatedGateway((org.apache.airavata.model.workspace.Gateway)value); - } - break; - } } @@ -33171,9 +33319,6 @@ public class Airavata { case GATEWAY_ID: return getGatewayId(); - case UPDATED_GATEWAY: - return getUpdatedGateway(); - } throw new IllegalStateException(); } @@ -33189,8 +33334,6 @@ public class Airavata { return isSetAuthzToken(); case GATEWAY_ID: return isSetGatewayId(); - case UPDATED_GATEWAY: - return isSetUpdatedGateway(); } throw new IllegalStateException(); } @@ -33199,12 +33342,12 @@ public class Airavata { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof updateGateway_args) - return this.equals((updateGateway_args)that); + if (that instanceof getAllUsersInGateway_args) + return this.equals((getAllUsersInGateway_args)that); return false; } - public boolean equals(updateGateway_args that) { + public boolean equals(getAllUsersInGateway_args that) { if (that == null) return false; @@ -33226,15 +33369,6 @@ public class Airavata { return false; } - boolean this_present_updatedGateway = true && this.isSetUpdatedGateway(); - boolean that_present_updatedGateway = true && that.isSetUpdatedGateway(); - if (this_present_updatedGateway || that_present_updatedGateway) { - if (!(this_present_updatedGateway && that_present_updatedGateway)) - return false; - if (!this.updatedGateway.equals(that.updatedGateway)) - return false; - } - return true; } @@ -33252,16 +33386,11 @@ public class Airavata { if (present_gatewayId) list.add(gatewayId); - boolean present_updatedGateway = true && (isSetUpdatedGateway()); - list.add(present_updatedGateway); - if (present_updatedGateway) - list.add(updatedGateway); - return list.hashCode(); } @Override - public int compareTo(updateGateway_args other) { + public int compareTo(getAllUsersInGateway_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -33288,16 +33417,6 @@ public class Airavata { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetUpdatedGateway()).compareTo(other.isSetUpdatedGateway()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetUpdatedGateway()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.updatedGateway, other.updatedGateway); - if (lastComparison != 0) { - return lastComparison; - } - } return 0; } @@ -33315,7 +33434,7 @@ public class Airavata { @Override public String toString() { - StringBuilder sb = new StringBuilder("updateGateway_args("); + StringBuilder sb = new StringBuilder("getAllUsersInGateway_args("); boolean first = true; sb.append("authzToken:"); @@ -33333,14 +33452,6 @@ public class Airavata { sb.append(this.gatewayId); } first = false; - if (!first) sb.append(", "); - sb.append("updatedGateway:"); - if (this.updatedGateway == null) { - sb.append("null"); - } else { - sb.append(this.updatedGateway); - } - first = false; sb.append(")"); return sb.toString(); } @@ -33353,16 +33464,10 @@ public class Airavata { if (gatewayId == null) { throw new org.apache.thrift.protocol.TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); } - if (updatedGateway == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'updatedGateway' was not present! Struct: " + toString()); - } // check for sub-struct validity if (authzToken != null) { authzToken.validate(); } - if (updatedGateway != null) { - updatedGateway.validate(); - } } private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { @@ -33381,15 +33486,15 @@ public class Airavata { } } - private static class updateGateway_argsStandardSchemeFactory implements SchemeFactory { - public updateGateway_argsStandardScheme getScheme() { - return new updateGateway_argsStandardScheme(); + private static class getAllUsersInGateway_argsStandardSchemeFactory implements SchemeFactory { + public getAllUsersInGateway_argsStandardScheme getScheme() { + return new getAllUsersInGateway_argsStandardScheme(); } } - private static class updateGateway_argsStandardScheme extends StandardScheme<updateGateway_args> { + private static class getAllUsersInGateway_argsStandardScheme extends StandardScheme<getAllUsersInGateway_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, updateGateway_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getAllUsersInGateway_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -33416,15 +33521,6 @@ public class Airavata { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; - case 3: // UPDATED_GATEWAY - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.updatedGateway = new org.apache.airavata.model.workspace.Gateway(); - struct.updatedGateway.read(iprot); - struct.setUpdatedGatewayIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -33436,7 +33532,7 @@ public class Airavata { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, updateGateway_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getAllUsersInGateway_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -33450,52 +33546,44 @@ public class Airavata { oprot.writeString(struct.gatewayId); oprot.writeFieldEnd(); } - if (struct.updatedGateway != null) { - oprot.writeFieldBegin(UPDATED_GATEWAY_FIELD_DESC); - struct.updatedGateway.write(oprot); - oprot.writeFieldEnd(); - } oprot.writeFieldStop(); oprot.writeStructEnd(); } } - private static class updateGateway_argsTupleSchemeFactory implements SchemeFactory { - public updateGateway_argsTupleScheme getScheme() { - return new updateGateway_argsTupleScheme(); + private static class getAllUsersInGateway_argsTupleSchemeFactory implements SchemeFactory { + public getAllUsersInGateway_argsTupleScheme getScheme() { + return new getAllUsersInGateway_argsTupleScheme(); } } - private static class updateGateway_argsTupleScheme extends TupleScheme<updateGateway_args> { + private static class getAllUsersInGateway_argsTupleScheme extends TupleScheme<getAllUsersInGateway_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, updateGateway_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getAllUsersInGateway_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; struct.authzToken.write(oprot); oprot.writeString(struct.gatewayId); - struct.updatedGateway.write(oprot); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, updateGateway_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getAllUsersInGateway_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.authzToken = new org.apache.airavata.model.security.AuthzToken(); struct.authzToken.read(iprot); struct.setAuthzTokenIsSet(true); struct.gatewayId = iprot.readString(); struct.setGatewayIdIsSet(true); - struct.updatedGateway = new org.apache.airavata.model.workspace.Gateway(); - struct.updatedGateway.read(iprot); - struct.setUpdatedGatewayIsSet(true); } } } - public static class updateGateway_result implements org.apache.thrift.TBase<updateGateway_result, updateGateway_result._Fields>, java.io.Serializable, Cloneable, Comparable<updateGateway_result> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("updateGateway_result"); + public static class getAllUsersInGateway_result implements org.apache.thrift.TBase<getAllUsersInGateway_result, getAllUsersInGateway_result._Fields>, java.io.Serializable, Cloneable, Comparable<getAllUsersInGateway_result> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getAllUsersInGateway_result"); + private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0); private static final org.apache.thrift.protocol.TField IRE_FIELD_DESC = new org.apache.thrift.protocol.TField("ire", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final org.apache.thrift.protocol.TField ACE_FIELD_DESC = new org.apache.thrift.protocol.TField("ace", org.apache.thrift.protocol.TType.STRUCT, (short)2); private static final org.apache.thrift.protocol.TField ASE_FIELD_DESC = new org.apache.thrift.protocol.TField("ase", org.apache.thrift.protocol.TType.STRUCT, (short)3); @@ -33503,10 +33591,11 @@ public class Airavata { private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new updateGateway_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new updateGateway_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new getAllUsersInGateway_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new getAllUsersInGateway_resultTupleSchemeFactory()); } + public List<String> success; // required public org.apache.airavata.model.error.InvalidRequestException ire; // required public org.apache.airavata.model.error.AiravataClientException ace; // required public org.apache.airavata.model.error.AiravataSystemException ase; // required @@ -33514,6 +33603,7 @@ public class Airavata { /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { + SUCCESS((short)0, "success"), IRE((short)1, "ire"), ACE((short)2, "ace"), ASE((short)3, "ase"), @@ -33532,6 +33622,8 @@ public class Airavata { */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { + case 0: // SUCCESS + return SUCCESS; case 1: // IRE return IRE; case 2: // ACE @@ -33583,6 +33675,9 @@ public class Airavata { public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); tmpMap.put(_Fields.ACE, new org.apache.thrift.meta_data.FieldMetaData("ace", org.apache.thrift.TFieldRequirementType.DEFAULT, @@ -33592,19 +33687,21 @@ public class Airavata { tmpMap.put(_Fields.AE, new org.apache.thrift.meta_data.FieldMetaData("ae", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(updateGateway_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getAllUsersInGateway_result.class, metaDataMap); } - public updateGateway_result() { + public getAllUsersInGateway_result() { } - public updateGateway_result( + public getAllUsersInGateway_result( + List<String> success, org.apache.airavata.model.error.InvalidRequestException ire, org.apache.airavata.model.error.AiravataClientException ace, org.apache.airavata.model.error.AiravataSystemException ase, org.apache.airavata.model.error.AuthorizationException ae) { this(); + this.success = success; this.ire = ire; this.ace = ace; this.ase = ase; @@ -33614,7 +33711,11 @@ public class Airavata { /** * Performs a deep copy on <i>other</i>. */ - public updateGateway_result(updateGateway_result other) { + public getAllUsersInGateway_result(getAllUsersInGateway_result other) { + if (other.isSetSuccess()) { + List<String> __this__success = new ArrayList<String>(other.success); + this.success = __this__success; + } if (other.isSetIre()) { this.ire = new org.apache.airavata.model.error.InvalidRequestException(other.ire); } @@ -33629,23 +33730,63 @@ public class Airavata { } } - public updateGateway_result deepCopy() { - return new updateGateway_result(this); + public getAllUsersInGateway_result deepCopy() { + return new getAllUsersInGateway_result(this); } @Override public void clear() { + this.success = null; this.ire = null; this.ace = null; this.ase = null; this.ae = null; } + public int getSuccessSize() { + return (this.success == null) ? 0 : this.success.size(); + } + + public java.util.Iterator<String> getSuccessIterator() { + return (this.success == null) ? null : this.success.iterator(); + } + + public void addToSuccess(String elem) { + if (this.success == null) { + this.success = new ArrayList<String>(); + } + this.success.add(elem); + } + + public List<String> getSuccess() { + return this.success; + } + + public getAllUsersInGateway_result setSuccess(List<String> success) { + this.success = success; + return this; + } + + public void unsetSuccess() { + this.success = null; + } + + /** Returns true if field success is set (has been assigned a value) and false otherwise */ + public boolean isSetSuccess() { + return this.success != null; + } + + public void setSuccessIsSet(boolean value) { + if (!value) { + this.success = null; + } + } + public org.apache.airavata.model.error.InvalidRequestException getIre() { return this.ire; } - public updateGateway_result setIre(org.apache.airavata.model.error.InvalidRequestException ire) { + public getAllUsersInGateway_result setIre(org.apache.airavata.model.error.InvalidRequestException ire) { this.ire = ire; return this; } @@ -33669,7 +33810,7 @@ public class Airavata { return this.ace; } - public updateGateway_result setAce(org.apache.airavata.model.error.AiravataClientException ace) { + public getAllUsersInGateway_result setAce(org.apache.airavata.model.error.AiravataClientException ace) { this.ace = ace; return this; } @@ -33693,7 +33834,7 @@ public class Airavata { return this.ase; } - public updateGateway_result setAse(org.apache.airavata.model.error.AiravataSystemException ase) { + public getAllUsersInGateway_result setAse(org.apache.airavata.model.error.AiravataSystemException ase) { this.ase = ase; return this; } @@ -33717,7 +33858,7 @@ public class Airavata { return this.ae; } - public updateGateway_result setAe(org.apache.airavata.model.error.AuthorizationException ae) { + public getAllUsersInGateway_result setAe(org.apache.airavata.model.error.AuthorizationException ae) { this.ae = ae; return this; } @@ -33739,6 +33880,14 @@ public class Airavata { public void setFieldValue(_Fields field, Object value) { switch (field) { + case SUCCESS: + if (value == null) { + unsetSuccess(); + } else { + setSuccess((List<String>)value); + } + break; + case IRE: if (value == null) { unsetIre(); @@ -33776,6 +33925,9 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { + case SUCCESS: + return getSuccess(); + case IRE: return getIre(); @@ -33799,6 +33951,8 @@ public class Airavata { } switch (field) { + case SUCCESS: + return isSetSuccess(); case IRE: return isSetIre(); case ACE: @@ -33815,15 +33969,24 @@ public class Airavata { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof updateGateway_result) - return this.equals((updateGateway_result)that); + if (that instanceof getAllUsersInGateway_result) + return this.equals((getAllUsersInGateway_result)that); return false; } - public boolean equals(updateGateway_result that) { + public boolean equals(getAllUsersInGateway_result that) { if (that == null) return false; + boolean this_present_success = true && this.isSetSuccess(); + boolean that_present_success = true && that.isSetSuccess(); + if (this_present_success || that_present_success) { + if (!(this_present_success && that_present_success)) + return false; + if (!this.success.equals(that.success)) + return false; + } + boolean this_present_ire = true && this.isSetIre(); boolean that_present_ire = true && that.isSetIre(); if (this_present_ire || that_present_ire) { @@ -33867,6 +34030,11 @@ public class Airavata { public int hashCode() { List<Object> list = new ArrayList<Object>(); + boolean present_success = true && (isSetSuccess()); + list.add(present_success); + if (present_success) + list.add(success); + boolean present_ire = true && (isSetIre()); list.add(present_ire); if (present_ire) @@ -33891,13 +34059,23 @@ public class Airavata { } @Override - public int compareTo(updateGateway_result other) { + public int compareTo(getAllUsersInGateway_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; + lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSuccess()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); + if (lastComparison != 0) { + return lastComparison; + } + } lastComparison = Boolean.valueOf(isSetIre()).compareTo(other.isSetIre()); if (lastComparison != 0) { return lastComparison; @@ -33955,9 +34133,17 @@ public class Airavata { @Override public String toString() { - StringBuilder sb = new StringBuilder("updateGateway_result("); + StringBuilder sb = new StringBuilder("getAllUsersInGateway_result("); boolean first = true; + sb.append("success:"); + if (this.success == null) { + sb.append("null"); + } else { + sb.append(this.success); + } + first = false; + if (!first) sb.append(", "); sb.append("ire:"); if (this.ire == null) { sb.append("null"); @@ -34014,15 +34200,15 @@ public class Airavata { } } - private static class updateGateway_resultStandardSchemeFactory implements SchemeFactory { - public updateGateway_resultStandardScheme getScheme() { - return new updateGateway_resultStandardScheme(); + private static class getAllUsersInGateway_resultStandardSchemeFactory implements SchemeFactory { + public getAllUsersInGateway_resultStandardScheme getScheme() { + return new getAllUsersInGateway_resultStandardScheme(); } } - private static class updateGateway_resultStandardScheme extends StandardScheme<updateGateway_result> { + private static class getAllUsersInGateway_resultStandardScheme extends StandardScheme<getAllUsersInGateway_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, updateGateway_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getAllUsersInGateway_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -34032,6 +34218,24 @@ public class Airavata { break; } switch (schemeField.id) { + case 0: // SUCCESS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list0 = iprot.readListBegin(); + struct.success = new ArrayList<String>(_list0.size); + String _elem1; + for (int _i2 = 0; _i2 < _list0.size; ++_i2) + { + _elem1 = iprot.readString(); + struct.success.add(_elem1); + } + iprot.readListEnd(); + } + struct.setSuccessIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; case 1: // IRE if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { struct.ire = new org.apache.airavata.model.error.InvalidRequestException(); @@ -34079,10 +34283,22 @@ public class Airavata { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, updateGateway_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getAllUsersInGateway_result struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); + if (struct.success != null) { + oprot.writeFieldBegin(SUCCESS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size())); + for (String _iter3 : struct.success) + { + oprot.writeString(_iter3); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } if (struct.ire != null) { oprot.writeFieldBegin(IRE_FIELD_DESC); struct.ire.write(oprot); @@ -34109,31 +34325,43 @@ public class Airavata { } - private static class updateGateway_resultTupleSchemeFactory implements SchemeFactory { - public updateGateway_resultTupleScheme getScheme() { - return new updateGateway_resultTupleScheme(); + private static class getAllUsersInGateway_resultTupleSchemeFactory implements SchemeFactory { + public getAllUsersInGateway_resultTupleScheme getScheme() { + return new getAllUsersInGateway_resultTupleScheme(); } } - private static class updateGateway_resultTupleScheme extends TupleScheme<updateGateway_result> { + private static class getAllUsersInGateway_resultTupleScheme extends TupleScheme<getAllUsersInGateway_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, updateGateway_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getAllUsersInGateway_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); - if (struct.isSetIre()) { + if (struct.isSetSuccess()) { optionals.set(0); } - if (struct.isSetAce()) { + if (struct.isSetIre()) { optionals.set(1); } - if (struct.isSetAse()) { + if (struct.isSetAce()) { optionals.set(2); } - if (struct.isSetAe()) { + if (struct.isSetAse()) { optionals.set(3); } - oprot.writeBitSet(optionals, 4); + if (struct.isSetAe()) { + optionals.set(4); + } + oprot.writeBitSet(optionals, 5); + if (struct.isSetSuccess()) { + { + oprot.writeI32(struct.success.size()); + for (String _iter4 : struct.success) + { + oprot.writeString(_iter4); + } + } + } if (struct.isSetIre()) { struct.ire.write(oprot); } @@ -34149,25 +34377,38 @@ public class Airavata { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, updateGateway_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getAllUsersInGateway_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(4); + BitSet incoming = iprot.readBitSet(5); if (incoming.get(0)) { + { + org.apache.thrift.protocol.TList _list5 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.success = new ArrayList<String>(_list5.size); + String _elem6; + for (int _i7 = 0; _i7 < _list5.size; ++_i7) + { + _elem6 = iprot.readString(); + struct.success.add(_elem6); + } + } + struct.setSuccessIsSet(true); + } + if (incoming.get(1)) { struct.ire = new org.apache.airavata.model.error.InvalidRequestException(); struct.ire.read(iprot); struct.setIreIsSet(true); } - if (incoming.get(1)) { + if (incoming.get(2)) { struct.ace = new org.apache.airavata.model.error.AiravataClientException(); struct.ace.read(iprot); struct.setAceIsSet(true); } - if (incoming.get(2)) { + if (incoming.get(3)) { struct.ase = new org.apache.airavata.model.error.AiravataSystemException(); struct.ase.read(iprot); struct.setAseIsSet(true); } - if (incoming.get(3)) { + if (incoming.get(4)) { struct.ae = new org.apache.airavata.model.error.AuthorizationException(); struct.ae.read(iprot); struct.setAeIsSet(true); @@ -34177,25 +34418,28 @@ public class Airavata { } - public static class getGateway_args implements org.apache.thrift.TBase<getGateway_args, getGateway_args._Fields>, java.io.Serializable, Cloneable, Comparable<getGateway_args> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getGateway_args"); + public static class updateGateway_args implements org.apache.thrift.TBase<updateGateway_args, updateGateway_args._Fields>, java.io.Serializable, Cloneable, Comparable<updateGateway_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("updateGateway_args"); private static final org.apache.thrift.protocol.TField AUTHZ_TOKEN_FIELD_DESC = new org.apache.thrift.protocol.TField("authzToken", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final org.apache.thrift.protocol.TField GATEWAY_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("gatewayId", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField UPDATED_GATEWAY_FIELD_DESC = new org.apache.thrift.protocol.TField("updatedGateway", org.apache.thrift.protocol.TType.STRUCT, (short)3); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getGateway_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getGateway_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new updateGateway_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new updateGateway_argsTupleSchemeFactory()); } public org.apache.airavata.model.security.AuthzToken authzToken; // required public String gatewayId; // required + public org.apache.airavata.model.workspace.Gateway updatedGateway; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { AUTHZ_TOKEN((short)1, "authzToken"), - GATEWAY_ID((short)2, "gatewayId"); + GATEWAY_ID((short)2, "gatewayId"), + UPDATED_GATEWAY((short)3, "updatedGateway"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -34214,6 +34458,8 @@ public class Airavata { return AUTHZ_TOKEN; case 2: // GATEWAY_ID return GATEWAY_ID; + case 3: // UPDATED_GATEWAY + return UPDATED_GATEWAY; default: return null; } @@ -34261,49 +34507,57 @@ public class Airavata { new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.security.AuthzToken.class))); tmpMap.put(_Fields.GATEWAY_ID, new org.apache.thrift.meta_data.FieldMetaData("gatewayId", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.UPDATED_GATEWAY, new org.apache.thrift.meta_data.FieldMetaData("updatedGateway", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.workspace.Gateway.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getGateway_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(updateGateway_args.class, metaDataMap); } - public getGateway_args() { + public updateGateway_args() { } - public getGateway_args( + public updateGateway_args( org.apache.airavata.model.security.AuthzToken authzToken, - String gatewayId) + String gatewayId, + org.apache.airavata.model.workspace.Gateway updatedGateway) { this(); this.authzToken = authzToken; this.gatewayId = gatewayId; + this.updatedGateway = updatedGateway; } /** * Performs a deep copy on <i>other</i>. */ - public getGateway_args(getGateway_args other) { + public updateGateway_args(updateGateway_args other) { if (other.isSetAuthzToken()) { this.authzToken = new org.apache.airavata.model.security.AuthzToken(other.authzToken); } if (other.isSetGatewayId()) { this.gatewayId = other.gatewayId; } + if (other.isSetUpdatedGateway()) { + this.updatedGateway = new org.apache.airavata.model.workspace.Gateway(other.updatedGateway); + } } - public getGateway_args deepCopy() { - return new getGateway_args(this); + public updateGateway_args deepCopy() { + return new updateGateway_args(this); } @Override public void clear() { this.authzToken = null; this.gatewayId = null; + this.updatedGateway = null; } public org.apache.airavata.model.security.AuthzToken getAuthzToken() { return this.authzToken; } - public getGateway_args setAuthzToken(org.apache.airavata.model.security.AuthzToken authzToken) { + public updateGateway_args setAuthzToken(org.apache.airavata.model.security.AuthzToken authzToken) { this.authzToken = authzToken; return this; } @@ -34327,7 +34581,7 @@ public class Airavata { return this.gatewayId; } - public getGateway_args setGatewayId(String gatewayId) { + public updateGateway_args setGatewayId(String gatewayId) { this.gatewayId = gatewayId; return this; } @@ -34347,6 +34601,30 @@ public class Airavata { } } + public org.apache.airavata.model.workspace.Gateway getUpdatedGateway() { + return this.updatedGateway; + } + + public updateGateway_args setUpdatedGateway(org.apache.airavata.model.workspace.Gateway updatedGateway) { + this.updatedGateway = updatedGateway; + return this; + } + + public void unsetUpdatedGateway() { + this.updatedGateway = null; + } + + /** Returns true if field updatedGateway is set (has been assigned a value) and false otherwise */ + public boolean isSetUpdatedGateway() { + return this.updatedGateway != null; + } + + public void setUpdatedGatewayIsSet(boolean value) { + if (!value) { + this.updatedGateway = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case AUTHZ_TOKEN: @@ -34365,6 +34643,14 @@ public class Airavata { } break; + case UPDATED_GATEWAY: + if (value == null) { + unsetUpdatedGateway(); + } else { + setUpdatedGateway((org.apache.airavata.model.workspace.Gateway)value); + } + break; + } } @@ -34376,6 +34662,9 @@ public class Airavata { case GATEWAY_ID: return getGatewayId(); + case UPDATED_GATEWAY: + return getUpdatedGateway(); + } throw new IllegalStateException(); } @@ -34391,6 +34680,8 @@ public class Airavata { return isSetAuthzToken(); case GATEWAY_ID: return isSetGatewayId(); + case UPDATED_GATEWAY: + return isSetUpdatedGateway(); } throw new IllegalStateException(); } @@ -34399,12 +34690,12 @@ public class Airavata { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getGateway_args) - return this.equals((getGateway_args)that); + if (that instanceof updateGateway_args) + return this.equals((updateGateway_args)that); return false; } - public boolean equals(getGateway_args that) { + public boolean equals(updateGateway_args that) { if (that == null) return false; @@ -34426,6 +34717,15 @@ public class Airavata { return false; } + boolean this_present_updatedGateway = true && this.isSetUpdatedGateway(); + boolean that_present_updatedGateway = true && that.isSetUpdatedGateway(); + if (this_present_updatedGateway || that_present_updatedGateway) { + if (!(this_present_updatedGateway && that_present_updatedGateway)) + return false; + if (!this.updatedGateway.equals(that.updatedGateway)) + return false; + } + return true; } @@ -34443,11 +34743,16 @@ public class Airavata { if (present_gatewayId) list.add(gatewayId); + boolean present_updatedGateway = true && (isSetUpdatedGateway()); + list.add(present_updatedGateway); + if (present_updatedGateway) + list.add(updatedGateway); + return list.hashCode(); } @Override - public int compareTo(getGateway_args other) { + public int compareTo(updateGateway_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -34474,6 +34779,16 @@ public class Airavata { return lastComparison; } } + lastComparison = Boolean.valueOf(isSetUpdatedGateway()).compareTo(other.isSetUpdatedGateway()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetUpdatedGateway()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.updatedGateway, other.updatedGateway); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -34491,7 +34806,7 @@ public class Airavata { @Override public String toString() { - StringBuilder sb = new StringBuilder("getGateway_args("); + StringBuilder sb = new StringBuilder("updateGateway_args("); boolean first = true; sb.append("authzToken:"); @@ -34509,6 +34824,14 @@ public class Airavata { sb.append(this.gatewayId); } first = false; + if (!first) sb.append(", "); + sb.append("updatedGateway:"); + if (this.updatedGateway == null) { + sb.append("null"); + } else { + sb.append(this.updatedGateway); + } + first = false; sb.append(")"); return sb.toString(); } @@ -34521,10 +34844,16 @@ public class Airavata { if (gatewayId == null) { throw new org.apache.thrift.protocol.TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); } + if (updatedGateway == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'updatedGateway' was not present! Struct: " + toString()); + } // check for sub-struct validity if (authzToken != null) { authzToken.validate(); } + if (updatedGateway != null) { + updatedGateway.validate(); + } } private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { @@ -34543,15 +34872,15 @@ public class Airavata { } } - private static class getGateway_argsStandardSchemeFactory implements SchemeFactory { - public getGateway_argsStandardScheme getScheme() { - return new getGateway_argsStandardScheme(); + private static class updateGateway_argsStandardSchemeFactory implements SchemeFactory { + public updateGateway_argsStandardScheme getScheme() { + return new updateGateway_argsStandardScheme(); } } - private static class getGateway_argsStandardScheme extends StandardScheme<getGateway_args> { + private static class updateGateway_argsStandardScheme extends StandardScheme<updateGateway_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getGateway_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, updateGateway_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -34578,6 +34907,15 @@ public class Airavata { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 3: // UPDATED_GATEWAY + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.updatedGateway = new org.apache.airavata.model.workspace.Gateway(); + struct.updatedGateway.read(iprot); + struct.setUpdatedGatewayIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -34589,7 +34927,7 @@ public class Airavata { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getGateway_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, updateGateway_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -34603,44 +34941,52 @@ public class Airavata { oprot.writeString(struct.gatewayId); oprot.writeFieldEnd(); } + if (struct.updatedGateway != null) { + oprot.writeFieldBegin(UPDATED_GATEWAY_FIELD_DESC); + struct.updatedGateway.write(oprot); + oprot.writeFieldEnd(); + } oprot.writeFieldStop(); oprot.writeStructEnd(); } } - private static class getGateway_argsTupleSchemeFactory implements SchemeFactory { - public getGateway_argsTupleScheme getScheme() { - return new getGateway_argsTupleScheme(); + private static class updateGateway_argsTupleSchemeFactory implements SchemeFactory { + public updateGateway_argsTupleScheme getScheme() { + return new updateGateway_argsTupleScheme(); } } - private static class getGateway_argsTupleScheme extends TupleScheme<getGateway_args> { + private static class updateGateway_argsTupleScheme extends TupleScheme<updateGateway_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getGateway_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, updateGateway_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; struct.authzToken.write(oprot); oprot.writeString(struct.gatewayId); + struct.updatedGateway.write(oprot); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getGateway_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, updateGateway_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.authzToken = new org.apache.airavata.model.security.AuthzToken(); struct.authzToken.read(iprot); struct.setAuthzTokenIsSet(true); struct.gatewayId = iprot.readString(); struct.setGatewayIdIsSet(true); + struct.updatedGateway = new org.apache.airavata.model.workspace.Gateway(); + struct.updatedGateway.read(iprot); + struct.setUpdatedGatewayIsSet(true); } } } - public static class getGateway_result implements org.apache.thrift.TBase<getGateway_result, getGateway_result._Fields>, java.io.Serializable, Cloneable, Comparable<getGateway_result> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getGateway_result"); + public static class updateGateway_result implements org.apache.thrift.TBase<updateGateway_result, updateGateway_result._Fields>, java.io.Serializable, Cloneable, Comparable<updateGateway_result> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("updateGateway_result"); - private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); private static final org.apache.thrift.protocol.TField IRE_FIELD_DESC = new org.apache.thrift.protocol.TField("ire", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final org.apache.thrift.protocol.TField ACE_FIELD_DESC = new org.apache.thrift.protocol.TField("ace", org.apache.thrift.protocol.TType.STRUCT, (short)2); private static final org.apache.thrift.protocol.TField ASE_FIELD_DESC = new org.apache.thrift.protocol.TField("ase", org.apache.thrift.protocol.TType.STRUCT, (short)3); @@ -34648,11 +34994,10 @@ public class Airavata { private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getGateway_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getGateway_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new updateGateway_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new updateGateway_resultTupleSchemeFactory()); } - public org.apache.airavata.model.workspace.Gateway success; // required public org.apache.airavata.model.error.InvalidRequestException ire; // required public org.apache.airavata.model.error.AiravataClientException ace; // required public org.apache.airavata.model.error.AiravataSystemException ase; // required @@ -34660,7 +35005,6 @@ public class Airavata { /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { - SUCCESS((short)0, "success"), IRE((short)1, "ire"), ACE((short)2, "ace"), ASE((short)3, "ase"), @@ -34679,8 +35023,6 @@ public class Airavata { */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { - case 0: // SUCCESS - return SUCCESS; case 1: // IRE return IRE; case 2: // ACE @@ -34732,8 +35074,6 @@ public class Airavata { public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.workspace.Gateway.class))); tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); tmpMap.put(_Fields.ACE, new org.apache.thrift.meta_data.FieldMetaData(
<TRUNCATED>
