// 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;

 	}