alwayson_net_plugin/pdpcontextmanager2/src/cenrepobserver.cpp
changeset 3 f7816ffc66ed
child 41 bbb64eb3bdee
equal deleted inserted replaced
2:086aae6fc07e 3:f7816ffc66ed
       
     1 /*
       
     2 * Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
       
     3 * All rights reserved.
       
     4 * This component and the accompanying materials are made available
       
     5 * under the terms of "Eclipse Public License v1.0"
       
     6 * which accompanies this distribution, and is available
       
     7 * at the URL "http://www.eclipse.org/legal/epl-v10.html".
       
     8 *
       
     9 * Initial Contributors:
       
    10 * Nokia Corporation - initial contribution.
       
    11 *
       
    12 * Contributors:
       
    13 *
       
    14 * Description:  Listens to changes in a Central Repository key 
       
    15 *               KCurrentCellularDataUsage in Repository KCRUidCmManager.
       
    16 */
       
    17 
       
    18 #include <commsdat.h>
       
    19 #include <centralrepository.h>
       
    20 #include <cmmanagerkeys.h>
       
    21 
       
    22 #include "cenrepobserver.h"
       
    23 #include "logger.h"
       
    24 
       
    25 // -----------------------------------------------------------------------------
       
    26 // CAOCenRepObserver::NewL
       
    27 // -----------------------------------------------------------------------------
       
    28 //
       
    29 CAOCenRepObserver* CAOCenRepObserver::NewL( MAOCenRepObserver& aObserver )
       
    30     {
       
    31     CAOCenRepObserver* self = 
       
    32              CAOCenRepObserver::NewLC( aObserver );
       
    33     CleanupStack::Pop( self );
       
    34     return self;
       
    35     }
       
    36 
       
    37 // -----------------------------------------------------------------------------
       
    38 // CAOCenRepObserver::NewLC
       
    39 // -----------------------------------------------------------------------------
       
    40 //
       
    41 CAOCenRepObserver* CAOCenRepObserver::NewLC( MAOCenRepObserver& aObserver )
       
    42     {
       
    43     CAOCenRepObserver* self = 
       
    44              new( ELeave ) CAOCenRepObserver( aObserver );
       
    45     CleanupStack::PushL( self );
       
    46     self->ConstructL();
       
    47     return self;
       
    48     }
       
    49 
       
    50 // -----------------------------------------------------------------------------
       
    51 // CAOCenRepObserver::~CAOCenRepObserver
       
    52 // -----------------------------------------------------------------------------
       
    53 //
       
    54 CAOCenRepObserver::~CAOCenRepObserver()
       
    55     {
       
    56     // Cancel outstanding request, if exists
       
    57     Cancel();
       
    58     delete iRepository;
       
    59     }
       
    60 
       
    61 // -----------------------------------------------------------------------------
       
    62 // CAOCenRepObserver::CAOCenRepObserver
       
    63 // -----------------------------------------------------------------------------
       
    64 //
       
    65 CAOCenRepObserver::CAOCenRepObserver( MAOCenRepObserver& aObserver )
       
    66         :
       
    67         CActive( CActive::EPriorityStandard ),
       
    68         iObserver( aObserver )
       
    69     {
       
    70     }
       
    71 
       
    72 // -----------------------------------------------------------------------------
       
    73 // CAOCenRepObserver::ConstructL
       
    74 // -----------------------------------------------------------------------------
       
    75 //
       
    76 void CAOCenRepObserver::ConstructL()
       
    77     {    
       
    78     TRAPD( err, iRepository = CRepository::NewL( KCRUidCmManager ) )
       
    79      
       
    80     if ( err == KErrNone )
       
    81         {
       
    82         CActiveScheduler::Add( this );
       
    83         RequestNotifications();
       
    84         }
       
    85     else
       
    86         {
       
    87         LOG_2( _L("FAILED to open KCRUidCmManager repository <%d>"), err ); 
       
    88         }
       
    89     }
       
    90 
       
    91 // -----------------------------------------------------------------------------
       
    92 // CAOCenRepObserver::RequestNotifications
       
    93 // -----------------------------------------------------------------------------
       
    94 //
       
    95 void CAOCenRepObserver::RequestNotifications()
       
    96     {
       
    97     LOG_1( _L("CAOCenRepObserver::RequestNotifications") );
       
    98 
       
    99     TInt err = iRepository->NotifyRequest( KCurrentCellularDataUsage, iStatus );
       
   100 
       
   101     if ( err == KErrNone )
       
   102         {
       
   103         SetActive();
       
   104         }
       
   105     else
       
   106         {
       
   107         LOG_2( _L("ERROR, iRepository->NotifyRequest() %d"), err );	
       
   108         }
       
   109     }
       
   110 
       
   111 // -----------------------------------------------------------------------------
       
   112 // CAOCenRepObserver::DoCancel
       
   113 // -----------------------------------------------------------------------------
       
   114 //
       
   115 void CAOCenRepObserver::DoCancel()
       
   116     {
       
   117     iRepository->NotifyCancel( KCurrentCellularDataUsage );
       
   118     }
       
   119 
       
   120 // -----------------------------------------------------------------------------
       
   121 // CAOCenRepObserver::RunL
       
   122 // -----------------------------------------------------------------------------
       
   123 //
       
   124 void CAOCenRepObserver::RunL()
       
   125     {
       
   126     LOG_2( _L("CAOCenRepObserver::RunL() %d"), iStatus.Int() );
       
   127 
       
   128     if ( iStatus.Int() < KErrNone )
       
   129         {
       
   130         iErrorCounter++;
       
   131         if ( iErrorCounter > KCenRepErrorRetryCount )
       
   132             {
       
   133             LOG_2( _L("Over %d consecutive errors, stopping notifications permanently"), 
       
   134                    KCenRepErrorRetryCount );	
       
   135             return;
       
   136             }
       
   137         }
       
   138     else
       
   139         {
       
   140         iErrorCounter = 0;
       
   141         
       
   142         TInt value( 0 );
       
   143         TInt err = iRepository->Get( KCurrentCellularDataUsage, value );
       
   144             
       
   145         if ( err == KErrNone )
       
   146             {
       
   147             LOG_2( _L("KCurrentCellularDataUsage: %d"), value );
       
   148                    	
       
   149             TRAPD( leaveCode, iObserver.CurrentCellularDataUsageChangedL( value ) )
       
   150             
       
   151             if ( leaveCode )
       
   152                 {
       
   153                 LOG_2( _L("iObserver->CurrentCellularDataUsageChangedL FAILED: %d"), 
       
   154                        leaveCode );
       
   155                 }
       
   156             }
       
   157         else
       
   158             {
       
   159             LOG_2( _L("ERROR, iRepository->Get(KCurrentCellularDataUsage) %d"), err );
       
   160             }
       
   161         }
       
   162 
       
   163     RequestNotifications();
       
   164     }
       
   165 
       
   166 // End-of-file