Package 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 org.apache.hadoop.hbase.procedure.Subprocedure

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	SimpleRSProcedureManager.SimpleSubprocedure.RSSimpleTask	Callable task.

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

org.apache.hadoop.hbase.procedure.Subprocedure.SubprocedureImpl

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.hadoop.hbase.regionserver.RegionServerServices	rss
private final SimpleRSProcedureManager.SimpleSubprocedurePool	taskManager

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

executionTimeoutTimer, monitor, rpcs, wakeFrequency

Constructor Summary

Constructors

Constructor	Description
SimpleSubprocedure(org.apache.hadoop.hbase.regionserver.RegionServerServices rss, org.apache.hadoop.hbase.procedure.ProcedureMember member, org.apache.hadoop.hbase.errorhandling.ForeignExceptionDispatcher errorListener, SimpleRSProcedureManager.SimpleSubprocedurePool taskManager, String name)

Method Summary

Modifier and Type	Method	Description
void	acquireBarrier()
void	cleanup(Exception e)	Cancel threads if they haven't finished.
private void	execute()
byte[]	insideBarrier()	do a log roll.

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

call, cancel, getErrorCheckable, getMemberName, getName, isComplete, receiveReachedGlobalBarrier, waitForLocallyCompleted, waitForReachedGlobalBarrier

Methods inherited from class java.lang.Object

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

Field Details

rss

private final org.apache.hadoop.hbase.regionserver.RegionServerServices rss

taskManager

private final SimpleRSProcedureManager.SimpleSubprocedurePool taskManager

Constructor Details

SimpleSubprocedure

public SimpleSubprocedure(org.apache.hadoop.hbase.regionserver.RegionServerServices rss,
 org.apache.hadoop.hbase.procedure.ProcedureMember member,
 org.apache.hadoop.hbase.errorhandling.ForeignExceptionDispatcher errorListener,
 SimpleRSProcedureManager.SimpleSubprocedurePool taskManager,
 String name)

Method Details

execute

private void execute()
              throws org.apache.hadoop.hbase.errorhandling.ForeignException

Throws:

org.apache.hadoop.hbase.errorhandling.ForeignException

acquireBarrier

public void acquireBarrier()
                    throws org.apache.hadoop.hbase.errorhandling.ForeignException

Specified by:

acquireBarrier in class org.apache.hadoop.hbase.procedure.Subprocedure

Throws:

org.apache.hadoop.hbase.errorhandling.ForeignException

insideBarrier

public byte[] insideBarrier()
                     throws org.apache.hadoop.hbase.errorhandling.ForeignException

do a log roll.

Specified by:

insideBarrier in class org.apache.hadoop.hbase.procedure.Subprocedure

Throws:

org.apache.hadoop.hbase.errorhandling.ForeignException

cleanup

public void cleanup(Exception e)

Cancel threads if they haven't finished.

Specified by:

cleanup in class org.apache.hadoop.hbase.procedure.Subprocedure