[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller/pool PoolJobController.java,1.9,1.10

[Suresh <sur...@us...>]

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)