mpxplugins/serviceplugins/collectionplugins/mpxsqlitedbcommon/src/mpxdbactivetask.cpp
changeset 0 ff3acec5bc43
equal deleted inserted replaced
-1:000000000000 0:ff3acec5bc43
       
     1 /*
       
     2 * Copyright (c) 2007 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:  Active object to split up long running db tasks
       
    15 *
       
    16 */
       
    17 
       
    18 
       
    19 // INCLUDE FILES
       
    20 #include <e32base.h>
       
    21 #include <mpxlog.h>
       
    22 #include "mpxdbactivetask.h"
       
    23 
       
    24 // ============================ MEMBER FUNCTIONS =============================
       
    25 
       
    26 // ---------------------------------------------------------------------------
       
    27 // Constructor
       
    28 // ---------------------------------------------------------------------------
       
    29 //
       
    30 CMPXDbActiveTask::CMPXDbActiveTask( MMPXDbActiveTaskObserver& aObserver ) :
       
    31     CActive( CActive::EPriorityStandard ),
       
    32     iObserver( aObserver )
       
    33     {
       
    34     MPX_FUNC("CMPXDbActiveTask::CMPXDbActiveTask");
       
    35     CActiveScheduler::Add( this );
       
    36     }
       
    37 
       
    38 // ---------------------------------------------------------------------------
       
    39 // 2nd-phase constructor
       
    40 // ---------------------------------------------------------------------------
       
    41 //
       
    42 void CMPXDbActiveTask::ConstructL()
       
    43     {
       
    44     MPX_FUNC("CMPXDbActiveTask::ConstructL");
       
    45     }
       
    46 
       
    47 // ---------------------------------------------------------------------------
       
    48 // Two-Phase Constructor
       
    49 // ---------------------------------------------------------------------------
       
    50 //
       
    51 EXPORT_C CMPXDbActiveTask* CMPXDbActiveTask::NewL( MMPXDbActiveTaskObserver& aObserver )
       
    52     {
       
    53     MPX_FUNC("CMPXDbActiveTask::NewL");
       
    54 
       
    55     CMPXDbActiveTask* self = new(ELeave) CMPXDbActiveTask( aObserver);
       
    56     CleanupStack::PushL( self );
       
    57     self->ConstructL();
       
    58     CleanupStack::Pop( self );
       
    59     return self;
       
    60     }
       
    61 
       
    62 // ---------------------------------------------------------------------------
       
    63 // Destructor
       
    64 // ---------------------------------------------------------------------------
       
    65 //
       
    66 EXPORT_C CMPXDbActiveTask::~CMPXDbActiveTask()
       
    67     {
       
    68     MPX_FUNC("CMPXDbActiveTask::~CMPXDbActiveTask");
       
    69 
       
    70     Cancel();
       
    71     delete iChangeMessages;
       
    72     delete iCurCommand;
       
    73     }
       
    74 
       
    75 // ---------------------------------------------------------------------------
       
    76 // Start the operation
       
    77 // ---------------------------------------------------------------------------
       
    78 //
       
    79 EXPORT_C void CMPXDbActiveTask::StartL( TMPXCommandId aTask, const CMPXCommand& aCommand )
       
    80     {
       
    81     delete iCurCommand;
       
    82     iCurCommand = NULL;
       
    83     iCurCommand = CMPXMedia::NewL( aCommand );
       
    84     iCurTask = aTask;
       
    85     iCurStep = 0;
       
    86     delete iChangeMessages;
       
    87     iChangeMessages = NULL;
       
    88     iChangeMessages = CMPXMessageArray::NewL();
       
    89     iCurVisibleChange = ENotVisibile;
       
    90 
       
    91     // Start the AO
       
    92     iStatus = KRequestPending;
       
    93     SetActive();
       
    94     TRequestStatus* status = &iStatus;
       
    95     User::RequestComplete( status, KErrNone );
       
    96     }
       
    97 
       
    98 // ---------------------------------------------------------------------------
       
    99 // Get the current step
       
   100 // ---------------------------------------------------------------------------
       
   101 //
       
   102 EXPORT_C TInt CMPXDbActiveTask::GetStep()
       
   103     {
       
   104     MPX_FUNC("CMPXDbActiveTask::GetStep");
       
   105     return iCurStep;
       
   106     }
       
   107 
       
   108 // ---------------------------------------------------------------------------
       
   109 // Get the current task
       
   110 // ---------------------------------------------------------------------------
       
   111 //
       
   112 EXPORT_C TMPXCommandId CMPXDbActiveTask::GetTask()
       
   113     {
       
   114     MPX_FUNC("CMPXDbActiveTask::GetTask");
       
   115     return iCurTask;
       
   116     }
       
   117 
       
   118 // ---------------------------------------------------------------------------
       
   119 // Get the current media
       
   120 // ---------------------------------------------------------------------------
       
   121 //
       
   122 EXPORT_C CMPXMedia& CMPXDbActiveTask::GetCommand()
       
   123     {
       
   124     MPX_FUNC("CMPXDbActiveTask::GetCommand");
       
   125     return *iCurCommand;
       
   126     }
       
   127 
       
   128 // ---------------------------------------------------------------------------
       
   129 // Get the current change messages
       
   130 // ---------------------------------------------------------------------------
       
   131 //
       
   132 EXPORT_C CMPXMessageArray& CMPXDbActiveTask::GetChangeMessages()
       
   133     {
       
   134     MPX_FUNC("CMPXDbActiveTask::GetChangeMessages");
       
   135     return *iChangeMessages;
       
   136     }
       
   137 
       
   138 // ---------------------------------------------------------------------------
       
   139 // Set the visible change flag
       
   140 // ---------------------------------------------------------------------------
       
   141 //
       
   142 EXPORT_C void CMPXDbActiveTask::SetVisibleChange( TChangeVisibility aChange )
       
   143     {
       
   144     MPX_FUNC("CMPXDbActiveTask::SetVisibleChange");
       
   145     iCurVisibleChange = aChange;
       
   146     }
       
   147 
       
   148 // ---------------------------------------------------------------------------
       
   149 // Get the visible change flag
       
   150 // ---------------------------------------------------------------------------
       
   151 //
       
   152 EXPORT_C CMPXDbActiveTask::TChangeVisibility CMPXDbActiveTask::GetVisibleChange()
       
   153     {
       
   154     MPX_FUNC("CMPXDbActiveTask::GetVisibleChange");
       
   155     return iCurVisibleChange;
       
   156     }
       
   157 
       
   158 // ---------------------------------------------------------------------------
       
   159 // From CActive
       
   160 // ---------------------------------------------------------------------------
       
   161 //
       
   162 EXPORT_C void CMPXDbActiveTask::RunL()
       
   163     {
       
   164     MPX_FUNC("CMPXDbActiveTask::RunL");
       
   165 
       
   166     // ETrue is done, EFalse is more to do
       
   167     //
       
   168     if( iObserver.HandleStepL() )
       
   169         {
       
   170         iObserver.HandleOperationCompleted( KErrNone );
       
   171         delete iCurCommand;
       
   172         iCurCommand = NULL;
       
   173         delete iChangeMessages;
       
   174         iChangeMessages = NULL;
       
   175         }
       
   176     else
       
   177         {
       
   178         ++iCurStep;
       
   179         iStatus = KRequestPending;
       
   180         SetActive();
       
   181         TRequestStatus* status = &iStatus;
       
   182         User::RequestComplete( status, KErrNone );
       
   183         }
       
   184     }
       
   185 
       
   186 // ---------------------------------------------------------------------------
       
   187 // From CActive
       
   188 // ---------------------------------------------------------------------------
       
   189 //
       
   190 EXPORT_C void CMPXDbActiveTask::DoCancel()
       
   191     {
       
   192     MPX_FUNC("CMPXDbActiveTask::DoCancel");
       
   193 
       
   194     // Callback and cleanup
       
   195     iObserver.HandleOperationCompleted( KErrCancel );
       
   196     delete iCurCommand;
       
   197     iCurCommand = NULL;
       
   198     iChangeMessages->Reset();
       
   199     }
       
   200 
       
   201 // ---------------------------------------------------------------------------
       
   202 // From CActive
       
   203 // ---------------------------------------------------------------------------
       
   204 //
       
   205 EXPORT_C TInt CMPXDbActiveTask::RunError( TInt aError )
       
   206     {
       
   207     MPX_FUNC("CMPXDbActiveTask::RunError");
       
   208 
       
   209     // Callback and cleanup
       
   210     iObserver.HandleOperationCompleted( aError );
       
   211     delete iCurCommand;
       
   212     iCurCommand = NULL;
       
   213     iChangeMessages->Reset();
       
   214 
       
   215     return KErrNone;
       
   216     }
       
   217 
       
   218 // END OF FILE