From 455897cc245b67d929f409a93cfa7106e835cc1f Mon Sep 17 00:00:00 2001
From: boli <boli@localhost>
Date: Thu, 01 Mar 2007 03:27:06 +0000
Subject: [PATCH] This removes old debug logging framework method calls that are going to be automatically instrumented by AspectJ. Non instrumented debug method calls are updated to use the new debug framework methods. However, the new debug logging framework is not yet active as the Aspects are not weaved in. After this revision, debug logging will be disabled in the server until the new AOP framework is complete. 

---
 opends/src/server/org/opends/server/extensions/TraditionalWorkerThread.java |   95 ++++++++++++++++++++++++-----------------------
 1 files changed, 48 insertions(+), 47 deletions(-)

diff --git a/opends/src/server/org/opends/server/extensions/TraditionalWorkerThread.java b/opends/src/server/org/opends/server/extensions/TraditionalWorkerThread.java
index e704054..f9e7c9e 100644
--- a/opends/src/server/org/opends/server/extensions/TraditionalWorkerThread.java
+++ b/opends/src/server/org/opends/server/extensions/TraditionalWorkerThread.java
@@ -22,7 +22,7 @@
  * CDDL HEADER END
  *
  *
- *      Portions Copyright 2006 Sun Microsystems, Inc.
+ *      Portions Copyright 2006-2007 Sun Microsystems, Inc.
  */
 package org.opends.server.extensions;
 
@@ -33,13 +33,15 @@
 import org.opends.server.core.Operation;
 import org.opends.server.types.CancelRequest;
 import org.opends.server.types.CancelResult;
-import org.opends.server.types.DebugLogCategory;
-import org.opends.server.types.DebugLogSeverity;
 import org.opends.server.types.DisconnectReason;
 import org.opends.server.types.ErrorLogCategory;
 import org.opends.server.types.ErrorLogSeverity;
 
-import static org.opends.server.loggers.Debug.*;
+import static org.opends.server.loggers.debug.DebugLogger.debugCought;
+import static org.opends.server.loggers.debug.DebugLogger.debugEnabled;
+import static org.opends.server.loggers.debug.DebugLogger.debugInfo;
+import static org.opends.server.loggers.debug.DebugLogger.debugWarning;
+import org.opends.server.types.DebugLogLevel;
 import static org.opends.server.loggers.Error.*;
 import static org.opends.server.messages.CoreMessages.*;
 import static org.opends.server.messages.MessageHandler.*;
