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