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

#include "CSimPhone.h"

#include <pcktcs.h>

#include "CSimPacketContext.h"

#include "Simlog.h"

#include "utils.h"

#include "CSimPubSubChange.h"

static const int KNumberofProfiles = 4;	//< Number chosen at random.  

CSimPacketQoS* CSimPacketQoS::NewL(CSimPhone* aPhone, CSimPacketContext* aPacketContext)

/**

* Standard two phase constructor

*

* @param aPacketContext Pointer to the Packet Context object (CSimPacketContext)

* @return CSimPacketQoS pointer to the packet QoS object created.

* @leave Leaves if no memory or object is not created for any reason.

*/

	{

	CSimPacketQoS* qos=new(ELeave) CSimPacketQoS(aPhone, aPacketContext);

	CleanupStack::PushL(qos);

	qos->ConstructL();

	CleanupStack::Pop();

	return qos;

	}

void CSimPacketQoS::Init()

	{}

/**

* Callback function for when timer expires. Note - this only gets called for Rel 99 profiles

*/

void CSimPacketQoS::TimerCallBack(TInt aId)

	{

	switch(aId)

		{

		case ETimerIdPcktQosNetWork:

			{

			TProfileNegR99 profile = iQosNetworkNotifications->At(iQosNetworkNotificationCount);

			CompleteNotifications(profile);

			break;

			}

		case ETimerIdPcktQosR5Network:

			{

			TProfileNegR5 profile = iQosR5NetworkNotifications->At(iQosR5NetworkNotificationCount);

			CompleteNotifications(profile);

			break;

			}

		case ETimerIdPcktQoSSet:

 			{

 			SetProfile(iSetQoSData->At(0).iTsyReqHandle, iSetQoSData->At(0).iData);

 			iSetQoSData->Delete(0);

 			if (iSetQoSData->Count() != 0)

 				iSetQoSTimer->Start(iSetQoSDelay,this,ETimerIdPcktQoSSet);

 			break;	

 			}

		}

	}

void CSimPacketQoS::PubSubCallback(TInt aProfileIndex)

/**

 * Called by CSimQoSChange when a network QoS change request has been received.

 *

 * @param aProfileIndex index of the QoS profile to set

 */

	{

	if (iCurrentProfileRel == TPacketDataConfigBase::KConfigRel5)

		{

		TInt length = iQosR5NetworkNotifications->Count();

		if (aProfileIndex < length)

			{

			TProfileNegR5& profile = iQosR5NetworkNotifications->At(aProfileIndex);

			if (profile.iContextName.Compare(iPacketContext->ContextName()) == 0)

				{

				CompleteNotifications(profile);

				}

			}

		}

	else // by default, uses R99/R4 notification setup

		{

		TInt length = iQosNetworkNotifications->Count();

		if (aProfileIndex < length)

			{

			TProfileNegR99& profile = iQosNetworkNotifications->At(aProfileIndex);

			if (profile.iContextName.Compare(iPacketContext->ContextName()) == 0)

				{

				CompleteNotifications(profile);

				}

			}

		}

	}

