// Copyright (c) 2006-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:

// e32test\mmu\paging_info.cpp

// 

//

#include <e32debug.h>

#include <e32svr.h>

#include <u32hal.h>

#include <hal.h>

#include "paging_info.h"

const TUint8* BenchmarkNames[] =

	{

	(const TUint8*)"Read rom page",

	(const TUint8*)"Read code page",

	(const TUint8*)"Decompress",

	(const TUint8*)"Set code page free",

	(const TUint8*)"Set code page old",

	(const TUint8*)"Read media",

	(const TUint8*)"Fixup code page",

	(const TUint8*)"Read data page",

	(const TUint8*)"Write data page",

	(const TUint8*)"Del notify data page",

	(const TUint8*)"Read media data page",

	(const TUint8*)"Write media data page",

	};

__ASSERT_COMPILE(sizeof(BenchmarkNames)/sizeof(TUint8*) == EMaxPagingBm);

TInt PagingInfo::ResetConcurrency(TInt aLocDrvNo, TMediaPagingStats aMediaStats)

	{

	TInt r = UserSvr::HalFunction(EHalGroupVM, EVMHalResetConcurrencyInfo, NULL, NULL);

	if (r!=KErrNotSupported && r!=KErrNone)

		return r;

	if(aLocDrvNo>=0)

		r=UserSvr::HalFunction(EHalGroupMedia,EMediaHalResetConcurrencyInfo,(TAny*)aLocDrvNo,(TAny*)aMediaStats);

	if(r==KErrNotSupported)

		r = KErrNone;

	return r;

	}

TInt PagingInfo::PrintConcurrency(TInt aLocDrvNo, TMediaPagingStats aMediaStats)

	{

	SPagingConcurrencyInfo info;

	TInt r = UserSvr::HalFunction(EHalGroupVM, EVMHalGetConcurrencyInfo, &info, NULL);

	if (r!=KErrNotSupported && r!=KErrNone)

		return r;

	if (r == KErrNone)

		{

		RDebug::Printf("Concurrency info:");

		RDebug::Printf("  Max waiting threads == %d", info.iMaxWaitingCount);

		RDebug::Printf("  Max paging threads == %d", info.iMaxPagingCount);

		}

	if(aLocDrvNo>=0)

		{

		if(aMediaStats==EMediaPagingStatsAll || aMediaStats==EMediaPagingStatsRom)

			{

			SMediaROMPagingConcurrencyInfo info;		

			r=UserSvr::HalFunction(EHalGroupMedia,EMediaHalGetROMConcurrencyInfo,(TAny*)aLocDrvNo,&info);

			if (r!=KErrNotSupported && r!=KErrNone)

				return r;

			if(r==KErrNone)

				{

				RDebug::Printf("ROM paging media concurrency stats on drive %d:",aLocDrvNo);

				RDebug::Printf("  Total page-in issued whilst processing other page-ins              : %d",info.iTotalConcurrentReqs);

				RDebug::Printf("  Total page-in issued with at least one queue not empty             : %d",info.iTotalReqIssuedNonEmptyQ);

				RDebug::Printf("  Max pending page-in in the main queue                              : %d",info.iMaxReqsInPending);

				RDebug::Printf("  Max pending page-in in the deferred queue                          : %d",info.iMaxReqsInDeferred);

				RDebug::Printf("  Total page-in first-time deferred during this session              : %d",info.iTotalFirstTimeDeferrals);

				RDebug::Printf("  Total page-in re-deferred during this session                      : %d",info.iTotalReDeferrals);

				RDebug::Printf("  Maximum deferrals of any single page-in                            : %d",info.iMaxDeferrals);

				RDebug::Printf("  Total times the main queue was emptied during asynchronous request : %d",info.iTotalSynchEmptiedMainQ);

				RDebug::Printf("  Total page-in serviced from main queue during asynchronous request : %d",info.iTotalSynchServicedFromMainQ);

				RDebug::Printf("  Total page-in deferred from main queue during asynchronous request : %d",info.iTotalSynchDeferredFromMainQ);

				RDebug::Printf("  Total page-in DFC run with an empty main queue                     : %d",info.iTotalRunDry);

				RDebug::Printf("  Total dry runs of paging DFC avoided                               : %d",info.iTotalDryRunsAvoided);

				}

			}

		if(aMediaStats==EMediaPagingStatsAll || aMediaStats==EMediaPagingStatsCode)

			{

			SMediaCodePagingConcurrencyInfo infoCode;

			r=UserSvr::HalFunction(EHalGroupMedia,EMediaHalGetCodeConcurrencyInfo,(TAny*)aLocDrvNo,&infoCode);

			if(r==KErrNone)

				{

				RDebug::Printf("Media Code Paging concurrency stats on drive %d", aLocDrvNo);

				RDebug::Printf("  Total page-in issued whilst processing other page in requests      : %d", infoCode.iTotalConcurrentReqs);

				RDebug::Printf("  Total page-in issued with at least one queue not empty             : %d", infoCode.iTotalReqIssuedNonEmptyQ);

				RDebug::Printf("  Max pending page-in in the main queue                              : %d", infoCode.iMaxReqsInPending);

				RDebug::Printf("  Max pending page-in requests in the deferred queue                 : %d", infoCode.iMaxReqsInDeferred);

				RDebug::Printf("  Total page-in first-time deferred                                  : %d", infoCode.iTotalFirstTimeDeferrals);

				RDebug::Printf("  Total page-in re-deferred during this session (from deferred queue): %d", infoCode.iTotalReDeferrals);

				RDebug::Printf("  Max number of deferrals of any single page in                      : %d", infoCode.iMaxDeferrals);

				RDebug::Printf("  Total pagein serviced from main queue during asynchronous request  : %d", infoCode.iTotalSynchServicedFromMainQ);

				RDebug::Printf("  Total pagein deferred from main queue during asynchronous request  : %d", infoCode.iTotalSynchDeferredFromMainQ);

				}

			}

		}

	if (r == KErrNotSupported)

		r = KErrNone;

	return r;

	}

