/*
 * Copyright (c) 2013 Faculty of Computer Science, University of Vienna
 * 
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 * 
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 * 
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */

package univie.cs.psps.utils;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;

import org.apache.commons.io.FileUtils;

import peersim.config.Configuration;
import peersim.core.Control;
import peersim.core.Network;

/**
 * Observes the results of an {@link AggregationProtocol} and determines when to
 * stop the execution of the protocol.
 * <p>
 * This control expects the following parameters in the configuration file:
 * <p>
 * <blockquote>{@code protocol} - the name of protocol to observe.<br/>
 * {@code precision} - stop the execution when the variance of all estimates is
 * less than or equal to {@code precision}.<br/>
 * {@code plotfile} - (optional) name of a file to write the output to . If this
 * parameter is set, the output will be formatted for Gnuplot.<br/>
 * </blockquote>
 * 
 * @author Dario Seidl
 * 
 */
public class AggregationProtocolObserver implements Control
{
	private static final String PAR_PROTOCOL = "protocol";
	private static final String PAR_PRECISION = "precision";
	private static final String PAR_PLOTFILE = "plotfile";
	private static final String VAR_CLUSTERS = "CLUSTERS";

	private final int protocolID;
	private final double precision;
	private final File plotFile;
	private final int clusters;

	/**
	 * The standard constructor called by the simulator, reading parameters from
	 * the configuration file.
	 * 
	 * @param prefix
	 *            the prefix for this control in the configuration file.
	 */
	public AggregationProtocolObserver(String prefix) throws FileNotFoundException
	{
		protocolID = Configuration.getPid(prefix + "." + PAR_PROTOCOL);
		precision = Configuration.getDouble(prefix + "." + PAR_PRECISION, -1);

		plotFile = (Configuration.contains(prefix + "." + PAR_PLOTFILE)) ? new File(Configuration.getString(prefix + "." + PAR_PLOTFILE))
				: null;

		clusters = Configuration.getInt(VAR_CLUSTERS, 1);
	}

	@Override
	public boolean execute()
	{
		if (plotFile != null)
		{
			return printPlotStats();
		}
		else
		{
			return printDetailedStats();
		}
	}

	private boolean printDetailedStats()
	{
		long time = peersim.core.CommonState.getTime();

		if (time == 0)
		{
			String line = FormattedStatistics.repeatChar('-', 34 + FormattedStatistics.header().length());
			System.out.format("%n%16s %16s %s %n%s%n", "time", "", FormattedStatistics.header(), line);
		}

		FormattedStatistics trueValues = new FormattedStatistics();

		for (int i = 0; i < Network.size(); i++)
		{
			AggregationProtocol protocol = (AggregationProtocol) Network.get(i).getProtocol(protocolID);
			trueValues.addValue(protocol.getTrueValue());
		}

		FormattedStatistics estimates = new FormattedStatistics();
		FormattedStatistics errors = new FormattedStatistics();

		for (int i = 0; i < Network.size(); i++)
		{
			AggregationProtocol protocol = (AggregationProtocol) Network.get(i).getProtocol(protocolID);
			estimates.addValue(protocol.getEstimate());
			errors.addValue(protocol.getEstimate() - trueValues.getMean());
		}

		System.out.format("%16d %16s %s%n%16s %16s %s%n%16s %16s %s%n%n", time, "true:", trueValues, "", "estimate:", estimates, "",
				"errors:", errors);

		// TODO is the first condition needed?
		return /* !Double.isInfinite(estimates.getMax()) && */estimates.getVariance() <= precision;
	}

	private boolean printPlotStats()
	{
		try
		{
			long time = peersim.core.CommonState.getTime();

			if (time == 0)
			{
				String line = FormattedStatistics.repeatChar('-',
						51 + FormattedStatistics.header().length() + FormattedStatistics.header("(err)").length());
				FileUtils.writeStringToFile(
						plotFile,
						String.format("#%15s %s %s %16s %16s%n#%s%n", "time", FormattedStatistics.header(),
								FormattedStatistics.header("(err)"), "true", "clusters", line), true);
			}

			FormattedStatistics trueValues = new FormattedStatistics();

			for (int i = 0; i < Network.size(); i++)
			{
				AggregationProtocol protocol = (AggregationProtocol) Network.get(i).getProtocol(protocolID);
				trueValues.addValue(protocol.getTrueValue());
			}

			FormattedStatistics estimates = new FormattedStatistics();
			FormattedStatistics errors = new FormattedStatistics();

			for (int i = 0; i < Network.size(); i++)
			{
				AggregationProtocol protocol = (AggregationProtocol) Network.get(i).getProtocol(protocolID);
				estimates.addValue(protocol.getEstimate());
				errors.addValue(protocol.getEstimate() - trueValues.getMean());
			}

			// TODO is the first condition needed?
			boolean stop = /* !Double.isInfinite(estimates.getMax()) && */estimates.getVariance() <= precision;

			if (stop)
			{
				FileUtils.writeStringToFile(plotFile,
						String.format("%16d %s %s %16e %16d%n", time, estimates, errors, trueValues.getMean(), clusters), true);
			}

			return stop;
		}
		catch (IOException e)
		{
			throw new RuntimeException(e);
		}
	}
}

@@ -4331,103 +4331,15 @@
 %0A%0A%09%09
-// TODO is the first condition needed?%0A%09%09return /* !Double.isInfinite(estimates.getMax()) && */
+return 
 esti
@@ -5537,112 +5537,23 @@
 %0A%09%09%09
-// TODO is the first condition needed?%0A%09%09%09boolean stop = /* !Double.isInfinite(estimates.getMax()) && */
+boolean stop = 
 esti

Remove infinite check in observer