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:

GlobalWorkpoolServer, ValidationService, WorkpoolServer, java.io.Serializable, java.lang.Runnable, java.rmi.Remote

public class GlobalWorkpoolImpl
extends java.rmi.server.UnicastRemoteObject
implements GlobalWorkpoolServer, ValidationService, java.lang.Runnable

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

Constructor Summary

Constructors

Constructor and Description
GlobalWorkpoolImpl()

Method Summary

Modifier and Type	Method and Description
void	addTask(Task t)
java.util.Vector<LoadInfo>	buildLoadInfo()
java.util.Vector<Task>	buildLocalityTaskBatch(java.lang.String hostname)
java.util.Vector<Task>	buildTaskBatch(java.lang.String hostname)
java.lang.String	getStats()
java.lang.String	getStatsInternal()
long	getSTS()
WorkStatus	getTask()
WorkStatus	getTaskForHost(java.lang.String hostname)
static void	main(java.lang.String[] args)
void	printFinalStats()
void	printProgress()
long	reportCompletion(long commitTS)
long	reportCompletion(Task t, java.util.HashSet<Task> tasksCreated)
long	reportCompletion(java.util.Vector<java.lang.Long> commitTSList)
void	reportStartup(java.lang.String url)
void	run()
void	updateLoadInfo(LoadInfo loadInfo)
ValidateResponse	validate(long startTS, RWSetInfo rwSetInfo, LoadInfo myLoadInfo)
java.util.Hashtable<java.lang.String,ValidateResponse>	validateBatch(java.util.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

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 java.rmi.RemoteException

Throws:

java.rmi.RemoteException

Method Detail

printProgress

public void printProgress()

reportStartup

public void reportStartup(java.lang.String url)
                   throws java.rmi.RemoteException

Specified by:

reportStartup in interface GlobalWorkpoolServer

Throws:

java.rmi.RemoteException

addTask

public void addTask(Task t)
             throws java.rmi.RemoteException

Specified by:

addTask in interface WorkpoolServer

Throws:

java.rmi.RemoteException

reportCompletion

public long reportCompletion(long commitTS)
                      throws java.rmi.RemoteException

Specified by:

reportCompletion in interface ValidationService

Throws:

java.rmi.RemoteException

reportCompletion

public long reportCompletion(java.util.Vector<java.lang.Long> commitTSList)
                      throws java.rmi.RemoteException

Specified by:

reportCompletion in interface ValidationService

Throws:

java.rmi.RemoteException

reportCompletion

public long reportCompletion(Task t,
                             java.util.HashSet<Task> tasksCreated)
                      throws java.rmi.RemoteException

Specified by:

reportCompletion in interface WorkpoolServer

Throws:

java.rmi.RemoteException

validate

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

Specified by:

validate in interface ValidationService

Throws:

java.rmi.RemoteException

validateBatch

public java.util.Hashtable<java.lang.String,ValidateResponse> validateBatch(java.util.Queue<ValidationRequest> requestBatch,
                                                                            LoadInfo myLoad)
                                                                     throws java.rmi.RemoteException

Specified by:

validateBatch in interface ValidationService

Throws:

java.rmi.RemoteException

buildLoadInfo

public java.util.Vector<LoadInfo> buildLoadInfo()

updateLoadInfo

public void updateLoadInfo(LoadInfo loadInfo)

getSTS

public long getSTS()
            throws java.rmi.RemoteException

Specified by:

getSTS in interface ValidationService

Throws:

java.rmi.RemoteException

printFinalStats

public void printFinalStats()

getStats

public java.lang.String getStats()
                          throws java.rmi.RemoteException

Specified by:

getStats in interface GlobalWorkpoolServer

Throws:

java.rmi.RemoteException

getStatsInternal

public java.lang.String getStatsInternal()

run

public void run()

Specified by:

run in interface java.lang.Runnable

main

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

Throws:

java.lang.Exception

getTask

public WorkStatus getTask()
                   throws java.rmi.RemoteException

Specified by:

getTask in interface WorkpoolServer

Throws:

java.rmi.RemoteException

buildLocalityTaskBatch

public java.util.Vector<Task> buildLocalityTaskBatch(java.lang.String hostname)

buildTaskBatch

public java.util.Vector<Task> buildTaskBatch(java.lang.String hostname)

getTaskForHost

public WorkStatus getTaskForHost(java.lang.String hostname)
                          throws java.rmi.RemoteException

Specified by:

getTaskForHost in interface GlobalWorkpoolServer

Throws:

java.rmi.RemoteException