1 /*

     2 * Copyright (c) 2006 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:  Implementation of the DataBufferQueue Item

    15 *

    16 */

    17 

    18 

    19 #include "DataBufferQueueItem.h"

    20 #include "tracemacros.h"

    21 

    22 using namespace multimedia;

    23 

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

    25 // Contructor

    26 // ---------------------------------------------------------------------------

    27 CDataBufferQueueItem::CDataBufferQueueItem( MBufferObserver& aObserver, 

    28                                             MDataBuffer& aBuffer,

    29                                             TBool aLastBuffer,

    30                                             TUint aBufSeqNum )

    31                                              : CActive(CActive::EPriorityStandard),

    32                                              iObserver(aObserver),

    33                                              iBuffer(aBuffer),

    34                                              iError(KErrNone)

    35     {

    36     CActiveScheduler::Add(this);

    37     iDataBufferAttributesStructPckg().iLastBuffer = aLastBuffer;

    38     iDataBufferAttributesStructPckg().iBufferSeqNum = aBufSeqNum;

    39     }

    40 

    41 // ---------------------------------------------------------------------------

    42 // Destructor

    43 // ---------------------------------------------------------------------------

    44 CDataBufferQueueItem::~CDataBufferQueueItem()

    45     {

    46     Cancel();

    47     }

    48 

    49 // ---------------------------------------------------------------------------

    50 // NewL

    51 // ---------------------------------------------------------------------------

    52 CDataBufferQueueItem* CDataBufferQueueItem::NewL( MBufferObserver& aObserver, 

    53                                                 MDataBuffer& aBuffer,

    54                                                 TBool aLastBuffer,

    55                                                 TUint aBufSeqNum )

    56     {

    57     CDataBufferQueueItem* self = new (ELeave)CDataBufferQueueItem( aObserver, aBuffer, aLastBuffer, aBufSeqNum );

    58     CleanupStack::PushL( self );

    59     self->ConstructL();

    60     CleanupStack::Pop( self );

    61     return self;

    62     }

    63 

    64 // ---------------------------------------------------------------------------

    65 // Second Phase Contructor

    66 // ---------------------------------------------------------------------------

    67 void CDataBufferQueueItem::ConstructL()

    68     {

    69     }

    70 

    71 // ---------------------------------------------------------------------------

    72 // SetActive

    73 // ---------------------------------------------------------------------------

    74 void CDataBufferQueueItem::SetActive()

    75     {

    76     if (!IsActive())

    77         {

    78         CActive::SetActive();

    79         }

    80     }

    81 

    82 // ---------------------------------------------------------------------------

    83 // Buffer

    84 // ---------------------------------------------------------------------------

    85 MDataBuffer& CDataBufferQueueItem::DataBuffer()

    86     {

    87     return iBuffer;

    88     }

    89 

    90 // ---------------------------------------------------------------------------

    91 // Error

    92 // ---------------------------------------------------------------------------

    93 TInt CDataBufferQueueItem::Error()

    94     {

    95     return iError;

    96     }

    97 

    98 // From CActive

    99 void CDataBufferQueueItem::RunL()

   100     {

   101     // Save the error code

   102     iError = iStatus.Int();

   103     // Signal the observer that this request is serviced

   104     iObserver.BufferProcessed( this );

   105     }

   106 

   107 void CDataBufferQueueItem::DoCancel()

   108     {

   109     iObserver.HandleCancel( *this );

   110     }

   111 

   112 TInt CDataBufferQueueItem::RunError( TInt /*aError*/ )

   113     {

   114     return KErrNone;

   115     }

   116 

   117 // ---------------------------------------------------------------------------

   118 // Return buffer attributes serialized in a descriptor

   119 // ---------------------------------------------------------------------------

   120 TDesC8& CDataBufferQueueItem::GetDataBufferAttributesDesc()

   121     {

   122     return iDataBufferAttributesStructPckg; 

   123     }    

   124 

   125 // ---------------------------------------------------------------------------

   126 // Return buffer sequence number

   127 // ---------------------------------------------------------------------------

   128 TUint CDataBufferQueueItem::GetBufferSequenceNumber()

   129     {

   130     return iDataBufferAttributesStructPckg().iBufferSeqNum;

   131     }

   132 

   133 void CDataBufferQueueItem::CompleteSelf( TInt aError )

   134     {

   135     EMC_TRACE3(_L("CDataBufferQueueItem::CompleteSelf:BufSeqNum[%d]aErr[%d]"), \

   136             iDataBufferAttributesStructPckg().iBufferSeqNum, aError);

   137     if ( IsActive() && (iStatus.Int() == KRequestPending) )

   138         {

   139         EMC_TRACE1(_L("CDataBufferQueueItem::CompleteSelf:User::RequestComplete"));

   140         TRequestStatus* status = &iStatus;

   141         User::RequestComplete(status, aError);

   142         }

   143     }

   144 

   145 // End of File