beehive.workpool

Class LocalWorkpoolImpl

java.lang.Object

java.rmi.server.RemoteObject

java.rmi.server.RemoteServer

java.rmi.server.UnicastRemoteObject

beehive.workpool.LocalWorkpoolImpl

All Implemented Interfaces:

LocalWorkpoolServer, java.io.Serializable, java.rmi.Remote

public class LocalWorkpoolImpl
extends java.rmi.server.UnicastRemoteObject
implements LocalWorkpoolServer

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.Integer	abortOnStartCounter
static java.lang.Integer	BARRIER_FINISHED
static java.lang.Integer	BARRIER_PENDING
Config	configParams
static long	GAP_TIME
static int	INIT
static int	INIT_PENDING
static int	JOB_FINISHED
static int	JOB_STARTED
java.util.concurrent.ConcurrentHashMap<java.lang.String,LoadInfo>	loadInfoTable
StatContainer	localDepStats
java.lang.StringBuffer	logBuffer
java.lang.String	modelType
java.lang.String	myHost
java.util.Vector<java.lang.String>	peerList
static long	SLEEP_TIME
static long	STS_DELAY
java.util.concurrent.ConcurrentHashMap<java.lang.String,LocalWorkpoolServer>	wpoolHandles

Constructor Summary

Constructors

Constructor and Description
LocalWorkpoolImpl(java.lang.String globalWpoolHostname, int workerCount)

Method Summary

Modifier and Type	Method and Description
void	addTask(Task t)
void	addTask(java.util.Vector<Task> taskVector)
void	barrierJoin(java.lang.String remoteHost)
void	broadcast(Task t)
boolean	checkTermination()
void	depositTask(Task t)
LoadInfo	depositTasks(java.util.Vector<Task> taskList)
LoadInfo	getLoadInfo()
int	getMyLoad()
java.lang.String	getNewTID()
ProgressStatus	getProgressStatus()
java.lang.String	getStats()
int	getStatus()
long	getSTS()
WorkStatus	getTask()
LoadInfo	getTerminationStatus(int oldts, int newts)
void	lookupPeers(java.util.Vector<java.lang.String> hostList)
void	printProgress()
void	proceedToClustering()
void	removeTask(Task t)
void	reportAbortOnStart()
void	reportCompletion(Task t, java.util.HashSet<Task> tasksCreated)
void	reportInitialization()
void	reportJobCompletion()
void	reportStartup()
void	reportTransactionCompletion(long commitTS)
void	setStatusInit()
void	updateLoadInfo(java.util.Vector<LoadInfo> loadVector)
void	updateSTS(long sts)
ValidateResponse	validate(Task t, RWSetInfo rwSetInfo)

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

wpoolHandles

public java.util.concurrent.ConcurrentHashMap<java.lang.String,LocalWorkpoolServer> wpoolHandles

loadInfoTable

public java.util.concurrent.ConcurrentHashMap<java.lang.String,LoadInfo> loadInfoTable

peerList

public java.util.Vector<java.lang.String> peerList

localDepStats

public StatContainer localDepStats

logBuffer

public java.lang.StringBuffer logBuffer

configParams

public Config configParams

INIT_PENDING

public static final int INIT_PENDING

See Also:

Constant Field Values

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

BARRIER_PENDING

public static final java.lang.Integer BARRIER_PENDING

BARRIER_FINISHED

public static final java.lang.Integer BARRIER_FINISHED

SLEEP_TIME

public static long SLEEP_TIME

GAP_TIME

public static long GAP_TIME

STS_DELAY

public static long STS_DELAY

modelType

public java.lang.String modelType

myHost

public java.lang.String myHost

abortOnStartCounter

public java.lang.Integer abortOnStartCounter

Constructor Detail

LocalWorkpoolImpl

public LocalWorkpoolImpl(java.lang.String globalWpoolHostname,
                         int workerCount)
                  throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

Method Detail

depositTasks

public LoadInfo depositTasks(java.util.Vector<Task> taskList)
                      throws java.rmi.RemoteException

Specified by:

depositTasks in interface LocalWorkpoolServer

Throws:

java.rmi.RemoteException

depositTask

public void depositTask(Task t)

reportJobCompletion

public void reportJobCompletion()
                         throws java.rmi.RemoteException

Specified by:

reportJobCompletion in interface LocalWorkpoolServer

Throws:

java.rmi.RemoteException

reportAbortOnStart

public void reportAbortOnStart()

getLoadInfo

public LoadInfo getLoadInfo()
                     throws java.rmi.RemoteException

Specified by:

getLoadInfo in interface LocalWorkpoolServer

Throws:

java.rmi.RemoteException

getTerminationStatus

public LoadInfo getTerminationStatus(int oldts,
                                     int newts)
                              throws java.rmi.RemoteException

Specified by:

getTerminationStatus in interface LocalWorkpoolServer

Throws:

java.rmi.RemoteException

barrierJoin

public void barrierJoin(java.lang.String remoteHost)

Specified by:

barrierJoin in interface LocalWorkpoolServer

getProgressStatus

public ProgressStatus getProgressStatus()

lookupPeers

public void lookupPeers(java.util.Vector<java.lang.String> hostList)

reportInitialization

public void reportInitialization()
                          throws java.rmi.RemoteException

Specified by:

reportInitialization in interface LocalWorkpoolServer

Throws:

java.rmi.RemoteException

reportStartup

public void reportStartup()
                   throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getStatus

public int getStatus()

setStatusInit

public void setStatusInit()

proceedToClustering

public void proceedToClustering()

broadcast

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

Throws:

java.rmi.RemoteException

addTask

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

Throws:

java.rmi.RemoteException

addTask

public void addTask(java.util.Vector<Task> taskVector)
             throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getTask

public WorkStatus getTask()
                   throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getNewTID

public java.lang.String getNewTID()

validate

public ValidateResponse validate(Task t,
                                 RWSetInfo rwSetInfo)
                          throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getSTS

public long getSTS()
            throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

updateSTS

public void updateSTS(long sts)

updateLoadInfo

public void updateLoadInfo(java.util.Vector<LoadInfo> loadVector)

removeTask

public void removeTask(Task t)

reportTransactionCompletion

public void reportTransactionCompletion(long commitTS)

reportCompletion

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

Throws:

java.rmi.RemoteException

printProgress

public void printProgress()

getStats

public java.lang.String getStats()

getMyLoad

public int getMyLoad()

checkTermination

public boolean checkTermination()
                         throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException