org.apache.hadoop.hbase.master.procedure

Class SchemaLocking

java.lang.Object

org.apache.hadoop.hbase.master.procedure.SchemaLocking

@InterfaceAudience.Private
class SchemaLocking
extends Object

Locks on namespaces, tables, and regions.

Since LockAndQueue implementation is NOT thread-safe, schedLock() guards all calls to these locks.

Field Summary

Fields

Modifier and Type	Field and Description
private LockAndQueue	metaLock
private Map<String,LockAndQueue>	namespaceLocks
private Map<String,LockAndQueue>	peerLocks
private Function<Long,Procedure<?>>	procedureRetriever
private Map<String,LockAndQueue>	regionLocks
private Map<ServerName,LockAndQueue>	serverLocks
private Map<TableName,LockAndQueue>	tableLocks

Constructor Summary

Constructors

Constructor and Description
SchemaLocking(Function<Long,Procedure<?>> procedureRetriever)

Method Summary

Modifier and Type	Method and Description
private <T> void	addToLockedResources(List<LockedResource> lockedResources, Map<T,LockAndQueue> locks, Function<T,String> keyTransformer, LockedResourceType resourcesType)
(package private) void	clear() Removes all locks by clearing the maps.
private LockedResource	createLockedResource(LockedResourceType resourceType, String resourceName, LockAndQueue queue)
private String	filterUnlocked(Map<?,LockAndQueue> locks)
private <T> LockAndQueue	getLock(Map<T,LockAndQueue> map, T key)
(package private) LockedResource	getLockResource(LockedResourceType resourceType, String resourceName)
(package private) List<LockedResource>	getLocks() List lock queues.
(package private) LockAndQueue	getMetaLock() Deprecated. only used for RecoverMetaProcedure. Should be removed along with RecoverMetaProcedure.
(package private) LockAndQueue	getNamespaceLock(String namespace)
(package private) LockAndQueue	getPeerLock(String peerId)
(package private) LockAndQueue	getRegionLock(String encodedRegionName)
(package private) LockAndQueue	getServerLock(ServerName serverName)
(package private) LockAndQueue	getTableLock(TableName tableName)
(package private) LockAndQueue	removePeerLock(String peerId)
(package private) LockAndQueue	removeRegionLock(String encodedRegionName)
(package private) LockAndQueue	removeServerLock(ServerName serverName)
(package private) LockAndQueue	removeTableLock(TableName tableName)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

procedureRetriever

private final Function<Long,Procedure<?>> procedureRetriever

serverLocks

private final Map<ServerName,LockAndQueue> serverLocks

namespaceLocks

private final Map<String,LockAndQueue> namespaceLocks

tableLocks

private final Map<TableName,LockAndQueue> tableLocks

regionLocks

private final Map<String,LockAndQueue> regionLocks

peerLocks

private final Map<String,LockAndQueue> peerLocks

metaLock

private final LockAndQueue metaLock

Constructor Detail

SchemaLocking

public SchemaLocking(Function<Long,Procedure<?>> procedureRetriever)

Method Detail

getLock

private <T> LockAndQueue getLock(Map<T,LockAndQueue> map,
                                 T key)

getTableLock

LockAndQueue getTableLock(TableName tableName)

removeTableLock

LockAndQueue removeTableLock(TableName tableName)

getNamespaceLock

LockAndQueue getNamespaceLock(String namespace)

getRegionLock

LockAndQueue getRegionLock(String encodedRegionName)

getMetaLock

@Deprecated
LockAndQueue getMetaLock()

Deprecated. only used for RecoverMetaProcedure. Should be removed along with RecoverMetaProcedure.

removeRegionLock

LockAndQueue removeRegionLock(String encodedRegionName)

getServerLock

LockAndQueue getServerLock(ServerName serverName)

removeServerLock

LockAndQueue removeServerLock(ServerName serverName)

getPeerLock

LockAndQueue getPeerLock(String peerId)

removePeerLock

LockAndQueue removePeerLock(String peerId)

createLockedResource

private LockedResource createLockedResource(LockedResourceType resourceType,
                                            String resourceName,
                                            LockAndQueue queue)

addToLockedResources

private <T> void addToLockedResources(List<LockedResource> lockedResources,
                                      Map<T,LockAndQueue> locks,
                                      Function<T,String> keyTransformer,
                                      LockedResourceType resourcesType)

getLocks

List<LockedResource> getLocks()

List lock queues.

Returns:

the locks

getLockResource

LockedResource getLockResource(LockedResourceType resourceType,
                               String resourceName)

Returns:

LockedResource for resource of specified type & name. null if resource is not locked.

clear

void clear()

Removes all locks by clearing the maps. Used when procedure executor is stopped for failure and recovery testing.

toString

public String toString()

Overrides:

toString in class Object

filterUnlocked

private String filterUnlocked(Map<?,LockAndQueue> locks)