void CSimPacketQoS::CompleteNotifications(TProfileNegR99& aProfile)

	{

	if (MatchContext(aProfile)==KErrNone)

		{

		if (iNotifyProfileR99.iNotifyPending)

			{

			RPacketQoS::TQoSR99_R4Negotiated& qos = *(RPacketQoS::TQoSR99_R4Negotiated*)iNotifyProfileR99.iNotifyData;

			qos.iBER = STATIC_CAST(RPacketQoS::TBitErrorRatio, aProfile.iNegTBitErrorRatio);

			qos.iDeliverErroneousSDU = STATIC_CAST(RPacketQoS::TErroneousSDUDelivery, aProfile.iNegErroneousSDUDelivery);

			qos.iDeliveryOrderReqd = STATIC_CAST(RPacketQoS::TDeliveryOrder, aProfile.iNegDeliveryOrder);

			qos.iGuaranteedRate.iUplinkRate = aProfile.iNegGuaranteedUpLinkBitRate;

			qos.iGuaranteedRate.iDownlinkRate = aProfile.iNegGuaranteedDownLinkBitRate;

			qos.iMaxRate.iUplinkRate = aProfile.iNegMaxUpLinkRate;

			qos.iMaxRate.iDownlinkRate = aProfile.iNegMaxDownLinkRate;

			qos.iMaxSDUSize = aProfile.iNegMaxSDUSize;

			qos.iSDUErrorRatio = STATIC_CAST(RPacketQoS::TSDUErrorRatio, aProfile.iNegTSDUErrorRatio);

			qos.iTrafficClass = STATIC_CAST(RPacketQoS::TTrafficClass,aProfile.iNegTraffic);

			qos.iTrafficHandlingPriority = STATIC_CAST(RPacketQoS::TTrafficHandlingPriority, aProfile.iNegTrafficHandlingPriority);

			qos.iTransferDelay = aProfile.iNegTransferDelay;

			iNotifyProfileR99.iNotifyPending=EFalse;

			ReqCompleted(iNotifyProfileR99.iNotifyHandle, KErrNone);

			}

		if (iNotifyProfileR5.iNotifyPending)

			{

			RPacketQoS::TQoSR5Negotiated& qos = *(RPacketQoS::TQoSR5Negotiated*)iNotifyProfileR5.iNotifyData;

			qos.iBER = STATIC_CAST(RPacketQoS::TBitErrorRatio, aProfile.iNegTBitErrorRatio);

			qos.iDeliverErroneousSDU = STATIC_CAST(RPacketQoS::TErroneousSDUDelivery, aProfile.iNegErroneousSDUDelivery);

			qos.iDeliveryOrderReqd = STATIC_CAST(RPacketQoS::TDeliveryOrder, aProfile.iNegDeliveryOrder);

			qos.iGuaranteedRate.iUplinkRate = aProfile.iNegGuaranteedUpLinkBitRate;

			qos.iGuaranteedRate.iDownlinkRate = aProfile.iNegGuaranteedDownLinkBitRate;

			qos.iMaxRate.iUplinkRate = aProfile.iNegMaxUpLinkRate;

			qos.iMaxRate.iDownlinkRate = aProfile.iNegMaxDownLinkRate;

			qos.iMaxSDUSize = aProfile.iNegMaxSDUSize;

			qos.iSDUErrorRatio = STATIC_CAST(RPacketQoS::TSDUErrorRatio, aProfile.iNegTSDUErrorRatio);

			qos.iTrafficClass = STATIC_CAST(RPacketQoS::TTrafficClass,aProfile.iNegTraffic);

			qos.iTrafficHandlingPriority = STATIC_CAST(RPacketQoS::TTrafficHandlingPriority, aProfile.iNegTrafficHandlingPriority);

			qos.iTransferDelay = aProfile.iNegTransferDelay;

			qos.iSignallingIndication = EFalse;

			qos.iSourceStatisticsDescriptor = RPacketQoS::ESourceStatisticsDescriptorUnknown;

			iNotifyProfileR5.iNotifyPending=EFalse;

			ReqCompleted(iNotifyProfileR5.iNotifyHandle, KErrNone);

			}

		}

	}

