Author: michiel
Date: 2009-11-23 22:45:50 +0100 (Mon, 23 Nov 2009)
New Revision: 39875
Modified:
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
Log:
remove from runningJobs if ready or error
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-11-23 21:45:35 UTC (rev 39874)
+++
mmbase/trunk/applications/streams/src/main/java/org/mmbase/streams/createcaches/JobCallable.java
2009-11-23 21:45:50 UTC (rev 39875)
@@ -170,14 +170,15 @@
logger.info("READY " + thisJob + "(" +
thisJob.getNode().getNodeManager().getName() + ":" +
thisJob.getNode().getNumber() + ")");
//thisJob.getNode().commit();
thisJob.ready();
+ Processor.runningJobs.remove(thisJob.getNode().getNumber());
}
} catch (RuntimeException e) {
logger.error(e.getMessage(), e);
+ Processor.runningJobs.remove(thisJob.getNode().getNumber());
throw e;
} finally {
logger.info("FINALLY " + resultCount);
thisJob.notifyAll(); // notify waiters
- //runningJobs.remove(thisJob.getNode().getNumber());
}
logger.info("3: returning resultCount: " + resultCount);
return resultCount;
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs
