// btrace_appresponse.cpp

// 

// Copyright (c) 2008 - 2010 Accenture. All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the "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:

// Accenture - Initial contribution

//

#include "btrace_parser.h"

#include <fshell/common.mmh>

//

// CBtraceAppResponse

//

EXPORT_C CBtraceAppResponse* CBtraceAppResponse::NewL(CBtraceReader& aReader)

	{

	CBtraceAppResponse* self = new (ELeave) CBtraceAppResponse(aReader);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

CBtraceAppResponse::CBtraceAppResponse(CBtraceReader& aReader)

	: iReader(aReader)

	{

	}

EXPORT_C CBtraceAppResponse::~CBtraceAppResponse()

	{

	iReader.RemoveObserver(KAmTraceCategory, *this);

	iNotifs.Close();

	}

void CBtraceAppResponse::ConstructL()

	{

	iReader.AddObserverL(KAmTraceCategory, *this);

	}

void CBtraceAppResponse::HandleBtraceFrameL(const TBtraceFrame& aFrame)

	{

	if (aFrame.iCategory != KAmTraceCategory) return;

	switch (aFrame.iSubCategory)

		{

		case EAmTraceSubCategoryEvCapture:

			{

			const TUint32* data = reinterpret_cast<const TUint32*>(aFrame.iData.Ptr());

			const TAmTraceEventEvCapture event = static_cast<TAmTraceEventEvCapture>(*data++);

			const TUint32 processIdLowWord = *data++;

			const TUint32 processIdHighWord = *data++;

			switch (event)

				{

				case EAmTraceEventEvCaptureSystemAppResponse:

					{

					SeenAppResponseL(aFrame.iTickCount, MAKE_TUINT64(processIdHighWord, processIdLowWord));

					}

				break;

				default:

					// ignore the event

				break;

				};

			}

		break;

		default:

			// ignore anything we don't know about.

		break;

		};

	}

void CBtraceAppResponse::SeenAppResponseL(const TBtraceTickCount& aTickCount, const TProcessId& aProcessId)

	{

	TInt ii = iNotifs.Count();

	while (--ii >= 0)

		{

		TAppResponseNotif& nt = iNotifs[ii];

		if (nt.iProcessId == aProcessId)

			{

			MBtraceAppResponseObserver& observer = nt.iObserver;

			if (nt.iPersistence == ENotificationOneShot)

				{

				iNotifs.Remove(ii);

				}

			observer.HandleAppResponseSeenL(aTickCount);

			}

		}	

	}

EXPORT_C void CBtraceAppResponse::NotifyAppResponseL(MBtraceAppResponseObserver& aObserver, const TProcessId& aProcessId)

	{

	NotifyAppResponseL(aObserver, aProcessId, ENotificationOneShot);

	}

EXPORT_C void CBtraceAppResponse::NotifyAppResponseL(MBtraceAppResponseObserver& aObserver, const TProcessId& aProcessId, TBtraceNotificationPersistence aPersistence)

	{

	TAppResponseNotif notify(aObserver, aProcessId, aPersistence);

	User::LeaveIfError(iNotifs.Append(notify));

	}

EXPORT_C void CBtraceAppResponse::CancelNotifyAppResponse(MBtraceAppResponseObserver& aObserver)

	{

	for (TInt i = (iNotifs.Count() - 1); i >= 0; --i)

		{

		if (&iNotifs[i].iObserver == &aObserver)

			{

			iNotifs.Remove(i);

			}

		}

	}

//

// CBtraceAppResponse::TAppResponseNotif

//

CBtraceAppResponse::TAppResponseNotif::TAppResponseNotif(MBtraceAppResponseObserver& aObserver, const TProcessId& aProcessId, TBtraceNotificationPersistence aPersistence)

	: iObserver(aObserver), iProcessId(aProcessId), iPersistence(aPersistence)

	{

	}