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

#include "mSLOGGER.H"

#include <pcktcs.h>

#include "atgprsqosprofile.h"

#include "ATIO.H"

#include <etelpckt.h>

#include "NOTIFY.H"

#include "Matstd.h"

_LIT8(KGetCGQREQCommand,"AT+CGQREQ?\r");

_LIT8(KGetCGQMINCommand,"AT+CGQMIN?\r");

_LIT8(KCGQmin, "AT+CGQMIN=%d,%d,%d,%d,%d,%d\r");

_LIT8(KCGQreq, "AT+CGQREQ=%d,%d,%d,%d,%d,%d\r");

 /**

 * @file

 * This file implements the CATGprsSetProfile class and the CATGprsGetProfile. These two classes are used by the 

 * GPRS AT TSY library. 

 * This state machine uses "AT+CGQREQ" "AT+CGQMIN" commands.

 */

CATGprsSetProfile* CATGprsSetProfile::NewL(TInt aCid, CATIO* aIo, CTelObject* aTelObject, CATInit* aInit, CPhoneGlobals* aPhoneGlobals)

/**

 *  Standard 2 phase constructor.

 *

 * @param aIo pointer to communication object.

 * @param aTelObject pointer to parent.

 * @param aPhoneGlobals pointer to phone global wide states.

 */

	{

	CATGprsSetProfile* p=new(ELeave) CATGprsSetProfile(aCid, aIo, aTelObject, aInit, aPhoneGlobals);

	CleanupStack::PushL(p);

	p->ConstructL();

	CleanupStack::Pop();

	return p;

	}

void CATGprsSetProfile::ConstructL()

/**

 * Construct all objects that can leave.

 */

	{

	CATCommands::ConstructL();

	}

CATGprsSetProfile::CATGprsSetProfile(TInt aCid, CATIO* aIo, CTelObject *aTelObject, CATInit* aInit, CPhoneGlobals* aPhoneGlobals)	

	: CATCommands(aIo, aTelObject, aInit, aPhoneGlobals), iCid(aCid)

/**

 * Constructor.

 *

 * @param aIo pointer to communication object.

 * @param aTelObject pointer to parent.

 * @param aInit pointer to AT phone init object.

 * @param aPhoneGlobals pointer to phone global wide states.

 */

	{

	LOGTEXT(_L8("CATGprsClass::CATGprsClass called"));

	}

CATGprsSetProfile::~CATGprsSetProfile()

/**

 * Destructor.

 */ 

	{

	LOGTEXT(_L8("CATGprsSetProfile::~CATGprsSetProfile called"));

	}

void CATGprsSetProfile::Start(TTsyReqHandle aTsyReqHandle, TAny* aConfig)

/**

 * This starts the sending of the set commands.

 *

 * @param aConfig config package.

 * @param aTsyReqHandle handle to the client.

 */

	{

	TPckg<RPacketQoS::TQoSGPRSRequested>* qoSProfileV1Pckg = (TPckg<RPacketQoS::TQoSGPRSRequested>*)aConfig;

	iGprsReqProfile	= &(*qoSProfileV1Pckg)();

	MakeupCGQMIN();

	LOGTEXT(_L8("CATGprsSetProfile:\tCATConfigGPRS::Start function called in TSY"));

	__ASSERT_ALWAYS(iIo->AddExpectString(this,KNotifyMeIfErrorString) != NULL, Panic(EGeneral));

	iReqHandle = aTsyReqHandle;

	iState=EWaitForSetCGQMINComplete;

	Write(KGprsCommandTimeOut);

	}

void CATGprsSetProfile::Stop(TTsyReqHandle aTsyReqHandle)

/**

 * This function cancels the outstanding read and sets the state to EWaitForDSR.

 *

 * @param aTsyReqHandle handle to the client.

 */

	{

	LOGTEXT(_L8("CATGprsSetProfile::Stop called"));

	if(iState!=EATNotInProgress && aTsyReqHandle==iReqHandle)

		{

		LOGTEXT(_L8("CATGprsSetProfile::Stop Completing client request with KErrCancel"));

		Complete(KErrCancel,ETimeOutCompletion);

		}

	}

void CATGprsSetProfile::CompleteWithIOError(TEventSource aSource,TInt aStatus)

/**

 * This Function completes the command from the client whith an error.

 *

 * @param aSource source of event from communication class.

 * @param aStatus status of event.

 */

	{

	Complete(aStatus, aSource);

	}

void CATGprsSetProfile::Complete(TInt aErr, TEventSource aSource)

/**

 * This Function completes the get or set command from the client.

 *

 * @param aErr an error code to relay to client.

 */

	{

	LOGTEXT(_L8("CATGprsSetProfile::Complete"));

	RemoveStdExpectStrings();

	iIo->WriteAndTimerCancel(this);

	iIo->RemoveExpectStrings(this); 

	if (aErr == KErrNone)

		{

		((CGprsQoS*)iTelObject)->SetReqQoSProfile(iGprsReqProfile);

		iPhoneGlobals->iNotificationStore->CheckNotification(iTelObject, EPacketQoSProfileChanged);

		}

	// Allow our base class to do its thing and then complete the client request

	CATCommands::Complete(aErr,aSource);		

	iTelObject->ReqCompleted(iReqHandle,aErr);

	iState=EATNotInProgress;

	}

