/**********************************************************************
 * Copyright (c) 2003 IBM Corporation and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Common Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/cpl-v10.html
 *
 * Contributors:
 *    IBM - Initial API and implementation
 **********************************************************************/
package net.sourceforge.phpdt.monitor.core.internal;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
/**
 * Monitor server I/O thread.
 */
public class DefaultThread extends Thread {
	private static final int BUFFER = 2048;
	protected InputStream in;
	protected OutputStream out;
	protected boolean isRequest;
	
	protected Connection conn;
	protected Request request;

	/**
	 * MonitorThread constructor comment.
	 */
	public DefaultThread(Connection conn, Request request, InputStream in, OutputStream out, boolean isRequest) {
		super();
		this.conn = conn;
		this.request = request;
		this.in = in;
		this.out = out;
		this.isRequest = isRequest;
		setPriority(Thread.NORM_PRIORITY + 1);
		setDaemon(true);
	}

	/**
	 * Listen for input, save it, and pass to the output stream.
	 */
	public void run() {
		try {
			byte[] b = new byte[BUFFER];
			int n = in.read(b);
			while (n > 0) {
				out.write(b, 0, n);
				if (b != null && n > 0) {
					byte[] x = null;
					if (n == BUFFER)
						x = b;
					else {
						x = new byte[n];
						System.arraycopy(b, 0, x, 0, n);
					}
					if (isRequest)
						request.addToRequest(x);
					else
						request.addToResponse(x);
				}
				n = in.read(b);
				Thread.yield();
			}
			out.flush();
		} catch (IOException e) {
		} finally {
			request.fireChangedEvent();
			if (!isRequest)
				conn.close();
		}
	}
}