// btrace_pubsub.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"

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

	{

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

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

CBtracePubSub::CBtracePubSub(CBtraceReader& aReader)

	: iReader(aReader)

	{

	}

EXPORT_C CBtracePubSub::~CBtracePubSub()

	{

	iNotifs.Close();

	iReader.RemoveObserver(ExtraBTrace::EPubSub, *this);

	}

void CBtracePubSub::ConstructL()

	{

	iReader.AddObserverL(ExtraBTrace::EPubSub, *this);

	}

EXPORT_C void CBtracePubSub::NotifyPropertyChangedL(MBtracePubSubObserver& aObserver)

	{

	iNotifs.AppendL(TPubSubNotif(NULL, NULL, NULL, NULL, aObserver, ENotificationOneShot));

	}

EXPORT_C void CBtracePubSub::NotifyPropertyChangedL(TUint* aCategory, TUint* aKey, MBtracePubSubObserver& aObserver, TBtraceNotificationPersistence aPersistence)

	{

	iNotifs.AppendL(TPubSubNotif(aCategory, aKey, NULL, NULL, aObserver, aPersistence));

	}

EXPORT_C void CBtracePubSub::NotifyIntegerPropertyChangedL(TUint* aCategory, TUint* aKey, TInt* aValue, MBtracePubSubObserver& aObserver, TBtraceNotificationPersistence aPersistence)

	{

	iNotifs.AppendL(TPubSubNotif(aCategory, aKey, aValue, NULL, aObserver, aPersistence));

	}

EXPORT_C void CBtracePubSub::NotifyDataPropertyChangedL(TUint* aCategory, TUint* aKey, const TDesC8* aValue, MBtracePubSubObserver& aObserver, TBtraceNotificationPersistence aPersistence)

	{

	iNotifs.AppendL(TPubSubNotif(aCategory, aKey, NULL, aValue, aObserver, aPersistence));

	}

EXPORT_C void CBtracePubSub::CancelNotifyPropertyChanged(MBtracePubSubObserver& aObserver)

	{

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

		{

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

			{

			iNotifs.Remove(i);

			}

		}

	}

void CBtracePubSub::HandleBtraceFrameL(const TBtraceFrame& aFrame)

	{

	if (aFrame.iCategory != ExtraBTrace::EPubSub) return;

	const TUint8* data = aFrame.iData.Ptr();

	TUint cat = *(TUint32*)data;

	TUint key = *((TUint32*)data + 1);

	switch (aFrame.iSubCategory)

		{

		case ExtraBTrace::EPubSubIntPropertyChanged:

			{

			TInt val = *((TUint32*)data + 2);

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

				{

				if (iNotifs[i].Matches(cat, key, val))

					{

					iNotifs[i].iObserver.HandlePropertyChangedL(aFrame.iTickCount, cat, key, val);

					}

				}

			break;

			}

		case ExtraBTrace::EPubSubDataPropertyChanged:

			{

			TPtrC8 val = aFrame.iData.Mid(8);

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

				{

				if (iNotifs[i].Matches(cat, key, val))

					{

					iNotifs[i].iObserver.HandlePropertyChangedL(aFrame.iTickCount, cat, key, val);

					}

				}

			break;

			}

		}

	}

CBtracePubSub::TPubSubNotif::TPubSubNotif(TUint* aCategory, TUint* aKey, TInt* aIntegerValue, const TDesC8* aDataValue, MBtracePubSubObserver& aObserver, TBtraceNotificationPersistence aPersistence)

	: iCategory(aCategory), iKey(aKey), iIntegerValue(aIntegerValue), iDataValue(aDataValue), iObserver(aObserver), iPersistence(aPersistence)

	{

	__ASSERT_ALWAYS(!(iIntegerValue && iDataValue), Panic(EBtpPanicIncompatiblePubSubArgs));

	}

TBool CBtracePubSub::TPubSubNotif::Matches(TUint aCategory, TUint aKey, TInt aIntegerValue) const

	{

	if ((iCategory == NULL) || (*iCategory == aCategory))

		{

		if ((iKey == NULL) || (*iKey == aKey))

			{

			if (((iIntegerValue == NULL) && (iDataValue == NULL)) || (*iIntegerValue == aIntegerValue))

				{

				return ETrue;

				}

			}

		}

	return EFalse;

	}

TBool CBtracePubSub::TPubSubNotif::Matches(TUint aCategory, TUint aKey, const TDesC8& aDataValue) const

	{

	if ((iCategory == NULL) || (*iCategory == aCategory))

		{

		if ((iKey == NULL) || (*iKey == aKey))

			{

			if (((iIntegerValue == NULL) && (iDataValue == NULL)) || (*iDataValue == aDataValue))

				{

				return ETrue;

				}

			}

		}

	return EFalse;

	}