batchserver-cvs

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

Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic
In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv15837/jmonks/batchserver/framework/controller/basic

Modified Files:
	BasicJobController.java 
Log Message:
no message

Index: BasicJobController.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic/BasicJobController.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -C2 -d -r1.10 -r1.11
*** BasicJobController.java	19 May 2006 18:55:17 -0000	1.10
--- BasicJobController.java	24 May 2006 14:33:59 -0000	1.11
***************
*** 3,13 ****
  import EDU.oswego.cs.dl.util.concurrent.CountDown;
  import EDU.oswego.cs.dl.util.concurrent.FutureResult;
! import java.util.ArrayList;
  import java.util.HashMap;
  import java.util.Hashtable;
  import java.util.Iterator;
- import java.util.List;
  import java.util.Map;
  import org.apache.log4j.Logger;
  import org.jmonks.batchserver.framework.common.ErrorCode;
  import org.jmonks.batchserver.framework.config.BasicJobControllerConfig;
--- 3,13 ----
  import EDU.oswego.cs.dl.util.concurrent.CountDown;
  import EDU.oswego.cs.dl.util.concurrent.FutureResult;
! import java.util.Calendar;
  import java.util.HashMap;
  import java.util.Hashtable;
  import java.util.Iterator;
  import java.util.Map;
  import org.apache.log4j.Logger;
+ import org.jmonks.batchserver.framework.JobStatistics;
  import org.jmonks.batchserver.framework.common.ErrorCode;
  import org.jmonks.batchserver.framework.config.BasicJobControllerConfig;
***************
*** 40,43 ****
--- 40,47 ----
       */
      private Map jobProcessorsResultMap=new Hashtable();
+     /**
+      *  Holds the statistics of the basic job controller.
+      */
+     private JobStatistics jobStatistics=null;
      
      private static Logger logger=Logger.getLogger(BasicJobController.class);
***************
*** 71,74 ****
--- 75,80 ----
          CountDown countDownLock=new CountDown(threadCount);
          logger.debug("Going to create " + threadCount + " basic job processor(s)");
+         this.jobStatistics=new JobStatistics(super.getJobName());
+         this.jobStatistics.setStartTime(Calendar.getInstance().getTime());
          for(int i=0;i<threadCount;i++)
          {
***************
*** 345,348 ****
--- 351,357 ----
          }
          
+         this.jobStatistics.setEndTime(Calendar.getInstance().getTime());
+         this.jobStatistics.setRecordsProcessed(this.getProcessedRecordsCount());
+         
          for(Iterator iterator=this.jobProcessorsResultMap.values().iterator();iterator.hasNext();)
          {
***************
*** 357,359 ****
--- 366,379 ----
          return returnCode;
      }
+     
+     /**
+      *  @see org.jmonks.batchserver.framework.controller.JobController#getJobStatistics()
+      */
+     public JobStatistics getJobStatistics()
+     {
+         if(this.jobStatistics.getEndTime()!=null)
+             return this.jobStatistics;
+         else
+             return null;
+     }
  }