Package org.apache.hadoop.hbase.master.locking

Class LockManager.RemoteLocks

java.lang.Object

org.apache.hadoop.hbase.master.locking.LockManager.RemoteLocks

Enclosing class:

LockManager

public class LockManager.RemoteLocks
extends Object

Locks on namespace/table/regions for remote operations. Since remote operations are unreliable and the client/RS may die anytime and never release locks, regular heartbeats are required to keep the lock held.

Constructor Summary

Constructors

Constructor	Description
RemoteLocks()

Method Summary

Modifier and Type	Method	Description
boolean	lockHeartbeat(long procId, boolean keepAlive)
long	requestNamespaceLock(String namespace, LockType type, String description, NonceKey nonceKey)
long	requestRegionsLock(RegionInfo[] regionInfos, String description, NonceKey nonceKey)
long	requestTableLock(TableName tableName, LockType type, String description, NonceKey nonceKey)

Methods inherited from class java.lang.Object

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

Constructor Details

RemoteLocks

public RemoteLocks()

Method Details

requestNamespaceLock

public long requestNamespaceLock(String namespace,
 LockType type,
 String description,
 NonceKey nonceKey)
                          throws IllegalArgumentException,
IOException

Throws:

IllegalArgumentException

IOException

requestTableLock

public long requestTableLock(TableName tableName,
 LockType type,
 String description,
 NonceKey nonceKey)
                      throws IllegalArgumentException,
IOException

Throws:

IllegalArgumentException

IOException

requestRegionsLock

public long requestRegionsLock(RegionInfo[] regionInfos,
 String description,
 NonceKey nonceKey)
                        throws IllegalArgumentException,
IOException

Throws:

IllegalArgumentException - if all regions are not from same table.

IOException

lockHeartbeat

public boolean lockHeartbeat(long procId,
 boolean keepAlive)
                      throws IOException

Parameters:

keepAlive - if false, release the lock.

Returns:

true, if procedure is found and it has the lock; else false.

Throws:

IOException