//import static org.openecomp.policy.common.logging.eelf.Configuration.TRANSACTION_ELAPSED_TIME;
//import static org.openecomp.policy.common.logging.eelf.Configuration.TRANSACTION_END_TIME_STAMP;
-import static com.att.eelf.configuration.Configuration.MDC_ALERT_SEVERITY;
-import static com.att.eelf.configuration.Configuration.MDC_INSTANCE_UUID;
-
import java.text.SimpleDateFormat;
import java.time.Duration;
import java.time.Instant;
-import java.time.ZoneOffset;
import java.util.Date;
-import java.util.Properties;
-import java.util.Timer;
-import java.util.TimerTask;
-
import org.slf4j.MDC;
import org.openecomp.policy.common.logging.nsa.LoggingContextFactory;
package org.openecomp.policy.common.logging.eelf;
import java.util.HashMap;
-import java.util.Map;
/**
*
public class ErrorCodeMap {
- public static HashMap<MessageCodes, ErrorCodeInfo> hm = new HashMap();
+ public static HashMap<MessageCodes, ErrorCodeInfo> hm = new HashMap<MessageCodes, ErrorCodeInfo>();
private static String ERROR_PERMISSIONS = "POLICY-100E";
private static String ERROR_PERMISSIONS_DESCRIPTION = "This is a Permissions Error. Please check the error message for detail information";
import java.time.Instant;
-import javax.swing.text.html.parser.Entity;
-
/**
*
* EventData can be used for logging a rule event.
package org.openecomp.policy.common.logging.eelf;
-import java.io.IOException;
-import java.time.Instant;
-import java.util.Properties;
-import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
-import org.openecomp.policy.common.logging.flexlogger.PropertyUtil;
-
/**
*
* EventTrackInfo contains a ConcurrentHashMap of EventData
import java.time.Duration;
import java.time.Instant;
import java.util.ArrayList;
-import java.util.Iterator;
-import java.util.Timer;
import java.util.TimerTask;
/**
public class EelfLogger implements Logger, Serializable {
- private String className = "";
+ /**
+ *
+ */
+ private static final long serialVersionUID = 5385586713941277192L;
+ private String className = "";
private String transId = UUID.randomUUID().toString();
/**
* Constructor
* @param clazz
*/
- public EelfLogger(Class clazz) {
+ public EelfLogger(Class<?> clazz) {
if(clazz != null){
className = clazz.getName();
}
* @param clazz
* @param isNewTransaction
*/
- public EelfLogger(Class clazz, boolean isNewTransaction) {
+ public EelfLogger(Class<?> clazz, boolean isNewTransaction) {
if(clazz != null){
className = clazz.getName();
}
* @param clazz
* @param transId
*/
- public EelfLogger(Class clazz, String transId) {
+ public EelfLogger(Class<?> clazz, String transId) {
if(clazz != null){
className = clazz.getName();
}
*/
public class Logger4J implements org.openecomp.policy.common.logging.flexlogger.Logger, Serializable {
+ /**
+ *
+ */
+ private static final long serialVersionUID = 3183729429888828471L;
private Logger log = null;
private String methodName = "";
private String className = "";
* Constructor
* @param clazz
*/
- public Logger4J (Class clazz){
+ public Logger4J (Class<?> clazz){
System.out.println("create instance of Logger4J");
if(clazz != null){
log = Logger.getLogger(clazz);
*/
public class SystemOutLogger implements Logger, Serializable {
+ /**
+ *
+ */
+ private static final long serialVersionUID = 4956408061058933929L;
private String className = "";
private boolean isDebugEnabled = true;
private boolean isInfoEnabled = true;
* Constructor
* @param clazz
*/
- public SystemOutLogger (Class clazz){
+ public SystemOutLogger (Class<?> clazz){
System.out.println("create instance of SystemOutLogger");
if(clazz != null){
className = clazz.getName();
//import org.apache.log4j.Logger;
-import org.openecomp.policy.common.ia.IntegrityAuditProperties.NodeTypeEnum;
import org.openecomp.policy.common.ia.jpa.IntegrityAuditEntity;
import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
import org.openecomp.policy.common.logging.flexlogger.Logger;
import javax.persistence.NamedQuery;
import javax.persistence.PrePersist;
import javax.persistence.PreUpdate;
-import javax.persistence.SequenceGenerator;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;
dbDAO = new DbDAO(resourceName, persistenceUnit, properties);
DbAudit dbAudit = new DbAudit(dbDAO);
- @SuppressWarnings("unused")
- String className = null;
HashSet<String> classNameSet = dbDAO.getPersistenceClassNames();
HashSet<Object> mismatchResult = new HashSet<Object>();
for(String c : classNameSet) {
- className = c;
if (c.equals("org.openecomp.policy.common.ia.jpa.IntegrityAuditEntity")){
String resourceName1 = resourceName;
String resourceName2 = resourceName;
// Add entries into DB1
dbDAO = new DbDAO(resourceName, persistenceUnit, properties);
- DbDAO dbDAO2 = new DbDAO("pdp2", persistenceUnit, properties);
+ new DbDAO("pdp2", persistenceUnit, properties);
DbAudit dbAudit = new DbAudit(dbDAO);
// Add entries into DB2
DbDAO dbDAO3 = new DbDAO(resourceName, persistenceUnit, properties2);
- DbDAO dbDAO4 = new DbDAO("pdp2", persistenceUnit, properties2);
+ new DbDAO("pdp2", persistenceUnit, properties2);
// Pull all entries and compare
HashSet<String> classNameSet = dbDAO.getPersistenceClassNames();
import java.io.FileOutputStream;
import java.io.InputStreamReader;
import java.util.Date;
-import java.util.HashSet;
import java.util.List;
import java.util.Properties;
try {
// Add some entries to the DB
d = new DbDAO(resourceName, persistenceUnit, properties);
- DbDAO d2 = new DbDAO("pdp1", persistenceUnit, properties);
+ new DbDAO("pdp1", persistenceUnit, properties);
properties.put(IntegrityAuditProperties.NODE_TYPE, "pdp_drools");
- DbDAO d3 = new DbDAO("pdp2", persistenceUnit, properties);
+ new DbDAO("pdp2", persistenceUnit, properties);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
try {
// create entries for the IntegrityAuditEntity table
d = new DbDAO(resourceName, persistenceUnit, properties);
- DbDAO d2 = new DbDAO("pdp1", persistenceUnit, properties);
- DbDAO d3 = new DbDAO("pdp2", persistenceUnit, properties);
+ new DbDAO("pdp1", persistenceUnit, properties);
+ new DbDAO("pdp2", persistenceUnit, properties);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
try {
// create entries for the IntegrityAuditEntity table
d = new DbDAO(resourceName, persistenceUnit, properties);
- DbDAO d2 = new DbDAO("pdp1", persistenceUnit, properties);
- DbDAO d3 = new DbDAO("pdp2", persistenceUnit, properties);
+ new DbDAO("pdp1", persistenceUnit, properties);
+ new DbDAO("pdp2", persistenceUnit, properties);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
try {
// create entries for the IntegrityAuditEntity table
d = new DbDAO(resourceName, persistenceUnit, properties);
- DbDAO d2 = new DbDAO("pdp1", persistenceUnit, properties);
- DbDAO d3 = new DbDAO("pdp2", persistenceUnit, properties);
+ new DbDAO("pdp1", persistenceUnit, properties);
+ new DbDAO("pdp2", persistenceUnit, properties);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
try {
// create entries for the IntegrityAuditEntity table
d = new DbDAO(resourceName, persistenceUnit, properties);
- DbDAO d2 = new DbDAO("pdp1", persistenceUnit, properties);
- DbDAO d3 = new DbDAO("pdp2", persistenceUnit, properties);
+ new DbDAO("pdp1", persistenceUnit, properties);
+ new DbDAO("pdp2", persistenceUnit, properties);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
try {
// create entries for the IntegrityAuditEntity table
d = new DbDAO(resourceName, persistenceUnit, properties);
- DbDAO d2 = new DbDAO("pdp1", persistenceUnit, properties);
- DbDAO d3 = new DbDAO("pdp2", persistenceUnit, properties);
+ new DbDAO("pdp1", persistenceUnit, properties);
+ new DbDAO("pdp2", persistenceUnit, properties);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
-import javax.persistence.Lob;
import javax.persistence.NamedQueries;
import javax.persistence.NamedQuery;
import javax.persistence.PrePersist;
import javax.persistence.PreUpdate;
-import javax.persistence.SequenceGenerator;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;
-import javax.persistence.Version;
-/*
- * The Entity class to persist a policy object Action Body
- */
@Entity
@Table(name="IaTestEntity")
private static IntegrityMonitor instance = null;
private static String resourceName = null;
- private boolean fpcError = false;
boolean alarmExists = false;
/*
// Persistence Unit for JPA
private static final String PERSISTENCE_UNIT = "operationalPU";
- private ComponentAdmin admin = null;
private StateManagement stateManager = null;
private static final int CYCLE_INTERVAL_MILLIS = 1000;
// create management bean
try {
- admin = new ComponentAdmin(resourceName, this, stateManager);
+ new ComponentAdmin(resourceName, this, stateManager);
} catch (Exception e) {
logger.error("ComponentAdmin constructor exception: " + e.toString());
}
- // create FPManager inner class
- FPManager fpMonitor = new FPManager();
+ new FPManager();
}
// no forward progress
missedCycles += 1;
if (missedCycles >= failedCounterThreshold && !alarmExists) {
- // set op state to disabled failed
- fpcError = true;
logger.info("Forward progress not detected for resource " + resourceName + ". Setting state to disable failed.");
if(!(stateManager.getOpState()).equals(StateManagement.DISABLED)){
// Note: The refreshStateAudit will make redundant calls
// forward progress has occurred
lastFpCounter = fpCounter;
missedCycles = 0;
- fpcError = false;
// set op state to enabled
logger.debug("Forward progress detected for resource " + resourceName + ". Setting state to enable not failed.");
if(!(stateManager.getOpState()).equals(StateManagement.ENABLED)){
package org.openecomp.policy.common.im;
public class StandbyStatusException extends Exception {
+ /**
+ *
+ */
+ private static final long serialVersionUID = -5262512285108747134L;
+
public StandbyStatusException()
{
}
package org.openecomp.policy.common.im;
-import java.util.*;
-
//import org.apache.log4j.Logger;
import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
import org.openecomp.policy.common.logging.flexlogger.Logger;
String endingStandbyStatus = null;
String exception = null;
- public void StateElement()
+ public StateElement()
{
}
import org.openecomp.policy.common.im.jpa.StateManagementEntity;
import org.openecomp.policy.common.im.StateElement;
import org.openecomp.policy.common.im.StandbyStatusException;
-import org.openecomp.policy.common.im.StateChangeNotifier;
import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
import org.openecomp.policy.common.logging.flexlogger.Logger;
public static final String AVAILABLE_STATUS= "availStatus";
public static final String STANDBY_STATUS = "standbyStatus";
- private static final String REMOVE = "remove";
- private static final String ADD = "add";
-
private String resourceName = null;
private String adminState = null;
private String opState = null;
private String availStatus = null;
private String standbyStatus = null;
private EntityManager em;
- private EntityManagerFactory emf = null;
private StateTransition st = null;
/*
public StateManagement(EntityManagerFactory emf, String resourceName) throws Exception
{
logger.debug("StateManagement: constructor, resourceName: " + resourceName);
- this.emf = emf;
em = emf.createEntityManager();
EntityTransaction et = em.getTransaction();
}
String key = adminState + "," + opState + "," + availStatus2 + "," + standbyStatus + "," + actionName;
logger.debug("Ending State search key: " + key);
- String value = (String)StateTable.get(key);
+ String value = StateTable.get(key);
if (value != null) {
try {
public void displayStateTable()
{
- Set set = StateTable.entrySet();
- Iterator iter = set.iterator();
+ Set<?> set = StateTable.entrySet();
+ Iterator<?> iter = set.iterator();
while(iter.hasNext()) {
- Map.Entry me = (Map.Entry)iter.next();
+ Map.Entry<?, ?> me = (Map.Entry<?, ?>)iter.next();
logger.debug((String)me.getKey() + ((String)me.getValue()).replace(".", ","));
}
}
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
-import java.util.Properties;
-
import javax.management.MBeanServerConnection;
import javax.management.Notification;
import javax.management.NotificationListener;
import javax.persistence.NamedQuery;
import javax.persistence.PrePersist;
import javax.persistence.PreUpdate;
-import javax.persistence.SequenceGenerator;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
-import javax.persistence.Lob;
import javax.persistence.NamedQueries;
import javax.persistence.NamedQuery;
import javax.persistence.PrePersist;
import javax.persistence.PreUpdate;
-import javax.persistence.SequenceGenerator;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;
-import javax.persistence.Version;
-/*
- * The Entity class to persist a policy object Action Body
- */
@Entity
@Table(name="ImTestEntity")
import javax.persistence.NamedQuery;
import javax.persistence.PrePersist;
import javax.persistence.PreUpdate;
-import javax.persistence.SequenceGenerator;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;
import javax.persistence.NamedQuery;
import javax.persistence.PrePersist;
import javax.persistence.PreUpdate;
-import javax.persistence.SequenceGenerator;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;
import org.openecomp.policy.common.im.IntegrityMonitorProperties;
import org.openecomp.policy.common.im.StateManagement;
import org.openecomp.policy.common.im.jpa.ForwardProgressEntity;
-import org.openecomp.policy.common.im.jpa.ImTestEntity;
import org.openecomp.policy.common.im.jpa.ResourceRegistrationEntity;
import org.openecomp.policy.common.im.jpa.StateManagementEntity;
import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
StateManagement stateManager = new StateManagement(emf, "group2_dep1");
stateManager.lock();
- //Now add new group1 stateManager instances
- StateManagement sm2 = new StateManagement(emf, "group1_dep1");
- StateManagement sm3 = new StateManagement(emf, "group1_dep2");
+ new StateManagement(emf, "group1_dep1");
+ new StateManagement(emf, "group1_dep2");
boolean sanityPass = true;
Thread.sleep(15000);
IntegrityMonitor.deleteInstance();
- IntegrityMonitor im = IntegrityMonitor.getInstance(resourceName, myProp);
+ IntegrityMonitor.getInstance(resourceName, myProp);
//the state here is unlocked, enabled, null, null
StateManagementEntity sme = null;
em.flush();
et.commit();
- //Now add new group1 stateManager instances
- StateManagement sm2 = new StateManagement(emf, "group1_dep1");
+ new StateManagement(emf, "group1_dep1");
boolean sanityPass = true;
//Thread.sleep(15000);
logger.debug("\nIntegrityMonitorTest:testStateAudit getting list of StateManagementEntity entries\n\n");
Query query = em.createQuery("SELECT s FROM StateManagementEntity s");
- List smeList = query.getResultList();
+ List<?> smeList = query.getResultList();
logger.debug("\n\n");
logger.debug("IntegrityMonitorTest:testStateAudit:StateManagementEntity entries");
package org.openecomp.policy.common.im.test;
-import static org.junit.Assert.*;
-
-import java.util.Date;
import java.util.List;
import java.util.Properties;
//Just test that we are retrieving the right object
@SuppressWarnings("rawtypes")
List resourceList = query.getResultList();
- String resource = null;
if (!resourceList.isEmpty()) {
// exist
StateManagementEntity sme2 = (StateManagementEntity) resourceList.get(0);
package org.openecomp.policy.common.im.test;
-import static org.junit.Assert.*;
-
-import java.util.ArrayList;
-import java.util.List;
import java.util.Properties;
-import java.util.StringTokenizer;
-import java.io.BufferedReader;
-import java.io.FileReader;
-import java.io.IOException;
-
-import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;
-import javax.persistence.EntityManager;
-import javax.persistence.EntityManagerFactory;
-import javax.persistence.LockModeType;
-import javax.persistence.PersistenceException;
-import javax.persistence.Query;
-
-
-
-
import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Ignore;
import org.junit.Test;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
import org.openecomp.policy.common.im.StateManagement;
-import org.openecomp.policy.common.im.StateTransition;
import org.openecomp.policy.common.im.StandbyStatusException;
import org.openecomp.policy.common.im.StateChangeNotifier;
import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
package org.openecomp.policy.common.im.test;
-import static org.junit.Assert.*;
-
-import java.util.ArrayList;
-import java.util.List;
import java.util.Properties;
-import java.util.StringTokenizer;
-import java.io.BufferedReader;
-import java.io.FileReader;
-import java.io.IOException;
-
-import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
-import javax.persistence.EntityTransaction;
-import javax.persistence.Persistence;
-
import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before;
import org.openecomp.policy.common.im.StateTransition;
import org.openecomp.policy.common.im.StateElement;
-import org.openecomp.policy.common.im.StandbyStatusException;
-import org.openecomp.policy.common.im.StateChangeNotifier;
import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
import org.openecomp.policy.common.logging.flexlogger.Logger;
/*
@Test
public void testJPA() throws Exception {
logger.info("\n\nlogger.infor StateTransitionTest: Entering\n\n");
- boolean standbyExceptionThrown = false;
-
//These parameters are in a properties file
EntityManagerFactory emf = null;
try {
String formatString = sb.toString();
// display column headers
- System.out.printf(formatString, labels);
- System.out.printf(formatString, underlines);
+ System.out.printf(formatString, (Object[])labels);
+ System.out.printf(formatString, (Object[])underlines);
// display all of the rows
for (String[] values : treeset)
{
- System.out.printf(formatString, values);
+ System.out.printf(formatString, (Object[])values);
}
}
}
Code Review / policy / common.git / commitdiff