Author: michiel
Date: 2009-12-01 21:01:40 +0100 (Tue, 01 Dec 2009)
New Revision: 40074
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/TranscoderResult.java
Log:
moved waiting a bit, and added a loop
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 18:00:38 UTC (rev 40073)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
2009-12-01 20:01:40 UTC (rev 40074)
@@ -158,8 +158,6 @@
for (AnalyzerLogger al : analyzerLoggers) {
al.getAnalyzer().ready(thisJob.getNode(),
result.getDestination());
}
- logger.debug("Analyzer ready, waiting 10 sec. to be sure
filesystem is ready.....");
- thisJob.getThread().sleep(10000);
resultCount++;
result.ready();
logger.info("RESULT " + thisJob + "(" +
thisJob.getNode().getNodeManager().getName() + ":" +
thisJob.getNode().getNumber() + "):" + result);
Modified:
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/TranscoderResult.java
===================================================================
---
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/TranscoderResult.java
2009-12-01 18:00:38 UTC (rev 40073)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/TranscoderResult.java
2009-12-01 20:01:40 UTC (rev 40074)
@@ -65,7 +65,18 @@
super.ready();
if (dest != null) {
File outFile = new File(directory,
dest.getStringValue("url").replace("/", File.separator));
- LOG.info("Looking at: " + outFile);
+ LOG.debug("Looking at: " + outFile);
+ int count = 0;
+ while (!outFile.exists() || outFile.length() <1 && count < 20) {
+ LOG.service("Result ready but, but file " + outFile +
(outFile.exists() ? "is too small" : "doesn't exists") + ". Waiting 10 sec. to
be sure filesystem is ready (" + count + ")");
+ try {
+ Thread.currentThread().sleep(10000);
+ count++;
+ } catch (InterruptedException ie) {
+ LOG.info("Interrupted");
+ return;
+ }
+ }
dest.setLongValue("filesize", outFile.length());
if (outFile.length() >= 1) { // @TODO: there should maybe be
other ways to detect if a transcoding failed
dest.setIntValue("state", State.DONE.getValue());
_______________________________________________
Cvs mailing list
Cvs@lists.mmbase.org
http://lists.mmbase.org/mailman/listinfo/cvs
