// 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 "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 "refBnepPacketNotifier.h"

EXPORT_C MBnepPacketNotifierBase* CRefBnepPacketNotifier::NewL()

	{

	MBnepPacketNotifierBase* self = new(ELeave) CRefBnepPacketNotifier;

	return self;

	}

CRefBnepPacketNotifier::CRefBnepPacketNotifier():iCounter(8) // 8 is the current maximum number of PAN connections, so is a good number to set the granularity to.

	{

	}

CRefBnepPacketNotifier::~CRefBnepPacketNotifier() 

	{

	iCounter.Close();

	}

void CRefBnepPacketNotifier::MbpnSetLinkControl(MPanLinkControlBase& aPanLinkControl) 

	{

	iPanLinkControl=(MPanLinkControl*) aPanLinkControl.MplcbGetInterface(KUidPanLinkControlV1);

	}

void CRefBnepPacketNotifier::MbpnBnepDataTransferred(const TArray<TBnepBytesTransferred> & aBnepBytesTransferred)

	{

	for (TInt dev=0;dev<aBnepBytesTransferred.Count();dev++)  // Cycle through array passed to function

		{

		for (TInt index=0;index<iCounter.Count();index++) // Cycle through our array

			{

			TBTDevAddr & curAddr = iCounter[index].iAddr;

			if (curAddr == aBnepBytesTransferred[dev].iBTDevAddr) // If the device addresses are the same

				{

				iCounter[index].iByteCount+=aBnepBytesTransferred[dev].iBytesSent + aBnepBytesTransferred[dev].iBytesReceived; // Increment byte counter

				iCounter[index].iTickCount++; // Increment counter 

				if (iCounter[index].iTickCount == KTicksToSniff) // If it's time to decide whether to sniff/active

					{

					iCounter[index].iTickCount=0; // Reset counter

					if (iPanLinkControl) 

						{

						if (iCounter[index].iByteCount < KMaxBytesToSniff )  

							{

							iPanLinkControl->MplcRequestSniff(curAddr); // Sniff if under KMaxBytesToSniff

							}

						else 

							{

							iPanLinkControl->MplcRequestActive(curAddr); // Otherwise active

							}

						iCounter[index].iByteCount=0; // Reset byte count

						}

					}

				if (aBnepBytesTransferred[dev].iBytesSent + aBnepBytesTransferred[dev].iBytesReceived > KMinBytesToUnSniff && iPanLinkControl)

					{

					iPanLinkControl->MplcRequestActive(curAddr); // If data in one tick is enough, bring out of sniff

					}	

				}

			}

		}

	}

void CRefBnepPacketNotifier::MbpnDeviceAdded(const TBTDevAddr& aAddr)

	{

	TByteCount devByteCount;

	devByteCount.iByteCount=0;

	devByteCount.iTickCount=0;

	devByteCount.iAddr=aAddr;

	}

void CRefBnepPacketNotifier::MbpnDeviceRemoved(const TBTDevAddr& aAddr)

	{

	for (TUint dataIndex=0; dataIndex < iCounter.Count(); ++dataIndex)

		{

		if (iCounter[dataIndex].iAddr==aAddr) 

        	{

        	iCounter.Remove(dataIndex);

        	}

        }

	}

MBnepPacketNotifier* CRefBnepPacketNotifier::Interface()

	{

	return this;

	}

TAny* CRefBnepPacketNotifier::MbpnbGetInterface(const TUid & aInterface) 

	{

	if (aInterface==KUidBnepPacketNotifierV1)

		{

		return Interface();

		}

	return NULL;

	}

void CRefBnepPacketNotifier::MbpnbRelease()

	{

	delete this;

	}