/*

* 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:  Video Source subsystem.

*

*/

// INCLUDE FILES

#include <ecam.h>

#include <e32debug.h>

#include "CVSMMFDataBuffer.h"

// MACROS

#ifdef _DEBUG

#    define __IF_DEBUG(t) {RDebug::t;}

#else

#    define __IF_DEBUG(t)

#endif

// ============================ CVSMMFDataBuffer ===============================

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

// CVSMMFDataBuffer::NewL

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

//

EXPORT_C CVSMMFDataBuffer* CVSMMFDataBuffer::NewL()

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::NewL() >>"), RThread().Id().operator TUint()));

    CVSMMFDataBuffer* self = new ( ELeave ) CVSMMFDataBuffer;

    CleanupStack::PushL(self);

    self->ConstructL( KMMFDataBufferDefaultBufferSize );

    CleanupStack::Pop(); // self

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::NewL <<"), RThread().Id().operator TUint()));

    return self;

    }

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

// CVSMMFDataBuffer::NewL

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

//

EXPORT_C CVSMMFDataBuffer* CVSMMFDataBuffer::NewL( TInt aMaxBufferSize )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::NewL() >>"), RThread().Id().operator TUint()));

    CVSMMFDataBuffer* self = new ( ELeave ) CVSMMFDataBuffer;

    CleanupStack::PushL(self);

    self->ConstructL( aMaxBufferSize );

    CleanupStack::Pop(); // self

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::NewL <<"), RThread().Id().operator TUint()));

    return self;

    }

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

// CVSMMFDataBuffer::~CVSMMFDataBuffer

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

//

EXPORT_C CVSMMFDataBuffer::~CVSMMFDataBuffer()

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::~CVSMMFDataBuffer() >>"), RThread().Id().operator TUint()));

    delete[] iData;

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::~CVSMMFDataBuffer() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::ReAllocBufferL

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

//

void CVSMMFDataBuffer::ReAllocBufferL( TInt aMaxBufferSize )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::ReAllocBufferL() >>"), RThread().Id().operator TUint()));

    if ( !iIsBufferSet )

        {

        TUint8* tmp = new (ELeave) TUint8[aMaxBufferSize];

        delete[] iData;

        iData = tmp;

        iPtr.Set( iData, 0, aMaxBufferSize );

        iMaxBufferSize = aMaxBufferSize;

        }

    else

        {

        User::Leave( KErrNotSupported );

        }

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::ReAllocBufferL() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::NeedsReset

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

//

TBool CVSMMFDataBuffer::NeedsReset() const

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::NeedsReset() ><"), RThread().Id().operator TUint()));

    return iNeedsReset;

    }

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

// CVSMMFDataBuffer::SetNeedsReset

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

//

void CVSMMFDataBuffer::SetNeedsReset( TBool aNeedsReset )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetNeedsReset() >>"), RThread().Id().operator TUint()));

    iNeedsReset = aNeedsReset;

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetNeedsReset() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::Reset

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

//

void CVSMMFDataBuffer::Reset()

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::Reset() >>"), RThread().Id().operator TUint()));

    iPtr.Zero();

    SetNeedsReset( EFalse );

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::Reset() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::Data

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

//

TDes8& CVSMMFDataBuffer::Data()

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::Data() >>"), RThread().Id().operator TUint()));

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::Data() <<"), RThread().Id().operator TUint()));

    return iPtr;

    }

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

// CVSMMFDataBuffer::Data

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

//

const TDesC8& CVSMMFDataBuffer::Data() const

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::Data() >>"), RThread().Id().operator TUint()));

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::Data() <<"), RThread().Id().operator TUint()));

    return iPtr;

    }

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

// CVSMMFDataBuffer::SetStatus

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

//

void CVSMMFDataBuffer::SetStatus( TBufferStatus aStatus )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetStatus() >>"), RThread().Id().operator TUint()));

    CMMFBuffer::SetStatus( aStatus );

    if ( iStatus == EBeingFilled )

        {

        Reset();

        }

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetStatus() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::SetRequestSizeL

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

//

void CVSMMFDataBuffer::SetRequestSizeL( TInt aSize )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetRequestSizeL() >>"), RThread().Id().operator TUint()));

    if ( aSize < 0 )

        {

        User::Leave( KErrUnderflow );

        }

    else if ( aSize > iPtr.MaxLength() )

        {

        User::Leave( KErrOverflow );

        }

    else

        {

        iRequestSize = aSize;

        }

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetRequestSizeL() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::BufferSize

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

//

