From 9277729f6cd6fdc0313b98d303fddff2ca8a63af Mon Sep 17 00:00:00 2001 From: "Gadicherla, Shiva" Date: Wed, 4 Dec 2019 21:52:39 +0000 Subject: Unit test cases for DeadLockDetectionUtil, CipherUtil and CassaLockStore Issue-ID: MUSIC-521 Signed-off-by: Gadicherla, Shiva Change-Id: I8544a2003548eff9d26c48f65e5109154924bfe9 --- .../onap/music/lockingservice/cassandra/CassaLockStore.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) (limited to 'music-core/src/main/java') diff --git a/music-core/src/main/java/org/onap/music/lockingservice/cassandra/CassaLockStore.java b/music-core/src/main/java/org/onap/music/lockingservice/cassandra/CassaLockStore.java index edce3fff..6a68b81c 100644 --- a/music-core/src/main/java/org/onap/music/lockingservice/cassandra/CassaLockStore.java +++ b/music-core/src/main/java/org/onap/music/lockingservice/cassandra/CassaLockStore.java @@ -478,7 +478,7 @@ public class CassaLockStore { queryObject.appendQueryString(" WHERE lockType = ? ALLOW FILTERING"); queryObject.addValue(LockType.WRITE); - DeadlockDetectionUtil ddu = new DeadlockDetectionUtil(); + DeadlockDetectionUtil ddu = getDeadlockDetectionUtil(); ResultSet rs = dsHandle.executeLocalQuorumConsistencyGet(queryObject); logger.debug("rs has " + rs.getAvailableWithoutFetching() + (rs.isFullyFetched()?"":" (or more!)") ); @@ -493,6 +493,14 @@ public class CassaLockStore { return deadlock; } + /** + * This is used for testing purpose + * @return new DeadlockDetectionUtil object + */ + DeadlockDetectionUtil getDeadlockDetectionUtil() { + return new DeadlockDetectionUtil(); + } + public List getAllLocksForOwner(String ownerId, String keyspace, String table) throws MusicServiceException, MusicQueryException { List toRet = new ArrayList(); String lockTable = table_prepend_name + table; -- cgit 1.2.3-korg