Author: andre
Date: 2009-12-01 17:03:46 +0100 (Tue, 01 Dec 2009)
New Revision: 40063
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
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Processor.java
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/TranscoderResult.java
Log:
work-in-progress on waiting for files for streamcaches nodes, bit of javadoc
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 12:28:46 UTC (rev 40062)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Job.java
2009-12-01 16:03:46 UTC (rev 40063)
@@ -106,6 +106,17 @@
assert url.length() > 0;
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....");
+ try {
+ getThread().sleep(10000);
+ } catch (java.lang.InterruptedException ie) {
+
+ }
+ if (!f.exists()) LOG.error("NO FILE!");
+ }
+
inURI = f.toURI();
inNode = node;
} else {
@@ -342,7 +353,7 @@
* exists in the cloud or otherwise will create one.
*
* @param src source node to create stream from
- * @param key representation of the way the stream was created from its
source
+ * @param key representation of the way the stream was created from its
source, f.e. trancoding parameters
* @return cached stream node
*/
protected Node getCacheNode(Node src, final String key) {
@@ -365,7 +376,7 @@
}
final NodeManager caches =
src.getCloud().getNodeManager(src.getNodeManager().getProperty("org.mmbase.streams.cachestype"));
- Node newNode = caches.createNode();
+ Node newNode = caches.createNode();
newNode.setNodeValue("id", src);
newNode.setStringValue("key", key);
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 12:28:46 UTC (rev 40062)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
2009-12-01 16:03:46 UTC (rev 40063)
@@ -158,6 +158,8 @@
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/Processor.java
===================================================================
---
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Processor.java
2009-12-01 12:28:46 UTC (rev 40062)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Processor.java
2009-12-01 16:03:46 UTC (rev 40063)
@@ -314,7 +314,8 @@
/**
* Creates and submits a job transcoding everything as configured for one
source object, this
* produces all new 'streamssourcescaches' as configured in
createcaches.xml.
- * @param node source stream
+ * @param ntCloud a non transactional cloud
+ * @param node node number of a source stream
* @param logger a logger that keeps track
* @return job trans coding a source stream in (an)other stream(s)
*/
@@ -338,7 +339,7 @@
/**
* Creates caches nodes when not existing by creating a transcoding Job
* @param ntCloud a non transactional cloud
- * @param int node number
+ * @param int node number of a source node
* @return Job recognizing and/or transcoding the source stream
*/
public Job createCaches(final Cloud ntCloud, final int node) {
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 12:28:46 UTC (rev 40062)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/TranscoderResult.java
2009-12-01 16:03:46 UTC (rev 40063)
@@ -65,6 +65,7 @@
super.ready();
if (dest != null) {
File outFile = new File(directory,
dest.getStringValue("url").replace("/", File.separator));
+ LOG.info("Looking at: " + outFile);
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
