Author: michiel
Date: 2009-06-04 12:20:24 +0200 (Thu, 04 Jun 2009)
New Revision: 35704
Modified:
speeltuin/mihxil/streams/src/main/java/org/mmbase/streams/CreateCachesProcessor.java
Log:
javadoc
Modified:
speeltuin/mihxil/streams/src/main/java/org/mmbase/streams/CreateCachesProcessor.java
===================================================================
---
speeltuin/mihxil/streams/src/main/java/org/mmbase/streams/CreateCachesProcessor.java
2009-06-04 10:15:02 UTC (rev 35703)
+++
speeltuin/mihxil/streams/src/main/java/org/mmbase/streams/CreateCachesProcessor.java
2009-06-04 10:20:24 UTC (rev 35704)
@@ -74,6 +74,7 @@
}
ResourceWatcher watcher = null;
+
public void setConfigFile(final String configFile) {
watcher = new ResourceWatcher() {
@Override
@@ -147,10 +148,23 @@
+ /**
+ * Gets, and if necessary creates, the node representing the 'cached'
stream (the result of a
+ * conversion).
+ * @param node The original node
+ * @param mediaprovider
+ * @param mediafragment
+ * @param transcoder The transcoder providing the 'key'.
+ */
protected Node getCacheNode(final Node node, final Node mediaprovider,
final Node mediafragment, final Transcoder t, Logger logger) {
+ assert mediafragment != null;
+ assert mediaprovider != null;
+
final NodeManager caches =
node.getCloud().getNonTransactionalCloud().getNodeManager("streamsourcescaches");
+
+
NodeQuery q = caches.createQuery();
Queries.addConstraint(q, Queries.createConstraint(q, "id",
FieldCompareConstraint.EQUAL, node));
Queries.addConstraint(q, Queries.createConstraint(q, "key",
FieldCompareConstraint.EQUAL, t.getKey()));
@@ -158,14 +172,14 @@
Node resultNode;
if (nodes.size() > 0) {
resultNode = nodes.get(0);
- resultNode.setIntValue("state", State.REQUEST.getValue());
+ resultNode.setIntValue("state", State.REQUEST.getValue());
resultNode.commit();
} else {
resultNode = caches.createNode();
- resultNode.setIntValue("state", State.REQUEST.getValue());
+ resultNode.setIntValue("state", State.REQUEST.getValue());
resultNode.setStringValue("key", t.getKey());
- resultNode.setNodeValue("id", node);
+ resultNode.setNodeValue("id", node);
resultNode.commit();
// virtual field actually creates relation
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs