Package org.apache.hadoop.hbase.backup.regionserver

Class LogRollBackupSubprocedure

java.lang.Object

org.apache.hadoop.hbase.procedure.Subprocedure

org.apache.hadoop.hbase.backup.regionserver.LogRollBackupSubprocedure

All Implemented Interfaces:

Callable<Void>

@Private
public class LogRollBackupSubprocedure
extends Subprocedure

This backup sub-procedure implementation forces a WAL rolling on a RS.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	LogRollBackupSubprocedure.RSRollLogTask	Callable task.

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure.Subprocedure

Subprocedure.SubprocedureImpl

Field Summary

Fields

Modifier and Type	Field	Description
private String	backupRoot
private static final org.slf4j.Logger	LOG
private final RegionServerServices	rss
private final LogRollBackupSubprocedurePool	taskManager

Fields inherited from class org.apache.hadoop.hbase.procedure.Subprocedure

executionTimeoutTimer, monitor, rpcs, wakeFrequency

Constructor Summary

Constructors

Constructor	Description
LogRollBackupSubprocedure(RegionServerServices rss, ProcedureMember member, ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout, LogRollBackupSubprocedurePool taskManager, byte[] data)

Method Summary

Modifier and Type	Method	Description
void	acquireBarrier()	The implementation of this method should gather and hold required resources (locks, disk space, etc) to satisfy the Procedures barrier condition.
void	cleanup(Exception e)	Cancel threads if they haven't finished.
byte[]	insideBarrier()	do a log roll.
void	releaseBarrier()	Hooray!
private void	rolllog()

Methods inherited from class org.apache.hadoop.hbase.procedure.Subprocedure

call, cancel, getMemberName, getName, receiveReachedGlobalBarrier, waitForLocallyCompleted

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

rss

private final RegionServerServices rss

taskManager

private final LogRollBackupSubprocedurePool taskManager

backupRoot

private String backupRoot

Constructor Details

LogRollBackupSubprocedure

public LogRollBackupSubprocedure(RegionServerServices rss,
 ProcedureMember member,
 ForeignExceptionDispatcher errorListener,
 long wakeFrequency,
 long timeout,
 LogRollBackupSubprocedurePool taskManager,
 byte[] data)

Method Details

rolllog

private void rolllog()
              throws ForeignException

Throws:

ForeignException

acquireBarrier

public void acquireBarrier()

Description copied from class: Subprocedure

The implementation of this method should gather and hold required resources (locks, disk space, etc) to satisfy the Procedures barrier condition. For example, this would be where to make all the regions on a RS on the quiescent for an procedure that required all regions to be globally quiesed. Users should override this method. If a quiescent is not required, this is overkill but can still be used to execute a procedure on all members and to propagate any exceptions.

Specified by:

acquireBarrier in class Subprocedure

insideBarrier

public byte[] insideBarrier()
                     throws ForeignException

do a log roll.

Specified by:

insideBarrier in class Subprocedure

Returns:

some bytes

Throws:

ForeignException

cleanup

public void cleanup(Exception e)

Cancel threads if they haven't finished.

Specified by:

cleanup in class Subprocedure

releaseBarrier

public void releaseBarrier()

Hooray!