beehive.workpool

Class LocalWorkpoolImpl

java.lang.Object

beehive.workpool.LocalWorkpoolImpl

All Implemented Interfaces:

CheckpointListener, LocalWorkpoolServer, java.rmi.Remote

public class LocalWorkpoolImpl
extends java.lang.Object
implements LocalWorkpoolServer, CheckpointListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	LocalWorkpoolImpl.PrintProgressStatusThread

Field Summary

Fields

Modifier and Type	Field and Description
Config	configParams
static long	GAP_TIME
boolean	globalValidationEnable
java.lang.String	modelType
java.lang.String	myHost
LocalWorkpoolImpl.PrintProgressStatusThread	progressStatusThread
boolean	recovery
static java.lang.String	RPC_MECHANISM
static long	SLEEP_TIME
int	status
static long	STS_DELAY
TaskComparator	taskComparator
ValidationService	validationService

Constructor Summary

Constructors

Constructor and Description
LocalWorkpoolImpl(java.lang.String validationHostDetail, int workerCount, int[] partitionedGraphHostNodesTable)
LocalWorkpoolImpl(java.lang.String validationHostDetail, int workerCount, int[] partitionedGraphHostNodesTable, boolean recover)

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	beginQuiescent()
void	broadcast(Task t)
void	checkpoint()
void	checkQuiescent()
LoadInfo	depositTasks(java.util.Vector<Task> taskList)
void	endQuiescent()
LoadInfo	getLoadInfo()
java.lang.String	getNewTID()
java.lang.String	getStats()
int	getStatus()
long	getSTS() Synchronizes the local stable timestamp with that of the global timestamp
WorkStatus	getTask()
LoadInfo	getTerminationStatus(int oldts, int newts)
WorkStatus	getWorkStatus()
void	lookupPeers(java.util.Vector<java.lang.String> hostList)
void	pause()
void	removeTask(Task t) Removes a task from the active workpool.
void	reportAbortOnStart()
void	reportCompletion(Task t, java.util.HashSet<Task> tasksCreated) A means to report the completion of the execution of a task.
void	reportInitialization()
void	reportJobCompletion()
void	reportQuiescent(java.lang.String remoteHost)
void	reportStartup()
void	reportTransactionCompletion(java.util.HashSet<Task> tasksCreated)
void	reportTransactionCompletion(long commitTS, java.util.HashSet<Task> tasksCreated) Provides the ability to report that a transaction/computation which does not rely on a Task structure has completed
void	saveState()
void	setStatusInit()
void	start()
void	updateLoadInfo(java.util.Vector<LoadInfo> loadVector) Each workpool caches the LoadInfo of its peers.
ValidateResponse	validate(Task t, RWSetInfo rwSetInfo)
ValidateResponse	validateTransaction(TransactionInfo txnInfo, RWSetInfo rwSetInfo) Provides the ability to validate a transaction/computation that does not rely on a Task structure

Methods inherited from class java.lang.Object

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

Field Detail

validationService

public ValidationService validationService

myHost

public java.lang.String myHost

progressStatusThread

public LocalWorkpoolImpl.PrintProgressStatusThread progressStatusThread

configParams

public Config configParams

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

RPC_MECHANISM

public static java.lang.String RPC_MECHANISM

globalValidationEnable

public boolean globalValidationEnable

status

public int status

taskComparator

public TaskComparator taskComparator

recovery

public boolean recovery

Constructor Detail

LocalWorkpoolImpl

public LocalWorkpoolImpl(java.lang.String validationHostDetail,
                         int workerCount,
                         int[] partitionedGraphHostNodesTable)
                  throws java.io.IOException

Throws:

java.io.IOException

LocalWorkpoolImpl

public LocalWorkpoolImpl(java.lang.String validationHostDetail,
                         int workerCount,
                         int[] partitionedGraphHostNodesTable,
                         boolean recover)
                  throws java.io.IOException

Throws:

java.io.IOException

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

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

pause

public void pause()
           throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

start

public void start()
           throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

saveState

public void saveState()
               throws java.rmi.RemoteException

Specified by:

saveState in interface LocalWorkpoolServer

Throws:

java.rmi.RemoteException

checkpoint

public void checkpoint()

Specified by:

checkpoint in interface CheckpointListener

beginQuiescent

public void beginQuiescent()
                    throws java.rmi.RemoteException

Specified by:

beginQuiescent in interface LocalWorkpoolServer

Throws:

java.rmi.RemoteException

reportQuiescent

public void reportQuiescent(java.lang.String remoteHost)

Specified by:

reportQuiescent in interface LocalWorkpoolServer

endQuiescent

public void endQuiescent()

Specified by:

endQuiescent in interface LocalWorkpoolServer

checkQuiescent

public void checkQuiescent()

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()

getWorkStatus

public WorkStatus getWorkStatus()

setStatusInit

public void setStatusInit()

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

validateTransaction

public ValidateResponse validateTransaction(TransactionInfo txnInfo,
                                            RWSetInfo rwSetInfo)
                                     throws java.rmi.RemoteException

Provides the ability to validate a transaction/computation that does not rely on a Task structure

Parameters:

txnInfo - The transaction's information

rwSetInfo - A set of nodeIds that may have been read or written to during the computation

Returns:

Information about the validation. Most important is the whether or not the task can be committed.

Throws:

java.rmi.RemoteException

getSTS

public long getSTS()
            throws java.rmi.RemoteException

Synchronizes the local stable timestamp with that of the global timestamp

Returns:

The current Stable timestamp of the system

Throws:

java.rmi.RemoteException - Thrown if the ValidationService could not be contacted

updateLoadInfo

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

Each workpool caches the LoadInfo of its peers. This is a means for this workpool to refresh its cache.

Parameters:

loadVector - The new loads of each workpool.

removeTask

public void removeTask(Task t)

Removes a task from the active workpool. If the workpools are configured to use BARRIER-JOIN, then if the load becomes 0, then the caller is blocked until all of its peers have joined the barrier.

Parameters:

t - The task that is to be removed.

reportCompletion

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

A means to report the completion of the execution of a task. If the task created additional tasks upon completion, then they will be distributed to all of the workpools in the cluster.

Parameters:

t - The task that is to reported for completion

tasksCreated - Any tasks created by the completed task

Throws:

java.rmi.RemoteException - Thrown if the created tasks could not be distributed

reportTransactionCompletion

public void reportTransactionCompletion(long commitTS,
                                        java.util.HashSet<Task> tasksCreated)
                                 throws java.rmi.RemoteException

Provides the ability to report that a transaction/computation which does not rely on a Task structure has completed

Parameters:

commitTS - The time at which the transaction was completed

tasksCreated - Any tasks created by the completed task

Throws:

java.rmi.RemoteException - Thrown if the created tasks could not be distributed

reportTransactionCompletion

public void reportTransactionCompletion(java.util.HashSet<Task> tasksCreated)
                                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getStats

public java.lang.String getStats()