com.bigdata.service

Class AbstractHATransactionService

java.lang.Object

com.bigdata.service.AbstractService

com.bigdata.service.AbstractTransactionService

com.bigdata.service.AbstractHATransactionService

All Implemented Interfaces:

ICounterSetAccess, HATXSGlue, ITimestampService, ITransactionService, IService, IServiceShutdown, Remote

Direct Known Subclasses:

JournalTransactionService

public abstract class AbstractHATransactionService
extends AbstractTransactionService
implements HATXSGlue

Adds local methods to support an HA aware ITransactionService.

Author:

Bryan Thompson

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
AbstractHATransactionService(Properties properties)

Method Summary

Methods

Modifier and Type	Method and Description
abstract Callable<IHANotifyReleaseTimeResponse>	newGatherMinimumVisibleCommitTimeTask(HAGlue leader, UUID serviceId, IHAGatherReleaseTimeRequest req) Factory for the Gather task that will be executed by the follower.
abstract void	runWithBarrierLock(Runnable r) Used to make a serviceJoin() MUTEX with the consensus protocol.
void	setReleaseTime(long newReleaseTime) Sets the new release time.
abstract IHANotifyReleaseTimeResponse	updateReleaseTimeConsensus(long newCommitCounter, long newCommitTime, UUID[] joinedServiceIds, long timeout, TimeUnit units) Coordinate the update of the releaseTime on each service that is joined with the met quorum.

Methods inherited from class com.bigdata.service.AbstractTransactionService

abort, abortAllTx, abortImpl, activateTx, assertOpen, assignTransactionIdentifier, commit, commitImpl, deactivateTx, destroy, findCommitTime, findNextCommitTime, findUnusedTimestamp, getAbortCount, getActiveCount, getCommitCount, getCounters, getEarliestActiveTx, getEffectiveReleaseTimeForHA, getLastCommitTime, getMinReleaseAge, getProperties, getReadOnlyActiveCount, getReadsOnTime, getReadWriteActiveCount, getReleaseTime, getRunState, getServiceIface, getStartCount, getTxState, isOpen, isReleaseTimeConsensusProtocol, newTx, nextTimestamp, notifyCommit, setRunState, shutdown, shutdownNow, start, updateReleaseTime, updateReleaseTimeForBareCommit

Methods inherited from class com.bigdata.service.AbstractService

clearLoggingContext, getFederation, 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.ha.HATXSGlue

gatherMinimumVisibleCommitTime, notifyEarliestCommitTime

Methods inherited from interface com.bigdata.service.IService

getHostname, getServiceName, getServiceUUID

Constructor Detail

AbstractHATransactionService

public AbstractHATransactionService(Properties properties)

Method Detail

newGatherMinimumVisibleCommitTimeTask

public abstract Callable<IHANotifyReleaseTimeResponse> newGatherMinimumVisibleCommitTimeTask(HAGlue leader,
                                                                           UUID serviceId,
                                                                           IHAGatherReleaseTimeRequest req)

Factory for the Gather task that will be executed by the follower.

Parameters:

leader - The proxy for the quorum leader (the service that made this request). This is used to RMI back to the leader and therefore MUST be non- null.

serviceId - The UUID of this service. This is required as part of the RMI back to the leader (so the leader knows which services responded) and therefore MUST be non-null.

req - The request.

Returns:

The task to run on the follower.

See Also:

Native thread leak in HAJournalServer process

updateReleaseTimeConsensus

public abstract IHANotifyReleaseTimeResponse updateReleaseTimeConsensus(long newCommitCounter,
                                                      long newCommitTime,
                                                      UUID[] joinedServiceIds,
                                                      long timeout,
                                                      TimeUnit units)
                                                                 throws IOException,
                                                                        TimeoutException,
                                                                        InterruptedException,
                                                                        Exception

Coordinate the update of the releaseTime on each service that is joined with the met quorum.

Parameters:

newCommitCounter - The commit counter that will be assigned to the new commit point.

newCommitTime - The commit time that will be assigned to the new commit point.

joinedServiceIds - The services that are joined with the met quorum as of an atomic decision point in AbstractJournal#commitNow().

timeout - The timeout for the release time consensus protocol.

units - The units for that timeout.

Throws:

IOException

TimeoutException

InterruptedException

Exception

runWithBarrierLock

public abstract void runWithBarrierLock(Runnable r)

Used to make a serviceJoin() MUTEX with the consensus protocol.

setReleaseTime

public void setReleaseTime(long newReleaseTime)

Sets the new release time.

Note: For a joined service in HA (the leader or a follower), the release time is set by the consensus protocol. Otherwise it is automatically maintained by AbstractTransactionService.updateReleaseTime(long, TxState) and AbstractTransactionService.updateReleaseTimeForBareCommit(long).

Overridden to expose this method so it may be invoked when a follower joins an existing quorum to set the consensus release time of the quorum leader of the newly joined follower. This prevents the follower from permitting new transaction starts against a commit point which has been recycled by the quorum leader.

Overrides:

setReleaseTime in class AbstractTransactionService

Parameters:

newReleaseTime - The new value.

See Also:

Query on follower fails during UPDATE on leader