beehive.workpool

Class ConcurrentValidator

java.lang.Object

beehive.workpool.ConcurrentValidator

public class ConcurrentValidator
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
Config	configParams

Constructor Summary

Constructors

Constructor and Description
ConcurrentValidator()

Method Summary

Modifier and Type	Method and Description
boolean	acquireLocksOnWriteSet(RWSetInfo rwSet)
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

configParams

public Config configParams

Constructor Detail

ConcurrentValidator

public ConcurrentValidator()

Method Detail

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)