/*

* Copyright (c) 2007 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: Operation for reading partial landmarks.

*

*

*/

#include    <eposlmasyncops.rsg>

#include    <EPos_LandmarksErrors.h>

#include    <epos_cposlmresourcereader.h>

#include    <EPos_PosLmImplExtension.h>

#include    <epos_poslmlandmarkhandler.h>

#include    <epos_cposlmlocaldbaccess.h>

#include    "EPos_LocalLandmarks.h"

#include    "epos_cposlmlocaldatabase.h"

#include    "EPos_RPosLmLocalAccessSubsession.h"

#include    "EPos_CPosLmLocalGetSortedIdsOp.h"

const TInt KGranularity = 128;

const TReal32 KOperationDone = 1;

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

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

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

//

CPosLmLocalGetSortedIdsOp::CPosLmLocalGetSortedIdsOp(

    CPosLmLocalDatabase& aDb, TPosLmSortPref aSortPref ) :

    CPosLmLocalOperation(aDb),

    iSortPref( aSortPref ),

    iStatusFlag( KPosLmOperationNotComplete )

    {

    }

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

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

//

void CPosLmLocalGetSortedIdsOp::ConstructL()

    {

    BaseConstructL();

    iIdArray = new (ELeave) CArrayFixSeg<TPosLmItemId>( KGranularity );

    ReadInfoFromResourceFileL();

    AquireLockL( CPosLmLocalDatabase::EReadLock );

    }

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

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

//

CPosLmLocalGetSortedIdsOp* CPosLmLocalGetSortedIdsOp::NewL(

    CPosLmLocalDatabase& aDb,

    TPosLmSortPref aSortPref )

    {

    CPosLmLocalGetSortedIdsOp* self = new (ELeave)

        CPosLmLocalGetSortedIdsOp( aDb, aSortPref );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

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

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

//

CPosLmLocalGetSortedIdsOp::~CPosLmLocalGetSortedIdsOp()

    {

    if ( iIdArray )

        {

        delete iIdArray;

        }

    }

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

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

//

TInt CPosLmLocalGetSortedIdsOp::NextStepL( TReal32& aProgress )

    {

    TPosLmItemId* ids = new (ELeave) TPosLmItemId[ iIdBatchSize ];

    CleanupStack::PushL( ids );

    TInt remainder( 0 );

    TInt result = iDb->NameIndex().ReadSortedIds( ids, iCurrent, iIdBatchSize, remainder );

    if ( result < 0 )

        {

        User::Leave( result );

        }

    else // result >= 0

        {

        for ( int i = 0; i < result ; i++)

            {

            iIdArray->AppendL( ids[i] );

            }

        iCurrent += result;

        }

    if ( remainder <= 0 ) // all retrieved

        {

        iStatusFlag = KErrNone;

        aProgress = KOperationDone;

        ReleaseLock();

        }

    else

        {

        aProgress = TReal32( iCurrent ) / TReal32( iCurrent + remainder );

        }

    CleanupStack::PopAndDestroy( ids );

    return iStatusFlag;

    }

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

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

//

void CPosLmLocalGetSortedIdsOp::HandleError( TInt& aError )

    {

    iStatusFlag = aError;

    ReleaseLock();

    }

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

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

//

void CPosLmLocalGetSortedIdsOp::GetResultL( RArray<TPosLmItemId>& aIdArray )

    {

    aIdArray.Reset();

    aIdArray.ReserveL( iIdArray->Count() );

    if ( iSortPref.SortOrder() == TPosLmSortPref::EAscending )

        {

        for ( TInt i = 0; i < iIdArray->Count(); i++ )

            {

            }

        }

    else

        {

        for ( TInt i = iIdArray->Count() - 1; i >= 0; i-- )

            {

            }

        }

    }

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

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

//

void CPosLmLocalGetSortedIdsOp::ReadInfoFromResourceFileL()

    {

    CPosLmResourceReader* resources =

        CPosLmResourceReader::NewLC(KPosLocalSuboperationResourceFile);

    iIdBatchSize = resources->ReadInt32L( R_POS_LM_LOCAL_GET_SORTED_IDS_OP );

    if ( iIdBatchSize <= 0 )

        {

        Panic(KPosLandmarksClientPanic,

            EPosInvalidValueSpecifiedInResourceFile );

        }

    CleanupStack::PopAndDestroy( resources );

    }