http://git-wip-us.apache.org/repos/asf/airavata/blob/83253df7/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 851f96e..6214caf 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 @@ -2621,11 +2621,34 @@ public class Airavata { */ public boolean deleteGatewayStoragePreference(org.apache.airavata.model.security.AuthzToken authzToken, String gatewayID, String storageId) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException; - public List<String> getSSHAccountProvisionerNames(org.apache.airavata.model.security.AuthzToken authzToken) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException; + public List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisioner> getSSHAccountProvisionerNames(org.apache.airavata.model.security.AuthzToken authzToken) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException; public List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisionerConfigParam> getSSHAccountProvisionerConfigParams(org.apache.airavata.model.security.AuthzToken authzToken, String provisionerName) 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; /** + * Setup and return a UserComputeResourcePreference object for this user to SSH into the given compute resource with + * the given SSH credential. This method will only work if the compute resource has an SSHAccountProvisioner + * configured for it. The returned UserComputeResourcePreference object is not saved; it is up to the client to + * call addUserComputeResourcePreference to persist it. + * + * @param authzToken + * @param computeResourceId + * @param username + * @param airavataCredStoreToken + */ + public org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference setupUserComputeResourcePreferencesForSSH(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username, String airavataCredStoreToken) 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; + + /** + * Check if user has an SSH account on the given compute resource. This + * method will only work if the compute resource has an SSHAccountProvisioner configured for it. + * + * @param authzToken + * @param computeResourceId + * @param username + */ + public boolean doesUserHaveSSHAccount(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username) 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; + + /** * Register User Resource Profile. * * @param UserResourceProfile @@ -3299,6 +3322,10 @@ public class Airavata { public void getSSHAccountProvisionerConfigParams(org.apache.airavata.model.security.AuthzToken authzToken, String provisionerName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void setupUserComputeResourcePreferencesForSSH(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username, String airavataCredStoreToken, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void doesUserHaveSSHAccount(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void registerUserResourceProfile(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile userResourceProfile, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getUserResourceProfile(org.apache.airavata.model.security.AuthzToken authzToken, String userId, String gatewayID, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -8283,7 +8310,7 @@ public class Airavata { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteGatewayStoragePreference failed: unknown result"); } - public List<String> getSSHAccountProvisionerNames(org.apache.airavata.model.security.AuthzToken authzToken) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException + public List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisioner> getSSHAccountProvisionerNames(org.apache.airavata.model.security.AuthzToken authzToken) throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException { send_getSSHAccountProvisionerNames(authzToken); return recv_getSSHAccountProvisionerNames(); @@ -8296,7 +8323,7 @@ public class Airavata { sendBase("getSSHAccountProvisionerNames", args); } - public List<String> recv_getSSHAccountProvisionerNames() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.airavata.model.error.AuthorizationException, org.apache.thrift.TException + public List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisioner> recv_getSSHAccountProvisionerNames() 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 { getSSHAccountProvisionerNames_result result = new getSSHAccountProvisionerNames_result(); receiveBase(result, "getSSHAccountProvisionerNames"); @@ -8354,6 +8381,81 @@ public class Airavata { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSSHAccountProvisionerConfigParams failed: unknown result"); } + public org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference setupUserComputeResourcePreferencesForSSH(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username, String airavataCredStoreToken) 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_setupUserComputeResourcePreferencesForSSH(authzToken, computeResourceId, username, airavataCredStoreToken); + return recv_setupUserComputeResourcePreferencesForSSH(); + } + + public void send_setupUserComputeResourcePreferencesForSSH(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username, String airavataCredStoreToken) throws org.apache.thrift.TException + { + setupUserComputeResourcePreferencesForSSH_args args = new setupUserComputeResourcePreferencesForSSH_args(); + args.setAuthzToken(authzToken); + args.setComputeResourceId(computeResourceId); + args.setUsername(username); + args.setAiravataCredStoreToken(airavataCredStoreToken); + sendBase("setupUserComputeResourcePreferencesForSSH", args); + } + + public org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference recv_setupUserComputeResourcePreferencesForSSH() 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 + { + setupUserComputeResourcePreferencesForSSH_result result = new setupUserComputeResourcePreferencesForSSH_result(); + receiveBase(result, "setupUserComputeResourcePreferencesForSSH"); + 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, "setupUserComputeResourcePreferencesForSSH failed: unknown result"); + } + + public boolean doesUserHaveSSHAccount(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username) 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_doesUserHaveSSHAccount(authzToken, computeResourceId, username); + return recv_doesUserHaveSSHAccount(); + } + + public void send_doesUserHaveSSHAccount(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username) throws org.apache.thrift.TException + { + doesUserHaveSSHAccount_args args = new doesUserHaveSSHAccount_args(); + args.setAuthzToken(authzToken); + args.setComputeResourceId(computeResourceId); + args.setUsername(username); + sendBase("doesUserHaveSSHAccount", args); + } + + public boolean recv_doesUserHaveSSHAccount() 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 + { + doesUserHaveSSHAccount_result result = new doesUserHaveSSHAccount_result(); + receiveBase(result, "doesUserHaveSSHAccount"); + 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, "doesUserHaveSSHAccount failed: unknown result"); + } + public String registerUserResourceProfile(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile userResourceProfile) 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_registerUserResourceProfile(authzToken, userResourceProfile); @@ -14687,7 +14789,7 @@ public class Airavata { 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 { + public List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisioner> 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!"); } @@ -14732,6 +14834,85 @@ public class Airavata { } } + public void setupUserComputeResourcePreferencesForSSH(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username, String airavataCredStoreToken, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + setupUserComputeResourcePreferencesForSSH_call method_call = new setupUserComputeResourcePreferencesForSSH_call(authzToken, computeResourceId, username, airavataCredStoreToken, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class setupUserComputeResourcePreferencesForSSH_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.airavata.model.security.AuthzToken authzToken; + private String computeResourceId; + private String username; + private String airavataCredStoreToken; + public setupUserComputeResourcePreferencesForSSH_call(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username, String airavataCredStoreToken, 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.computeResourceId = computeResourceId; + this.username = username; + this.airavataCredStoreToken = airavataCredStoreToken; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setupUserComputeResourcePreferencesForSSH", org.apache.thrift.protocol.TMessageType.CALL, 0)); + setupUserComputeResourcePreferencesForSSH_args args = new setupUserComputeResourcePreferencesForSSH_args(); + args.setAuthzToken(authzToken); + args.setComputeResourceId(computeResourceId); + args.setUsername(username); + args.setAiravataCredStoreToken(airavataCredStoreToken); + args.write(prot); + prot.writeMessageEnd(); + } + + public org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference 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_setupUserComputeResourcePreferencesForSSH(); + } + } + + public void doesUserHaveSSHAccount(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, String username, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + doesUserHaveSSHAccount_call method_call = new doesUserHaveSSHAccount_call(authzToken, computeResourceId, username, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class doesUserHaveSSHAccount_call extends org.apache.thrift.async.TAsyncMethodCall { + private org.apache.airavata.model.security.AuthzToken authzToken; + private String computeResourceId; + private String username; + public doesUserHaveSSHAccount_call(org.apache.airavata.model.security.AuthzToken authzToken, String computeResourceId, 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.computeResourceId = computeResourceId; + 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("doesUserHaveSSHAccount", org.apache.thrift.protocol.TMessageType.CALL, 0)); + doesUserHaveSSHAccount_args args = new doesUserHaveSSHAccount_args(); + args.setAuthzToken(authzToken); + args.setComputeResourceId(computeResourceId); + args.setUsername(username); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean getResult() throws org.apache.airavata.model.error.InvalidRequestException, org.apache.airavata.model.error.AiravataClientException, org.apache.airavata.model.error.AiravataSystemException, org.apache.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_doesUserHaveSSHAccount(); + } + } + public void registerUserResourceProfile(org.apache.airavata.model.security.AuthzToken authzToken, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile userResourceProfile, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); registerUserResourceProfile_call method_call = new registerUserResourceProfile_call(authzToken, userResourceProfile, resultHandler, this, ___protocolFactory, ___transport); @@ -16239,6 +16420,8 @@ public class Airavata { processMap.put("deleteGatewayStoragePreference", new deleteGatewayStoragePreference()); processMap.put("getSSHAccountProvisionerNames", new getSSHAccountProvisionerNames()); processMap.put("getSSHAccountProvisionerConfigParams", new getSSHAccountProvisionerConfigParams()); + processMap.put("setupUserComputeResourcePreferencesForSSH", new setupUserComputeResourcePreferencesForSSH()); + processMap.put("doesUserHaveSSHAccount", new doesUserHaveSSHAccount()); processMap.put("registerUserResourceProfile", new registerUserResourceProfile()); processMap.put("getUserResourceProfile", new getUserResourceProfile()); processMap.put("updateUserResourceProfile", new updateUserResourceProfile()); @@ -20384,6 +20567,67 @@ public class Airavata { } } + public static class setupUserComputeResourcePreferencesForSSH<I extends Iface> extends org.apache.thrift.ProcessFunction<I, setupUserComputeResourcePreferencesForSSH_args> { + public setupUserComputeResourcePreferencesForSSH() { + super("setupUserComputeResourcePreferencesForSSH"); + } + + public setupUserComputeResourcePreferencesForSSH_args getEmptyArgsInstance() { + return new setupUserComputeResourcePreferencesForSSH_args(); + } + + protected boolean isOneway() { + return false; + } + + public setupUserComputeResourcePreferencesForSSH_result getResult(I iface, setupUserComputeResourcePreferencesForSSH_args args) throws org.apache.thrift.TException { + setupUserComputeResourcePreferencesForSSH_result result = new setupUserComputeResourcePreferencesForSSH_result(); + try { + result.success = iface.setupUserComputeResourcePreferencesForSSH(args.authzToken, args.computeResourceId, args.username, args.airavataCredStoreToken); + } 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 doesUserHaveSSHAccount<I extends Iface> extends org.apache.thrift.ProcessFunction<I, doesUserHaveSSHAccount_args> { + public doesUserHaveSSHAccount() { + super("doesUserHaveSSHAccount"); + } + + public doesUserHaveSSHAccount_args getEmptyArgsInstance() { + return new doesUserHaveSSHAccount_args(); + } + + protected boolean isOneway() { + return false; + } + + public doesUserHaveSSHAccount_result getResult(I iface, doesUserHaveSSHAccount_args args) throws org.apache.thrift.TException { + doesUserHaveSSHAccount_result result = new doesUserHaveSSHAccount_result(); + try { + result.success = iface.doesUserHaveSSHAccount(args.authzToken, args.computeResourceId, args.username); + result.setSuccessIsSet(true); + } catch (org.apache.airavata.model.error.InvalidRequestException ire) { + result.ire = ire; + } catch (org.apache.airavata.model.error.AiravataClientException ace) { + result.ace = ace; + } catch (org.apache.airavata.model.error.AiravataSystemException ase) { + result.ase = ase; + } catch (org.apache.airavata.model.error.AuthorizationException ae) { + result.ae = ae; + } + return result; + } + } + public static class registerUserResourceProfile<I extends Iface> extends org.apache.thrift.ProcessFunction<I, registerUserResourceProfile_args> { public registerUserResourceProfile() { super("registerUserResourceProfile"); @@ -21625,6 +21869,8 @@ public class Airavata { processMap.put("deleteGatewayStoragePreference", new deleteGatewayStoragePreference()); processMap.put("getSSHAccountProvisionerNames", new getSSHAccountProvisionerNames()); processMap.put("getSSHAccountProvisionerConfigParams", new getSSHAccountProvisionerConfigParams()); + processMap.put("setupUserComputeResourcePreferencesForSSH", new setupUserComputeResourcePreferencesForSSH()); + processMap.put("doesUserHaveSSHAccount", new doesUserHaveSSHAccount()); processMap.put("registerUserResourceProfile", new registerUserResourceProfile()); processMap.put("getUserResourceProfile", new getUserResourceProfile()); processMap.put("updateUserResourceProfile", new updateUserResourceProfile()); @@ -31305,7 +31551,7 @@ public class Airavata { } } - public static class getSSHAccountProvisionerNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSSHAccountProvisionerNames_args, List<String>> { + public static class getSSHAccountProvisionerNames<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getSSHAccountProvisionerNames_args, List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisioner>> { public getSSHAccountProvisionerNames() { super("getSSHAccountProvisionerNames"); } @@ -31314,10 +31560,10 @@ public class Airavata { return new getSSHAccountProvisionerNames_args(); } - public AsyncMethodCallback<List<String>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisioner>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<String>>() { - public void onComplete(List<String> o) { + return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisioner>>() { + public void onComplete(List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisioner> o) { getSSHAccountProvisionerNames_result result = new getSSHAccountProvisionerNames_result(); result.success = o; try { @@ -31372,7 +31618,7 @@ public class Airavata { return false; } - public void start(I iface, getSSHAccountProvisionerNames_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { + public void start(I iface, getSSHAccountProvisionerNames_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.accountprovisioning.SSHAccountProvisioner>> resultHandler) throws TException { iface.getSSHAccountProvisionerNames(args.authzToken,resultHandler); } } @@ -31449,92 +31695,20 @@ public class Airavata { } } - public static class registerUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerUserResourceProfile_args, String> { - public registerUserResourceProfile() { - super("registerUserResourceProfile"); + public static class setupUserComputeResourcePreferencesForSSH<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, setupUserComputeResourcePreferencesForSSH_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> { + public setupUserComputeResourcePreferencesForSSH() { + super("setupUserComputeResourcePreferencesForSSH"); } - public registerUserResourceProfile_args getEmptyArgsInstance() { - return new registerUserResourceProfile_args(); + public setupUserComputeResourcePreferencesForSSH_args getEmptyArgsInstance() { + return new setupUserComputeResourcePreferencesForSSH_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) { - registerUserResourceProfile_result result = new registerUserResourceProfile_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; - registerUserResourceProfile_result result = new registerUserResourceProfile_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, registerUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.registerUserResourceProfile(args.authzToken, args.userResourceProfile,resultHandler); - } - } - - public static class getUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserResourceProfile_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> { - public getUserResourceProfile() { - super("getUserResourceProfile"); - } - - public getUserResourceProfile_args getEmptyArgsInstance() { - return new getUserResourceProfile_args(); - } - - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>() { - public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile o) { - getUserResourceProfile_result result = new getUserResourceProfile_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>() { + public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference o) { + setupUserComputeResourcePreferencesForSSH_result result = new setupUserComputeResourcePreferencesForSSH_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -31547,7 +31721,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getUserResourceProfile_result result = new getUserResourceProfile_result(); + setupUserComputeResourcePreferencesForSSH_result result = new setupUserComputeResourcePreferencesForSSH_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -31588,25 +31762,25 @@ public class Airavata { return false; } - public void start(I iface, getUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> resultHandler) throws TException { - iface.getUserResourceProfile(args.authzToken, args.userId, args.gatewayID,resultHandler); + public void start(I iface, setupUserComputeResourcePreferencesForSSH_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> resultHandler) throws TException { + iface.setupUserComputeResourcePreferencesForSSH(args.authzToken, args.computeResourceId, args.username, args.airavataCredStoreToken,resultHandler); } } - public static class updateUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserResourceProfile_args, Boolean> { - public updateUserResourceProfile() { - super("updateUserResourceProfile"); + public static class doesUserHaveSSHAccount<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, doesUserHaveSSHAccount_args, Boolean> { + public doesUserHaveSSHAccount() { + super("doesUserHaveSSHAccount"); } - public updateUserResourceProfile_args getEmptyArgsInstance() { - return new updateUserResourceProfile_args(); + public doesUserHaveSSHAccount_args getEmptyArgsInstance() { + return new doesUserHaveSSHAccount_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) { - updateUserResourceProfile_result result = new updateUserResourceProfile_result(); + doesUserHaveSSHAccount_result result = new doesUserHaveSSHAccount_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -31620,7 +31794,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateUserResourceProfile_result result = new updateUserResourceProfile_result(); + doesUserHaveSSHAccount_result result = new doesUserHaveSSHAccount_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -31661,27 +31835,26 @@ public class Airavata { return false; } - public void start(I iface, updateUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateUserResourceProfile(args.authzToken, args.userId, args.gatewayID, args.userResourceProfile,resultHandler); + public void start(I iface, doesUserHaveSSHAccount_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.doesUserHaveSSHAccount(args.authzToken, args.computeResourceId, args.username,resultHandler); } } - public static class deleteUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserResourceProfile_args, Boolean> { - public deleteUserResourceProfile() { - super("deleteUserResourceProfile"); + public static class registerUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerUserResourceProfile_args, String> { + public registerUserResourceProfile() { + super("registerUserResourceProfile"); } - public deleteUserResourceProfile_args getEmptyArgsInstance() { - return new deleteUserResourceProfile_args(); + public registerUserResourceProfile_args getEmptyArgsInstance() { + return new registerUserResourceProfile_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) { - deleteUserResourceProfile_result result = new deleteUserResourceProfile_result(); + return new AsyncMethodCallback<String>() { + public void onComplete(String o) { + registerUserResourceProfile_result result = new registerUserResourceProfile_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -31693,7 +31866,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteUserResourceProfile_result result = new deleteUserResourceProfile_result(); + registerUserResourceProfile_result result = new registerUserResourceProfile_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -31734,27 +31907,26 @@ public class Airavata { return false; } - public void start(I iface, deleteUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteUserResourceProfile(args.authzToken, args.userId, args.gatewayID,resultHandler); + public void start(I iface, registerUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + iface.registerUserResourceProfile(args.authzToken, args.userResourceProfile,resultHandler); } } - public static class addUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUserComputeResourcePreference_args, Boolean> { - public addUserComputeResourcePreference() { - super("addUserComputeResourcePreference"); + public static class getUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserResourceProfile_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> { + public getUserResourceProfile() { + super("getUserResourceProfile"); } - public addUserComputeResourcePreference_args getEmptyArgsInstance() { - return new addUserComputeResourcePreference_args(); + public getUserResourceProfile_args getEmptyArgsInstance() { + return new getUserResourceProfile_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - addUserComputeResourcePreference_result result = new addUserComputeResourcePreference_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>() { + public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile o) { + getUserResourceProfile_result result = new getUserResourceProfile_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -31766,7 +31938,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - addUserComputeResourcePreference_result result = new addUserComputeResourcePreference_result(); + getUserResourceProfile_result result = new getUserResourceProfile_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -31807,25 +31979,25 @@ public class Airavata { return false; } - public void start(I iface, addUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.addUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId, args.userComputeResourcePreference,resultHandler); + public void start(I iface, getUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> resultHandler) throws TException { + iface.getUserResourceProfile(args.authzToken, args.userId, args.gatewayID,resultHandler); } } - public static class addUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUserStoragePreference_args, Boolean> { - public addUserStoragePreference() { - super("addUserStoragePreference"); + public static class updateUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserResourceProfile_args, Boolean> { + public updateUserResourceProfile() { + super("updateUserResourceProfile"); } - public addUserStoragePreference_args getEmptyArgsInstance() { - return new addUserStoragePreference_args(); + public updateUserResourceProfile_args getEmptyArgsInstance() { + return new updateUserResourceProfile_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) { - addUserStoragePreference_result result = new addUserStoragePreference_result(); + updateUserResourceProfile_result result = new updateUserResourceProfile_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -31839,7 +32011,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - addUserStoragePreference_result result = new addUserStoragePreference_result(); + updateUserResourceProfile_result result = new updateUserResourceProfile_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -31880,26 +32052,27 @@ public class Airavata { return false; } - public void start(I iface, addUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.addUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageResourceId, args.userStoragePreference,resultHandler); + public void start(I iface, updateUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateUserResourceProfile(args.authzToken, args.userId, args.gatewayID, args.userResourceProfile,resultHandler); } } - public static class getUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserComputeResourcePreference_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> { - public getUserComputeResourcePreference() { - super("getUserComputeResourcePreference"); + public static class deleteUserResourceProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserResourceProfile_args, Boolean> { + public deleteUserResourceProfile() { + super("deleteUserResourceProfile"); } - public getUserComputeResourcePreference_args getEmptyArgsInstance() { - return new getUserComputeResourcePreference_args(); + public deleteUserResourceProfile_args getEmptyArgsInstance() { + return new deleteUserResourceProfile_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> 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<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>() { - public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference o) { - getUserComputeResourcePreference_result result = new getUserComputeResourcePreference_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + deleteUserResourceProfile_result result = new deleteUserResourceProfile_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -31911,7 +32084,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getUserComputeResourcePreference_result result = new getUserComputeResourcePreference_result(); + deleteUserResourceProfile_result result = new deleteUserResourceProfile_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -31952,26 +32125,27 @@ public class Airavata { return false; } - public void start(I iface, getUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> resultHandler) throws TException { - iface.getUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId,resultHandler); + public void start(I iface, deleteUserResourceProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteUserResourceProfile(args.authzToken, args.userId, args.gatewayID,resultHandler); } } - public static class getUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserStoragePreference_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> { - public getUserStoragePreference() { - super("getUserStoragePreference"); + public static class addUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUserComputeResourcePreference_args, Boolean> { + public addUserComputeResourcePreference() { + super("addUserComputeResourcePreference"); } - public getUserStoragePreference_args getEmptyArgsInstance() { - return new getUserStoragePreference_args(); + public addUserComputeResourcePreference_args getEmptyArgsInstance() { + return new addUserComputeResourcePreference_args(); } - public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> 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<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>() { - public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference o) { - getUserStoragePreference_result result = new getUserStoragePreference_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + addUserComputeResourcePreference_result result = new addUserComputeResourcePreference_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -31983,7 +32157,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getUserStoragePreference_result result = new getUserStoragePreference_result(); + addUserComputeResourcePreference_result result = new addUserComputeResourcePreference_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32024,26 +32198,27 @@ public class Airavata { return false; } - public void start(I iface, getUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> resultHandler) throws TException { - iface.getUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageResourceId,resultHandler); + public void start(I iface, addUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.addUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId, args.userComputeResourcePreference,resultHandler); } } - public static class getAllUserComputeResourcePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserComputeResourcePreferences_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> { - public getAllUserComputeResourcePreferences() { - super("getAllUserComputeResourcePreferences"); + public static class addUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUserStoragePreference_args, Boolean> { + public addUserStoragePreference() { + super("addUserStoragePreference"); } - public getAllUserComputeResourcePreferences_args getEmptyArgsInstance() { - return new getAllUserComputeResourcePreferences_args(); + public addUserStoragePreference_args getEmptyArgsInstance() { + return new addUserStoragePreference_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> 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.appcatalog.userresourceprofile.UserComputeResourcePreference>>() { - public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> o) { - getAllUserComputeResourcePreferences_result result = new getAllUserComputeResourcePreferences_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + addUserStoragePreference_result result = new addUserStoragePreference_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32055,7 +32230,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllUserComputeResourcePreferences_result result = new getAllUserComputeResourcePreferences_result(); + addUserStoragePreference_result result = new addUserStoragePreference_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32096,25 +32271,25 @@ public class Airavata { return false; } - public void start(I iface, getAllUserComputeResourcePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> resultHandler) throws TException { - iface.getAllUserComputeResourcePreferences(args.authzToken, args.userId, args.gatewayID,resultHandler); + public void start(I iface, addUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.addUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageResourceId, args.userStoragePreference,resultHandler); } } - public static class getAllUserStoragePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserStoragePreferences_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> { - public getAllUserStoragePreferences() { - super("getAllUserStoragePreferences"); + public static class getUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserComputeResourcePreference_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> { + public getUserComputeResourcePreference() { + super("getUserComputeResourcePreference"); } - public getAllUserStoragePreferences_args getEmptyArgsInstance() { - return new getAllUserStoragePreferences_args(); + public getUserComputeResourcePreference_args getEmptyArgsInstance() { + return new getUserComputeResourcePreference_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>>() { - public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> o) { - getAllUserStoragePreferences_result result = new getAllUserStoragePreferences_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>() { + public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference o) { + getUserComputeResourcePreference_result result = new getUserComputeResourcePreference_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -32127,7 +32302,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllUserStoragePreferences_result result = new getAllUserStoragePreferences_result(); + getUserComputeResourcePreference_result result = new getUserComputeResourcePreference_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32168,25 +32343,25 @@ public class Airavata { return false; } - public void start(I iface, getAllUserStoragePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> resultHandler) throws TException { - iface.getAllUserStoragePreferences(args.authzToken, args.userId, args.gatewayID,resultHandler); + public void start(I iface, getUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> resultHandler) throws TException { + iface.getUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId,resultHandler); } } - public static class getAllUserResourceProfiles<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserResourceProfiles_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> { - public getAllUserResourceProfiles() { - super("getAllUserResourceProfiles"); + public static class getUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserStoragePreference_args, org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> { + public getUserStoragePreference() { + super("getUserStoragePreference"); } - public getAllUserResourceProfiles_args getEmptyArgsInstance() { - return new getAllUserResourceProfiles_args(); + public getUserStoragePreference_args getEmptyArgsInstance() { + return new getUserStoragePreference_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>>() { - public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> o) { - getAllUserResourceProfiles_result result = new getAllUserResourceProfiles_result(); + return new AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>() { + public void onComplete(org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference o) { + getUserStoragePreference_result result = new getUserStoragePreference_result(); result.success = o; try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); @@ -32199,7 +32374,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllUserResourceProfiles_result result = new getAllUserResourceProfiles_result(); + getUserStoragePreference_result result = new getUserStoragePreference_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32240,27 +32415,26 @@ public class Airavata { return false; } - public void start(I iface, getAllUserResourceProfiles_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> resultHandler) throws TException { - iface.getAllUserResourceProfiles(args.authzToken,resultHandler); + public void start(I iface, getUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> resultHandler) throws TException { + iface.getUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageResourceId,resultHandler); } } - public static class updateUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserComputeResourcePreference_args, Boolean> { - public updateUserComputeResourcePreference() { - super("updateUserComputeResourcePreference"); + public static class getAllUserComputeResourcePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserComputeResourcePreferences_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> { + public getAllUserComputeResourcePreferences() { + super("getAllUserComputeResourcePreferences"); } - public updateUserComputeResourcePreference_args getEmptyArgsInstance() { - return new updateUserComputeResourcePreference_args(); + public getAllUserComputeResourcePreferences_args getEmptyArgsInstance() { + return new getAllUserComputeResourcePreferences_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateUserComputeResourcePreference_result result = new updateUserComputeResourcePreference_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>>() { + public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference> o) { + getAllUserComputeResourcePreferences_result result = new getAllUserComputeResourcePreferences_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32272,7 +32446,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateUserComputeResourcePreference_result result = new updateUserComputeResourcePreference_result(); + getAllUserComputeResourcePreferences_result result = new getAllUserComputeResourcePreferences_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32313,27 +32487,26 @@ public class Airavata { return false; } - public void start(I iface, updateUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId, args.userComputeResourcePreference,resultHandler); + public void start(I iface, getAllUserComputeResourcePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserComputeResourcePreference>> resultHandler) throws TException { + iface.getAllUserComputeResourcePreferences(args.authzToken, args.userId, args.gatewayID,resultHandler); } } - public static class updateUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserStoragePreference_args, Boolean> { - public updateUserStoragePreference() { - super("updateUserStoragePreference"); + public static class getAllUserStoragePreferences<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserStoragePreferences_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> { + public getAllUserStoragePreferences() { + super("getAllUserStoragePreferences"); } - public updateUserStoragePreference_args getEmptyArgsInstance() { - return new updateUserStoragePreference_args(); + public getAllUserStoragePreferences_args getEmptyArgsInstance() { + return new getAllUserStoragePreferences_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateUserStoragePreference_result result = new updateUserStoragePreference_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>>() { + public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference> o) { + getAllUserStoragePreferences_result result = new getAllUserStoragePreferences_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32345,7 +32518,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - updateUserStoragePreference_result result = new updateUserStoragePreference_result(); + getAllUserStoragePreferences_result result = new getAllUserStoragePreferences_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32386,27 +32559,26 @@ public class Airavata { return false; } - public void start(I iface, updateUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageId, args.userStoragePreference,resultHandler); + public void start(I iface, getAllUserStoragePreferences_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserStoragePreference>> resultHandler) throws TException { + iface.getAllUserStoragePreferences(args.authzToken, args.userId, args.gatewayID,resultHandler); } } - public static class deleteUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserComputeResourcePreference_args, Boolean> { - public deleteUserComputeResourcePreference() { - super("deleteUserComputeResourcePreference"); + public static class getAllUserResourceProfiles<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserResourceProfiles_args, List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> { + public getAllUserResourceProfiles() { + super("getAllUserResourceProfiles"); } - public deleteUserComputeResourcePreference_args getEmptyArgsInstance() { - return new deleteUserComputeResourcePreference_args(); + public getAllUserResourceProfiles_args getEmptyArgsInstance() { + return new getAllUserResourceProfiles_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - deleteUserComputeResourcePreference_result result = new deleteUserComputeResourcePreference_result(); + return new AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>>() { + public void onComplete(List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile> o) { + getAllUserResourceProfiles_result result = new getAllUserResourceProfiles_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32418,7 +32590,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteUserComputeResourcePreference_result result = new deleteUserComputeResourcePreference_result(); + getAllUserResourceProfiles_result result = new getAllUserResourceProfiles_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32459,25 +32631,25 @@ public class Airavata { return false; } - public void start(I iface, deleteUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId,resultHandler); + public void start(I iface, getAllUserResourceProfiles_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.appcatalog.userresourceprofile.UserResourceProfile>> resultHandler) throws TException { + iface.getAllUserResourceProfiles(args.authzToken,resultHandler); } } - public static class deleteUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserStoragePreference_args, Boolean> { - public deleteUserStoragePreference() { - super("deleteUserStoragePreference"); + public static class updateUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserComputeResourcePreference_args, Boolean> { + public updateUserComputeResourcePreference() { + super("updateUserComputeResourcePreference"); } - public deleteUserStoragePreference_args getEmptyArgsInstance() { - return new deleteUserStoragePreference_args(); + public updateUserComputeResourcePreference_args getEmptyArgsInstance() { + return new updateUserComputeResourcePreference_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) { - deleteUserStoragePreference_result result = new deleteUserStoragePreference_result(); + updateUserComputeResourcePreference_result result = new updateUserComputeResourcePreference_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -32491,7 +32663,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deleteUserStoragePreference_result result = new deleteUserStoragePreference_result(); + updateUserComputeResourcePreference_result result = new updateUserComputeResourcePreference_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32532,26 +32704,27 @@ public class Airavata { return false; } - public void start(I iface, deleteUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageId,resultHandler); + public void start(I iface, updateUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId, args.userComputeResourcePreference,resultHandler); } } - public static class getAllWorkflows<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllWorkflows_args, List<String>> { - public getAllWorkflows() { - super("getAllWorkflows"); + public static class updateUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserStoragePreference_args, Boolean> { + public updateUserStoragePreference() { + super("updateUserStoragePreference"); } - public getAllWorkflows_args getEmptyArgsInstance() { - return new getAllWorkflows_args(); + public updateUserStoragePreference_args getEmptyArgsInstance() { + return new updateUserStoragePreference_args(); } - public AsyncMethodCallback<List<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<List<String>>() { - public void onComplete(List<String> o) { - getAllWorkflows_result result = new getAllWorkflows_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + updateUserStoragePreference_result result = new updateUserStoragePreference_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32563,7 +32736,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getAllWorkflows_result result = new getAllWorkflows_result(); + updateUserStoragePreference_result result = new updateUserStoragePreference_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32604,26 +32777,27 @@ public class Airavata { return false; } - public void start(I iface, getAllWorkflows_args args, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws TException { - iface.getAllWorkflows(args.authzToken, args.gatewayId,resultHandler); + public void start(I iface, updateUserStoragePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.updateUserStoragePreference(args.authzToken, args.userId, args.gatewayID, args.userStorageId, args.userStoragePreference,resultHandler); } } - public static class getLatestQueueStatuses<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getLatestQueueStatuses_args, List<org.apache.airavata.model.status.QueueStatusModel>> { - public getLatestQueueStatuses() { - super("getLatestQueueStatuses"); + public static class deleteUserComputeResourcePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserComputeResourcePreference_args, Boolean> { + public deleteUserComputeResourcePreference() { + super("deleteUserComputeResourcePreference"); } - public getLatestQueueStatuses_args getEmptyArgsInstance() { - return new getLatestQueueStatuses_args(); + public deleteUserComputeResourcePreference_args getEmptyArgsInstance() { + return new deleteUserComputeResourcePreference_args(); } - public AsyncMethodCallback<List<org.apache.airavata.model.status.QueueStatusModel>> 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.status.QueueStatusModel>>() { - public void onComplete(List<org.apache.airavata.model.status.QueueStatusModel> o) { - getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + deleteUserComputeResourcePreference_result result = new deleteUserComputeResourcePreference_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32635,7 +32809,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getLatestQueueStatuses_result result = new getLatestQueueStatuses_result(); + deleteUserComputeResourcePreference_result result = new deleteUserComputeResourcePreference_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.error.InvalidRequestException) e; result.setIreIsSet(true); @@ -32676,26 +32850,27 @@ public class Airavata { return false; } - public void start(I iface, getLatestQueueStatuses_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.status.QueueStatusModel>> resultHandler) throws TException { - iface.getLatestQueueStatuses(args.authzToken,resultHandler); + public void start(I iface, deleteUserComputeResourcePreference_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deleteUserComputeResourcePreference(args.authzToken, args.userId, args.gatewayID, args.userComputeResourceId,resultHandler); } } - public static class getWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getWorkflow_args, org.apache.airavata.model.WorkflowModel> { - public getWorkflow() { - super("getWorkflow"); + public static class deleteUserStoragePreference<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserStoragePreference_args, Boolean> { + public deleteUserStoragePreference() { + super("deleteUserStoragePreference"); } - public getWorkflow_args getEmptyArgsInstance() { - return new getWorkflow_args(); + public deleteUserStoragePreference_args getEmptyArgsInstance() { + return new deleteUserStoragePreference_args(); } - public AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> 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<org.apache.airavata.model.WorkflowModel>() { - public void onComplete(org.apache.airavata.model.WorkflowModel o) { - getWorkflow_result result = new getWorkflow_result(); + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + deleteUserStoragePreference_result result = new deleteUserStoragePreference_result(); result.success = o; + result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -32707,78 +32882,7 @@ public class Airavata { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - getWorkflow_result result = new getWorkflow_result(); - 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, getWorkflow_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.WorkflowModel> resultHandler) throws TException { - iface.getWorkflow(args.authzToken, args.workflowTemplateId,resultHandler); - } - } - - public static class deleteWorkflow<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteWorkflow_args, Void> { - public deleteWorkflow() { - super("deleteWorkflow"); - } - - public deleteWorkflow_args getEmptyArgsInstance() { - return new deleteWorkflow_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) { - deleteWorkflow_result result = new deleteWorkflow_result(); - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - deleteWorkflow_result result = new deleteWorkflow_result(); + deleteUserStoragePreference_result result = new deleteUserStoragePreference_result(); if (e instanceof org.apache.airavata.model.error.InvalidRequestException) { result.ire = (org.apache.airavata.model.
<TRUNCATED>
