beehive.workpool

Class LocalValidator

java.lang.Object

beehive.workpool.LocalValidator

public class LocalValidator
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	BATCHSIZE

Constructor Summary

Constructors

Constructor and Description
LocalValidator(ValidationService validationService)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

BATCHSIZE

public static int BATCHSIZE

Constructor Detail

LocalValidator

public LocalValidator(ValidationService validationService)
               throws IOException

Throws:

IOException

Method Detail

validate

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

processResponse

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

isBatchReady

public boolean isBatchReady()

fetchBatch

public Queue<ValidationRequest> fetchBatch()

notifyWaitingThreads

public void notifyWaitingThreads()

getStats

public String getStats()