Author: andre
Date: 2009-11-22 16:22:44 +0100 (Sun, 22 Nov 2009)
New Revision: 39835

Modified:
   
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Job.java
   
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
Log:
fix for not continueing with next Result, seems a bit weird to use if in stead 
of while here but looks like this works

Modified: 
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Job.java
===================================================================
--- 
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Job.java
    2009-11-22 12:03:04 UTC (rev 39834)
+++ 
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Job.java
    2009-11-22 15:22:44 UTC (rev 39835)
@@ -230,7 +230,6 @@
                     for (; i < results.size(); i++) {
                         if (results.get(i) != null && ! 
results.get(i).isReady()) {
                             current = results.get(i);
-                            LOG.debug("not ready? c: " + current);
                             Job.this.notifyAll();
                             i++;
                             break;

Modified: 
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
===================================================================
--- 
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
    2009-11-22 12:03:04 UTC (rev 39834)
+++ 
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
    2009-11-22 15:22:44 UTC (rev 39835)
@@ -102,9 +102,8 @@
                 LOG.info("Checking to execute " + thisJob);
                 Result current = thisJob.getCurrent();
                 if (current == null || current.isReady()) {
-                    LOG.info("current: " + current + " ready? " + 
current.isReady());
-                    while (iterator.hasNext()) {
-                        LOG.info("next !"); // BUG: not arriving here when 
there are still nodes to do
+                    if (iterator.hasNext()) {
+                        LOG.info("next !");
                         iterator.next();
                     }
                     current = thisJob.getCurrent();

_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs

Reply via email to