beehive.workpool

Class LocalValidator

java.lang.Object

beehive.workpool.LocalValidator

public class LocalValidator
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	BATCHSIZE

Constructor Summary

Constructors

Constructor and Description
LocalValidator(java.lang.String validatorHostname)

Method Summary

Modifier and Type	Method and Description
java.util.Queue<ValidationRequest>	fetchBatch()
java.lang.String	getStats()
boolean	isBatchReady()
void	notifyWaitingThreads()
void	processResponse(java.lang.String tid, ValidateResponse response, RWSetInfo rwSet)
ValidateResponse	validate(java.lang.String tid, long startTS, RWSetInfo rwSet, LoadInfo myLoadInfo)

Methods inherited from class java.lang.Object

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

Field Detail

BATCHSIZE

public static int BATCHSIZE

Constructor Detail

LocalValidator

public LocalValidator(java.lang.String validatorHostname)

Method Detail

validate

public ValidateResponse validate(java.lang.String tid,
                                 long startTS,
                                 RWSetInfo rwSet,
                                 LoadInfo myLoadInfo)

processResponse

public void processResponse(java.lang.String tid,
                            ValidateResponse response,
                            RWSetInfo rwSet)

isBatchReady

public boolean isBatchReady()

fetchBatch

public java.util.Queue<ValidationRequest> fetchBatch()

notifyWaitingThreads

public void notifyWaitingThreads()

getStats

public java.lang.String getStats()