--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/webengine/osswebengine/MemoryManager/Src/StopScheduler.cpp	Mon Mar 30 12:54:55 2009 +0300
@@ -0,0 +1,159 @@
+/*
+* 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