Package org.apache.hadoop.hdfs.server.federation.router.async

Class RouterAsyncUserProtocol

java.lang.Object

org.apache.hadoop.hdfs.server.federation.router.RouterUserProtocol

org.apache.hadoop.hdfs.server.federation.router.async.RouterAsyncUserProtocol

All Implemented Interfaces:

org.apache.hadoop.security.RefreshUserMappingsProtocol, org.apache.hadoop.tools.GetUserMappingsProtocol

public class RouterAsyncUserProtocol
extends RouterUserProtocol

Module that implements all the asynchronous RPC calls in RefreshUserMappingsProtocol GetUserMappingsProtocol in the RouterRpcServer.

Field Summary

Fields inherited from interface org.apache.hadoop.tools.GetUserMappingsProtocol

versionID

Fields inherited from interface org.apache.hadoop.security.RefreshUserMappingsProtocol

versionID

Constructor Summary

Constructors

Constructor	Description
RouterAsyncUserProtocol(RouterRpcServer server)

Method Summary

Modifier and Type	Method	Description
String[]	getGroupsForUser(String user)	Asynchronously get the groups which are mapped to the given user.
void	refreshSuperUserGroupsConfiguration()	Asynchronously refresh superuser proxy group list.
void	refreshUserToGroupsMappings()	Asynchronously refresh user to group mappings.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RouterAsyncUserProtocol

public RouterAsyncUserProtocol(RouterRpcServer server)

Method Details

refreshUserToGroupsMappings

public void refreshUserToGroupsMappings()
                                 throws IOException

Asynchronously refresh user to group mappings.

Specified by:

refreshUserToGroupsMappings in interface org.apache.hadoop.security.RefreshUserMappingsProtocol

Overrides:

refreshUserToGroupsMappings in class RouterUserProtocol

Throws:

IOException - raised on errors performing I/O.

refreshSuperUserGroupsConfiguration

public void refreshSuperUserGroupsConfiguration()
                                         throws IOException

Asynchronously refresh superuser proxy group list.

Specified by:

refreshSuperUserGroupsConfiguration in interface org.apache.hadoop.security.RefreshUserMappingsProtocol

Overrides:

refreshSuperUserGroupsConfiguration in class RouterUserProtocol

Throws:

IOException - raised on errors performing I/O.

getGroupsForUser

public String[] getGroupsForUser(String user)
                          throws IOException

Asynchronously get the groups which are mapped to the given user.

Specified by:

getGroupsForUser in interface org.apache.hadoop.tools.GetUserMappingsProtocol

Overrides:

getGroupsForUser in class RouterUserProtocol

Parameters:

user - The user to get the groups for.

Returns:

The set of groups the user belongs to.

Throws:

IOException - raised on errors performing I/O.