// 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:

// Implementation of CInputRequestListener

// 

//

/**

 @file

 @internalComponent

*/

#include "CPdpFsmInterface.h"

#include "SpudUnitTestServer.h"

#include "InputRequestListener.h"

#include <in_iface.h>

#include "reteldriverinput.h"

#include "ceteldriverfactory.h"

#include "cpdpfsmfactory.h"

#include "DefaultContextParameters.h"

CInputRequestListener* CInputRequestListener::NewL(TBool aUseTestPdpInterface, TInt aUmtsRelease)

	{

	CInputRequestListener *me = new(ELeave) CInputRequestListener(aUseTestPdpInterface, aUmtsRelease);

	CleanupStack::PushL(me);

	me->ConstructL();

	CleanupStack::Pop(me);

	return me;

	}

CInputRequestListener::CInputRequestListener(TBool aUseTestPdpFsmInterface, TInt aUmtsRelease) : CActive(EPriorityStandard), iUseTestPdpFsmInterface(aUseTestPdpFsmInterface)

	{

	iReadyForInputRequest = KRequestPending;

	iThreadDestructed     = KRequestPending;

	iThreadInitialized    = KRequestPending;

	iEtelDriverInputResponseStatus             = KRequestPending;

	iEtelDriverConfigGPRSNotificationStatus    = KRequestPending;

	iEtelDriverContextStatusNotificationStatus = KRequestPending;

	iEtelDriverQosNotificationStatus           = KRequestPending;

	iEtelDriverServiceNotificationStatus       = KRequestPending;

	iFsmInputResponseStatus          = KRequestPending;

	iFsmNetworkStatusStatus          = KRequestPending;

	iFsmContextParameterChangeStatus = KRequestPending;

	iFsmContextSuspendedStatus       = KRequestPending;

	iFsmContextResumedStatus         = KRequestPending;	

    iFsmObjectCreateResponse         = KRequestPending;	

    iUmtsRelease = aUmtsRelease;

	}

void CInputRequestListener::ConstructL()

	{ }

CInputRequestListener::~CInputRequestListener()

	{

	Cancel();

	if (iEtelDriver)

		{

		iEtelDriver->Close();

		delete iEtelDriver;

		iEtelDriver = NULL;

		}

	if (iPdpFsmInterfaceTest)

		{

		iPdpFsmInterfaceTest->Close();

		delete iPdpFsmInterfaceTest;

		iPdpFsmInterfaceTest = NULL;

		}

	if (iPdpFsmInterface)

		{

		iPdpFsmInterface->Close();

		delete iPdpFsmInterface;

		iPdpFsmInterface = NULL;

		}

	iEventHandlers.ResetAndDestroy();

	}

void CInputRequestListener::DoCancel()

	{

	iStatus = KErrCancel;

	}

/**

 Wrapper for private method CActive::SetActive()

 */

void CInputRequestListener::Activate()

	{

	iStatus = KRequestPending;

	SetActive();

	}

/**

 If iStatus was completed with EEtelDriverInputRequest, REtelDriverInput::Input is called with the parameters supplied in iInputData

 If iStatus was completed with EEtelDriverCancelPdpRequest, REtelDriverInput::Cancel is called with the parameters supplied in iEtelDriverCancelRequestData

 If iStatus was completed with EFsmInputRequest, RPdpFsmInterface::Input is called with the parameters supplied in iFsmInputRequestData

 If iStatus was completed with ECleanup, or anything else, the active scheduler is stopped

 */

