// Copyright (c) 2000-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the License "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:

//

//  INCLUDES

#include "ctlbsposclientholder.h"

#include "ctlbsposclient.h"

// CONSTANTS

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

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

// might leave.

//

CT_LbsPosClientHolder::CT_LbsPosClientHolder() 

: CActive(EPriorityHigh), iRequestsActive(EFalse), iCancelTime(0)

    {

    }

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

// CT_LbsPosClientHolder::ConstructL

//

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

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

//

void CT_LbsPosClientHolder::ConstructL(TInt aRequestCount, TUid aPsy, TBool aSameServer) 

    {

    User::LeaveIfError(iTimer.CreateLocal());

    CActiveScheduler::Add(this);

    User::LeaveIfError(iPosServer.Connect());

    CT_LbsPosClient* requester = NULL;

    for (TInt i = 0; i < aRequestCount; i++)

        {

        if (aSameServer)

            {

            requester = CT_LbsPosClient::NewL(this, aPsy,iPosServer);

            }

        else

            {

            requester = CT_LbsPosClient::NewL(this, aPsy);

            }

        CleanupStack::PushL(requester);

        User::LeaveIfError(iRequesters.Append(requester));

        CleanupStack::Pop(requester);

        }

    }

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

// CT_LbsPosClientHolder::NewLC

//

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

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

//

CT_LbsPosClientHolder* CT_LbsPosClientHolder::NewLC(TInt aRequestCount, TUid aPsy, TBool aSameServer) 

    {

    CT_LbsPosClientHolder* self = new (ELeave) CT_LbsPosClientHolder;

    CleanupStack::PushL(self);

    self->ConstructL(aRequestCount, aPsy, aSameServer);

    return self;

    }

// Destructor

CT_LbsPosClientHolder::~CT_LbsPosClientHolder()

    {

    Cancel();

    iTimer.Close();

    iRequesters.ResetAndDestroy();

    iRequesters.Close();

    iRequestersWhoWillCancel.Close();

    iPosServer.Close();

    }

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

// CT_LbsPosClientHolder::MakeRequests

//

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

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

//

void CT_LbsPosClientHolder::MakeRequests()

    {

    if (iRequestsActive)

        {

        return;

        }

    iRequestsActive = ETrue;

    TInt requesterCount = iRequesters.Count();

    iNofRequestsDone = 0;

    for (TInt i = 0; i < requesterCount; i++)

        {

        iRequesters[i]->MakeRequest();

        }

    // initiate cancelling if this is set.

    if (iRequestersWhoWillCancel.Count() > 0)

        {

        iTimer.After(iStatus, iCancelTime);

        SetActive();

        }

    CActiveScheduler::Start();

    }

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

// CT_LbsPosClientHolder::HandleRequestDone

//

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

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

//

void CT_LbsPosClientHolder::HandleRequestDone()

    {

    iNofRequestsDone++;

    if (iNofRequestsDone == iRequesters.Count())

        {

        iRequestsActive = EFalse;

        CActiveScheduler::Stop();

        }

    }

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

// CT_LbsPosClientHolder::RunL

//

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

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

//

void CT_LbsPosClientHolder::RunL()

    {

    // Cancel certain requests.

    TInt nofRequestersWhoWillCancel = iRequestersWhoWillCancel.Count();

    for (TInt i = 0; i < nofRequestersWhoWillCancel; i++)

        {

        iRequesters[iRequestersWhoWillCancel[i]]->Cancel();

        HandleRequestDone();

        }

    }

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

// CT_LbsPosClientHolder::DoCancel

//

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

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

//

void CT_LbsPosClientHolder::DoCancel()

    {

    iTimer.Cancel();

    }

void CT_LbsPosClientHolder::StopRequests()

    {

    if (!iRequestsActive)

        {

        return;

        }

    Cancel();

    TInt requesterCount = iRequesters.Count();

    for (TInt i = 0; i < requesterCount; i++)

        {

        iRequesters[i]->Cancel();

        }

    CActiveScheduler::Stop();

    iRequestsActive = EFalse;

    }

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

// CT_LbsPosClientHolder::GetResult

//

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

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

//

void CT_LbsPosClientHolder::GetResult(

            TInt& aStatus, 

            TPositionInfo& aModuleInfo,

            TTimeIntervalMicroSeconds& aRequestTime,

            TInt aRequesterIndex)

    {

    iRequesters[aRequesterIndex]->GetResult(aStatus, aModuleInfo, aRequestTime);

    }

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

// CT_LbsPosClientHolder::SetRequesterWillCancelL

//

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

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

//

void CT_LbsPosClientHolder::SetCancelTime(TTimeIntervalMicroSeconds32 aTimeInterval)

	{

	iCancelTime = aTimeInterval;

	}

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

// CT_LbsPosClientHolder::SetRequesterWillCancelL

//

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

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

//

void CT_LbsPosClientHolder::SetRequesterWillCancelL(TInt aIndex)

    {

    TInt length = iRequestersWhoWillCancel.Count();

    for (TInt i = 0; i < length; i++)

        {

        if (iRequestersWhoWillCancel[i] == aIndex) return;

        }

    User::LeaveIfError(iRequestersWhoWillCancel.Append(aIndex));

    }

// End of File