--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/contextframework/cfw/src/cfserver/cfstarter.cpp	Tue Feb 02 10:12:00 2010 +0200
@@ -0,0 +1,284 @@
+/*
+* Copyright (c) 2006-2008 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:  CFStarter class implementation.
+*
+*/
+
+
+#include "cfstarter.h"
+#include "cfstarterobserver.h"
+#include "cfphasedevicestarting.h"
+#include "cfphasedevicestarted.h"
+#include "cfphaseloadingplugins.h"
+#include "cfphaseloadingrules.h"
+#include "cfphasecfwready.h"
+#include "cfwcontextdef.h"
+#include "cfcontextinterface.h"
+#include "cftrace.h"
+
+// CONSTANTS
+
+#ifdef _DEBUG
+
+// Panic category
+_LIT( KPanicCat, "CFStarter" );
+
+// Panic codes
+enum TPanicReason
+    {
+    EInvalidObserver,
+    EAlreadyStarted,
+    EInvalidState
+    };
+
+// Local panic function
+LOCAL_C void Panic( TInt aCode )
+    {
+    User::Panic( KPanicCat, aCode );
+    }
+
+#endif
+
+// MEMBER FUNCTIONS
+
+CCFStarter* CCFStarter::NewL( MCFContextInterface& aCF )
+    {
+    FUNC_LOG;
+    
+    CCFStarter* self = CCFStarter::NewLC( aCF );
+    CleanupStack::Pop( self );
+
+    return self;
+    }
+
+CCFStarter* CCFStarter::NewLC( MCFContextInterface& aCF )
+    {
+    FUNC_LOG;
+    
+    CCFStarter* self = new ( ELeave ) CCFStarter( aCF );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+
+    return self;
+    }
+
+CCFStarter::~CCFStarter()
+    {
+    FUNC_LOG;
+    
+    Cancel();
+    iPhases.ResetAndDestroy();
+    iObservers.Close();
+    }
+
+CCFStarter::CCFStarter( MCFContextInterface& aCF ):
+    CActive( EPriorityStandard ),
+    iCF( aCF )
+    {
+    FUNC_LOG;
+    
+    CActiveScheduler::Add( this );
+    }
+
+void CCFStarter::ConstructL()
+    {
+    FUNC_LOG;
+    
+    // Construct starter phases
+    iPhases.InsertL(
+        CCFPhaseDeviceStarting::NewL( iCF ),
+        CCFPhaseBase::ECFDeviceStarting );
+    iPhases.InsertL(
+        CCFPhaseDeviceStarted::NewL( iCF ),
+        CCFPhaseBase::ECFDeviceStarted );
+    iPhases.InsertL(
+        CCFPhaseLoadingPlugins::NewL( iCF ),
+        CCFPhaseBase::ECFLoadingPlugins );
+    iPhases.InsertL(
+        CCFPhaseLoadingRules::NewL( iCF ),
+        CCFPhaseBase::ECFLoadingRules );
+    iPhases.InsertL(
+        CCFPhaseCfwReady::NewL( iCF ),
+        CCFPhaseBase::ECFCfwReady );
+    }
+
+// METHODS
+
+//-----------------------------------------------------------------------------
+// CCFStarter::AddObserverL
+//-----------------------------------------------------------------------------
+//
+void CCFStarter::AddObserverL( MCFStarterObserver* aObserver )
+    {
+    FUNC_LOG;
+    
+    __ASSERT_DEBUG( aObserver, Panic( EInvalidObserver ) );
+    
+    iObservers.AppendL( aObserver );
+
+    aObserver->SetEventHandler( *this );
+    }
+
+//-----------------------------------------------------------------------------
+// CCFStarter::Start
+//-----------------------------------------------------------------------------
+//
+void CCFStarter::StartL()
+    {
+    FUNC_LOG;
+    
+    HEAP( "Starting CF initialization" );
+    TIMESTAMP( "Starting CF initialization" );
+    
+    // Define context: [ContextFramework: Status]
+    iCF.DefineContext( KCfwSource, KCfwSourceStatus, KCfwSourceStatusSec );
+    
+    // Set in first state and run it
+    iCurrentPhase = CCFPhaseBase::ECFDeviceStarting;
+    RunNextL();
+    }
+
+//-----------------------------------------------------------------------------
+// CCFStarter::RunL
+//-----------------------------------------------------------------------------
+//
+void CCFStarter::RunL()
+    {
+    FUNC_LOG;
+    
+    // First switch to next phase if error occurs we can continue
+    CCFPhaseBase::TCFPhaseId phaseId = SwitchToNextPhase();
+
+    INFO_1( "Phase %d execution start", phaseId );
+    HEAP_1( "Phase %d execution start", phaseId );
+    TIMESTAMP( "Phase execution start" );
+
+    // Handle current phase
+    if( iStatus == KErrNone )
+        {
+        TInt count = iObservers.Count();
+        for( TInt i = 0; i < count; i++ )
+            {
+            TInt err = KErrNone;
+            TRAP( err, iObservers[i]->InitializePhaseL( phaseId ) );
+            ERROR_3( err, "Phase observer with index: [%d] failed to init in phase: [%d] with error code: %d",
+                i,
+                phaseId,
+                err );
+            }
+        }
+        
+    INFO_1( "Phase %d execution end", phaseId );
+    HEAP_1( "Phase %d execution end", phaseId );
+    TIMESTAMP( "Phase execution end" );
+
+    // Run next phase
+    RunNextL();
+    }
+
+//-----------------------------------------------------------------------------
+// CCFStarter::DoCancel
+//-----------------------------------------------------------------------------
+//
+void CCFStarter::DoCancel()
+    {
+    FUNC_LOG;
+    
+    if( iCurrentPhase < iPhases.Count() )
+        {
+        iPhases[iCurrentPhase]->Cancel();
+        }
+    }
+
+//-----------------------------------------------------------------------------
+// CCFStarter::RunError
+//-----------------------------------------------------------------------------
+//
+TInt CCFStarter::RunError( TInt /*aError*/ )
+    {
+    FUNC_LOG;
+
+    // Current phase failed to run in RunL
+    // Switch to next phase
+    SwitchToNextPhase();
+    TInt count = iPhases.Count();
+    for( TInt i = iCurrentPhase; i < count; i++ )
+        {
+        TRAPD( err, RunNextL() );
+        if( err == KErrNone )
+            {
+            break;
+            }
+        else
+            {
+            // Failed to run next phase again
+            // Switch to next phase
+            SwitchToNextPhase();
+            }
+        }
+    return KErrNone;
+    }
+
+//-----------------------------------------------------------------------------
+// CCFStarter::HandleEvent
+//-----------------------------------------------------------------------------
+//
+void CCFStarter::HandleEvent( TCFStarterEvents aEvent )
+    {
+    FUNC_LOG;
+    
+    if( iCurrentPhase >= 0 && iCurrentPhase < iPhases.Count() )
+        {
+        iPhases[iCurrentPhase]->HandleEvent( aEvent );	
+        }    
+    }
+
+//-----------------------------------------------------------------------------
+// CCFStarter::SwitchToNextPhase
+//-----------------------------------------------------------------------------
+//
+CCFPhaseBase::TCFPhaseId CCFStarter::SwitchToNextPhase()
+    {
+    FUNC_LOG;
+    
+    __ASSERT_DEBUG( iCurrentPhase >= 0 && iCurrentPhase < iPhases.Count(),
+        Panic( EInvalidState ) );
+
+    CCFPhaseBase::TCFPhaseId previous = iCurrentPhase;
+    iCurrentPhase = iPhases[iCurrentPhase]->NextPhase();
+    
+    return previous;
+    }
+
+//-----------------------------------------------------------------------------
+// CCFStarter::RunNextL
+//-----------------------------------------------------------------------------
+//
+void CCFStarter::RunNextL()
+    {
+    FUNC_LOG;
+
+    __ASSERT_DEBUG( !IsActive(), Panic( EAlreadyStarted ) );
+
+    if( iCurrentPhase < iPhases.Count() )
+        {
+        iStatus = KRequestPending;
+        iPhases[iCurrentPhase]->ExecuteL( &iStatus );
+        SetActive();
+        }
+    else
+        {
+        HEAP( "[END] CF Starter phases executed" );
+        }
+    }