com.bigdata.service

Class TestDistributedTransactionServiceRestart.MockDistributedTransactionService

java.lang.Object

com.bigdata.service.AbstractService

com.bigdata.service.AbstractTransactionService

com.bigdata.service.DistributedTransactionService

com.bigdata.service.TestDistributedTransactionServiceRestart.MockDistributedTransactionService

All Implemented Interfaces:

ICounterSetAccess, IDistributedTransactionService, ITimestampService, ITransactionService, IService, IServiceShutdown, Remote

Enclosing class:

TestDistributedTransactionServiceRestart

protected static class TestDistributedTransactionServiceRestart.MockDistributedTransactionService
extends DistributedTransactionService

Nested Class Summary

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

DistributedTransactionService.NotifyReleaseTimeTask, DistributedTransactionService.Options, DistributedTransactionService.SnapshotHelper

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

AbstractTransactionService.TxState

Field Summary

Fields inherited from class com.bigdata.service.DistributedTransactionService

BASENAME, commitTimeIndex, dataDir, EXT

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
TestDistributedTransactionServiceRestart.MockDistributedTransactionService(Properties properties)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addScheduledTasks() Note: The scheduled tasks are disabled for the unit test since we do not have a federation for this test.
AbstractFederation	getFederation() Return the proxy used to access other services in the federation.
protected void	setReleaseTime(long releaseTime) Extended to truncate the head of the DistributedTransactionService.commitTimeIndex such only the commit times requires for reading on timestamps GTE to the new releaseTime are retained.
TestDistributedTransactionServiceRestart.MockDistributedTransactionService	start() Verifies that AbstractTransactionService.nextTimestamp() will not report a time before AbstractTransactionService.getLastCommitTime() and then changes the TxServiceRunState to TxServiceRunState.Running.
protected void	updateReleaseTimeForBareCommit(long commitTime) This is overridden to be a NOP for this test suite.

Methods inherited from class com.bigdata.service.DistributedTransactionService

abortImpl, commitImpl, committed, declareResources, destroy, findCommitTime, findNextCommitTime, getCounters, getDataServices, getLastCommitTime, notifyCommit, prepared, shutdown, shutdownNow, singlePhaseCommit, snapshot

Methods inherited from class com.bigdata.service.AbstractTransactionService

abort, abortAllTx, activateTx, assertOpen, assignTransactionIdentifier, commit, deactivateTx, findUnusedTimestamp, getAbortCount, getActiveCount, getCommitCount, getEarliestActiveTx, getEffectiveReleaseTimeForHA, getMinReleaseAge, getProperties, getReadOnlyActiveCount, getReadsOnTime, getReadWriteActiveCount, getReleaseTime, getRunState, getServiceIface, getStartCount, getTxState, isOpen, isReleaseTimeConsensusProtocol, newTx, nextTimestamp, setRunState, updateReleaseTime

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.journal.ITransactionService

abort, commit, getReleaseTime, newTx

Methods inherited from interface com.bigdata.journal.ITimestampService

nextTimestamp

Methods inherited from interface com.bigdata.service.IService

getHostname, getServiceIface, getServiceName, getServiceUUID

Constructor Detail

TestDistributedTransactionServiceRestart.MockDistributedTransactionService

public TestDistributedTransactionServiceRestart.MockDistributedTransactionService(Properties properties)

Method Detail

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

setReleaseTime

protected void setReleaseTime(long releaseTime)

Description copied from class: DistributedTransactionService

Extended to truncate the head of the DistributedTransactionService.commitTimeIndex such only the commit times requires for reading on timestamps GTE to the new releaseTime are retained.

Overrides:

setReleaseTime in class DistributedTransactionService

Parameters:

releaseTime - The new value.

See Also:

Query on follower fails during UPDATE on leader

addScheduledTasks

protected void addScheduledTasks()

Note: The scheduled tasks are disabled for the unit test since we do not have a federation for this test.

Overrides:

addScheduledTasks in class DistributedTransactionService

start

public TestDistributedTransactionServiceRestart.MockDistributedTransactionService 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 DistributedTransactionService

Returns:

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

updateReleaseTimeForBareCommit

protected void updateReleaseTimeForBareCommit(long commitTime)

This is overridden to be a NOP for this test suite. The unit tests in this suite depend on the ability to inject specific commit times into the transaction service without having them "release" based on the actual system clock.

Overrides:

updateReleaseTimeForBareCommit in class AbstractTransactionService