com.bigdata.journal

Class TestTransactionService.MockTransactionService

java.lang.Object

com.bigdata.service.AbstractService

com.bigdata.service.AbstractTransactionService

com.bigdata.journal.TestTransactionService.MockTransactionService

All Implemented Interfaces:

ICounterSetAccess, ITimestampService, ITransactionService, IService, IServiceShutdown, Remote

Enclosing class:

TestTransactionService

protected static class TestTransactionService.MockTransactionService
extends AbstractTransactionService

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.service.AbstractTransactionService

AbstractTransactionService.Options, AbstractTransactionService.TxState

Field Summary

Fields inherited from class com.bigdata.service.AbstractTransactionService

ERR_NO_SUCH, ERR_NOT_ACTIVE, ERR_READ_ONLY, ERR_SERVICE_NOT_AVAIL, lock, log, txDeactivate

Constructor Summary

Constructors

Constructor and Description
TestTransactionService.MockTransactionService(Properties p)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	abortImpl(AbstractTransactionService.TxState state) Implementation must abort the tx on the journal (standalone) or on each data service (federation) on which it has written.
void	awaitRunState(TxServiceRunState expectedRunState) Awaits the specified run state.
protected long	commitImpl(AbstractTransactionService.TxState state) Implementation must either single-phase commit (standalone journal or a transaction that only writes on a single data service) or 2-/3-phase commit (distributed transaction running on a federation).
protected long	findCommitTime(long timestamp) Find the commit time from which the tx will read (largest commitTime LTE timestamp).
protected long	findNextCommitTime(long commitTime) Return the commit time for the successor of that commit point have the specified timestamp (a commit time strictly GT the given value).
protected AbstractTransactionService.TxState	getEarliestActiveTx() Return the AbstractTransactionService.TxState for the earliest active Tx -or- null if there is no active tx.
AbstractFederation<?>	getFederation() Return the proxy used to access other services in the federation.
long	getLastCommitTime() Note: Declared abstract so that we can hide the IOException.
protected long	getReadsOnTime(long txId) Return the commit time on which the transaction is reading.
protected AbstractTransactionService.TxState	getTxState(long txId) Return the AbstractTransactionService.TxState associated with the specified transition identifier.
long	nextTimestamp() Note: This currently waits until at least two milliseconds have elapsed.
void	notifyCommit(long commitTime) The basic implementation advances the release time periodically as commits occur even when there are no transactions in use.
TestTransactionService.MockTransactionService	start() Verifies that AbstractTransactionService.nextTimestamp() will not report a time before AbstractTransactionService.getLastCommitTime() and then changes the TxServiceRunState to TxServiceRunState.Running.

Methods inherited from class com.bigdata.service.AbstractTransactionService

abort, abortAllTx, activateTx, assertOpen, assignTransactionIdentifier, commit, deactivateTx, destroy, findUnusedTimestamp, getAbortCount, getActiveCount, getCommitCount, getCounters, getEffectiveReleaseTimeForHA, getMinReleaseAge, getProperties, getReadOnlyActiveCount, getReadWriteActiveCount, getReleaseTime, getRunState, getServiceIface, getStartCount, isOpen, isReleaseTimeConsensusProtocol, newTx, setReleaseTime, setRunState, shutdown, shutdownNow, updateReleaseTime, updateReleaseTimeForBareCommit

Methods inherited from class com.bigdata.service.AbstractService

clearLoggingContext, getHostname, getServiceName, getServiceUUID, setServiceUUID, setupLoggingContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.service.IService

getHostname, getServiceName, getServiceUUID

Constructor Detail

TestTransactionService.MockTransactionService

public TestTransactionService.MockTransactionService(Properties p)

Method Detail

start

public TestTransactionService.MockTransactionService start()

Description copied from class: AbstractTransactionService

Verifies that AbstractTransactionService.nextTimestamp() will not report a time before AbstractTransactionService.getLastCommitTime() and then changes the TxServiceRunState to TxServiceRunState.Running.

Overrides:

start in class AbstractTransactionService

Returns:

this (the return type should be strengthened by the concrete implementation to return the actual type).

getReadsOnTime

protected long getReadsOnTime(long txId)

Description copied from class: AbstractTransactionService

Return the commit time on which the transaction is reading.

Note: This method is exposed primarily for the unit tests.

Overrides:

getReadsOnTime in class AbstractTransactionService

Parameters:

txId - The transaction identifier.

Returns:

The commit time on which that transaction is reading.

getFederation

public AbstractFederation<?> getFederation()

Description copied from class: AbstractService

Return the proxy used to access other services in the federation.

Specified by:

getFederation in class AbstractService

abortImpl

protected void abortImpl(AbstractTransactionService.TxState state)

Description copied from class: AbstractTransactionService

Implementation must abort the tx on the journal (standalone) or on each data service (federation) on which it has written.

Pre-conditions:

1. The transaction is RunState.Active; and
2. The caller holds the AbstractTransactionService.TxState.lock.