TInt PagingInfo::ResetEvents()

	{

	return UserSvr::HalFunction(EHalGroupVM,EVMHalResetEventInfo,0,0);

	}

TInt PagingInfo::PrintEvents()

	{

	SVMEventInfo info;

	TPckg<SVMEventInfo> infoBuf(info);

	TInt r = UserSvr::HalFunction(EHalGroupVM,EVMHalGetEventInfo,&infoBuf,0);

	if(r!=KErrNone)

		return r;

	RDebug::Printf("Event info:");

	RDebug::Printf("  Page fault events: %Ld", info.iPageFaultCount);

	RDebug::Printf("  Page in events: %Ld", info.iPageInReadCount);

	return KErrNone;

	}

TInt PagingInfo::ResetBenchmarks(TInt aLocDrvNo, TMediaPagingStats aMediaStats)

	{

	TInt r = KErrNone;

	for (TInt i = 0 ; r == KErrNone && i < EMaxPagingBm ; ++i)

		{

		r = UserSvr::HalFunction(EHalGroupVM, EVMHalResetPagingBenchmark, (TAny*)i, NULL);

		if (r!=KErrNotSupported && r!=KErrNone)

			return r;

		}

	if(aLocDrvNo>=0)

		r=UserSvr::HalFunction(EHalGroupMedia,EMediaHalResetPagingBenchmark,(TAny*)aLocDrvNo,(TAny*)aMediaStats);

	if(r==KErrNotSupported)

		r = KErrNone;

	return r;

	}