void CATGprsSetProfile::EventSignal(TEventSource aSource)

/**

 * This function contains the state machine for the command.  The states flow consecutively in 

 * get and set states and are described below.

 *	

 * @par  aSource Source of function call.

 *

 * @par		EWaitForSetCGQMINComplete,

 * Wait for response from the phone on the set command.

 *

 * @par		EWaitForSetCGQMINOK,

 * Validate phone response and send set AT+CGQREQ command.

 *

 * @par		EWaitForSetCGQREQComplete,

 * Wait for response from the phone on the set command.

 *

 * @par		EWaitForSetCGQREQOK,

 * Validate response and Complete set command.

 */

	{

	LOGTEXT2(_L8("CATGprsSetProfile::EventSignal with iState %d"),iState);

	if ((aSource==ETimeOutCompletion))

		{

		LOGTEXT(_L8("CATGprsSetProfile:\tTimeout Error during Config"));

		Complete(KErrTimedOut,aSource);

		return;

		}

	switch(iState)

		{

		case EWaitForSetCGQMINComplete:

			{

			LOGTEXT(_L8("CATGprsSetProfile::EventSignal, EWaitForSetCGQMINComplete"));

			iIo->WriteAndTimerCancel(this);

			StandardWriteCompletionHandler(aSource, KGprsCommandTimeOut);

			iState = EWaitForSetCGQMINOK;

			}

			break;

		case EWaitForSetCGQMINOK:

			{

			LOGTEXT(_L8("CATGprsSetProfile::EventSignal, EWaitForSetCGQMINOK"));

			__ASSERT_ALWAYS(aSource==EReadCompletion,Panic(EATCommand_IllegalCompletionReadExpected));

			TInt ret = ValidateExpectString();

			RemoveStdExpectStrings();

			if(ret)

				{

				Complete(ret, aSource);

				return;

				}

			MakeupCGQREQ();

			Write(KGprsCommandTimeOut);

			iState = EWaitForSetCGQREQComplete;

			}

			break;

		case EWaitForSetCGQREQComplete:

			{

			LOGTEXT(_L8("CATGprsSetProfile::EventSignal, EWaitForSetCGQREQComplete"));

			StandardWriteCompletionHandler(aSource, KGprsCommandTimeOut);

			iState = EWaitForSetCGQREQOK;

			}

		break;

		case EWaitForSetCGQREQOK:

			{

			LOGTEXT(_L8("CATGprsSetProfile::EventSignal, EWaitForSetCGQREQOK"));

			__ASSERT_ALWAYS(aSource==EReadCompletion,Panic(EATCommand_IllegalCompletionReadExpected));

			TInt ret = ValidateExpectString();

			Complete(ret, aSource);

			}

			break;

		case EATNotInProgress:

			break;

		default:

			{

			LOGTEXT(_L8("CATGprsSetProfile::EventSignal, default. Panic"));

			Panic(EIllegalEvent);

			}

			break;

		}			

	}

void CATGprsSetProfile::MakeupCGQMIN()

