diff options
Diffstat (limited to 'integrity-monitor/src/main/java/org/onap/policy/common/im/StateManagement.java')
| -rw-r--r-- | integrity-monitor/src/main/java/org/onap/policy/common/im/StateManagement.java | 1835 |
1 files changed, 930 insertions, 905 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 5cafd876..dbb278e7 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 @@ -23,927 +23,952 @@ package org.onap.policy.common.im; import java.util.Date; import java.util.List; import java.util.Observable; + import javax.persistence.EntityManager; import javax.persistence.EntityManagerFactory; import javax.persistence.FlushModeType; import javax.persistence.LockModeType; import javax.persistence.TypedQuery; + import org.onap.policy.common.im.exceptions.EntityRetrievalException; import org.onap.policy.common.im.jpa.StateManagementEntity; import org.onap.policy.common.utils.jpa.EntityMgrCloser; import org.onap.policy.common.utils.jpa.EntityTransCloser; import org.slf4j.Logger; import org.slf4j.LoggerFactory; + /** - * - * StateManagement class handles all state changes per the Telecom standard X.731. - * It extends the Observable class and, thus, has an interface to register - * instances of the StateChangeNotifier/Observer class. When any state change - * occurs, the registered observers are notified. + * StateManagement class handles all state changes per the Telecom standard X.731. It extends the + * Observable class and, thus, has an interface to register instances of the + * StateChangeNotifier/Observer class. When any state change occurs, the registered observers are + * notified. * */ public class StateManagement extends Observable { - private static final String RESOURCE_NAME = "resource"; - private static final String GET_STATE_MANAGEMENT_ENTITY_QUERY = + private static final String RESOURCE_NAME = "resource"; + private static final String GET_STATE_MANAGEMENT_ENTITY_QUERY = "Select p from StateManagementEntity p where p.resourceName=:" + RESOURCE_NAME; - private static final Logger logger = LoggerFactory.getLogger(StateManagement.class); - public static final String LOCKED = "locked"; - public static final String UNLOCKED = "unlocked"; - public static final String ENABLED = "enabled"; - public static final String DISABLED = "disabled"; - public static final String ENABLE_NOT_FAILED = "enableNotFailed"; - public static final String DISABLE_FAILED = "disableFailed"; - public static final String FAILED = "failed"; - public static final String DEPENDENCY = "dependency"; - public static final String DEPENDENCY_FAILED = "dependency,failed"; - public static final String DISABLE_DEPENDENCY = "disableDependency"; - public static final String ENABLE_NO_DEPENDENCY = "enableNoDependency"; - public static final String NULL_VALUE = "null"; - public static final String LOCK = "lock"; - public static final String UNLOCK = "unlock"; - public static final String PROMOTE = "promote"; - public static final String DEMOTE = "demote"; - public static final String HOT_STANDBY = "hotstandby"; - public static final String COLD_STANDBY = "coldstandby"; - public static final String PROVIDING_SERVICE = "providingservice"; - - public static final String ADMIN_STATE = "adminState"; - public static final String OPERATION_STATE = "opState"; - public static final String AVAILABLE_STATUS= "availStatus"; - public static final String STANDBY_STATUS = "standbyStatus"; - - private String resourceName = null; - private String adminState = null; - private String opState = null; - private String availStatus = null; - private String standbyStatus = null; - private final EntityManagerFactory emf; - private StateTransition st = null; - - /* - * Guarantees single-threadedness of all actions. Only one action can execute - * at a time. That avoids race conditions between actions being called - * from different places. - * - * Some actions can take significant time to complete and, if another conflicting - * action is called during its execution, it could put the system in an inconsistent - * state. This very thing happened when demote was called and the active/standby - * algorithm, seeing the state attempted to promote the PDP-D. - * - */ - private static final Object SYNCLOCK = new Object(); - private static final Object FLUSHLOCK = new Object(); - - /** - * StateManagement constructor - * @param entityManagerFactory - * @param resourceName - * @throws StateManagementException - */ - public StateManagement(final EntityManagerFactory entityManagerFactory, final String resourceName) throws StateManagementException - { - emf = entityManagerFactory; - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: constructor, resourceName: {}", resourceName); - } - - final EntityManager em = emf.createEntityManager(); - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - this.resourceName = resourceName; - if(logger.isDebugEnabled()){ - logger.debug("resourceName = {}", this.resourceName); - } - - - try { - //Create a StateManagementEntity object - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); - - //persist the administrative state - if(logger.isDebugEnabled()){ - logger.debug("Persist adminstrative state, resourceName = {}", this.resourceName); - } - em.persist(sm); + private static final Logger logger = LoggerFactory.getLogger(StateManagement.class); + public static final String LOCKED = "locked"; + public static final String UNLOCKED = "unlocked"; + public static final String ENABLED = "enabled"; + public static final String DISABLED = "disabled"; + public static final String ENABLE_NOT_FAILED = "enableNotFailed"; + public static final String DISABLE_FAILED = "disableFailed"; + public static final String FAILED = "failed"; + public static final String DEPENDENCY = "dependency"; + public static final String DEPENDENCY_FAILED = "dependency,failed"; + public static final String DISABLE_DEPENDENCY = "disableDependency"; + public static final String ENABLE_NO_DEPENDENCY = "enableNoDependency"; + public static final String NULL_VALUE = "null"; + public static final String LOCK = "lock"; + public static final String UNLOCK = "unlock"; + public static final String PROMOTE = "promote"; + public static final String DEMOTE = "demote"; + public static final String HOT_STANDBY = "hotstandby"; + public static final String COLD_STANDBY = "coldstandby"; + public static final String PROVIDING_SERVICE = "providingservice"; + + public static final String ADMIN_STATE = "adminState"; + public static final String OPERATION_STATE = "opState"; + public static final String AVAILABLE_STATUS = "availStatus"; + public static final String STANDBY_STATUS = "standbyStatus"; + + private String resourceName = null; + private String adminState = null; + private String opState = null; + private String availStatus = null; + private String standbyStatus = null; + private final EntityManagerFactory emf; + private StateTransition st = null; + + /* + * Guarantees single-threadedness of all actions. Only one action can execute at a time. That + * avoids race conditions between actions being called from different places. + * + * Some actions can take significant time to complete and, if another conflicting action is + * called during its execution, it could put the system in an inconsistent state. This very + * thing happened when demote was called and the active/standby algorithm, seeing the state + * attempted to promote the PDP-D. + * + */ + private static final Object SYNCLOCK = new Object(); + private static final Object FLUSHLOCK = new Object(); + + /** + * StateManagement constructor. + * + * @param entityManagerFactory the entity manager factory + * @param resourceName the resource name + * @throws StateManagementException if an error occurs + */ + public StateManagement(final EntityManagerFactory entityManagerFactory, final String resourceName) + throws StateManagementException { + emf = entityManagerFactory; + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: constructor, resourceName: {}", resourceName); + } + + final EntityManager em = emf.createEntityManager(); + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + this.resourceName = resourceName; + if (logger.isDebugEnabled()) { + logger.debug("resourceName = {}", this.resourceName); + } + + + try { + // Create a StateManagementEntity object + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); + + // persist the administrative state + if (logger.isDebugEnabled()) { + logger.debug("Persist adminstrative state, resourceName = {}", this.resourceName); + } + em.persist(sm); + et.commit(); + + // Load the StateTransition hash table + st = new StateTransition(); + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: constructor end, resourceName: {}", this.resourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement: constructor caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement: Exception: " + ex.toString(), ex); + } + } + } + + /** + * initializeState() is called when it is necessary to set the StateManagement to a known + * initial state. It preserves the Administrative State since it must persist across node + * reboots. Starting from this state, the IntegrityMonitory will determine the Operational State + * and the owning application will set the StandbyStatus. + */ + public void initializeState() throws StateManagementException { + synchronized (SYNCLOCK) { + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK initializeState() operation for resourceName = {}\n", + this.resourceName); + logger.debug("StateManagement: initializeState() operation started, resourceName = {}", + this.resourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); + // set state + sm.setAdminState(sm.getAdminState()); // preserve the Admin state + sm.setOpState(StateManagement.ENABLED); + sm.setAvailStatus(StateManagement.NULL_VALUE); + sm.setStandbyStatus(StateManagement.NULL_VALUE); + + em.persist(sm); + et.commit(); + setChanged(); + notifyObservers(ADMIN_STATE); + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: initializeState() operation completed, resourceName = {}", + this.resourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.initializeState() caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.initializeState() Exception: " + ex); + } + } + } + + /** + * lock() changes the administrative state to locked. + * + * @throws StateManagementException if an error occurs + */ + public void lock() throws StateManagementException { + synchronized (SYNCLOCK) { + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK lock() operation for resourceName = {}\n", this.resourceName); + logger.debug("StateManagement: lock() operation started, resourceName = {}", this.resourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); + + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), LOCK); + + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + setChanged(); + notifyObservers(ADMIN_STATE); + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: lock() operation completed, resourceName = {}", this.resourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.lock() caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.lock() Exception: " + ex.toString()); + } + } + } + + /** + * unlock() changes the administrative state to unlocked. + * + * @throws StateManagementException if an error occurs + */ + public void unlock() throws StateManagementException { + synchronized (SYNCLOCK) { + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK unlock() operation for resourceName = {}\n", + this.resourceName); + logger.debug("StateManagement: unlock() operation started, resourceName = {}", this.resourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), UNLOCK); + // set transition state + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + setChanged(); + notifyObservers(ADMIN_STATE); + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: unlock() operation completed, resourceName = {}", this.resourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.unlock() caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.unlock() Exception: " + ex); + } + } + } + + /** + * enableNotFailed() removes the "failed" availability status and changes the operational state + * to enabled if no dependency is also failed. + * + * @throws StateManagementException if an error occurs + */ + public void enableNotFailed() throws StateManagementException { + synchronized (SYNCLOCK) { + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK enabledNotFailed() operation for resourceName = {}\n", + this.resourceName); + logger.debug("StateManagement: enableNotFailed() operation started, resourceName = {}", + this.resourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), ENABLE_NOT_FAILED); + // set transition state + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + + setChanged(); + notifyObservers(OPERATION_STATE); + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement enableNotFailed() operation completed, resourceName = {}", + this.resourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.enableNotFailed() caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.enableNotFailed() Exception: " + ex); + } + } + } + + /** + * disableFailed() changes the operational state to disabled and adds availability status of + * "failed". + * + * @throws StateManagementException if an error occurs + */ + public void disableFailed() throws StateManagementException { + synchronized (SYNCLOCK) { + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK disabledFailed() operation for resourceName = {}\n", + this.resourceName); + logger.debug("StateManagement: disableFailed() operation started, resourceName = {}", + this.resourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), DISABLE_FAILED); + // set transition state + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + setChanged(); + notifyObservers(OPERATION_STATE); + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: disableFailed() operation completed, resourceName = {}", + this.resourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.disableFailed() caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.disableFailed() Exception: " + ex); + } + } + } + + /** + * This version of disableFailed is to be used to manipulate the state of a remote resource in + * the event that remote resource has failed but its state is still showing that it is viable. + * + * @throws StateManagementException if an error occurs + */ + public void disableFailed(final String otherResourceName) throws StateManagementException { + synchronized (SYNCLOCK) { + if (otherResourceName == null) { + logger.error("\nStateManagement: SYNCLOCK disableFailed(otherResourceName) operation: resourceName is " + + "NULL.\n"); + return; + } + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK disabledFailed(otherResourceName) operation for resourceName " + + "= {}\n", otherResourceName); + logger.debug("StateManagement: disableFailed(otherResourceName) operation started, resourceName = {}", + otherResourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for " + otherResourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, otherResourceName); + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), DISABLE_FAILED); + // set transition state + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + setChanged(); + notifyObservers(OPERATION_STATE); + + if (logger.isDebugEnabled()) { + logger.debug( + "StateManagement: disableFailed(otherResourceName) operation completed, resourceName = {}", + otherResourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.disableFailed(otherResourceName) caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.disableFailed(otherResourceName) Exception: " + ex); + } + } + } + + /** + * disableDependency() changes operational state to disabled and adds availability status of + * "dependency". + * + * @throws StateManagementException if an error occurs + */ + public void disableDependency() throws StateManagementException { + synchronized (SYNCLOCK) { + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK disableDependency() operation for resourceName = {}\n", + this.resourceName); + logger.debug("StateManagement: disableDependency() operation started, resourceName = {}", + this.resourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), DISABLE_DEPENDENCY); + // set transition state + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + setChanged(); + notifyObservers(OPERATION_STATE); + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: disableDependency() operation completed, resourceName = {}", + this.resourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.disableDependency() caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.disableDependency() Exception: " + ex); + } + } + } + + /** + * enableNoDependency() removes the availability status of "dependency " and will change the + * operational state to enabled if not otherwise failed. + * + * @throws StateManagementException if an error occurs + */ + public void enableNoDependency() throws StateManagementException { + synchronized (SYNCLOCK) { + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK enableNoDependency() operation for resourceName = {}\n", + this.resourceName); + logger.debug("StateManagement: enableNoDependency() operation started, resourceName = {}", + this.resourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), ENABLE_NO_DEPENDENCY); + // set transition state + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + setChanged(); + notifyObservers(OPERATION_STATE); + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: enableNoDependency() operation completed, resourceName = {}", + this.resourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.enableNoDependency() caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.enableNoDependency() Exception: " + ex); + } + } + } + + /** + * promote() changes the standby status to providingservice if not otherwise failed. + * + * @throws StandbyStatusException if the status fails to change + * @throws StateManagementException if an error occurs when promoting the status + */ + public void promote() throws StandbyStatusException, StateManagementException { + synchronized (SYNCLOCK) { + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK promote() operation for resourceName = {}\n", + this.resourceName); + logger.debug("StateManagement: promote() operation started, resourceName = {}", this.resourceName); + } + + StateManagementEntity sm; + + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + sm = findStateManagementEntity(em, this.resourceName); + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), PROMOTE); + // set transition state + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + setChanged(); + notifyObservers(STANDBY_STATUS); + } catch (final Exception ex) { + logger.error("StateManagement.promote() caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.promote() Exception: " + ex); + } + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: promote() operation completed, resourceName = ", this.resourceName); + } + if (sm.getStandbyStatus().equals(StateManagement.COLD_STANDBY)) { + final String msg = + "Failure to promote " + this.resourceName + " StandbyStatus = " + StateManagement.COLD_STANDBY; + throw new StandbyStatusException(msg); + } + } + } + + /** + * demote() changes standbystatus to hotstandby or, if failed, coldstandby. + * + * @throws StateManagementException if an error occurs + */ + public void demote() throws StateManagementException { + synchronized (SYNCLOCK) { + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK demote() operation for resourceName = \n", this.resourceName); + logger.debug("StateManagement: demote() operation started, resourceName = {}", this.resourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("findStateManagementEntity for {}", this.resourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), DEMOTE); + // set transition state + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + setChanged(); + notifyObservers(STANDBY_STATUS); + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: demote() operation completed, resourceName = {}", this.resourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.demote() caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.demote() Exception: " + ex); + } + } + } + + /** + * Only used for a remote resource. It will not notify observers. It is used only in cases where + * the remote resource has failed is such a way that it cannot update its own states. In + * particular this is observed by PDP-D DroolsPdpsElectionHandler when it is trying to determine + * which PDP-D should be designated as the lead. + * + * @param otherResourceName the resouce name + * @throws StateManagementException if an error occurs + */ + public void demote(final String otherResourceName) throws StateManagementException { + synchronized (SYNCLOCK) { + if (otherResourceName == null) { + logger.error( + "\nStateManagement: SYNCLOCK demote(otherResourceName) operation: resourceName is NULL.\n"); + return; + } + if (logger.isDebugEnabled()) { + logger.debug("\nStateManagement: SYNCLOCK demote(otherResourceName) operation for resourceName = {}\n", + otherResourceName); + } + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: SYNCLOCK demote(otherResourceName) findStateManagementEntity for {}", + otherResourceName); + } + final StateManagementEntity sm = findStateManagementEntity(em, otherResourceName); + final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), + sm.getAvailStatus(), sm.getStandbyStatus(), DEMOTE); + // set transition state + sm.setAdminState(stateElement.getEndingAdminState()); + sm.setOpState(stateElement.getEndingOpState()); + sm.setAvailStatus(stateElement.getEndingAvailStatus()); + sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); + + em.persist(sm); + et.commit(); + // We don't notify observers because this is assumed to be a remote resource + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: demote(otherResourceName) operation completed, resourceName = {}", + otherResourceName); + } + } catch (final Exception ex) { + logger.error("StateManagement.demote(otherResourceName) caught unexpected exception: ", ex); + throw new StateManagementException("StateManagement.demote(otherResourceName) Exception: " + ex); + } + } + } + + /** + * Get the administration state. + * + * @return the administration state + */ + public String getAdminState() { + if (logger.isDebugEnabled()) { + logger.debug("StateManagement(6/1/16): getAdminState for resourceName {}", this.resourceName); + } + + final EntityManager em = emf.createEntityManager(); + try (final EntityMgrCloser emc = new EntityMgrCloser(em)) { + final TypedQuery<StateManagementEntity> query = + em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); + + query.setParameter(RESOURCE_NAME, this.resourceName); + + // Just test that we are retrieving the right object + final List<StateManagementEntity> resourceList = + query.setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); + if (!resourceList.isEmpty()) { + // exist + final StateManagementEntity stateManagementEntity = resourceList.get(0); + // refresh the object from DB in case cached data was returned + em.refresh(stateManagementEntity); + this.adminState = stateManagementEntity.getAdminState(); + } else { + this.adminState = null; + } + } catch (final Exception ex) { + logger.error("StateManagement: getAdminState exception: {}", ex.toString(), ex); + } + + return this.adminState; + } + + /** + * Get the operational state. + * + * @return the operational state + */ + public String getOpState() { + if (logger.isDebugEnabled()) { + logger.debug("StateManagement(6/1/16): getOpState for resourceName {}", this.resourceName); + } + + final EntityManager em = emf.createEntityManager(); + try (EntityMgrCloser emc = new EntityMgrCloser(em)) { + final TypedQuery<StateManagementEntity> query = + em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); + + query.setParameter(RESOURCE_NAME, this.resourceName); + + // Just test that we are retrieving the right object + final List<StateManagementEntity> resourceList = + query.setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); + if (!resourceList.isEmpty()) { + // exist + final StateManagementEntity stateManagementEntity = resourceList.get(0); + // refresh the object from DB in case cached data was returned + em.refresh(stateManagementEntity); + this.opState = stateManagementEntity.getOpState(); + } else { + this.opState = null; + } + } catch (final Exception ex) { + logger.error("StateManagement: getOpState exception: {}", ex.toString(), ex); + } + + return this.opState; + } + + /** + * Get the availability status. + * + * @return the availability status + */ + public String getAvailStatus() { + if (logger.isDebugEnabled()) { + logger.debug("StateManagement(6/1/16): getAvailStatus for resourceName {}", this.resourceName); + } + + final EntityManager em = emf.createEntityManager(); + try (EntityMgrCloser emc = new EntityMgrCloser(em)) { + final TypedQuery<StateManagementEntity> query = + em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); + + query.setParameter(RESOURCE_NAME, this.resourceName); + + // Just test that we are retrieving the right object + final List<StateManagementEntity> resourceList = + query.setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); + if (!resourceList.isEmpty()) { + // exist + final StateManagementEntity stateManagementEntity = resourceList.get(0); + // refresh the object from DB in case cached data was returned + em.refresh(stateManagementEntity); + this.availStatus = stateManagementEntity.getAvailStatus(); + } else { + this.availStatus = null; + } + } catch (final Exception ex) { + logger.error("StateManagement: getAvailStatus exception: {}", ex.toString(), ex); + } + + return this.availStatus; + } + + /** + * Get the standy status. + * + * @return the standby status + */ + public String getStandbyStatus() { + if (logger.isDebugEnabled()) { + logger.debug("StateManagement(6/1/16): getStandbyStatus for resourceName {}", this.resourceName); + } + + final EntityManager em = emf.createEntityManager(); + try (EntityMgrCloser emc = new EntityMgrCloser(em)) { + final TypedQuery<StateManagementEntity> query = + em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); + + query.setParameter(RESOURCE_NAME, this.resourceName); + + // Just test that we are retrieving the right object + final List<StateManagementEntity> resourceList = + query.setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); + if (!resourceList.isEmpty()) { + // exist + final StateManagementEntity stateManagementEntity = resourceList.get(0); + // refresh the object from DB in case cached data was returned + em.refresh(stateManagementEntity); + this.standbyStatus = stateManagementEntity.getStandbyStatus(); + } else { + this.standbyStatus = null; + } + } catch (final Exception ex) { + logger.error("StateManagement: getStandbyStatus exception: {}", ex.toString(), ex); + } + + return this.standbyStatus; + } + + /** + * Get the standbystatus of a particular resource. + * + * @param otherResourceName the resource + * @return the standby status + */ + public String getStandbyStatus(final String otherResourceName) { + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: getStandbyStatus: Entering, resourceName='{}'", otherResourceName); + } + + String tempStandbyStatus = null; + + // The transaction is required for the LockModeType + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + + final TypedQuery<StateManagementEntity> stateManagementListQuery = + em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); + stateManagementListQuery.setParameter(RESOURCE_NAME, otherResourceName); + final List<StateManagementEntity> stateManagementList = stateManagementListQuery + .setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); + if (!stateManagementList.isEmpty()) { + final StateManagementEntity stateManagementEntity = stateManagementList.get(0); + // refresh the object from DB in case cached data was returned + em.refresh(stateManagementEntity); + tempStandbyStatus = stateManagementEntity.getStandbyStatus(); + if (logger.isDebugEnabled()) { + logger.debug("getStandbyStatus: resourceName ={} has standbyStatus={}", otherResourceName, + tempStandbyStatus); + } + } else { + logger.error("getStandbyStatus: resourceName ={} not found in statemanagemententity table", + otherResourceName); + } + et.commit(); - - //Load the StateTransition hash table - st = new StateTransition(); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: constructor end, resourceName: {}", this.resourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement: constructor caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement: Exception: " + ex.toString(), ex); - } - } - } - - /** - * initializeState() is called when it is necessary to set the StateManagement to a known initial state. - * It preserves the Administrative State since it must persist across node reboots. - * Starting from this state, the IntegrityMonitory will determine the Operational State and the - * owning application will set the StandbyStatus. - */ - public void initializeState() throws StateManagementException - { - synchronized (SYNCLOCK){ - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK initializeState() operation for resourceName = {}\n", this.resourceName); - logger.debug("StateManagement: initializeState() operation started, resourceName = {}", this.resourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); - // set state - sm.setAdminState(sm.getAdminState()); //preserve the Admin state - sm.setOpState(StateManagement.ENABLED); - sm.setAvailStatus(StateManagement.NULL_VALUE); - sm.setStandbyStatus(StateManagement.NULL_VALUE); - - em.persist(sm); - et.commit(); - setChanged(); - notifyObservers(ADMIN_STATE); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: initializeState() operation completed, resourceName = {}", this.resourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.initializeState() caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.initializeState() Exception: " + ex); - } - } - } - - /** - * lock() changes the administrative state to locked. - * @throws StateManagementException - */ - public void lock() throws StateManagementException - { - synchronized (SYNCLOCK){ - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK lock() operation for resourceName = {}\n", this.resourceName); - logger.debug("StateManagement: lock() operation started, resourceName = {}", this.resourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); - - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), LOCK); - - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - setChanged(); - notifyObservers(ADMIN_STATE); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: lock() operation completed, resourceName = {}", this.resourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.lock() caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.lock() Exception: " + ex.toString()); - } - } - } - - /** - * unlock() changes the administrative state to unlocked. - * @throws StateManagementException - */ - public void unlock() throws StateManagementException - { - synchronized (SYNCLOCK){ - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK unlock() operation for resourceName = {}\n", this.resourceName); - logger.debug("StateManagement: unlock() operation started, resourceName = {}", this.resourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), UNLOCK); - // set transition state - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - setChanged(); - notifyObservers(ADMIN_STATE); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: unlock() operation completed, resourceName = {}", this.resourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.unlock() caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.unlock() Exception: " + ex); - } - } - } - - /** - * enableNotFailed() removes the "failed" availability status and changes the operational - * state to enabled if no dependency is also failed. - * @throws StateManagementException - */ - public void enableNotFailed() throws StateManagementException - { - synchronized (SYNCLOCK){ - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK enabledNotFailed() operation for resourceName = {}\n", this.resourceName); - logger.debug("StateManagement: enableNotFailed() operation started, resourceName = {}", this.resourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), ENABLE_NOT_FAILED); - // set transition state - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - - setChanged(); - notifyObservers(OPERATION_STATE); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement enableNotFailed() operation completed, resourceName = {}", this.resourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.enableNotFailed() caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.enableNotFailed() Exception: " + ex); - } - } - } - - /** - * disableFailed() changes the operational state to disabled and adds availability status of "failed" - * @throws StateManagementException - */ - public void disableFailed() throws StateManagementException - { - synchronized (SYNCLOCK){ - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK disabledFailed() operation for resourceName = {}\n", this.resourceName); - logger.debug("StateManagement: disableFailed() operation started, resourceName = {}", this.resourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), DISABLE_FAILED); - // set transition state - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - setChanged(); - notifyObservers(OPERATION_STATE); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: disableFailed() operation completed, resourceName = {}", this.resourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.disableFailed() caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.disableFailed() Exception: " + ex); - } - } - } - /** - * This version of disableFailed is to be used to manipulate the state of a remote resource in the event - * that remote resource has failed but its state is still showing that it is viable. - * @throws StateManagementException - */ - public void disableFailed(final String otherResourceName) throws StateManagementException - { - synchronized (SYNCLOCK){ - if(otherResourceName == null){ - logger.error("\nStateManagement: SYNCLOCK disableFailed(otherResourceName) operation: resourceName is NULL.\n"); - return; - } - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK disabledFailed(otherResourceName) operation for resourceName = {}\n", - otherResourceName); - logger.debug("StateManagement: disableFailed(otherResourceName) operation started, resourceName = {}", - otherResourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for " + otherResourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, otherResourceName); - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), DISABLE_FAILED); - // set transition state - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - setChanged(); - notifyObservers(OPERATION_STATE); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: disableFailed(otherResourceName) operation completed, resourceName = {}", - otherResourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.disableFailed(otherResourceName) caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.disableFailed(otherResourceName) Exception: " + ex); - } - } - } - - /** - * disableDependency() changes operational state to disabled and adds availability status of "dependency" - * @throws StateManagementException - */ - public void disableDependency() throws StateManagementException - { - synchronized (SYNCLOCK){ - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK disableDependency() operation for resourceName = {}\n", this.resourceName); - logger.debug("StateManagement: disableDependency() operation started, resourceName = {}", this.resourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), DISABLE_DEPENDENCY); - // set transition state - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - setChanged(); - notifyObservers(OPERATION_STATE); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: disableDependency() operation completed, resourceName = {}", this.resourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.disableDependency() caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.disableDependency() Exception: " + ex); - } - } - } - - /** - * enableNoDependency() removes the availability status of "dependency " and will change the - * operational state to enabled if not otherwise failed. - * @throws StateManagementException - */ - public void enableNoDependency() throws StateManagementException - { - synchronized (SYNCLOCK){ - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK enableNoDependency() operation for resourceName = {}\n", this.resourceName); - logger.debug("StateManagement: enableNoDependency() operation started, resourceName = {}", this.resourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), ENABLE_NO_DEPENDENCY); - // set transition state - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - setChanged(); - notifyObservers(OPERATION_STATE); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: enableNoDependency() operation completed, resourceName = {}", this.resourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.enableNoDependency() caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.enableNoDependency() Exception: " + ex); - } - } - } - - /** - * promote() changes the standby status to providingservice if not otherwise failed. - * @throws StandbyStatusException - * @throws StateManagementException - */ - public void promote() throws IntegrityMonitorException - { - synchronized (SYNCLOCK){ - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK promote() operation for resourceName = {}\n", this.resourceName); - logger.debug("StateManagement: promote() operation started, resourceName = {}", this.resourceName); - } - - StateManagementEntity sm; - - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - sm = findStateManagementEntity(em, this.resourceName); - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), PROMOTE); - // set transition state - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - setChanged(); - notifyObservers(STANDBY_STATUS); - }catch(final Exception ex){ - logger.error("StateManagement.promote() caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.promote() Exception: " + ex); - } - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: promote() operation completed, resourceName = ", this.resourceName); - } - if (sm.getStandbyStatus().equals(StateManagement.COLD_STANDBY)){ - final String msg = "Failure to promote " + this.resourceName + " StandbyStatus = " + StateManagement.COLD_STANDBY; - throw new StandbyStatusException(msg); - } - } - } - - /** - * demote() changes standbystatus to hotstandby or, if failed, coldstandby - * @throws StateManagementException - */ - public void demote() throws StateManagementException - { - synchronized (SYNCLOCK){ - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK demote() operation for resourceName = \n", this.resourceName); - logger.debug("StateManagement: demote() operation started, resourceName = {}", this.resourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("findStateManagementEntity for {}", this.resourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), DEMOTE); - // set transition state - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - setChanged(); - notifyObservers(STANDBY_STATUS); - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: demote() operation completed, resourceName = {}", this.resourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.demote() caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.demote() Exception: " + ex); - } - } - } - - /** - * - * Only used for a remote resource. It will not notify observers. It is used only in cases where - * the remote resource has failed is such a way that it cannot update its own states. In particular - * this is observed by PDP-D DroolsPdpsElectionHandler when it is trying to determine which PDP-D should - * be designated as the lead. - * @param otherResourceName - * @throws StateManagementException - */ - public void demote(final String otherResourceName) throws StateManagementException - { - synchronized (SYNCLOCK){ - if(otherResourceName==null){ - logger.error("\nStateManagement: SYNCLOCK demote(otherResourceName) operation: resourceName is NULL.\n"); - return; - } - if(logger.isDebugEnabled()){ - logger.debug("\nStateManagement: SYNCLOCK demote(otherResourceName) operation for resourceName = {}\n", otherResourceName); - } - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: SYNCLOCK demote(otherResourceName) findStateManagementEntity for {}", otherResourceName); - } - final StateManagementEntity sm = findStateManagementEntity(em, otherResourceName); - final StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), - sm.getAvailStatus(), sm.getStandbyStatus(), DEMOTE); - // set transition state - sm.setAdminState(stateElement.getEndingAdminState()); - sm.setOpState(stateElement.getEndingOpState()); - sm.setAvailStatus(stateElement.getEndingAvailStatus()); - sm.setStandbyStatus(stateElement.getEndingStandbyStatus()); - - em.persist(sm); - et.commit(); - //We don't notify observers because this is assumed to be a remote resource - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: demote(otherResourceName) operation completed, resourceName = {}", otherResourceName); - } - } catch(final Exception ex) { - logger.error("StateManagement.demote(otherResourceName) caught unexpected exception: ", ex); - throw new StateManagementException("StateManagement.demote(otherResourceName) Exception: " + ex); - } - } - } - - /** - * @return - */ -public String getAdminState() - { - if(logger.isDebugEnabled()){ - logger.debug("StateManagement(6/1/16): getAdminState for resourceName {}", this.resourceName); - } - - final EntityManager em = emf.createEntityManager(); - try(final EntityMgrCloser emc = new EntityMgrCloser(em)) { - final TypedQuery<StateManagementEntity> query = em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); - - query.setParameter(RESOURCE_NAME, this.resourceName); - - //Just test that we are retrieving the right object - final - List<StateManagementEntity> resourceList = query.setLockMode( - LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); - if (!resourceList.isEmpty()) { - // exist - final StateManagementEntity stateManagementEntity = resourceList.get(0); - // refresh the object from DB in case cached data was returned - em.refresh(stateManagementEntity); - this.adminState = stateManagementEntity.getAdminState(); - } else { - this.adminState = null; - } - } catch(final Exception ex) { - logger.error("StateManagement: getAdminState exception: {}", ex.toString(), ex); - } - - return this.adminState; - } - - /** - * @return - */ -public String getOpState() - { - if(logger.isDebugEnabled()){ - logger.debug("StateManagement(6/1/16): getOpState for resourceName {}", this.resourceName); - } - - final EntityManager em = emf.createEntityManager(); - try(EntityMgrCloser emc = new EntityMgrCloser(em)) { - final TypedQuery<StateManagementEntity> query = em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); - - query.setParameter(RESOURCE_NAME, this.resourceName); - - //Just test that we are retrieving the right object - final - List<StateManagementEntity> resourceList = query.setLockMode( - LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); - if (!resourceList.isEmpty()) { - // exist - final StateManagementEntity stateManagementEntity = resourceList.get(0); - // refresh the object from DB in case cached data was returned - em.refresh(stateManagementEntity); - this.opState = stateManagementEntity.getOpState(); - } else { - this.opState = null; - } - } catch(final Exception ex) { - logger.error("StateManagement: getOpState exception: {}", ex.toString(), ex); - } - - return this.opState; - } - - /** - * @return - */ - public String getAvailStatus() - { - if(logger.isDebugEnabled()){ - logger.debug("StateManagement(6/1/16): getAvailStatus for resourceName {}", this.resourceName); - } - - final EntityManager em = emf.createEntityManager(); - try(EntityMgrCloser emc = new EntityMgrCloser(em)) { - final TypedQuery<StateManagementEntity> query = em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); - - query.setParameter(RESOURCE_NAME, this.resourceName); - - //Just test that we are retrieving the right object - final - List<StateManagementEntity> resourceList = query.setLockMode( - LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); - if (!resourceList.isEmpty()) { - // exist - final StateManagementEntity stateManagementEntity = resourceList.get(0); - // refresh the object from DB in case cached data was returned - em.refresh(stateManagementEntity); - this.availStatus = stateManagementEntity.getAvailStatus(); - } else { - this.availStatus = null; - } - } catch(final Exception ex) { - logger.error("StateManagement: getAvailStatus exception: {}", ex.toString(), ex); - } - - return this.availStatus; - } - - /** - * @return - */ - public String getStandbyStatus() - { - if(logger.isDebugEnabled()){ - logger.debug("StateManagement(6/1/16): getStandbyStatus for resourceName {}", this.resourceName); - } - - final EntityManager em = emf.createEntityManager(); - try(EntityMgrCloser emc = new EntityMgrCloser(em)) { - final TypedQuery<StateManagementEntity> query = em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); - - query.setParameter(RESOURCE_NAME, this.resourceName); - - //Just test that we are retrieving the right object - final - List<StateManagementEntity> resourceList = query.setLockMode( - LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); - if (!resourceList.isEmpty()) { - // exist - final StateManagementEntity stateManagementEntity = resourceList.get(0); - // refresh the object from DB in case cached data was returned - em.refresh(stateManagementEntity); - this.standbyStatus = stateManagementEntity.getStandbyStatus(); - } else { - this.standbyStatus = null; - } - } catch(final Exception ex) { - logger.error("StateManagement: getStandbyStatus exception: {}", ex.toString(), ex); - } - - return this.standbyStatus; - } - - /** - * Find a StateManagementEntity - * @param em - * @param otherResourceName - * @return - */ - private static StateManagementEntity findStateManagementEntity(final EntityManager em, final String otherResourceName) - { - if(logger.isDebugEnabled()){ - logger.debug("StateManagementEntity: findStateManagementEntity: Entry"); - } - try { - final TypedQuery<StateManagementEntity> query = - em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); - - query.setParameter(RESOURCE_NAME, otherResourceName); - - //Just test that we are retrieving the right object - final - List<StateManagementEntity> resourceList = query.setLockMode( - LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); - if (!resourceList.isEmpty()) { - // exist - final StateManagementEntity stateManagementEntity = resourceList.get(0); - // refresh the object from DB in case cached data was returned - em.refresh(stateManagementEntity); - stateManagementEntity.setModifiedDate(new Date()); - return stateManagementEntity; - } else { - // not exist - create one - final StateManagementEntity stateManagementEntity = new StateManagementEntity(); - stateManagementEntity.setResourceName(otherResourceName); - stateManagementEntity.setAdminState(UNLOCKED); - stateManagementEntity.setOpState(ENABLED); - stateManagementEntity.setAvailStatus(NULL_VALUE); - stateManagementEntity.setStandbyStatus(NULL_VALUE); // default - return stateManagementEntity; - } - } catch(final Exception ex) { - final String message = "findStateManagementEntity exception"; - logger.error("{}: {}", message, ex.toString(), ex); - throw new EntityRetrievalException(message, ex); - } - } - - /** - * Get the standbystatus of a particular resource - * @param otherResourceName - * @return - */ - public String getStandbyStatus(final String otherResourceName) { - - if (logger.isDebugEnabled()) { - logger.debug("StateManagement: getStandbyStatus: Entering, resourceName='{}'", otherResourceName); - } - - String tempStandbyStatus = null; - - // The transaction is required for the LockModeType - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - - final TypedQuery<StateManagementEntity> stateManagementListQuery = em - .createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); - stateManagementListQuery.setParameter(RESOURCE_NAME, otherResourceName); - final List<StateManagementEntity> stateManagementList = stateManagementListQuery.setLockMode( - LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); - if (!stateManagementList.isEmpty()) { - final StateManagementEntity stateManagementEntity = stateManagementList.get(0); - // refresh the object from DB in case cached data was returned - em.refresh(stateManagementEntity); - tempStandbyStatus = stateManagementEntity.getStandbyStatus(); - if (logger.isDebugEnabled()) { - logger.debug("getStandbyStatus: resourceName ={} has standbyStatus={}", otherResourceName, tempStandbyStatus); - } - } else { - logger.error("getStandbyStatus: resourceName ={} not found in statemanagemententity table", otherResourceName); - } - - et.commit(); - } catch (final Exception e) { - logger.error("getStandbyStatus: Caught Exception attempting to get statemanagemententity record, message='{}'", e.getMessage(), e); - } - if (logger.isDebugEnabled()) { - logger.debug("getStandbyStatus: Returning standbyStatus={}", tempStandbyStatus); - } - - return tempStandbyStatus; - } - - /** - * Clean up all the StateManagementEntities - */ - public void deleteAllStateManagementEntities() { - - if(logger.isDebugEnabled()){ - logger.debug("StateManagement: deleteAllStateManagementEntities: Entering"); - } - - /* - * Start transaction - */ - final EntityManager em = emf.createEntityManager(); - - try(EntityMgrCloser emc = new EntityMgrCloser(em); - MyTransaction et = new MyTransaction(em)) { - final TypedQuery<StateManagementEntity> stateManagementEntityListQuery = em - .createQuery("SELECT p FROM StateManagementEntity p", StateManagementEntity.class); - final - List<StateManagementEntity> stateManagementEntityList = stateManagementEntityListQuery.setLockMode( - LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); - if(logger.isDebugEnabled()){ - logger.debug("deleteAllStateManagementEntities: Deleting {} StateManagementEntity records", stateManagementEntityList.size()); - } - for (final StateManagementEntity stateManagementEntity : stateManagementEntityList) { - if(logger.isDebugEnabled()){ - logger.debug("deleteAllStateManagementEntities: Deleting statemanagemententity with resourceName={} and standbyStatus={}", - stateManagementEntity.getResourceName(), - stateManagementEntity.getStandbyStatus()); - } - em.remove(stateManagementEntity); - } - - et.commit(); - }catch(final Exception ex){ - logger.error("StateManagement.deleteAllStateManagementEntities() caught Exception: ", ex); - } - if(logger.isDebugEnabled()){ - logger.debug("deleteAllStateManagementEntities: Exiting"); - } - } - - private static class MyTransaction extends EntityTransCloser { - - /** - * @param em - */ - public MyTransaction(final EntityManager em) { - super(em.getTransaction()); - } - - @Override - public void commit() { - synchronized(FLUSHLOCK){ - if(getTransation().isActive()){ - super.commit(); - } - } - } - - @Override - public void rollback() { - synchronized(FLUSHLOCK){ - if(getTransation().isActive()){ - super.rollback(); - } - } - } - - } + } catch (final Exception e) { + logger.error( + "getStandbyStatus: Caught Exception attempting to get statemanagemententity record, message='{}'", + e.getMessage(), e); + } + if (logger.isDebugEnabled()) { + logger.debug("getStandbyStatus: Returning standbyStatus={}", tempStandbyStatus); + } + + return tempStandbyStatus; + } + + /** + * Find a StateManagementEntity. + * + * @param em the entity manager + * @param otherResourceName the resource name + * @return the StateManagementEntity + */ + private static StateManagementEntity findStateManagementEntity(final EntityManager em, + final String otherResourceName) { + if (logger.isDebugEnabled()) { + logger.debug("StateManagementEntity: findStateManagementEntity: Entry"); + } + try { + final TypedQuery<StateManagementEntity> query = + em.createQuery(GET_STATE_MANAGEMENT_ENTITY_QUERY, StateManagementEntity.class); + + query.setParameter(RESOURCE_NAME, otherResourceName); + + // Just test that we are retrieving the right object + final List<StateManagementEntity> resourceList = + query.setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); + if (!resourceList.isEmpty()) { + // exist + final StateManagementEntity stateManagementEntity = resourceList.get(0); + // refresh the object from DB in case cached data was returned + em.refresh(stateManagementEntity); + stateManagementEntity.setModifiedDate(new Date()); + return stateManagementEntity; + } else { + // not exist - create one + final StateManagementEntity stateManagementEntity = new StateManagementEntity(); + stateManagementEntity.setResourceName(otherResourceName); + stateManagementEntity.setAdminState(UNLOCKED); + stateManagementEntity.setOpState(ENABLED); + stateManagementEntity.setAvailStatus(NULL_VALUE); + stateManagementEntity.setStandbyStatus(NULL_VALUE); // default + return stateManagementEntity; + } + } catch (final Exception ex) { + final String message = "findStateManagementEntity exception"; + logger.error("{}: {}", message, ex.toString(), ex); + throw new EntityRetrievalException(message, ex); + } + } + + /** + * Clean up all the StateManagementEntities. + */ + public void deleteAllStateManagementEntities() { + + if (logger.isDebugEnabled()) { + logger.debug("StateManagement: deleteAllStateManagementEntities: Entering"); + } + + /* + * Start transaction + */ + final EntityManager em = emf.createEntityManager(); + + try (EntityMgrCloser emc = new EntityMgrCloser(em); MyTransaction et = new MyTransaction(em)) { + final TypedQuery<StateManagementEntity> stateManagementEntityListQuery = + em.createQuery("SELECT p FROM StateManagementEntity p", StateManagementEntity.class); + final List<StateManagementEntity> stateManagementEntityList = stateManagementEntityListQuery + .setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); + if (logger.isDebugEnabled()) { + logger.debug("deleteAllStateManagementEntities: Deleting {} StateManagementEntity records", + stateManagementEntityList.size()); + } + for (final StateManagementEntity stateManagementEntity : stateManagementEntityList) { + if (logger.isDebugEnabled()) { + logger.debug( + "deleteAllStateManagementEntities: Deleting statemanagemententity with resourceName={} and" + + " standbyStatus={}", + stateManagementEntity.getResourceName(), stateManagementEntity.getStandbyStatus()); + } + em.remove(stateManagementEntity); + } + + et.commit(); + } catch (final Exception ex) { + logger.error("StateManagement.deleteAllStateManagementEntities() caught Exception: ", ex); + } + if (logger.isDebugEnabled()) { + logger.debug("deleteAllStateManagementEntities: Exiting"); + } + } + + private static class MyTransaction extends EntityTransCloser { + + /** + * Create an instance. + * + * @param em the entity manager + */ + public MyTransaction(final EntityManager em) { + super(em.getTransaction()); + } + + @Override + public void commit() { + synchronized (FLUSHLOCK) { + if (getTransation().isActive()) { + super.commit(); + } + } + } + + @Override + public void rollback() { + synchronized (FLUSHLOCK) { + if (getTransation().isActive()) { + super.rollback(); + } + } + } + + } } |