/* -*- mode: java; c-basic-offset: 2; indent-tabs-mode: nil -*- */

/*
	Part of the Processing project - http://processing.org

	Copyright (c) 2004-06 Ben Fry and Casey Reas
	Copyright (c) 2001-04 Massachusetts Institute of Technology

	This program is free software; you can redistribute it and/or modify
	it under the terms of the GNU General Public License as published by
	the Free Software Foundation; either version 2 of the License, or
	(at your option) any later version.

	This program is distributed in the hope that it will be useful,
	but WITHOUT ANY WARRANTY; without even the implied warranty of
	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.	See the
	GNU General Public License for more details.

	You should have received a copy of the GNU General Public License
	along with this program; if not, write to the Free Software Foundation,
	Inc., 59 Temple Place, Suite 330, Boston, MA	02111-1307	USA
*/

package processing.mode.java.runner;

import java.io.*;


/**
 * Slurps up messages from compiler.
 */
public class MessageSiphon implements Runnable {
	BufferedReader streamReader;
	Thread thread;
	MessageConsumer consumer;


	public MessageSiphon(InputStream stream, MessageConsumer consumer) {
		this.streamReader = new BufferedReader(new InputStreamReader(stream));
		this.consumer = consumer;

		thread = new Thread(this);
		// don't set priority too low, otherwise exceptions won't
		// bubble up in time (i.e. compile errors have a weird delay)
		//thread.setPriority(Thread.MIN_PRIORITY);
		thread.setPriority(Thread.MAX_PRIORITY-1);
		//thread.start();
	}


	public void run() {
		try {
			// process data until we hit EOF; this will happily block
			// (effectively sleeping the thread) until new data comes in.
			// when the program is finally done, null will come through.
			//
			String currentLine;
			while ((currentLine = streamReader.readLine()) != null) {
				// \n is added again because readLine() strips it out
				//EditorConsole.systemOut.println("messaging in");
				consumer.message(currentLine + "\n");
				//EditorConsole.systemOut.println("messaging out");
			}
			//EditorConsole.systemOut.println("messaging thread done");
			thread = null;

		} catch (NullPointerException npe) {
			// Fairly common exception during shutdown
			thread = null;

		} catch (Exception e) {
			// On Linux and sometimes on Mac OS X, a "bad file descriptor"
			// message comes up when closing an applet that's run externally.
			// That message just gets supressed here..
			String mess = e.getMessage();
			if ((mess != null) &&
					(mess.indexOf("Bad file descriptor") != -1)) {
				//if (e.getMessage().indexOf("Bad file descriptor") == -1) {
				//System.err.println("MessageSiphon err " + e);
				//e.printStackTrace();
			} else {
				e.printStackTrace();
			}
			thread = null;
		}
	}
	
	
	public Thread getThread() {
		return thread;
	}
}
