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 and 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 and 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 and 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 Detail

startedAcquireBarrier

CountDownLatch startedAcquireBarrier

startedDuringBarrier

CountDownLatch startedDuringBarrier

completedProcedure

CountDownLatch completedProcedure

Constructor Detail

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 Detail

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