/*

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

*

*

*/

#include "StopScheduler.h"

#include "MemoryPool.h"

#include "fast_malloc.h"

// MEMBER FUNCTIONS

static const TUint KLessRAM = ( 2*1024*1024 );

static const TUint KMinimumRAM = (1024 * 1024);

static const TTimeIntervalMicroSeconds32 KMemoryCheckIntervalSlow = 1000000;        // 1 second

static const TTimeIntervalMicroSeconds32 KMemoryCheckIntervalFast = 500000;         // 0.5 second

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

// CStopScheduler::CStopScheduler

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

CStopScheduler::CStopScheduler(CMemoryPool& aMemoryPool)

  : CActive( CActive::EPriorityHigh ), iMemoryPool( aMemoryPool ), iState( EIdle ), iNextStop( EAllStop )

    {

    CActiveScheduler::Add( this );

    iCheckTimer.CreateLocal();

    }

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

// CStopScheduler::~CStopScheduler

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

CStopScheduler::~CStopScheduler()

    {

    iCheckTimer.Close();

    Cancel();

    }

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

// CStopScheduler::Start

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

void CStopScheduler::Start( TSchedulerState aState, TInt aMemSize )

    {

    // stopping has a higher priority than collecting

    if( aState <= iState ) return;

    Cancel();

    iMemRequested = aMemSize;

    iState = aState;

    SelfComplete();

    iNextStop = EAllStop;

    }

void CStopScheduler::SelfComplete()

    {

    TRequestStatus* status = &iStatus;

    SetActive();

    User::RequestComplete( status, iState );    

    }

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

// CStopScheduler::RunL

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

void CStopScheduler::RunL()

    {

    if( iState == EStopLoading )

        {

        StopLoading( EOOM_PriorityLow );

        iNextStop &= ~ENormalStop;

        CheckMemoryDefered( KMemoryCheckIntervalFast );

        }

    else if( iState == ECheckMemory )

        {

        TFreeMem freeMem;

        TInt total = iMemoryPool.FreeMemory( freeMem );

        // see if free memory is enough to restore all collectors

        if( freeMem.iHal >= KLessRAM )

            {

            iMemoryPool.RestoreCollectors( EOOM_PriorityLow );

            iState = EIdle;

            iNextStop = EAllStop;

            // recover the rescue buffer, if it is already released.

            iMemoryPool.RestoreRescueBuffer();

            }

        else if( freeMem.iHal >= KMinimumRAM/2 )

            {

            iMemoryPool.RestoreCollectors( EOOM_PriorityMiddle );

            CheckMemoryDefered( KMemoryCheckIntervalSlow );

            iNextStop = EAllStop;

            }

        else if( freeMem.iHal >= KMinimumRAM/4 )

            {

            if( iNextStop & ENormalStop ) 

                {

                StopLoading( EOOM_PriorityLow );

                iNextStop &= ~ENormalStop;

                }

            CheckMemoryDefered( KMemoryCheckIntervalFast );

            }

        else

            {

            if( iNextStop & EEmergencyStop ) 

                {

                StopLoading( EOOM_PriorityHigh );

                iNextStop &= ~EEmergencyStop;

                }

            CheckMemoryDefered( KMemoryCheckIntervalFast );

            }

        }

    }

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

// CStopScheduler::DoCancel

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

void CStopScheduler::DoCancel()

    {

    iState = EIdle;

    }

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

// CStopScheduler::StopLoading

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

void CStopScheduler::StopLoading( TOOMPriority aPriority )

    {

    // stop operations

    for( TInt i=0; i<iMemoryPool.Stoppers().Count(); ++i )

        {

        MOOMStopper* stopper = iMemoryPool.Stoppers()[i];

        if( stopper->Priority() == aPriority )

            stopper->Stop();

        }

    iMemoryPool.SetStopping( EFalse );

    }

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

// CStopScheduler::CheckMemoryDefered

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

void CStopScheduler::CheckMemoryDefered( TTimeIntervalMicroSeconds32 aDelay )

    {

    iState = ECheckMemory;

    if( !IsActive() )

        {

        iCheckTimer.After( iStatus, aDelay );

        SetActive();

        }

    }

// END OF FILE