@@ -54,11 +56,6 @@
 public class TraditionalWorkerThread
        extends DirectoryThread
 {
-  /**
-   * The fully-qualified name of this class for debugging purposes.
-   */
-  private static final String CLASS_NAME =
-  "org.opends.server.core.WorkerThread";
 
 
 
@@ -96,8 +93,6 @@
   {
     super("Worker Thread " + threadID);
 
-    assert debugConstructor(CLASS_NAME, String.valueOf(workQueue),
-                            String.valueOf(threadID));
 
     this.workQueue = workQueue;
 
@@ -117,7 +112,6 @@
    */
   public void setStoppedByReducedThreadNumber()
   {
-    assert debugEnter(CLASS_NAME, "setStoppedByReducedThreadNumber");
 
     stoppedByReducedThreadNumber = true;
   }
@@ -135,7 +129,6 @@
    */
   public boolean isActive()
   {
-    assert debugEnter(CLASS_NAME, "isActive");
 
     return (isAlive() && (operation != null));
   }
@@ -148,9 +141,6 @@
    */
   public void run()
   {
-    assert debugEnter(CLASS_NAME, "run");
-    assert debugMessage(DebugLogCategory.CORE_SERVER, DebugLogSeverity.INFO,
-                        CLASS_NAME, "run", getName() + " starting.");
 
     workerThread = currentThread();
 
@@ -190,12 +180,14 @@
       }
       catch (Exception e)
       {
-        assert debugMessage(DebugLogCategory.CORE_SERVER,
-                            DebugLogSeverity.WARNING, CLASS_NAME, "run",
-                            "Uncaught exception in worker thread while " +
-                            "processing operation " +
-                            String.valueOf(operation) + ":  " + e);
-        assert debugException(CLASS_NAME, "run", e);
+        if (debugEnabled())
+        {
+          debugWarning(
+            "Uncaught exception in worker thread while processing " +
+                "operation %s: %s", String.valueOf(operation), e);
+
+          debugCought(DebugLogLevel.ERROR, e);
+        }
 
         try
         {
@@ -213,12 +205,14 @@
         }
         catch (Exception e2)
         {
-          assert debugMessage(DebugLogCategory.CORE_SERVER,
-                              DebugLogSeverity.WARNING, CLASS_NAME, "run",
-                              "Exception in worker thread while trying to " +
-                              "log a message about an uncaught exception " + e +
-                              ":  " + e2);
-          assert debugException(CLASS_NAME, "run", e2);
+          if (debugEnabled())
+          {
+            debugWarning(
+              "Exception in worker thread while trying to log a " +
+                  "message about an uncaught exception %s: %s", e, e2);
+
+            debugCought(DebugLogLevel.ERROR, e2);
+          }
         }
 
 
@@ -234,12 +228,14 @@
         }
         catch (Exception e2)
         {
-          assert debugException(CLASS_NAME, "run", e2);
+          if (debugEnabled())
+          {
+            debugCought(DebugLogLevel.ERROR, e2);
+          }
         }
       }
     }
 
-
     // If we have gotten here, then we presume that the server thread is
     // shutting down.  However, if that's not the case then that is a problem
     // and we will want to log a message.
@@ -255,8 +251,10 @@
     }
 
 
-    assert debugMessage(DebugLogCategory.CORE_SERVER, DebugLogSeverity.INFO,
-                        CLASS_NAME, "run", getName() + " exiting.");
+    if (debugEnabled())
+    {
+      debugInfo(getName() + " exiting.");
+    }
   }
 
 
@@ -267,11 +265,11 @@
    */
   public void shutDown()
   {
-    assert debugEnter(CLASS_NAME, "shutDown");
-    assert debugMessage(DebugLogCategory.CORE_SERVER,
-                        DebugLogSeverity.INFO, CLASS_NAME, "shutDown",
-                        getName() + " being signaled to shut down.");
 
+    if (debugEnabled())
+    {
+      debugInfo(getName() + " being signaled to shut down.");
+    }
 
     // Set a flag that indicates that the thread should stop running.
     shutdownRequested = true;
@@ -287,11 +285,13 @@
       }
       catch (Exception e)
       {
-        assert debugMessage(DebugLogCategory.CORE_SERVER,
-                            DebugLogSeverity.WARNING, CLASS_NAME, "shutDown",
-                            "Caught an exception while trying to interrupt " +
-                            "the worker thread waiting for work:  " + e);
-        assert debugException(CLASS_NAME, "shutDown", e);
+        if (debugEnabled())
+        {
+          debugWarning(
+            "Caught an exception while trying to interrupt the worker " +
+                "thread waiting for work: %s", e);
+          debugCought(DebugLogLevel.ERROR, e);
+        }
       }
     }
     else
@@ -304,12 +304,13 @@
       }
       catch (Exception e)
       {
-        assert debugMessage(DebugLogCategory.CORE_SERVER,
-                            DebugLogSeverity.WARNING, CLASS_NAME, "shutDown",
-                            "Caught an exception while trying to abandon the " +
-                            "operation in progress for the worker thread:  " +
-                            e);
-        assert debugException(CLASS_NAME, "shutDown", e);
+        if (debugEnabled())
+        {
+          debugWarning(
+            "Caught an exception while trying to abandon the " +
+                "operation in progress for the worker thread: %s", e);
+          debugCought(DebugLogLevel.ERROR, e);
+        }
       }
     }
   }

--
Gitblit v1.10.0