beehive.workpool

Class ConcurrentValidatorWithTruncation

java.lang.Object

beehive.workpool.ConcurrentValidatorWithTruncation

public class ConcurrentValidatorWithTruncation
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
Config	configParams
ConcurrentHashMap<String,beehive.workpool.NodeRWLock>	cTable
List<ReentrantLock>	cTableLockList
ArrayList<Long>	sortedActiveTSList
long	tts
ReentrantLock	ttsLock

Constructor Summary

Constructors

Constructor and Description
ConcurrentValidatorWithTruncation(TimestampManager timestampMgr)

Method Summary

Modifier and Type	Method and Description
boolean	acquireLocksOnWriteSet(RWSetInfo rwSet)
void	advanceTruncationTime()
void	releaseLock(RWSetInfo rwSet)
long	speculativeValidate(long startTS, RWSetInfo rwSet, HashSet<String> conflictSet)
long	syncValidate(long startTS, RWSetInfo rwSet, HashSet<String> conflictSet)
void	update(long cmtTS, RWSetInfo rwSet)
long	validate(long startTS, RWSetInfo rwSet, HashSet<String> conflictSet)
long	validateAndUpdate(long startTS, long cmtTS, RWSetInfo rwSet, HashSet<String> refetchSet)

Methods inherited from class java.lang.Object

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

Field Detail

cTable

public ConcurrentHashMap<String,beehive.workpool.NodeRWLock> cTable

sortedActiveTSList

public ArrayList<Long> sortedActiveTSList

tts

public long tts

ttsLock

public ReentrantLock ttsLock

cTableLockList

public List<ReentrantLock> cTableLockList

configParams

public Config configParams

Constructor Detail

ConcurrentValidatorWithTruncation

public ConcurrentValidatorWithTruncation(TimestampManager timestampMgr)

Method Detail

advanceTruncationTime

public void advanceTruncationTime()

syncValidate

public long syncValidate(long startTS,
                         RWSetInfo rwSet,
                         HashSet<String> conflictSet)

speculativeValidate

public long speculativeValidate(long startTS,
                                RWSetInfo rwSet,
                                HashSet<String> conflictSet)

validate

public long validate(long startTS,
                     RWSetInfo rwSet,
                     HashSet<String> conflictSet)

acquireLocksOnWriteSet

public boolean acquireLocksOnWriteSet(RWSetInfo rwSet)

releaseLock

public void releaseLock(RWSetInfo rwSet)

update

public void update(long cmtTS,
                   RWSetInfo rwSet)

validateAndUpdate

public long validateAndUpdate(long startTS,
                              long cmtTS,
                              RWSetInfo rwSet,
                              HashSet<String> refetchSet)