[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller/basic BasicJobContro
Brought to you by:
suresh_pragada
From: Suresh <sur...@us...> - 2006-09-13 04:49:51
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv20831/framework/controller/basic Modified Files: BasicJobController.java BasicJobProcessor.java Log Message: no message Index: BasicJobProcessor.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic/BasicJobProcessor.java,v retrieving revision 1.10 retrieving revision 1.11 diff -C2 -d -r1.10 -r1.11 *** BasicJobProcessor.java 29 Aug 2006 02:01:32 -0000 1.10 --- BasicJobProcessor.java 13 Sep 2006 04:49:46 -0000 1.11 *************** *** 166,170 **** * @return Returns the number of records/jobs this processor is going to process. */ ! public abstract int getTotalRecordsCount(); /** --- 166,170 ---- * @return Returns the number of records/jobs this processor is going to process. */ ! public abstract long getTotalRecordsCount(); /** *************** *** 174,177 **** * @return Returns the number of records/jobs this processor has finished processing. */ ! public abstract int getProcessedRecordsCount(); } --- 174,177 ---- * @return Returns the number of records/jobs this processor has finished processing. */ ! public abstract long getProcessedRecordsCount(); } Index: BasicJobController.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic/BasicJobController.java,v retrieving revision 1.13 retrieving revision 1.14 diff -C2 -d -r1.13 -r1.14 *** BasicJobController.java 10 Sep 2006 17:58:07 -0000 1.13 --- BasicJobController.java 13 Sep 2006 04:49:46 -0000 1.14 *************** *** 100,107 **** * @return Returns the total number of records the job going to process. */ ! public int getExpectedRecordsCount() { logger.trace("Entering getExpectedRecordsCount"); ! int expectedRecordsCount=0; for(Iterator iterator=this.jobProcessorsMap.values().iterator();iterator.hasNext();) --- 100,107 ---- * @return Returns the total number of records the job going to process. */ ! public long getExpectedRecordsCount() { logger.trace("Entering getExpectedRecordsCount"); ! long expectedRecordsCount=0; for(Iterator iterator=this.jobProcessorsMap.values().iterator();iterator.hasNext();) *************** *** 120,127 **** * @return Returns the count of processed records. */ ! public int getProcessedRecordsCount() { logger.trace("Entering getProcessedRecordsCount"); ! int processedRecordsCount=0; for(Iterator iterator=this.jobProcessorsMap.values().iterator();iterator.hasNext();) --- 120,127 ---- * @return Returns the count of processed records. */ ! public long getProcessedRecordsCount() { logger.trace("Entering getProcessedRecordsCount"); ! long processedRecordsCount=0; for(Iterator iterator=this.jobProcessorsMap.values().iterator();iterator.hasNext();) |