// Copyright (c) 2000-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the License "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:
//

#include "analyse.h"
#include "activity.h"
#include "output.h"

#ifdef __MSVCDOTNET__
#include <ostream>
#include <iomanip>
#else //!__MSVCDOTNET__
#include <ostream.h>
#include <iomanip.h>
#endif //__MSVCDOTNET__

#include <algorithm>


// class Activity::Bucket

inline Activity::Bucket::Bucket(unsigned aPeriod,int aThread)
	:iPeriod(aPeriod),iThread(aThread)
	{}

bool Activity::Bucket::operator<(const Bucket& aRhs) const
	{
	if (iPeriod != aRhs.iPeriod)
		return iPeriod < aRhs.iPeriod;
	return iThread < aRhs.iThread;
	}

// class Activity::ThreadData

inline Activity::ThreadData::ThreadData(const Thread& aThread)
	:iThread(&aThread), iTotal(0)
	{}

inline Activity::ThreadData::ThreadData(unsigned aCutoff)
	:iTotal(aCutoff)
	{}

inline bool Activity::ThreadData::operator<(const ThreadData& aRhs) const
	{
	return iTotal < aRhs.iTotal;
	}


// class Activity


Activity::Activity(int aBucketSize, unsigned aBeginSample, double aCutOff)
	:iBucketSize(aBucketSize), iBeginSample(aBeginSample), iCutOff(aCutOff)
	{
	cout << "Execution activity\n\n";
	}

void Activity::Sample(unsigned aNumber, const Thread& aThread, PC)
	{
	if (aThread.iIndex == iThreads.size())
		iThreads.push_back(ThreadData(aThread));

	++iThreads[aThread.iIndex].iTotal;
	++iData[Bucket((aNumber - iBeginSample) / iBucketSize, aThread.iIndex)];
	} 

void Activity::Complete(unsigned aTotal, unsigned aActive)
	{
	cout.setf(ios::fixed, ios::floatfield);
	cout << setfill(' ');
	cout.precision(2);
	const char* emptySeparator;
	const char* separator;
//
	const unsigned ixCount = iThreads.size();
	int* remap = new int[ixCount];
	std::fill(remap, remap + ixCount, -1);

	std::sort(iThreads.begin(), iThreads.end());
	Threads::iterator cutoff = std::lower_bound(iThreads.begin(), iThreads.end(), ThreadData(iCutOff * aTotal * 0.01));
	iThreads.erase(iThreads.begin(), cutoff);

	const unsigned disCount = iThreads.size();
	for (int ix = 0; ix < disCount; ++ix)
		remap[iThreads[ix].iThread->iIndex] = ix;


	if (Analyse::Format() != Analyse::EExcel)
		{
		cout << "ID  Thread name\n";
		int ix;
		for (ix = 0; ix < disCount; ++ix)
			cout << char('A' + ix) << "  " << *iThreads[ix].iThread << '\n';

		cout << "\nsample  ";
		for (ix = 0; ix < disCount; ++ix)
			cout << setw(4) << char('A' + ix) << "    ";
		cout << "\n\n";
		separator = " ";
		emptySeparator = "        ";
		}
	else
		{
		cout << "sample";
		for (int ix = 0; ix < disCount; ++ix)
			cout << '\t' << *iThreads[ix].iThread;
		cout << '\n';
		separator = emptySeparator = "\t";
		}

	unsigned* totals = new unsigned[disCount];
	std::fill(totals, totals + disCount, 0);
	unsigned period = 0;
	bool values = false;
	for (Data::iterator p = iData.begin(), e = iData.end(); p != e; ++p)
		{
		while (period != p->first.iPeriod)
			{
			cout << setw(7) << (period * iBucketSize) + iBeginSample;
			if (values)
				{
				for (int ix = 0; ix < disCount; ++ix)
					cout <<	separator << Result(totals[ix], iBucketSize);
				std::fill(totals, totals + disCount, 0);
				values = false;
				}
			cout << '\n';
			++period;
			}
		int ix = remap[p->first.iThread];
		if (ix >= 0)
			{
			totals[ix] = p->second;
			values = true;
			}
		}
	if (values)
		{
		cout << setw(7) << (period * iBucketSize) + iBeginSample;
		for (int ix = 0; ix < disCount; ++ix)
			cout <<	separator << Result(totals[ix], iBucketSize);
		cout << '\n';
		}

	delete [] remap;
	delete [] totals;
	}