Update of /var/cvs/speeltuin/mihxil/streams/src/org/mmbase/streams
In directory james.mmbase.org:/tmp/cvs-serv18456/src/org/mmbase/streams
Modified Files:
CreateCachesProcessor.java
Log Message:
arranged state field
See also:
http://cvs.mmbase.org/viewcvs/speeltuin/mihxil/streams/src/org/mmbase/streams
Index: CreateCachesProcessor.java
===================================================================
RCS file:
/var/cvs/speeltuin/mihxil/streams/src/org/mmbase/streams/CreateCachesProcessor.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -b -r1.1 -r1.2
--- CreateCachesProcessor.java 24 Apr 2009 18:26:05 -0000 1.1
+++ CreateCachesProcessor.java 24 Apr 2009 18:43:30 -0000 1.2
@@ -15,6 +15,7 @@
import org.mmbase.bridge.util.Queries;
import org.mmbase.util.*;
import org.mmbase.datatypes.processors.*;
+import org.mmbase.applications.media.State;
import java.util.*;
import java.io.*;
import java.net.*;
@@ -57,6 +58,7 @@
resultNode = caches.createNode();
resultNode.setNodeValue("id", node);
resultNode.setStringValue("key", t.getKey());
+ resultNode.setIntValue("state", State.REQUEST.ordinal());
logger.service("Created " + resultNode);
}
return resultNode;
@@ -91,9 +93,13 @@
buf.append(ResourceLoader.getName(inFile.getName())).append(".").append(t.getExtension());
File outFile = new
File(FileServlet.getDirectory(), buf.toString().replace("/", File.separator));
try {
+ cacheNode.setIntValue("state",
State.BUSY.ordinal());
+ cacheNode.commit();
t.transcode(in, outFile.toURI(), logger);
cacheNode.setStringValue("url",
buf.toString());
+ cacheNode.setIntValue("state",
State.DONE.ordinal());
cacheNode.commit();
+
} catch (Exception e) {
logger.error(e.getMessage());
}
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs
