beehive.workpool

Class GlobalWorkpoolImpl

java.lang.Object

java.rmi.server.RemoteObject

java.rmi.server.RemoteServer

java.rmi.server.UnicastRemoteObject

beehive.workpool.GlobalWorkpoolImpl

All Implemented Interfaces:

ValidationService_thrift.Iface, ValidationService, Serializable, Runnable, Remote

public class GlobalWorkpoolImpl
extends UnicastRemoteObject
implements ValidationService, Runnable, ValidationService_thrift.Iface

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
Config	configParams
static int	DISPATCH_BATCH_SIZE
static long	idleTimeInterval
static int	INIT
static int	JOB_FINISHED
static int	JOB_STARTED
boolean	locality
boolean	logging
static int	NOAFFINITY_BATCH_SIZE
static long	printProgressInterval

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

Constructors

Constructor and Description
GlobalWorkpoolImpl()

Method Summary

Modifier and Type	Method and Description
void	addTask(Task t)
Map<String,ValidateResponse_thrift>	batchValidate_thrift(List<ValidationRequest_thrift> requests)
Vector<LoadInfo>	buildLoadInfo()
Vector<Task>	buildLocalityTaskBatch(String hostname)
Vector<Task>	buildTaskBatch(String hostname)
String	getStats()
String	getStatsInternal()
long	getSTS_thrift()
long	getSTS()
WorkStatus	getTask()
WorkStatus	getTaskForHost(String hostname)
static void	main(String[] args)
void	printFinalStats()
void	printProgress()
long	reportCompletion_thrift(long commitTS)
long	reportCompletion(long commitTS)
long	reportCompletion(Task t, HashSet<Task> tasksCreated)
long	reportCompletion(Vector<Long> commitTSList)
long	reportCompletionBatch_thrift(List<Long> commitTSList)
void	reportStartup(String url)
void	run()
void	updateLoadInfo(LoadInfo loadInfo)
ValidateResponse_thrift	validate_thrift(long startTS, RWSetInfo_thrift rwSet)
ValidateResponse	validate(long startTS, RWSetInfo rwSetInfo, LoadInfo myLoadInfo)
Hashtable<String,ValidateResponse>	validateBatch(Queue<ValidationRequest> requestBatch, LoadInfo myLoad)

Methods inherited from class java.rmi.server.UnicastRemoteObject

clone, exportObject, exportObject, exportObject, unexportObject

Methods inherited from class java.rmi.server.RemoteServer

getClientHost, getLog, setLog

Methods inherited from class java.rmi.server.RemoteObject

equals, getRef, hashCode, toString, toStub

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

configParams

public Config configParams

INIT

public static final int INIT

See Also:

Constant Field Values

JOB_STARTED

public static final int JOB_STARTED

See Also:

Constant Field Values

JOB_FINISHED

public static final int JOB_FINISHED

See Also:

Constant Field Values

DISPATCH_BATCH_SIZE

public static int DISPATCH_BATCH_SIZE

NOAFFINITY_BATCH_SIZE

public static int NOAFFINITY_BATCH_SIZE

printProgressInterval

public static long printProgressInterval

idleTimeInterval

public static long idleTimeInterval

locality

public boolean locality

logging

public boolean logging

Constructor Detail

GlobalWorkpoolImpl

public GlobalWorkpoolImpl()
                   throws RemoteException

Throws:

RemoteException

Method Detail

printProgress

public void printProgress()

reportStartup

public void reportStartup(String url)
                   throws RemoteException

Throws:

RemoteException

addTask

public void addTask(Task t)
             throws RemoteException

Throws:

RemoteException

reportCompletion

public long reportCompletion(long commitTS)
                      throws RemoteException

Specified by:

reportCompletion in interface ValidationService

Throws:

RemoteException

reportCompletion

public long reportCompletion(Vector<Long> commitTSList)
                      throws RemoteException

Specified by:

reportCompletion in interface ValidationService

Throws:

RemoteException

reportCompletion

public long reportCompletion(Task t,
                             HashSet<Task> tasksCreated)
                      throws RemoteException

Throws:

RemoteException

validate

public ValidateResponse validate(long startTS,
                                 RWSetInfo rwSetInfo,
                                 LoadInfo myLoadInfo)
                          throws RemoteException

Specified by:

validate in interface ValidationService

Throws:

RemoteException

validateBatch

public Hashtable<String,ValidateResponse> validateBatch(Queue<ValidationRequest> requestBatch,
                                                        LoadInfo myLoad)
                                                 throws RemoteException

Specified by:

validateBatch in interface ValidationService

Throws:

RemoteException

buildLoadInfo

public Vector<LoadInfo> buildLoadInfo()

updateLoadInfo

public void updateLoadInfo(LoadInfo loadInfo)

getSTS

public long getSTS()
            throws RemoteException

Specified by:

getSTS in interface ValidationService

Throws:

RemoteException

printFinalStats

public void printFinalStats()

getStats

public String getStats()
                throws RemoteException

Throws:

RemoteException

getStatsInternal

public String getStatsInternal()

run

public void run()

Specified by:

run in interface Runnable

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

getTask

public WorkStatus getTask()
                   throws RemoteException

Throws:

RemoteException

buildLocalityTaskBatch

public Vector<Task> buildLocalityTaskBatch(String hostname)

buildTaskBatch

public Vector<Task> buildTaskBatch(String hostname)

getTaskForHost

public WorkStatus getTaskForHost(String hostname)
                          throws RemoteException

Throws:

RemoteException

getSTS_thrift

public long getSTS_thrift()

Specified by:

getSTS_thrift in interface ValidationService_thrift.Iface

validate_thrift

public ValidateResponse_thrift validate_thrift(long startTS,
                                               RWSetInfo_thrift rwSet)
                                        throws org.apache.thrift.TException

Specified by:

validate_thrift in interface ValidationService_thrift.Iface

Throws:

org.apache.thrift.TException

reportCompletion_thrift

public long reportCompletion_thrift(long commitTS)

Specified by:

reportCompletion_thrift in interface ValidationService_thrift.Iface

reportCompletionBatch_thrift

public long reportCompletionBatch_thrift(List<Long> commitTSList)

Specified by:

reportCompletionBatch_thrift in interface ValidationService_thrift.Iface

batchValidate_thrift

public Map<String,ValidateResponse_thrift> batchValidate_thrift(List<ValidationRequest_thrift> requests)

Specified by:

batchValidate_thrift in interface ValidationService_thrift.Iface