org.apache.hadoop.hbase.procedure2

Class ProcedureTestingUtility

java.lang.Object

org.apache.hadoop.hbase.procedure2.ProcedureTestingUtility

public class ProcedureTestingUtility
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ProcedureTestingUtility.TestProcedure

Method Summary

Modifier and Type	Method and Description
static void	assertIsAbortException(ProcedureInfo result)
static void	assertIsIllegalArgumentException(ProcedureInfo result)
static void	assertIsTimeoutException(ProcedureInfo result)
static Throwable	assertProcFailed(ProcedureInfo result)
static <TEnv> void	assertProcNotFailed(ProcedureExecutor<TEnv> procExecutor, long procId)
static void	assertProcNotFailed(ProcedureInfo result)
static <TEnv> void	assertProcNotYetCompleted(ProcedureExecutor<TEnv> procExecutor, long procId)
static ProcedureStore	createStore(Configuration conf, FileSystem fs, Path baseDir)
static WALProcedureStore	createWalStore(Configuration conf, FileSystem fs, Path walDir)
static Throwable	getExceptionCause(ProcedureInfo procInfo)
static <TEnv> void	restart(ProcedureExecutor<TEnv> procExecutor)
static <TEnv> void	restart(ProcedureExecutor<TEnv> procExecutor, Runnable beforeStartAction)
static <TEnv> void	setKillAndToggleBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor, boolean value)
static <TEnv> void	setKillBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor, boolean value)
static <TEnv> void	setToggleKillBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor, boolean value)
static <TEnv> long	submitAndWait(ProcedureExecutor<TEnv> procExecutor, Procedure proc)
static <TEnv> long	submitAndWait(ProcedureExecutor<TEnv> procExecutor, Procedure proc, long nonceGroup, long nonce)
static <TEnv> long	submitProcedure(ProcedureExecutor<TEnv> procExecutor, Procedure proc, long nonceGroup, long nonce)
static <TEnv> void	toggleKillBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor)
static <TEnv> void	waitNoProcedureRunning(ProcedureExecutor<TEnv> procExecutor)
static <TEnv> void	waitProcedure(ProcedureExecutor<TEnv> procExecutor, long procId)

Methods inherited from class java.lang.Object

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

Method Detail

createStore

public static ProcedureStore createStore(Configuration conf,
                                         FileSystem fs,
                                         Path baseDir)
                                  throws IOException

Throws:

IOException

createWalStore

public static WALProcedureStore createWalStore(Configuration conf,
                                               FileSystem fs,
                                               Path walDir)
                                        throws IOException

Throws:

IOException

restart

public static <TEnv> void restart(ProcedureExecutor<TEnv> procExecutor)
                           throws Exception

Throws:

Exception

restart

public static <TEnv> void restart(ProcedureExecutor<TEnv> procExecutor,
                                  Runnable beforeStartAction)
                           throws Exception

Throws:

Exception

setKillBeforeStoreUpdate

public static <TEnv> void setKillBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor,
                                                   boolean value)

setToggleKillBeforeStoreUpdate

public static <TEnv> void setToggleKillBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor,
                                                         boolean value)

toggleKillBeforeStoreUpdate

public static <TEnv> void toggleKillBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor)

setKillAndToggleBeforeStoreUpdate

public static <TEnv> void setKillAndToggleBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor,
                                                            boolean value)

submitAndWait

public static <TEnv> long submitAndWait(ProcedureExecutor<TEnv> procExecutor,
                                        Procedure proc)

submitAndWait

public static <TEnv> long submitAndWait(ProcedureExecutor<TEnv> procExecutor,
                                        Procedure proc,
                                        long nonceGroup,
                                        long nonce)

submitProcedure

public static <TEnv> long submitProcedure(ProcedureExecutor<TEnv> procExecutor,
                                          Procedure proc,
                                          long nonceGroup,
                                          long nonce)

waitProcedure

public static <TEnv> void waitProcedure(ProcedureExecutor<TEnv> procExecutor,
                                        long procId)

waitNoProcedureRunning

public static <TEnv> void waitNoProcedureRunning(ProcedureExecutor<TEnv> procExecutor)

assertProcNotYetCompleted

public static <TEnv> void assertProcNotYetCompleted(ProcedureExecutor<TEnv> procExecutor,
                                                    long procId)

assertProcNotFailed

public static <TEnv> void assertProcNotFailed(ProcedureExecutor<TEnv> procExecutor,
                                              long procId)

assertProcNotFailed

public static void assertProcNotFailed(ProcedureInfo result)

assertProcFailed

public static Throwable assertProcFailed(ProcedureInfo result)

assertIsAbortException

public static void assertIsAbortException(ProcedureInfo result)

assertIsTimeoutException

public static void assertIsTimeoutException(ProcedureInfo result)

assertIsIllegalArgumentException

public static void assertIsIllegalArgumentException(ProcedureInfo result)

getExceptionCause

public static Throwable getExceptionCause(ProcedureInfo procInfo)