co.paralleluniverse.db.quasar

Class DBaseImpl<R,T>

java.lang.Object

co.paralleluniverse.db.tree.AbstractDBase<R,T>

co.paralleluniverse.db.quasar.DBaseImpl<R,T>

All Implemented Interfaces:

DBase<T>, TXNContainer<T>

public class DBaseImpl<R,T>
extends co.paralleluniverse.db.tree.AbstractDBase<R,T>
implements DBase<T>

Field Summary

Fields inherited from class co.paralleluniverse.db.tree.AbstractDBase

tree

Constructor Summary

Constructors

Constructor and Description
DBaseImpl(co.paralleluniverse.db.tree.Tree<R,T> tree)

Method Summary

Methods

Modifier and Type	Method and Description
void	addTXNListener(TXNListener<T> listener)
Collection<Object>	createCollection()
protected co.paralleluniverse.common.monitoring.FlightRecorder	getFlightRecorder()
String	getName() Returns the SpaceBase store’s name.
int	getQueueLength()
protected co.paralleluniverse.db.tree.ForkJoinScheduler<R,?>	getScheduler()
protected boolean	isAsync()
boolean	isCurrentStrandAsynchronous() Tests whether this strand was put in asynchronous mode.
void	joinAllPendingOperations() If this store has been configured as parallel and setCurrentThreadAsynchronous(true) has been called on this thread, this method awaits the completion of all, yet-uncompleted operations.
protected void	joinSync(co.paralleluniverse.db.tree.Scheduler.Job<R> job)
protected void	joinSync(Sync sync)
protected Sync	perhapsJoin(co.paralleluniverse.db.tree.Scheduler.Job<R> job)
protected Sync	perhapsJoin(Sync sync)
void	prettyPrint(PrintStream out)
void	removeTXNListener(TXNListener<T> listener)
protected void	setCurrentBlock(TXN<T> txn)
void	setCurrentStrandAsynchronous(boolean value) If this store has been configured as parallel, calling this method with the value true puts this strand in asynchronous mode, i.e.
void	shutdown()
protected QuasarSync	sync()
protected Sync	sync(co.paralleluniverse.db.tree.Scheduler.Job job)
void	unregisterMBeans()
protected void	verifyNotInBlock()

Methods inherited from class co.paralleluniverse.db.tree.AbstractDBase

getTree, setCurrentTransaction

Methods inherited from class java.lang.Object

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

Constructor Detail

DBaseImpl

public DBaseImpl(co.paralleluniverse.db.tree.Tree<R,T> tree)

Method Detail

getScheduler

protected co.paralleluniverse.db.tree.ForkJoinScheduler<R,?> getScheduler()

getFlightRecorder

protected co.paralleluniverse.common.monitoring.FlightRecorder getFlightRecorder()

isCurrentStrandAsynchronous

public boolean isCurrentStrandAsynchronous()

Description copied from interface: DBase

Tests whether this strand was put in asynchronous mode.

Specified by:

isCurrentStrandAsynchronous in interface DBase<T>

Returns:

true for asynchronous mode, false for synchronous mode.

setCurrentStrandAsynchronous

public void setCurrentStrandAsynchronous(boolean value)

Description copied from interface: DBase

If this store has been configured as parallel, calling this method with the value true puts this strand in asynchronous mode, i.e. methods of this SpaceBase return immediately, possibly before completion. If this store has not been configured as parallel, calling this method has no effect.

Specified by:

setCurrentStrandAsynchronous in interface DBase<T>

Parameters:

value - true for asynchronous mode, false for synchronous mode.

verifyNotInBlock

protected void verifyNotInBlock()

sync

protected QuasarSync sync()

sync

protected Sync sync(co.paralleluniverse.db.tree.Scheduler.Job job)

isAsync

protected boolean isAsync()

joinSync

protected void joinSync(co.paralleluniverse.db.tree.Scheduler.Job<R> job)
                 throws SuspendExecution

Throws:

SuspendExecution

joinSync

protected void joinSync(Sync sync)
                 throws SuspendExecution

Throws:

SuspendExecution

perhapsJoin

protected Sync perhapsJoin(co.paralleluniverse.db.tree.Scheduler.Job<R> job)
                    throws SuspendExecution

Throws:

SuspendExecution

perhapsJoin

protected Sync perhapsJoin(Sync sync)
                    throws SuspendExecution

Throws:

SuspendExecution

setCurrentBlock

protected void setCurrentBlock(TXN<T> txn)

addTXNListener

public void addTXNListener(TXNListener<T> listener)

Specified by:

addTXNListener in interface TXNContainer<T>

removeTXNListener

public void removeTXNListener(TXNListener<T> listener)

Specified by:

removeTXNListener in interface TXNContainer<T>

getName

public String getName()

Description copied from interface: DBase

Returns the SpaceBase store’s name.

Specified by:

getName in interface DBase<T>

Returns:

The store’s name.

createCollection

public Collection<Object> createCollection()

getQueueLength

public int getQueueLength()

unregisterMBeans

public void unregisterMBeans()

prettyPrint

public void prettyPrint(PrintStream out)

joinAllPendingOperations

public void joinAllPendingOperations()
                              throws InterruptedException,
                                     SuspendExecution

Description copied from interface: DBase

If this store has been configured as parallel and setCurrentThreadAsynchronous(true) has been called on this thread, this method awaits the completion of all, yet-uncompleted operations. Upon its return, all of the operations modifications to the store are visible by this thread.
If this store has not been configured as parallel, or not set as asynchronous, this method has no effect, and will never throw an exception.

Specified by:

joinAllPendingOperations in interface DBase<T>

Throws:

InterruptedException

SuspendExecution

shutdown

public void shutdown()

Specified by:

shutdown in interface DBase<T>