TUint CVSMMFDataBuffer::BufferSize() const

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::BufferSize() >>"), RThread().Id().operator TUint()));

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::BufferSize() <<"), RThread().Id().operator TUint()));

    return iPtr.Length();

    }

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

// CVSMMFDataBuffer::SetPosition

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

//

void CVSMMFDataBuffer::SetPosition( TUint aPosition )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetPosition() >>"), RThread().Id().operator TUint()));

    if ( aPosition <= (TUint)iPtr.Length() )

        {

        iPosition = aPosition;

        }

    else

        {

        iPosition = (TUint)iPtr.Length();   // Tried to position beyond end of

                                            // data

        }

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetPosition() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::SetFrameBufferL

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

//

void CVSMMFDataBuffer::SetFrameBufferL( MFrameBuffer* aFrameBuffer )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetFrameBuffer() >>"), RThread().Id().operator TUint()));

    iFrameBuffer = aFrameBuffer;

    //Buffer is valid

    iIsBufferSet = ETrue;

    if ( aFrameBuffer == NULL )

        {

        iPtr.Set( iData, 0, iMaxBufferSize );

        }

    else

        {

        Reset();

        TPtrC8 ptr( *iFrameBuffer->DataL( 0 ) );

        iPtr.Set((TUint8*)ptr.Ptr(), ptr.Size(), ptr.Size());

        }

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetFrameBuffer() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::SetFrameBufferL

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

//

void CVSMMFDataBuffer::SetFrameBufferL( MCameraBuffer* aCameraBuffer )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetFrameBuffer() >>"), RThread().Id().operator TUint()));

    iCameraBuffer = aCameraBuffer;

    //Buffer is valid

    iIsBufferSet = ETrue;

    if ( aCameraBuffer == NULL )

        {

        iPtr.Set( iData, 0, iMaxBufferSize );

        }

    else

        {

        Reset();

        // Take the latest frame data from buffer should be always 0,

        // but if buffer contains more than 1 frame could be something else

        TPtrC8 ptr( *iCameraBuffer->DataL( iCameraBuffer->NumFrames() - 1 ) );

        iPtr.Set((TUint8*)ptr.Ptr(), ptr.Size(), ptr.Size());

        }

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetFrameBuffer() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::ReleaseL

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

//

void CVSMMFDataBuffer::ReleaseL()

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::Release() >>"), RThread().Id().operator TUint()));

    if( iFrameBuffer )

        {

        iFrameBuffer->Release();

        SetFrameBufferL( (MFrameBuffer*)NULL );

        }

    else if( iCameraBuffer )

    	{

    	iCameraBuffer->Release();

        SetFrameBufferL( (MCameraBuffer*)NULL );

    	}

    else

        {

        if ( iPtr.Ptr() != iData )

            {

            iPtr.Set( iData, 0, iMaxBufferSize );

            }

        if( NeedsReset() )

            {

            Reset();

            }

        }

    //Buffer is no longer valid

    iIsBufferSet = EFalse;

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::Release() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::SetBufferOffset

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

//

void CVSMMFDataBuffer::SetBufferOffset( TInt aOffset )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetBufferOffset() >>"), RThread().Id().operator TUint()));

    if ( !iIsBufferSet )

        {

        __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetBufferOffset(): Length = %d, Offset = %d"), RThread().Id().operator TUint(), iPtr.Length(), aOffset));

        iPtr.Set( iData + aOffset, iPtr.Length() - aOffset, iMaxBufferSize );

        }

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::SetBufferOffset() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::CVSMMFDataBuffer

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

//

CVSMMFDataBuffer::CVSMMFDataBuffer() :

    CMMFDataBuffer( KUidMmfDataBuffer ), iPtr(0,0,0), iIsBufferSet(EFalse)

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::CVSMMFDataBuffer() >>"), RThread().Id().operator TUint()));

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::CVSMMFDataBuffer() <<"), RThread().Id().operator TUint()));

    }

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

// CVSMMFDataBuffer::ConstructL

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

//

void CVSMMFDataBuffer::ConstructL( TInt aMaxBufferSize )

    {

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::ConstructL() >>"), RThread().Id().operator TUint()));

    iData = new (ELeave) TUint8[aMaxBufferSize];

    iPtr.Set( iData, 0, aMaxBufferSize );

    iMaxBufferSize = aMaxBufferSize;

    __IF_DEBUG(Print(_L("VideoSource[%d]: CVSMMFDataBuffer::ConstructL() <<"), RThread().Id().operator TUint()));

    }

//  End of File