beehive.validation

Class ConcurrentValidatorWithTruncation

java.lang.Object

beehive.validation.ConcurrentValidatorWithTruncation

public class ConcurrentValidatorWithTruncation
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
Config	configParams
java.util.concurrent.ConcurrentHashMap<java.lang.String,beehive.validation.NodeRWLock>	cTable
java.util.List<java.util.concurrent.locks.ReentrantLock>	cTableLockList
java.util.ArrayList<java.lang.Long>	sortedActiveTSList
long	tts
java.util.concurrent.locks.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, java.util.HashSet<java.lang.String> conflictSet)
long	syncValidate(long startTS, RWSetInfo rwSet, java.util.HashSet<java.lang.String> conflictSet)
void	update(long cmtTS, RWSetInfo rwSet)
long	validate(long startTS, RWSetInfo rwSet, java.util.HashSet<java.lang.String> conflictSet)
long	validateAndUpdate(long startTS, long cmtTS, RWSetInfo rwSet, java.util.HashSet<java.lang.String> refetchSet)

Methods inherited from class java.lang.Object

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

Field Detail

cTable

public java.util.concurrent.ConcurrentHashMap<java.lang.String,beehive.validation.NodeRWLock> cTable

sortedActiveTSList

public java.util.ArrayList<java.lang.Long> sortedActiveTSList

tts

public long tts

ttsLock

public java.util.concurrent.locks.ReentrantLock ttsLock

cTableLockList

public java.util.List<java.util.concurrent.locks.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,
                         java.util.HashSet<java.lang.String> conflictSet)

speculativeValidate

public long speculativeValidate(long startTS,
                                RWSetInfo rwSet,
                                java.util.HashSet<java.lang.String> conflictSet)

validate

public long validate(long startTS,
                     RWSetInfo rwSet,
                     java.util.HashSet<java.lang.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,
                              java.util.HashSet<java.lang.String> refetchSet)