// Copyright (c) 2005-2010 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:

// sblpapi.cpp - SBLP QoS API

//

#include "OstTraceDefinitions.h"

#ifdef OST_TRACE_COMPILER_IN_USE

#include "sblpextnTraces.h"

#endif

#include "sblpextn.h"

#include "qosextn_constants.h"

#include <networking/qosparameters.h>

// Buffer size

const TUint KSblpApiBufSize = 8192;

const TUint KNumberOfElementsPerFlowId = 2;

// Note that KAuthorizationTokenAdjustedStringLength value should be calculated 

// very carefully to fit the string inside the config block used by the pfqoslib.

// if KAuthorizationTokenActualStringLength = 255, KAuthorizationTokenAdjustedStringLength should

// be 260.

const TUint KAuthorizationTokenActualStringLength = 255;

const TUint KAuthorizationTokenStringZeroTerminated = KAuthorizationTokenActualStringLength + 1;

const TUint KAuthorizationTokenAdjustedStringLength = KAuthorizationTokenStringZeroTerminated + 4;

EXPORT_C CSblpParameters::CSblpParameters()

	{

	iAuthorizationToken = KNullDesC8;

	}

EXPORT_C CSblpParameters::~CSblpParameters()

	{

	iFlowIds.Reset();

	}

EXPORT_C CSblpParameters& CSblpParameters::operator= (const CSblpParameters& f)

	{

	if (this != &f)

		{

		SetMAT(f.iAuthorizationToken);

		SetFlowIds(f.iFlowIds);

		}

	return *this;

	}

EXPORT_C TInt CSblpParameters::GetMAT(TAuthorizationToken &aAuthToken) const

	{

	aAuthToken = iAuthorizationToken;

	return KErrNone;

	}

EXPORT_C void CSblpParameters::SetMAT(const TAuthorizationToken &aAuthToken )

	{

	iAuthorizationToken = aAuthToken;

	}

EXPORT_C CSblpParameters::TFlowIdentifier& CSblpParameters::GetFlowId(TInt aIndex)

	{

	__ASSERT_DEBUG(aIndex<iFlowIds.Count(),User::Panic(_L("CSblpParameters::GetFlowId"),KErrArgument));

	return iFlowIds[aIndex];

	}

EXPORT_C void CSblpParameters::SetFlowIds(const RArray<TFlowIdentifier> &aFlowIds)

	{

    //in case of low memory the function might not set all the ids

	iFlowIds.Reset();

	TInt i;

	for(i=0; i<aFlowIds.Count();i++)

		{

		TInt errorCode = this->iFlowIds.Append(aFlowIds[i]);

		if (errorCode != KErrNone) 

		    {

            OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPARAMETERS_SETFLOWID, "Not Enough Memory");

		    }

		}

	}

EXPORT_C TInt CSblpParameters::GetFlowIds(RArray<TFlowIdentifier>& aFlowIds)

	{

    //in case of low memory the function might not get all the ids and returns an error code

	aFlowIds.Reset();

	TInt i;

	TInt errorCode = KErrNone;

	for(i=0; i<iFlowIds.Count();i++)

		{

        errorCode = aFlowIds.Append(this->iFlowIds[i]);

        if (errorCode != KErrNone) 

            {

            OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPARAMETERS_GETFLOWID, "Not Enough Memory");

            return errorCode;

            }

		}

	return KErrNone;

	}

EXPORT_C TInt CSblpParameters::NrOfFlowIds()

	{

	return iFlowIds.Count();

	}

//

// CSblpPolicy

//

EXPORT_C CSblpPolicy* CSblpPolicy::NewL()

	{

	CSblpPolicy* policy = new (ELeave) CSblpPolicy();

	CleanupStack::PushL(policy);

	policy->ConstructL();

	CleanupStack::Pop();

	return policy;

	}

CSblpPolicy::CSblpPolicy()

	{

	iType = KPfqosExtensionSBLP;

	}

void CSblpPolicy::ConstructL()

	{

	iData = HBufC8::NewL(KSblpApiBufSize);

	iSblp = new (ELeave) CSblpParameters;

	}

EXPORT_C CSblpPolicy::~CSblpPolicy()

	{

	delete iSblp;

	//iData is deleted in the base

	}

static void SetIntValue(pfqos_configblock_int& data, TInt aValue,

						const TDesC8& aName)

	{

	data.len = sizeof(pfqos_configblock_int)/8;

	data.padding = data.reserved = 0;

	data.type = KPfqosTypeInteger;

	data.value = aValue;

	Mem::FillZ(data.id, KPfqosMaxName);

	Mem::Copy(data.id, aName.Ptr(), aName.Length());

	}

static void SetStringBlockHeader(pfqos_configblock& data,

								 TDesC8& /*aValue*/, const TDesC8& aName)

	{

	data.len = (sizeof(pfqos_configblock) + KAuthorizationTokenAdjustedStringLength )/8;

	data.padding = data.reserved = 0;

	data.type = KPfqosTypeString;

	Mem::FillZ(data.id, KPfqosMaxName);

	Mem::Copy(data.id, aName.Ptr(), aName.Length());

	}

