activityfw/activitydatabase/hsactivitydbserver/src/activitystoragesynctask.cpp
changeset 103 b99b84bcd2d1
parent 83 156f692b1687
child 104 9b022b1f357c
equal deleted inserted replaced
83:156f692b1687 103:b99b84bcd2d1
     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:
       
    15 *
       
    16 */
       
    17 #include "activitystoragesynctask.h"
       
    18 #include "activitycmd.h"
       
    19 
       
    20 _LIT(KUnsupportedStorageSyncTask, "Unsupported sync storage task");
       
    21 
       
    22 // -----------------------------------------------------------------------------
       
    23 //
       
    24 // -----------------------------------------------------------------------------
       
    25 //
       
    26 void ActivityStorageSyncTask::ExecuteL(MActivityTaskStorage& observers,
       
    27                                        CActivityStorage& dataStorage, 
       
    28                                        const RMessage2& msg)
       
    29 {
       
    30     switch (msg.Function()) {
       
    31     case AddActivity: 
       
    32         AddActivityL(dataStorage, msg);
       
    33         break;
       
    34     case UpdateActivity:
       
    35         UpdateActivityL(dataStorage, msg);
       
    36         break;
       
    37     case RemoveActivity:
       
    38         DeleteActivityL(dataStorage, msg);
       
    39         break;
       
    40     case RemoveApplicationActivities:
       
    41         DeleteApplicationActivitiesL(dataStorage, msg);
       
    42         break;
       
    43     default:
       
    44         //this code shouldn't be called. fatal error: means wrong session implementation 
       
    45         User::Panic(KUnsupportedStorageSyncTask, KErrGeneral);
       
    46     };
       
    47     msg.Complete(KErrNone);
       
    48     NotifyChangeL(observers, msg);
       
    49 }
       
    50 
       
    51 // -----------------------------------------------------------------------------
       
    52 //
       
    53 // -----------------------------------------------------------------------------
       
    54 //
       
    55 void ActivityStorageSyncTask::AddActivityL(CActivityStorage& dataStorage, const RMessage2& msg)
       
    56 {
       
    57     TPckgBuf<TInt> appId;
       
    58     msg.ReadL(KRequestAppIdOffset, appId);
       
    59     
       
    60     RBuf8 actId;
       
    61     CleanupClosePushL(actId);
       
    62     actId.CreateL(msg.GetDesLengthL(KRequestActOffset));
       
    63     msg.ReadL(KRequestActOffset, actId, 0);
       
    64     
       
    65     RBuf8 data;
       
    66     CleanupClosePushL(data);
       
    67     data.CreateL(msg.GetDesLengthL(KRequestData));
       
    68     msg.ReadL(KRequestData, data, 0);
       
    69     
       
    70     dataStorage.AddActivityL(appId(), actId, data);
       
    71     
       
    72     CleanupStack::PopAndDestroy(&data);
       
    73     CleanupStack::PopAndDestroy(&actId);
       
    74 }
       
    75 
       
    76 // -----------------------------------------------------------------------------
       
    77 //
       
    78 // -----------------------------------------------------------------------------
       
    79 //
       
    80 void ActivityStorageSyncTask::UpdateActivityL(CActivityStorage& dataStorage, const RMessage2& msg)
       
    81 {
       
    82     TPckgBuf<TInt> appId;
       
    83     msg.ReadL(KRequestAppIdOffset, appId);
       
    84     
       
    85     RBuf8 actId;
       
    86     CleanupClosePushL(actId);
       
    87     actId.CreateL(msg.GetDesLengthL(KRequestActOffset));
       
    88     msg.ReadL(KRequestActOffset, actId, 0);
       
    89     
       
    90     RBuf8 data;
       
    91     CleanupClosePushL(data);
       
    92     data.CreateL(msg.GetDesLengthL(KRequestData));
       
    93     msg.ReadL(KRequestData, data, 0);
       
    94     
       
    95     dataStorage.UpdateActivityL(appId(), actId, data);
       
    96     
       
    97     CleanupStack::PopAndDestroy(&data);
       
    98     CleanupStack::PopAndDestroy(&actId);
       
    99 }
       
   100 
       
   101 // -----------------------------------------------------------------------------
       
   102 //
       
   103 // -----------------------------------------------------------------------------
       
   104 //
       
   105 void ActivityStorageSyncTask::DeleteActivityL(CActivityStorage& dataStorage, const RMessage2& msg)
       
   106 {
       
   107     TPckgBuf<TInt> appId;
       
   108     msg.ReadL(KRequestAppIdOffset, appId);
       
   109     
       
   110     RBuf8 actId;
       
   111     CleanupClosePushL(actId);
       
   112     actId.CreateL(msg.GetDesLengthL(KRequestActOffset));
       
   113     msg.ReadL(KRequestActOffset, actId, 0);
       
   114     
       
   115     dataStorage.DeleteActivityL(appId(), actId);
       
   116     
       
   117     CleanupStack::PopAndDestroy(&actId);
       
   118 }
       
   119 
       
   120 // -----------------------------------------------------------------------------
       
   121 //
       
   122 // -----------------------------------------------------------------------------
       
   123 //
       
   124 void ActivityStorageSyncTask::DeleteApplicationActivitiesL(CActivityStorage& dataStorage, const RMessage2& msg)
       
   125 {
       
   126     TPckgBuf<TInt> appId;
       
   127     msg.ReadL(KRequestAppIdOffset, appId);
       
   128     dataStorage.DeleteActivitiesL(appId());
       
   129 }
       
   130 
       
   131 // -----------------------------------------------------------------------------
       
   132 //
       
   133 // -----------------------------------------------------------------------------
       
   134 //
       
   135 void ActivityStorageSyncTask::NotifyChangeL(MActivityTaskStorage& observers,
       
   136                           const RMessage2& msg)
       
   137 {
       
   138     const RPointerArray<CActivityTask> &table(observers.StorageData());
       
   139     for (TInt iter(table.Count() - 1); 0 <= iter; --iter) {
       
   140         table[iter]->BroadcastReceivedL(msg);
       
   141     }
       
   142 }