void CInputRequestListener::RunL()

	{

	TRequestStatus status = iStatus;

	iStatus = KRequestPending;

	if (status == EEtelDriverInputRequest     || 

	    status == EEtelDriverCancelPdpRequest ||

	    status == EFsmInputRequest            || 

	    status == EFsmObjectCreate)

		{

		switch (status.Int())

		    {

		    case EEtelDriverInputRequest:

		        {

    			// the main test thread requested a call to REtelDriverInput::Input

    			iEtelDriver->Input(iEtelDriverInputRequestData.iPdpId, iEtelDriverInputRequestData.iOperation); // error

    			break;

    			}

		    case EEtelDriverCancelPdpRequest:

		        {

    			iEtelDriver->CancelPdp(iEtelDriverCancelRequestPdpId);

    			break;

    			}

		    case EFsmInputRequest:

		        {

    			iPdpFsmInterface->Input(iFsmInputRequestData.iPdpId, iFsmInputRequestData.iOperation);

    			break;

    			}

		    case EFsmObjectCreate:

    			{

				CSpudUnitTestEventHandler* handler = CSpudUnitTestEventHandler::NewL(*this, iUmtsRelease);

				CleanupStack::PushL(handler);

				iEventHandlers.AppendL(handler);

				CleanupStack::Pop(handler);

				SpudMan::TPdpContextType contextType;

				if(iFsmInputRequestData.iPdpId == 0)

					{

					contextType=SpudMan::EPrimary;

					}

				else

					{

					contextType=SpudMan::ESecondary;

					}	

    			TRAPD(err, iFsmInputRequestData.iPdpId = iPdpFsmInterface->NewFsmContextL(*handler,contextType));

				handler->SetContextId(iFsmInputRequestData.iPdpId);

                // Reproduce completion  as per 'SpudManInterfaceTest::Input()' 

                // - since we're not being called asynchronously from EtelPkt

        		iFsmInputResponseData.iPdpId = iFsmInputRequestData.iPdpId;

        		TRequestStatus *readyStatus = &iFsmObjectCreateResponse;

        	 	iParentThread.RequestComplete(readyStatus, err);

        	 	break;

    			}

    		default:

    		    ASSERT(EFalse);

    		}

		// we are finished with the iInputData or iControlData parameters, so this signals to the main test thread

		// that this data can be updated with new parameters

		TRequestStatus *readyStatus = &iReadyForInputRequest;

	 	iParentThread.RequestComplete(readyStatus, KErrNone);

		SetActive(); 	

		}

	else

		{

		// the status was ECleanup, or we don't recognize the status, so abort the active scheduler, and the thread will be exited

		CActiveScheduler::Stop();

		}

	}

/**

 Creates the unit under test - the FSM if iUseTestPdpFsmInterface is false, and the EtelDriver otherwise

 */

void CInputRequestListener::CreateUnitUnderTestL()

	{

	if (iUseTestPdpFsmInterface)

		{

		CreateEtelDriverL();

		}

	else

		{

		CreatePdpFsmL();

		}

	}

/**

 Create and initialize the SPUDTEL

 */

void CInputRequestListener::CreateEtelDriverL()

	{

	iEtelDriver = NewEtelDriverInputL();

	iPdpFsmInterfaceTest = new(ELeave)CPdpFsmInterfaceTest(*this);

	iPdpFsmInterfaceTest->TsyName();

	iEtelDriver->OpenL(*iPdpFsmInterfaceTest);

	iPdpFsmInterfaceTest->OpenL(SimTsyName(), iUmtsRelease);

	for (TContextId i = 0; i < KMaxPdpContexts; i++)

		{

		if (i!=0)

			{

			iEtelDriver->CreatePdpL(i,SpudMan::ESecondary);

			}

		else

			{

			iEtelDriver->CreatePdpL(i,SpudMan::EPrimary);	

			}

		}

	}

/**

 Create and initialize the SPUD FSM

 */

void CInputRequestListener::CreatePdpFsmL()

	{

	iPdpFsmInterface = new(ELeave)CPdpFsmInterface();

	iPdpFsmInterface->OpenL(SimTsyName(), iUmtsRelease);

	}

/**

 Delete and cleanup and resources associated with SPUDTEL and SPUDFSM

 */

