com.bigdata.service

Class DistributedTransactionService.NotifyReleaseTimeTask

java.lang.Object

com.bigdata.service.DistributedTransactionService.NotifyReleaseTimeTask

All Implemented Interfaces:

Runnable

Enclosing class:

DistributedTransactionService

protected class DistributedTransactionService.NotifyReleaseTimeTask
extends Object
implements Runnable

Task periodically notifies the discovered IDataServices of the new release time.

Note: Running a concurrent instance of this could cause release times to be distributed that do not strictly advance. If you need to do this, e.g., in order to immediately update the release time, then also introduce a lock for this task on the AbstractTransactionService so that instances of the task must run in sequence.

Author:

Bryan Thompson

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DistributedTransactionService.NotifyReleaseTimeTask()

Method Summary

Methods

Modifier and Type	Method and Description
void	run() Notifies all IDataServices of the current release time.

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedTransactionService.NotifyReleaseTimeTask

protected DistributedTransactionService.NotifyReleaseTimeTask()

Method Detail

run

public void run()

Notifies all IDataServices of the current release time.

Note: An IDataService WILL NOT release its most current commit point, regardless of the releaseTime that is sent to that service.

Note: If this method throws an exception then the task will no longer be scheduled!

Specified by:

run in interface Runnable