/*

* Copyright (c) 2002 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:  

*   Active object to count messages background for mainview.

*

*/

// INCLUDE FILES

#include "MceUtilsIdleClass.h"

#include "MceLogText.h"

// CONSTANTS

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

CMceUtilsIdleClass* CMceUtilsIdleClass::NewL(

    MMceUtilsIdleClassObserver& aObserver )

    {

    CMceUtilsIdleClass* self = new (ELeave) CMceUtilsIdleClass( aObserver );

    return self;

    }

CMceUtilsIdleClass::CMceUtilsIdleClass(

    MMceUtilsIdleClassObserver& aObserver )

    :   

    CActive( CActive::EPriorityIdle ),

    iObserver( aObserver )

    {

    CActiveScheduler::Add(this);

    }

// destructor

CMceUtilsIdleClass::~CMceUtilsIdleClass()

    {

    Cancel();

    }

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

// CMceUtilsIdleClass::StartL

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

//

void CMceUtilsIdleClass::StartL()

    {

    MCELOGGER_ENTERFN("CMceUtilsIdleClass::StartL()");

    if(!IsActive())

        {

        TRequestStatus *s = &iStatus;

        User::RequestComplete(s, KErrNone);

        SetActive();

        MCELOGGER_WRITE_TIMESTAMP("Started at: ");

        }

#ifdef _DEBUG

    else

        {

        MCELOGGER_WRITE_TIMESTAMP("Already running, time: ");

        }        

#endif

        MCELOGGER_LEAVEFN("CMceUtilsIdleClass::StartL()");

    }

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

// CMceUtilsIdleClass::FinishL

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

//

void CMceUtilsIdleClass::ForceFinishL()

    {

    MCELOGGER_ENTERFN("CMceUtilsIdleClass::ForceFinishL()");

    if(IsActive())

        {

        // First consume the outstanding completion.

        Cancel();

        // Now try to do remaining steps synchronously.

        TBool startAgain = EFalse;

        TInt i = 0;

        MCELOGGER_WRITE_TIMESTAMP("start time: ");

        startAgain = iObserver.MMceUtilsIdleClassStepL();

        while( startAgain && i < 100 /* safety */)

            {

            i++;

            startAgain = iObserver.MMceUtilsIdleClassStepL();

            }

        MCELOGGER_WRITE_TIMESTAMP("stop time: ");

        }

    MCELOGGER_LEAVEFN("CMceUtilsIdleClass::ForceFinishL()");

    }

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

// CMceUtilsIdleClass::DoCancel

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

//

void CMceUtilsIdleClass::DoCancel()

    {

    }

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

// CMceUtilsIdleClass::RunL

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

//

void CMceUtilsIdleClass::RunL()

    {

    MCELOGGER_ENTERFN("CMceUtilsIdleClass::RunL()");

    QueueNextL();

#ifdef _DEBUG    

    if(!IsActive())

        {

        MCELOGGER_WRITE("CMceUtilsIdleClass: finished");

        MCELOGGER_WRITE_TIMESTAMP("CMceUtilsIdleClass Time: ");

        }

#endif        

    MCELOGGER_LEAVEFN("CMceUtilsIdleClass::RunL()");

    }

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

// CMceUtilsIdleClass::RunError

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

//

TInt CMceUtilsIdleClass::RunError(TInt /*aError*/)

    {

    // ignore all the errors

    return KErrNone;

    }

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

// CMceUtilsIdleClass::QueueLoad

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

//

void CMceUtilsIdleClass::QueueNextL()

    {

    MCELOGGER_ENTERFN("CMceUtilsIdleClass::QueueNextL()");

    TBool startAgain = EFalse;

    MCELOGGER_WRITE_TIMESTAMP("About to call MMceUtilsIdleClassStepL: ");

    startAgain = iObserver.MMceUtilsIdleClassStepL();

    MCELOGGER_WRITE_TIMESTAMP("<--- MMceUtilsIdleClassStepL done ");

    // OPEN: should we start again in case of leave?

    // OPEN: Is there need for some safety counter???

    if( startAgain )

        {

        TRequestStatus *s = &iStatus;

        User::RequestComplete(s, KErrNone);

        SetActive();

        MCELOGGER_WRITE_TIMESTAMP("Started again at: ");

        }

    MCELOGGER_LEAVEFN("CMceUtilsIdleClass::QueueNextL()");

    }

//  End of File