Author: andre
Date: 2009-11-22 21:17:13 +0100 (Sun, 22 Nov 2009)
New Revision: 39836
Modified:
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Processor.java
Log:
if I am correct this with the threadPools and stages is meant to be the other
way around
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-11-22 15:22:44 UTC (rev 39835)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/Processor.java
2009-11-22 20:17:13 UTC (rev 39836)
@@ -98,10 +98,10 @@
// fill the complete map, so we don't have to think about it any more
later on.
for (Stage s : Stage.values()) {
if (s.ordinal() < Stage.TRANSCODER.ordinal()) {
- threadPools.put(s, threadPools.get(Stage.TRANSCODER));
+ threadPools.put(s, threadPools.get(Stage.RECOGNIZER));
}
if (s.ordinal() > Stage.RECOGNIZER.ordinal()) {
- threadPools.put(s, threadPools.get(Stage.RECOGNIZER));
+ threadPools.put(s, threadPools.get(Stage.TRANSCODER));
}
}
for (Map.Entry<Stage, ThreadPoolExecutor> e : threadPools.entrySet()) {
@@ -273,7 +273,6 @@
} else {
return "Could not cancel " + job;
}
-
}
} else {
return "You may not cancel jobs";
@@ -306,7 +305,6 @@
return thisJob;
}
-
}
@@ -374,7 +372,7 @@
return clone;
}
- public void readExternal(ObjectInput in) throws IOException,
ClassNotFoundException {
+ public void readExternal(ObjectInput in) throws IOException,
ClassNotFoundException {
}
public void writeExternal(ObjectOutput stream) throws IOException {
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs
