--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32utils/analyse/activity.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,158 @@
+// 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;
+	}