org.apache.hadoop.hbase.master.procedure

Class ProcedureSyncWait

java.lang.Object

org.apache.hadoop.hbase.master.procedure.ProcedureSyncWait

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public final class ProcedureSyncWait
extends Object

Helper to synchronously wait on conditions. This will be removed in the future (mainly when the AssignmentManager will be replaced with a Procedure version) by using ProcedureYieldException, and the queue will handle waiting and scheduling based on events.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ProcedureSyncWait.Predicate<T>

Method Summary

Modifier and Type	Method and Description
protected static MasterQuotaManager	getMasterQuotaManager(MasterProcedureEnv env)
static byte[]	submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<MasterProcedureEnv> proc)
static Future<byte[]>	submitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<MasterProcedureEnv> proc)
static <T> T	waitFor(MasterProcedureEnv env, long waitTime, long waitingTimeForEvents, String purpose, ProcedureSyncWait.Predicate<T> predicate)
static <T> T	waitFor(MasterProcedureEnv env, String purpose, ProcedureSyncWait.Predicate<T> predicate)
static byte[]	waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<?> proc, long timeout)
static byte[]	waitForProcedureToCompleteIOE(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<?> proc, long timeout)
protected static void	waitMetaRegions(MasterProcedureEnv env)
protected static void	waitRegionInTransition(MasterProcedureEnv env, List<RegionInfo> regions)

Methods inherited from class java.lang.Object

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

Method Detail

submitProcedure

public static Future<byte[]> submitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec,
                                             Procedure<MasterProcedureEnv> proc)

submitAndWaitProcedure

public static byte[] submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec,
                                            Procedure<MasterProcedureEnv> proc)
                                     throws IOException

Throws:

IOException

waitForProcedureToCompleteIOE

public static byte[] waitForProcedureToCompleteIOE(ProcedureExecutor<MasterProcedureEnv> procExec,
                                                   Procedure<?> proc,
                                                   long timeout)
                                            throws IOException

Throws:

IOException

waitForProcedureToComplete

public static byte[] waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec,
                                                Procedure<?> proc,
                                                long timeout)
                                         throws IOException

Throws:

IOException

waitFor

public static <T> T waitFor(MasterProcedureEnv env,
                            String purpose,
                            ProcedureSyncWait.Predicate<T> predicate)
                     throws IOException

Throws:

IOException

waitFor

public static <T> T waitFor(MasterProcedureEnv env,
                            long waitTime,
                            long waitingTimeForEvents,
                            String purpose,
                            ProcedureSyncWait.Predicate<T> predicate)
                     throws IOException

Throws:

IOException

waitMetaRegions

protected static void waitMetaRegions(MasterProcedureEnv env)
                               throws IOException

Throws:

IOException

waitRegionInTransition

protected static void waitRegionInTransition(MasterProcedureEnv env,
                                             List<RegionInfo> regions)
                                      throws IOException

Throws:

IOException

getMasterQuotaManager

protected static MasterQuotaManager getMasterQuotaManager(MasterProcedureEnv env)
                                                   throws IOException

Throws:

IOException