--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/testdev/ite/src/com.nokia.testfw.launch/src/com/nokia/testfw/launch/monitor/LogMonitor.java	Tue Mar 30 14:39:29 2010 +0800
@@ -0,0 +1,142 @@
+/*
+ * Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies). 
+ * All rights reserved.
+ * This component and the accompanying materials are made available
+ * under the terms of "Eclipse Public License v1.0"
+ * which accompanies this distribution, and is available
+ * at the URL "http://www.eclipse.org/legal/epl-v10.html".
+ *
+ * Initial Contributors:
+ * Nokia Corporation - initial contribution.
+ *
+ * Contributors:
+ *
+ * Description:
+ *
+ */
+package com.nokia.testfw.launch.monitor;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.Set;
+
+import org.eclipse.debug.core.model.IProcess;
+
+import com.nokia.testfw.core.model.result.TestRunResult;
+import com.nokia.testfw.launch.TFWLaunchPlugin;
+import com.nokia.testfw.resultview.model.TestRunSession;
+
+/**
+ * Monitor stf log file during test progress. It will create a test result
+ * object and continue update the result during test execution according to real
+ * time information get from stf log file
+ * 
+ * @see TestRunResult
+ * @author kevin wang
+ * 
+ */
+public class LogMonitor extends Thread {
+
+	private boolean iStop = false;
+	private Map<TestRunSession, InputStream> iMonitorSessions = new HashMap<TestRunSession, InputStream>();
+	private Set<TestRunSession> iTerminatedSessions = new HashSet<TestRunSession>();
+
+	public void addTestRunSession(TestRunSession session) {
+		synchronized (iMonitorSessions) {
+			iMonitorSessions.put(session, session.getInputStream());
+			iMonitorSessions.notifyAll();
+		}
+	}
+
+	public void removeTestRunSession(TestRunSession session) {
+		synchronized (iMonitorSessions) {
+			iMonitorSessions.remove(session);
+			iMonitorSessions.notifyAll();
+		}
+	}
+
+	/*
+	 * (non-Javadoc)
+	 * 
+	 * @see java.lang.Thread#run()
+	 */
+	@Override
+	public void run() {
+		long count;
+		int readlength;
+		byte[] buffer = new byte[4096];
+		while (!iStop) {
+			count = 0;
+			iTerminatedSessions.clear();
+			synchronized (iMonitorSessions) {
+				if (iMonitorSessions.isEmpty()) {
+					try {
+						iMonitorSessions.wait();
+					} catch (InterruptedException ignore) {
+					}
+				}
+				for (TestRunSession session : iMonitorSessions.keySet()) {
+					if (session.isClosed()) {
+						iTerminatedSessions.add(session);
+					} else {
+						InputStream stream = iMonitorSessions.get(session);
+						try {
+							if (stream == null) {
+								stream = session.getInputStream();
+								if (stream == null) {
+									continue;
+								} else {
+									iMonitorSessions.put(session, stream);
+									stream.reset();
+								}
+							}
+							if (stream.available() > 0) {
+								StringBuilder builder = new StringBuilder();
+								while ((readlength = stream.read(buffer)) > -1) {
+									builder.append(new String(buffer, 0,
+											readlength));
+									count = count + readlength;
+								}
+								session.update(builder.toString());
+							}
+						} catch (IOException e) {
+							TFWLaunchPlugin.log(e);
+						}
+					}
+					boolean isTerminated = true;
+					IProcess[] lProcesses = session.getLaunch().getProcesses();
+					for (IProcess process : lProcesses) {
+						if (!process.isTerminated()) {
+							isTerminated = false;
+							break;
+						}
+					}
+					if (isTerminated && lProcesses.length > 0) {
+						iTerminatedSessions.add(session);
+						session.close();
+					}
+				}
+				for (TestRunSession session : iTerminatedSessions) {
+					iMonitorSessions.remove(session);
+				}
+				if (count == 0) {
+					try {
+						iMonitorSessions.wait(100);
+					} catch (InterruptedException ignore) {
+					}
+				}
+			}
+		}
+		for (TestRunSession session : iMonitorSessions.keySet()) {
+			session.close();
+		}
+	}
+
+	public void stopme() {
+		iStop = true;
+		iMonitorSessions.notifyAll();
+	}
+}