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

CT_LbsTestActiveManager* CT_LbsTestActiveManager::NewL(TInt aObjectId, MTestFlowObserver& aObserver, TPriority aPriority, CTestStep& aStep)

	{

	CT_LbsTestActiveManager* self = new(ELeave) CT_LbsTestActiveManager(aObjectId, aObserver, aPriority, aStep);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

CT_LbsTestActiveManager::~CT_LbsTestActiveManager()

	{

	Cancel();

	}

CT_LbsTestActiveManager::CT_LbsTestActiveManager(TInt aObjectId, MTestFlowObserver& aObserver, TPriority aPriority, CTestStep& aStep)

	: CTimer(aPriority), iState(EStateNone), iObjectId(aObjectId), 

		iWaiting(EFalse), iIsDeactivated(EFalse), iObserver(aObserver), iStep(aStep)

	{

	CActiveScheduler::Add(this);

	}

void CT_LbsTestActiveManager::StartL(TTimeIntervalMicroSeconds32 aDelay)

	{

	if(iWaiting || iIsDeactivated)

		{

		return;

		}

	iState = EStateWaitingToStart;

	After(aDelay);

	iWaiting = ETrue;

	}

void CT_LbsTestActiveManager::WaitForPosition(TTimeIntervalMicroSeconds32 aDelay)

	{

	if(iWaiting || iIsDeactivated)

		{

		return;

		}

	iState = EStateWaitingForPosition;

	After(aDelay);

	iWaiting = ETrue;

	}

void CT_LbsTestActiveManager::Deactivate()

	{

	iIsDeactivated = ETrue;

	}

TBool CT_LbsTestActiveManager::IsDeactivated()

	{

	return iIsDeactivated;

	}

// MPosServerObserver

void CT_LbsTestActiveManager::OnGetLastKnownPosition(TInt32 aErr, const TPositionInfoBase& aPosInfo)

	{

	iWaiting = EFalse;

	Cancel();

	TRAPD(err, iObserver.OnGetLastKnownPositionL(iObjectId, aErr, aPosInfo));

	if(err != KErrNone)

		{

		RunError(err);

		}

	}

void CT_LbsTestActiveManager::OnNotifyPositionUpdate(TInt32 aErr, const TPositionInfoBase& aPosInfo)

	{

	iWaiting = EFalse;

	Cancel();

	TRAPD(err, iObserver.OnNotifyPositionUpdateL(iObjectId, aErr, aPosInfo));

	if(err != KErrNone)

		{

		RunError(err);

		}

	}

void CT_LbsTestActiveManager::RunL()

	{

	iWaiting = EFalse;

	switch(iState)

		{

		case EStateWaitingToStart:

			{

			iState = EStateNone;

			iObserver.OnReadyL(iObjectId);

			break;

			}

		case EStateWaitingForPosition:

			{

			iState = EStateNone;

			iObserver.OnTimedOutL(iObjectId);

			break;

			}

		default:

			{

			User::Leave(KErrCorrupt);

			}

		}

	}

TInt CT_LbsTestActiveManager::RunError(TInt aError)

	{

	iStep.SetTestStepError(aError);

	iStep.SetTestStepResult(EFail);

	iObserver.StopTest();

	return KErrNone;

	}