| Package | Description |
|---|---|
| beehive.server | |
| beehive.util | |
| beehive.worker |
| Modifier and Type | Method and Description |
|---|---|
Node |
HashtableServerImpl.cacheEvict(java.lang.String nodeId)
cache eviction thread invokes this method when removing a copy from the cache table (cache replacement)
|
Node |
HashtableServer.getNodeForCaching(java.lang.String nodeID,
int cachingSite) |
Node |
HashtableServerImpl.getNodeForCaching(java.lang.String nodeId,
int cachingSite)
Remote server invokes this method on the master site when requesting a cache copy
|
Node |
HashtableServer.getNodeFromCacheTable(java.lang.String nodeId) |
Node |
HashtableServerImpl.getNodeFromCacheTable(java.lang.String nodeId)
get node for nodeId from the cache table
returns null if node not found
|
Node |
HashtableServer.getNodeFromTable(java.lang.String nodeId) |
Node |
HashtableServerImpl.getNodeFromTable(java.lang.String nodeId)
get a node from the table
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Vector<Node> |
HashtableServer.getAllNodes() |
java.util.Vector<Node> |
HashtableServerImpl.getAllNodes()
Get all nodes present in the main table (does not include cache table)
|
java.util.Vector<Node> |
HashtableServer.getCachedObjects(java.util.Vector<java.lang.String> nodeIds) |
java.util.Vector<Node> |
HashtableServerImpl.getCachedObjects(java.util.Vector<java.lang.String> nodeIds) |
java.util.Vector<Node> |
HashtableServer.getNodesForCaching(java.util.Vector<java.lang.String> nodeIds,
int callingSite) |
java.util.Vector<Node> |
HashtableServerImpl.getNodesForCaching(java.util.Vector<java.lang.String> nodeIds,
int cachingSite)
Bulk call for getNodeForCaching
|
| Modifier and Type | Method and Description |
|---|---|
void |
ReflectionServer.addNode(Node node) |
ResultObject |
HashtableServer.cachePut(java.lang.String nodeID,
Node node,
int masterCopySite,
long storageSystemThreadId) |
ResultObject |
HashtableServerImpl.cachePut(java.lang.String nodeId,
Node node,
int masterCopySite,
long storageSystemThreadId)
Once a node has been fetched for caching, insert into cache table.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Vector<ResultObject> |
HashtableServer.cachePut(java.util.Map<java.lang.Integer,java.util.Vector<Node>> nodes,
long storageSystemThreadId) |
java.util.Vector<ResultObject> |
HashtableServerImpl.cachePut(java.util.Map<java.lang.Integer,java.util.Vector<Node>> nodes,
long storageSystemThreadId)
Bulk call for cachePut
|
void |
HashtableServer.loadNodes(java.util.Vector<Node> nodes) |
void |
HashtableServerImpl.loadNodes(java.util.Vector<Node> nodes)
To load initial nodes into the table, used by the file loader
|
java.util.Vector<ResultObject> |
HashtableServer.putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList) |
java.util.Vector<ResultObject> |
HashtableServerImpl.putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList)
putObjects back into the hash table
|
java.util.Vector<ResultObject> |
HashtableServer.putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList,
int callerServerId) |
java.util.Vector<ResultObject> |
HashtableServerImpl.putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList,
int callingServerId)
put objects back into the hash table for the write through cache case
|
void |
HashtableServer.writeThroughToCacheBulk(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> map) |
void |
HashtableServerImpl.writeThroughToCacheBulk(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> map)
bulk call for writeThroughToCache
|
| Modifier and Type | Method and Description |
|---|---|
Node |
StorageSystem.getNode(java.lang.String paramString)
get node from local or remote and return to application
|
Node |
StorageSystem.getNode(java.lang.String paramString,
boolean withCaching)
similar to getNode, with an additional application level directive to control caching
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<java.lang.Integer,java.util.Vector<Node>> |
GetRemoteNodes.call() |
java.util.Vector<Node> |
StorageSystem.getAllNodes() |
java.util.Vector<Node> |
StorageSystem.getLocalNodes(java.util.Vector<java.lang.String> paramVector) |
java.util.Vector<Node> |
StorageSystem.getLocalNodes(java.util.Vector<java.lang.String> paramVector,
boolean withCaching) |
java.util.Vector<Node> |
StorageSystem.getNodesParallel(java.util.Vector<java.lang.String> paramVector)
bulk call for getNode
|
java.util.Vector<Node> |
StorageSystem.getNodesParallel(java.util.Vector<java.lang.String> paramVector,
boolean withCaching)
bulk call for getNode, with an additional application level directive to control caching
|
| Modifier and Type | Method and Description |
|---|---|
void |
StorageSystem.putNode(java.lang.String paramString,
Node paramNode)
put node, called from the application to put a node in the local or remote server
|
| Modifier and Type | Method and Description |
|---|---|
void |
StorageSystem.putNodesParallel(java.util.Vector<Node> nodeList)
Bulk call to putNode, called by the application
Calls are bucketised to the respective servers
|
| Constructor and Description |
|---|
RemotePutHandler(HashtableServer server,
java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> nT) |
| Modifier and Type | Field and Description |
|---|---|
java.util.Hashtable<java.lang.String,Node> |
Worker.updatedNodes |
| Modifier and Type | Method and Description |
|---|---|
java.util.Vector<Node> |
Worker.getLocalNeighbors(Node u) |
java.util.Vector<Node> |
Worker.getNeighbors(Node u) |
java.util.Vector<Node> |
Worker.getRemoteNeighbors(java.util.Vector<java.lang.String> nbrKeys) |
java.util.Vector<Node> |
Worker.refetchNodes(java.util.HashSet<java.lang.String> refetchSet,
java.util.Vector<Node> neighborNodes) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Vector<Node> |
Worker.getLocalNeighbors(Node u) |
java.util.Vector<java.lang.String> |
Worker.getNeighborIds(Node u) |
java.util.Vector<Node> |
Worker.getNeighbors(Node u) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
Worker.earlyValidation(Task t,
java.util.Vector<Node> readNodes,
java.util.Vector<NodeData> readNodesData) |
java.util.Vector<Node> |
Worker.refetchNodes(java.util.HashSet<java.lang.String> refetchSet,
java.util.Vector<Node> neighborNodes) |