summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorKevin McKiou <km097d@att.com>2018-01-05 16:44:51 -0600
committerKevin McKiou <km097d@att.com>2018-01-05 16:45:15 -0600
commit9c978cea0a5af3d4a9d587a5f09b88d660bd498b (patch)
treefc9cfb090cba8fd5c95e75f64858bb1c8c1eac01
parenteffbd1d07e7192e7cf8eb42316f5ce0cfb09dd0b (diff)
StateManagement EntityManager Creation
Patch 1: This change modifies StateManagement methods that use transactions so that an EntityManager is created each time the method is called. This eliminates issues with EntityManager transactions being shared across threads causing errors when multiple threads are active. Issue-ID: POLICY-518 Change-Id: I071660a530de610ec56af82347b92496f87bf4e1 Signed-off-by: Kevin McKiou <km097d@att.com>
-rw-r--r--integrity-monitor/src/main/java/org/onap/policy/common/im/StateManagement.java27
1 files changed, 22 insertions, 5 deletions
diff --git a/integrity-monitor/src/main/java/org/onap/policy/common/im/StateManagement.java b/integrity-monitor/src/main/java/org/onap/policy/common/im/StateManagement.java
index 637a3042..05da2a87 100644
--- a/integrity-monitor/src/main/java/org/onap/policy/common/im/StateManagement.java
+++ b/integrity-monitor/src/main/java/org/onap/policy/common/im/StateManagement.java
@@ -75,7 +75,7 @@ public class StateManagement extends Observable {
private String opState = null;
private String availStatus = null;
private String standbyStatus = null;
- private EntityManager em;
+ private EntityManagerFactory emf;
private StateTransition st = null;
/*
@@ -94,16 +94,17 @@ public class StateManagement extends Observable {
/**
* StateManagement constructor
- * @param emf
+ * @param entityManagerFactory
* @param resourceName
* @throws Exception
*/
- public StateManagement(EntityManagerFactory emf, String resourceName) throws StateManagementException
+ public StateManagement(EntityManagerFactory entityManagerFactory, String resourceName) throws StateManagementException
{
+ emf = entityManagerFactory;
if(logger.isDebugEnabled()){
logger.debug("StateManagement: constructor, resourceName: {}", resourceName);
}
- em = emf.createEntityManager();
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -173,6 +174,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("StateManagement: initializeState() operation started, resourceName = {}", this.resourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -227,6 +229,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("StateManagement: lock() operation started, resourceName = {}", this.resourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -284,6 +287,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("StateManagement: unlock() operation started, resourceName = {}", this.resourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -341,6 +345,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("StateManagement: enableNotFailed() operation started, resourceName = {}", this.resourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -397,6 +402,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("StateManagement: disableFailed() operation started, resourceName = {}", this.resourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
et.begin();
@@ -458,6 +464,7 @@ public class StateManagement extends Observable {
logger.debug("StateManagement: disableFailed(otherResourceName) operation started, resourceName = {}",
otherResourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
et.begin();
@@ -514,6 +521,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("StateManagement: disableDependency() operation started, resourceName = {}", this.resourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -571,6 +579,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("StateManagement: enableNoDependency() operation started, resourceName = {}", this.resourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -628,6 +637,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("StateManagement: promote() operation started, resourceName = {}", this.resourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -690,6 +700,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("StateManagement: demote() operation started, resourceName = {}", this.resourceName);
}
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -752,7 +763,7 @@ public class StateManagement extends Observable {
if(logger.isDebugEnabled()){
logger.debug("\nStateManagement: SYNCLOCK demote(otherResourceName) operation for resourceName = {}\n", otherResourceName);
}
-
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
@@ -804,6 +815,7 @@ public String getAdminState()
logger.debug("StateManagement(6/1/16): getAdminState for resourceName {}", this.resourceName);
}
try {
+ EntityManager em = emf.createEntityManager();
Query query = em.createQuery("Select p from StateManagementEntity p where p.resourceName=:resource");
query.setParameter("resource", this.resourceName);
@@ -837,6 +849,7 @@ public String getOpState()
logger.debug("StateManagement(6/1/16): getOpState for resourceName {}", this.resourceName);
}
try {
+ EntityManager em = emf.createEntityManager();
Query query = em.createQuery("Select p from StateManagementEntity p where p.resourceName=:resource");
query.setParameter("resource", this.resourceName);
@@ -870,6 +883,7 @@ public String getOpState()
logger.debug("StateManagement(6/1/16): getAvailStatus for resourceName {}", this.resourceName);
}
try {
+ EntityManager em = emf.createEntityManager();
Query query = em.createQuery("Select p from StateManagementEntity p where p.resourceName=:resource");
query.setParameter("resource", this.resourceName);
@@ -903,6 +917,7 @@ public String getOpState()
logger.debug("StateManagement(6/1/16): getStandbyStatus for resourceName {}", this.resourceName);
}
try {
+ EntityManager em = emf.createEntityManager();
Query query = em.createQuery("Select p from StateManagementEntity p where p.resourceName=:resource");
query.setParameter("resource", this.resourceName);
@@ -983,6 +998,7 @@ public String getOpState()
String tempStandbyStatus = null;
// The transaction is required for the LockModeType
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
et.begin();
@@ -1039,6 +1055,7 @@ public String getOpState()
/*
* Start transaction
*/
+ EntityManager em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
if(!et.isActive()){
et.begin();