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 java.lang.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 and Description
RemoteLocks()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteLocks

public RemoteLocks()

Method Detail

requestNamespaceLock

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

Throws:

java.lang.IllegalArgumentException

java.io.IOException

requestTableLock

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

Throws:

java.lang.IllegalArgumentException

java.io.IOException

requestRegionsLock

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

Throws:

java.lang.IllegalArgumentException - if all regions are not from same table.

java.io.IOException

lockHeartbeat

public boolean lockHeartbeat(long procId,
                             boolean keepAlive)
                      throws java.io.IOException

Parameters:

keepAlive - if false, release the lock.

Returns:

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

Throws:

java.io.IOException