http://git-wip-us.apache.org/repos/asf/airavata/blob/e1013926/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 d395425..b638076 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 @@ -263,25 +263,6 @@ public class Airavata { /** * - * Get a Public Key by Providing the Token - * - * @param CredStoreToken - * Credential Store Token which you want to find the Public Key for. - * - * @param gatewayId - * This is the unique identifier of your gateway where the token and public key was generated from. - * - * @return SSHpubKey - * - * - * - * @param authzToken - * @param userName - */ - public Map<String,String> getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException; - - /** - * * Get all Public Keys of the Gateway * * @param CredStoreToken @@ -2739,8 +2720,6 @@ public class Airavata { public void getSSHPubKey(org.apache.airavata.model.security.AuthzToken authzToken, String airavataCredStoreToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void getAllGatewaySSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getAllGatewayPWDCredentials(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -3594,39 +3573,6 @@ public class Airavata { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSSHPubKey failed: unknown result"); } - public Map<String,String> getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException - { - send_getAllUserSSHPubKeys(authzToken, userName); - return recv_getAllUserSSHPubKeys(); - } - - public void send_getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName) throws org.apache.thrift.TException - { - getAllUserSSHPubKeys_args args = new getAllUserSSHPubKeys_args(); - args.setAuthzToken(authzToken); - args.setUserName(userName); - sendBase("getAllUserSSHPubKeys", args); - } - - public Map<String,String> recv_getAllUserSSHPubKeys() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException - { - getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result(); - receiveBase(result, "getAllUserSSHPubKeys"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.ire != null) { - throw result.ire; - } - if (result.ace != null) { - throw result.ace; - } - if (result.ase != null) { - throw result.ase; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllUserSSHPubKeys failed: unknown result"); - } - public Map<String,String> getAllGatewaySSHPubKeys(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.thrift.TException { send_getAllGatewaySSHPubKeys(authzToken, gatewayId); @@ -9013,41 +8959,6 @@ public class Airavata { } } - public void getAllUserSSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getAllUserSSHPubKeys_call method_call = new getAllUserSSHPubKeys_call(authzToken, userName, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getAllUserSSHPubKeys_call extends org.apache.thrift.async.TAsyncMethodCall { - private org.apache.airavata.model.security.AuthzToken authzToken; - private String userName; - public getAllUserSSHPubKeys_call(org.apache.airavata.model.security.AuthzToken authzToken, String userName, 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.userName = userName; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllUserSSHPubKeys", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getAllUserSSHPubKeys_args args = new getAllUserSSHPubKeys_args(); - args.setAuthzToken(authzToken); - args.setUserName(userName); - args.write(prot); - prot.writeMessageEnd(); - } - - public Map<String,String> getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getAllUserSSHPubKeys(); - } - } - public void getAllGatewaySSHPubKeys(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); getAllGatewaySSHPubKeys_call method_call = new getAllGatewaySSHPubKeys_call(authzToken, gatewayId, resultHandler, this, ___protocolFactory, ___transport); @@ -13966,7 +13877,6 @@ public class Airavata { processMap.put("generateAndRegisterSSHKeys", new generateAndRegisterSSHKeys()); processMap.put("registerPwdCredential", new registerPwdCredential()); processMap.put("getSSHPubKey", new getSSHPubKey()); - processMap.put("getAllUserSSHPubKeys", new getAllUserSSHPubKeys()); processMap.put("getAllGatewaySSHPubKeys", new getAllGatewaySSHPubKeys()); processMap.put("getAllGatewayPWDCredentials", new getAllGatewayPWDCredentials()); processMap.put("deleteSSHPubKey", new deleteSSHPubKey()); @@ -14579,34 +14489,6 @@ public class Airavata { } } - public static class getAllUserSSHPubKeys<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllUserSSHPubKeys_args> { - public getAllUserSSHPubKeys() { - super("getAllUserSSHPubKeys"); - } - - public getAllUserSSHPubKeys_args getEmptyArgsInstance() { - return new getAllUserSSHPubKeys_args(); - } - - protected boolean isOneway() { - return false; - } - - public getAllUserSSHPubKeys_result getResult(I iface, getAllUserSSHPubKeys_args args) throws org.apache.thrift.TException { - getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result(); - try { - result.success = iface.getAllUserSSHPubKeys(args.authzToken, args.userName); - } catch (org.apache.airavata.model.error.InvalidRequestException ire) { - result.ire = ire; - } catch (org.apache.airavata.model.error.AiravataClientException ace) { - result.ace = ace; - } catch (org.apache.airavata.model.error.AiravataSystemException ase) { - result.ase = ase; - } - return result; - } - } - public static class getAllGatewaySSHPubKeys<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllGatewaySSHPubKeys_args> { public getAllGatewaySSHPubKeys() { super("getAllGatewaySSHPubKeys"); @@ -18589,7 +18471,6 @@ public class Airavata { processMap.put("generateAndRegisterSSHKeys", new generateAndRegisterSSHKeys()); processMap.put("registerPwdCredential", new registerPwdCredential()); processMap.put("getSSHPubKey", new getSSHPubKey()); - processMap.put("getAllUserSSHPubKeys", new getAllUserSSHPubKeys()); processMap.put("getAllGatewaySSHPubKeys", new getAllGatewaySSHPubKeys()); processMap.put("getAllGatewayPWDCredentials", new getAllGatewayPWDCredentials()); processMap.put("deleteSSHPubKey", new deleteSSHPubKey()); @@ -19864,20 +19745,20 @@ public class Airavata { } } - public static class getAllUserSSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserSSHPubKeys_args, Map<String,String>> { - public getAllUserSSHPubKeys() { - super("getAllUserSSHPubKeys"); + public static class getAllGatewaySSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewaySSHPubKeys_args, Map<String,String>> { + public getAllGatewaySSHPubKeys() { + super("getAllGatewaySSHPubKeys"); } - public getAllUserSSHPubKeys_args getEmptyArgsInstance() { - return new getAllUserSSHPubKeys_args(); + public getAllGatewaySSHPubKeys_args getEmptyArgsInstance() { + return new getAllGatewaySSHPubKeys_args(); } public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Map<String,String>>() { public void onComplete(Map<String,String> o) { - getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result(); + getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19890,7 +19771,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllUserSSHPubKeys_result result = new getAllUserSSHPubKeys_result(); + getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19926,25 +19807,25 @@ public class Airavata { return false; } - public void start(I iface, getAllUserSSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { - iface.getAllUserSSHPubKeys(args.authzToken, args.userName,resultHandler); + public void start(I iface, getAllGatewaySSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { + iface.getAllGatewaySSHPubKeys(args.authzToken, args.gatewayId,resultHandler); } } - public static class getAllGatewaySSHPubKeys<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewaySSHPubKeys_args, Map<String,String>> { - public getAllGatewaySSHPubKeys() { - super("getAllGatewaySSHPubKeys"); + public static class getAllGatewayPWDCredentials<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayPWDCredentials_args, Map<String,String>> { + public getAllGatewayPWDCredentials() { + super("getAllGatewayPWDCredentials"); } - public getAllGatewaySSHPubKeys_args getEmptyArgsInstance() { - return new getAllGatewaySSHPubKeys_args(); + public getAllGatewayPWDCredentials_args getEmptyArgsInstance() { + return new getAllGatewayPWDCredentials_args(); } public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Map<String,String>>() { public void onComplete(Map<String,String> o) { - getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result(); + getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -19957,7 +19838,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllGatewaySSHPubKeys_result result = new getAllGatewaySSHPubKeys_result(); + getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -19993,26 +19874,27 @@ public class Airavata { return false; } - public void start(I iface, getAllGatewaySSHPubKeys_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { - iface.getAllGatewaySSHPubKeys(args.authzToken, args.gatewayId,resultHandler); + public void start(I iface, getAllGatewayPWDCredentials_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { + iface.getAllGatewayPWDCredentials(args.authzToken, args.gatewayId,resultHandler); } } - public static class getAllGatewayPWDCredentials<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllGatewayPWDCredentials_args, Map<String,String>> { - public getAllGatewayPWDCredentials() { - super("getAllGatewayPWDCredentials"); + public static class deleteSSHPubKey<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteSSHPubKey_args, Boolean> { + public deleteSSHPubKey() { + super("deleteSSHPubKey"); } - public getAllGatewayPWDCredentials_args getEmptyArgsInstance() { - return new getAllGatewayPWDCredentials_args(); + public deleteSSHPubKey_args getEmptyArgsInstance() { + return new deleteSSHPubKey_args(); } - public AsyncMethodCallback<Map<String,String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Map<String,String>>() { - public void onComplete(Map<String,String> o) { - getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + deleteSSHPubKey_result result = new deleteSSHPubKey_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20024,7 +19906,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllGatewayPWDCredentials_result result = new getAllGatewayPWDCredentials_result(); + deleteSSHPubKey_result result = new deleteSSHPubKey_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20060,25 +19942,25 @@ public class Airavata { return false; } - public void start(I iface, getAllGatewayPWDCredentials_args args, org.apache.thrift.async.AsyncMethodCallback<Map<String,String>> resultHandler) throws TException { - iface.getAllGatewayPWDCredentials(args.authzToken, args.gatewayId,resultHandler); + public void start(I iface, deleteSSHPubKey_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler); } } - public static class deleteSSHPubKey<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteSSHPubKey_args, Boolean> { - public deleteSSHPubKey() { - super("deleteSSHPubKey"); + public static class deletePWDCredential<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deletePWDCredential_args, Boolean> { + public deletePWDCredential() { + super("deletePWDCredential"); } - public deleteSSHPubKey_args getEmptyArgsInstance() { - return new deleteSSHPubKey_args(); + public deletePWDCredential_args getEmptyArgsInstance() { + return new deletePWDCredential_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) { - deleteSSHPubKey_result result = new deleteSSHPubKey_result(); + deletePWDCredential_result result = new deletePWDCredential_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -20092,7 +19974,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteSSHPubKey_result result = new deleteSSHPubKey_result(); + deletePWDCredential_result result = new deletePWDCredential_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20128,27 +20010,26 @@ public class Airavata { return false; } - public void start(I iface, deleteSSHPubKey_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler); + public void start(I iface, deletePWDCredential_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deletePWDCredential(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler); } } - public static class deletePWDCredential<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deletePWDCredential_args, Boolean> { - public deletePWDCredential() { - super("deletePWDCredential"); + public static class createProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createProject_args, String> { + public createProject() { + super("createProject"); } - public deletePWDCredential_args getEmptyArgsInstance() { - return new deletePWDCredential_args(); + public createProject_args getEmptyArgsInstance() { + return new createProject_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - deletePWDCredential_result result = new deletePWDCredential_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + createProject_result result = new createProject_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20160,7 +20041,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deletePWDCredential_result result = new deletePWDCredential_result(); + createProject_result result = new createProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20176,6 +20057,11 @@ public class Airavata { 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; @@ -20196,25 +20082,101 @@ public class Airavata { return false; } - public void start(I iface, deletePWDCredential_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deletePWDCredential(args.authzToken, args.airavataCredStoreToken, args.gatewayId,resultHandler); + public void start(I iface, createProject_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.createProject(args.authzToken, args.gatewayId, args.project,resultHandler); } } - public static class createProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createProject_args, String> { - public createProject() { - super("createProject"); + public static class updateProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateProject_args, Void> { + public updateProject() { + super("updateProject"); } - public createProject_args getEmptyArgsInstance() { - return new createProject_args(); + public updateProject_args getEmptyArgsInstance() { + return new updateProject_args(); } - public AsyncMethodCallback<String> 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<String>() { - public void onComplete(String o) { - createProject_result result = new createProject_result(); + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateProject_result result = new updateProject_result(); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } 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; + updateProject_result result = new updateProject_result(); + if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { + result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; + result.setIreIsSet(true); + 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.ProjectNotFoundException) { + result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; + result.setPnfeIsSet(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, updateProject_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateProject(args.authzToken, args.projectId, args.updatedProject,resultHandler); + } + } + + public static class getProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getProject_args, org.apache.airavata.model.workspace.Project> { + public getProject() { + super("getProject"); + } + + public getProject_args getEmptyArgsInstance() { + return new getProject_args(); + } + + public AsyncMethodCallback<org.apache.airavata.model.workspace.Project> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<org.apache.airavata.model.workspace.Project>() { + public void onComplete(org.apache.airavata.model.workspace.Project o) { + getProject_result result = new getProject_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20227,7 +20189,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - createProject_result result = new createProject_result(); + getProject_result result = new getProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20243,6 +20205,11 @@ public class Airavata { result.setAseIsSet(true); msg = result; } + else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { + result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; + result.setPnfeIsSet(true); + msg = result; + } else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { result.ae = (org.apache.airavata.model.error.AuthorizationException) e; result.setAeIsSet(true); @@ -20268,25 +20235,27 @@ public class Airavata { return false; } - public void start(I iface, createProject_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.createProject(args.authzToken, args.gatewayId, args.project,resultHandler); + public void start(I iface, getProject_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Project> resultHandler) throws TException { + iface.getProject(args.authzToken, args.projectId,resultHandler); } } - public static class updateProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateProject_args, Void> { - public updateProject() { - super("updateProject"); + public static class deleteProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteProject_args, Boolean> { + public deleteProject() { + super("deleteProject"); } - public updateProject_args getEmptyArgsInstance() { - return new updateProject_args(); + public deleteProject_args getEmptyArgsInstance() { + return new deleteProject_args(); } - public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Void>() { - public void onComplete(Void o) { - updateProject_result result = new updateProject_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + deleteProject_result result = new deleteProject_result(); + result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20298,7 +20267,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateProject_result result = new updateProject_result(); + deleteProject_result result = new deleteProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20344,25 +20313,25 @@ public class Airavata { return false; } - public void start(I iface, updateProject_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { - iface.updateProject(args.authzToken, args.projectId, args.updatedProject,resultHandler); + public void start(I iface, deleteProject_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteProject(args.authzToken, args.projectId,resultHandler); } } - public static class getProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getProject_args, org.apache.airavata.model.workspace.Project> { - public getProject() { - super("getProject"); + public static class getUserProjects<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserProjects_args, List<org.apache.airavata.model.workspace.Project>> { + public getUserProjects() { + super("getUserProjects"); } - public getProject_args getEmptyArgsInstance() { - return new getProject_args(); + public getUserProjects_args getEmptyArgsInstance() { + return new getUserProjects_args(); } - public AsyncMethodCallback<org.apache.airavata.model.workspace.Project> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.workspace.Project>() { - public void onComplete(org.apache.airavata.model.workspace.Project o) { - getProject_result result = new getProject_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { + getUserProjects_result result = new getUserProjects_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20375,7 +20344,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getProject_result result = new getProject_result(); + getUserProjects_result result = new getUserProjects_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20391,11 +20360,6 @@ public class Airavata { result.setAseIsSet(true); msg = result; } - else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { - result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; - result.setPnfeIsSet(true); - msg = result; - } else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { result.ae = (org.apache.airavata.model.error.AuthorizationException) e; result.setAeIsSet(true); @@ -20421,27 +20385,26 @@ public class Airavata { return false; } - public void start(I iface, getProject_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.workspace.Project> resultHandler) throws TException { - iface.getProject(args.authzToken, args.projectId,resultHandler); + public void start(I iface, getUserProjects_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { + iface.getUserProjects(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler); } } - public static class deleteProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteProject_args, Boolean> { - public deleteProject() { - super("deleteProject"); + public static class searchProjectsByProjectName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectName_args, List<org.apache.airavata.model.workspace.Project>> { + public searchProjectsByProjectName() { + super("searchProjectsByProjectName"); } - public deleteProject_args getEmptyArgsInstance() { - return new deleteProject_args(); + public searchProjectsByProjectName_args getEmptyArgsInstance() { + return new searchProjectsByProjectName_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - deleteProject_result result = new deleteProject_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { + public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { + searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -20453,7 +20416,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteProject_result result = new deleteProject_result(); + searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20469,11 +20432,6 @@ public class Airavata { result.setAseIsSet(true); msg = result; } - else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { - result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; - result.setPnfeIsSet(true); - msg = result; - } else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { result.ae = (org.apache.airavata.model.error.AuthorizationException) e; result.setAeIsSet(true); @@ -20499,25 +20457,25 @@ public class Airavata { return false; } - public void start(I iface, deleteProject_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteProject(args.authzToken, args.projectId,resultHandler); + public void start(I iface, searchProjectsByProjectName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { + iface.searchProjectsByProjectName(args.authzToken, args.gatewayId, args.userName, args.projectName, args.limit, args.offset,resultHandler); } } - public static class getUserProjects<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserProjects_args, List<org.apache.airavata.model.workspace.Project>> { - public getUserProjects() { - super("getUserProjects"); + public static class searchProjectsByProjectDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectDesc_args, List<org.apache.airavata.model.workspace.Project>> { + public searchProjectsByProjectDesc() { + super("searchProjectsByProjectDesc"); } - public getUserProjects_args getEmptyArgsInstance() { - return new getUserProjects_args(); + public searchProjectsByProjectDesc_args getEmptyArgsInstance() { + return new searchProjectsByProjectDesc_args(); } public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { - getUserProjects_result result = new getUserProjects_result(); + searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20530,7 +20488,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getUserProjects_result result = new getUserProjects_result(); + searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20571,25 +20529,25 @@ public class Airavata { return false; } - public void start(I iface, getUserProjects_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { - iface.getUserProjects(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler); + public void start(I iface, searchProjectsByProjectDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { + iface.searchProjectsByProjectDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler); } } - public static class searchProjectsByProjectName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectName_args, List<org.apache.airavata.model.workspace.Project>> { - public searchProjectsByProjectName() { - super("searchProjectsByProjectName"); + public static class searchExperimentsByName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByName_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByName() { + super("searchExperimentsByName"); } - public searchProjectsByProjectName_args getEmptyArgsInstance() { - return new searchProjectsByProjectName_args(); + public searchExperimentsByName_args getEmptyArgsInstance() { + return new searchExperimentsByName_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { - public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { - searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { + public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { + searchExperimentsByName_result result = new searchExperimentsByName_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20602,7 +20560,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchProjectsByProjectName_result result = new searchProjectsByProjectName_result(); + searchExperimentsByName_result result = new searchExperimentsByName_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20643,25 +20601,25 @@ public class Airavata { return false; } - public void start(I iface, searchProjectsByProjectName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { - iface.searchProjectsByProjectName(args.authzToken, args.gatewayId, args.userName, args.projectName, args.limit, args.offset,resultHandler); + public void start(I iface, searchExperimentsByName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperimentsByName(args.authzToken, args.gatewayId, args.userName, args.expName, args.limit, args.offset,resultHandler); } } - public static class searchProjectsByProjectDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchProjectsByProjectDesc_args, List<org.apache.airavata.model.workspace.Project>> { - public searchProjectsByProjectDesc() { - super("searchProjectsByProjectDesc"); + public static class searchExperimentsByDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByDesc_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByDesc() { + super("searchExperimentsByDesc"); } - public searchProjectsByProjectDesc_args getEmptyArgsInstance() { - return new searchProjectsByProjectDesc_args(); + public searchExperimentsByDesc_args getEmptyArgsInstance() { + return new searchExperimentsByDesc_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>>() { - public void onComplete(List<org.apache.airavata.model.workspace.Project> o) { - searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { + public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { + searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20674,7 +20632,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchProjectsByProjectDesc_result result = new searchProjectsByProjectDesc_result(); + searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20715,25 +20673,25 @@ public class Airavata { return false; } - public void start(I iface, searchProjectsByProjectDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.workspace.Project>> resultHandler) throws TException { - iface.searchProjectsByProjectDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler); + public void start(I iface, searchExperimentsByDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperimentsByDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler); } } - public static class searchExperimentsByName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByName_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByName() { - super("searchExperimentsByName"); + public static class searchExperimentsByApplication<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByApplication_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByApplication() { + super("searchExperimentsByApplication"); } - public searchExperimentsByName_args getEmptyArgsInstance() { - return new searchExperimentsByName_args(); + public searchExperimentsByApplication_args getEmptyArgsInstance() { + return new searchExperimentsByApplication_args(); } public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByName_result result = new searchExperimentsByName_result(); + searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20746,7 +20704,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByName_result result = new searchExperimentsByName_result(); + searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20787,25 +20745,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByName_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByName(args.authzToken, args.gatewayId, args.userName, args.expName, args.limit, args.offset,resultHandler); + public void start(I iface, searchExperimentsByApplication_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperimentsByApplication(args.authzToken, args.gatewayId, args.userName, args.applicationId, args.limit, args.offset,resultHandler); } } - public static class searchExperimentsByDesc<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByDesc_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByDesc() { - super("searchExperimentsByDesc"); + public static class searchExperimentsByStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByStatus_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByStatus() { + super("searchExperimentsByStatus"); } - public searchExperimentsByDesc_args getEmptyArgsInstance() { - return new searchExperimentsByDesc_args(); + public searchExperimentsByStatus_args getEmptyArgsInstance() { + return new searchExperimentsByStatus_args(); } public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); + searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20818,7 +20776,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByDesc_result result = new searchExperimentsByDesc_result(); + searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20859,25 +20817,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByDesc_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset,resultHandler); + public void start(I iface, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperimentsByStatus(args.authzToken, args.gatewayId, args.userName, args.experimentState, args.limit, args.offset,resultHandler); } } - public static class searchExperimentsByApplication<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByApplication_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByApplication() { - super("searchExperimentsByApplication"); + public static class searchExperimentsByCreationTime<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByCreationTime_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperimentsByCreationTime() { + super("searchExperimentsByCreationTime"); } - public searchExperimentsByApplication_args getEmptyArgsInstance() { - return new searchExperimentsByApplication_args(); + public searchExperimentsByCreationTime_args getEmptyArgsInstance() { + return new searchExperimentsByCreationTime_args(); } public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); + searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20890,7 +20848,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByApplication_result result = new searchExperimentsByApplication_result(); + searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -20931,25 +20889,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByApplication_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByApplication(args.authzToken, args.gatewayId, args.userName, args.applicationId, args.limit, args.offset,resultHandler); + public void start(I iface, searchExperimentsByCreationTime_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperimentsByCreationTime(args.authzToken, args.gatewayId, args.userName, args.fromTime, args.toTime, args.limit, args.offset,resultHandler); } } - public static class searchExperimentsByStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByStatus_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByStatus() { - super("searchExperimentsByStatus"); + public static class searchExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperiments_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { + public searchExperiments() { + super("searchExperiments"); } - public searchExperimentsByStatus_args getEmptyArgsInstance() { - return new searchExperimentsByStatus_args(); + public searchExperiments_args getEmptyArgsInstance() { + return new searchExperiments_args(); } public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); + searchExperiments_result result = new searchExperiments_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -20962,7 +20920,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByStatus_result result = new searchExperimentsByStatus_result(); + searchExperiments_result result = new searchExperiments_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21003,25 +20961,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByStatus_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByStatus(args.authzToken, args.gatewayId, args.userName, args.experimentState, args.limit, args.offset,resultHandler); + public void start(I iface, searchExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { + iface.searchExperiments(args.authzToken, args.gatewayId, args.userName, args.filters, args.limit, args.offset,resultHandler); } } - public static class searchExperimentsByCreationTime<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperimentsByCreationTime_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperimentsByCreationTime() { - super("searchExperimentsByCreationTime"); + public static class getExperimentStatistics<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatistics_args, org.apache.airavata.model.experiment.ExperimentStatistics> { + public getExperimentStatistics() { + super("getExperimentStatistics"); } - public searchExperimentsByCreationTime_args getEmptyArgsInstance() { - return new searchExperimentsByCreationTime_args(); + public getExperimentStatistics_args getEmptyArgsInstance() { + return new getExperimentStatistics_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { - public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); + return new AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics>() { + public void onComplete(org.apache.airavata.model.experiment.ExperimentStatistics o) { + getExperimentStatistics_result result = new getExperimentStatistics_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -21034,7 +20992,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperimentsByCreationTime_result result = new searchExperimentsByCreationTime_result(); + getExperimentStatistics_result result = new getExperimentStatistics_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21075,25 +21033,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperimentsByCreationTime_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperimentsByCreationTime(args.authzToken, args.gatewayId, args.userName, args.fromTime, args.toTime, args.limit, args.offset,resultHandler); + public void start(I iface, getExperimentStatistics_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> resultHandler) throws TException { + iface.getExperimentStatistics(args.authzToken, args.gatewayId, args.fromTime, args.toTime,resultHandler); } } - public static class searchExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, searchExperiments_args, List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> { - public searchExperiments() { - super("searchExperiments"); + public static class getExperimentsInProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentsInProject_args, List<org.apache.airavata.model.experiment.ExperimentModel>> { + public getExperimentsInProject() { + super("getExperimentsInProject"); } - public searchExperiments_args getEmptyArgsInstance() { - return new searchExperiments_args(); + public getExperimentsInProject_args getEmptyArgsInstance() { + return new getExperimentsInProject_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>>() { - public void onComplete(List<org.apache.airavata.model.experiment.ExperimentSummaryModel> o) { - searchExperiments_result result = new searchExperiments_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>>() { + public void onComplete(List<org.apache.airavata.model.experiment.ExperimentModel> o) { + getExperimentsInProject_result result = new getExperimentsInProject_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -21106,7 +21064,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - searchExperiments_result result = new searchExperiments_result(); + getExperimentsInProject_result result = new getExperimentsInProject_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21122,6 +21080,11 @@ public class Airavata { result.setAseIsSet(true); msg = result; } + else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { + result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; + result.setPnfeIsSet(true); + msg = result; + } else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { result.ae = (org.apache.airavata.model.error.AuthorizationException) e; result.setAeIsSet(true); @@ -21147,25 +21110,25 @@ public class Airavata { return false; } - public void start(I iface, searchExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentSummaryModel>> resultHandler) throws TException { - iface.searchExperiments(args.authzToken, args.gatewayId, args.userName, args.filters, args.limit, args.offset,resultHandler); + public void start(I iface, getExperimentsInProject_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> resultHandler) throws TException { + iface.getExperimentsInProject(args.authzToken, args.projectId, args.limit, args.offset,resultHandler); } } - public static class getExperimentStatistics<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentStatistics_args, org.apache.airavata.model.experiment.ExperimentStatistics> { - public getExperimentStatistics() { - super("getExperimentStatistics"); + public static class getUserExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserExperiments_args, List<org.apache.airavata.model.experiment.ExperimentModel>> { + public getUserExperiments() { + super("getUserExperiments"); } - public getExperimentStatistics_args getEmptyArgsInstance() { - return new getExperimentStatistics_args(); + public getUserExperiments_args getEmptyArgsInstance() { + return new getUserExperiments_args(); } - public AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics>() { - public void onComplete(org.apache.airavata.model.experiment.ExperimentStatistics o) { - getExperimentStatistics_result result = new getExperimentStatistics_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>>() { + public void onComplete(List<org.apache.airavata.model.experiment.ExperimentModel> o) { + getUserExperiments_result result = new getUserExperiments_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -21178,7 +21141,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getExperimentStatistics_result result = new getExperimentStatistics_result(); + getUserExperiments_result result = new getUserExperiments_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21219,25 +21182,25 @@ public class Airavata { return false; } - public void start(I iface, getExperimentStatistics_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentStatistics> resultHandler) throws TException { - iface.getExperimentStatistics(args.authzToken, args.gatewayId, args.fromTime, args.toTime,resultHandler); + public void start(I iface, getUserExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> resultHandler) throws TException { + iface.getUserExperiments(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler); } } - public static class getExperimentsInProject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperimentsInProject_args, List<org.apache.airavata.model.experiment.ExperimentModel>> { - public getExperimentsInProject() { - super("getExperimentsInProject"); + public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> { + public createExperiment() { + super("createExperiment"); } - public getExperimentsInProject_args getEmptyArgsInstance() { - return new getExperimentsInProject_args(); + public createExperiment_args getEmptyArgsInstance() { + return new createExperiment_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>>() { - public void onComplete(List<org.apache.airavata.model.experiment.ExperimentModel> o) { - getExperimentsInProject_result result = new getExperimentsInProject_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + createExperiment_result result = new createExperiment_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -21250,7 +21213,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getExperimentsInProject_result result = new getExperimentsInProject_result(); + createExperiment_result result = new createExperiment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21266,11 +21229,6 @@ public class Airavata { result.setAseIsSet(true); msg = result; } - else if (e instanceof org.apache.airavata.model.error.ProjectNotFoundException) { - result.pnfe = (org.apache.airavata.model.error.ProjectNotFoundException) e; - result.setPnfeIsSet(true); - msg = result; - } else if (e instanceof org.apache.airavata.model.error.AuthorizationException) { result.ae = (org.apache.airavata.model.error.AuthorizationException) e; result.setAeIsSet(true); @@ -21296,26 +21254,27 @@ public class Airavata { return false; } - public void start(I iface, getExperimentsInProject_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> resultHandler) throws TException { - iface.getExperimentsInProject(args.authzToken, args.projectId, args.limit, args.offset,resultHandler); + public void start(I iface, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.createExperiment(args.authzToken, args.gatewayId, args.experiment,resultHandler); } } - public static class getUserExperiments<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserExperiments_args, List<org.apache.airavata.model.experiment.ExperimentModel>> { - public getUserExperiments() { - super("getUserExperiments"); + public static class deleteExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteExperiment_args, Boolean> { + public deleteExperiment() { + super("deleteExperiment"); } - public getUserExperiments_args getEmptyArgsInstance() { - return new getUserExperiments_args(); + public deleteExperiment_args getEmptyArgsInstance() { + return new deleteExperiment_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>>() { - public void onComplete(List<org.apache.airavata.model.experiment.ExperimentModel> o) { - getUserExperiments_result result = new getUserExperiments_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + deleteExperiment_result result = new deleteExperiment_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -21327,7 +21286,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getUserExperiments_result result = new getUserExperiments_result(); + deleteExperiment_result result = new deleteExperiment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -21368,25 +21327,25 @@ public class Airavata { return false; } - public void start(I iface, getUserExperiments_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.experiment.ExperimentModel>> resultHandler) throws TException { - iface.getUserExperiments(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset,resultHandler); + public void start(I iface, deleteExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteExperiment(args.authzToken, args.experimentId,resultHandler); } } - public static class createExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createExperiment_args, String> { - public createExperiment() { - super("createExperiment"); + public static class getExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperiment_args, org.apache.airavata.model.experiment.ExperimentModel> { + public getExperiment() { + super("getExperiment"); } - public createExperiment_args getEmptyArgsInstance() { - return new createExperiment_args(); + public getExperiment_args getEmptyArgsInstance() { + return new getExperiment_args(); } - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - createExperiment_result result = new createExperiment_result(); + return new AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel>() { + public void onComplete(org.apache.airavata.model.experiment.ExperimentModel o) { + getExperiment_result result = new getExperiment_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -21399,12 +21358,17 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - createExperiment_result result = new createExperiment_result(); + getExperiment_result result = new getExperiment_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); msg = result; } + else if (e instanceof org.apache.airavata.model.error.ExperimentNotFoundException) { + result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e; + result.setEnfIsSet(true); + msg = result; + } else if (e instanceof org.apache.airavata.model.error.AiravataClientException) { result.ace = (org.apache.airavata.model.error.AiravataClientException) e; result.setAceIsSet(true); @@ -21440,27 +21404,26 @@ public class Airavata { return false; } - public void start(I iface, createExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.createExperiment(args.authzToken, args.gatewayId, args.experiment,resultHandler); + public void start(I iface, getExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel> resultHandler) throws TException { + iface.getExperiment(args.authzToken, args.airavataExperimentId,resultHandler); } } - public static class deleteExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteExperiment_args, Boolean> { - public deleteExperiment() { - super("deleteExperiment"); + public static class getDetailedExperimentTree<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getDetailedExperimentTree_args, org.apache.airavata.model.experiment.ExperimentModel> { + public getDetailedExperimentTree() { + super("getDetailedExperimentTree"); } - public deleteExperiment_args getEmptyArgsInstance() { - return new deleteExperiment_args(); + public getDetailedExperimentTree_args getEmptyArgsInstance() { + return new getDetailedExperimentTree_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - deleteExperiment_result result = new deleteExperiment_result(); + return new AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel>() { + public void onComplete(org.apache.airavata.model.experiment.ExperimentModel o) { + getDetailedExperimentTree_result result = new getDetailedExperimentTree_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -21472,12 +21435,17 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteExperiment_result result = new deleteExperiment_result(); + getDetailedExperimentTree_result result = new getDetailedExperimentTree_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); msg = result; } + else if (e instanceof org.apache.airavata.model.error.ExperimentNotFoundException) { + result.enf = (org.apache.airavata.model.error.ExperimentNotFoundException) e; + result.setEnfIsSet(true); + msg = result; + } else if (e instanceof org.apache.airavata.model.error.AiravataClientException) { result.ace = (org.apache.airavata.model.error.AiravataClientException) e; result.setAceIsSet(true); @@ -21513,26 +21481,25 @@ public class Airavata { return false; } - public void start(I iface, deleteExperiment_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteExperiment(args.authzToken, args.experimentId,resultHandler); + public void start(I iface, getDetailedExperimentTree_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.experiment.ExperimentModel> resultHandler) throws TException { + iface.getDetailedExperimentTree(args.authzToken, args.airavataExperimentId,resultHandler); } } - public static class getExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getExperiment_args, org.apache.airavata.model.experiment.ExperimentModel> { - public getExperiment() { - super("getExperiment"); + public static class updateExperiment<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateExperiment_args, Void> { + public updateExperiment() { + super("updateExperiment"); } - public getExperiment_args getEmptyArgsInstance() { - return new getExperiment_args(); + public updateExperiment_args getEmptyArgsInstance() { + return new updateExperiment_args(); } - public
<TRUNCATED>
