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>
private static class	ProcedureSyncWait.ProcedureFuture

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ProcedureSyncWait()

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

ProcedureSyncWait

private ProcedureSyncWait()

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