beehive.util

Class HostDispatchTable

java.lang.Object

beehive.util.HostDispatchTable

public class HostDispatchTable
extends Object

Hostwise Request aggragated in this class. It also has the worker requests.

Field Summary

Fields

Modifier and Type	Field and Description
static String	RPC_MECHANISM

Constructor Summary

Constructors

Constructor and Description
HostDispatchTable(StorageSystem strsys)

Method Summary

Modifier and Type	Method and Description
void	clearWorkerRequest(Long wrkId)
void	dispatchBatch(Integer hostId)
void	doGetNodeData(WorkerRequest wrkReq, ConcurrentHashMap<Integer,Vector<NodeData>> hostNodeDataBucket)

Methods inherited from class java.lang.Object

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

Field Detail

RPC_MECHANISM

public static String RPC_MECHANISM

Constructor Detail

HostDispatchTable

public HostDispatchTable(StorageSystem strsys)

Method Detail

doGetNodeData

public void doGetNodeData(WorkerRequest wrkReq,
                          ConcurrentHashMap<Integer,Vector<NodeData>> hostNodeDataBucket)
                   throws InterruptedException

Throws:

InterruptedException

dispatchBatch

public void dispatchBatch(Integer hostId)
                   throws InterruptedException

Throws:

InterruptedException

clearWorkerRequest

public void clearWorkerRequest(Long wrkId)