// Copyright (c) 2004-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 "policies.h"

#include "qoslog.h"

#ifdef _LOG

#include "qos_prot.h"	// for the TLogAddress class!

// Dump selector

void DumpSelector(const CSelectorBase& aSel)

	{

	TLogAddress dst(aSel.iDst);

	TLogAddress dmsk(aSel.iDstMask);

	TLogAddress src(aSel.iSrc);

	TLogAddress smsk(aSel.iSrcMask);

	Log::Printf(_L("\t\tsel(%d): src=%S - %d %S dst=%S - %d %S prot=%d name='%S' iap=%d uid(%d %d %d) pri=%d, owner=%d"),

			aSel.iType,

			&src, (TInt)aSel.iSrcPortMax, &smsk,

			&dst, (TInt)aSel.iDstPortMax, &dmsk,

			(TInt)aSel.iProtocol, &aSel.iName,

			aSel.iIapId,

			aSel.iUid.UidType()[0].iUid, aSel.iUid.UidType()[1].iUid, aSel.iUid.UidType()[2].iUid,

			aSel.iPriority, aSel.iOwner);

	}

#endif

//

// CPolicySelector

//

CPolicySelector::CPolicySelector(TPfqosMessage& aMsg) :

  CSelectorBase(aMsg.iBase, aMsg.iSelector, aMsg.iSrcAddr, aMsg.iDstAddr, 

				EPfqosFlowspecPolicy)

	{

	iType = EPfqosFlowspecPolicy;

	LOG(Log::Printf(_L("new\tqos selector[%u] EPfqosFlowspecPolicy(%d) size=%d"), (TInt)this, iType, sizeof(CPolicySelector)));

	}

CPolicySelector::CPolicySelector(CSelectorBase& aSel) 

	: CSelectorBase(aSel)

	{

	iType = EPfqosFlowspecPolicy;

	LOG(Log::Printf(_L("new\tqos selector[%u] EPfqosFlowspecPolicy(%d) size=%d"), (TInt)this, iType, sizeof(CPolicySelector)));

	}

CPolicySelector::~CPolicySelector()

	{

	LOG(Log::Printf(_L("~\tqos selector[%u] EPfqosFlowspecPolicy(%d) -- done"), (TInt)this, iType));

	}

void CPolicySelector::SetQoSParameters(const TPfqosFlowSpec& aSpec)

	{

	if (!aSpec.iExt)

		{

		return;

		}

	// Uplink

	iQoS.SetUpLinkDelay(aSpec.iExt->uplink_delay);

	iQoS.SetUpLinkMaximumPacketSize(aSpec.iExt->uplink_maximum_packet_size);

	iQoS.SetUpLinkAveragePacketSize(aSpec.iExt->uplink_average_packet_size);

	iQoS.SetUpLinkPriority(aSpec.iExt->uplink_priority);

	iQoS.SetUpLinkMaximumBurstSize(aSpec.iExt->uplink_maximum_burst_size);

	iQoS.SetUplinkBandwidth(aSpec.iExt->uplink_bandwidth);

	iQoS.SetName(aSpec.iExt->name);

	// Downlink

	iQoS.SetDownLinkDelay(aSpec.iExt->downlink_delay);

	iQoS.SetDownLinkMaximumPacketSize(

		aSpec.iExt->downlink_maximum_packet_size);

	iQoS.SetDownLinkAveragePacketSize(

		aSpec.iExt->downlink_average_packet_size);

	iQoS.SetDownLinkPriority(aSpec.iExt->downlink_priority);

	iQoS.SetDownLinkMaximumBurstSize(aSpec.iExt->downlink_maximum_burst_size);

	iQoS.SetDownlinkBandwidth(aSpec.iExt->downlink_bandwidth);

	// Flags

	iQoS.SetFlags(aSpec.iExt->flags);

	}

//

// CModuleSelector

//