EXPORT_C TDesC8& CSblpPolicy::Data()

	{

	TPtr8 bufPtr = iData->Des();

	bufPtr.SetLength(0);

	const TInt byte_len = (sizeof(pfqos_configure)+

						  sizeof(pfqos_extension)+

						  sizeof(pfqos_configblock)+

						  KAuthorizationTokenAdjustedStringLength+

			                          KNumberOfElementsPerFlowId * iSblp->NrOfFlowIds() *

						  sizeof(pfqos_configblock_int));

	pfqos_configure header;

	header.pfqos_configure_len = (TUint16)((byte_len + 7) / 8);

	header.pfqos_ext_type = EPfqosExtExtension;

	header.reserved = 0;

	header.protocol_id = 0;

	bufPtr.Append((TUint8*)&header, sizeof(pfqos_configure));

	pfqos_extension extensionType;

	extensionType.pfqos_ext_len = 0;

	extensionType.pfqos_ext_type = EPfqosExtExtension;

	extensionType.pfqos_extension_type = KPfqosExtensionSBLP;

	bufPtr.Append((TUint8*)&extensionType, sizeof(pfqos_extension));

	/* MAT

	MAT is a string

	The string is put after pfqos_configblock

	The pfqos_configblock length is the size of pfqos_configblock

	plus the string length

	*/

	TAuthorizationToken authToken; 

	pfqos_configblock stringBlock;

	iSblp->GetMAT(authToken);

	SetStringBlockHeader(stringBlock,authToken,KDescSblpMediaAuthorizationToken);

	bufPtr.Append((TUint8*)&stringBlock, sizeof(pfqos_configblock));

	// put the string now

	authToken.ZeroTerminate();

	bufPtr.Append((TUint8*)authToken.Ptr(),KAuthorizationTokenAdjustedStringLength);

	// Flowids

	pfqos_configblock_int ext;

	TInt i;

	for(i=0; i<iSblp->NrOfFlowIds();i++)

		{

		CSblpParameters::TFlowIdentifier& flowId = iSblp->GetFlowId(i);

		SetIntValue(ext,flowId.iMediaComponentNumber,KDescSblpMediaComponentNumber);

		bufPtr.Append((TUint8*)&ext, sizeof(pfqos_configblock_int));

		SetIntValue(ext,flowId.iIPFlowNumber,KDescSblpIPFlowNumber);

		bufPtr.Append((TUint8*)&ext, sizeof(pfqos_configblock_int));

		}

	bufPtr.AppendFill(0, header.pfqos_configure_len * 8 - byte_len);

	return *iData;

	}

EXPORT_C TInt CSblpPolicy::ParseMessage(const TDesC8& /*aData*/)

	{

	return KErrNone;

	}

EXPORT_C CExtensionBase* CSblpPolicy::CreateL()

	{

	CSblpPolicy *extension = CSblpPolicy::NewL();

	return extension;

	}

EXPORT_C TInt CSblpPolicy::Copy(const CExtensionBase& aExtension)

	{

	if (aExtension.Type() != iType)

		return KErrArgument;

	const CSblpPolicy& policy = (CSblpPolicy&)aExtension;

	policy.GetSblpParameters(*iSblp);

	return KErrNone;

	}

EXPORT_C void CSblpPolicy::SetSblpParameters(const CSblpParameters& aSblp)

	{

	*iSblp = aSblp;

	// following code is to create logs

	TAuthorizationToken authToken;

	iSblp->GetMAT (authToken);

    RArray<CSblpParameters::TFlowIdentifier> flowIds;

	iSblp->GetFlowIds(flowIds);

	// in case of low memory GetFlowIds might return an error and flowIds might not have all the ids, but we still try to log as much as we can

	TBuf<KAuthorizationTokenSize> label;

	label.Copy(authToken);

	OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPOLICY_SETSBLPPARAMETERS_1, "<------------------------------------------------\n");

	OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPOLICY_SETSBLPPARAMETERS_2, "CSblpPolicy::SetSblpParameters");

	OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPOLICY_SETSBLPPARAMETERS_3, "\n");

	OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPOLICY_SETSBLPPARAMETERS_4, "SBLP VALUES SUPPLIED BY CLIENT IS \n");

	OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPOLICY_SETSBLPPARAMETERS_5, "\n");

	OstTraceDefExt1(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPOLICY_SETSBLPPARAMETERS_6, "[MAT string           :   = %S]\n",label);

	TInt i;

	for(i=0; i<flowIds.Count();i++)

		{

		OstTraceDef1(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPOLICY_SETSBLPPARAMETERS_7, "Media component number  :   = %d]\n",flowIds[i].iMediaComponentNumber);

		OstTraceDef1(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPOLICY_SETSBLPPARAMETERS_8, "IP flow number       :  = %d]\n",flowIds[i].iIPFlowNumber);

		}

	OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, CSBLPPOLICY_SETSBLPPARAMETERS_9, "------------------------------------------------>\n");

	flowIds.Close();

	}

EXPORT_C void CSblpPolicy::GetSblpParameters(CSblpParameters& aSblp) const

	{

	aSblp = *iSblp;

	}