[MMBASE SCM] r41603 - mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams/createcaches

[andre]

Author: andre
Date: 2010-03-25 14:08:19 +0100 (Thu, 25 Mar 2010)
New Revision: 41603

Modified:
   
mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
Log:
logging



Modified: 
mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
===================================================================
--- 
mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
      2010-03-25 13:06:10 UTC (rev 41602)
+++ 
mmbase/branches/MMBase-1_9/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
      2010-03-25 13:08:19 UTC (rev 41603)
@@ -116,7 +116,7 @@
                 Result current = thisJob.getCurrent();
                 if (current == null || current.isReady()) {
                     if (iterator.hasNext()) {
-                        LOG.debug("next !");
+                        //LOG.debug("next !");
                         iterator.next();
                     }
                     current = thisJob.getCurrent();
@@ -125,7 +125,7 @@
                     if (current.isReady()) {
                         thisJob.ready();
                         
Processor.runningJobs.remove(thisJob.getNode().getNumber());
-                        LOG.info("1: returning resultCount: " + resultCount);
+                        //LOG.info("1: returning resultCount: " + resultCount);
                         return resultCount;
                     }
 
@@ -136,7 +136,7 @@
                         thisJob.submit(this);
                     } catch (Exception e) {
                     }
-                    LOG.info("2: returning resultCount: " + resultCount);
+                    //LOG.info("2: returning resultCount: " + resultCount);
                     return resultCount;
                 }
                 result = current;
@@ -151,18 +151,18 @@
                     analyzerLoggers.add(al);
                     logger.addLogger(al);
                 }
+                
                 assert in != null;
-
                 try {
                     jd.transcoder.transcode(in, out, logger);
                     for (AnalyzerLogger al : analyzerLoggers) {
                         al.getAnalyzer().ready(thisJob.getNode(), 
result.getDestination());
                     }
                     
-                    
                     resultCount++;
                     result.ready();
                     logger.info("RESULT " + thisJob + "(" + 
thisJob.getNode().getNodeManager().getName() + ":" + 
thisJob.getNode().getNumber() + "):" + result);
+                    
                     if (thisJob.isInterrupted() || 
Thread.currentThread().isInterrupted()){
                         logger.info("Interrupted");
                         break;
@@ -196,7 +196,7 @@
             logger.info("FINALLY " + resultCount);
             thisJob.notifyAll(); // notify waiters
         }
-        logger.info("3: returning resultCount: " + resultCount);
+        //logger.info("3: returning resultCount: " + resultCount);
         return resultCount;
     }
 

_______________________________________________
Cvs mailing list
Cvs@lists.mmbase.org
http://lists.mmbase.org/mailman/listinfo/cvs