DEBUG: change some thread names for debugging 77/32477/1
authorgreatim <jaewon81.lim@samsung.com>
Thu, 18 Dec 2014 11:54:47 +0000 (20:54 +0900)
committergreatim <jaewon81.lim@samsung.com>
Thu, 18 Dec 2014 11:54:47 +0000 (20:54 +0900)
change some thread names for debugging

Change-Id: I4de231fd3697ce3c1ad752e703c35be6470d29c0
Signed-off-by: greatim <jaewon81.lim@samsung.com>
org.tizen.dynamicanalyzer/src/org/tizen/dynamicanalyzer/common/AnalyzerConstants.java
org.tizen.dynamicanalyzer/src/org/tizen/dynamicanalyzer/swap/logparser/PageDataManager.java
org.tizen.dynamicanalyzer/src/org/tizen/dynamicanalyzer/swap/model/data/ProfileData.java

index 9bd2df5..832e2e6 100644 (file)
@@ -68,8 +68,8 @@ public class AnalyzerConstants {
        public static final String FAILED_DATA_TABLE_NAME = "FailedData"; //$NON-NLS-1$
 
        /* thread names */
-       public static final String LOG_QUEUE_OBSERVING_THREAD = "Log Queue Observing thread"; //$NON-NLS-1$
-       public static final String COMMUNICATOR_RECEIVE_THREAD = "Communicator Receive Thread"; //$NON-NLS-1$
+       public static final String LOG_QUEUE_OBSERVING_THREAD = "Log parser thread"; //$NON-NLS-1$
+       public static final String COMMUNICATOR_RECEIVE_THREAD = "Data channel recv thread"; //$NON-NLS-1$
        public static final String MESSAGE_INTERNAL_IMAGE_THREAD = "Internal Image Process Thread"; //$NON-NLS-1$
        public static final String STOP_LOG_THREAD = "Stop Log Thread"; //$NON-NLS-1$
        public static final String BATTERY_RECEIVE_THREAD = "Battery Receive Thread"; //$NON-NLS-1$
index beda044..3583435 100644 (file)
@@ -31,28 +31,28 @@ import java.util.concurrent.LinkedBlockingQueue;
 
 import org.tizen.dynamicanalyzer.common.AnalyzerConstants;
 import org.tizen.dynamicanalyzer.common.AnalyzerManager;
+import org.tizen.dynamicanalyzer.constant.CommonConstants;
 import org.tizen.dynamicanalyzer.util.Logger;
 
 public abstract class PageDataManager implements Runnable {
-       private String name = null;
+       protected String name = null;
        private Thread thread = null;
        private BlockingQueue<LogPackage> logPackQueue = new LinkedBlockingQueue<LogPackage>();
 
        private enum State {
-               NOT_RUNNING,
-               RUNNING,
-               TO_BE_STOPED
+               NOT_RUNNING, RUNNING, TO_BE_STOPED
        }
 
        private State state = State.NOT_RUNNING;
 
        public final String getName() {
                if (name == null) {
-                       name = getClass().getName();
+                       String[] tnames = getClass().getName().split(CommonConstants.CMD_SPLIT_DOT);
+                       name = tnames[tnames.length - 1];
                }
                return name;
        }
-       
+
        public final void updateLog(LogPackage logPack) {
                try {
                        logPackQueue.put(logPack);
@@ -65,13 +65,13 @@ public abstract class PageDataManager implements Runnable {
                LogPackage pack = null;
                try {
                        if (state == State.RUNNING)
-                               pack = logPackQueue.take();             // wait if empty
+                               pack = logPackQueue.take(); // wait if empty
                        else if (state == State.TO_BE_STOPED)
-                               pack = logPackQueue.poll();             // return null if empty
+                               pack = logPackQueue.poll(); // return null if empty
                } catch (InterruptedException e) {
                        e.printStackTrace();
                }
-               
+
                return pack;
        }
 
@@ -84,7 +84,7 @@ public abstract class PageDataManager implements Runnable {
        }
 
        // "called stopThread" means that there is no more data
-       // coming in this page data manager 
+       // coming in this page data manager
        // It means that this function should be called only in data offerer
        // when all data offer is finished.
        public synchronized final void stopThread() {
@@ -113,7 +113,7 @@ public abstract class PageDataManager implements Runnable {
        private void sendNotify() {
                LogPackage endOfStream = new LogPackage();
                endOfStream.setEndOfStream();
-               
+
                try {
                        logPackQueue.put(endOfStream);
                } catch (InterruptedException e) {
@@ -130,7 +130,7 @@ public abstract class PageDataManager implements Runnable {
 
                        makeData(pack);
                }
-               
+
                onThreadStop();
 
                /* log for debug */
index 6067dd4..25be027 100644 (file)
@@ -201,7 +201,7 @@ public class ProfileData extends LogData {
                                LibraryObject obj = null;
                                ProcessMemoryMap pmap = process.getProcessMemoryMap(time);
                                if (pmap == null || (obj = pmap.getLibraryByAddress(pcAddr)) == null) {
-                                       Logger.error("cannot find library for the pid and address : " + pid + ", " + pcAddr);
+                                       Logger.warning("cannot find library for the pid and address : " + pid + ", " + pcAddr);
                                        binaryId = -1;
                                } else {
                                        binaryId = obj.getBinaryID();