| Package | Description |
|---|---|
| beehive.server | |
| beehive.util |
| Modifier and Type | Method and Description |
|---|---|
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.
|
ResultObject |
HashtableServer.exec(NodeData nd) |
ResultObject |
HashtableServerImpl.exec(NodeData n) |
ResultObject |
HashtableServer.get(java.lang.String key,
long storageSystemThreadId) |
ResultObject |
HashtableServerImpl.get(java.lang.String key,
long storageSystemThreadId)
Given a node id, returns a node to the storage system (application)
Forks off to getUseCache in the useCaching = true case
|
ResultObject |
HashtableServer.getNodeProperties(NodeData n) |
ResultObject |
HashtableServerImpl.getNodeProperties(NodeData n)
retrieve the node data for a node, given its node ids and the required properties
|
ResultObject |
HashtableServer.lock(int nodeId) |
ResultObject |
HashtableServerImpl.lock(int nodeId)
Lock an object to prevent its relocation
|
ResultObject |
HashtableServer.put(java.lang.String key,
java.lang.Object value) |
ResultObject |
HashtableServerImpl.put(java.lang.String key,
java.lang.Object value)
put the node into the table, given a node-id
Forks off to putUseCache in the useCaching = true case
|
ResultObject |
HashtableServer.put(java.lang.String key,
java.lang.Object value,
int callingServerId) |
ResultObject |
HashtableServerImpl.put(java.lang.String key,
java.lang.Object value,
int callerServerId)
put for the write through cache case
|
ResultObject |
HashtableServerImpl.putUseCache(java.lang.String key,
java.lang.Object value,
int callingServerId)
putUseCache for the write through cache case
also takes in a calling server id, to keep track of cache invaldations (write through cache = no invalidation on calling server)
|
ResultObject |
HashtableServer.relocate(int nodeId,
java.lang.String serverName) |
ResultObject |
HashtableServerImpl.relocate(int nodeId,
java.lang.String serverName)
called on the homesite when relocating a node to a remote server
homesite makes a note of it in the location table
|
ResultObject |
HashtableServer.updateNodeProperties(NodeData n) |
ResultObject |
HashtableServerImpl.updateNodeProperties(NodeData value)
update the properties of a node, given the node id and the updated property map
|
| 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
|
java.util.Vector<ResultObject> |
HashtableServer.execBulk(java.util.Vector<NodeData> keyList) |
java.util.Vector<ResultObject> |
HashtableServerImpl.execBulk(java.util.Vector<NodeData> keyList) |
java.util.Vector<ResultObject> |
HashtableServer.getLocalNodes(java.util.Vector<java.lang.String> nodeIds,
long storageSystemThreadId) |
java.util.Vector<ResultObject> |
HashtableServerImpl.getLocalNodes(java.util.Vector<java.lang.String> nodeIds,
long storageSystemThreadId)
Storage system invokes this method on the server when requesting nodes and status for those nodes which are not available
Only used in caching case
|
java.util.Vector<ResultObject> |
HashtableServer.getObjects(java.util.Vector<java.lang.String> keyList) |
java.util.Vector<ResultObject> |
HashtableServerImpl.getObjects(java.util.Vector<java.lang.String> keyList)
getObjects from the hash table.
|
java.util.Vector<ResultObject> |
HashtableServer.getObjectsProperties(java.util.Vector<NodeData> keyList) |
java.util.Vector<ResultObject> |
HashtableServerImpl.getObjectsProperties(java.util.Vector<NodeData> keyList)
Bulk call to get object properties for a set of nodes
|
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
|
java.util.Vector<ResultObject> |
HashtableServer.updateNodePropertiesParallel(java.util.Vector<NodeData> objList) |
java.util.Vector<ResultObject> |
HashtableServerImpl.updateNodePropertiesParallel(java.util.Vector<NodeData> objList)
This is the reflection counterpart of putObjects, used for bulk update of node properties
repeatedly calls the updateNodeProperties (can be done in parallel)
|
| Modifier and Type | Method and Description |
|---|---|
ResultObject |
CacheCopy.call() |
ResultObject |
PutNodes.call() |