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 class Worker
extends java.rmi.server.UnicastRemoteObject
implements java.lang.Runnable

Author:

varun Worker class does not contain any Application related data It deals with Node and not with any derived classes of this

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
Config	configParams
StorageSystem	dataStorage
long	endTime
Logger	log
boolean	master
RWSetInfo	rwsetinfo
long	startTime
StatContainer	statCommitTaskTime
StatContainer	statComputeTime
StatContainer	statDoTaskTime
StatContainer	statGetTaskTime
StatContainer	statValidateTime
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

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()
void	commitTask(Task t)
void	doTask(Task tsk)
boolean	earlyValidation(Task t, java.util.Vector<Node> readNodes, java.util.Vector<NodeData> readNodesData)
java.util.Vector<Node>	getLocalNeighbors(Node u)
java.util.Vector<java.lang.String>	getNeighborIds(Node u)
java.util.Vector<Node>	getNeighbors(Node u)
java.util.Vector<Node>	getRemoteNeighbors(java.util.Vector<java.lang.String> nbrKeys)
java.lang.String	getStats()
void	recordStat(StatContainer stat, float value)
java.util.Vector<Node>	refetchNodes(java.util.HashSet<java.lang.String> refetchSet, java.util.Vector<Node> neighborNodes)
void	run()

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

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

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

statGetTaskTime

public StatContainer statGetTaskTime

statDoTaskTime

public StatContainer statDoTaskTime

statComputeTime

public StatContainer statComputeTime

statValidateTime

public StatContainer statValidateTime

statCommitTaskTime

public StatContainer statCommitTaskTime

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

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

Throws:

java.lang.Exception

getRemoteNeighbors

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

Throws:

java.lang.Exception

getNeighborIds

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

beginTransaction

public TransactionInfo beginTransaction()
                                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

doTask

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

Throws:

java.lang.Exception

commitTask

public void commitTask(Task t)

earlyValidation

public boolean earlyValidation(Task t,
                               java.util.Vector<Node> readNodes,
                               java.util.Vector<NodeData> readNodesData)

refetchNodes

public java.util.Vector<Node> refetchNodes(java.util.HashSet<java.lang.String> refetchSet,
                                           java.util.Vector<Node> neighborNodes)
                                    throws java.lang.Exception

Throws:

java.lang.Exception

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