/*

* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies). 

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "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 <QMessageBox>

#include <memspy/engine/memspyenginehelpersysmemtrackerconfig.h>

#include "enginewrapper.h"

// CONSTANTS

const QString OUTPUT_MODE = "output/mode";

const QString OUTPUT_PATH = "output/path";

const QString SWMT_PERIOD = "swmt/period";

const QString SWMT_MODE = "swmt/mode";

const QString SWMT_CATEGORIES = "swmt/categories";

const QString HEAP_DUMPS_MODE = "heapdumps/mode";

QString MemSpyProcess::exitInfo() const

{

    QChar exitType[] = {'K', 'T', 'P', 'R'};

    QString result = QString("[%1]").arg(exitType[mProcess->ExitType()]);

    if (mProcess->ExitType() != EExitKill && mProcess->ExitType() != EExitPending) {

        QString exitCategory = QString((QChar*) mProcess->ExitCategory().Ptr(), mProcess->ExitCategory().Length());

        result.append(QString(" %1-%2").arg(exitCategory).arg(mProcess->ExitReason()));

    }

    return result;

}

MemSpyDwoProgressTracker::MemSpyDwoProgressTracker(RMemSpySession &session) :

	CActive(EPriorityStandard), mSession(session)

{

	CActiveScheduler::Add(this);

}

MemSpyDwoProgressTracker::~MemSpyDwoProgressTracker()

{

	Cancel();

}

void MemSpyDwoProgressTracker::start()

{

	mSession.NotifyDeviceWideOperationProgress(mProgress, iStatus);

	SetActive();

}

void MemSpyDwoProgressTracker::cancel()

{

	Cancel();

}

// Event handler method.

void MemSpyDwoProgressTracker::RunL()

    {

    // If an error occurred handle it in RunError().

    User::LeaveIfError(iStatus.Int());

    // Resubmit the request immediately

    mSession.NotifyDeviceWideOperationProgress(mProgress, iStatus);

    SetActive();

    emit progress(mProgress.Progress(), QString((QChar*) mProgress.Description().Ptr(), mProgress.Description().Length()));

    }

void MemSpyDwoProgressTracker::DoCancel()

{ 

	// this is not yet implemented, as it is not required in current use cases

}

TInt MemSpyDwoProgressTracker::RunError(TInt aError)

{ 

	// KErrNotReady and KErrCancel errors are OK, they just notify 

	// us about the outstanding notification request that won't be 

	// processed.

	Q_UNUSED(aError);

    return KErrNone;

}

MemSpyDwoTracker::MemSpyDwoTracker(RMemSpySession &session, DeviceWideOperation operation) :

	CActive(EPriorityStandard), 

	mSession(session),

	mProgressTracker(new MemSpyDwoProgressTracker(session)),

	mOperation(operation)

{

	CActiveScheduler::Add(this);

	connect(mProgressTracker, SIGNAL(progress(int,QString)), this, SIGNAL(progress(int,QString)));

}

MemSpyDwoTracker::~MemSpyDwoTracker()

{

	Cancel();

	delete mProgressTracker;

}

void MemSpyDwoTracker::start()

{

	void (RMemSpySession::*functions[])(TRequestStatus&) = { 

			&RMemSpySession::OutputPhoneInfo,

			&RMemSpySession::OutputDetailedPhoneInfo,

			&RMemSpySession::OutputHeapInfo,

			&RMemSpySession::OutputCompactHeapInfo,

			&RMemSpySession::OutputHeapCellListing,

			&RMemSpySession::OutputHeapData,

			&RMemSpySession::OutputStackInfo,

			&RMemSpySession::OutputCompactStackInfo,

			&RMemSpySession::OutputUserStackData,

			&RMemSpySession::OutputKernelStackData };

	(mSession.*functions[mOperation])(iStatus);

	mProgressTracker->start();

	SetActive();

}

void MemSpyDwoTracker::cancel()

{

	Cancel();

}

// Event handler method.

void MemSpyDwoTracker::RunL()

    {

    // If an error occurred handle it in RunError().

    User::LeaveIfError(iStatus.Int());

    // Operation has finished successfully 

    emit finished(0);

    }

void MemSpyDwoTracker::DoCancel()

{

	// Cancel progress tracker

	mProgressTracker->cancel();

	mSession.CancelDeviceWideOperationL();

}

TInt MemSpyDwoTracker::RunError(TInt aError)

{ 

	// Emit the finished signal to notify user 

	// operation was canceled

	emit finished(aError);

    return KErrNone;

}

MemSpyAsyncTracker::MemSpyAsyncTracker(RMemSpySession& session, void (RMemSpySession::*function)(TRequestStatus&)) :

	CActive(EPriorityStandard), 

	mFunction(function),

	mSession(session)

{

	CActiveScheduler::Add(this);

}

void MemSpyAsyncTracker::RunL()

{ 

    // If an error occurred handle it in RunError().

    User::LeaveIfError(iStatus.Int());

    // Operation has finished successfully 

    emit finished(0);

}

void MemSpyAsyncTracker::DoCancel()

{

	// nothing to do here

}

TInt MemSpyAsyncTracker::RunError(TInt aError)

{ 

	// Emit the finished signal to notify user 

	// that operation was canceled

	emit finished(aError);

    return KErrNone;

}

void MemSpyAsyncTracker::start()

{

	(mSession.*mFunction)(iStatus);

	SetActive();

}

MemSpySettings::MemSpySettings() : 

	QSettings("Nokia", "MemSpy") 

{

}

OutputMode MemSpySettings::outputMode() const

{

	return static_cast<OutputMode>(value(OUTPUT_MODE, 0).toInt());

}

void MemSpySettings::setOutputMode(OutputMode mode)

{

	setValue(OUTPUT_MODE, mode);

}

QString MemSpySettings::outputPath() const

{

	return value(OUTPUT_PATH).toString();

}

void MemSpySettings::setOutputPath(const QString& path)

{

	setValue(OUTPUT_PATH, path);

}

int MemSpySettings::swmtTimerPeriod() const

{

	return value(SWMT_PERIOD, 30).toInt();

}

void MemSpySettings::setSwmtMode(SwmtMode mode)

{

	setValue(SWMT_MODE, mode);

}

SwmtMode MemSpySettings::swmtMode() const

{

	return static_cast<SwmtMode>(value(SWMT_MODE, 0).toInt());

}

void MemSpySettings::setSwmtTimerPeriod(int period)

{

	setValue(SWMT_PERIOD, period);

}

QVariantList MemSpySettings::swmtCategories() const

{

	return value(SWMT_CATEGORIES).toList();

}

void MemSpySettings::setSwmtCategories(const QVariantList& categories)

{

	setValue(SWMT_CATEGORIES, categories);

}

HeapDumpsMode MemSpySettings::heapDumpsMode() const

{

	return static_cast<HeapDumpsMode>(value(HEAP_DUMPS_MODE).toInt());

}

void MemSpySettings::setHeapDumpsMode(HeapDumpsMode mode)

{

	setValue(HEAP_DUMPS_MODE, mode);

}

EngineWrapper::EngineWrapper() :

	mSwmtRunning(false)

{

}

EngineWrapper::~EngineWrapper()

{

	mSession.Close();

}

bool EngineWrapper::initialize()

{

	return mSession.Connect() == KErrNone;

}

MemSpySettings& EngineWrapper::settings()

{

	return mSettings;

}

const MemSpySettings& EngineWrapper::settings() const

{

	return mSettings;

}

QList<MemSpyProcess*> EngineWrapper::getProcesses()

{

	QList<MemSpyProcess*> result;

	RArray<CMemSpyApiProcess*> proc;

	QT_TRAP_THROWING(mSession.GetProcessesL(proc));

	for (TInt i=0; i<proc.Count(); i++)

        result.append(new MemSpyProcess(proc[i]));

	return result;

}

QList<MemSpyThread*> EngineWrapper::getThreads(ProcessId processId)

{

	QList<MemSpyThread*> result;

	RArray<CMemSpyApiThread*> proc;

	QT_TRAP_THROWING(mSession.GetThreadsL(processId, proc));

    for (TInt i=0; i<proc.Count(); i++)

        result.append(new MemSpyThread(proc[i]));

	return result;

}

QList<MemSpyThreadInfoItem*> EngineWrapper::getThreadInfo(ThreadId threadId, ThreadInfoType type)

{

	QList<MemSpyThreadInfoItem*> result;

	RArray<CMemSpyApiThreadInfoItem*> threadInfo;

	qt_symbian_throwIfError(mSession.GetThreadInfoItems(threadInfo, threadId, 

			static_cast<TMemSpyThreadInfoItemType>(type)));

	for (TInt i=0; i<threadInfo.Count(); i++)

		result.append(new MemSpyThreadInfoItem(threadInfo[i]));

	return result;

}

void EngineWrapper::setThreadPriority(ThreadId threadId, ThreadPriority priority)

{

	TRAP_IGNORE(mSession.SetThreadPriorityL(threadId, priority));

}

QList<MemSpyKernelObjectType*> EngineWrapper::getKernelObjectTypes()

{

	QList<MemSpyKernelObjectType*> result;

	RArray<CMemSpyApiKernelObject*> types;

	qt_symbian_throwIfError(mSession.GetKernelObjects(types));

	for(TInt i=0; i<types.Count(); i++)

		result.append(new MemSpyKernelObjectType(types[i]));

	return result;

}

QList<MemSpyKernelObject*> EngineWrapper::getKernelObjects(int type)

{

	QList<MemSpyKernelObject*> result;

	RArray<CMemSpyApiKernelObjectItem*> objects;

	qt_symbian_throwIfError(mSession.GetKernelObjectItems(objects, 

			static_cast<TMemSpyDriverContainerType>(type)));

	for(TInt i=0; i<objects.Count(); i++)

		result.append(new MemSpyKernelObject(objects[i]));

	return result;

}

MemSpyDwoTracker* EngineWrapper::createDeviceWideOperation(DeviceWideOperation operation)

{

	return new MemSpyDwoTracker(mSession, operation);

}

MemSpyKernelHeapDumpTracker* EngineWrapper::createKernelHeapDumpTracker()

{

	return new MemSpyKernelHeapDumpTracker(mSession);

}

MemSpySwmtDumpTracker* EngineWrapper::createSwmtDumpTracker()

{

	return new MemSpySwmtDumpTracker(mSession);

}

void EngineWrapper::setSwmtSettings(SwmtMode mode, const QVariantList& categories)

{

	int bits = 0;

	bool heapDumps = false;

	switch (mode)

	{

	case SwmtModeBasic:

		bits = TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryUserHeap | 

			TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryUserStacks |

			TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryGlobalData |

			TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategorySystemMemory;

		break;

	case SwmtModeFull:

		bits = TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryAll;

		heapDumps = true;

		break;

	case SwmtModeCustom:

		bits = 0;

		// this needs to be in sync. with swmt view categories

		TMemSpyEngineHelperSysMemTrackerConfig::TMemSpyEngineSysMemTrackerCategories cats[] = {

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryFileServerCache,

            //TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryBitmapHandles,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryUserHeap,

            //TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryKernelHeap,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryLocalChunks,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryGlobalChunks,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryRAMDrive,

            //TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryUserStacks,

            //TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryGlobalData,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryRAMLoadedCode,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryKernelHandles,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryOpenFiles,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryDiskusage,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategorySystemMemory,

            TMemSpyEngineHelperSysMemTrackerConfig::EMemSpyEngineSysMemTrackerCategoryWindowGroups

		};

		foreach (const QVariant& bit, categories)

			bits |= cats[bit.toInt()];

		break;

	}

	TRAP_IGNORE(mSession.SetSwmtCategoriesL(bits));

	TRAP_IGNORE(mSession.SetSwmtHeapDumpsEnabledL(heapDumps));

}

bool EngineWrapper::isSwmtRunning()

{

	return mSwmtRunning;

}

void EngineWrapper::startSwmt(int period)

{

	mSwmtRunning = true;

	updateOutputSettings();

	TRAP_IGNORE(mSession.StartSwmtTimerL(period));

}

void EngineWrapper::stopSwmt()

{

	mSwmtRunning = false;

	TRAP_IGNORE(mSession.StopSwmtTimerL());

}

void EngineWrapper::forceSwmtDump()

{

	updateOutputSettings();	

	TRAP_IGNORE(mSession.ForceSwmtUpdateL());

}

void EngineWrapper::outputKernelHeapData()

{

	updateOutputSettings();

	TRAP_IGNORE(mSession.OutputKernelHeapDataL());

}

int EngineWrapper::outputThreadHeapData(const QString& filter)

{

	TPtrC customFilterDesc(static_cast<const TUint16*>(filter.utf16()), filter.length());

	TRAPD(err, mSession.OutputThreadHeapDataL(customFilterDesc));

	return err;

}

void EngineWrapper::updateOutputSettings()

{

	switch (mSettings.outputMode()) {

		case OutputModeTrace:

			TRAP_IGNORE(mSession.SwitchOutputToTraceL());

			break;

		case OutputModeFile:

			if (mSettings.outputPath().isEmpty()) {

				TRAP_IGNORE(mSession.SwitchOutputToFileL(KNullDesC));

			} else {

				QString root = mSettings.outputPath();

				TPtrC rootDesc (static_cast<const TUint16*>(root.utf16()), root.length());

				TRAP_IGNORE(mSession.SwitchOutputToFileL(rootDesc));

			}

	}

}