TInt PagingInfo::PrintBenchmarks(TInt aLocDrvNo, TMediaPagingStats aMediaStats)

	{

	RDebug::Printf("Paging benchmarks:");

	RDebug::Printf("  Name:                         Count:  Min (us):  Max(us):  Avg(us):");

	TInt freq = 0;

	TReal min;

	TReal max;

	TReal avg;

	TInt r = HAL::Get(HAL::EFastCounterFrequency, freq);

	if (r != KErrNone)

		return r;

	TReal mult = 1000000.0 / freq;

	for (TInt i = 0 ; i < EMaxPagingBm ; ++i)

		{

		SPagingBenchmarkInfo info;

		r = UserSvr::HalFunction(EHalGroupVM, EVMHalGetPagingBenchmark, (TAny*)i, &info);

		if (r!=KErrNotSupported && r!=KErrNone)

			return r;

		if (r == KErrNone)

			{

			min = 0.0;

			max = 0.0;

			avg = 0.0;

			if (info.iCount != 0)

				{

				min = info.iMinTime * mult;

				max = info.iMaxTime * mult;

				avg = (info.iTotalTime * mult) / info.iCount;

				}

			const TUint8* name = BenchmarkNames[i];

			RDebug::Printf("  %-30s %6d %9.1f %9.1f %9.1f", name, info.iCount, min, max, avg);

			}

		}

	if(aLocDrvNo>=0)

		{

		if(aMediaStats==EMediaPagingStatsAll || aMediaStats==EMediaPagingStatsRom)

			{

			SPagingBenchmarkInfo info;

			r=UserSvr::HalFunction(EHalGroupMedia,EMediaHalGetROMPagingBenchmark,(TAny*)aLocDrvNo,&info);

			if (r!=KErrNotSupported && r!=KErrNone)

				return r;

			if(r==KErrNone)

				{

				if (info.iCount != 0)

					{

					min = info.iMinTime * mult;

					max = info.iMaxTime * mult;

					avg = (info.iTotalTime * mult) / info.iCount;

					RDebug::Printf("ROM paging media benchmarks on drive %d:",aLocDrvNo);

					RDebug::Printf("  %-30s %6d %9.1f %9.1f %9.1f", "Page-in latency", info.iCount, min, max, avg);

					}

				}

			}

		if(aMediaStats==EMediaPagingStatsAll || aMediaStats==EMediaPagingStatsCode)

			{

			SPagingBenchmarkInfo info;

			r=UserSvr::HalFunction(EHalGroupMedia,EMediaHalGetCodePagingBenchmark,(TAny*)aLocDrvNo,&info);

			if (r!=KErrNotSupported && r!=KErrNone)

				return r;

			if(r==KErrNone)

				{

				if (info.iCount != 0)

					{

					min = info.iMinTime * mult;

					max = info.iMaxTime * mult;

					avg = (info.iTotalTime * mult) / info.iCount;

					RDebug::Printf("Code paging media benchmarks on drive %d:",aLocDrvNo);

					RDebug::Printf("  %-30s %6d %9.1f %9.1f %9.1f", "Page-in latency", info.iCount, min, max, avg);

					}

				}

			}

		if(aMediaStats==EMediaPagingStatsAll || aMediaStats==EMediaPagingStatsDataIn)

			{

			SPagingBenchmarkInfo info;

			r=UserSvr::HalFunction(EHalGroupMedia,EMediaHalGetDataInPagingBenchmark,(TAny*)aLocDrvNo,&info);

			if (r!=KErrNotSupported && r!=KErrNone)

				return r;

			if(r==KErrNone)

				{

				if (info.iCount != 0)

					{

					min = info.iMinTime * mult;

					max = info.iMaxTime * mult;

					avg = (info.iTotalTime * mult) / info.iCount;

					RDebug::Printf("Data page-in media benchmarks on drive %d:",aLocDrvNo);

					RDebug::Printf("  %-30s %6d %9.1f %9.1f %9.1f", "Page-in latency", info.iCount, min, max, avg);

					}

				}

			}

		if(aMediaStats==EMediaPagingStatsAll || aMediaStats==EMediaPagingStatsDataOut)

			{

			SPagingBenchmarkInfo info;

			r=UserSvr::HalFunction(EHalGroupMedia,EMediaHalGetDataOutPagingBenchmark,(TAny*)aLocDrvNo,&info);

			if (r!=KErrNotSupported && r!=KErrNone)

				return r;

			if(r==KErrNone)

				{

				if (info.iCount != 0)

					{

					min = info.iMinTime * mult;

					max = info.iMaxTime * mult;

					avg = (info.iTotalTime * mult) / info.iCount;

					RDebug::Printf("Data page-out media benchmarks on drive %d:",aLocDrvNo);

					RDebug::Printf("  %-30s %6d %9.1f %9.1f %9.1f", "Page-in latency", info.iCount, min, max, avg);

					}

				}

			}

		}

	return KErrNone;

	}

TInt PagingInfo::ResetAll(TInt aLocDrvNo, TMediaPagingStats aMediaStats)

	{

	TInt r = ResetEvents();

	if (r == KErrNone || r == KErrNotSupported)

		r = ResetConcurrency(aLocDrvNo,aMediaStats);

	if (r == KErrNone || r == KErrNotSupported)

		r = ResetBenchmarks(aLocDrvNo,aMediaStats);

	if (r == KErrNotSupported)

		r = KErrNone;

	return r;

	}

TInt PagingInfo::PrintAll(TInt aLocDrvNo, TMediaPagingStats aMediaStats)

	{

	TInt r = PrintEvents();

	if (r == KErrNone || r == KErrNotSupported)

		r = PrintConcurrency(aLocDrvNo,aMediaStats);

	if (r == KErrNone || r == KErrNotSupported)

		r = PrintBenchmarks(aLocDrvNo,aMediaStats);

	if (r == KErrNotSupported)

		r = KErrNone;

	return r;

	}