Author: andre
Date: 2009-11-22 13:03:04 +0100 (Sun, 22 Nov 2009)
New Revision: 39834
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:
trying to solve bug in getting next result to transcode
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 11:54:49 UTC (rev 39833)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Job.java
2009-11-22 12:03:04 UTC (rev 39834)
@@ -214,7 +214,7 @@
return new Iterator<Result>() {
int i = 0;
public boolean hasNext() {
- for (int j = i ; j < results.size(); j++) {
+ for (int j = i; j < results.size(); j++) {
if (results.get(j) != null && ! results.get(j).isReady()) {
LOG.debug("Found to do at " + j + " -> " +
results.get(j));
return true;
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 11:54:49 UTC (rev 39833)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
2009-11-22 12:03:04 UTC (rev 39834)
@@ -104,7 +104,7 @@
if (current == null || current.isReady()) {
LOG.info("current: " + current + " ready? " +
current.isReady());
while (iterator.hasNext()) {
- LOG.info("next !");
+ LOG.info("next !"); // BUG: not arriving here when
there are still nodes to do
iterator.next();
}
current = thisJob.getCurrent();
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs
