--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tsrc/xmltestharness/xmlclient/src/videobufferhandler_mpeg4.cpp	Wed Aug 25 12:40:50 2010 +0300
@@ -0,0 +1,151 @@
+/*
+* 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);
+    }
+
+
+