---

Batch.java

gehe zur Dokumentation dieser Datei

/*
 * $Source: /shared/cvsroot/diplom/app/src/java/de/picana/control/Batch.java,v $
 * $Author: mstolpe $
 * $Date: 2003/02/24 23:08:29 $
 * $Revision: 1.3 $
 * $Release$
 *
 * Created on 18. August 2002, 19:14
 *
 * Copyright 2002 by Marco Stolpe
 */

package de.picana.control;

import org.jdom.*;
import org.jdom.input.SAXBuilder;
import java.io.*;
import java.util.*;


public class Batch extends Task {

    private Random rand;
    private Hashtable taskinfo_hash;
    private Vector taskid_list;
    private Task act_task;
    
    
    public Batch() {
        LOGSRC = "control.Batch";
        taskinfo_hash = new Hashtable();
        taskid_list = new Vector();
        rand = new Random();
    }

    public void load(String filename) throws TaskException {
        try {
            File file = new File(filename);
            FileInputStream in = new FileInputStream(file);
            load(in);

        } catch (Exception e) {
            logger.error(LOGSRC, e.toString());
            throw new TaskException(e.toString());    
        }
    }
    
    public void load(InputStream in) throws TaskException {
        
        try {
            taskinfo_hash = new Hashtable();
            taskid_list = new Vector();
            
            SAXBuilder builder = new SAXBuilder(false);
            Document doc = builder.build(in);
            Element root = doc.getRootElement();
            
            List tasks = root.getChildren("task");
            
            Iterator i = tasks.iterator();
            while (i.hasNext()) {
                Element currentTask = (Element)i.next();
                
                String taskid = currentTask.getAttributeValue("id");
                if (taskid == null) {
                    String newid = String.valueOf(rand.nextInt());
                    while (taskinfo_hash.containsKey(newid))
                        newid = String.valueOf(rand.nextInt());
                    taskid = newid;
                }
                String taskname = currentTask.getAttributeValue("name");
                String classname = currentTask.getAttributeValue("class");
                ParameterSet set = constructParameterSet(currentTask);
                
                TaskInfo ti = new TaskInfo(taskid, taskname, classname, set);
                addTaskInfo(ti);
            }
            
        } catch (Exception e) {
            logger.error(LOGSRC, e.toString());
            throw new TaskException(e.toString());
        }
    }
    
    private ParameterSet constructParameterSet(Element setElem) {
        
        ParameterSet set = new ParameterSet();
        
        set.setName(setElem.getAttributeValue("name"));
        
        List parameterElements = setElem.getChildren("parameter");
            
        // Add parameters to this ParameterSet
            
        Iterator i = parameterElements.iterator();
        while (i.hasNext()) {
            Element currentParameter = (Element)i.next();
                
            String paramName = currentParameter.getAttributeValue("name");
                
            if (currentParameter.getAttributeValue("value") != null) {
                    
                // Add a single parameter value to ParameterSet
                    
                set.setParameter(paramName,
                    currentParameter.getAttributeValue("value"));
                
            } else {
                    
                // Add list of parameter values to ParameterSet
                
                Element elem = currentParameter.getChild("parameter");
                
                if (elem.getAttributeValue("name") != null) {
                    
                    // construct Hashtable
                    
                    Hashtable valueHash = new Hashtable();
                    
                    List valueElements = currentParameter.getChildren("parameter");
                    
                    Iterator j = valueElements.iterator();
                    while (j.hasNext()) {
                        Element currentParam = (Element)j.next();
                        valueHash.put(currentParam.getAttributeValue("name"),
                            currentParam.getAttributeValue("value"));
                    }
                    
                    set.setParameter(paramName, valueHash);
                    
                } else {
                
                    // construct Vector
                    
                    Vector valueList = new Vector();
                    
                    List valueElements = currentParameter.getChildren("parameter");
                    
                    Iterator j = valueElements.iterator();
                    while (j.hasNext()) {
                        Element currentValue = (Element)j.next();
                        valueList.addElement(
                            currentValue.getAttributeValue("value"));
                    }
                    
                    set.setParameter(paramName, valueList);
                }
            }
        }
            
        // Add parameter sets to this ParameterSet
           
        List paramSetElements = setElem.getChildren("parameter-set");
         
        i = paramSetElements.iterator();
        while (i.hasNext()) {
            Element currentParameterSet = (Element)i.next();
                
            ParameterSet cset = constructParameterSet(currentParameterSet);
            set.setParameter(cset.getName(), cset);
        }
            
        return set;
    }
    
    private void addTaskInfo(TaskInfo ti) {
        taskinfo_hash.put(ti.getId(), ti);
        taskid_list.addElement(ti.getId());
    }
    
    private TaskInfo getTaskInfo(String taskid) {
        return (TaskInfo)taskinfo_hash.get(taskid);
    }
    
    private Enumeration getTaskIds() {
        return taskid_list.elements();    
    }
    
    private Task getTask(String taskid) throws TaskException {
        Task task = null;
        try {
            TaskInfo ti = getTaskInfo(taskid);
            task = (Task)ti.getJavaClass().newInstance();
            task.init(ti.getParameterSet(), logger);
            
        } catch (Exception e) {
            throw new TaskException(e.toString());    
        }
        return task;
    }
    
    public void start() throws TaskException {
        
        try {
            logger.info(LOGSRC, "Started.");
            
            Enumeration taskids = getTaskIds();
            while (taskids.hasMoreElements()) {
                String taskid = (String)taskids.nextElement();
                act_task = getTask(taskid);
                act_task.start();
            }
            
            logger.info(LOGSRC, "Stopped.");
            
        } catch (Exception e) {
            throw new TaskException(e.toString());    
        }
    }
    
    public void stop() {
        act_task.stop();
    }
    
    public void pause() {
        act_task.pause();
    }
    
    public void resume() {
        act_task.resume();
    }
}

---