process/execution/DefaultProcessMonitor.java

	DefaultProcessMonitor.java revision 2
/*
 * Created on Jun 27, 2005
 */
package org.mindswap.owls.process.execution;

import java.io.PrintWriter;
import java.io.Writer;
import java.util.Iterator;

import org.mindswap.exceptions.ExecutionException;
import org.mindswap.owl.OWLIndividual;
import org.mindswap.owl.OWLValue;
import org.mindswap.owls.process.Input;
import org.mindswap.owls.process.Output;
import org.mindswap.owls.process.Process;
import org.mindswap.query.ValueMap;

/**
 * A simple process monitor implementation that prints the progress to console
 *
 * @author Evren Sirin
 *
 */
public class DefaultProcessMonitor implements ProcessMonitor {
    private PrintWriter out;
    private int monitorFilter;

    public DefaultProcessMonitor() {
        this( new PrintWriter( System.out ) );
    }

    public DefaultProcessMonitor( Writer writer ) {
        monitorFilter = Process.ANY;

        setWriter( writer );
    }

    public void setWriter( Writer writer ) {
        this.out = (writer instanceof PrintWriter)
            ? (PrintWriter) writer
            : new PrintWriter( writer );
    }

    public void executionStarted() {
        out.println();
        out.flush();
    }

    public void executionFinished() {
        out.println();
        out.flush();
    }

    public void executionStarted(Process process, ValueMap inputs) {
        out.println( "Start executing process " + process );
        out.println( "Inputs: ");
        for(Iterator i = process.getInputs().iterator(); i.hasNext();) {
            Input input = (Input) i.next();
            out.print( input.toPrettyString() + " =  " );
            OWLValue value = inputs.getValue( input );
            if( value == null )
                value = input.getConstantValue();
            if( value == null )
                out.println( "<< NO VALUE >>" );
            else if( value.isDataValue() )
                out.println( value );
            else {
                OWLIndividual ind = (OWLIndividual) value;
                if( ind.isAnon() )
                    out.println( ind.toRDF( false ) );
                else
                    out.println( value );
            }

        }
        out.flush();
    }

    public void executionFinished(Process process, ValueMap inputs, ValueMap outputs) {
        out.println( "Execution finished for " + process );
        out.println( "Outputs: ");
        for(Iterator i = process.getOutputs().iterator(); i.hasNext();) {
            Output output = (Output) i.next();
            out.print( output.toPrettyString() + " =  ");
            OWLValue value = outputs.getValue( output );
            if( value == null )
                out.println( "<< NO VALUE >>" );
            else if( value.isDataValue() )
                out.println( value );
            else {
                OWLIndividual ind = (OWLIndividual) value;
                if( ind.isAnon() )
                    out.println( ind.toRDF( false ) );
                else
                    out.println( value );
            }
        }
        out.flush();
    }

    public void executionFailed(ExecutionException e) {
        out.println( "Execution failed: ");
        out.println( e );
        out.flush();
    }

    public void setMonitorFilter(int processType) {
        monitorFilter = processType;
    }

    public int getMonitorFilter() {
        return monitorFilter;
    }
}