Author: andre
Date: 2009-12-01 21:03:08 +0100 (Tue, 01 Dec 2009)
New Revision: 40076
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:
wait for file
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-12-01 20:02:27 UTC (rev 40075)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Job.java
2009-12-01 20:03:08 UTC (rev 40076)
@@ -107,16 +107,17 @@
File f = new File(processor.getDirectory(), url);
assert f.exists() : "No such file " + f;
- if (!f.exists()) {
- LOG.warn("No such file '" + f + "' waiting 10
sec....");
+ int w = 0;
+ while (!f.exists() && w < 15) {
+ LOG.warn("No such file '" + f + "' waiting 2 sec...");
try {
- getThread().sleep(10000);
+ getThread().sleep(2000);
+ w++;
} catch (java.lang.InterruptedException ie) {
-
+ LOG.error(ie);
}
- if (!f.exists()) LOG.error("NO FILE!");
}
-
+ if (!f.exists()) LOG.error("NO FILE! '" + f + "', but
continuing anyway.");
inURI = f.toURI();
inNode = node;
} else {
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-12-01 20:02:27 UTC (rev 40075)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
2009-12-01 20:03:08 UTC (rev 40076)
@@ -158,6 +158,8 @@
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);
_______________________________________________
Cvs mailing list
Cvs@lists.mmbase.org
http://lists.mmbase.org/mailman/listinfo/cvs
