Package org.apache.hadoop.hbase.master.procedure

Class Queue<TKey extends Comparable<TKey>>

java.lang.Object

org.apache.hadoop.hbase.util.AvlUtil.AvlNode<TNode>

org.apache.hadoop.hbase.util.AvlUtil.AvlLinkedNode<Queue<TKey>>

org.apache.hadoop.hbase.master.procedure.Queue<TKey>

Direct Known Subclasses:

GlobalQueue, MetaQueue, PeerQueue, ServerQueue, TableQueue

@Private
abstract class Queue<TKey extends Comparable<TKey>>
extends AvlUtil.AvlLinkedNode<Queue<TKey>>

Field Summary

Fields

Modifier and Type	Field	Description
private final TKey	key
private final LockStatus	lockStatus
private final int	priority
private final ProcedureDeque	runnables

Fields inherited from class org.apache.hadoop.hbase.util.AvlUtil.AvlLinkedNode

iterNext, iterPrev

Fields inherited from class org.apache.hadoop.hbase.util.AvlUtil.AvlNode

avlHeight, avlLeft, avlRight

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Queue(TKey key, int priority, LockStatus lockStatus)
protected	Queue(TKey key, LockStatus lockStatus)

Method Summary

Modifier and Type	Method	Description
void	add(Procedure<?> proc, boolean addToFront)
int	compareKey(TKey cmpKey)
int	compareTo(Queue<TKey> other)
protected TKey	getKey()
protected LockStatus	getLockStatus()
int	getPriority()
boolean	isAvailable()
boolean	isEmpty()
Procedure<?>	peek()
Procedure<?>	poll()
(package private) abstract boolean	requireExclusiveLock(Procedure<?> proc)
int	size()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

key

private final TKey extends Comparable<TKey> key

priority

private final int priority

runnables

private final ProcedureDeque runnables

lockStatus

private final LockStatus lockStatus

Constructor Details

Queue

protected Queue(TKey key,
 LockStatus lockStatus)

Queue

protected Queue(TKey key,
 int priority,
 LockStatus lockStatus)

Method Details

requireExclusiveLock

abstract boolean requireExclusiveLock(Procedure<?> proc)

Parameters:

proc - must not be null

getKey

protected TKey getKey()

getPriority

public int getPriority()

getLockStatus

protected LockStatus getLockStatus()

isAvailable

public boolean isAvailable()

add

public void add(Procedure<?> proc,
 boolean addToFront)

peek

public Procedure<?> peek()

poll

public Procedure<?> poll()

isEmpty

public boolean isEmpty()

size

public int size()

compareKey

public int compareKey(TKey cmpKey)

compareTo

public int compareTo(Queue<TKey> other)

Specified by:

compareTo in class AvlUtil.AvlNode<Queue<TKey extends Comparable<TKey>>>

toString

public String toString()

Overrides:

toString in class Object