void CInputRequestListener::DeleteUnitUnderTest()

	{

	if (iEtelDriver)

		{

		iEtelDriver->Close();

		delete iEtelDriver;

		iEtelDriver = NULL;

		}

	if (iPdpFsmInterfaceTest)

		{

		iPdpFsmInterfaceTest->Close();

		delete iPdpFsmInterfaceTest;

		iPdpFsmInterfaceTest = NULL;

		}

	if (iPdpFsmInterface)

		{

		iPdpFsmInterface->Close();

		delete iPdpFsmInterface;

		iPdpFsmInterface = NULL;

		}

	iEventHandlers.ResetAndDestroy();		

	}

/**

Identifier used in a SpudInput call to signal the SpudMan that the UmtsGprsSCPR is shutting

down and that the real CPdpFsmInterface object will be deleted.

definition moved here from MSpudmaninterface.h as that file no longer exists

*/

const TUint KPdpFsmShuttingDown = 0xff; 

/**

   callback handler for the fsm.

*/

void CSpudUnitTestEventHandler::Event(TInt aEvent, TInt aParam)

	{

	if (aEvent == KPdpFsmShuttingDown)

		{

		// This event requires no notification - In the real SpudMan it would cause SpudMan

		// to close down (NULL) the pointer to the PdpFsmInterface provided by the UmtsGprsSCPR.

		return;

		}

	// The aOperation parameters are broken up into those that are notifications and those that aren't

	// Since notifications can happen anytime, separate request status members need to be kept for each one

	// Other input requests happen serially, so only one request can be pending at any time

	TRequestStatus *status = NULL;

    // Here, rather than in the case statement due to rvct compiler warning

#ifdef SYMBIAN_NETWORKING_UMTSR5

    RPacketQoS::TQoSR5Negotiated neg;

#else

    RPacketQoS::TQoSR99_R4Negotiated neg;

#endif

// SYMBIAN_NETWORKING_UMTSR5

	switch (aEvent)

		{

	case KContextParametersChangeEvent:

		iListener.iContextParametersEventData.iPdpId = iPdpId;

		iListener.iPdpFsmInterface->Get(iPdpId, neg);

		iListener.iContextParametersEventData.iNegotiated = neg;

		switch (iUmtsRelease)

			{

			case TPacketDataConfigBase::KConfigGPRS:

				{

				iListener.iPdpFsmInterface->Get(iPdpId, iListener.iContextParametersEventData.iContextConfig);

				}

				break;

			case TPacketDataConfigBase::KConfigRel99Rel4:

				{

				iListener.iPdpFsmInterface->Get(iPdpId, iListener.iContextParametersEventData.iContextConfigR99_R4);

				}

				break;

			case TPacketDataConfigBase::KConfigRel5:

				{

				iListener.iPdpFsmInterface->Get(iPdpId, iListener.iContextParametersEventData.iContextConfig_R5);

				}

				break;

			}

		status = &iListener.iFsmContextParameterChangeStatus;

		break;

	case KNetworkStatusEvent:

		status = &iListener.iFsmNetworkStatusStatus;

		break;

	case KContextBlockedEvent:

		iListener.iContextBlockedEventPdpId = iPdpId;

		status = &iListener.iFsmContextSuspendedStatus;

		break;

	case KContextUnblockedEvent:

		iListener.iContextUnblockedEventPdpId = iPdpId;

		status = &iListener.iFsmContextResumedStatus;

		break;

	default:

		iListener.iFsmInputResponseData.iPdpId = iPdpId;

		iListener.iFsmInputResponseData.iEvent = aEvent;

		iListener.iFsmInputResponseData.iParam = aParam;

		status = &iListener.iFsmInputResponseStatus;

		break;

		}

	iListener.iParentThread.RequestComplete(status, KErrNone);	

	}

CSpudUnitTestEventHandler *CSpudUnitTestEventHandler::NewL(CInputRequestListener& aListener, TInt aUmtsRelease)

	{

	return new(ELeave) CSpudUnitTestEventHandler(aListener, aUmtsRelease);

	}

CSpudUnitTestEventHandler::CSpudUnitTestEventHandler(CInputRequestListener& aListener, TInt aUmtsRelease)

	: iListener(aListener), iUmtsRelease(aUmtsRelease)

	{

	}