/*

* Copyright (c) 2006 Nokia Corporation and/or its subsidiary(-ies). 

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:  Implementation of the DataBufferQueue Item

*

*/

#include "DataBufferQueueItem.h"

#include "tracemacros.h"

using namespace multimedia;

// ---------------------------------------------------------------------------

// Contructor

// ---------------------------------------------------------------------------

CDataBufferQueueItem::CDataBufferQueueItem( MBufferObserver& aObserver, 

                                            MDataBuffer& aBuffer,

                                            TBool aLastBuffer,

                                            TUint aBufSeqNum )

                                             : CActive(CActive::EPriorityStandard),

                                             iObserver(aObserver),

                                             iBuffer(aBuffer),

                                             iError(KErrNone)

    {

    CActiveScheduler::Add(this);

    iDataBufferAttributesStructPckg().iLastBuffer = aLastBuffer;

    iDataBufferAttributesStructPckg().iBufferSeqNum = aBufSeqNum;

    }

// ---------------------------------------------------------------------------

// Destructor

// ---------------------------------------------------------------------------

CDataBufferQueueItem::~CDataBufferQueueItem()

    {

    Cancel();

    }

// ---------------------------------------------------------------------------

// NewL

// ---------------------------------------------------------------------------

CDataBufferQueueItem* CDataBufferQueueItem::NewL( MBufferObserver& aObserver, 

                                                MDataBuffer& aBuffer,

                                                TBool aLastBuffer,

                                                TUint aBufSeqNum )

    {

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

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

// ---------------------------------------------------------------------------

// Second Phase Contructor

// ---------------------------------------------------------------------------

void CDataBufferQueueItem::ConstructL()

    {

    }

// ---------------------------------------------------------------------------

// SetActive

// ---------------------------------------------------------------------------

void CDataBufferQueueItem::SetActive()

    {

    if (!IsActive())

        {

        CActive::SetActive();

        }

    }

// ---------------------------------------------------------------------------

// Buffer

// ---------------------------------------------------------------------------

MDataBuffer& CDataBufferQueueItem::DataBuffer()

    {

    return iBuffer;

    }

// ---------------------------------------------------------------------------

// Error

// ---------------------------------------------------------------------------

TInt CDataBufferQueueItem::Error()

    {

    return iError;

    }

// From CActive

void CDataBufferQueueItem::RunL()

    {

    // Save the error code

    iError = iStatus.Int();

    // Signal the observer that this request is serviced

    iObserver.BufferProcessed( this );

    }

void CDataBufferQueueItem::DoCancel()

    {

    iObserver.HandleCancel( *this );

    }

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

    {

    return KErrNone;

    }

// ---------------------------------------------------------------------------

// Return buffer attributes serialized in a descriptor

// ---------------------------------------------------------------------------

TDesC8& CDataBufferQueueItem::GetDataBufferAttributesDesc()

    {

    return iDataBufferAttributesStructPckg; 

    }    

// ---------------------------------------------------------------------------

// Return buffer sequence number

// ---------------------------------------------------------------------------

TUint CDataBufferQueueItem::GetBufferSequenceNumber()

    {

    return iDataBufferAttributesStructPckg().iBufferSeqNum;

    }

void CDataBufferQueueItem::CompleteSelf( TInt aError )

    {

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

            iDataBufferAttributesStructPckg().iBufferSeqNum, aError);

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

        {

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

        TRequestStatus* status = &iStatus;

        User::RequestComplete(status, aError);

        }

    }

// End of File