org.ow2.proactive.resourcemanager.db

Class RMDBManager

java.lang.Object

org.ow2.proactive.resourcemanager.db.RMDBManager

public class RMDBManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RMDBManager.NodeLockUpdateAction

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_ITEMS_IN_LIST

Constructor Summary

Constructors

Constructor and Description
RMDBManager(Configuration configuration, boolean drop, boolean dropNS) Used only for testing purposes of the hibernate config needs to be changed.

Method Summary

Modifier and Type	Method and Description
void	addNode(RMNodeData rmNodeData, String nodeSourceName)
boolean	addNodeSource(NodeSourceData nodeSourceData)
void	changeNodesState(List<RMNodeData> nodesList, Map<String,String> nodeSourceNameMap, NodeState nodeState, long stateChangeTime, Client owner, int usageInfoCriteriaSize)
void	clearLockHistory() Removes all entries from LockHistory table.
void	close()
static RMDBManager	createInMemoryRMDBManager()
void	createLockEntryOrUpdate(String nodeSource, RMDBManager.NodeLockUpdateAction actionOnUpdate)
void	deleteOldNodeHistory()
void	deleteOldUserHistory()
Map<String,org.objectweb.proactive.core.util.MutableInteger>	entityToMap(List<LockHistory> lockHistoryResult)
<T> T	executeReadTransaction(SessionWork<T> sessionWork) Should be used for select queries only.
protected <T> T	executeReadWriteTransaction(SessionWork<T> sessionWork) Should be used for insert/update/delete queries
List<?>	executeSqlQuery(String queryStr)
Map<String,org.objectweb.proactive.core.util.MutableInteger>	findNodesLockedOnPreviousRun() Returns information about the nodes which have been locked on previous RM run.
Alive	findRmLastAliveEntry()
Collection<RMNodeData>	getAllNodes()
RMDBManagerBuffer	getBuffer()
static RMDBManager	getInstance()
List<LockHistory>	getLockHistories()
RMNodeData	getNodeByNameAndUrl(String nodeName, String nodeUrl)
Collection<RMNodeData>	getNodesByNodeSource(String nodeSourceName)
List<NodeHistory>	getNodesHistory(long windowStart, long windowEnd)
NodeSourceData	getNodeSource(String sourceName)
Collection<NodeSourceData>	getNodeSources()
void	removeAllNodes()
void	removeAllNodesFromNodeSource(String nodeSourceName)
void	removeNode(RMNode rmNode)
void	removeNode(RMNodeData rmNodeData, String nodeSourceName)
void	removeNodeSource(String sourceName)
void	saveNodeHistory(NodeHistory nodeHistory)
void	saveUserHistory(UserHistory history)
void	startHouseKeeping()
void	updateNode(RMNodeData rmNodeData, String nodeSourceName)
void	updateNodeSource(NodeSourceData nodeSourceData)
protected void	updateRmAliveTime()
void	updateUserHistory(UserHistory history)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_ITEMS_IN_LIST

public static final int MAX_ITEMS_IN_LIST

Constructor Detail

RMDBManager

public RMDBManager(Configuration configuration,
                   boolean drop,
                   boolean dropNS)

Used only for testing purposes of the hibernate config needs to be changed. RMDBManager.getInstance() should be used in most of cases.

Method Detail

getInstance

public static RMDBManager getInstance()

createInMemoryRMDBManager

public static RMDBManager createInMemoryRMDBManager()

startHouseKeeping

public void startHouseKeeping()

findRmLastAliveEntry

public Alive findRmLastAliveEntry()

executeReadWriteTransaction

protected <T> T executeReadWriteTransaction(SessionWork<T> sessionWork)

Should be used for insert/update/delete queries

executeReadTransaction

public <T> T executeReadTransaction(SessionWork<T> sessionWork)

Should be used for select queries only. In case of failure no rollback is performed.

close

public void close()

addNodeSource

public boolean addNodeSource(NodeSourceData nodeSourceData)

getNodeSource

public NodeSourceData getNodeSource(String sourceName)

updateNodeSource

public void updateNodeSource(NodeSourceData nodeSourceData)

removeNodeSource

public void removeNodeSource(String sourceName)

getNodeSources

public Collection<NodeSourceData> getNodeSources()

addNode

public void addNode(RMNodeData rmNodeData,
                    String nodeSourceName)

changeNodesState

public void changeNodesState(List<RMNodeData> nodesList,
                             Map<String,String> nodeSourceNameMap,
                             NodeState nodeState,
                             long stateChangeTime,
                             Client owner,
                             int usageInfoCriteriaSize)

updateNode

public void updateNode(RMNodeData rmNodeData,
                       String nodeSourceName)

removeNode

public void removeNode(RMNode rmNode)

removeNode

public void removeNode(RMNodeData rmNodeData,
                       String nodeSourceName)

removeAllNodes

public void removeAllNodes()

removeAllNodesFromNodeSource

public void removeAllNodesFromNodeSource(String nodeSourceName)

getNodeByNameAndUrl

public RMNodeData getNodeByNameAndUrl(String nodeName,
                                      String nodeUrl)

getNodesByNodeSource

public Collection<RMNodeData> getNodesByNodeSource(String nodeSourceName)

getAllNodes

public Collection<RMNodeData> getAllNodes()

saveUserHistory

public void saveUserHistory(UserHistory history)

updateUserHistory

public void updateUserHistory(UserHistory history)

saveNodeHistory

public void saveNodeHistory(NodeHistory nodeHistory)

deleteOldNodeHistory

public void deleteOldNodeHistory()

deleteOldUserHistory

public void deleteOldUserHistory()

clearLockHistory

public void clearLockHistory()

Removes all entries from LockHistory table.

findNodesLockedOnPreviousRun

public Map<String,org.objectweb.proactive.core.util.MutableInteger> findNodesLockedOnPreviousRun()

Returns information about the nodes which have been locked on previous RM run.

The purpose of this method is to fetch the number of nodes locked per node source on the previous RM run.

Returns:

the number of nodes locked, per node source, on the previous RM run.

getLockHistories

public List<LockHistory> getLockHistories()

entityToMap

public Map<String,org.objectweb.proactive.core.util.MutableInteger> entityToMap(List<LockHistory> lockHistoryResult)

updateRmAliveTime

protected void updateRmAliveTime()

createLockEntryOrUpdate

public void createLockEntryOrUpdate(String nodeSource,
                                    RMDBManager.NodeLockUpdateAction actionOnUpdate)

executeSqlQuery

public List<?> executeSqlQuery(String queryStr)

getBuffer

public RMDBManagerBuffer getBuffer()

getNodesHistory

public List<NodeHistory> getNodesHistory(long windowStart,
                                         long windowEnd)