X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdatarouter%2Fprovisioning%2Futils%2FLogfileLoader.java;h=6c5a13fdb8de1987b1fc9efabf1032aefbee4c40;hb=5775de7b0fc84a29511dc4a1a480c3ab32da2ade;hp=ab1a3a78eb72d1ee39a68820d7f443600fb4cf82;hpb=f926474924870c9ed4d5c4c8ccba55a1942d8e37;p=dmaap%2Fdatarouter.git

diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java
index ab1a3a78..6c5a13fd 100644
--- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java
+++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/LogfileLoader.java
@@ -82,7 +82,7 @@ public class LogfileLoader extends Thread {
     /**
      * This is a singleton -- there is only one LogfileLoader object in the server
      */
-    private static LogfileLoader p;
+    private static LogfileLoader logfileLoader;
 
     /**
      * Get the singleton LogfileLoader object, and start it if it is not running.
@@ -90,11 +90,11 @@ public class LogfileLoader extends Thread {
      * @return the LogfileLoader
      */
     public static synchronized LogfileLoader getLoader() {
-        if (p == null)
-            p = new LogfileLoader();
-        if (!p.isAlive())
-            p.start();
-        return p;
+        if (logfileLoader == null)
+            logfileLoader = new LogfileLoader();
+        if (!logfileLoader.isAlive())
+            logfileLoader.start();
+        return logfileLoader;
     }
 
     /**
@@ -218,7 +218,7 @@ public class LogfileLoader extends Thread {
         }
     }
 
-    private boolean pruneRecords() {
+    boolean pruneRecords() {
         boolean did1 = false;
         long count = countRecords();
         long threshold = DEFAULT_LOG_RETENTION;
@@ -282,7 +282,7 @@ public class LogfileLoader extends Thread {
         return did1;
     }
 
-    private long countRecords() {
+    long countRecords() {
         long count = 0;
         Connection conn = null;
         try {
@@ -303,7 +303,7 @@ public class LogfileLoader extends Thread {
         return count;
     }
 
-    private Map<Long, Long> getHistogram() {
+    Map<Long, Long> getHistogram() {
         Map<Long, Long> map = new HashMap<Long, Long>();
         Connection conn = null;
         try {
@@ -382,7 +382,7 @@ public class LogfileLoader extends Thread {
     }
 
     @SuppressWarnings("resource")
-    private int[] process(File f) {
+    int[] process(File f) {
         int ok = 0, total = 0;
         try {
             Connection conn = db.getConnection();
@@ -442,7 +442,7 @@ public class LogfileLoader extends Thread {
         return new int[]{ok, total};
     }
 
-    private Loadable[] buildRecords(String line) throws ParseException {
+    Loadable[] buildRecords(String line) throws ParseException {
         String[] pp = line.split("\\|");
         if (pp != null && pp.length >= 7) {
             String rtype = pp[1].toUpperCase();