You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2017/03/07 22:16:40 UTC
[7/9] airavata git commit: adding isExists methods to sharing service
http://git-wip-us.apache.org/repos/asf/airavata/blob/536cca16/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java
----------------------------------------------------------------------
diff --git a/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java b/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java
index 2fc5691..eb3d3be 100644
--- a/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java
+++ b/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java
@@ -54,6 +54,13 @@ public class SharingRegistryService {
public boolean updateDomain(org.apache.airavata.sharing.registry.models.Domain domain) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
/**
+ * <p>API method to check Domain Exists</p>
+ *
+ * @param domainId
+ */
+ public boolean isDomainExists(String domainId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
+
+ /**
* <p>API method to delete domain</p>
*
* @param domainId
@@ -90,6 +97,14 @@ public class SharingRegistryService {
public boolean updatedUser(org.apache.airavata.sharing.registry.models.User user) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
/**
+ * <p>API method to check User Exists</p>
+ *
+ * @param domainId
+ * @param userId
+ */
+ public boolean isUserExists(String domainId, String userId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
+
+ /**
* <p>API method to delete user</p>
*
* @param domainId
@@ -132,6 +147,14 @@ public class SharingRegistryService {
public boolean updateGroup(org.apache.airavata.sharing.registry.models.UserGroup group) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
/**
+ * <p>API method to check Group Exists</p>
+ *
+ * @param domainId
+ * @param groupId
+ */
+ public boolean isGroupExists(String domainId, String groupId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
+
+ /**
* <p>API method to delete a group</p>
*
* @param domainId
@@ -227,6 +250,14 @@ public class SharingRegistryService {
public boolean updateEntityType(org.apache.airavata.sharing.registry.models.EntityType entityType) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
/**
+ * <p>API method to check EntityType Exists</p>
+ *
+ * @param domainId
+ * @param entityTypeId
+ */
+ public boolean isEntityTypeExists(String domainId, String entityTypeId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
+
+ /**
* <p>API method to delete entity type</p>
*
* @param domainId
@@ -266,6 +297,14 @@ public class SharingRegistryService {
public boolean updateEntity(org.apache.airavata.sharing.registry.models.Entity entity) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
/**
+ * <p>API method to check Entity Exists</p>
+ *
+ * @param domainId
+ * @param entityId
+ */
+ public boolean isEntityExists(String domainId, String entityId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
+
+ /**
* <p>API method to delete entity</p>
*
* @param domainId
@@ -325,6 +364,14 @@ public class SharingRegistryService {
public boolean updatePermissionType(org.apache.airavata.sharing.registry.models.PermissionType permissionType) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
/**
+ * <p>API method to check Permission Exists</p>
+ *
+ * @param dimainId
+ * @param permissionId
+ */
+ public boolean isPermissionExists(String dimainId, String permissionId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException;
+
+ /**
* <p>API method to delete permission type</p>
*
* @param domainId
@@ -409,6 +456,8 @@ public class SharingRegistryService {
public void updateDomain(org.apache.airavata.sharing.registry.models.Domain domain, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void isDomainExists(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void deleteDomain(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getDomain(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -419,6 +468,8 @@ public class SharingRegistryService {
public void updatedUser(org.apache.airavata.sharing.registry.models.User user, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void isUserExists(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void deleteUser(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getUser(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -429,6 +480,8 @@ public class SharingRegistryService {
public void updateGroup(org.apache.airavata.sharing.registry.models.UserGroup group, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void isGroupExists(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void deleteGroup(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getGroup(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -451,6 +504,8 @@ public class SharingRegistryService {
public void updateEntityType(org.apache.airavata.sharing.registry.models.EntityType entityType, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void isEntityTypeExists(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void deleteEntityType(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getEntityType(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -461,6 +516,8 @@ public class SharingRegistryService {
public void updateEntity(org.apache.airavata.sharing.registry.models.Entity entity, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void isEntityExists(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void deleteEntity(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getEntity(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -475,6 +532,8 @@ public class SharingRegistryService {
public void updatePermissionType(org.apache.airavata.sharing.registry.models.PermissionType permissionType, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void isPermissionExists(String dimainId, String permissionId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void deletePermissionType(String domainId, String permissionTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void getPermissionType(String domainId, String permissionTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -565,6 +624,32 @@ public class SharingRegistryService {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateDomain failed: unknown result");
}
+ public boolean isDomainExists(String domainId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ send_isDomainExists(domainId);
+ return recv_isDomainExists();
+ }
+
+ public void send_isDomainExists(String domainId) throws org.apache.thrift.TException
+ {
+ isDomainExists_args args = new isDomainExists_args();
+ args.setDomainId(domainId);
+ sendBase("isDomainExists", args);
+ }
+
+ public boolean recv_isDomainExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ isDomainExists_result result = new isDomainExists_result();
+ receiveBase(result, "isDomainExists");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.sre != null) {
+ throw result.sre;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isDomainExists failed: unknown result");
+ }
+
public boolean deleteDomain(String domainId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
{
send_deleteDomain(domainId);
@@ -696,6 +781,33 @@ public class SharingRegistryService {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updatedUser failed: unknown result");
}
+ public boolean isUserExists(String domainId, String userId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ send_isUserExists(domainId, userId);
+ return recv_isUserExists();
+ }
+
+ public void send_isUserExists(String domainId, String userId) throws org.apache.thrift.TException
+ {
+ isUserExists_args args = new isUserExists_args();
+ args.setDomainId(domainId);
+ args.setUserId(userId);
+ sendBase("isUserExists", args);
+ }
+
+ public boolean recv_isUserExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ isUserExists_result result = new isUserExists_result();
+ receiveBase(result, "isUserExists");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.sre != null) {
+ throw result.sre;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isUserExists failed: unknown result");
+ }
+
public boolean deleteUser(String domainId, String userId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
{
send_deleteUser(domainId, userId);
@@ -830,6 +942,33 @@ public class SharingRegistryService {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateGroup failed: unknown result");
}
+ public boolean isGroupExists(String domainId, String groupId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ send_isGroupExists(domainId, groupId);
+ return recv_isGroupExists();
+ }
+
+ public void send_isGroupExists(String domainId, String groupId) throws org.apache.thrift.TException
+ {
+ isGroupExists_args args = new isGroupExists_args();
+ args.setDomainId(domainId);
+ args.setGroupId(groupId);
+ sendBase("isGroupExists", args);
+ }
+
+ public boolean recv_isGroupExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ isGroupExists_result result = new isGroupExists_result();
+ receiveBase(result, "isGroupExists");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.sre != null) {
+ throw result.sre;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isGroupExists failed: unknown result");
+ }
+
public boolean deleteGroup(String domainId, String groupId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
{
send_deleteGroup(domainId, groupId);
@@ -1131,6 +1270,33 @@ public class SharingRegistryService {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateEntityType failed: unknown result");
}
+ public boolean isEntityTypeExists(String domainId, String entityTypeId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ send_isEntityTypeExists(domainId, entityTypeId);
+ return recv_isEntityTypeExists();
+ }
+
+ public void send_isEntityTypeExists(String domainId, String entityTypeId) throws org.apache.thrift.TException
+ {
+ isEntityTypeExists_args args = new isEntityTypeExists_args();
+ args.setDomainId(domainId);
+ args.setEntityTypeId(entityTypeId);
+ sendBase("isEntityTypeExists", args);
+ }
+
+ public boolean recv_isEntityTypeExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ isEntityTypeExists_result result = new isEntityTypeExists_result();
+ receiveBase(result, "isEntityTypeExists");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.sre != null) {
+ throw result.sre;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isEntityTypeExists failed: unknown result");
+ }
+
public boolean deleteEntityType(String domainId, String entityTypeId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
{
send_deleteEntityType(domainId, entityTypeId);
@@ -1265,6 +1431,33 @@ public class SharingRegistryService {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateEntity failed: unknown result");
}
+ public boolean isEntityExists(String domainId, String entityId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ send_isEntityExists(domainId, entityId);
+ return recv_isEntityExists();
+ }
+
+ public void send_isEntityExists(String domainId, String entityId) throws org.apache.thrift.TException
+ {
+ isEntityExists_args args = new isEntityExists_args();
+ args.setDomainId(domainId);
+ args.setEntityId(entityId);
+ sendBase("isEntityExists", args);
+ }
+
+ public boolean recv_isEntityExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ isEntityExists_result result = new isEntityExists_result();
+ receiveBase(result, "isEntityExists");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.sre != null) {
+ throw result.sre;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isEntityExists failed: unknown result");
+ }
+
public boolean deleteEntity(String domainId, String entityId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
{
send_deleteEntity(domainId, entityId);
@@ -1457,6 +1650,33 @@ public class SharingRegistryService {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updatePermissionType failed: unknown result");
}
+ public boolean isPermissionExists(String dimainId, String permissionId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ send_isPermissionExists(dimainId, permissionId);
+ return recv_isPermissionExists();
+ }
+
+ public void send_isPermissionExists(String dimainId, String permissionId) throws org.apache.thrift.TException
+ {
+ isPermissionExists_args args = new isPermissionExists_args();
+ args.setDimainId(dimainId);
+ args.setPermissionId(permissionId);
+ sendBase("isPermissionExists", args);
+ }
+
+ public boolean recv_isPermissionExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
+ {
+ isPermissionExists_result result = new isPermissionExists_result();
+ receiveBase(result, "isPermissionExists");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.sre != null) {
+ throw result.sre;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isPermissionExists failed: unknown result");
+ }
+
public boolean deletePermissionType(String domainId, String permissionTypeId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException
{
send_deletePermissionType(domainId, permissionTypeId);
@@ -1768,6 +1988,38 @@ public class SharingRegistryService {
}
}
+ public void isDomainExists(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ isDomainExists_call method_call = new isDomainExists_call(domainId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class isDomainExists_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String domainId;
+ public isDomainExists_call(String domainId, 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.domainId = domainId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isDomainExists", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ isDomainExists_args args = new isDomainExists_args();
+ args.setDomainId(domainId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, 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_isDomainExists();
+ }
+ }
+
public void deleteDomain(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
deleteDomain_call method_call = new deleteDomain_call(domainId, resultHandler, this, ___protocolFactory, ___transport);
@@ -1931,6 +2183,41 @@ public class SharingRegistryService {
}
}
+ public void isUserExists(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ isUserExists_call method_call = new isUserExists_call(domainId, userId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class isUserExists_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String domainId;
+ private String userId;
+ public isUserExists_call(String domainId, String userId, 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.domainId = domainId;
+ this.userId = userId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isUserExists", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ isUserExists_args args = new isUserExists_args();
+ args.setDomainId(domainId);
+ args.setUserId(userId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, 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_isUserExists();
+ }
+ }
+
public void deleteUser(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
deleteUser_call method_call = new deleteUser_call(domainId, userId, resultHandler, this, ___protocolFactory, ___transport);
@@ -2103,6 +2390,41 @@ public class SharingRegistryService {
}
}
+ public void isGroupExists(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ isGroupExists_call method_call = new isGroupExists_call(domainId, groupId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class isGroupExists_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String domainId;
+ private String groupId;
+ public isGroupExists_call(String domainId, String groupId, 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.domainId = domainId;
+ this.groupId = groupId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isGroupExists", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ isGroupExists_args args = new isGroupExists_args();
+ args.setDomainId(domainId);
+ args.setGroupId(groupId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, 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_isGroupExists();
+ }
+ }
+
public void deleteGroup(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
deleteGroup_call method_call = new deleteGroup_call(domainId, groupId, resultHandler, this, ___protocolFactory, ___transport);
@@ -2509,6 +2831,41 @@ public class SharingRegistryService {
}
}
+ public void isEntityTypeExists(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ isEntityTypeExists_call method_call = new isEntityTypeExists_call(domainId, entityTypeId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class isEntityTypeExists_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String domainId;
+ private String entityTypeId;
+ public isEntityTypeExists_call(String domainId, String entityTypeId, 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.domainId = domainId;
+ this.entityTypeId = entityTypeId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isEntityTypeExists", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ isEntityTypeExists_args args = new isEntityTypeExists_args();
+ args.setDomainId(domainId);
+ args.setEntityTypeId(entityTypeId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, 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_isEntityTypeExists();
+ }
+ }
+
public void deleteEntityType(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
deleteEntityType_call method_call = new deleteEntityType_call(domainId, entityTypeId, resultHandler, this, ___protocolFactory, ___transport);
@@ -2681,6 +3038,41 @@ public class SharingRegistryService {
}
}
+ public void isEntityExists(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ isEntityExists_call method_call = new isEntityExists_call(domainId, entityId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class isEntityExists_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String domainId;
+ private String entityId;
+ public isEntityExists_call(String domainId, String entityId, 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.domainId = domainId;
+ this.entityId = entityId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isEntityExists", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ isEntityExists_args args = new isEntityExists_args();
+ args.setDomainId(domainId);
+ args.setEntityId(entityId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, 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_isEntityExists();
+ }
+ }
+
public void deleteEntity(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
deleteEntity_call method_call = new deleteEntity_call(domainId, entityId, resultHandler, this, ___protocolFactory, ___transport);
@@ -2764,7 +3156,6 @@ public class SharingRegistryService {
private List<org.apache.airavata.sharing.registry.models.SearchCriteria> filters;
private int offset;
private int limit;
-
public searchEntities_call(String domainId, String userId, List<org.apache.airavata.sharing.registry.models.SearchCriteria> filters, int offset, int limit, 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.domainId = domainId;
@@ -2936,6 +3327,41 @@ public class SharingRegistryService {
}
}
+ public void isPermissionExists(String dimainId, String permissionId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ isPermissionExists_call method_call = new isPermissionExists_call(dimainId, permissionId, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class isPermissionExists_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String dimainId;
+ private String permissionId;
+ public isPermissionExists_call(String dimainId, String permissionId, 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.dimainId = dimainId;
+ this.permissionId = permissionId;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isPermissionExists", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ isPermissionExists_args args = new isPermissionExists_args();
+ args.setDimainId(dimainId);
+ args.setPermissionId(permissionId);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, 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_isPermissionExists();
+ }
+ }
+
public void deletePermissionType(String domainId, String permissionTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
deletePermissionType_call method_call = new deletePermissionType_call(domainId, permissionTypeId, resultHandler, this, ___protocolFactory, ___transport);
@@ -3270,16 +3696,19 @@ public class SharingRegistryService {
private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
processMap.put("createDomain", new createDomain());
processMap.put("updateDomain", new updateDomain());
+ processMap.put("isDomainExists", new isDomainExists());
processMap.put("deleteDomain", new deleteDomain());
processMap.put("getDomain", new getDomain());
processMap.put("getDomains", new getDomains());
processMap.put("createUser", new createUser());
processMap.put("updatedUser", new updatedUser());
+ processMap.put("isUserExists", new isUserExists());
processMap.put("deleteUser", new deleteUser());
processMap.put("getUser", new getUser());
processMap.put("getUsers", new getUsers());
processMap.put("createGroup", new createGroup());
processMap.put("updateGroup", new updateGroup());
+ processMap.put("isGroupExists", new isGroupExists());
processMap.put("deleteGroup", new deleteGroup());
processMap.put("getGroup", new getGroup());
processMap.put("getGroups", new getGroups());
@@ -3291,11 +3720,13 @@ public class SharingRegistryService {
processMap.put("removeChildGroupFromParentGroup", new removeChildGroupFromParentGroup());
processMap.put("createEntityType", new createEntityType());
processMap.put("updateEntityType", new updateEntityType());
+ processMap.put("isEntityTypeExists", new isEntityTypeExists());
processMap.put("deleteEntityType", new deleteEntityType());
processMap.put("getEntityType", new getEntityType());
processMap.put("getEntityTypes", new getEntityTypes());
processMap.put("createEntity", new createEntity());
processMap.put("updateEntity", new updateEntity());
+ processMap.put("isEntityExists", new isEntityExists());
processMap.put("deleteEntity", new deleteEntity());
processMap.put("getEntity", new getEntity());
processMap.put("searchEntities", new searchEntities());
@@ -3303,6 +3734,7 @@ public class SharingRegistryService {
processMap.put("getListOfSharedGroups", new getListOfSharedGroups());
processMap.put("createPermissionType", new createPermissionType());
processMap.put("updatePermissionType", new updatePermissionType());
+ processMap.put("isPermissionExists", new isPermissionExists());
processMap.put("deletePermissionType", new deletePermissionType());
processMap.put("getPermissionType", new getPermissionType());
processMap.put("getPermissionTypes", new getPermissionTypes());
@@ -3363,6 +3795,31 @@ public class SharingRegistryService {
}
}
+ public static class isDomainExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isDomainExists_args> {
+ public isDomainExists() {
+ super("isDomainExists");
+ }
+
+ public isDomainExists_args getEmptyArgsInstance() {
+ return new isDomainExists_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public isDomainExists_result getResult(I iface, isDomainExists_args args) throws org.apache.thrift.TException {
+ isDomainExists_result result = new isDomainExists_result();
+ try {
+ result.success = iface.isDomainExists(args.domainId);
+ result.setSuccessIsSet(true);
+ } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) {
+ result.sre = sre;
+ }
+ return result;
+ }
+ }
+
public static class deleteDomain<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteDomain_args> {
public deleteDomain() {
super("deleteDomain");
@@ -3485,6 +3942,31 @@ public class SharingRegistryService {
}
}
+ public static class isUserExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isUserExists_args> {
+ public isUserExists() {
+ super("isUserExists");
+ }
+
+ public isUserExists_args getEmptyArgsInstance() {
+ return new isUserExists_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public isUserExists_result getResult(I iface, isUserExists_args args) throws org.apache.thrift.TException {
+ isUserExists_result result = new isUserExists_result();
+ try {
+ result.success = iface.isUserExists(args.domainId, args.userId);
+ result.setSuccessIsSet(true);
+ } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) {
+ result.sre = sre;
+ }
+ return result;
+ }
+ }
+
public static class deleteUser<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteUser_args> {
public deleteUser() {
super("deleteUser");
@@ -3607,6 +4089,31 @@ public class SharingRegistryService {
}
}
+ public static class isGroupExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isGroupExists_args> {
+ public isGroupExists() {
+ super("isGroupExists");
+ }
+
+ public isGroupExists_args getEmptyArgsInstance() {
+ return new isGroupExists_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public isGroupExists_result getResult(I iface, isGroupExists_args args) throws org.apache.thrift.TException {
+ isGroupExists_result result = new isGroupExists_result();
+ try {
+ result.success = iface.isGroupExists(args.domainId, args.groupId);
+ result.setSuccessIsSet(true);
+ } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) {
+ result.sre = sre;
+ }
+ return result;
+ }
+ }
+
public static class deleteGroup<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteGroup_args> {
public deleteGroup() {
super("deleteGroup");
@@ -3873,6 +4380,31 @@ public class SharingRegistryService {
}
}
+ public static class isEntityTypeExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isEntityTypeExists_args> {
+ public isEntityTypeExists() {
+ super("isEntityTypeExists");
+ }
+
+ public isEntityTypeExists_args getEmptyArgsInstance() {
+ return new isEntityTypeExists_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public isEntityTypeExists_result getResult(I iface, isEntityTypeExists_args args) throws org.apache.thrift.TException {
+ isEntityTypeExists_result result = new isEntityTypeExists_result();
+ try {
+ result.success = iface.isEntityTypeExists(args.domainId, args.entityTypeId);
+ result.setSuccessIsSet(true);
+ } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) {
+ result.sre = sre;
+ }
+ return result;
+ }
+ }
+
public static class deleteEntityType<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteEntityType_args> {
public deleteEntityType() {
super("deleteEntityType");
@@ -3995,6 +4527,31 @@ public class SharingRegistryService {
}
}
+ public static class isEntityExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isEntityExists_args> {
+ public isEntityExists() {
+ super("isEntityExists");
+ }
+
+ public isEntityExists_args getEmptyArgsInstance() {
+ return new isEntityExists_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public isEntityExists_result getResult(I iface, isEntityExists_args args) throws org.apache.thrift.TException {
+ isEntityExists_result result = new isEntityExists_result();
+ try {
+ result.success = iface.isEntityExists(args.domainId, args.entityId);
+ result.setSuccessIsSet(true);
+ } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) {
+ result.sre = sre;
+ }
+ return result;
+ }
+ }
+
public static class deleteEntity<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteEntity_args> {
public deleteEntity() {
super("deleteEntity");
@@ -4165,6 +4722,31 @@ public class SharingRegistryService {
}
}
+ public static class isPermissionExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isPermissionExists_args> {
+ public isPermissionExists() {
+ super("isPermissionExists");
+ }
+
+ public isPermissionExists_args getEmptyArgsInstance() {
+ return new isPermissionExists_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public isPermissionExists_result getResult(I iface, isPermissionExists_args args) throws org.apache.thrift.TException {
+ isPermissionExists_result result = new isPermissionExists_result();
+ try {
+ result.success = iface.isPermissionExists(args.dimainId, args.permissionId);
+ result.setSuccessIsSet(true);
+ } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) {
+ result.sre = sre;
+ }
+ return result;
+ }
+ }
+
public static class deletePermissionType<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deletePermissionType_args> {
public deletePermissionType() {
super("deletePermissionType");
@@ -4378,16 +4960,19 @@ public class SharingRegistryService {
private static <I extends AsyncIface> Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) {
processMap.put("createDomain", new createDomain());
processMap.put("updateDomain", new updateDomain());
+ processMap.put("isDomainExists", new isDomainExists());
processMap.put("deleteDomain", new deleteDomain());
processMap.put("getDomain", new getDomain());
processMap.put("getDomains", new getDomains());
processMap.put("createUser", new createUser());
processMap.put("updatedUser", new updatedUser());
+ processMap.put("isUserExists", new isUserExists());
processMap.put("deleteUser", new deleteUser());
processMap.put("getUser", new getUser());
processMap.put("getUsers", new getUsers());
processMap.put("createGroup", new createGroup());
processMap.put("updateGroup", new updateGroup());
+ processMap.put("isGroupExists", new isGroupExists());
processMap.put("deleteGroup", new deleteGroup());
processMap.put("getGroup", new getGroup());
processMap.put("getGroups", new getGroups());
@@ -4399,11 +4984,13 @@ public class SharingRegistryService {
processMap.put("removeChildGroupFromParentGroup", new removeChildGroupFromParentGroup());
processMap.put("createEntityType", new createEntityType());
processMap.put("updateEntityType", new updateEntityType());
+ processMap.put("isEntityTypeExists", new isEntityTypeExists());
processMap.put("deleteEntityType", new deleteEntityType());
processMap.put("getEntityType", new getEntityType());
processMap.put("getEntityTypes", new getEntityTypes());
processMap.put("createEntity", new createEntity());
processMap.put("updateEntity", new updateEntity());
+ processMap.put("isEntityExists", new isEntityExists());
processMap.put("deleteEntity", new deleteEntity());
processMap.put("getEntity", new getEntity());
processMap.put("searchEntities", new searchEntities());
@@ -4411,6 +4998,7 @@ public class SharingRegistryService {
processMap.put("getListOfSharedGroups", new getListOfSharedGroups());
processMap.put("createPermissionType", new createPermissionType());
processMap.put("updatePermissionType", new updatePermissionType());
+ processMap.put("isPermissionExists", new isPermissionExists());
processMap.put("deletePermissionType", new deletePermissionType());
processMap.put("getPermissionType", new getPermissionType());
processMap.put("getPermissionTypes", new getPermissionTypes());
@@ -4537,6 +5125,64 @@ public class SharingRegistryService {
}
}
+ public static class isDomainExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isDomainExists_args, Boolean> {
+ public isDomainExists() {
+ super("isDomainExists");
+ }
+
+ public isDomainExists_args getEmptyArgsInstance() {
+ return new isDomainExists_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) {
+ isDomainExists_result result = new isDomainExists_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ isDomainExists_result result = new isDomainExists_result();
+ if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
+ result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
+ result.setSreIsSet(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, isDomainExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.isDomainExists(args.domainId,resultHandler);
+ }
+ }
+
public static class deleteDomain<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteDomain_args, Boolean> {
public deleteDomain() {
super("deleteDomain");
@@ -4824,6 +5470,64 @@ public class SharingRegistryService {
}
}
+ public static class isUserExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isUserExists_args, Boolean> {
+ public isUserExists() {
+ super("isUserExists");
+ }
+
+ public isUserExists_args getEmptyArgsInstance() {
+ return new isUserExists_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) {
+ isUserExists_result result = new isUserExists_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ isUserExists_result result = new isUserExists_result();
+ if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
+ result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
+ result.setSreIsSet(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, isUserExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.isUserExists(args.domainId, args.userId,resultHandler);
+ }
+ }
+
public static class deleteUser<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUser_args, Boolean> {
public deleteUser() {
super("deleteUser");
@@ -5111,6 +5815,64 @@ public class SharingRegistryService {
}
}
+ public static class isGroupExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isGroupExists_args, Boolean> {
+ public isGroupExists() {
+ super("isGroupExists");
+ }
+
+ public isGroupExists_args getEmptyArgsInstance() {
+ return new isGroupExists_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) {
+ isGroupExists_result result = new isGroupExists_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ isGroupExists_result result = new isGroupExists_result();
+ if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
+ result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
+ result.setSreIsSet(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, isGroupExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.isGroupExists(args.domainId, args.groupId,resultHandler);
+ }
+ }
+
public static class deleteGroup<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteGroup_args, Boolean> {
public deleteGroup() {
super("deleteGroup");
@@ -5738,6 +6500,64 @@ public class SharingRegistryService {
}
}
+ public static class isEntityTypeExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isEntityTypeExists_args, Boolean> {
+ public isEntityTypeExists() {
+ super("isEntityTypeExists");
+ }
+
+ public isEntityTypeExists_args getEmptyArgsInstance() {
+ return new isEntityTypeExists_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) {
+ isEntityTypeExists_result result = new isEntityTypeExists_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ isEntityTypeExists_result result = new isEntityTypeExists_result();
+ if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
+ result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
+ result.setSreIsSet(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, isEntityTypeExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.isEntityTypeExists(args.domainId, args.entityTypeId,resultHandler);
+ }
+ }
+
public static class deleteEntityType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteEntityType_args, Boolean> {
public deleteEntityType() {
super("deleteEntityType");
@@ -6025,6 +6845,64 @@ public class SharingRegistryService {
}
}
+ public static class isEntityExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isEntityExists_args, Boolean> {
+ public isEntityExists() {
+ super("isEntityExists");
+ }
+
+ public isEntityExists_args getEmptyArgsInstance() {
+ return new isEntityExists_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) {
+ isEntityExists_result result = new isEntityExists_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ isEntityExists_result result = new isEntityExists_result();
+ if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
+ result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
+ result.setSreIsSet(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, isEntityExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.isEntityExists(args.domainId, args.entityId,resultHandler);
+ }
+ }
+
public static class deleteEntity<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteEntity_args, Boolean> {
public deleteEntity() {
super("deleteEntity");
@@ -6193,7 +7071,7 @@ public class SharingRegistryService {
}
public void start(I iface, searchEntities_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.Entity>> resultHandler) throws TException {
- iface.searchEntities(args.domainId, args.userId, args.filters, args.offset, args.limit, resultHandler);
+ iface.searchEntities(args.domainId, args.userId, args.filters, args.offset, args.limit,resultHandler);
}
}
@@ -6426,20 +7304,20 @@ public class SharingRegistryService {
}
}
- public static class deletePermissionType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deletePermissionType_args, Boolean> {
- public deletePermissionType() {
- super("deletePermissionType");
+ public static class isPermissionExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isPermissionExists_args, Boolean> {
+ public isPermissionExists() {
+ super("isPermissionExists");
}
- public deletePermissionType_args getEmptyArgsInstance() {
- return new deletePermissionType_args();
+ public isPermissionExists_args getEmptyArgsInstance() {
+ return new isPermissionExists_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) {
- deletePermissionType_result result = new deletePermissionType_result();
+ isPermissionExists_result result = new isPermissionExists_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -6453,121 +7331,7 @@ public class SharingRegistryService {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- deletePermissionType_result result = new deletePermissionType_result();
- if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
- result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
- result.setSreIsSet(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, deletePermissionType_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.deletePermissionType(args.domainId, args.permissionTypeId,resultHandler);
- }
- }
-
- public static class getPermissionType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPermissionType_args, org.apache.airavata.sharing.registry.models.PermissionType> {
- public getPermissionType() {
- super("getPermissionType");
- }
-
- public getPermissionType_args getEmptyArgsInstance() {
- return new getPermissionType_args();
- }
-
- public AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType>() {
- public void onComplete(org.apache.airavata.sharing.registry.models.PermissionType o) {
- getPermissionType_result result = new getPermissionType_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;
- getPermissionType_result result = new getPermissionType_result();
- if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
- result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
- result.setSreIsSet(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, getPermissionType_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType> resultHandler) throws TException {
- iface.getPermissionType(args.domainId, args.permissionTypeId,resultHandler);
- }
- }
-
- public static class getPermissionTypes<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPermissionTypes_args, List<org.apache.airavata.sharing.registry.models.PermissionType>> {
- public getPermissionTypes() {
- super("getPermissionTypes");
- }
-
- public getPermissionTypes_args getEmptyArgsInstance() {
- return new getPermissionTypes_args();
- }
-
- public AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>>() {
- public void onComplete(List<org.apache.airavata.sharing.registry.models.PermissionType> o) {
- getPermissionTypes_result result = new getPermissionTypes_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;
- getPermissionTypes_result result = new getPermissionTypes_result();
+ isPermissionExists_result result = new isPermissionExists_result();
if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
result.setSreIsSet(true);
@@ -6593,25 +7357,25 @@ public class SharingRegistryService {
return false;
}
- public void start(I iface, getPermissionTypes_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>> resultHandler) throws TException {
- iface.getPermissionTypes(args.domainId, args.offset, args.limit,resultHandler);
+ public void start(I iface, isPermissionExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.isPermissionExists(args.dimainId, args.permissionId,resultHandler);
}
}
- public static class shareEntityWithUsers<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, shareEntityWithUsers_args, Boolean> {
- public shareEntityWithUsers() {
- super("shareEntityWithUsers");
+ public static class deletePermissionType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deletePermissionType_args, Boolean> {
+ public deletePermissionType() {
+ super("deletePermissionType");
}
- public shareEntityWithUsers_args getEmptyArgsInstance() {
- return new shareEntityWithUsers_args();
+ public deletePermissionType_args getEmptyArgsInstance() {
+ return new deletePermissionType_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) {
- shareEntityWithUsers_result result = new shareEntityWithUsers_result();
+ deletePermissionType_result result = new deletePermissionType_result();
result.success = o;
result.setSuccessIsSet(true);
try {
@@ -6625,7 +7389,7 @@ public class SharingRegistryService {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- shareEntityWithUsers_result result = new shareEntityWithUsers_result();
+ deletePermissionType_result result = new deletePermissionType_result();
if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
result.setSreIsSet(true);
@@ -6651,27 +7415,26 @@ public class SharingRegistryService {
return false;
}
- public void start(I iface, shareEntityWithUsers_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
- iface.shareEntityWithUsers(args.domainId, args.entityId, args.userList, args.perssionTypeId, args.cascadePermission,resultHandler);
+ public void start(I iface, deletePermissionType_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.deletePermissionType(args.domainId, args.permissionTypeId,resultHandler);
}
}
- public static class revokeEntitySharingFromUsers<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, revokeEntitySharingFromUsers_args, Boolean> {
- public revokeEntitySharingFromUsers() {
- super("revokeEntitySharingFromUsers");
+ public static class getPermissionType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPermissionType_args, org.apache.airavata.sharing.registry.models.PermissionType> {
+ public getPermissionType() {
+ super("getPermissionType");
}
- public revokeEntitySharingFromUsers_args getEmptyArgsInstance() {
- return new revokeEntitySharingFromUsers_args();
+ public getPermissionType_args getEmptyArgsInstance() {
+ return new getPermissionType_args();
}
- public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ public AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new AsyncMethodCallback<Boolean>() {
- public void onComplete(Boolean o) {
- revokeEntitySharingFromUsers_result result = new revokeEntitySharingFromUsers_result();
+ return new AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType>() {
+ public void onComplete(org.apache.airavata.sharing.registry.models.PermissionType o) {
+ getPermissionType_result result = new getPermissionType_result();
result.success = o;
- result.setSuccessIsSet(true);
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@@ -6683,7 +7446,180 @@ public class SharingRegistryService {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
- revokeEntitySharingFromUsers_result result = new revokeEntitySharingFromUsers_result();
+ getPermissionType_result result = new getPermissionType_result();
+ if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
+ result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
+ result.setSreIsSet(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, getPermissionType_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType> resultHandler) throws TException {
+ iface.getPermissionType(args.domainId, args.permissionTypeId,resultHandler);
+ }
+ }
+
+ public static class getPermissionTypes<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPermissionTypes_args, List<org.apache.airavata.sharing.registry.models.PermissionType>> {
+ public getPermissionTypes() {
+ super("getPermissionTypes");
+ }
+
+ public getPermissionTypes_args getEmptyArgsInstance() {
+ return new getPermissionTypes_args();
+ }
+
+ public AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>>() {
+ public void onComplete(List<org.apache.airavata.sharing.registry.models.PermissionType> o) {
+ getPermissionTypes_result result = new getPermissionTypes_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;
+ getPermissionTypes_result result = new getPermissionTypes_result();
+ if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
+ result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
+ result.setSreIsSet(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, getPermissionTypes_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>> resultHandler) throws TException {
+ iface.getPermissionTypes(args.domainId, args.offset, args.limit,resultHandler);
+ }
+ }
+
+ public static class shareEntityWithUsers<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, shareEntityWithUsers_args, Boolean> {
+ public shareEntityWithUsers() {
+ super("shareEntityWithUsers");
+ }
+
+ public shareEntityWithUsers_args getEmptyArgsInstance() {
+ return new shareEntityWithUsers_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) {
+ shareEntityWithUsers_result result = new shareEntityWithUsers_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ shareEntityWithUsers_result result = new shareEntityWithUsers_result();
+ if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
+ result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
+ result.setSreIsSet(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, shareEntityWithUsers_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException {
+ iface.shareEntityWithUsers(args.domainId, args.entityId, args.userList, args.perssionTypeId, args.cascadePermission,resultHandler);
+ }
+ }
+
+ public static class revokeEntitySharingFromUsers<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, revokeEntitySharingFromUsers_args, Boolean> {
+ public revokeEntitySharingFromUsers() {
+ super("revokeEntitySharingFromUsers");
+ }
+
+ public revokeEntitySharingFromUsers_args getEmptyArgsInstance() {
+ return new revokeEntitySharingFromUsers_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) {
+ revokeEntitySharingFromUsers_result result = new revokeEntitySharingFromUsers_result();
+ result.success = o;
+ result.setSuccessIsSet(true);
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ revokeEntitySharingFromUsers_result result = new revokeEntitySharingFromUsers_result();
if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) {
result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e;
result.setSreIsSet(true);
@@ -8544,15 +9480,15 @@ public class SharingRegistryService {
}
- public static class deleteDomain_args implements org.apache.thrift.TBase<deleteDomain_args, deleteDomain_args._Fields>, java.io.Serializable, Cloneable, Comparable<deleteDomain_args> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("deleteDomain_args");
+ public static class isDomainExists_args implements org.apache.thrift.TBase<isDomainExists_args, isDomainExists_args._Fields>, java.io.Serializable, Cloneable, Comparable<isDomainExists_args> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("isDomainExists_args");
private static final org.apache.thrift.protocol.TField DOMAIN_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("domainId", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
- schemes.put(StandardScheme.class, new deleteDomain_argsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new deleteDomain_argsTupleSchemeFactory());
+ schemes.put(StandardScheme.class, new isDomainExists_argsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new isDomainExists_argsTupleSchemeFactory());
}
public String domainId; // required
@@ -8622,13 +9558,13 @@ public class SharingRegistryService {
tmpMap.put(_Fields.DOMAIN_ID, new org.apache.thrift.meta_data.FieldMetaData("domainId", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(deleteDomain_args.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isDomainExists_args.class, metaDataMap);
}
- public deleteDomain_args() {
+ public isDomainExists_args() {
}
- public deleteDomain_args(
+ public isDomainExists_args(
String domainId)
{
this();
@@ -8638,14 +9574,14 @@ public class SharingRegistryService {
/**
* Performs a deep copy on <i>other</i>.
*/
- public deleteDomain_args(deleteDomain_args other) {
+ public isDomainExists_args(isDomainExists_args other) {
if (other.isSetDomainId()) {
this.domainId = other.domainId;
}
}
- public deleteDomain_args deepCopy() {
- return new deleteDomain_args(this);
+ public isDomainExists_args deepCopy() {
+ return new isDomainExists_args(this);
}
@Override
@@ -8657,7 +9593,7 @@ public class SharingRegistryService {
return this.domainId;
}
- public deleteDomain_args setDomainId(String domainId) {
+ public isDomainExists_args setDomainId(String domainId) {
this.domainId = domainId;
return this;
}
@@ -8716,12 +9652,12 @@ public class SharingRegistryService {
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof deleteDomain_args)
- return this.equals((deleteDomain_args)that);
+ if (that instanceof isDomainExists_args)
+ return this.equals((isDomainExists_args)that);
return false;
}
- public boolean equals(deleteDomain_args that) {
+ public boolean equals(isDomainExists_args that) {
if (that == null)
return false;
@@ -8750,7 +9686,7 @@ public class SharingRegistryService {
}
@Override
- public int compareTo(deleteDomain_args other) {
+ public int compareTo(isDomainExists_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
@@ -8784,7 +9720,7 @@ public class SharingRegistryService {
@Override
public String toString() {
- StringBuilder sb = new StringBuilder("deleteDomain_args(");
+ StringBuilder sb = new StringBuilder("isDomainExists_args(");
boolean first = true;
sb.append("domainId:");
@@ -8822,15 +9758,15 @@ public class SharingRegistryService {
}
}
- private static class deleteDomain_argsStandardSchemeFactory implements SchemeFactory {
- public deleteDomain_argsStandardScheme getScheme() {
- return new deleteDomain_argsStandardScheme();
+ private static class isDomainExists_argsStandardSchemeFactory implements SchemeFactory {
+ public isDomainExists_argsStandardScheme getScheme() {
+ return new isDomainExists_argsStandardScheme();
}
}
- private static class deleteDomain_argsStandardScheme extends StandardScheme<deleteDomain_args> {
+ private static class isDomainExists_argsStandardScheme extends StandardScheme<isDomainExists_args> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, deleteDomain_args struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol iprot, isDomainExists_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@@ -8859,7 +9795,7 @@ public class SharingRegistryService {
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot, deleteDomain_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol oprot, isDomainExists_args struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -8874,22 +9810,22 @@ public class SharingRegistryService {
}
- private static class deleteDomain_argsTupleSchemeFactory implements SchemeFactory {
-
<TRUNCATED>