org.apache.hadoop.hbase.procedure

Class SimpleRSProcedureManager.SimpleSubprocedure

java.lang.Object

org.apache.hadoop.hbase.procedure.Subprocedure

org.apache.hadoop.hbase.procedure.SimpleRSProcedureManager.SimpleSubprocedure

All Implemented Interfaces:

Callable<Void>

Enclosing class:

SimpleRSProcedureManager

public class SimpleRSProcedureManager.SimpleSubprocedure
extends Subprocedure

Nested Class Summary

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

Subprocedure.SubprocedureImpl

Field Summary

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

executionTimeoutTimer, monitor, rpcs, wakeFrequency

Constructor Summary

Constructors

Constructor and Description
SimpleSubprocedure(RegionServerServices rss, ProcedureMember member, ForeignExceptionDispatcher errorListener, SimpleRSProcedureManager.SimpleSubprocedurePool taskManager, String name)

Method Summary

Modifier and Type	Method and 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.

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

Constructor Detail

SimpleSubprocedure

public SimpleSubprocedure(RegionServerServices rss,
                          ProcedureMember member,
                          ForeignExceptionDispatcher errorListener,
                          SimpleRSProcedureManager.SimpleSubprocedurePool taskManager,
                          String name)

Method Detail

acquireBarrier

public void acquireBarrier()
                    throws ForeignException

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

Throws:

ForeignException

insideBarrier

public byte[] insideBarrier()
                     throws ForeignException

do a log roll.

Specified by:

insideBarrier in class Subprocedure

Returns:

the data the subprocedure wants to return to coordinator side.

Throws:

ForeignException

cleanup

public void cleanup(Exception e)

Cancel threads if they haven't finished.

Specified by:

cleanup in class Subprocedure