void CSimPacketQoS::CompleteNotifications(TProfileNegR5& aProfile)

	{

	if (MatchContext(aProfile)==KErrNone)

		{

		if (iNotifyProfileR99.iNotifyPending)

			{

			RPacketQoS::TQoSR99_R4Negotiated& qos = *(RPacketQoS::TQoSR99_R4Negotiated*)iNotifyProfileR99.iNotifyData;

			qos.iBER = STATIC_CAST(RPacketQoS::TBitErrorRatio, aProfile.iNegTBitErrorRatio);

			qos.iDeliverErroneousSDU = STATIC_CAST(RPacketQoS::TErroneousSDUDelivery, aProfile.iNegErroneousSDUDelivery);

			qos.iDeliveryOrderReqd = STATIC_CAST(RPacketQoS::TDeliveryOrder, aProfile.iNegDeliveryOrder);

			qos.iGuaranteedRate.iUplinkRate = aProfile.iNegGuaranteedUpLinkBitRate;

			qos.iGuaranteedRate.iDownlinkRate = aProfile.iNegGuaranteedDownLinkBitRate;

			qos.iMaxRate.iUplinkRate = aProfile.iNegMaxUpLinkRate;

			qos.iMaxRate.iDownlinkRate = aProfile.iNegMaxDownLinkRate;

			qos.iMaxSDUSize = aProfile.iNegMaxSDUSize;

			qos.iSDUErrorRatio = STATIC_CAST(RPacketQoS::TSDUErrorRatio, aProfile.iNegTSDUErrorRatio);

			qos.iTrafficClass = STATIC_CAST(RPacketQoS::TTrafficClass,aProfile.iNegTraffic);

			qos.iTrafficHandlingPriority = STATIC_CAST(RPacketQoS::TTrafficHandlingPriority, aProfile.iNegTrafficHandlingPriority);

			qos.iTransferDelay = aProfile.iNegTransferDelay;

			iNotifyProfileR99.iNotifyPending=EFalse;

			ReqCompleted(iNotifyProfileR99.iNotifyHandle, KErrNone);

			}

		if (iNotifyProfileR5.iNotifyPending)

			{

			RPacketQoS::TQoSR5Negotiated& qos = *(RPacketQoS::TQoSR5Negotiated*)iNotifyProfileR5.iNotifyData;

			qos.iBER = STATIC_CAST(RPacketQoS::TBitErrorRatio, aProfile.iNegTBitErrorRatio);

			qos.iDeliverErroneousSDU = STATIC_CAST(RPacketQoS::TErroneousSDUDelivery, aProfile.iNegErroneousSDUDelivery);

			qos.iDeliveryOrderReqd = STATIC_CAST(RPacketQoS::TDeliveryOrder, aProfile.iNegDeliveryOrder);

			qos.iGuaranteedRate.iUplinkRate = aProfile.iNegGuaranteedUpLinkBitRate;

			qos.iGuaranteedRate.iDownlinkRate = aProfile.iNegGuaranteedDownLinkBitRate;

			qos.iMaxRate.iUplinkRate = aProfile.iNegMaxUpLinkRate;

			qos.iMaxRate.iDownlinkRate = aProfile.iNegMaxDownLinkRate;

			qos.iMaxSDUSize = aProfile.iNegMaxSDUSize;

			qos.iSDUErrorRatio = STATIC_CAST(RPacketQoS::TSDUErrorRatio, aProfile.iNegTSDUErrorRatio);

			qos.iTrafficClass = STATIC_CAST(RPacketQoS::TTrafficClass,aProfile.iNegTraffic);

			qos.iTrafficHandlingPriority = STATIC_CAST(RPacketQoS::TTrafficHandlingPriority, aProfile.iNegTrafficHandlingPriority);

			qos.iTransferDelay = aProfile.iNegTransferDelay;

			qos.iSignallingIndication = aProfile.iSignallingIndication;			

			qos.iSourceStatisticsDescriptor = STATIC_CAST(RPacketQoS::TSourceStatisticsDescriptor, aProfile.iNegTSourceStatisticsDescriptor);

			iNotifyProfileR5.iNotifyPending=EFalse;

			ReqCompleted(iNotifyProfileR5.iNotifyHandle, KErrNone);

			}

		}

	}

CSimPacketQoS::CSimPacketQoS(CSimPhone* aPhone, CSimPacketContext* aPacketContext)

	:iPhone(aPhone), iPacketContext(aPacketContext),iCurrentNeg(0), iCurrentNeg99(0), iCurrentNegR5(0),

	iSetProfilePending(EFalse),	iCurrentProfileRel(TPacketDataConfigBase::KConfigGPRS), iSetProfileCallCount(0), 

	iUseNetworkNotificationBool(EFalse), iTimerStartedBool(EFalse), iSetQoSData(NULL)

/**

* Trivial Constructor.  Initialises all the data members

*

* @param aPacketContext Pointer to the Packet QoS object (CSimPacketContext)

*/

	{

	iNotifyProfileGPRS.iNotifyPending = EFalse;

	iNotifyProfileR99.iNotifyPending = EFalse;

	iNotifyProfileR5.iNotifyPending = EFalse;

	}

