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

//

// INCLUDE FILES

#include "EPos_CPosControllerBase.h"

#include "EPos_CPosSimulationPositioner.h"

#include <e32debug.h>

//consts

const TInt KDefaultReadInterval(1000000); //1 second

// ================= MEMBER FUNCTIONS =======================

// C++ default constructor can NOT contain any code, that

// might leave.

//

CPosControllerBase::CPosControllerBase(TBool aTimeRelativePlayback)

: CActive(EPriorityStandard), iTimeRelativePlayback(aTimeRelativePlayback),

iTimeBetweenReads(KDefaultReadInterval)

    {

    }

// Destructor

CPosControllerBase::~CPosControllerBase()

    {

    CancelAllNotifyPositionUpdate();

    iSimulationPositioners.Close();

    }

void CPosControllerBase::CompleteRequest(const TInt aIndex, TInt aErrorCode)

	{

	if (aIndex > KErrNotFound && aIndex < iSimulationPositioners.Count())

	    {

	    TRequestStatus& status = iSimulationPositioners[aIndex].iReqStatus;

		iSimulationPositioners[aIndex].iSimPos.CompleteRequest(status, aErrorCode);

		iSimulationPositioners.Remove(aIndex);

	    }

	else

		{

		User::Panic(_L("iSimulationPositioners corrupted"), KErrCorrupt);

		}

	}

// ----------------------------------------------------------------------------

// CPosNmeaController::CancelNotifyPositionUpdate

//

// (other items were commented in a header).

// ----------------------------------------------------------------------------

//

void CPosControllerBase::CancelNotifyPositionUpdate(const CPosSimulationPositioner& aSimPos)

    {

    TInt index = FindPositioner(aSimPos);

    if (index > KErrNotFound)

    	{

		TRequestStatus& rs = iSimulationPositioners[index].iReqStatus;

		CompleteRequest(index, KErrCancel);

    	}

    }

void CPosControllerBase::CancelAllNotifyPositionUpdate()

    {

    while ( iSimulationPositioners.Count() > 0 )

    	{

    	//complete always first of iSimulationPositioner

    	//because CompleteRequest deletes completed positioner

    	CompleteRequest(0, KErrCancel);

    	}

//    for(TInt index=0; index < iSimulationPositioners.Count(); index++)

//    	{

//		CompleteRequest(index, KErrCancel);

//		index--;

//    	}

    }

void CPosControllerBase::NotifyPositionUpdateBase(TPositionInfoBase& aPosInfo, TRequestStatus& aStatus, CPosSimulationPositioner& aSimPos)

	{

    aStatus = KRequestPending;

    CPosSimulationPositioner::ClearAndSetDefaultPositionData(aPosInfo);

    TPositionerReference ref(aSimPos,aStatus, static_cast<TPositionInfo&>(aPosInfo));

    TInt err = iSimulationPositioners.Append(ref);

    if (err != KErrNone)

    	{

    	//not using CopleteRequest(const CPosSimulationPositioner&, TRequestStatus&, TInt)

    	//because adding positioner to array was unsuccessful then we can't remove it 

    	//from it. It could cause PANIC

    	aSimPos.CompleteRequest(aStatus, err);

    	}

	}

void CPosControllerBase::CompleteRequestBase(TInt aErrorCode)

	{

	TPosition pos;

	iPosition.GetPosition(pos);

	TInt i = 0;

	while (i < iSimulationPositioners.Count())

		{

		if (aErrorCode != KPositionPartialUpdate

				|| iSimulationPositioners[i].iSimPos.PartialUpdateAllowed())

			{

			iSimulationPositioners[i].iPosition.SetPosition(pos);

			CompleteRequest(i, aErrorCode);

			//complete request removes current position from iSimulationPositioners

			//then wee need to not modify iterator

			}

		else

			{

			i++;

			}

		}

//	for(TInt i=0; i < iSimulationPositioners.Count(); i++)

//		{

//		if(aErrorCode!=KPositionPartialUpdate || 

//				iSimulationPositioners[i].iSimPos.PartialUpdateAllowed() )

//			{

//			iSimulationPositioners[i].iPosition.SetPosition(pos);

//			CompleteRequest(i, aErrorCode);

//			//complete request removes current position from iSimulationPositioners

//			//then wee need to modify iterator

//			i--;

//			}

//		}

	CPosSimulationPositioner::ClearAndSetDefaultPositionData(iPosition);

	}

TInt CPosControllerBase::FindPositioner(const CPosSimulationPositioner& aSimPos)

	{

	TInt ret = KErrNotFound;

	for(TInt i = 0; i < iSimulationPositioners.Count(); i++)

		{

		if( &iSimulationPositioners[i].iSimPos == &aSimPos)

			{

			ret = i;

			break;

			}

		}

	return ret;

	}

//  End of File