beehive.server

Interface HashtableServer

All Superinterfaces:

java.rmi.Remote

All Known Implementing Classes:

HashtableServerImpl

public interface HashtableServer
extends java.rmi.Remote

Method Summary

Modifier and Type	Method and Description
void	cacheEvictMasterNotify(java.lang.String cachingServerId, java.util.Hashtable<java.lang.String,java.lang.Long> evictedNodes)
void	cacheInvalidate(java.lang.String nodeID)
java.util.Vector<ResultObject>	cachePut(java.util.Map<java.lang.Integer,java.util.Vector<Node>> nodes, long storageSystemThreadId)
ResultObject	cachePut(java.lang.String nodeID, Node node, int masterCopySite, long storageSystemThreadId)
void	clearStatContainers()
boolean	contains(java.lang.String key)
ResultObject	exec(NodeData nd)
java.util.Vector<ResultObject>	execBulk(java.util.Vector<NodeData> keyList)
ResultObject	get(java.lang.String key, long storageSystemThreadId)
java.util.Vector<java.lang.String>	getAllKeys()
java.util.Vector<Node>	getAllNodes()
java.util.Vector<Node>	getCachedObjects(java.util.Vector<java.lang.String> nodeIds)
ClusterMeasures	getClusterMeasures()
java.util.Vector<ResultObject>	getLocalNodes(java.util.Vector<java.lang.String> nodeIds, long storageSystemThreadId)
Node	getNodeForCaching(java.lang.String nodeID, int cachingSite)
Node	getNodeFromCacheTable(java.lang.String nodeId)
Node	getNodeFromTable(java.lang.String nodeId)
ResultObject	getNodeProperties(NodeData n)
java.util.Vector<Node>	getNodesForCaching(java.util.Vector<java.lang.String> nodeIds, int callingSite)
int	getNumServers()
java.util.Vector<ResultObject>	getObjects(java.util.Vector<java.lang.String> keyList)
java.util.Vector<ResultObject>	getObjectsProperties(java.util.Vector<NodeData> keyList)
int	getServerId()
java.lang.String	getStats()
void	loadNodes(java.util.Vector<Node> nodes)
void	locationChange(int nodeId, java.lang.String serverName)
ResultObject	lock(int nodeId)
java.util.Date	ping()
ResultObject	put(java.lang.String key, java.lang.Object value)
ResultObject	put(java.lang.String key, java.lang.Object value, int callingServerId)
java.util.Vector<ResultObject>	putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList)
java.util.Vector<ResultObject>	putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList, int callerServerId)
ResultObject	relocate(int nodeId, java.lang.String serverName)
void	removeLocationTableEntry(java.lang.String key)
void	setNumServers(int n)
ResultObject	updateNodeProperties(NodeData n)
java.util.Vector<ResultObject>	updateNodePropertiesParallel(java.util.Vector<NodeData> objList)
void	writeThroughToCache(java.lang.String paramString, java.lang.Object value)
void	writeThroughToCacheBulk(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> map)

Method Detail

ping

java.util.Date ping()
             throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

put

ResultObject put(java.lang.String key,
                 java.lang.Object value)
          throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

put

ResultObject put(java.lang.String key,
                 java.lang.Object value,
                 int callingServerId)
          throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

get

ResultObject get(java.lang.String key,
                 long storageSystemThreadId)
          throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getObjects

java.util.Vector<ResultObject> getObjects(java.util.Vector<java.lang.String> keyList)
                                   throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

putObjects

java.util.Vector<ResultObject> putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList)
                                   throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getNodeProperties

ResultObject getNodeProperties(NodeData n)
                        throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getObjectsProperties

java.util.Vector<ResultObject> getObjectsProperties(java.util.Vector<NodeData> keyList)
                                             throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

updateNodeProperties

ResultObject updateNodeProperties(NodeData n)
                           throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

updateNodePropertiesParallel

java.util.Vector<ResultObject> updateNodePropertiesParallel(java.util.Vector<NodeData> objList)
                                                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

exec

ResultObject exec(NodeData nd)
           throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

execBulk

java.util.Vector<ResultObject> execBulk(java.util.Vector<NodeData> keyList)
                                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

putObjects

java.util.Vector<ResultObject> putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList,
                                          int callerServerId)
                                   throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

contains

boolean contains(java.lang.String key)
          throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getAllNodes

java.util.Vector<Node> getAllNodes()
                            throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getAllKeys

java.util.Vector<java.lang.String> getAllKeys()
                                       throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getStats

java.lang.String getStats()
                   throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

clearStatContainers

void clearStatContainers()
                  throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getNodeFromTable

Node getNodeFromTable(java.lang.String nodeId)
               throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

loadNodes

void loadNodes(java.util.Vector<Node> nodes)
        throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getServerId

int getServerId()
         throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getNumServers

int getNumServers()
           throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

setNumServers

void setNumServers(int n)
            throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

relocate

ResultObject relocate(int nodeId,
                      java.lang.String serverName)
               throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

locationChange

void locationChange(int nodeId,
                    java.lang.String serverName)
             throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

lock

ResultObject lock(int nodeId)
           throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

removeLocationTableEntry

void removeLocationTableEntry(java.lang.String key)
                       throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getClusterMeasures

ClusterMeasures getClusterMeasures()
                            throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

cacheInvalidate

void cacheInvalidate(java.lang.String nodeID)
              throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getNodeForCaching

Node getNodeForCaching(java.lang.String nodeID,
                       int cachingSite)
                throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

cachePut

ResultObject cachePut(java.lang.String nodeID,
                      Node node,
                      int masterCopySite,
                      long storageSystemThreadId)
               throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

cachePut

java.util.Vector<ResultObject> cachePut(java.util.Map<java.lang.Integer,java.util.Vector<Node>> nodes,
                                        long storageSystemThreadId)
                                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getLocalNodes

java.util.Vector<ResultObject> getLocalNodes(java.util.Vector<java.lang.String> nodeIds,
                                             long storageSystemThreadId)
                                      throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getNodesForCaching

java.util.Vector<Node> getNodesForCaching(java.util.Vector<java.lang.String> nodeIds,
                                          int callingSite)
                                   throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

writeThroughToCache

void writeThroughToCache(java.lang.String paramString,
                         java.lang.Object value)
                  throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

writeThroughToCacheBulk

void writeThroughToCacheBulk(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> map)
                      throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getNodeFromCacheTable

Node getNodeFromCacheTable(java.lang.String nodeId)
                    throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getCachedObjects

java.util.Vector<Node> getCachedObjects(java.util.Vector<java.lang.String> nodeIds)
                                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

cacheEvictMasterNotify

void cacheEvictMasterNotify(java.lang.String cachingServerId,
                            java.util.Hashtable<java.lang.String,java.lang.Long> evictedNodes)
                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException