import org.javasim.*;

/*
Monitors the cumulative response time during consecutive periods for the purpose
of identifying possible serial correlation between the successive samples.

Foresees Experiment_count independent experiments for statistical analysis purposes
*/

public class Reporter extends SimulationProcess
{
public Reporter(int Experiment_count, int Sample_count, long interval)
{
	check=interval;
	E_count=Experiment_count;
	S_count=Sample_count;

}
public void run ()
{
	for (;;)
	{
		result[exp][checkcount]= MachineShop.TotalResponseTime-oldResponseTime;
		oldResponseTime= MachineShop.TotalResponseTime;
		checkcount++;
		try
		{
		hold(check);
		}
		catch (SimulationException e){}
		catch (RestartException e){}
		
	}
}
public void report(int count)
{
	for (int i=0; i< count; i++) {
		for (int j=0; j<E_count; j++) {
			System.out.print(result[j][i]+" ");
		}
		System.out.println();
	}
}

public void reset(int experiment)
{
	exp=experiment;
	checkcount=0;
	oldResponseTime=MachineShop.TotalResponseTime;
}
private long check;
private int checkcount=0;
private int exp=0;
private int E_count=10;
private int S_count=100;
private double oldResponseTime=0;
private double[][] result = new double[E_count][S_count]; 
}