org.apache.hadoop.hbase.master.procedure

Class TestSchedulerQueueDeadLock.TableExclusiveProcedure

java.lang.Object

org.apache.hadoop.hbase.procedure2.Procedure<TEnv>

org.apache.hadoop.hbase.procedure2.ProcedureTestingUtility.NoopProcedure<TestSchedulerQueueDeadLock.TestEnv>

org.apache.hadoop.hbase.master.procedure.TestSchedulerQueueDeadLock.TableExclusiveProcedure

All Implemented Interfaces:

Comparable<org.apache.hadoop.hbase.procedure2.Procedure<TestSchedulerQueueDeadLock.TestEnv>>, org.apache.hadoop.hbase.master.procedure.TableProcedureInterface

Direct Known Subclasses:

TestSchedulerQueueDeadLock.TableExclusiveProcedureWithId

Enclosing class:

TestSchedulerQueueDeadLock

public static class TestSchedulerQueueDeadLock.TableExclusiveProcedure
extends ProcedureTestingUtility.NoopProcedure<TestSchedulerQueueDeadLock.TestEnv>
implements org.apache.hadoop.hbase.master.procedure.TableProcedureInterface

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.Procedure

org.apache.hadoop.hbase.procedure2.Procedure.LockState

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.master.procedure.TableProcedureInterface

org.apache.hadoop.hbase.master.procedure.TableProcedureInterface.TableOperationType

Field Summary

Fields

Modifier and Type	Field and Description
private Semaphore	latch

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

NO_PROC_ID, NO_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TableExclusiveProcedure()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.procedure2.Procedure.LockState	acquireLock(TestSchedulerQueueDeadLock.TestEnv env)
protected org.apache.hadoop.hbase.procedure2.Procedure<TestSchedulerQueueDeadLock.TestEnv>[]	execute(TestSchedulerQueueDeadLock.TestEnv env)
org.apache.hadoop.hbase.TableName	getTableName()
org.apache.hadoop.hbase.master.procedure.TableProcedureInterface.TableOperationType	getTableOperationType()
protected boolean	holdLock(TestSchedulerQueueDeadLock.TestEnv env)
protected void	releaseLock(TestSchedulerQueueDeadLock.TestEnv env)

Methods inherited from class org.apache.hadoop.hbase.procedure2.ProcedureTestingUtility.NoopProcedure

abort, deserializeStateData, rollback, serializeStateData

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

addStackIndex, afterReplay, beforeReplay, bypass, compareTo, completionCleanup, doExecute, doRollback, elapsedTime, getChildrenLatch, getException, getLastUpdate, getNonceKey, getOwner, getParentProcId, getProcedureMetrics, getProcId, getProcIdHashCode, getProcName, getResult, getRootProcedureId, getRootProcId, getStackIndexes, getState, getSubmittedTime, getTimeout, getTimeoutTimestamp, hasChildren, hasException, hasLock, hasOwner, hasParent, hasTimeout, haveSameParent, incChildrenLatch, isBypass, isFailed, isFinished, isInitializing, isLockedWhenLoading, isRunnable, isSuccess, isWaiting, isYieldAfterExecutionStep, removeStackIndex, setAbortFailure, setChildrenLatch, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, setTimeoutFailure, shouldWaitClientAck, skipPersistence, toString, toStringClass, toStringClassDetails, toStringDetails, toStringSimpleSB, toStringState, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, waitInitialized, wasExecuted

Methods inherited from class java.lang.Object

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

Field Detail

latch

private final Semaphore latch

Constructor Detail

TableExclusiveProcedure

public TableExclusiveProcedure()

Method Detail

execute

protected org.apache.hadoop.hbase.procedure2.Procedure<TestSchedulerQueueDeadLock.TestEnv>[] execute(TestSchedulerQueueDeadLock.TestEnv env)
                                                                                              throws org.apache.hadoop.hbase.procedure2.ProcedureYieldException,
                                                                                                     org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException,
                                                                                                     InterruptedException

Overrides:

execute in class ProcedureTestingUtility.NoopProcedure<TestSchedulerQueueDeadLock.TestEnv>

Throws:

org.apache.hadoop.hbase.procedure2.ProcedureYieldException

org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException

InterruptedException

acquireLock

protected org.apache.hadoop.hbase.procedure2.Procedure.LockState acquireLock(TestSchedulerQueueDeadLock.TestEnv env)

Overrides:

acquireLock in class org.apache.hadoop.hbase.procedure2.Procedure<TestSchedulerQueueDeadLock.TestEnv>

releaseLock

protected void releaseLock(TestSchedulerQueueDeadLock.TestEnv env)

Overrides:

releaseLock in class org.apache.hadoop.hbase.procedure2.Procedure<TestSchedulerQueueDeadLock.TestEnv>

holdLock

protected boolean holdLock(TestSchedulerQueueDeadLock.TestEnv env)

Overrides:

holdLock in class org.apache.hadoop.hbase.procedure2.Procedure<TestSchedulerQueueDeadLock.TestEnv>

getTableName

public org.apache.hadoop.hbase.TableName getTableName()

Specified by:

getTableName in interface org.apache.hadoop.hbase.master.procedure.TableProcedureInterface

getTableOperationType

public org.apache.hadoop.hbase.master.procedure.TableProcedureInterface.TableOperationType getTableOperationType()

Specified by:

getTableOperationType in interface org.apache.hadoop.hbase.master.procedure.TableProcedureInterface