/**

 * This Function creates the at set string for the AT+CGQMIN command.

 */

	{

	TInt precedence, delay, reliability, peakthru, meanthru = 0;

	switch (iGprsReqProfile->iMinPrecedence)

		{

		case RPacketQoS::EPriorityHighPrecedence:

			precedence = 1; // high precedence

		break;

		case RPacketQoS::EPriorityMediumPrecedence:

			precedence = 2; // normal precedence

		break;

		case RPacketQoS::EPriorityLowPrecedence:

			precedence = 3; // low precedence

		break;

		default:

			precedence = 0; // unspecified or unknown precedence

		break;

		};

	switch (iGprsReqProfile->iMinDelay)

		{

		case RPacketQoS::EDelayClass1:

			delay = 1;

		break;

		case RPacketQoS::EDelayClass2:

			delay = 2;

		break;

		case RPacketQoS::EDelayClass3:

			delay = 3;

		break;

		case RPacketQoS::EDelayClass4:

			delay = 4;

		break;

		default:

			delay = 0;

		break;

		};

	switch (iGprsReqProfile->iMinReliability)

		{

		case RPacketQoS::EReliabilityClass1:

			reliability = 1;

		break;

		case RPacketQoS::EReliabilityClass2:

			reliability = 2;

		break;

		case RPacketQoS::EReliabilityClass3:

			reliability = 3;

		break;

		case RPacketQoS::EReliabilityClass4:

			reliability = 4;

		break;

		case RPacketQoS::EReliabilityClass5:

			reliability = 5;

		break;

		default:

			reliability = 0; // unspecified or unknown reliability

		break;

		};

	switch (iGprsReqProfile->iMinPeakThroughput)

		{

		case RPacketQoS::EPeakThroughput1000:

			peakthru = 1;

		break;

		case RPacketQoS::EPeakThroughput2000:

			peakthru = 2;

		break;

		case RPacketQoS::EPeakThroughput4000:

			peakthru = 3;

		break;

		case RPacketQoS::EPeakThroughput8000:

			peakthru = 4;

		break;

		case RPacketQoS::EPeakThroughput16000:

			peakthru = 5;

		break;

		case RPacketQoS::EPeakThroughput32000:

			peakthru = 6;

		break;

		case RPacketQoS::EPeakThroughput64000:

			peakthru = 7;

		break;

		case RPacketQoS::EPeakThroughput128000:

			peakthru = 8;

		break;

		case RPacketQoS::EPeakThroughput256000:

			peakthru = 9;

		break;

		default:

			peakthru = 0; // unspecified or unknown peak throughput

		break;

		};

	switch (iGprsReqProfile->iMinMeanThroughput)

		{

		case RPacketQoS::EMeanThroughput100:

			meanthru = 2;

		break;

		case RPacketQoS::EMeanThroughput200:

			meanthru = 3;

		break;

		case RPacketQoS::EMeanThroughput500:

			meanthru = 4;

		break;

		case RPacketQoS::EMeanThroughput1000:

			meanthru = 5;

		break;

		case RPacketQoS::EMeanThroughput2000:

			meanthru = 6;

		break;

		case RPacketQoS::EMeanThroughput5000:

			meanthru = 7;

		break;

		case RPacketQoS::EMeanThroughput10000:

			meanthru = 8;

		break;

		case RPacketQoS::EMeanThroughput20000:

			meanthru = 9;

		break;

		case RPacketQoS::EMeanThroughput50000:

			meanthru = 10;

		break;

		case RPacketQoS::EMeanThroughput100000:

			meanthru = 11;

		break;

		case RPacketQoS::EMeanThroughput200000:

			meanthru = 12;

		break;

		case RPacketQoS::EMeanThroughput500000:

			meanthru = 13;

		break;

		case RPacketQoS::EMeanThroughput1000000:

			meanthru = 14;

		break;

		case RPacketQoS::EMeanThroughput2000000:

			meanthru = 15;

		break;

		case RPacketQoS::EMeanThroughput5000000:

			meanthru = 16;

		break;

		case RPacketQoS::EMeanThroughput10000000:

			meanthru = 17;

		break;

		case RPacketQoS::EMeanThroughput20000000:

			meanthru = 18;

		break;

		case RPacketQoS::EUnspecifiedMeanThroughput:

		case RPacketQoS::EMeanThroughput50000000:

			meanthru = 31;

		break;

		default:

			meanthru = 0; // unspecified or unknown mean throughput

		break;

		};

	iTxBuffer.Format(KCGQmin, iCid,	

			precedence,

			delay,

			reliability,

			peakthru,

			meanthru);

	}

void CATGprsSetProfile::MakeupCGQREQ()

/**

 * This Function creates the at set string for the AT+CGQREQ command.

 */

	{

	TInt precedence, delay, reliability, peakthru, meanthru = 0;

	switch (iGprsReqProfile->iReqPrecedence)

		{

		case RPacketQoS::EPriorityHighPrecedence:

			precedence = 1; // high precedence

		break;

		case RPacketQoS::EPriorityMediumPrecedence:

			precedence = 2; // normal precedence

		break;

		case RPacketQoS::EPriorityLowPrecedence:

			precedence = 3; // low precedence

		break;

		default:

			precedence = 0; // unspecified or unknown precedence

		break;

		};

	switch (iGprsReqProfile->iReqDelay)

		{

		case RPacketQoS::EDelayClass1:

			delay = 1;

		break;

		case RPacketQoS::EDelayClass2:

			delay = 2;

		break;

		case RPacketQoS::EDelayClass3:

			delay = 3;

		break;

		case RPacketQoS::EDelayClass4:

			delay = 4;

		break;

		default:

			delay = 0;

		break;

		};

	switch (iGprsReqProfile->iReqReliability)

		{

		case RPacketQoS::EReliabilityClass1:

			reliability = 1;

		break;

		case RPacketQoS::EReliabilityClass2:

			reliability = 2;

		break;

		case RPacketQoS::EReliabilityClass3:

			reliability = 3;

		break;

		case RPacketQoS::EReliabilityClass4:

			reliability = 4;

		break;

		case RPacketQoS::EReliabilityClass5:

			reliability = 5;

		break;

		default:

			reliability = 0; // unspecified or unknown reliability

		break;

		};

	switch (iGprsReqProfile->iReqPeakThroughput)

		{

		case RPacketQoS::EPeakThroughput1000:

			peakthru = 1;

		break;