Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool
In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv17021/org/jmonks/batchserver/framework/controller/pool
Modified Files:
PoolJobController.java
Log Message:
no message
Index: PoolJobController.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/PoolJobController.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -C2 -d -r1.9 -r1.10
*** PoolJobController.java 19 May 2006 18:55:17 -0000 1.9
--- PoolJobController.java 20 May 2006 04:40:43 -0000 1.10
***************
*** 13,16 ****
--- 13,21 ----
import org.jmonks.batchserver.framework.management.ProcessorState;
import org.jmonks.batchserver.framework.management.ProcessorStatus;
+ import org.jmonks.batchserver.framework.common.*;
+ import org.jmonks.batchserver.framework.controller.*;
+ import org.jmonks.batchserver.framework.management.*;
+ import EDU.oswego.cs.dl.util.concurrent.*;
+ import java.util.*;
/**
***************
*** 57,61 ****
* </table>
* </p>
! *
* @author Suresh Pragada
* @version 1.0
--- 62,66 ----
* </table>
* </p>
! *
* @author Suresh Pragada
* @version 1.0
***************
*** 74,77 ****
--- 79,86 ----
*/
private Map jobProcessorsResultMap=new Hashtable();
+ /**
+ * Job pool reference being used by the loader and processor.
+ */
+ private JobPool pool=null;
private static Logger logger=Logger.getLogger(PoolJobController.class);
***************
*** 102,106 ****
* Create and initialize the pool
*/
! JobPool pool=(JobPool)this.getInstance(poolJobControllerConfig.getPoolClassName());
pool.initialize(poolJobControllerConfig.getPoolConfigProperties());
--- 111,115 ----
* Create and initialize the pool
*/
! this.pool=(JobPool)this.getInstance(poolJobControllerConfig.getPoolClassName());
pool.initialize(poolJobControllerConfig.getPoolConfigProperties());
***************
*** 364,367 ****
--- 373,378 ----
countDownLock.acquire();
logger.info("Loader and all processor(s) have finished their task.");
+ /** As per the contract cleanup the pool. */
+ this.pool.cleanup();
}
catch(InterruptedException exception)
|
