/*

 * Copyright (c) 2008-2010 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:  Definitions for the class EpocReader

 *

 */

package com.nokia.s60tools.analyzetool.engine;

import java.io.BufferedReader;

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStreamReader;

import org.eclipse.core.resources.IProject;

import org.eclipse.core.runtime.IProgressMonitor;

import org.eclipse.core.runtime.IStatus;

import org.eclipse.core.runtime.Status;

import org.eclipse.core.runtime.jobs.Job;

import com.nokia.s60tools.analyzetool.global.Constants;

import com.nokia.s60tools.analyzetool.global.Util;

import com.nokia.s60tools.analyzetool.ui.MainView;

/**

 * Creates new job for polling epocwind.out file

 * @author kihe

 */

	private final String emulatorFileLocation;

	boolean alreadyStarted = false;

	static final int POLL_INTERVAL = 1000; // 1 second

	long fileSize = -1;

	/**

	 */

	long readCharacters = 0;

	IProject project;

	MainView main;

	boolean stillRun = true;

	/**

	 * Constructor

	 */

		super(Constants.OUTPUT_READER_TITLE);

		project = projectRef;

		main = parentClass;

	}

	/**

	 * Starts epocwind.out file reading

	 */

			return;

		}

		setPriority(Job.LONG);

		setUser(false);

		schedule();

		alreadyStarted = true;

	}

	/**

	 * Stops listening emulator

	 */

	public void stop() {

		alreadyStarted = false;

		fileSize = -1;

		readCharacters = 0;

		stillRun = false;

		cancel();

	}

	/**

	 * Reads the epocwind.out file if it has been changed since last time

	 */

	@Override

	protected IStatus run(IProgressMonitor arg0) {

		FileInputStream fis = null;

		BufferedReader br = null;

			try {

				File epocFile = new File(emulatorFileLocation);

				if (epocFile.exists()) {

					// emulator output is not read

					// so we need to thru existing data of emulator output,

					// because we are only interested of new data.

					if (fileSize == -1) {

						fileSize = epocFile.length();

						fis = new FileInputStream(epocFile);

						br.skip(readCharacters);

						String line = "";

						// read all new lines of epocwind.out file

						while ((line = br.readLine()) != null) {

						}

					} else if (epocFile.length() > fileSize) {

						fis = new FileInputStream(epocFile);

						br.skip(readCharacters);

						String line = "";

						// read all new lines in epocwind.out

						while ((line = br.readLine()) != null) {

						}

						fileSize = epocFile.length();

						main.updateAllocNumber();

						fileSize = 0;

						readCharacters = 0;

					}

				}

					br.close();

					br = null;

				}

					fis.close();

					fis = null;

				}

				Thread.sleep(POLL_INTERVAL);

			} catch (InterruptedException ie) {

				cancel();

			} catch (Exception e) {

				e.printStackTrace();

				cancel();

						br.close();

					}

					ioe.printStackTrace();

				}

						fis.close();

					}

					ioe.printStackTrace();

				}

			}

		}

		return Status.OK_STATUS;

	}

}