/*
* Copyright (c) 2002-2005 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: A local representation of the operation class assigned for operations that
* modifies the database.
*
*
*/


#include    <epos_cposlmlocaldbaccess.h>
#include    <epos_cposlmresourcereader.h>

#include    "epos_cposlmlocaldatabase.h"
#include    "EPos_RPosLmLocalAccessSubsession.h"
#include    "EPos_LocalLandmarks.h"
#include    "EPos_CPosLmLocalModifyOp.h"

const TReal32 KPosLmLocalSubOpInitialProgress = 0.05f;
const TReal32 KPosLmLocalSubOpProgressChange = 0.9f;
const TReal32 KPosLmLocalSubOpAlmost100Percent = 0.99f;


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

// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
//
CPosLmLocalModifyOp::CPosLmLocalModifyOp(
    CPosLmLocalDatabase& aDb) :
    CPosLmLocalOperation(aDb),
    iStatusFlag(KPosLmOperationNotComplete),
    iCompactState(ECompactSubOperationOff)
    {
    }

// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
//
void CPosLmLocalModifyOp::BaseConstructL()
    {
    CPosLmLocalOperation::BaseConstructL();

    AquireLockL(CPosLmLocalDatabase::EWriteLock);
    User::LeaveIfError(iDb->DatabaseAccess()->BeginTransaction());
    if ( iUsesServerData )
        {
        iDb->BeginServerTransactionL();
        }
    }

// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
//
CPosLmLocalModifyOp::~CPosLmLocalModifyOp()
    {
    delete iCompactSubOp;
    }

// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
//
TInt CPosLmLocalModifyOp::NextStepL(
    TReal32& aProgress)
    {
    if (iCompactState == ECompactSubOperationOn)
        {
        // Compact state. Continue compacting sub operation.
        TReal32 progress;
        if (iCompactSubOp->NextL(progress))
            {
            delete iCompactSubOp;
            iCompactSubOp = NULL;
            iCompactState = ECompactSubOperationOff;
            }

        aProgress = iSavedProgress +
            CalculateSubOperationProgress(Step(), progress);
        }
    else
        {
        // Normal operation state
        DoNextStepPreL(aProgress);

        User::LeaveIfError(iDb->DatabaseAccess()->CommitTransaction());
        if ( iUsesServerData )
            {
            iDb->CommitServerTransactionL();
            }

        if (iDb->DatabaseAccess()->IsCompactNeededL())
            {
            RecalculateProgressDueToCompact(aProgress, Step());

            iCompactState = ECompactSubOperationOn;
            iSavedProgress = aProgress;
            iCompactSubOp = CPosLmCompactDatabase::NewL(*iDb->DatabaseAccess());
            }
        }

    if (iCompactState == ECompactSubOperationOff)
        {
        if (DoNextStepPostL(aProgress))
            {
            User::LeaveIfError(iDb->DatabaseAccess()->BeginTransaction());
            if ( iUsesServerData )
                {
                iDb->BeginServerTransactionL();
                }
            }
        else
            {
            ReleaseLock();
            }
        }

    return iStatusFlag;
    }

// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
//
void CPosLmLocalModifyOp::ReadInfoFromResourceFileL(
    TInt aResourceId)
    {
    CPosLmResourceReader* resources = CPosLmResourceReader::NewLC(
        KPosLocalSuboperationResourceFile);
    iNoOfSubOperations = resources->ReadInt32L(aResourceId);
    CleanupStack::PopAndDestroy(resources);

    CheckResourceValue(aResourceId, iNoOfSubOperations);
    }

// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
//
void CPosLmLocalModifyOp::RollbackIfNeeded()
    {
    if ( iStatusFlag != KErrNone )
        {
        if (iDb->DatabaseAccess()->InTransaction())
            {
            iDb->DatabaseAccess()->RollbackTransaction();
            if ( iUsesServerData )
                {
                iDb->RollbackServerTransaction();
                }
            }
        ReleaseLock();
        }
    }

// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
//
TBool CPosLmLocalModifyOp::IsInCompactingState()
    {
    return (iCompactState == ECompactSubOperationOn);
    }

// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
//
TReal32 CPosLmLocalModifyOp::CalculateSubOperationProgress(
    TReal32 aProgressStep,
    TReal32 aCompactProgress)
    {
    return aProgressStep * (KPosLmLocalSubOpInitialProgress +
        KPosLmLocalSubOpProgressChange * aCompactProgress);
    }

// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
//
void CPosLmLocalModifyOp::RecalculateProgressDueToCompact(
    TReal32& aProgress,
    TReal32 aProgressStep)
    {
    aProgress = aProgress - aProgressStep * KPosLmLocalSubOpAlmost100Percent;
    }