diff options
Diffstat (limited to 'integrity-monitor/src/main')
4 files changed, 33 insertions, 43 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 ce042541..fef4b897 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 @@ -549,8 +549,8 @@ public class IntegrityMonitor { } catch (Exception e) { String msg = "IntegrityMonitor.stateCheck(): Failed to diableFail dependent resource = " + dep + "; " + e.getMessage(); - logger.debug(msg); - logger.error(msg); + logger.debug(msg, e); + logger.error(msg, e); } } } @@ -844,6 +844,7 @@ public class IntegrityMonitor { this.stateManager.disableDependency(); } } catch (Exception e) { + logger.error(e); if (!error_msg.isEmpty()) { error_msg = error_msg.concat(","); } @@ -867,6 +868,7 @@ public class IntegrityMonitor { this.stateManager.enableNoDependency(); } // The refreshStateAudit will catch the case where it is disabled but availStatus != failed } catch (Exception e) { + logger.error(e); if (!error_msg.isEmpty()) { error_msg = error_msg.concat(","); } @@ -887,6 +889,7 @@ public class IntegrityMonitor { this.stateManager.enableNoDependency(); }// The refreshStateAudit will catch the case where it is disabled but availStatus != failed } catch (Exception e) { + logger.error(e); if (!error_msg.isEmpty()) { error_msg = error_msg.concat(","); } @@ -913,6 +916,7 @@ public class IntegrityMonitor { error_msg = error_msg.concat(resourceName + ": " + e.getMessage()); this.stateManager.disableDependency(); } catch (Exception ex) { + logger.error(ex); if (!error_msg.isEmpty()) { error_msg = error_msg.concat(","); } @@ -943,7 +947,7 @@ public class IntegrityMonitor { try { startTransaction(); } catch (AdministrativeStateException | StandbyStatusException e) { - // ignore + logger.debug(e); } // TODO: add test functionality if needed @@ -1049,7 +1053,7 @@ public class IntegrityMonitor { } } } catch (Exception e1) { - // ignore + logger.debug(e1); } logger.error("writeFpc DB table commit failed with exception: " + e); throw e; @@ -1131,7 +1135,7 @@ public class IntegrityMonitor { dep_groups = prop.getProperty(IntegrityMonitorProperties.DEPENDENCY_GROUPS).split(";"); logger.info("dependency groups property = " + Arrays.toString(dep_groups)); } catch (Exception e) { - logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.DEPENDENCY_GROUPS); + logger.warn("Ignored invalid property: " + IntegrityMonitorProperties.DEPENDENCY_GROUPS, e); } } @@ -1203,7 +1207,7 @@ public class IntegrityMonitor { try { validateProperties(newprop); } catch (IntegrityMonitorPropertiesException e) { - // ignore + logger.debug(e); } } else { @@ -1355,9 +1359,9 @@ public class IntegrityMonitor { } } catch (Exception e) { // log an error - String msg = "IntegrityMonitor.stateAudit(): " + fpe.getResourceName() + ": StateManagementEntity DB read failed with exception: " + e; + String msg = "IntegrityMonitor.stateAudit(): " + fpe.getResourceName() + ": StateManagementEntity DB read failed with exception: "; + logger.error(msg, e); logger.debug(msg); - logger.error(msg); synchronized(IMFLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -1372,7 +1376,7 @@ public class IntegrityMonitor { } catch (Exception e) { String msg = "IntegrityMonitor.stateAudit(): Failed to disable " + sme.getResourceName(); logger.debug(msg); - logger.error(msg); + logger.error(msg, e); } } }// end if(diffMs > staleMs) @@ -1427,7 +1431,7 @@ public class IntegrityMonitor { try { writeFpc(); } catch (Exception e) { - // ignore + logger.debug(e); } } } @@ -1477,9 +1481,6 @@ public class IntegrityMonitor { stateManager.lock(); } catch (Exception e) { logger.error("refreshStateAudit: caught unexpected exception from stateManager.lock(): " + e ); - System.out.println(new Date() + " refreshStateAudit: caught unexpected exception " - + "from stateManager.lock()"); - e.printStackTrace(); } }else{//unlocked try { @@ -1487,9 +1488,6 @@ public class IntegrityMonitor { stateManager.unlock();; } catch (Exception e) { logger.error("refreshStateAudit: caught unexpected exception from stateManager.unlock(): " + e ); - System.out.println(new Date() + " refreshStateAudit: caught unexpected exception " - + "from stateManager.unlock()"); - e.printStackTrace(); } } refreshStateAuditLastRunDate = new Date(); @@ -1528,6 +1526,8 @@ public class IntegrityMonitor { Thread.sleep(CYCLE_INTERVAL_MILLIS); } catch (InterruptedException e) { // The 'sleep' call was interrupted + logger.debug(e); + Thread.currentThread().interrupt(); continue; } 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 d8e0f693..bcf910f7 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 @@ -136,7 +136,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement: constructor end, resourceName: " + this.resourceName); } catch(Exception ex) { logger.error("StateManagement: constructor caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -182,7 +181,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement: initializeState() operation completed, resourceName = " + this.resourceName); } catch(Exception ex) { logger.error("StateManagement.initializeState() caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -230,7 +228,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement: lock() operation completed, resourceName = " + this.resourceName); } catch(Exception ex) { logger.error("StateManagement.lock() caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -277,7 +274,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement: unlock() operation completed, resourceName = " + this.resourceName); } catch(Exception ex) { logger.error("StateManagement.unlock() caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -325,7 +321,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement enableNotFailed() operation completed, resourceName = " + this.resourceName); } catch(Exception ex) { logger.error("StateManagement.enableNotFailed() caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -371,7 +366,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement: disableFailed() operation completed, resourceName = " + this.resourceName); } catch(Exception ex) { logger.error("StateManagement.disableFailed() caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -424,7 +418,6 @@ public class StateManagement extends Observable { + otherResourceName); } catch(Exception ex) { logger.error("StateManagement.disableFailed(otherResourceName) caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -471,7 +464,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement: disableDependency() operation completed, resourceName = " + this.resourceName); } catch(Exception ex) { logger.error("StateManagement.disableDependency() caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -519,7 +511,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement: enableNoDependency() operation completed, resourceName = " + this.resourceName); } catch(Exception ex) { logger.error("StateManagement.enableNoDependency() caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -569,7 +560,6 @@ public class StateManagement extends Observable { notifyObservers(STANDBY_STATUS); }catch(Exception ex){ logger.error("StateManagement.promote() caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -622,7 +612,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement: demote() operation completed, resourceName = " + this.resourceName); } catch(Exception ex) { logger.error("StateManagement.demote() caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -677,7 +666,6 @@ public class StateManagement extends Observable { logger.debug("StateManagement: demote(otherResourceName) operation completed, resourceName = " + otherResourceName); } catch(Exception ex) { logger.error("StateManagement.demote(otherResourceName) caught unexpected exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -713,8 +701,7 @@ public String getAdminState() this.adminState = null; } } catch(Exception ex) { - ex.printStackTrace(); - logger.error("StateManagement: getAdminState exception: " + ex.toString()); + logger.error("StateManagement: getAdminState exception: " + ex); } return this.adminState; @@ -745,8 +732,7 @@ public String getOpState() this.opState = null; } } catch(Exception ex) { - ex.printStackTrace(); - logger.error("StateManagement: getOpState exception: " + ex.toString()); + logger.error("StateManagement: getOpState exception: " + ex); } return this.opState; @@ -777,8 +763,7 @@ public String getOpState() this.availStatus = null; } } catch(Exception ex) { - ex.printStackTrace(); - logger.error("StateManagement: getAvailStatus exception: " + ex.toString()); + logger.error("StateManagement: getAvailStatus exception: ", ex); } return this.availStatus; @@ -809,8 +794,7 @@ public String getOpState() this.standbyStatus = null; } } catch(Exception ex) { - ex.printStackTrace(); - logger.error("StateManagement: getStandbyStatus exception: " + ex.toString()); + logger.error("StateManagement: getStandbyStatus exception: " + ex); } return this.standbyStatus; @@ -851,8 +835,7 @@ public String getOpState() stateManagementEntity.setStandbyStatus(NULL_VALUE); // default } } catch(Exception ex) { - ex.printStackTrace(); - logger.error("findStateManagementEntity exception: " + ex.toString()); + logger.error("findStateManagementEntity exception: " + ex); } return stateManagementEntity; } @@ -903,8 +886,7 @@ public String getOpState() } } catch (Exception e) { logger.error("getStandbyStatus: Caught Exception attempting to get statemanagemententity record, message='" - + e.getMessage() + "'"); - e.printStackTrace(); + + e.getMessage() + "'", e); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); @@ -954,7 +936,6 @@ public String getOpState() } }catch(Exception ex){ logger.error("StateManagement.deleteAllStateManagementEntities() caught Exception: " + ex); - ex.printStackTrace(); synchronized(FLUSHLOCK){ if(et.isActive()){ et.rollback(); 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 a45a536b..03f6f4e3 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 @@ -55,6 +55,7 @@ public class StateTransition { setupStateTable(); } catch(Exception ex) { + logger.debug(ex); throw new StateTransitionException("StateTransition Exception: " + ex.toString()); } } @@ -142,7 +143,7 @@ public class StateTransition { stateElement.displayStateElement(); } catch(Exception ex) { - logger.error("String split exception: " + ex.toString()); + logger.error("String split exception: " + ex); } } else { @@ -152,6 +153,7 @@ public class StateTransition { throw new StateTransitionException(msg); } } catch (Exception ex) { + logger.debug(ex); throw new StateTransitionException("Exception: " + ex.toString() + ", adminState=[" + adminState + "], opState=[" + opState + "], availStatus=[" + availStatus + "], standbyStatus=[" + standbyStatus + "], actionName=[" + actionName + "]"); } diff --git a/integrity-monitor/src/main/java/org/onap/policy/common/im/jmx/JmxAgentConnection.java b/integrity-monitor/src/main/java/org/onap/policy/common/im/jmx/JmxAgentConnection.java index 9b9bc48c..091f2d57 100644 --- a/integrity-monitor/src/main/java/org/onap/policy/common/im/jmx/JmxAgentConnection.java +++ b/integrity-monitor/src/main/java/org/onap/policy/common/im/jmx/JmxAgentConnection.java @@ -26,6 +26,7 @@ package org.onap.policy.common.im.jmx; import java.io.IOException; import java.util.HashMap; import java.util.Map; + import javax.management.MBeanServerConnection; import javax.management.Notification; import javax.management.NotificationListener; @@ -34,10 +35,16 @@ import javax.management.remote.JMXConnector; import javax.management.remote.JMXConnectorFactory; import javax.management.remote.JMXServiceURL; +import org.onap.policy.common.logging.flexlogger.FlexLogger; +import org.onap.policy.common.logging.flexlogger.Logger; + /** * Class to create a JMX RMI connection to the JmxAgent. */ public final class JmxAgentConnection { + + private static final Logger logger = FlexLogger.getLogger(JmxAgentConnection.class); + private static final String DEFAULT_HOST = "localhost"; private static final String DEFAULT_PORT = "9996"; @@ -117,7 +124,7 @@ public final class JmxAgentConnection { */ public void disconnect() { if (connector != null) { - try { connector.close(); } catch (IOException e) { } + try { connector.close(); } catch (IOException e) { logger.debug(e); } } } } |