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 "activitystorageasynctask.h"

    18 #include "activitycmd.h"

    19 

    20 _LIT(KUnsupportedStorageAsyncTask, "Unsupported async storage task");

    21 

    22 // -----------------------------------------------------------------------------

    23 //

    24 // -----------------------------------------------------------------------------

    25 //

    26 CActivityStorageAsyncTask::CActivityStorageAsyncTask()

    27 {

    28     // No implementation required

    29 }

    30 

    31 // -----------------------------------------------------------------------------

    32 //

    33 // -----------------------------------------------------------------------------

    34 //

    35 CActivityStorageAsyncTask::~CActivityStorageAsyncTask()

    36 {

    37     mData.Close();

    38 }

    39 

    40 // -----------------------------------------------------------------------------

    41 //

    42 // -----------------------------------------------------------------------------

    43 //

    44 void CActivityStorageAsyncTask::ExecuteLD(MActivityTaskStorage& taskStorage, 

    45                                           CActivityStorage& dataStorage, 

    46                                           const RMessage2& msg)

    47 {

    48     CActivityStorageAsyncTask* self = new (ELeave) CActivityStorageAsyncTask();

    49     CleanupStack::PushL(self);

    50     self->ExecuteL(dataStorage, msg);

    51     taskStorage.PushL(self);

    52     CleanupStack::Pop(self);

    53     msg.Complete(KErrNone);

    54 }

    55 

    56 // -----------------------------------------------------------------------------

    57 //

    58 // -----------------------------------------------------------------------------

    59 //

    60 const TDesC8& CActivityStorageAsyncTask::CActivityStorageAsyncTask::Data() const

    61 {

    62     return mData;

    63 }

    64 

    65 // -----------------------------------------------------------------------------

    66 //

    67 // -----------------------------------------------------------------------------

    68 //

    69 void CActivityStorageAsyncTask::BroadcastReceivedL(const RMessage2& )

    70 {

    71     // No implementation required

    72 }

    73 

    74 // -----------------------------------------------------------------------------

    75 //

    76 // -----------------------------------------------------------------------------

    77 //

    78 void CActivityStorageAsyncTask::ExecuteL(CActivityStorage& dataStorage, 

    79                                          const RMessage2& msg)

    80 {

    81     switch (msg.Function()) {

    82     case Activities:

    83         AllActivitiesL(dataStorage, msg);

    84         break;

    85     case ApplicationActivities:

    86         ApplicationActivitiesL(dataStorage, msg);

    87         break;

    88     default:

    89         //this code shouldn't be called. fatal error: means wrong session implementation 

    90         User::Panic(KUnsupportedStorageAsyncTask, KErrGeneral);

    91     };

    92 }

    93 

    94 // -----------------------------------------------------------------------------

    95 //

    96 // -----------------------------------------------------------------------------

    97 //

    98 void CActivityStorageAsyncTask::AllActivitiesL(CActivityStorage& dataStorage, 

    99                                                const RMessage2& msg)

   100 {

   101     dataStorage.ActivitiesL(mData);

   102     WriteResponseL(msg);

   103 }

   104 

   105 // -----------------------------------------------------------------------------

   106 //

   107 // -----------------------------------------------------------------------------

   108 //

   109 void CActivityStorageAsyncTask::ApplicationActivitiesL(CActivityStorage& dataStorage, 

   110                                                        const RMessage2& msg)

   111 {

   112     TPckgBuf<TInt> appId;

   113     msg.ReadL(KRequestAppIdOffset, appId);

   114     dataStorage.ActivitiesL(mData, appId());

   115     WriteResponseL(msg);

   116 }

   117 

   118 // -----------------------------------------------------------------------------

   119 //

   120 // -----------------------------------------------------------------------------

   121 //

   122 void CActivityStorageAsyncTask::WriteResponseL(const RMessage2& msg)

   123 {

   124     msg.WriteL(KResponseDataSizeOffset, TPckgBuf<TInt>(mData.Length()));//write data size

   125     msg.WriteL(KResponseIdOffset, TPckgBuf<CBase*>(this));//task identyfier

   126 }