You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mi...@apache.org on 2009/03/13 20:10:50 UTC

svn commit: r753350 - /ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/WatchDog.java

Author: midon
Date: Fri Mar 13 19:10:45 2009
New Revision: 753350

URL: http://svn.apache.org/viewvc?rev=753350&view=rev
Log:
ODE-549: better logging for WatchDog

Modified:
    ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/WatchDog.java

Modified: ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/WatchDog.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/WatchDog.java?rev=753350&r1=753349&r2=753350&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/WatchDog.java (original)
+++ ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/WatchDog.java Fri Mar 13 19:10:45 2009
@@ -113,31 +113,35 @@
         long now = System.currentTimeMillis();
         if (expire <= now) {
             expire = now + delay;
-            if (log.isDebugEnabled()) log.debug("Check for changes: " + mutable);
+            if (log.isDebugEnabled()) log.debug("["+mutable+"]"+ " check for changes");
             if (mutable.exists()) {
                 existedBefore = true;
                 if (lastModif == null || mutable.hasChangedSince(lastModif)) {
                     lastModif = mutable.lastModified();
                     observer.onUpdate();
-                    if (log.isInfoEnabled()) log.info(mutable + " updated");
+                    if (log.isInfoEnabled()) log.info("["+mutable+"]"+" updated");
                     warnedAlready = false;
+                }else{
+                    if (log.isDebugEnabled()) log.debug("["+mutable+"]"+" has not changed");
                 }
             } else if (!observer.isInitialized()) {
                 // no resource and first time
                 observer.init();
-                if (log.isInfoEnabled()) log.info(mutable + " initialized");
+                if (log.isInfoEnabled()) log.info("["+mutable+"]"+ " initialized");
             } else {
                 if (existedBefore) {
                     existedBefore = false;
                     lastModif = null;
                     observer.onDelete();
-                    if (log.isInfoEnabled()) log.info(mutable + " deleted");
+                    if (log.isInfoEnabled()) log.info("["+mutable+"]"+ " deleted");
                 }
                 if (!warnedAlready) {
                     warnedAlready = true;
-                    if (log.isInfoEnabled()) log.info(mutable + " does not exist.");
+                    if (log.isInfoEnabled()) log.info("["+mutable+"]"+" does not exist.");
                 }
             }
+        }else{
+            if (log.isTraceEnabled()) log.trace("["+mutable+"]"+" wait period is not over");
         }
     }