Package org.apache.hadoop.hbase.procedure2

Class RemoteProcedureDispatcher.BufferNode

java.lang.Object

org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject

org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainer<T>

org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainerWithTimestamp<TRemote>

org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode

All Implemented Interfaces:

Comparable<Delayed>, Delayed, RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote>, DelayedUtil.DelayedWithTimeout

Enclosing class:

RemoteProcedureDispatcher<TEnv,TRemote extends Comparable<TRemote>>

protected final class RemoteProcedureDispatcher.BufferNode
extends DelayedUtil.DelayedContainerWithTimestamp<TRemote>
implements RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote>

Node that contains a set of RemoteProcedures

Field Summary

Fields

Modifier and Type	Field	Description
private final Set<RemoteProcedureDispatcher.RemoteProcedure>	dispatchedOperations
private Set<RemoteProcedureDispatcher.RemoteProcedure>	operations

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BufferNode(TRemote key)

Method Summary

Modifier and Type	Method	Description
void	abortOperationsInQueue()
void	add(RemoteProcedureDispatcher.RemoteProcedure operation)
void	dispatch()
TRemote	getKey()
void	operationCompleted(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure)
String	toString()

Methods inherited from class org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainerWithTimestamp

getTimeout, setTimeout

Methods inherited from class org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedContainer

equals, getObject, hashCode

Methods inherited from class org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject

compareTo, getDelay

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

operations

private Set<RemoteProcedureDispatcher.RemoteProcedure> operations

dispatchedOperations

private final Set<RemoteProcedureDispatcher.RemoteProcedure> dispatchedOperations

Constructor Details

BufferNode

protected BufferNode(TRemote key)

Method Details

getKey

public TRemote getKey()

Specified by:

getKey in interface RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote extends Comparable<TRemote>>

add

public void add(RemoteProcedureDispatcher.RemoteProcedure operation)

Specified by:

add in interface RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote extends Comparable<TRemote>>

dispatch

public void dispatch()

Specified by:

dispatch in interface RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote extends Comparable<TRemote>>

abortOperationsInQueue

public void abortOperationsInQueue()

operationCompleted

public void operationCompleted(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure)

toString

public String toString()

Overrides:

toString in class DelayedUtil.DelayedContainer<TRemote extends Comparable<TRemote>>