CModuleSelector::CModuleSelector(TPfqosMessage& aMsg) 

	: CSelectorBase(aMsg.iBase, aMsg.iSelector, aMsg.iSrcAddr, aMsg.iDstAddr, 

					EPfqosModulespecPolicy), 

	  iModules(_FOFF(CModuleSpec, iDLink))

	{

	iType = EPfqosModulespecPolicy;

	LOG(Log::Printf(_L("new\tqos selector[%u] EPfqosModulespecPolicy(%d) size=%d"), (TInt)this, iType, sizeof(CPolicySelector)));

	}

CModuleSelector::CModuleSelector(CSelectorBase& aSel) 

	: CSelectorBase(aSel), iModules(_FOFF(CModuleSpec, iDLink))

	{

	iType = EPfqosModulespecPolicy;

	LOG(Log::Printf(_L("new\tqos selector[%u] EPfqosModulespecPolicy(%d) size=%d"), (TInt)this, iType, sizeof(CPolicySelector)));

	}

CModuleSelector::~CModuleSelector()

	{

	LOG(Log::Printf(_L("~\tqos selector[%u] EPfqosModulespecPolicy(%d) - destruct start"), (TInt)this, iType));

	TDblQueIter<CModuleSpec> iter(iModules);

	CModuleSpec* sel;

	while ((sel = iter++) != NULL)

		{

		sel->iDLink.Deque();

		delete sel;

		}

	LOG(Log::Printf(_L("~\tqos selector[%u] EPfqosModulespecPolicy(%d) - destruct complete"), (TInt)this, iType));

	}

void CModuleSelector::AddModuleSpec(CModuleSpec& aModule)

	{

	iModules.AddLast(aModule);

	}

void CModuleSelector::RemoveModuleSpec(CModuleSpec* aModule)

	{

	aModule->iDLink.Deque();

	delete aModule;

	}

CModuleSpec* CModuleSelector::FindModuleSpec(TUint aProtocolId)

	{

	TDblQueIter<CModuleSpec> iter(iModules);

	CModuleSpec* sel;

	while ((sel = iter++) != NULL)

		{

		if (sel->ProtocolId() == aProtocolId)

			{

			return sel;

			}

		}

	return NULL;

	}

//

// CModuleSpec

//

CModuleSpec* CModuleSpec::NewL(const TDesC& aFileName, 

							   const TDesC& aModuleName)

	{

	CModuleSpec* moduleSpec = new (ELeave) CModuleSpec();

	CleanupStack::PushL(moduleSpec);

	moduleSpec->ContructL(aFileName, aModuleName);

	CleanupStack::Pop();

	return moduleSpec;

	}

CModuleSpec* CModuleSpec::NewL(const TPfqosModule& aModule)

	{

	CModuleSpec* moduleSpec = new (ELeave) CModuleSpec();

	CleanupStack::PushL(moduleSpec);

	moduleSpec->ContructL(aModule);

	CleanupStack::Pop();

	return moduleSpec;

	}

void CModuleSpec::ContructL(const TPfqosModule& aModule)

	{

	iExtension = CExtension::NewL();

	iExtension->CopyL(aModule.iData);

	TPtrC8 fileName((TUint8*)aModule.iExt->path);

	iFileName.Copy(fileName);

	TPtrC8 moduleName((TUint8*)aModule.iExt->name);

	iName.Copy(moduleName);

	iProtocolId = aModule.iExt->protocol_id;

	iFlags = aModule.iExt->flags;

	}

void CModuleSpec::ContructL(const TDesC& aFileName, const TDesC& aModuleName)

	{

	iExtension = CExtension::NewL();

	iFileName.Copy(aFileName);

	iName.Copy(aModuleName);

	iProtocolId = 0;

	iFlags = 0;

	}

CModuleSpec::CModuleSpec()

	{

	LOG(Log::Printf(_L("new\tqos ModuleSpec[%u] size=%d"), (TInt)this, sizeof(CModuleSpec)));

	iProtocolId = 0;

	iFlags = 0;

	iFileName.FillZ();

	iName.FillZ();

	}

CModuleSpec::~CModuleSpec()

	{

	delete iExtension;

	LOG(Log::Printf(_L("~\tqos ModuleSpec[%u] deleted"), (TInt)this));

	}