org.apache.hadoop.hbase.procedure2.store

Class ProcedureStoreBase

java.lang.Object

org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase

All Implemented Interfaces:

ProcedureStore

Direct Known Subclasses:

NoopProcedureStore, WALProcedureStore

@InterfaceAudience.Private
public abstract class ProcedureStoreBase
extends Object
implements ProcedureStore

Base class for ProcedureStores.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.procedure2.store.ProcedureStore

ProcedureStore.ProcedureIterator, ProcedureStore.ProcedureLoader, ProcedureStore.ProcedureStoreListener

Field Summary

Fields

Modifier and Type	Field and Description
private CopyOnWriteArrayList<ProcedureStore.ProcedureStoreListener>	listeners
private AtomicBoolean	running

Constructor Summary

Constructors

Constructor and Description
ProcedureStoreBase()

Method Summary

Modifier and Type	Method and Description
boolean	isRunning()
void	registerListener(ProcedureStore.ProcedureStoreListener listener) Add the listener to the notification list.
protected void	sendAbortProcessSignal()
protected void	sendForceUpdateSignal(long[] procIds)
protected void	sendPostSyncSignal()
protected boolean	setRunning(boolean isRunning) Change the state to 'isRunning', returns true if the store state was changed, false if the store was already in that state.
boolean	unregisterListener(ProcedureStore.ProcedureStoreListener listener) Remove the listener from the notification list.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.procedure2.store.ProcedureStore

delete, delete, delete, getNumThreads, insert, insert, load, recoverLease, setRunningProcedureCount, start, stop, update

Field Detail

listeners

private final CopyOnWriteArrayList<ProcedureStore.ProcedureStoreListener> listeners

running

private final AtomicBoolean running

Constructor Detail

ProcedureStoreBase

public ProcedureStoreBase()

Method Detail

setRunning

protected boolean setRunning(boolean isRunning)

Change the state to 'isRunning', returns true if the store state was changed, false if the store was already in that state.

Parameters:

isRunning - the state to set.

Returns:

true if the store state was changed, otherwise false.

isRunning

public boolean isRunning()

Specified by:

isRunning in interface ProcedureStore

Returns:

true if the store is running, otherwise false.

registerListener

public void registerListener(ProcedureStore.ProcedureStoreListener listener)

Description copied from interface: ProcedureStore

Add the listener to the notification list.

Specified by:

registerListener in interface ProcedureStore

Parameters:

listener - The AssignmentListener to register

unregisterListener

public boolean unregisterListener(ProcedureStore.ProcedureStoreListener listener)

Description copied from interface: ProcedureStore

Remove the listener from the notification list.

Specified by:

unregisterListener in interface ProcedureStore

Parameters:

listener - The AssignmentListener to unregister

Returns:

true if the listner was in the list and it was removed, otherwise false.

sendPostSyncSignal

protected final void sendPostSyncSignal()

sendAbortProcessSignal

protected final void sendAbortProcessSignal()

sendForceUpdateSignal

protected final void sendForceUpdateSignal(long[] procIds)