// Copyright (c) 2005-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:
// The implementation file for the PDP Context control requests.
// 
//

/**
 @file
 @internalComponent
*/


#include "PdpFsmRequest.h"


//-=========================================================
//
//CModifyActivePDPCtx
//
//-=========================================================
CModifyActivePDPCtx::CModifyActivePDPCtx(CUmtsGprsSubConnProvd& aProvider, MPdpFsmRequestOwner& aOwner)
:CPdpFsmRequestBase(aProvider, aOwner)
{	
}

CModifyActivePDPCtx::~CModifyActivePDPCtx()
{
}


TInt CModifyActivePDPCtx::Start()
{
	// Store the Context Id in order to check replies later
	iContextId = iProvider.GetContextId();
	return iProvider.GetPdpFsmInterface().Input(iContextId, SpudMan::EContextModifyActive);
}

/**
@param aEvent The event Id
@param aParam Data relavent to the event. Usually a system-wide error code
@return ETrue if the event was consumed, EFalse if it was of no interest and should
be passed on to SpudMan for processing.
*/
TBool CModifyActivePDPCtx::PdpFsmEvent(TContextId aContextId, TInt aEvent, TInt aParam)
{
	if (aContextId == iContextId && aEvent == KContextModifyActiveEvent)
		{
		iOwner.Done(aParam, *this);
		return ETrue;
		}
	
	return EFalse;
}



#ifdef SYMBIAN_NETWORKING_UMTSR5
//-=========================================================
//
//CModifyR5QoS
//
//-=========================================================
CModifyR5QoS::CModifyR5QoS(CUmtsGprsSubConnProvd& aProvider, MPdpFsmRequestOwner& aOwner, RPacketQoS::TQoSR5Requested& aParams)
:CPdpFsmRequestBase(aProvider, aOwner),
 iModifyActive(NULL),
 i5(aParams)
{
}

CModifyR5QoS::~CModifyR5QoS()
{
    ASSERT(iModifyActive == NULL || iContextId == 0); 
    //If we assert here is is becuase Start has been called (allocated iContextId), but Done has not been called (cleans iModifyActive)
	delete iModifyActive;
}

void CModifyR5QoS::GrantedSetupL()
	{
	CSubConGenEventParamsGranted* event = CSubConGenEventParamsGranted::NewL();
	CleanupStack::PushL (TCleanupItem(SubconEventCleanupFunction, event));
	event->SetFamily (KSubConQoSFamily);
	RPacketQoS::TQoSR5Negotiated negotiatedQoS;
	iProvider.GetPdpFsmInterface().Get(iProvider.GetContextId(), negotiatedQoS);
	iProvider.MapQosEtelToGrantedParamsL(&negotiatedQoS, *event);
	iProvider.NotifyClientEvent (*event);
	CleanupStack::Pop();
	delete event;
	
	}

void CModifyR5QoS::RejectedSetupL(TInt aResult)
	{
	CSubConGenEventParamsRejected* event = CSubConGenEventParamsRejected::NewL();
	CleanupStack::PushL (TCleanupItem(SubconEventCleanupFunction, event));
	event->SetFamilyId (KSubConQoSFamily);
	event->SetError (aResult);
	iProvider.NotifyClientEvent (*event);
	CleanupStack::Pop();
	delete event;
	}

void CModifyR5QoS::Done( TInt aResult, CPdpFsmRequestBase&  aThis )
{
   __ASSERT_ALWAYS(iModifyActive == &aThis, User::Invariant());

	if ( aResult == KErrNone )
   		{
		// QoS Modification complete with success.
	  	__FLOG_1(_L("CModifyR5QoS [this=%08x]:\tDone(): QoS Params Granted"), this);
	  	TRAP_IGNORE(GrantedSetupL());
   		}
	else
	  	{
	  	//QoS Modification complete with failure.
	  	__FLOG_2(_L("CModifyR5QoS [this=%08x]:\tDone(): QoS Params Rejected [aResult=%d]"), this, aResult); 
	  	TRAP_IGNORE(RejectedSetupL(aResult));
	  	}


   delete iModifyActive;
   iModifyActive = NULL;
   iOwner.Done(aResult, *this);
}


TInt CModifyR5QoS::Start()
{
	// Store the Context Id in order to check replies later
	iContextId = iProvider.GetContextId();

	TInt result;
	result = iProvider.GetPdpFsmInterface().Set(iContextId, i5);
	if (result == KErrNone)
		{
		result = iProvider.GetPdpFsmInterface().Input(iContextId, SpudMan::EContextQoSSet);
		}
	  
	return result;
}


TBool CModifyR5QoS::PdpFsmEvent(TContextId aContextId, TInt aEvent, TInt aParam)
{
	if (aContextId != iContextId)
		{
		return EFalse;
		}
		
	TBool handled(EFalse);
	if (aEvent == KContextQoSSetEvent)
		{
		if (aParam == KErrNone)
			{
			iModifyActive->Start();
			}
		else
			{
			//QoS Modification complete with failure.
			__FLOG_2(_L("CModifyR5QoS [this=%08x]:\tPdpFsmEvent(): QoS Params Rejected [aParam=%d]"), this, aParam);
	   
			Done(aParam, *iModifyActive);
			}
		handled = ETrue;
		}
	else
		{
		handled = iModifyActive->PdpFsmEvent(aContextId, aEvent, aParam);
		}

	return handled;
}


