--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/satengine/SatServer/SystemState/src/CSatCenRepChangeNotifier.cpp	Tue Feb 02 01:11:09 2010 +0200
@@ -0,0 +1,269 @@
+/*
+* Copyright (c) 2002-2007 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:  Notifies the changes in central repository values.
+*
+*/
+
+
+
+// INCLUDE FILES
+#include    <centralrepository.h>
+#include    "CSatCenRepChangeNotifier.h"
+#include    "MSatSystemStateObserver.h"
+#include    "Panic.h"
+#include    "SatLog.h"
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// CSatCenRepChangeNotifier::CSatCenRepChangeNotifier
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// -----------------------------------------------------------------------------
+//
+CSatCenRepChangeNotifier::CSatCenRepChangeNotifier(
+    const TUid& aCenRepCategory,
+    TUint32 aCenRepId,
+    MSatSystemStateObserver& aObserver,
+    TInt aCenRepType ) :
+    CActive( EPriorityStandard ),
+    iObserver( aObserver ),
+    iCenRepCategory( aCenRepCategory ),
+    iCenRepId( aCenRepId ),
+    iCenRepType( aCenRepType )
+    {
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
+        CSatCenRepChangeNotifier calling" )
+    // Log parameters
+    LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
+        CSatCenRepChangeNotifier Category: %d", aCenRepCategory )
+    LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
+        CSatCenRepChangeNotifier ID: %d", aCenRepId )
+    LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
+        CSatCenRepChangeNotifier Type: %d ", aCenRepType )
+
+    CActiveScheduler::Add( this );
+
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
+        CSatCenRepChangeNotifier exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatCenRepChangeNotifier::NewL
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+//
+CSatCenRepChangeNotifier* CSatCenRepChangeNotifier::NewL(
+    const TUid& aCenRepCategory,
+    TUint32 aCenRepId,
+    MSatSystemStateObserver& aObserver,
+    TInt aCenRepType )
+    {
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::NewL calling" )
+
+    CSatCenRepChangeNotifier* self =
+        new( ELeave ) CSatCenRepChangeNotifier(
+            aCenRepCategory, aCenRepId, aObserver, aCenRepType );
+
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    CleanupStack::Pop( self );
+
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::NewL exiting" )
+    return self;
+    }
+
+
+// Destructor
+CSatCenRepChangeNotifier::~CSatCenRepChangeNotifier()
+    {
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
+        ~CSatCenRepChangeNotifier calling" )
+
+    Cancel();
+    if ( iCenRepClient )
+        {
+        delete iCenRepClient;
+        iCenRepClient = NULL;
+        }
+
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::\
+        ~CSatCenRepChangeNotifier exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatCenRepChangeNotifier::ConstructL
+// Creates central repository object.
+// (other items were commented in a header).
+// -----------------------------------------------------------------------------
+//
+void CSatCenRepChangeNotifier::ConstructL()
+    {
+    LOG( SIMPLE,
+        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::ConstructL calling" )
+
+    iCenRepClient = CRepository::NewL( iCenRepCategory );
+
+    LOG( SIMPLE,
+        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::ConstructL exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatCenRepChangeNotifier::NotifyChangeL
+// Issues notification request.
+// (other items were commented in a header).
+// -----------------------------------------------------------------------------
+//
+void CSatCenRepChangeNotifier::NotifyChangeL()
+    {
+    LOG( SIMPLE,
+        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::NotifyChangeL calling" )
+
+    __ASSERT_ALWAYS( !IsActive(), Panic( ESatSystemStateAllReadyActive ) );
+    ActivateL();
+
+    LOG( SIMPLE,
+        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::NotifyChangeL exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatCenRepChangeNotifier::CancelNotify
+// Cancels outstanding request.
+// (other items were commented in a header).
+// -----------------------------------------------------------------------------
+//
+void CSatCenRepChangeNotifier::CancelNotify()
+    {
+    LOG( SIMPLE,
+        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::CancelNotify calling" )
+
+    Cancel();
+
+    LOG( SIMPLE,
+        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::CancelNotify exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatCenRepChangeNotifier::DoCancel
+// (other items were commented in a header).
+// -----------------------------------------------------------------------------
+//
+void CSatCenRepChangeNotifier::DoCancel()
+    {
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::DoCancel calling" )
+
+    // Cancel all notifications. This causes notification mechanism to return
+    // KInvalidNotificationId in the RunL function, so it must be handled there.
+    iCenRepClient->NotifyCancelAll();
+
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::DoCancel exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatCenRepChangeNotifier::RunL
+// Activates the request again and calls the observer.
+// (other items were commented in a header).
+// -----------------------------------------------------------------------------
+//
+void CSatCenRepChangeNotifier::RunL()
+    {
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL calling" )
+
+    // In CenRep CRepository returns the key for the changed value in iStatus.
+    const TUint32 cenRepId( iStatus.Int() );
+    LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
+    iStatus: %d", iStatus.Int() )
+    // Makes sure that all the changes are notified.
+    if ( KErrCancel != iStatus.Int() )
+        {
+        ActivateL();
+        }
+        
+    // Check that notification came from that ID we are observing.
+    if ( cenRepId == iCenRepId )
+        {
+        LOG( SIMPLE, 
+        "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL cenRepId == iCenRepId" )
+        switch ( iCenRepType )
+            {
+            case ECRTypeInteger:
+                {
+                TInt value;
+                iCenRepClient->Get( iCenRepId, value );
+                LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
+                    Notifying TInt value: %d", value )
+                iObserver.StateChanged( value );
+                break;
+                }
+            case ECRTypeReal:
+                {
+                TReal value;
+                iCenRepClient->Get( iCenRepId, value );
+                LOG2( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
+                    Notifying TReal value: %d", value )
+                iObserver.StateChanged( value );
+                break;
+                }
+            case ECRTypeDesC8:
+                {
+                TBuf8<NCentralRepositoryConstants::KMaxBinaryLength> value;
+                iCenRepClient->Get( iCenRepId, value );
+                LOG( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
+                    Notifying string value" )
+                iObserver.StateChanged( value );
+                break;
+                }
+            case ECRTypeDesC16:
+                {
+                TBuf16<NCentralRepositoryConstants::KMaxUnicodeStringLength> value;
+                iCenRepClient->Get( iCenRepId, value );
+                LOG( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
+                    Notifying Unicode value" )
+                iObserver.StateChanged( value );
+                break;
+                }
+            case ECRTypeUnknown:
+            default:
+                {
+                LOG( NORMAL, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL \
+                    Notifying without value" )
+                // If type is not defined, call StateChanged without parameters
+                iObserver.StateChanged();
+                break;
+                }
+            }
+        }
+
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::RunL exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatCenRepChangeNotifier::ActivateL
+// (other items were commented in a header).
+// -----------------------------------------------------------------------------
+//
+void CSatCenRepChangeNotifier::ActivateL()
+    {
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::ActivateL calling" )
+
+    // This request notifies all changes in this category, not just the one we
+    // are observing. Thus we have to read the value from CenRep before
+    // notification.
+    User::LeaveIfError( iCenRepClient->NotifyRequest( iCenRepId, iStatus ) );
+    SetActive();
+
+    LOG( SIMPLE, "SATSYSTEMSTATE: CSatCenRepChangeNotifier::ActivateL exiting" )
+    }
+
+//  End of File