/*

* Copyright (c) 2008 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:

*

*/

#include <gdi.h>

#include "videobufferhandler.h"

#include <openmax/il/khronos/v1_x/OMX_Core.h>

const TInt KDefaultTimeInterval = 100000;

CVideoBufferHandler* CVideoBufferHandler::NewL(

    TDesC& aFilename, 

    OMX_SYMBIAN_PARAM_3PLANE_CHUNK_DATA& aChunkDataMsg,

    const OMX_SYMBIAN_PARAM_BUFFER_SIZE& aBufferSize, 

    OMX_PARAM_PORTDEFINITIONTYPE& portDef)

	{

	CVideoBufferHandler* handler = new (ELeave) CVideoBufferHandler(aFilename);

	CleanupStack::PushL(handler);

	handler->ConstructL(aChunkDataMsg, aBufferSize, portDef);

	CleanupStack::Pop(handler);

	return handler;

	}

CVideoBufferHandler::~CVideoBufferHandler()

	{

	iReceiveBuffer.Close();

	iSendBuffer.Close();

	iBufferChunk.Close();

	iFileSource.Close();

	iFs.Close();

	}

void CVideoBufferHandler::DoCancel()

	{

	iReceiveBuffer.CancelDataAvailable();

	}

CVideoBufferHandler::CVideoBufferHandler(TDesC& aFilename):

	CActive(EPriorityStandard),

	iReadDes(NULL, 0, 0),

	iFirstBuffer(ETrue)

	{

	CActiveScheduler::Add(this);

	iFileName.Append(aFilename);

	}

void CVideoBufferHandler::ChangeFilledBufferLength(TInt aLength)

    {

    if (!iChangeFileBufferLength)

        {

        iChangeFileBufferLength = ETrue;

        }

    iFileBufferLengthTestValue = aLength;

    }

void CVideoBufferHandler::SetSendInvalidBufferId(TInt aSendInvalidBufferId)    

	{

	iSendInvalidBufferId = aSendInvalidBufferId;

	}

void CVideoBufferHandler::RunL()

	{

	// Timer has expired check for new messages...

	TFilledBufferHeaderV2 header;

	User::LeaveIfError(iReceiveBuffer.Receive(header));

	TUint8* chunkBase = iBufferChunk.Base();

	TUint8* bufBase = chunkBase + header.iOffset;

	iReadDes.Set(bufBase, 0, iBufConfig.iBufferSizeInBytes);

	iFileSource.Read(iReadDes);

	if (iChangeFileBufferLength)

	    {

	    // this is negative test case. COmxILCallbackManager::BufferDoneNotification() will panic

	    header.iFilledLength = iFileBufferLengthTestValue;

	    }

	else

	    {

	    header.iFilledLength = iReadDes.Length();

	    }

	iTimeStamp += KDefaultTimeInterval;

	header.iTimeStamp = iTimeStamp;	

	if (iReadDes.Length() != 0)

		{

		// there is more to read from file source, request for more buffer

		header.iFlags = iFirstBuffer ? OMX_BUFFERFLAG_STARTTIME : 0;

		iReceiveBuffer.NotifyDataAvailable(iStatus);

		SetActive();

		}

	else

		{

		header.iFlags = OMX_BUFFERFLAG_EOS;

		}

	if (iSendInvalidBufferId)

		{

		header.iOffset=KMaxTUint32;

		User::LeaveIfError(iSendBuffer.Send(header));

		iSendInvalidBufferId = 0;

		}

	else

		User::LeaveIfError(iSendBuffer.Send(header));

	}

void CVideoBufferHandler::ConstructL(OMX_SYMBIAN_PARAM_3PLANE_CHUNK_DATA& aChunkDataMsg, const OMX_SYMBIAN_PARAM_BUFFER_SIZE& aBufferSize, OMX_PARAM_PORTDEFINITIONTYPE& portDef)

    {

    iBufferChunk.SetHandle(aChunkDataMsg.nChunk);

    User::LeaveIfError(iBufferChunk.Duplicate(RThread()));

    iReceiveBuffer.SetHandle(aChunkDataMsg.nAvailableBufferQueue );

    User::LeaveIfError(iReceiveBuffer.Duplicate(RThread()));

    iSendBuffer.SetHandle(aChunkDataMsg.nFilledBufferQueue);

    User::LeaveIfError(iSendBuffer.Duplicate(RThread()));

   	if (portDef.nBufferCountActual <= 0 || portDef.nBufferSize <= 0)

		{

		User::Leave(KErrArgument);

		}

	iBufConfig.iNumBuffers = portDef.nBufferCountActual;

	iBufConfig.iBufferSizeInBytes = aBufferSize.nBufferSize;

	// Open datafile

	User::LeaveIfError(iFs.Connect());

	User::LeaveIfError(iFileSource.Open(iFs, iFileName, EFileShareExclusive|EFileRead));

	}

void CVideoBufferHandler::Start()

	{

	// Start streaming

	iFirstBuffer = ETrue;

	iReceiveBuffer.NotifyDataAvailable(iStatus);

	iTimeStamp = KDefaultTimeInterval;

	SetActive();

	}