void CSimPacketQoS::ConstructL()

/**

* Second phase of the 2-phase constructor.

* Constructs all the member data and retrieves all the data from the config file specific to this class.

*

* @leave Leaves no memory or any data member does not construct for any reason.

*/

	{

	LOGPACKET1("CSimPacketQoS: Entered constructor");

	iQosNetworkNotificationCount = 0;

	iQosR5NetworkNotificationCount = 0;

	iTimer=CSimTimer::NewL(iPhone);

	iSetQoSData = new (ELeave) CArrayFixFlat<TSetQoSData>(1);

 	iSetQoSTimer = CSimTimer::NewL(iPhone);

	iSimQoSChange = CSimPubSubChange::NewL(this, CSimPubSub::TPubSubProperty(KUidPSSimTsyCategory, KPSSimTsyNetworkQoSChange, KPSSimTsyNetworkQoSChangeKeyType));

	LOGPACKET1("Starting to Load and Parse Packet Qos Config File");

	GetGPRSReqProfilesL();

	GetGPRSNegProfilesL();

	GetR99ReqProfilesL();

	GetR99NegProfilesL();

	GetR99NetworkNotificationsL();

	GetR5ReqProfilesL();

	GetR5NegProfilesL();

	GetR5NetworkNotificationsL();

	GetGPRSQosProfileCaps();

	GetR99QosProfileCaps();

	GetR5QosProfileCaps();

	GetProfileFailSettings();

	GetSetQoSSettings();

	LOGPACKET1("...Finished parsing Packet qos config parameters...");

	}

void CSimPacketQoS::GetGPRSReqProfilesL()

	{

	TProfileConfig profile;

	TUint8 digit = 0;

	iProfiles = new(ELeave) CArrayFixFlat<TProfileConfig>(KNumberofProfiles);

	TInt count = iPacketContext->CfgFile()->ItemCount(KQosProfileReqGPRS);

	//< Read in all the data for setting GPRS Requested Profile parameters

	for(TInt i = 0; i < count; i++)

		{

		const CTestConfigItem *item = iPacketContext->CfgFile()->Item(KQosProfileReqGPRS,i);

		if(!item)

			break;

		TPtrC8 minPrecedence, reqPrecedence, minDelay, reqDelay, minPeek, reqPeek;

		TPtrC8 minReliability, reqReliability, minMean, reqMean;

		TInt ret = CTestConfig::GetElement(item->Value(),KStdDelimiter,0,minPrecedence);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::minPrecedence",ret,0,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(minPrecedence, digit)==KErrNone)

				profile.iMinPrecedence = digit;

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,1,reqPrecedence);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::reqPrecedence",ret,1,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(reqPrecedence, digit)==KErrNone)

				profile.iReqPrecedence = digit;

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,2,minDelay);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::minDelay",ret,2,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(minDelay, digit)==KErrNone)

				profile.iMinDelay = digit;

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,3,reqDelay);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::reqDelay",ret,3,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(reqDelay, digit)==KErrNone)

				profile.iReqDelay = digit;

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,4,minReliability);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::minReliability",ret,4,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(minReliability, digit)==KErrNone)

				profile.iMinReliability = digit;

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,5,reqReliability);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::reqReliability",ret,5,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(reqReliability, digit)==KErrNone)

				profile.iReqReliability = digit;

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,6,minPeek);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::minPeek",ret,6,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(minPeek, digit)==KErrNone)

				profile.iMinPeekThroughput = digit;

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,7,reqPeek);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::reqPeek",ret,7,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(reqPeek, digit)==KErrNone)

				profile.iReqPeekThroughput = digit;

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,8,minMean);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::minMean",ret,8,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(minMean, digit)==KErrNone)

				profile.iMinMeanThroughput = digit;

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,9,reqMean);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::reqMean",ret,9,&KQosProfileReqGPRS);

			continue;

			}

		else

			{

			if(AsciiToNum(reqMean, digit)==KErrNone)

				profile.iReqMeanThroughput = digit;

			}

		iProfiles->AppendL(profile);

		}

	}

