diff options
Diffstat (limited to 'integrity-monitor/src/main/java')
6 files changed, 524 insertions, 286 deletions
diff --git a/integrity-monitor/src/main/java/org/onap/policy/common/im/IntegrityMonitor.java b/integrity-monitor/src/main/java/org/onap/policy/common/im/IntegrityMonitor.java index 9d437938..9ac5adb6 100644 --- a/integrity-monitor/src/main/java/org/onap/policy/common/im/IntegrityMonitor.java +++ b/integrity-monitor/src/main/java/org/onap/policy/common/im/IntegrityMonitor.java @@ -41,11 +41,11 @@ import javax.persistence.Query; import org.onap.policy.common.im.jpa.ForwardProgressEntity; import org.onap.policy.common.im.jpa.ResourceRegistrationEntity; import org.onap.policy.common.im.jpa.StateManagementEntity; -import org.onap.policy.common.logging.flexlogger.FlexLogger; -import org.onap.policy.common.logging.flexlogger.Logger; import org.onap.policy.common.im.jmx.ComponentAdmin; import org.onap.policy.common.im.jmx.ComponentAdminMBean; import org.onap.policy.common.im.jmx.JmxAgentConnection; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * IntegrityMonitor @@ -53,7 +53,7 @@ import org.onap.policy.common.im.jmx.JmxAgentConnection; * the X.731 ITU standard. */ public class IntegrityMonitor { - private static final Logger logger = FlexLogger.getLogger(IntegrityMonitor.class.getName()); + private static final Logger logger = LoggerFactory.getLogger(IntegrityMonitor.class.getName()); // only allow one instance of IntegrityMonitor @@ -174,14 +174,18 @@ public class IntegrityMonitor { */ public static IntegrityMonitor getInstance(String resourceName, Properties properties) throws Exception { synchronized(getInstanceLock){ - logger.info("getInstance() called - resourceName=" + resourceName); + if(logger.isDebugEnabled()){ + logger.debug("getInstance() called - resourceName= {}", resourceName); + } if (resourceName == null || resourceName.isEmpty() || properties == null) { logger.error("Error: getIntegrityMonitorInstance() called with invalid input"); return null; } if (instance == null) { - logger.info("Creating new instance of IntegrityMonitor"); + if(logger.isDebugEnabled()){ + logger.debug("Creating new instance of IntegrityMonitor"); + } instance = new IntegrityMonitor(resourceName, properties); } return instance; @@ -189,7 +193,9 @@ public class IntegrityMonitor { } public static IntegrityMonitor getInstance() throws Exception{ - logger.info("getInstance() called"); + if(logger.isDebugEnabled()){ + logger.debug("getInstance() called"); + } if (instance == null) { String msg = "No IntegrityMonitor instance exists." + " Please use the method IntegrityMonitor.getInstance(String resourceName, Properties properties)"; @@ -200,11 +206,15 @@ public class IntegrityMonitor { } public static void deleteInstance(){ - logger.info("deleteInstance() called"); + if(logger.isDebugEnabled()){ + logger.debug("deleteInstance() called"); + } if(isUnitTesting()){ instance=null; } - logger.info("deleteInstance() exit"); + if(logger.isDebugEnabled()){ + logger.debug("deleteInstance() exit"); + } } /** * IntegrityMonitor constructor. It is invoked from the getInstance() method in @@ -221,7 +231,7 @@ public class IntegrityMonitor { // singleton check since this constructor can be called from a child or sub-class if (instance != null) { String msg = "IM object exists and only one instance allowed"; - logger.error(msg); + logger.error("{}", msg); throw new IntegrityMonitorException("IntegrityMonitor constructor exception: " + msg); } instance = this; @@ -245,8 +255,8 @@ public class IntegrityMonitor { // Did it get created? // if (emf == null) { - logger.error("Error creating IM entity manager factory with persistence unit: " - + PERSISTENCE_UNIT); + logger.error("Error creating IM entity manager factory with persistence unit: {}", + PERSISTENCE_UNIT); throw new IntegrityMonitorException("Unable to create IM Entity Manager Factory"); } @@ -272,11 +282,15 @@ public class IntegrityMonitor { fpx = (ForwardProgressEntity) fpList.get(0); // refresh the object from DB in case cached data was returned em.refresh(fpx); - logger.info("Resource " + resourceName + " exists and will be updated - old fpc=" + fpx.getFpcCount() + ", lastUpdated=" + fpx.getLastUpdated()); + if(logger.isDebugEnabled()){ + logger.debug("Resource {} exists and will be updated - old fpc= {}, lastUpdated= {}", resourceName, fpx.getFpcCount(), fpx.getLastUpdated()); + } fpx.setFpcCount(fpCounter); }else{ //Create a forward progress object - logger.info("Adding resource " + resourceName + " to ForwardProgress table"); + if(logger.isDebugEnabled()){ + logger.debug("Adding resource {} to ForwardProgress table", resourceName); + } fpx = new ForwardProgressEntity(); } //update/set columns in entry @@ -300,11 +314,15 @@ public class IntegrityMonitor { rrx = (ResourceRegistrationEntity) rrList.get(0); // refresh the object from DB in case cached data was returned em.refresh(rrx); - logger.info("Resource " + resourceName + " exists and will be updated - old url=" + rrx.getResourceUrl() + ", createdDate=" + rrx.getCreatedDate()); + if(logger.isDebugEnabled()){ + logger.debug("Resource {} exists and will be updated - old url= {}, createdDate={}", resourceName, rrx.getResourceUrl(), rrx.getCreatedDate()); + } rrx.setLastUpdated(new Date()); }else{ // register resource by adding entry to table in DB - logger.info("Adding resource " + resourceName + " to ResourceRegistration table"); + if(logger.isDebugEnabled()){ + logger.debug("Adding resource {} to ResourceRegistration table", resourceName); + } rrx = new ResourceRegistrationEntity(); } //update/set columns in entry @@ -319,7 +337,7 @@ public class IntegrityMonitor { } } catch (Exception e) { - logger.error("IntegrityMonitor constructor DB table update failed with exception: " + e); + logger.error("IntegrityMonitor constructor DB table update failed with exception: ", e); try { if (et.isActive()) { synchronized(IMFLUSHLOCK){ @@ -327,7 +345,7 @@ public class IntegrityMonitor { } } } catch (Exception e1) { - logger.error("IntegrityMonitor constructor threw exception: " + e1); + logger.error("IntegrityMonitor constructor threw exception: ", e1); } throw e; } @@ -348,7 +366,7 @@ public class IntegrityMonitor { try { new ComponentAdmin(resourceName, this, stateManager); } catch (Exception e) { - logger.error("ComponentAdmin constructor exception: " + e); + logger.error("ComponentAdmin constructor exception: {}", e.toString(), e); } new FPManager(); @@ -364,7 +382,7 @@ public class IntegrityMonitor { String jmx_err_msg; if (jmx_port == null) { jmx_err_msg = "System property com.sun.management.jmxremote.port for JMX remote port is not set"; - logger.error(jmx_err_msg); + logger.error("{}", jmx_err_msg); throw new IntegrityMonitorException("getJmxUrl exception: " + jmx_err_msg); } @@ -373,7 +391,7 @@ public class IntegrityMonitor { port = Integer.parseInt(jmx_port); } catch (NumberFormatException e) { jmx_err_msg = "JMX remote port is not a valid integer value - " + jmx_port; - logger.error(jmx_err_msg); + logger.error("{}", jmx_err_msg); throw new IntegrityMonitorException("getJmxUrl exception: " + jmx_err_msg); } @@ -382,19 +400,22 @@ public class IntegrityMonitor { jmxFqdn = InetAddress.getLocalHost().getCanonicalHostName(); // get FQDN of this host } } catch (Exception e) { - String msg = "getJmxUrl could not get hostname" + e; - logger.error(msg); + String msg = "getJmxUrl could not get hostname"; + logger.error("{}", msg, e); throw new IntegrityMonitorException("getJmxUrl Exception: " + msg); } if (jmxFqdn == null) { String msg = "getJmxUrl encountered null hostname"; - logger.error(msg); + logger.error("{}", msg); throw new IntegrityMonitorException("getJmxUrl error: " + msg); } // assemble the jmx url String jmx_url = "service:jmx:rmi:///jndi/rmi://" + jmxFqdn + ":" + port + "/jmxrmi"; - logger.info("IntegerityMonitor - jmx url=" + jmx_url); + + if(logger.isDebugEnabled()){ + logger.debug("IntegerityMonitor - jmx url={}", jmx_url); + } return jmx_url; } @@ -405,29 +426,38 @@ public class IntegrityMonitor { * which includes information about any dependency (node) which has failed. */ public void evaluateSanity() throws Exception { - logger.debug("evaluateSanity called ...."); + if(logger.isDebugEnabled()){ + logger.debug("evaluateSanity called ...."); + } synchronized(evaluateSanityLock){ String error_msg = dependencyCheckErrorMsg; - logger.debug("evaluateSanity dependencyCheckErrorMsg = " + error_msg); - + if(logger.isDebugEnabled()){ + logger.debug("evaluateSanity dependencyCheckErrorMsg = {}", error_msg); + } // check op state and throw exception if disabled if ((stateManager.getOpState() != null) && stateManager.getOpState().equals(StateManagement.DISABLED)) { String msg = "Resource " + resourceName + " operation state is disabled. " + error_msg; - logger.debug(msg); + if(logger.isDebugEnabled()){ + logger.debug("{}", msg); + } throw new IntegrityMonitorException(msg); } // check admin state and throw exception if locked if ((stateManager.getAdminState() != null) && stateManager.getAdminState().equals(StateManagement.LOCKED)) { String msg = "Resource " + resourceName + " is administratively locked"; - logger.debug(msg); + if(logger.isDebugEnabled()){ + logger.debug("{}", msg); + } throw new AdministrativeStateException("IntegrityMonitor Admin State Exception: " + msg); } // check standby state and throw exception if cold standby if ((stateManager.getStandbyStatus() != null) && stateManager.getStandbyStatus().equals(StateManagement.COLD_STANDBY)){ String msg = "Resource " + resourceName + " is cold standby"; - logger.debug(msg); + if(logger.isDebugEnabled()){ + logger.debug("{}", msg); + } throw new StandbyStatusException("IntegrityMonitor Standby Status Exception: " + msg); } @@ -443,8 +473,9 @@ public class IntegrityMonitor { * will return an error. */ public String stateCheck(String dep) { - logger.debug("checking state of dependent resource: " + dep); - + if(logger.isDebugEnabled()){ + logger.debug("checking state of dependent resource: {}", dep); + } String error_msg = null; ForwardProgressEntity forwardProgressEntity = null; StateManagementEntity stateManagementEntity = null; @@ -466,11 +497,12 @@ public class IntegrityMonitor { forwardProgressEntity = (ForwardProgressEntity) fpList.get(0); // refresh the object from DB in case cached data was returned em.refresh(forwardProgressEntity); - logger.debug("Found entry in ForwardProgressEntity table for dependent Resource=" + dep); + if(logger.isDebugEnabled()){ + logger.debug("Found entry in ForwardProgressEntity table for dependent Resource={}", dep); + } } else { error_msg = dep + ": resource not found in ForwardProgressEntity database table"; - logger.debug(error_msg); - logger.error(error_msg); + logger.error("{}", error_msg); } synchronized(IMFLUSHLOCK){ et.commit(); @@ -478,9 +510,8 @@ public class IntegrityMonitor { } catch(Exception ex){ // log an error - error_msg = dep + ": ForwardProgressEntity DB operation failed with exception: " + ex; - logger.debug(error_msg); - logger.error(error_msg); + error_msg = dep + ": ForwardProgressEntity DB operation failed with exception: "; + logger.error("{}", error_msg, ex); synchronized(IMFLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -505,11 +536,12 @@ public class IntegrityMonitor { stateManagementEntity = (StateManagementEntity) smList.get(0); // refresh the object from DB in case cached data was returned em.refresh(stateManagementEntity); - logger.debug("Found entry in StateManagementEntity table for dependent Resource=" + dep); + if(logger.isDebugEnabled()){ + logger.debug("Found entry in StateManagementEntity table for dependent Resource={}", dep); + } } else { error_msg = dep + ": resource not found in state management entity database table"; - logger.debug(error_msg); - logger.error(error_msg); + logger.error("{}", error_msg); } synchronized(IMFLUSHLOCK){ @@ -517,9 +549,8 @@ public class IntegrityMonitor { } } catch (Exception e) { // log an error - error_msg = dep + ": StateManagementEntity DB read failed with exception: " + e; - logger.debug(error_msg); - logger.error(error_msg); + error_msg = dep + ": StateManagementEntity DB read failed with exception: "; + logger.error("{}", error_msg, e); synchronized(IMFLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -533,24 +564,29 @@ public class IntegrityMonitor { if (forwardProgressEntity != null && stateManagementEntity != null) { Date date = new Date(); long diffMs = date.getTime() - forwardProgressEntity.getLastUpdated().getTime(); - logger.debug("IntegrityMonitor.stateCheck(): diffMs = " + diffMs); + if(logger.isDebugEnabled()){ + logger.debug("IntegrityMonitor.stateCheck(): diffMs = {}", diffMs); + } //Threshold for a stale entry long staleMs = failedCounterThreshold * monitorInterval * (long)1000; - logger.debug("IntegrityMonitor.stateCheck(): staleMs = " + staleMs); + if(logger.isDebugEnabled()){ + logger.debug("IntegrityMonitor.stateCheck(): staleMs = {}", staleMs); + } if(diffMs > staleMs){ //ForwardProgress is stale. Disable it try { if(!stateManagementEntity.getOpState().equals(StateManagement.DISABLED)){ - logger.debug("IntegrityMonitor.stateCheck(): Changing OpStat = disabled for " + dep); + if(logger.isDebugEnabled()){ + logger.debug("IntegrityMonitor.stateCheck(): Changing OpStat = disabled for {}", dep); + } stateManager.disableFailed(dep); } } catch (Exception e) { String msg = "IntegrityMonitor.stateCheck(): Failed to diableFail dependent resource = " + dep + "; " + e.getMessage(); - logger.debug(msg, e); - logger.error(msg, e); + logger.error("{}",msg, e); } } } @@ -559,15 +595,13 @@ public class IntegrityMonitor { if(forwardProgressEntity == null) { String msg = "IntegrityMonitor.stateCheck(): Failed to diableFail dependent resource = " + dep + "; " + " forwardProgressEntity == null."; - logger.debug(msg); - logger.error(msg); + logger.error("{}", msg); } else { String msg = "IntegrityMonitor.stateCheck(): Failed to diableFail dependent resource = " + dep + "; " + " stateManagementEntity == null."; - logger.debug(msg); - logger.error(msg); + logger.error("{}", msg); } } } @@ -577,32 +611,32 @@ public class IntegrityMonitor { if(stateManagementEntity != null) { if ((stateManager.getAdminState() != null) && stateManagementEntity.getAdminState().equals(StateManagement.LOCKED)) { error_msg = dep + ": resource is administratively locked"; - logger.debug(error_msg); - logger.error(error_msg); + logger.error("{}", error_msg); } else if ((stateManager.getOpState() != null) && stateManagementEntity.getOpState().equals(StateManagement.DISABLED)) { error_msg = dep + ": resource is operationally disabled"; - logger.debug(error_msg); - logger.error(error_msg); + logger.error("{}", error_msg); } else if ((stateManager.getStandbyStatus() != null) && stateManagementEntity.getStandbyStatus().equals(StateManagement.COLD_STANDBY)) { error_msg = dep + ": resource is cold standby"; - logger.debug(error_msg); - logger.error(error_msg); + logger.error("{}", error_msg); } } else { error_msg = dep + ": could not check standy state of resource. stateManagementEntity == null."; - logger.debug(error_msg); - logger.error(error_msg); + logger.error("{}", error_msg); } } String returnMsg = "IntegrityMonitor.stateCheck(): returned error_msg: " + error_msg; - logger.debug(returnMsg); + if(logger.isDebugEnabled()){ + logger.debug("{}", returnMsg); + } return error_msg; } private String fpCheck(String dep) { - logger.debug("checking forward progress count of dependent resource: " + dep); + if(logger.isDebugEnabled()){ + logger.debug("checking forward progress count of dependent resource: {}", dep); + } String error_msg = null; @@ -624,36 +658,40 @@ public class IntegrityMonitor { fpx = (ForwardProgressEntity) fpList.get(0); // refresh the object from DB in case cached data was returned em.refresh(fpx); - logger.debug("Dependent resource " + dep + " - fpc=" + fpx.getFpcCount() + ", lastUpdated=" + fpx.getLastUpdated()); + if(logger.isDebugEnabled()){ + logger.debug("Dependent resource {} - fpc= {}, lastUpdated={}", dep, fpx.getFpcCount(), fpx.getLastUpdated()); + } long currTime = System.currentTimeMillis(); // if dependent resource FPC has not been updated, consider it an error if ((currTime - fpx.getLastUpdated().getTime()) > (1000 * maxFpcUpdateInterval)) { error_msg = dep + ": FP count has not been updated in the last " + maxFpcUpdateInterval + " seconds"; - logger.error(error_msg); + logger.error("{}", error_msg); try { // create instance of StateMangement class for dependent StateManagement depStateManager = new StateManagement(emf, dep); if(!depStateManager.getOpState().equals(StateManagement.DISABLED)){ - logger.info("Forward progress not detected for dependent resource " + dep + ". Setting dependent's state to disable failed."); + if(logger.isDebugEnabled()){ + logger.debug("Forward progress not detected for dependent resource {}. Setting dependent's state to disable failed.", dep); + } depStateManager.disableFailed(); } } catch (Exception e) { // ignore errors - logger.info("Update dependent state failed with exception: " + e); + logger.error("Update dependent state failed with exception: ", e); } } } else { // resource entry not found in FPC table error_msg = dep + ": resource not found in ForwardProgressEntity table in the DB"; - logger.error(error_msg); + logger.error("{}", error_msg); } synchronized(IMFLUSHLOCK){ et.commit(); } } catch (Exception e) { // log an error and continue - error_msg = dep + ": ForwardProgressEntity DB read failed with exception: " + e; - logger.error(error_msg); + error_msg = dep + ": ForwardProgressEntity DB read failed with exception: "; + logger.error("{}", error_msg, e); synchronized(IMFLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -681,13 +719,13 @@ public class IntegrityMonitor { et.commit(); } if(logger.isDebugEnabled()){ - logger.debug("getAllForwardProgressEntity: myList.size(): " + myList.size()); + logger.debug("getAllForwardProgressEntity: myList.size(): {}", myList.size()); } if(!myList.isEmpty()){ for(int i = 0; i < myList.size(); i++){ if(logger.isDebugEnabled()){ - logger.debug("getAllForwardProgressEntity: myList.get(" + i +").getResourceName()" - + ": " + ((ForwardProgressEntity)myList.get(i)).getResourceName()); + logger.debug("getAllForwardProgressEntity: myList.get({}).getResourceName(): {}",i, + ((ForwardProgressEntity)myList.get(i)).getResourceName()); } fpList.add((ForwardProgressEntity) myList.get(i)); } @@ -699,8 +737,8 @@ public class IntegrityMonitor { } } catch (Exception e) { // log an error and continue - String msg = "getAllForwardProgessEntity DB read failed with exception: " + e; - logger.error(msg); + String msg = "getAllForwardProgessEntity DB read failed with exception: "; + logger.error("{}", msg, e); synchronized(IMFLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -712,7 +750,9 @@ public class IntegrityMonitor { private String jmxCheck(String dep) { - logger.debug("checking health of dependent by calling test() via JMX on resource: " + dep); + if(logger.isDebugEnabled()){ + logger.debug("checking health of dependent by calling test() via JMX on resource: {}", dep); + } String error_msg = null; @@ -737,18 +777,20 @@ public class IntegrityMonitor { // refresh the object from DB in case cached data was returned em.refresh(rrx); jmxUrl = rrx.getResourceUrl(); - logger.debug("Dependent Resource=" + dep + ", url=" + jmxUrl + ", createdDate=" + rrx.getCreatedDate()); + if(logger.isDebugEnabled()){ + logger.debug("Dependent Resource={}, url={}, createdDate={}", dep, jmxUrl, rrx.getCreatedDate()); + } } else { error_msg = dep + ": resource not found in ResourceRegistrationEntity table in the DB"; - logger.error(error_msg); + logger.error("{}", error_msg); } synchronized(IMFLUSHLOCK){ et.commit(); } } catch (Exception e) { - error_msg = dep + ": ResourceRegistrationEntity DB read failed with exception: " + e; - logger.error(error_msg); + error_msg = dep + ": ResourceRegistrationEntity DB read failed with exception: "; + logger.error("{}", error_msg, e); synchronized(IMFLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -767,10 +809,12 @@ public class IntegrityMonitor { // invoke the test method via the jmx proxy admin.test(); - logger.debug("Dependent resource " + dep + " sanity test passed"); + if(logger.isDebugEnabled()){ + logger.debug("Dependent resource {} sanity test passed", dep); + } } catch (Exception e) { - error_msg = dep + ": resource sanity test failed with exception: " + e; - logger.error(error_msg); + error_msg = dep + ": resource sanity test failed with exception: "; + logger.error("{}", error_msg, e); // TODO: extract real error message from exception which may be nested } finally { // close the JMX connector @@ -784,7 +828,9 @@ public class IntegrityMonitor { } private String dependencyCheck() { - logger.debug("dependencyCheck: entry - checking health of dependent groups and setting resource's state"); + if(logger.isDebugEnabled()){ + logger.debug("dependencyCheck: entry - checking health of dependent groups and setting resource's state"); + } synchronized(dependencyCheckLock){ // Start with the error message empty @@ -802,7 +848,9 @@ public class IntegrityMonitor { continue; } String [] dependencies = group.split(","); - logger.debug("group dependencies = " + Arrays.toString(dependencies)); + if(logger.isDebugEnabled()){ + logger.debug("group dependencies = {}", Arrays.toString(dependencies)); + } int real_dep_count = 0; int fail_dep_count = 0; for (String dep : dependencies) { @@ -833,7 +881,9 @@ public class IntegrityMonitor { if ((real_dep_count > 0) && (fail_dep_count == real_dep_count)) { dependencyFailure=true; try { - logger.info("All dependents in group " + group + " have failed their health check. Updating this resource's state to disableDependency"); + if(logger.isDebugEnabled()){ + logger.debug("All dependents in group {} have failed their health check. Updating this resource's state to disableDependency", group); + } if( !( (stateManager.getAvailStatus()).equals(StateManagement.DEPENDENCY) || (stateManager.getAvailStatus()).equals(StateManagement.DEPENDENCY_FAILED) ) ){ // Note: redundant calls are made by refreshStateAudit @@ -844,7 +894,7 @@ public class IntegrityMonitor { this.stateManager.disableDependency(); } } catch (Exception e) { - logger.error(e); + logger.error("IntegrityMonitor threw exception.", e); if (!error_msg.isEmpty()) { error_msg = error_msg.concat(","); } @@ -861,14 +911,16 @@ public class IntegrityMonitor { */ if(!dependencyFailure){ try { - logger.debug("All dependency groups have at least one viable member. Updating this resource's state to enableNoDependency"); + if(logger.isDebugEnabled()){ + logger.debug("All dependency groups have at least one viable member. Updating this resource's state to enableNoDependency"); + } if( (stateManager.getAvailStatus()).equals(StateManagement.DEPENDENCY) || (stateManager.getAvailStatus()).equals(StateManagement.DEPENDENCY_FAILED) ){ // Note: redundant calls are made by refreshStateAudit this.stateManager.enableNoDependency(); } // The refreshStateAudit will catch the case where it is disabled but availStatus != failed } catch (Exception e) { - logger.error(e); + logger.error("IntegrityMonitor threw exception.", e); if (!error_msg.isEmpty()) { error_msg = error_msg.concat(","); } @@ -882,14 +934,16 @@ public class IntegrityMonitor { * this happen in the lab, but is not very likely in a production environment...but you never know. */ try { - logger.debug("There are no dependents. Updating this resource's state to enableNoDependency"); + if(logger.isDebugEnabled()){ + logger.debug("There are no dependents. Updating this resource's state to enableNoDependency"); + } if( (stateManager.getAvailStatus()).equals(StateManagement.DEPENDENCY) || (stateManager.getAvailStatus()).equals(StateManagement.DEPENDENCY_FAILED) ){ // Note: redundant calls are made by refreshStateAudit this.stateManager.enableNoDependency(); }// The refreshStateAudit will catch the case where it is disabled but availStatus != failed } catch (Exception e) { - logger.error(e); + logger.error("IntegrityMonitor threw exception.", e); if (!error_msg.isEmpty()) { error_msg = error_msg.concat(","); } @@ -906,10 +960,12 @@ public class IntegrityMonitor { //Test any subsystems that are not covered under the dependency relationship subsystemTest(); }catch (Exception e){ - logger.error(e); + logger.error("IntegrityMonitor threw exception", e); //This indicates a subsystemTest failure try { - logger.info(resourceName + ": There has been a subsystemTest failure with error: " + e.getMessage() + " Updating this resource's state to disableDependency"); + if(logger.isDebugEnabled()){ + logger.debug("{}: There has been a subsystemTest failure with error:{} Updating this resource's state to disableDependency", resourceName, e.getMessage()); + } //Capture the subsystemTest failure info if(!error_msg.isEmpty()){ error_msg = error_msg.concat(","); @@ -917,7 +973,7 @@ public class IntegrityMonitor { error_msg = error_msg.concat(resourceName + ": " + e.getMessage()); this.stateManager.disableDependency(); } catch (Exception ex) { - logger.error(ex); + logger.error("IntegrityMonitor threw exception.", ex); if (!error_msg.isEmpty()) { error_msg = error_msg.concat(","); } @@ -926,7 +982,7 @@ public class IntegrityMonitor { } if (!error_msg.isEmpty()) { - logger.error("Sanity failure detected in a dependent resource: " + error_msg); + logger.error("Sanity failure detected in a dependent resource: {}", error_msg); } @@ -943,12 +999,14 @@ public class IntegrityMonitor { */ public void testTransaction() { synchronized (testTransactionLock){ - logger.debug("testTransaction called..."); + if(logger.isDebugEnabled()){ + logger.debug("testTransaction called..."); + } // start Transaction - resets transaction timer and check admin state try { startTransaction(); } catch (AdministrativeStateException | StandbyStatusException e) { - logger.debug(e); + logger.error("IntegrityMonitor threw exception.", e); } // TODO: add test functionality if needed @@ -964,7 +1022,9 @@ public class IntegrityMonitor { */ public void subsystemTest() throws IntegrityMonitorException { // Testing provided by subsystem - logger.debug("IntegrityMonitor subsystemTest() OK"); + if(logger.isDebugEnabled()){ + logger.debug("IntegrityMonitor subsystemTest() OK"); + } } /** @@ -1032,8 +1092,13 @@ public class IntegrityMonitor { fpx = (ForwardProgressEntity) fpList.get(0); // refresh the object from DB in case cached data was returned em.refresh(fpx); - logger.debug("Updating FP entry: Resource=" + resourceName + ", fpcCount=" + fpx.getFpcCount() + - ", lastUpdated=" + fpx.getLastUpdated() + ", new fpcCount=" + fpCounter); + if(logger.isDebugEnabled()){ + logger.debug("Updating FP entry: Resource={}, fpcCount={}, lastUpdated={}, new fpcCount={}", + resourceName, + fpx.getFpcCount(), + fpx.getLastUpdated(), + fpCounter); + } fpx.setFpcCount(fpCounter); em.persist(fpx); // flush to the DB and commit @@ -1054,9 +1119,9 @@ public class IntegrityMonitor { } } } catch (Exception e1) { - logger.debug(e1); + logger.error("IntegrityMonitor threw exception.", e1); } - logger.error("writeFpc DB table commit failed with exception: " + e); + logger.error("writeFpc DB table commit failed with exception: {}", e); throw e; } } @@ -1074,25 +1139,25 @@ public class IntegrityMonitor { if (prop.getProperty(IntegrityMonitorProperties.DB_DRIVER)== null){ String msg = IntegrityMonitorProperties.DB_DRIVER + " property is null"; - logger.error(msg); + logger.error("{}", msg); throw new IntegrityMonitorPropertiesException("IntegrityMonitor Property Exception: " + msg); } if (prop.getProperty(IntegrityMonitorProperties.DB_URL)== null){ String msg = IntegrityMonitorProperties.DB_URL + " property is null"; - logger.error(msg); + logger.error("{}", msg); throw new IntegrityMonitorPropertiesException("IntegrityMonitor Property Exception: " + msg); } if (prop.getProperty(IntegrityMonitorProperties.DB_USER)== null){ String msg = IntegrityMonitorProperties.DB_USER + " property is null"; - logger.error(msg); + logger.error("{}", msg); throw new IntegrityMonitorPropertiesException("IntegrityMonitor Property Exception: " + msg); } if (prop.getProperty(IntegrityMonitorProperties.DB_PWD)== null){ String msg = IntegrityMonitorProperties.DB_PWD + " property is null"; - logger.error(msg); + logger.error("{}", msg); throw new IntegrityMonitorPropertiesException("IntegrityMonitor Property Exception: " + msg); } @@ -1100,7 +1165,7 @@ public class IntegrityMonitor { try { monitorInterval = Integer.parseInt(prop.getProperty(IntegrityMonitorProperties.FP_MONITOR_INTERVAL).trim()); } catch (NumberFormatException e) { - logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.FP_MONITOR_INTERVAL); + logger.warn("Ignored invalid property: {}", IntegrityMonitorProperties.FP_MONITOR_INTERVAL, e); } } @@ -1108,7 +1173,7 @@ public class IntegrityMonitor { try { failedCounterThreshold = Integer.parseInt(prop.getProperty(IntegrityMonitorProperties.FAILED_COUNTER_THRESHOLD).trim()); } catch (NumberFormatException e) { - logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.FAILED_COUNTER_THRESHOLD); + logger.warn("Ignored invalid property: {}", IntegrityMonitorProperties.FAILED_COUNTER_THRESHOLD, e); } } @@ -1116,7 +1181,7 @@ public class IntegrityMonitor { try { testTransInterval = Integer.parseInt(prop.getProperty(IntegrityMonitorProperties.TEST_TRANS_INTERVAL).trim()); } catch (NumberFormatException e) { - logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.TEST_TRANS_INTERVAL); + logger.warn("Ignored invalid property: {}", IntegrityMonitorProperties.TEST_TRANS_INTERVAL, e); } } @@ -1124,7 +1189,7 @@ public class IntegrityMonitor { try { writeFpcInterval = Integer.parseInt(prop.getProperty(IntegrityMonitorProperties.WRITE_FPC_INTERVAL).trim()); } catch (NumberFormatException e) { - logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.WRITE_FPC_INTERVAL); + logger.warn("Ignored invalid property: {}", IntegrityMonitorProperties.WRITE_FPC_INTERVAL, e); } } @@ -1134,16 +1199,18 @@ public class IntegrityMonitor { if (prop.getProperty(IntegrityMonitorProperties.DEPENDENCY_GROUPS) != null) { try { dep_groups = prop.getProperty(IntegrityMonitorProperties.DEPENDENCY_GROUPS).split(";"); - logger.info("dependency groups property = " + Arrays.toString(dep_groups)); + if(logger.isDebugEnabled()){ + logger.debug("dependency groups property = {}", Arrays.toString(dep_groups)); + } } catch (Exception e) { - logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.DEPENDENCY_GROUPS, e); + logger.warn("Ignored invalid property: {}", IntegrityMonitorProperties.DEPENDENCY_GROUPS, e); } } site_name = prop.getProperty(IntegrityMonitorProperties.SITE_NAME); if (site_name == null) { String msg = IntegrityMonitorProperties.SITE_NAME + " property is null"; - logger.error(msg); + logger.error("{}", msg); throw new IntegrityMonitorPropertiesException("IntegrityMonitor Property Exception: " + msg); }else{ site_name = site_name.trim(); @@ -1152,13 +1219,13 @@ public class IntegrityMonitor { node_type = prop.getProperty(IntegrityMonitorProperties.NODE_TYPE); if (node_type == null) { String msg = IntegrityMonitorProperties.NODE_TYPE + " property is null"; - logger.error(msg); + logger.error("{}", msg); throw new IntegrityMonitorPropertiesException("IntegrityMonitor Property Exception: " + msg); } else { node_type = node_type.trim(); if (!isNodeTypeEnum(node_type)) { String msg = IntegrityMonitorProperties.NODE_TYPE + " property " + node_type + " is invalid"; - logger.error(msg); + logger.error("{}", msg); throw new IntegrityMonitorPropertiesException("IntegrityMonitor Property Exception: " + msg); } } @@ -1180,7 +1247,7 @@ public class IntegrityMonitor { try { maxFpcUpdateInterval = Integer.parseInt(prop.getProperty(IntegrityMonitorProperties.MAX_FPC_UPDATE_INTERVAL).trim()); } catch (NumberFormatException e) { - logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.MAX_FPC_UPDATE_INTERVAL); + logger.warn("Ignored invalid property: {}", IntegrityMonitorProperties.MAX_FPC_UPDATE_INTERVAL, e); } } @@ -1188,7 +1255,7 @@ public class IntegrityMonitor { try{ stateAuditIntervalMs = Long.parseLong(prop.getProperty(IntegrityMonitorProperties.STATE_AUDIT_INTERVAL_MS)); }catch(NumberFormatException e){ - logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.STATE_AUDIT_INTERVAL_MS); + logger.warn("Ignored invalid property: {}", IntegrityMonitorProperties.STATE_AUDIT_INTERVAL_MS, e); } } @@ -1196,7 +1263,7 @@ public class IntegrityMonitor { try{ refreshStateAuditIntervalMs = Long.parseLong(prop.getProperty(IntegrityMonitorProperties.REFRESH_STATE_AUDIT_INTERVAL_MS)); }catch(NumberFormatException e){ - logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.REFRESH_STATE_AUDIT_INTERVAL_MS); + logger.warn("Ignored invalid property: {}", IntegrityMonitorProperties.REFRESH_STATE_AUDIT_INTERVAL_MS, e); } } @@ -1208,11 +1275,13 @@ public class IntegrityMonitor { try { validateProperties(newprop); } catch (IntegrityMonitorPropertiesException e) { - logger.debug(e); + logger.error("IntegrityMonitor threw exception.", e); } } else { - logger.info("Update integrity monitor properties not allowed"); + if(logger.isDebugEnabled()){ + logger.debug("Update integrity monitor properties not allowed"); + } } } @@ -1253,7 +1322,9 @@ public class IntegrityMonitor { // no forward progress missedCycles += 1; if (missedCycles >= failedCounterThreshold && !alarmExists) { - logger.info("Forward progress not detected for resource " + resourceName + ". Setting state to disable failed."); + if(logger.isDebugEnabled()){ + logger.debug("Forward progress not detected for resource {}. Setting state to disable failed.", resourceName); + } if(!(stateManager.getOpState()).equals(StateManagement.DISABLED)){ // Note: The refreshStateAudit will make redundant calls stateManager.disableFailed(); @@ -1266,7 +1337,9 @@ public class IntegrityMonitor { lastFpCounter = fpCounter; missedCycles = 0; // set op state to enabled - logger.debug("Forward progress detected for resource " + resourceName + ". Setting state to enable not failed."); + if(logger.isDebugEnabled()){ + logger.debug("Forward progress detected for resource {}. Setting state to enable not failed.", resourceName); + } if(!(stateManager.getOpState()).equals(StateManagement.ENABLED)){ // Note: The refreshStateAudit will make redundant calls stateManager.enableNotFailed(); @@ -1324,11 +1397,15 @@ public class IntegrityMonitor { //Make sure you are not getting a cached version em.refresh(fpe); long diffMs = date.getTime() - fpe.getLastUpdated().getTime(); - logger.debug("IntegrityMonitor.stateAudit(): diffMs = " + diffMs); + if(logger.isDebugEnabled()){ + logger.debug("IntegrityMonitor.stateAudit(): diffMs = {}", diffMs); + } //Threshold for a stale entry long staleMs = maxFpcUpdateInterval * (long)1000; - logger.debug("IntegrityMonitor.stateAudit(): staleMs = " + staleMs); + if(logger.isDebugEnabled()){ + logger.debug("IntegrityMonitor.stateAudit(): staleMs = {}", staleMs); + } if(diffMs > staleMs){ //ForwardProgress is stale. Disable it @@ -1349,20 +1426,19 @@ public class IntegrityMonitor { sme = (StateManagementEntity) smList.get(0); // refresh the object from DB in case cached data was returned em.refresh(sme); - logger.debug("IntegrityMonitor.stateAudit(): Found entry in StateManagementEntity table for Resource=" + sme.getResourceName()); + if(logger.isDebugEnabled()){ + logger.debug("IntegrityMonitor.stateAudit(): Found entry in StateManagementEntity table for Resource={}", sme.getResourceName()); + } } else { String msg = "IntegrityMonitor.stateAudit(): " + fpe.getResourceName() + ": resource not found in state management entity database table"; - logger.debug(msg); - logger.error(msg); + logger.error("{}", msg); } synchronized(IMFLUSHLOCK){ et.commit(); } } catch (Exception e) { // log an error - String msg = "IntegrityMonitor.stateAudit(): " + fpe.getResourceName() + ": StateManagementEntity DB read failed with exception: "; - logger.error(msg, e); - logger.debug(msg); + logger.error("IntegrityMonitor.stateAudit(): {}: StateManagementEntity DB read failed with exception: ", fpe.getResourceName(), e); synchronized(IMFLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -1371,13 +1447,14 @@ public class IntegrityMonitor { } if(sme != null && !sme.getOpState().equals(StateManagement.DISABLED)){ - logger.debug("IntegrityMonitor.stateAudit(): Changing OpStat = disabled for " + sme.getResourceName()); + if(logger.isDebugEnabled()){ + logger.debug("IntegrityMonitor.stateAudit(): Changing OpStat = disabled for {}", sme.getResourceName()); + } try { stateManager.disableFailed(sme.getResourceName()); } catch (Exception e) { String msg = "IntegrityMonitor.stateAudit(): Failed to disable " + sme.getResourceName(); - logger.debug(msg); - logger.error(msg, e); + logger.error("{}", msg, e); } } }// end if(diffMs > staleMs) @@ -1432,7 +1509,7 @@ public class IntegrityMonitor { try { writeFpc(); } catch (Exception e) { - logger.debug(e); + logger.error("IntegrityMonitor threw exception.", e); } } } @@ -1441,10 +1518,14 @@ public class IntegrityMonitor { * Execute a dependency health check periodically which also updates this resource's state. */ private void checkDependentHealth() { - logger.debug("checkDependentHealth: entry"); + if(logger.isDebugEnabled()){ + logger.debug("checkDependentHealth: entry"); + } long currTime = System.currentTimeMillis(); - logger.debug("checkDependentHealth currTime - lastDependencyCheckTime = " + (currTime - lastDependencyCheckTime)); + if(logger.isDebugEnabled()){ + logger.debug("checkDependentHealth currTime - lastDependencyCheckTime = {}", (currTime - lastDependencyCheckTime)); + } if ((currTime - lastDependencyCheckTime) > (1000 * IntegrityMonitorProperties.DEFAULT_TEST_INTERVAL)) { // execute dependency check and update this resource's state @@ -1467,32 +1548,44 @@ public class IntegrityMonitor { return; } synchronized(refreshStateAuditLock){ - logger.debug("refreshStateAudit: entry"); + if(logger.isDebugEnabled()){ + logger.debug("refreshStateAudit: entry"); + } Date now = new Date(); long nowMs = now.getTime(); long lastTimeMs = refreshStateAuditLastRunDate.getTime(); - logger.debug("refreshStateAudit: ms since last run = " + (nowMs - lastTimeMs)); + if(logger.isDebugEnabled()){ + logger.debug("refreshStateAudit: ms since last run = {}", (nowMs - lastTimeMs)); + } if((nowMs - lastTimeMs) > refreshStateAuditIntervalMs){ String adminState = stateManager.getAdminState(); - logger.debug("refreshStateAudit: adminState = " + adminState); + if(logger.isDebugEnabled()){ + logger.debug("refreshStateAudit: adminState = {}", adminState); + } if(adminState.equals(StateManagement.LOCKED)){ try { - logger.debug("refreshStateAudit: calling lock()"); + if(logger.isDebugEnabled()){ + logger.debug("refreshStateAudit: calling lock()"); + } stateManager.lock(); } catch (Exception e) { - logger.error("refreshStateAudit: caught unexpected exception from stateManager.lock(): " + e ); + logger.error("refreshStateAudit: caught unexpected exception from stateManager.lock(): ", e); } }else{//unlocked try { - logger.debug("refreshStateAudit: calling unlock()"); + if(logger.isDebugEnabled()){ + logger.debug("refreshStateAudit: calling unlock()"); + } stateManager.unlock();; } catch (Exception e) { - logger.error("refreshStateAudit: caught unexpected exception from stateManager.unlock(): " + e ); + logger.error("refreshStateAudit: caught unexpected exception from stateManager.unlock(): ", e); } } refreshStateAuditLastRunDate = new Date(); - logger.debug("refreshStateAudit: exit"); + if(logger.isDebugEnabled()){ + logger.debug("refreshStateAudit: exit"); + } } } } @@ -1521,13 +1614,17 @@ public class IntegrityMonitor { @Override public void run() { - logger.info("FPManager thread running"); + if(logger.isDebugEnabled()){ + logger.debug("FPManager thread running"); + } while (true) { try { Thread.sleep(CYCLE_INTERVAL_MILLIS); } catch (InterruptedException e) { // The 'sleep' call was interrupted - logger.debug(e); + if(logger.isDebugEnabled()){ + logger.debug("IntegrityMonitor threw exception.", e); + } Thread.currentThread().interrupt(); continue; } @@ -1570,7 +1667,7 @@ public class IntegrityMonitor { IntegrityMonitor.this.stateAudit(); } catch (Exception e) { - logger.debug("Ignore FPManager thread processing timer(s) exception: " + e); + logger.error("Ignore FPManager thread processing timer(s) exception: ", e); } } } diff --git a/integrity-monitor/src/main/java/org/onap/policy/common/im/StateChangeNotifier.java b/integrity-monitor/src/main/java/org/onap/policy/common/im/StateChangeNotifier.java index f3f6958e..0d4bd029 100644 --- a/integrity-monitor/src/main/java/org/onap/policy/common/im/StateChangeNotifier.java +++ b/integrity-monitor/src/main/java/org/onap/policy/common/im/StateChangeNotifier.java @@ -22,6 +22,8 @@ package org.onap.policy.common.im; import java.util.Observable; import java.util.Observer; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /* * This is implementing the Observer interface to make it specific for * state management. @@ -36,8 +38,7 @@ import java.util.Observer; */ -import org.onap.policy.common.logging.flexlogger.FlexLogger; -import org.onap.policy.common.logging.flexlogger.Logger; + /** * @@ -47,7 +48,7 @@ import org.onap.policy.common.logging.flexlogger.Logger; * */ public class StateChangeNotifier implements Observer { - private static final Logger logger = FlexLogger.getLogger(StateChangeNotifier.class); + private static final Logger logger = LoggerFactory.getLogger(StateChangeNotifier.class); //The observable class StateManagement stateManagement; @@ -63,7 +64,9 @@ public class StateChangeNotifier implements Observer { } public void handleStateChange() { - logger.debug("handleStateChange, message: " + this.message); + if(logger.isDebugEnabled()){ + logger.debug("handleStateChange, message: {}", this.message); + } } public StateManagement getStateManagement() { diff --git a/integrity-monitor/src/main/java/org/onap/policy/common/im/StateElement.java b/integrity-monitor/src/main/java/org/onap/policy/common/im/StateElement.java index 7870e6a3..e38971ea 100644 --- a/integrity-monitor/src/main/java/org/onap/policy/common/im/StateElement.java +++ b/integrity-monitor/src/main/java/org/onap/policy/common/im/StateElement.java @@ -21,12 +21,12 @@ package org.onap.policy.common.im; -import org.onap.policy.common.logging.flexlogger.FlexLogger; -import org.onap.policy.common.logging.flexlogger.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class StateElement { - private static final Logger logger = FlexLogger.getLogger(StateElement.class); - + private static final Logger logger = LoggerFactory.getLogger(StateElement.class); + String adminState = null; String opState = null; String availStatus = null; @@ -144,15 +144,20 @@ public class StateElement { public void displayStateElement() { - logger.debug("adminState=[" + getAdminState() + - "], opState=[" + getOpState() + - "], availStatus=[" + getAvailStatus() + - "], standbyStatus=[" + getStandbyStatus() + - "], actionName=[" + getActionName() + - "], endingAdminState=[" + getEndingAdminState() + - "], endingOpState=[" + getEndingOpState() + - "], endingAvailStatus=[" + getEndingAvailStatus() + - "], endingStandbyStatus=[" + getEndingStandbyStatus() + - "], exception=[" + getException() + "]"); + if(logger.isDebugEnabled()){ + logger.debug("adminState=[{}], opState=[{}], availStatus=[{}], standbyStatus=[{}], " + + "actionName=[{}], endingAdminState=[{}], endingOpState=[{}], " + + "endingAvailStatus=[{}], endingStandbyStatus=[{}], exception=[{}]", + getAdminState(), + getOpState(), + getAvailStatus(), + getStandbyStatus(), + getActionName(), + getEndingAdminState(), + getEndingOpState(), + getEndingAvailStatus(), + getEndingStandbyStatus(), + getException()); + } } } 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 bcf910f7..cf78b775 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 @@ -33,9 +33,8 @@ import javax.persistence.Query; import org.onap.policy.common.im.jpa.StateManagementEntity; import org.onap.policy.common.im.StateElement; import org.onap.policy.common.im.StandbyStatusException; -import org.onap.policy.common.logging.flexlogger.FlexLogger; -import org.onap.policy.common.logging.flexlogger.Logger; - +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * * StateManagement class handles all state changes per the Telecom standard X.731. @@ -45,7 +44,7 @@ import org.onap.policy.common.logging.flexlogger.Logger; * */ public class StateManagement extends Observable { - private static final Logger logger = FlexLogger.getLogger(StateManagement.class); + 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"; @@ -101,7 +100,9 @@ public class StateManagement extends Observable { */ public StateManagement(EntityManagerFactory emf, String resourceName) throws StateManagementException { - logger.debug("StateManagement: constructor, resourceName: " + resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: constructor, resourceName: {}", resourceName); + } em = emf.createEntityManager(); EntityTransaction et = em.getTransaction(); @@ -109,17 +110,23 @@ public class StateManagement extends Observable { et.begin(); } this.resourceName = resourceName; - logger.info("resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("resourceName = {}", this.resourceName); + } try { //Create a StateManagementEntity object - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); //persist the administrative state if (sm != null) { - logger.debug("Persist adminstrative state, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("Persist adminstrative state, resourceName = {}", this.resourceName); + } em.persist(sm); synchronized(FLUSHLOCK){ et.commit(); @@ -133,15 +140,17 @@ public class StateManagement extends Observable { //Load the StateTransition hash table st = new StateTransition(); - logger.debug("StateManagement: constructor end, resourceName: " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: constructor end, resourceName: {}", this.resourceName); + } } catch(Exception ex) { - logger.error("StateManagement: constructor caught unexpected exception: " + ex); + logger.error("StateManagement: constructor caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); } } - throw new StateManagementException("StateManagement: Exception: " + ex.toString()); + throw new StateManagementException("StateManagement: Exception: " + ex.toString(), ex); } } @@ -154,8 +163,12 @@ public class StateManagement extends Observable { public void initializeState() throws StateManagementException { synchronized (SYNCLOCK){ - logger.debug("\nStateManagement: SYNCLOCK initializeState() operation for resourceName = " + this.resourceName + "\n"); - logger.debug("StateManagement: initializeState() operation started, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK initializeState() operation for resourceName = {}\n", this.resourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: initializeState() operation started, resourceName = {}", this.resourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ @@ -163,7 +176,9 @@ public class StateManagement extends Observable { } try { - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); // set state sm.setAdminState(sm.getAdminState()); //preserve the Admin state @@ -178,9 +193,11 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(ADMIN_STATE); - logger.debug("StateManagement: initializeState() operation completed, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: initializeState() operation completed, resourceName = {}", this.resourceName); + } } catch(Exception ex) { - logger.error("StateManagement.initializeState() caught unexpected exception: " + ex); + logger.error("StateManagement.initializeState() caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -198,8 +215,12 @@ public class StateManagement extends Observable { public void lock() throws StateManagementException { synchronized (SYNCLOCK){ - logger.debug("\nStateManagement: SYNCLOCK lock() operation for resourceName = " + this.resourceName + "\n"); - logger.debug("StateManagement: lock() operation started, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK lock() operation for resourceName = {}\n", this.resourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: lock() operation started, resourceName = {}", this.resourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ @@ -207,7 +228,9 @@ public class StateManagement extends Observable { } try { - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), @@ -225,9 +248,11 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(ADMIN_STATE); - logger.debug("StateManagement: lock() operation completed, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: lock() operation completed, resourceName = {}", this.resourceName); + } } catch(Exception ex) { - logger.error("StateManagement.lock() caught unexpected exception: " + ex); + logger.error("StateManagement.lock() caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -245,8 +270,12 @@ public class StateManagement extends Observable { public void unlock() throws StateManagementException { synchronized (SYNCLOCK){ - logger.debug("\nStateManagement: SYNCLOCK unlock() operation for resourceName = " + this.resourceName + "\n"); - logger.debug("StateManagement: unlock() operation started, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK unlock() operation for resourceName = {}\n", this.resourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: unlock() operation started, resourceName = {}", this.resourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ @@ -254,7 +283,9 @@ public class StateManagement extends Observable { } try { - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), sm.getAvailStatus(), sm.getStandbyStatus(), UNLOCK); @@ -271,9 +302,11 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(ADMIN_STATE); - logger.debug("StateManagement: unlock() operation completed, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: unlock() operation completed, resourceName = {}", this.resourceName); + } } catch(Exception ex) { - logger.error("StateManagement.unlock() caught unexpected exception: " + ex); + logger.error("StateManagement.unlock() caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -292,8 +325,12 @@ public class StateManagement extends Observable { public void enableNotFailed() throws StateManagementException { synchronized (SYNCLOCK){ - logger.debug("\nStateManagement: SYNCLOCK enabledNotFailed() operation for resourceName = " + this.resourceName + "\n"); - logger.debug("StateManagement: enableNotFailed() operation started, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK enabledNotFailed() operation for resourceName = {}\n", this.resourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: enableNotFailed() operation started, resourceName = {}", this.resourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ @@ -301,7 +338,9 @@ public class StateManagement extends Observable { } try { - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), sm.getAvailStatus(), sm.getStandbyStatus(), ENABLE_NOT_FAILED); @@ -318,9 +357,11 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(OPERATION_STATE); - logger.debug("StateManagement enableNotFailed() operation completed, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement enableNotFailed() operation completed, resourceName = {}", this.resourceName); + } } catch(Exception ex) { - logger.error("StateManagement.enableNotFailed() caught unexpected exception: " + ex); + logger.error("StateManagement.enableNotFailed() caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -338,15 +379,21 @@ public class StateManagement extends Observable { public void disableFailed() throws StateManagementException { synchronized (SYNCLOCK){ - logger.debug("\nStateManagement: SYNCLOCK disabledFailed() operation for resourceName = " + this.resourceName + "\n"); - logger.debug("StateManagement: disableFailed() operation started, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK disabledFailed() operation for resourceName = {}\n", this.resourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: disableFailed() operation started, resourceName = {}", this.resourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ et.begin(); } try { - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), sm.getAvailStatus(), sm.getStandbyStatus(), DISABLE_FAILED); @@ -363,9 +410,11 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(OPERATION_STATE); - logger.debug("StateManagement: disableFailed() operation completed, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: disableFailed() operation completed, resourceName = {}", this.resourceName); + } } catch(Exception ex) { - logger.error("StateManagement.disableFailed() caught unexpected exception: " + ex); + logger.error("StateManagement.disableFailed() caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -387,17 +436,23 @@ public class StateManagement extends Observable { logger.error("\nStateManagement: SYNCLOCK disableFailed(otherResourceName) operation: resourceName is NULL.\n"); return; } - logger.debug("\nStateManagement: SYNCLOCK disabledFailed(otherResourceName) operation for resourceName = " - + otherResourceName + "\n"); - logger.debug("StateManagement: disableFailed(otherResourceName) operation started, resourceName = " - + otherResourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK disabledFailed(otherResourceName) operation for resourceName = {}\n", + otherResourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: disableFailed(otherResourceName) operation started, resourceName = {}", + otherResourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ et.begin(); } try { - logger.debug("findStateManagementEntity for " + otherResourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for " + otherResourceName); + } StateManagementEntity sm = findStateManagementEntity(em, otherResourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), sm.getAvailStatus(), sm.getStandbyStatus(), DISABLE_FAILED); @@ -414,10 +469,12 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(OPERATION_STATE); - logger.debug("StateManagement: disableFailed(otherResourceName) operation completed, resourceName = " - + otherResourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: disableFailed(otherResourceName) operation completed, resourceName = {}", + otherResourceName); + } } catch(Exception ex) { - logger.error("StateManagement.disableFailed(otherResourceName) caught unexpected exception: " + ex); + logger.error("StateManagement.disableFailed(otherResourceName) caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -435,8 +492,12 @@ public class StateManagement extends Observable { public void disableDependency() throws StateManagementException { synchronized (SYNCLOCK){ - logger.debug("\nStateManagement: SYNCLOCK disableDependency() operation for resourceName = " + this.resourceName + "\n"); - logger.debug("StateManagement: disableDependency() operation started, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK disableDependency() operation for resourceName = {}\n", this.resourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: disableDependency() operation started, resourceName = {}", this.resourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ @@ -444,7 +505,9 @@ public class StateManagement extends Observable { } try { - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), sm.getAvailStatus(), sm.getStandbyStatus(), DISABLE_DEPENDENCY); @@ -461,9 +524,11 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(OPERATION_STATE); - logger.debug("StateManagement: disableDependency() operation completed, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: disableDependency() operation completed, resourceName = {}", this.resourceName); + } } catch(Exception ex) { - logger.error("StateManagement.disableDependency() caught unexpected exception: " + ex); + logger.error("StateManagement.disableDependency() caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -482,8 +547,12 @@ public class StateManagement extends Observable { public void enableNoDependency() throws StateManagementException { synchronized (SYNCLOCK){ - logger.debug("\nStateManagement: SYNCLOCK enableNoDependency() operation for resourceName = " + this.resourceName + "\n"); - logger.debug("StateManagement: enableNoDependency() operation started, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK enableNoDependency() operation for resourceName = {}\n", this.resourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: enableNoDependency() operation started, resourceName = {}", this.resourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ @@ -491,7 +560,9 @@ public class StateManagement extends Observable { } try { - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), sm.getAvailStatus(), sm.getStandbyStatus(), ENABLE_NO_DEPENDENCY); @@ -508,9 +579,11 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(OPERATION_STATE); - logger.debug("StateManagement: enableNoDependency() operation completed, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: enableNoDependency() operation completed, resourceName = {}", this.resourceName); + } } catch(Exception ex) { - logger.error("StateManagement.enableNoDependency() caught unexpected exception: " + ex); + logger.error("StateManagement.enableNoDependency() caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -529,8 +602,12 @@ public class StateManagement extends Observable { public void promote() throws StandbyStatusException, StateManagementException { synchronized (SYNCLOCK){ - logger.debug("\nStateManagement: SYNCLOCK promote() operation for resourceName = " + this.resourceName + "\n"); - logger.debug("StateManagement: promote() operation started, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK promote() operation for resourceName = {}\n", this.resourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: promote() operation started, resourceName = {}", this.resourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ @@ -540,7 +617,9 @@ public class StateManagement extends Observable { StateManagementEntity sm; try{ - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } sm = findStateManagementEntity(em, this.resourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), sm.getAvailStatus(), sm.getStandbyStatus(), PROMOTE); @@ -559,7 +638,7 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(STANDBY_STATUS); }catch(Exception ex){ - logger.error("StateManagement.promote() caught unexpected exception: " + ex); + logger.error("StateManagement.promote() caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -568,7 +647,9 @@ public class StateManagement extends Observable { throw new StateManagementException("StateManagement.promote() Exception: " + ex); } - logger.debug("StateManagement: promote() operation completed, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: promote() operation completed, resourceName = ", this.resourceName); + } if (sm.getStandbyStatus().equals(StateManagement.COLD_STANDBY)){ String msg = "Failure to promote " + this.resourceName + " StandbyStatus = " + StateManagement.COLD_STANDBY; throw new StandbyStatusException(msg); @@ -583,8 +664,12 @@ public class StateManagement extends Observable { public void demote() throws StateManagementException { synchronized (SYNCLOCK){ - logger.debug("\nStateManagement: SYNCLOCK demote() operation for resourceName = " + this.resourceName + "\n"); - logger.debug("StateManagement: demote() operation started, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK demote() operation for resourceName = \n", this.resourceName); + } + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: demote() operation started, resourceName = {}", this.resourceName); + } EntityTransaction et = em.getTransaction(); if(!et.isActive()){ @@ -592,7 +677,9 @@ public class StateManagement extends Observable { } try { - logger.debug("findStateManagementEntity for " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("findStateManagementEntity for {}", this.resourceName); + } StateManagementEntity sm = findStateManagementEntity(em, this.resourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), sm.getAvailStatus(), sm.getStandbyStatus(), DEMOTE); @@ -609,9 +696,11 @@ public class StateManagement extends Observable { setChanged(); notifyObservers(STANDBY_STATUS); - logger.debug("StateManagement: demote() operation completed, resourceName = " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: demote() operation completed, resourceName = {}", this.resourceName); + } } catch(Exception ex) { - logger.error("StateManagement.demote() caught unexpected exception: " + ex); + logger.error("StateManagement.demote() caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -638,7 +727,9 @@ public class StateManagement extends Observable { logger.error("\nStateManagement: SYNCLOCK demote(otherResourceName) operation: resourceName is NULL.\n"); return; } - logger.debug("\nStateManagement: SYNCLOCK demote(otherResourceName) operation for resourceName = " + otherResourceName + "\n"); + if(logger.isDebugEnabled()){ + logger.debug("\nStateManagement: SYNCLOCK demote(otherResourceName) operation for resourceName = {}\n", otherResourceName); + } EntityTransaction et = em.getTransaction(); @@ -647,7 +738,9 @@ public class StateManagement extends Observable { } try { - logger.debug("StateManagement: SYNCLOCK demote(otherResourceName) findStateManagementEntity for " + otherResourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: SYNCLOCK demote(otherResourceName) findStateManagementEntity for {}", otherResourceName); + } StateManagementEntity sm = findStateManagementEntity(em, otherResourceName); StateElement stateElement = st.getEndingState(sm.getAdminState(), sm.getOpState(), sm.getAvailStatus(), sm.getStandbyStatus(), DEMOTE); @@ -663,9 +756,11 @@ public class StateManagement extends Observable { } //We don't notify observers because this is assumed to be a remote resource - logger.debug("StateManagement: demote(otherResourceName) operation completed, resourceName = " + otherResourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: demote(otherResourceName) operation completed, resourceName = {}", otherResourceName); + } } catch(Exception ex) { - logger.error("StateManagement.demote(otherResourceName) caught unexpected exception: " + ex); + logger.error("StateManagement.demote(otherResourceName) caught unexpected exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -681,7 +776,9 @@ public class StateManagement extends Observable { */ public String getAdminState() { - logger.debug("StateManagement(6/1/16): getAdminState for resourceName " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement(6/1/16): getAdminState for resourceName {}", this.resourceName); + } try { Query query = em.createQuery("Select p from StateManagementEntity p where p.resourceName=:resource"); @@ -701,7 +798,7 @@ public String getAdminState() this.adminState = null; } } catch(Exception ex) { - logger.error("StateManagement: getAdminState exception: " + ex); + logger.error("StateManagement: getAdminState exception: {}", ex.toString(), ex); } return this.adminState; @@ -712,7 +809,9 @@ public String getAdminState() */ public String getOpState() { - logger.debug("StateManagement(6/1/16): getOpState for resourceName " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement(6/1/16): getOpState for resourceName {}", this.resourceName); + } try { Query query = em.createQuery("Select p from StateManagementEntity p where p.resourceName=:resource"); @@ -732,7 +831,7 @@ public String getOpState() this.opState = null; } } catch(Exception ex) { - logger.error("StateManagement: getOpState exception: " + ex); + logger.error("StateManagement: getOpState exception: {}", ex.toString(), ex); } return this.opState; @@ -743,7 +842,9 @@ public String getOpState() */ public String getAvailStatus() { - logger.debug("StateManagement(6/1/16): getAvailStatus for resourceName " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement(6/1/16): getAvailStatus for resourceName {}", this.resourceName); + } try { Query query = em.createQuery("Select p from StateManagementEntity p where p.resourceName=:resource"); @@ -763,7 +864,7 @@ public String getOpState() this.availStatus = null; } } catch(Exception ex) { - logger.error("StateManagement: getAvailStatus exception: ", ex); + logger.error("StateManagement: getAvailStatus exception: {}", ex.toString(), ex); } return this.availStatus; @@ -774,7 +875,9 @@ public String getOpState() */ public String getStandbyStatus() { - logger.debug("StateManagement(6/1/16): getStandbyStatus for resourceName " + this.resourceName); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement(6/1/16): getStandbyStatus for resourceName {}", this.resourceName); + } try { Query query = em.createQuery("Select p from StateManagementEntity p where p.resourceName=:resource"); @@ -794,7 +897,7 @@ public String getOpState() this.standbyStatus = null; } } catch(Exception ex) { - logger.error("StateManagement: getStandbyStatus exception: " + ex); + logger.error("StateManagement: getStandbyStatus exception: {}", ex.toString(), ex); } return this.standbyStatus; @@ -808,7 +911,9 @@ public String getOpState() */ private static StateManagementEntity findStateManagementEntity(EntityManager em, String otherResourceName) { - logger.debug("StateManagementEntity: findStateManagementEntity: Entry"); + if(logger.isDebugEnabled()){ + logger.debug("StateManagementEntity: findStateManagementEntity: Entry"); + } StateManagementEntity stateManagementEntity = null; try { Query query = em.createQuery("Select p from StateManagementEntity p where p.resourceName=:resource"); @@ -835,7 +940,7 @@ public String getOpState() stateManagementEntity.setStandbyStatus(NULL_VALUE); // default } } catch(Exception ex) { - logger.error("findStateManagementEntity exception: " + ex); + logger.error("findStateManagementEntity exception: {}", ex.toString(), ex); } return stateManagementEntity; } @@ -848,8 +953,7 @@ public String getOpState() public String getStandbyStatus(String otherResourceName) { if (logger.isDebugEnabled()) { - logger.debug("StateManagement: getStandbyStatus: Entering, resourceName='" - + otherResourceName + "'"); + logger.debug("StateManagement: getStandbyStatus: Entering, resourceName='{}'", otherResourceName); } String tempStandbyStatus = null; @@ -874,19 +978,16 @@ public String getOpState() em.refresh(stateManagementEntity); tempStandbyStatus = stateManagementEntity.getStandbyStatus(); if (logger.isDebugEnabled()) { - logger.debug("getStandbyStatus: resourceName =" + otherResourceName - + " has standbyStatus=" + tempStandbyStatus); + logger.debug("getStandbyStatus: resourceName ={} has standbyStatus={}", otherResourceName, tempStandbyStatus); } } else { - logger.error("getStandbyStatus: resourceName =" + otherResourceName - + " not found in statemanagemententity table"); + logger.error("getStandbyStatus: resourceName ={} not found in statemanagemententity table", otherResourceName); } synchronized(FLUSHLOCK){ et.commit(); } } catch (Exception e) { - logger.error("getStandbyStatus: Caught Exception attempting to get statemanagemententity record, message='" - + e.getMessage() + "'", e); + logger.error("getStandbyStatus: Caught Exception attempting to get statemanagemententity record, message='{}'", e.getMessage(), e); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -894,8 +995,7 @@ public String getOpState() } } if (logger.isDebugEnabled()) { - logger.debug("getStandbyStatus: Returning standbyStatus=" - + tempStandbyStatus); + logger.debug("getStandbyStatus: Returning standbyStatus={}", tempStandbyStatus); } return tempStandbyStatus; @@ -906,7 +1006,9 @@ public String getOpState() */ public void deleteAllStateManagementEntities() { - logger.info("StateManagement: deleteAllStateManagementEntities: Entering"); + if(logger.isDebugEnabled()){ + logger.debug("StateManagement: deleteAllStateManagementEntities: Entering"); + } /* * Start transaction @@ -922,20 +1024,22 @@ public String getOpState() @SuppressWarnings("unchecked") List<StateManagementEntity> stateManagementEntityList = stateManagementEntityListQuery.setLockMode( LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList(); - logger.info("deleteAllStateManagementEntities: Deleting " - + stateManagementEntityList.size() - + " StateManagementEntity records"); + if(logger.isDebugEnabled()){ + logger.debug("deleteAllStateManagementEntities: Deleting {} StateManagementEntity records", stateManagementEntityList.size()); + } for (StateManagementEntity stateManagementEntity : stateManagementEntityList) { - logger.info("deleteAllStateManagementEntities: Deleting statemanagemententity with resourceName=" - + stateManagementEntity.getResourceName() + " and standbyStatus=" - + stateManagementEntity.getStandbyStatus()); + if(logger.isDebugEnabled()){ + logger.debug("deleteAllStateManagementEntities: Deleting statemanagemententity with resourceName={} and standbyStatus={}", + stateManagementEntity.getResourceName(), + stateManagementEntity.getStandbyStatus()); + } em.remove(stateManagementEntity); } synchronized(FLUSHLOCK){ et.commit(); } }catch(Exception ex){ - logger.error("StateManagement.deleteAllStateManagementEntities() caught Exception: " + ex); + logger.error("StateManagement.deleteAllStateManagementEntities() caught Exception: ", ex); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -943,7 +1047,7 @@ public String getOpState() } } if(logger.isDebugEnabled()){ - logger.info("deleteAllStateManagementEntities: Exiting"); + logger.debug("deleteAllStateManagementEntities: Exiting"); } } diff --git a/integrity-monitor/src/main/java/org/onap/policy/common/im/StateTransition.java b/integrity-monitor/src/main/java/org/onap/policy/common/im/StateTransition.java index 03f6f4e3..3f690187 100644 --- a/integrity-monitor/src/main/java/org/onap/policy/common/im/StateTransition.java +++ b/integrity-monitor/src/main/java/org/onap/policy/common/im/StateTransition.java @@ -24,15 +24,15 @@ import java.util.*; import org.onap.policy.common.im.StateElement; -import org.onap.policy.common.im.StateManagement; -import org.onap.policy.common.logging.flexlogger.FlexLogger; -import org.onap.policy.common.logging.flexlogger.Logger; +import org.onap.policy.common.im.StateManagement; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * The StateTransition class coordinates all state transitions. */ public class StateTransition { - private static final Logger logger = FlexLogger.getLogger(StateTransition.class); + private static final Logger logger = LoggerFactory.getLogger(StateTransition.class); public static final String ADMIN_STATE = "adminState"; public static final String OPERATION_STATE = "opState"; @@ -48,14 +48,18 @@ public class StateTransition { */ public StateTransition() throws StateTransitionException { - logger.debug("StateTransition constructor"); + if(logger.isDebugEnabled()){ + logger.debug("StateTransition constructor"); + } try { - logger.debug("Load StateTable started"); + if(logger.isDebugEnabled()){ + logger.debug("Load StateTable started"); + } setupStateTable(); } catch(Exception ex) { - logger.debug(ex); + logger.error("StateTransition threw exception.", ex); throw new StateTransitionException("StateTransition Exception: " + ex.toString()); } } @@ -73,9 +77,17 @@ public class StateTransition { public StateElement getEndingState(String adminState, String opState, String availStatus, String standbyStatus, String actionName) throws StateTransitionException { - logger.info("getEndingState"); - logger.info("adminState=[" + adminState + "], opState=[" + opState + "], availStatus=[" + - availStatus + "], standbyStatus=[" + standbyStatus + "], actionName=[" + actionName + "]"); + if(logger.isDebugEnabled()){ + logger.debug("getEndingState"); + } + if(logger.isDebugEnabled()){ + logger.debug("adminState=[{}], opState=[{}], availStatus=[{}], standbyStatus=[{}], actionName[{}]", + adminState, + opState, + availStatus, + standbyStatus, + actionName); + } if(availStatus==null){ availStatus="null"; } @@ -124,7 +136,9 @@ public class StateTransition { availStatus2 = availStatus.replace(",", "."); } String key = adminState + "," + opState + "," + availStatus2 + "," + standbyStatus + "," + actionName; - logger.debug("Ending State search key: " + key); + if(logger.isDebugEnabled()){ + logger.debug("Ending State search key: {}", key); + } String value = StateTable.get(key); if (value != null) { @@ -143,17 +157,17 @@ public class StateTransition { stateElement.displayStateElement(); } catch(Exception ex) { - logger.error("String split exception: " + ex); + logger.error("String split exception: {}", ex.toString(), ex); } } else { String msg = "Ending state not found, adminState=[" + adminState + "], opState=[" + opState + "], availStatus=[" + availStatus + "], standbyStatus=[" + standbyStatus + "], actionName=[" + actionName + "]"; - logger.error(msg); + logger.error("{}", msg); throw new StateTransitionException(msg); } } catch (Exception ex) { - logger.debug(ex); + logger.error("StateTransition threw exception.", ex); throw new StateTransitionException("Exception: " + ex.toString() + ", adminState=[" + adminState + "], opState=[" + opState + "], availStatus=[" + availStatus + "], standbyStatus=[" + standbyStatus + "], actionName=[" + actionName + "]"); } @@ -720,7 +734,10 @@ public class StateTransition { while(iter.hasNext()) { Map.Entry<?, ?> me = (Map.Entry<?, ?>)iter.next(); - logger.debug((String)me.getKey() + ((String)me.getValue()).replace(".", ",")); + String key = (String)me.getKey() + ((String)me.getValue()).replace(".", ","); + if(logger.isDebugEnabled()){ + logger.debug("{}", key); + } } } } diff --git a/integrity-monitor/src/main/java/org/onap/policy/common/im/jmx/ComponentAdmin.java b/integrity-monitor/src/main/java/org/onap/policy/common/im/jmx/ComponentAdmin.java index 8ffb1b74..c9b1c1df 100644 --- a/integrity-monitor/src/main/java/org/onap/policy/common/im/jmx/ComponentAdmin.java +++ b/integrity-monitor/src/main/java/org/onap/policy/common/im/jmx/ComponentAdmin.java @@ -32,7 +32,8 @@ import javax.management.MalformedObjectNameException; import javax.management.NotCompliantMBeanException; import javax.management.ObjectName; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.onap.policy.common.im.IntegrityMonitor; import org.onap.policy.common.im.StateManagement; @@ -41,7 +42,7 @@ import org.onap.policy.common.im.StateManagement; * Base class for component MBeans. */ public class ComponentAdmin implements ComponentAdminMBean { - private static final Logger logger = Logger.getLogger(ComponentAdmin.class.getName()); + private static final Logger logger = LoggerFactory.getLogger(ComponentAdmin.class.getName()); private final String name; private MBeanServer registeredMBeanServer; @@ -69,7 +70,9 @@ public class ComponentAdmin implements ComponentAdminMBean { try { register(); } catch (Exception e) { - logger.info("Failed to register ComponentAdmin MBean"); + if(logger.isDebugEnabled()){ + logger.debug("Failed to register ComponentAdmin MBean"); + } throw e; } } @@ -87,7 +90,9 @@ public class ComponentAdmin implements ComponentAdminMBean { InstanceAlreadyExistsException, NotCompliantMBeanException { - logger.info("Registering " + name + " MBean"); + if(logger.isDebugEnabled()){ + logger.debug("Registering {} MBean", name); + } MBeanServer mbeanServer = findMBeanServer(); @@ -99,8 +104,9 @@ public class ComponentAdmin implements ComponentAdminMBean { ObjectName objectName = new ObjectName(name); if (mbeanServer.isRegistered(objectName)) { - logger.info("Unregistering a previously registered " - + name + " MBean"); + if(logger.isDebugEnabled()){ + logger.debug("Unregistering a previously registered {} MBean", name); + } mbeanServer.unregisterMBean(objectName); } @@ -186,7 +192,9 @@ public class ComponentAdmin implements ComponentAdminMBean { @Override public void test() throws Exception { // Call evaluateSanity on IntegrityMonitor to run the test - logger.info("test() called..."); + if(logger.isDebugEnabled()){ + logger.debug("test() called..."); + } if (integrityMonitor != null) { integrityMonitor.evaluateSanity(); } @@ -199,7 +207,9 @@ public class ComponentAdmin implements ComponentAdminMBean { @Override public void lock() throws Exception { - logger.info("lock() called..."); + if(logger.isDebugEnabled()){ + logger.debug("lock() called..."); + } if (stateManager != null) { stateManager.lock(); } @@ -211,7 +221,9 @@ public class ComponentAdmin implements ComponentAdminMBean { @Override public void unlock() throws Exception { - logger.info("unlock() called..."); + if(logger.isDebugEnabled()){ + logger.debug("unlock() called..."); + } if (stateManager != null) { stateManager.unlock(); } |