public class ConcurrentValidatorWithTruncation
extends java.lang.Object
| 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 and Description |
|---|
ConcurrentValidatorWithTruncation(TimestampManager timestampMgr) |
| 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) |
public java.util.concurrent.ConcurrentHashMap<java.lang.String,beehive.validation.NodeRWLock> cTable
public java.util.ArrayList<java.lang.Long> sortedActiveTSList
public long tts
public java.util.concurrent.locks.ReentrantLock ttsLock
public java.util.List<java.util.concurrent.locks.ReentrantLock> cTableLockList
public Config configParams
public ConcurrentValidatorWithTruncation(TimestampManager timestampMgr)
public void advanceTruncationTime()
public long syncValidate(long startTS,
RWSetInfo rwSet,
java.util.HashSet<java.lang.String> conflictSet)
public long speculativeValidate(long startTS,
RWSetInfo rwSet,
java.util.HashSet<java.lang.String> conflictSet)
public long validate(long startTS,
RWSetInfo rwSet,
java.util.HashSet<java.lang.String> conflictSet)
public boolean acquireLocksOnWriteSet(RWSetInfo rwSet)
public void releaseLock(RWSetInfo rwSet)
public void update(long cmtTS,
RWSetInfo rwSet)
public long validateAndUpdate(long startTS,
long cmtTS,
RWSetInfo rwSet,
java.util.HashSet<java.lang.String> refetchSet)