void CSimPacketQoS::GetGPRSNegProfilesL()

	{

	TNegProfileConfig negProfile;

	TUint8 digit = 0;

	iNegProfiles = new(ELeave) CArrayFixFlat<TNegProfileConfig>(KNumberofProfiles);

	TInt count = iPacketContext->CfgFile()->ItemCount(KQosProfileNegGPRS);

	//< Read in all the data for setting GPRS Negotiated Profile parameters

	for(TInt i = 0; i < count; i++)

		{

		const CTestConfigItem* item = iPacketContext->CfgFile()->Item(KQosProfileNegGPRS,i);

		if(!item)

			break;

		TPtrC8 negPrecedence, negDelay, negPeek, negReliability, negMean;

		TInt ret = CTestConfig::GetElement(item->Value(),KStdDelimiter,0,negPrecedence);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::negPrecedence",ret,0,&KQosProfileNegGPRS);

			continue;

			}

		else

			if(AsciiToNum(negPrecedence, digit)==KErrNone)

				negProfile.iNegPrecedence = digit;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,1,negDelay);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::negDelay",ret,1,&KQosProfileNegGPRS);

			continue;

			}

		else

			if(AsciiToNum(negDelay, digit)==KErrNone)

				negProfile.iNegDelay = digit;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,2,negReliability);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::negReliability",ret,2,&KQosProfileNegGPRS);

			continue;

			}

		else

			if(AsciiToNum(negReliability, digit)==KErrNone)

				negProfile.iNegReliability = digit;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,3,negPeek);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::negPeek",ret,3,&KQosProfileNegGPRS);

			continue;

			}

		else

			if(AsciiToNum(negPeek, digit)==KErrNone)

				negProfile.iNegPeekThroughput = digit;

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,4,negMean);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqGPRS::negMean",ret,4,&KQosProfileNegGPRS);

			continue;

			}

		else

			if(AsciiToNum(negMean, digit)==KErrNone)

				negProfile.iNegMeanThroughput = digit;

		iNegProfiles->AppendL(negProfile);

		}

	}

void CSimPacketQoS::GetR99ReqProfilesL()

	{

	TProfileReqR99 profileReq99;

	TUint8 digit = 0;

	iReqR99Profiles = new(ELeave) CArrayFixFlat<TProfileReqR99>(KNumberofProfiles);

	// parse Release Rel99 profile parameters

	TInt count = iPacketContext->CfgFile()->ItemCount(KQosProfileReqR99);

	for(TInt i = 0; i < count; i++)

		{

		const CTestConfigItem* item = iPacketContext->CfgFile()->Item(KQosProfileReqR99,i);

		if(!item)

			break;

		// continue to load item's parameters

		TPtrC8 contextName, reqTraffic, minTraffic, reqDeliveryOrder, minDeliveryOrder;

		TPtrC8 reqErroneousSDU, minErroneousSDU;

		TInt minUpLinkBitRate, minDownLinkBitRate, reqUpLinkBitRate, reqDownLinkBitRate;

		TInt maxSDUSize, minSDUSize;

		TPtrC8 reqBitErrorRatio, minBitErrorRatio, reqSDUErrorRatio, minSDUErrorRatio;

		TPtrC8 reqTrafficHandlingPriority, minTrafficHandlingPriority;

		TInt reqTransferDelay, minTransferDelay, reqGuaranteedUpLinkBitRate, reqGuaranteedDownLinkBitRate;

		TInt minGuaranteedUpLinkBitRate, minGuaranteedDownLinkBitRate;

		TInt ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,0,contextName);

		if(ret!=KErrNone)

			{

			LOGPARSERR("QosProfileReqR99::contextName",ret,0,KQosProfileReqR99);

			continue;

			}

		else 

			{

			profileReq99.iContextName.Copy(contextName);

			if (profileReq99.iContextName.Match(iPacketContext->ContextName())==KErrNotFound)

				{

				LOGPARSERR("QosProfileReqR99::contextName",KErrArgument,0,&KQosProfileReqR99);

				continue;

				}

			}

		ret=CTestConfig::GetElement(item->Value(),KStdDelimiter,1,reqTraffic);

		if(ret!=KErrNone)

			{