Post-conditions:

1. The transaction is RunState.Aborted; and
2. The transaction write set has been discarded by each Journal or IDataService or which it has written (applicable for read-write transactions only).

Specified by:

abortImpl in class AbstractTransactionService

Parameters:

state - The transaction state as maintained by the transaction server.

commitImpl

protected long commitImpl(AbstractTransactionService.TxState state)
                   throws Exception

Description copied from class: AbstractTransactionService

Implementation must either single-phase commit (standalone journal or a transaction that only writes on a single data service) or 2-/3-phase commit (distributed transaction running on a federation).

Pre-conditions:

1. The transaction is RunState.Active; and
2. The caller holds the AbstractTransactionService.TxState.lock.

Post-conditions (success for read-only transaction or a read-write transaction with an empty write set):

1. The transaction is RunState.Committed; and
2. The returned commitTime is ZERO (0L).

Post-conditions (success for read-write transaction with a non-empty write set):

1. The transaction is RunState.Committed;
2. The transaction write set has been made restart-safe by each Journal or IDataService or which it has written (applicable for read-write transactions only); and
3. The application can read exactly the data written by the transaction from the commit point identified by the returned commitTime.

Post-conditions (failure):

1. The transaction is RunState.Aborted; and
2. The transaction write set has been discarded by each Journal or IDataService or which it has written (applicable for read-write transactions only).

Specified by:

commitImpl in class AbstractTransactionService

Returns:

The commit time for the transaction -or- ZERO (0L) if the transaction was read-only or had an empty write set.

Throws:

Exception - if something else goes wrong. This will be (or will wrap) a ValidationError if validation fails.

getLastCommitTime

public long getLastCommitTime()

Description copied from class: AbstractTransactionService

Note: Declared abstract so that we can hide the IOException.

Specified by:

getLastCommitTime in interface ITransactionService

Specified by:

getLastCommitTime in class AbstractTransactionService

Returns:

The last known commit time.

findCommitTime

protected long findCommitTime(long timestamp)

Description copied from class: AbstractTransactionService

Find the commit time from which the tx will read (largest commitTime LTE timestamp).

Specified by:

findCommitTime in class AbstractTransactionService

Parameters:

timestamp - The timestamp.

Returns:

The commit time and -1L if there is no such commit time.

findNextCommitTime

protected long findNextCommitTime(long commitTime)

Description copied from class: AbstractTransactionService

Return the commit time for the successor of that commit point have the specified timestamp (a commit time strictly GT the given value).

Specified by:

findNextCommitTime in class AbstractTransactionService

Parameters:

commitTime - The probe.

Returns:

The successor or -1L iff the is no successor for that commit time.

notifyCommit

public void notifyCommit(long commitTime)

Description copied from class: AbstractTransactionService

The basic implementation advances the release time periodically as commits occur even when there are no transactions in use.

Note: This needs to be a fairly low-latency operation since this method is invoked for all commits on all data services and will otherwise be a global hotspot.

Specified by:

notifyCommit in interface ITransactionService

Overrides:

notifyCommit in class AbstractTransactionService

Parameters:

commitTime - The commit time.

awaitRunState

public void awaitRunState(TxServiceRunState expectedRunState)
                   throws InterruptedException

Awaits the specified run state.

Parameters:

expectedRunState - The expected run state.

Throws:

InterruptedException

AssertionError

nextTimestamp

public long nextTimestamp()

Note: This currently waits until at least two milliseconds have elapsed. This is a workaround for TestTransactionService.test_newTx_readOnly() until (if) ISSUE#145 is resolved. TODO This override of nextTimestamp() should be removed once that issue is fixed.

Specified by:

nextTimestamp in interface ITimestampService

Overrides:

nextTimestamp in class AbstractTransactionService

See Also:

TimestampServiceUtil.nextTimestamp(ITimestampService)

getEarliestActiveTx

protected AbstractTransactionService.TxState getEarliestActiveTx()

Return the AbstractTransactionService.TxState for the earliest active Tx -or- null if there is no active tx.

Note: The AbstractTransactionService.lock is required in order to make atomic decisions about the earliest active tx. Without the AbstractTransactionService.lock, the tx could stop or a new tx could start, thereby invalidating the "earliest active" guarantee.

Exposed to the test suite.

This version takes the lock since we are controlling concurrency explicitly in the test suite. This makes it easier to write the tests.

Overrides:

getEarliestActiveTx in class AbstractTransactionService

getTxState

protected AbstractTransactionService.TxState getTxState(long txId)

Return the AbstractTransactionService.TxState associated with the specified transition identifier.

Note: This method is an internal API. The caller must adhere to the internal synchronization APIs for the transaction service.

Exposed to the test suite.

Overrides:

getTxState in class AbstractTransactionService

Parameters:

txId - The transaction identifier (the signed value, NOT the absolute value).

Returns:

The AbstractTransactionService.TxState -or- null if there is no such active transaction.