void CModifyR5QoS::ConstructL()
{
	iModifyActive = new(ELeave)CModifyActivePDPCtx(iProvider, *this);
}


CModifyR5QoS* CModifyR5QoS::NewL(CUmtsGprsSubConnProvd& aProvider, MPdpFsmRequestOwner& aOwner, RPacketQoS::TQoSR5Requested& aParams)
{
	CModifyR5QoS* request = new(ELeave) CModifyR5QoS(aProvider, aOwner, aParams);
	CleanupStack::PushL(request);
	request->ConstructL();
	CleanupStack::Pop(request);
	return request;
}


#else
// !SYMBIAN_NETWORKING_UMTSR5

//-=========================================================
//
//CModifyR4QoS
//
//-=========================================================
CModifyR4QoS::CModifyR4QoS(CUmtsGprsSubConnProvd& aProvider, MPdpFsmRequestOwner& aOwner, RPacketQoS::TQoSR99_R4Requested aParams)
:CPdpFsmRequestBase(aProvider, aOwner),
 iModifyActive(NULL),
 i99(aParams)
{
}

CModifyR4QoS::~CModifyR4QoS()
{
    ASSERT(iModifyActive == NULL || iContextId == 0); 
    //If we assert here is is becuase Start has been called (allocated iContextId), but Done has not been called (cleans iModifyActive)
	delete iModifyActive;

}

void CModifyR4QoS::GrantedSetupL()
	{
	CSubConGenEventParamsGranted* event = CSubConGenEventParamsGranted::NewL();
	CleanupStack::PushL (TCleanupItem(SubconEventCleanupFunction, event));
	event->SetFamily (KSubConQoSFamily);
	RPacketQoS::TQoSR99_R4Negotiated negotiatedQoS;
	iProvider.GetPdpFsmInterface().Get(iProvider.GetContextId(), negotiatedQoS);
	iProvider.MapQosEtelToGrantedParamsL(&negotiatedQoS, *event);
	iProvider.NotifyClientEvent (*event);
	CleanupStack::Pop();
	delete event;
	}

void CModifyR4QoS::RejectedSetupL(TInt aResult)
	{
	CSubConGenEventParamsRejected* event = CSubConGenEventParamsRejected::NewL();
	CleanupStack::PushL (TCleanupItem(SubconEventCleanupFunction, event));
	event->SetFamilyId (KSubConQoSFamily);
	event->SetError (aResult);
	iProvider.NotifyClientEvent (*event);
	CleanupStack::Pop();
	delete event;
	}

void CModifyR4QoS::Done( TInt aResult, CPdpFsmRequestBase&  aThis )
{

	__ASSERT_ALWAYS(iModifyActive == &aThis, User::Invariant());
   	if ( aResult == KErrNone )
		{
		// QoS Modification complete with success.
		__FLOG_1(_L("CModifyR4QoS [this=%08x]:\tDone(): QoS Params Granted"), this);
		TRAP_IGNORE(GrantedSetupL());
		}
	else
	{
		//QoS Modification complete with failure.
		__FLOG_2(_L("CModifyR4QoS [this=%08x]:\tDone(): QoS Params Rejected [aResult=%d]"), this, aResult);
		TRAP_IGNORE(RejectedSetupL(aResult));
	}
	delete iModifyActive;
	iModifyActive = NULL;
	iOwner.Done(aResult, *this);
}


TInt CModifyR4QoS::Start()
{
	// Store the Context Id in order to check replies later
	iContextId = iProvider.GetContextId();

	TInt result;
	result = iProvider.GetPdpFsmInterface().Set(iContextId, i99);
	if (result == KErrNone)
		{
		result = iProvider.GetPdpFsmInterface().Input(iContextId, SpudMan::EContextQoSSet);
		}
	  
	return result;
}

TBool CModifyR4QoS::PdpFsmEvent(TContextId aContextId, TInt aEvent, TInt aParam)
{   
	if (aContextId != iContextId)
		{
		return EFalse;
		}

	TBool handled(EFalse);
	if (aEvent == KContextQoSSetEvent)
		{
		if (aParam == KErrNone)
			{
		   	iModifyActive->Start();
			}
		else
			{
			//QoS Modification complete with failure.
			__FLOG_2(_L("CModifyR4QoS [this=%08x]:\tPdpFsmEvent(): QoS Params Rejected [aParam=%d]"), this, aParam);
			Done(aParam, *iModifyActive);
			}
		handled = ETrue;
		}
	else
		{
		handled = iModifyActive->PdpFsmEvent(aContextId, aEvent, aParam);
		}
		
	return handled;
}


void CModifyR4QoS::ConstructL()
{
	iModifyActive = new(ELeave)CModifyActivePDPCtx(iProvider, *this);
}

CModifyR4QoS* CModifyR4QoS::NewL(CUmtsGprsSubConnProvd& aProvider, MPdpFsmRequestOwner& aOwner, RPacketQoS::TQoSR99_R4Requested aParams)
{
	CModifyR4QoS* request = new(ELeave) CModifyR4QoS(aProvider, aOwner, aParams);
	CleanupStack::PushL(request);
	request->ConstructL();
	CleanupStack::Pop(request);
	return request;
}



#endif 
// SYMBIAN_NETWORKING_UMTSR5