beehive.worker

Class Worker

java.lang.Object

java.rmi.server.RemoteObject

java.rmi.server.RemoteServer

java.rmi.server.UnicastRemoteObject

beehive.worker.Worker

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable, java.rmi.Remote

public abstract class Worker
extends java.rmi.server.UnicastRemoteObject
implements java.lang.Runnable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
Config	configParams
StorageSystem	dataStorage
long	endTime
boolean	globalValidationEnable
Logger	log
boolean	master
java.util.Map<java.lang.String,java.lang.Long>	readsetTS
RWSetInfo	rwsetinfo
long	startTime
static long	STS_DELAY
java.util.HashSet<Task>	tasksCreated
java.util.Hashtable<java.lang.String,Node>	updatedNodes
java.util.Hashtable<java.lang.String,NodeData>	updatedNodesData
int	workerId
WorkerStatus	workerStatus
LocalWorkpoolImpl	workpool

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

Constructors

Constructor and Description
Worker(java.lang.String configFile, LocalWorkpoolImpl wpool, int workerNum, StorageSystem dataStore, boolean master)

Method Summary

Modifier and Type	Method and Description
TransactionInfo	beginTransaction()
void	cleanUp()
boolean	commitTransaction(TransactionInfo txnInfo)
abstract void	doTask(Task tsk)
protected java.util.Vector<Node>	getLocalNeighbors(Node u)
protected java.util.Vector<java.lang.String>	getNeighborIds(Node u)
java.util.Vector<Node>	getNeighbors(Node u)
protected java.util.Vector<Node>	getRemoteNeighbors(java.util.Vector<java.lang.String> nbrKeys)
java.lang.String	getStats()
void	recordStat(StatContainer stat, float value)
void	run()
boolean	validateTask(Task tsk)
boolean	validateTransaction(TransactionInfo txnInfo)

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

workpool

public LocalWorkpoolImpl workpool

dataStorage

public StorageSystem dataStorage

rwsetinfo

public RWSetInfo rwsetinfo

updatedNodes

public java.util.Hashtable<java.lang.String,Node> updatedNodes

updatedNodesData

public java.util.Hashtable<java.lang.String,NodeData> updatedNodesData

readsetTS

public java.util.Map<java.lang.String,java.lang.Long> readsetTS

tasksCreated

public java.util.HashSet<Task> tasksCreated

configParams

public Config configParams

workerId

public int workerId

master

public boolean master

startTime

public long startTime

endTime

public long endTime

workerStatus

public WorkerStatus workerStatus

log

public Logger log

STS_DELAY

public static long STS_DELAY

globalValidationEnable

public boolean globalValidationEnable

Constructor Detail

Worker

public Worker(java.lang.String configFile,
              LocalWorkpoolImpl wpool,
              int workerNum,
              StorageSystem dataStore,
              boolean master)
       throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

Method Detail

cleanUp

public void cleanUp()

getNeighbors

public java.util.Vector<Node> getNeighbors(Node u)
                                    throws java.lang.Exception

Throws:

java.lang.Exception

getLocalNeighbors

protected java.util.Vector<Node> getLocalNeighbors(Node u)
                                            throws java.lang.Exception

Throws:

java.lang.Exception

getRemoteNeighbors

protected java.util.Vector<Node> getRemoteNeighbors(java.util.Vector<java.lang.String> nbrKeys)
                                             throws java.lang.Exception

Throws:

java.lang.Exception

getNeighborIds

protected java.util.Vector<java.lang.String> getNeighborIds(Node u)

beginTransaction

public final TransactionInfo beginTransaction()
                                       throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

doTask

public abstract void doTask(Task tsk)
                     throws java.lang.Exception

Throws:

java.lang.Exception

validateTask

public boolean validateTask(Task tsk)
                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

validateTransaction

public boolean validateTransaction(TransactionInfo txnInfo)
                            throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

commitTransaction

public boolean commitTransaction(TransactionInfo txnInfo)

run

public void run()

Specified by:

run in interface java.lang.Runnable

recordStat

public void recordStat(StatContainer stat,
                       float value)

getStats

public java.lang.String getStats()