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