Package org.apache.hadoop.hbase.regionserver

Class LeaseManager

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.regionserver.LeaseManager

All Implemented Interfaces:

Runnable

@Private
public class LeaseManager
extends Thread

Leases There are several server classes in HBase that need to track external clients that occasionally send heartbeats.

These external clients hold resources in the server class. Those resources need to be released if the external client fails to send a heartbeat after some interval of time passes.

The Leases class is a general reusable class for this kind of pattern. An instance of the Leases class will create a thread to do its dirty work. You should close() the instance if you want to clean up the thread properly.

NOTE: This class extends Thread rather than Chore because the sleep time can be interrupted when there is something to do, rather than the Chore sleep time which is invariant.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	LeaseManager.Lease	This class tracks a single Lease.
static class	LeaseManager.LeaseStillHeldException	Thrown if we are asked to create a lease but lease on passed name already exists.

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final int	leaseCheckFrequency
private final Map<String,LeaseManager.Lease>	leases
private static final org.slf4j.Logger	LOG
private static final int	MIN_WAIT_TIME
private boolean	stopRequested

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
LeaseManager(int leaseCheckFrequency)	Creates a lease manager.

Method Summary

Modifier and Type	Method	Description
void	addLease(LeaseManager.Lease lease)	Inserts lease.
void	cancelLease(String leaseName)	Client explicitly cancels a lease.
void	close()	Shut down this Leases instance.
void	closeAfterLeasesExpire()	Shuts down this lease instance when all outstanding leases expire.
LeaseManager.Lease	createLease(String leaseName, int leaseTimeoutPeriod, LeaseListener listener)	Create a lease and insert it to the map of leases.
(package private) LeaseManager.Lease	removeLease(String leaseName)	Remove named lease.
void	renewLease(String leaseName)	Renew a lease
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

MIN_WAIT_TIME

private static final int MIN_WAIT_TIME

See Also:

• Constant Field Values

leases

private final Map<String,LeaseManager.Lease> leases

leaseCheckFrequency

private final int leaseCheckFrequency

stopRequested

private volatile boolean stopRequested

Constructor Details

LeaseManager

public LeaseManager(int leaseCheckFrequency)

Creates a lease manager.

Parameters:

leaseCheckFrequency - - how often the lease should be checked (milliseconds)

Method Details

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

closeAfterLeasesExpire

public void closeAfterLeasesExpire()

Shuts down this lease instance when all outstanding leases expire. Like close() but rather than violently end all leases, waits first on extant leases to finish. Use this method if the lease holders could lose data, leak locks, etc. Presumes client has shutdown allocation of new leases.

close

public void close()

Shut down this Leases instance. All pending leases will be destroyed, without any cancellation calls.

createLease

public LeaseManager.Lease createLease(String leaseName,
 int leaseTimeoutPeriod,
 LeaseListener listener)
                               throws LeaseManager.LeaseStillHeldException

Create a lease and insert it to the map of leases.

Parameters:

leaseName - name of the lease

leaseTimeoutPeriod - length of the lease in milliseconds

listener - listener that will process lease expirations

Returns:

The lease created.

Throws:

LeaseManager.LeaseStillHeldException

addLease

public void addLease(LeaseManager.Lease lease)
              throws LeaseManager.LeaseStillHeldException

Inserts lease. Resets expiration before insertion.

Throws:

LeaseManager.LeaseStillHeldException

renewLease

public void renewLease(String leaseName)
                throws LeaseException

Renew a lease

Parameters:

leaseName - name of the lease

Throws:

LeaseException

cancelLease

public void cancelLease(String leaseName)
                 throws LeaseException

Client explicitly cancels a lease.

Parameters:

leaseName - name of lease

Throws:

LeaseException

removeLease

LeaseManager.Lease removeLease(String leaseName)
                        throws LeaseException

Remove named lease. Lease is removed from the map of leases.

Parameters:

leaseName - name of lease

Returns:

Removed lease

Throws:

LeaseException