/*
* 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_mpeg4.h"
#include <openmax/il/khronos/v1_x/OMX_Core.h>
#include <e32debug.h>


CVideoBufferHandlerMPEG4* CVideoBufferHandlerMPEG4::NewL(
    TDesC& aFilename,
    OMX_SYMBIAN_PARAM_3PLANE_CHUNK_DATA& aChunkDataMsg,
    const OMX_SYMBIAN_PARAM_BUFFER_SIZE& aBufferSize,
    OMX_PARAM_PORTDEFINITIONTYPE& portDef)
	{
	CVideoBufferHandlerMPEG4* handler = new (ELeave) CVideoBufferHandlerMPEG4(aFilename);
	CleanupStack::PushL(handler);
	handler->ConstructL(aChunkDataMsg, aBufferSize, portDef);
	CleanupStack::Pop(handler);

	return handler;
	}
	
CVideoBufferHandlerMPEG4::~CVideoBufferHandlerMPEG4()
	{
	delete iFrameSupplier;
	}

CVideoBufferHandlerMPEG4::CVideoBufferHandlerMPEG4(TDesC& aFilename):
	CVideoBufferHandler(aFilename)
	{
	}

void CVideoBufferHandlerMPEG4::RunL()
	{
	// Timer has expired check for new messages...
	TFilledBufferHeaderV2 header;
	
	User::LeaveIfError(iReceiveBuffer.Receive(header));
	TUint8* chunkBase = iBufferChunk.Base();
	//__ASSERT_ALWAYS(message < iBufConfig.iNumBuffers, User::Invariant());

	TUint8* bufBase = chunkBase + header.iOffset;

	TInt frameLength = 0;
	TInt err = iFrameSupplier->NextFrameData(bufBase, frameLength);
	if (err != KErrNone)
	    {
	    User::Leave(err);
	    }
	
	if (iChangeFileBufferLength)
	    {
	    // this is negative test case. COmxILCallbackManager::BufferDoneNotification() will panic
	    header.iFilledLength = iFileBufferLengthTestValue;
	    }
	else
	    {
	    header.iFilledLength = frameLength;
	    }
	    
	if (!iFrameSupplier->IsLastFrame())
		{
		// there is more to read from file source, request for more buffer
		header.iTimeStamp = 0;
		header.iFlags = (iFrameSupplier->CurrentFrame() == 0 ? OMX_BUFFERFLAG_STARTTIME : 0);
		iReceiveBuffer.NotifyDataAvailable(iStatus);
		SetActive();
		}
	else
		{
		header.iFlags = OMX_BUFFERFLAG_EOS;
		}
		
	if (iSendInvalidBufferId)
		{
		User::LeaveIfError(iSendBuffer.Send(header));
		iSendInvalidBufferId = 0;
		}
	else
	    {
		User::LeaveIfError(iSendBuffer.Send(header));
	    }
	}
	

void CVideoBufferHandlerMPEG4::ConstructL(OMX_SYMBIAN_PARAM_3PLANE_CHUNK_DATA& aChunkDataMsg, const OMX_SYMBIAN_PARAM_BUFFER_SIZE& aBufferSize, OMX_PARAM_PORTDEFINITIONTYPE& portDef)
	{
	RThread chunkOwnerThread;
	
    TInt error = chunkOwnerThread.Open(TThreadId(aChunkDataMsg.nThreadId));    
	iBufferChunk.SetHandle(aChunkDataMsg.nChunk);
	User::LeaveIfError(iBufferChunk.Duplicate(chunkOwnerThread));
	
	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);
		}
	
	iFrameSupplier = CVideoFrameSupplier::NewL(iFileName, CVideoFrameSupplier::EVideoFileTypeMPEG4);
	
    iBufConfig.iNumBuffers = portDef.nBufferCountActual;
    iBufConfig.iBufferSizeInBytes = aBufferSize.nBufferSize;
	}


void CVideoBufferHandlerMPEG4::SetChunkDetailAndOpenL(TInt aChunkHandleId, TUint64 aThreadId)
    {
    RThread chunkOwnerThread;
    
    TInt err = chunkOwnerThread.Open(TThreadId(aThreadId));
    if (err != KErrNone)
        {
        User::LeaveIfError(err);
        }
    
    CleanupClosePushL(chunkOwnerThread);
    
    iBufferChunk.SetHandle(aChunkHandleId);
    err = iBufferChunk.Duplicate(chunkOwnerThread);
    if (err != KErrNone)
        {
        User::LeaveIfError(err);
        }
    
    CleanupStack::PopAndDestroy(&chunkOwnerThread);
    }