[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller/pool AbstractPoolJobLo
Brought to you by:
suresh_pragada
From: Suresh <sur...@us...> - 2006-03-04 04:42:14
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv22982 Modified Files: AbstractPoolJobLoader.java AbstractPoolJobProcessor.java CollectionJobPool.java DefaultCollectionJobPool.java JobPool.java OrderedCollectionJobPool.java PoolJobController.java PoolJobLoader.java PoolJobProcessor.java Log Message: no message Index: PoolJobLoader.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/PoolJobLoader.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** PoolJobLoader.java 3 Mar 2006 04:19:56 -0000 1.1 --- PoolJobLoader.java 4 Mar 2006 04:42:01 -0000 1.2 *************** *** 1,4 **** package org.jmonks.batchserver.framework.controller.pool; ! import org.jmonks.batchserver.framework.config.*; /** --- 1,4 ---- package org.jmonks.batchserver.framework.controller.pool; ! import java.util.Map; /** *************** *** 10,15 **** public interface PoolJobLoader { - public void initialize(org.jmonks.batchserver.framework.controller.pool.JobPool pool, org.jmonks.batchserver.framework.config.PoolJobLoaderConfig config); - public void cleanup(); --- 10,13 ---- Index: JobPool.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/JobPool.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** JobPool.java 3 Mar 2006 04:19:56 -0000 1.1 --- JobPool.java 4 Mar 2006 04:42:01 -0000 1.2 *************** *** 1,5 **** package org.jmonks.batchserver.framework.controller.pool; ! ! import org.jmonks.batchserver.framework.config.*; /** --- 1,4 ---- package org.jmonks.batchserver.framework.controller.pool; ! import java.util.Map; /** *************** *** 17,21 **** public Object getNextJobData(); ! public void initialize(org.jmonks.batchserver.framework.config.JobPoolConfig config); public void cleanup(); --- 16,20 ---- public Object getNextJobData(); ! public void initialize(Map configProps); public void cleanup(); Index: AbstractPoolJobProcessor.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/AbstractPoolJobProcessor.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** AbstractPoolJobProcessor.java 3 Mar 2006 04:19:56 -0000 1.1 --- AbstractPoolJobProcessor.java 4 Mar 2006 04:42:01 -0000 1.2 *************** *** 1,8 **** package org.jmonks.batchserver.framework.controller.pool; ! ! import org.jmonks.batchserver.framework.*; ! import org.jmonks.batchserver.framework.config.*; ! import org.jmonks.batchserver.framework.controller.pool; ! import org.jmonks.batchserver.framework.controller.pool; --- 1,4 ---- package org.jmonks.batchserver.framework.controller.pool; ! import java.util.Map; *************** *** 23,27 **** } ! public abstract void initialize(org.jmonks.batchserver.framework.config.PoolJobProcessorConfig config); public boolean suspend() --- 19,23 ---- } ! public abstract void initialize(Map configProps); public boolean suspend() *************** *** 40,46 **** } - public void initialize(org.jmonks.batchserver.framework.controller.pool.JobPool pool, org.jmonks.batchserver.framework.config.PoolJobProcessorConfig config) - { - } public abstract void cleanup(); --- 36,39 ---- Index: PoolJobProcessor.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/PoolJobProcessor.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** PoolJobProcessor.java 3 Mar 2006 04:19:56 -0000 1.1 --- PoolJobProcessor.java 4 Mar 2006 04:42:01 -0000 1.2 *************** *** 1,4 **** --- 1,6 ---- package org.jmonks.batchserver.framework.controller.pool; + import java.util.Map; + /** * Processor is the one which processes the job data. This interface defines the responsiblities of the job processor. *************** *** 15,20 **** public boolean stop(); - public void initialize(org.jmonks.batchserver.framework.controller.pool.JobPool pool, org.jmonks.batchserver.framework.config.PoolJobProcessorConfig config); - public void cleanup(); --- 17,20 ---- Index: DefaultCollectionJobPool.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/DefaultCollectionJobPool.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** DefaultCollectionJobPool.java 3 Mar 2006 04:19:56 -0000 1.1 --- DefaultCollectionJobPool.java 4 Mar 2006 04:42:01 -0000 1.2 *************** *** 1,4 **** --- 1,6 ---- package org.jmonks.batchserver.framework.controller.pool; + import java.util.List; + /** * <p> Index: AbstractPoolJobLoader.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/AbstractPoolJobLoader.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** AbstractPoolJobLoader.java 3 Mar 2006 04:19:56 -0000 1.1 --- AbstractPoolJobLoader.java 4 Mar 2006 04:42:01 -0000 1.2 *************** *** 1,6 **** package org.jmonks.batchserver.framework.controller.pool; - import org.jmonks.batchserver.framework.config.*; - import org.jmonks.batchserver.framework.controller.pool; --- 1,5 ---- package org.jmonks.batchserver.framework.controller.pool; + import java.util.Map; *************** *** 22,30 **** public abstract int loadJobData(); ! public abstract void initialize(org.jmonks.batchserver.framework.config.PoolJobLoaderConfig config); public abstract Object getNextLoadableJobData(); ! public void initialize(org.jmonks.batchserver.framework.controller.pool.JobPool pool, org.jmonks.batchserver.framework.config.PoolJobLoaderConfig config) { } --- 21,29 ---- public abstract int loadJobData(); ! public abstract void initialize(Map configProps); public abstract Object getNextLoadableJobData(); ! public void initialize(Map configProps,org.jmonks.batchserver.framework.controller.pool.JobPool pool) { } *************** *** 58,64 **** return null; } - - public void initialize(Map configProps, org.jmonks.batchserver.framework.controller.pool.JobPool pool) - { - } } --- 57,59 ---- Index: OrderedCollectionJobPool.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/OrderedCollectionJobPool.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** OrderedCollectionJobPool.java 3 Mar 2006 04:19:56 -0000 1.1 --- OrderedCollectionJobPool.java 4 Mar 2006 04:42:01 -0000 1.2 *************** *** 1,4 **** --- 1,6 ---- package org.jmonks.batchserver.framework.controller.pool; + import java.util.List; + /** Index: PoolJobController.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/PoolJobController.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** PoolJobController.java 3 Mar 2006 04:19:56 -0000 1.1 --- PoolJobController.java 4 Mar 2006 04:42:01 -0000 1.2 *************** *** 1,8 **** package org.jmonks.batchserver.framework.controller.pool; ! import org.jmonks.batchserver.framework.*; import org.jmonks.batchserver.framework.controller.JobController; ! import org.jmonks.batchserver.framework.controller.*; ! import org.jmonks.batchserver.framework.mgmtmntr.*; ! import org.jmonks.batchserver.framework.common.*; --- 1,6 ---- package org.jmonks.batchserver.framework.controller.pool; ! import org.jmonks.batchserver.framework.config.JobControllerConfig; import org.jmonks.batchserver.framework.controller.JobController; ! *************** *** 52,55 **** --- 50,54 ---- public PoolJobController(JobControllerConfig config) { + } *************** *** 57,61 **** { ! return null; } --- 56,61 ---- { ! return null; ! } *************** *** 70,74 **** { ! return 0; } --- 70,77 ---- { ! return 0; ! ! ! } *************** *** 82,86 **** { ! return 0; } --- 85,91 ---- { ! return 0; ! ! } *************** *** 90,98 **** * @return Returns the number of threads controller created to process this job. */ ! public String getThreadIDList() { ! return null; } --- 95,105 ---- * @return Returns the number of threads controller created to process this job. */ ! public java.lang.String[] getThreadIDList() { ! return null; ! ! } *************** *** 107,111 **** { ! return null; } --- 114,120 ---- { ! return null; ! ! } *************** *** 119,123 **** { ! return null; } --- 128,134 ---- { ! return null; ! ! } *************** *** 128,132 **** { ! return true; } --- 139,144 ---- { ! return true; ! } *************** *** 139,143 **** { ! return true; } --- 151,156 ---- { ! return true; ! } *************** *** 150,154 **** { ! return true; } --- 163,168 ---- { ! return true; ! } Index: CollectionJobPool.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/CollectionJobPool.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** CollectionJobPool.java 3 Mar 2006 04:19:56 -0000 1.1 --- CollectionJobPool.java 4 Mar 2006 04:42:01 -0000 1.2 *************** *** 1,4 **** --- 1,7 ---- package org.jmonks.batchserver.framework.controller.pool; + import java.util.List; + import java.util.Map; + /** * <p> *************** *** 27,31 **** } ! public void initialize(org.jmonks.batchserver.framework.config.JobPoolConfig config) { } --- 30,34 ---- } ! public void initialize(Map configProps) { } |