Package org.apache.hadoop.hbase.master.procedure

Class SchemaLocking

java.lang.Object

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

@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	Description
private final Map<String,LockAndQueue>	globalLocks
private final LockAndQueue	metaLock
private final Map<String,LockAndQueue>	namespaceLocks
private final Map<String,LockAndQueue>	peerLocks
private final Function<Long,Procedure<?>>	procedureRetriever
private final Map<String,LockAndQueue>	regionLocks
private final Map<ServerName,LockAndQueue>	serverLocks
private final Map<TableName,LockAndQueue>	tableLocks

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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)
(package private) LockAndQueue	getGlobalLock(String globalId)
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.
(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	removeGlobalLock(String globalId)
(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 Details

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

globalLocks

private final Map<String,LockAndQueue> globalLocks

metaLock

private final LockAndQueue metaLock

Constructor Details

SchemaLocking

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

Method Details

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.

getGlobalLock

LockAndQueue getGlobalLock(String globalId)

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)

removeGlobalLock

LockAndQueue removeGlobalLock(String globalId)

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)