Package org.apache.hadoop.hbase.procedure

Class TestProcedure.LatchedProcedure

java.lang.Object

org.apache.hadoop.hbase.procedure.Procedure

org.apache.hadoop.hbase.procedure.TestProcedure.LatchedProcedure

All Implemented Interfaces:

Callable<Void>, org.apache.hadoop.hbase.errorhandling.ForeignExceptionListener

Enclosing class:

TestProcedure

static class TestProcedure.LatchedProcedure
extends org.apache.hadoop.hbase.procedure.Procedure

Field Summary

Fields

Modifier and Type	Field	Description
(package private) CountDownLatch	completedProcedure
(package private) CountDownLatch	startedAcquireBarrier
(package private) CountDownLatch	startedDuringBarrier

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

acquiredBarrierLatch, completedLatch, releasedBarrierLatch, timeoutInjector, wakeFrequency

Constructor Summary

Constructors

Constructor	Description
LatchedProcedure(org.apache.hadoop.hbase.procedure.ProcedureCoordinator coord, org.apache.hadoop.hbase.errorhandling.ForeignExceptionDispatcher monitor, long wakeFreq, long timeout, String opName, byte[] data, List<String> expectedMembers)

Method Summary

Modifier and Type	Method	Description
void	sendGlobalBarrierComplete()
void	sendGlobalBarrierReached()
void	sendGlobalBarrierStart()

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

barrierAcquiredByMember, barrierReleasedByMember, call, getErrorMonitor, getName, getStatus, isCompleted, receive, waitForCompleted, waitForCompletedWithRet, waitForLatch

Methods inherited from class java.lang.Object

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

Field Details

startedAcquireBarrier

CountDownLatch startedAcquireBarrier

startedDuringBarrier

CountDownLatch startedDuringBarrier

completedProcedure

CountDownLatch completedProcedure

Constructor Details

LatchedProcedure

public LatchedProcedure(org.apache.hadoop.hbase.procedure.ProcedureCoordinator coord,
 org.apache.hadoop.hbase.errorhandling.ForeignExceptionDispatcher monitor,
 long wakeFreq,
 long timeout,
 String opName,
 byte[] data,
 List<String> expectedMembers)

Method Details

sendGlobalBarrierStart

public void sendGlobalBarrierStart()

Overrides:

sendGlobalBarrierStart in class org.apache.hadoop.hbase.procedure.Procedure

sendGlobalBarrierReached

public void sendGlobalBarrierReached()

Overrides:

sendGlobalBarrierReached in class org.apache.hadoop.hbase.procedure.Procedure

sendGlobalBarrierComplete

public void sendGlobalBarrierComplete()

Overrides:

sendGlobalBarrierComplete in class org.apache.hadoop.hbase.procedure.Procedure