/*
 *                 Sun Public License Notice
 * 
 * The contents of this file are subject to the Sun Public License
 * Version 1.0 (the "License"). You may not use this file except in
 * compliance with the License. A copy of the License is available at
 * http://www.sun.com/
 * 
 * The Original Code is NetBeans. The Initial Developer of the Original
 * Code is Sun Microsystems, Inc. Portions Copyright 1997-2000 Sun
 * Microsystems, Inc. All Rights Reserved.
 */

package org.openide.compiler;

import java.io.IOException;
import java.io.BufferedReader;
import java.io.InputStreamReader;


import org.openide.filesystems.*;
import org.openide.ErrorManager;

/** Connected to stdout/stderr external compiler - parses errors
*
* @author Ales Novak
*/
final class ErrorsParsingThread extends Thread {

    /** reference for firing errors */
    private ExternalCompilerGroup compiler;

    /** parsed stream */
    private BufferedReader parsedReader;

    /** flag for parsing loop whether continue or not */
    private boolean stopParsing = false;
    
    /** The ErrorExpression */
    private ExternalCompiler.ErrorExpression err;

    /**
    * @param is is an InputStream that is parsed
    * @param ExternalCompilerGroup is a refernce to class through
    * that errors are fired
    * @param classPath is a classpath of external process
    */
    ErrorsParsingThread(java.io.InputStream is,
                        ExternalCompilerGroup c,
                        ExternalCompiler.ErrorExpression err
                       ) {

        this.compiler = c;
        this.err = err;
        parsedReader = new BufferedReader(new InputStreamReader(is));
    }


    /** stops parsing
    * @param hardStop ignored
    */
    void stopParsing(boolean hardStop) {
        stopParsing = true;
        try {
            join();
        } catch (InterruptedException ex) { // ignore
        }
    }

    /** reads input stream, parses it and reports errors */
    public void run() {
        try {
            compiler.parseErrors(err, parsedReader);
        } catch (RuntimeException e) {
            synchronized (System.err) {
                System.err.println("ERR: " + Thread.currentThread());
                e.printStackTrace();
            }
            throw e;
        } finally {
            try {
                parsedReader.close();
            } catch (IOException e) {
                ErrorManager.getDefault().notify(e);
            }
        }
    }
}