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

//

#ifndef PORTBUFFERHANDLER_H

#define PORTBUFFERHANDLER_H

#include <e32base.h>

#include <f32file.h>

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

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

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

#include "omx_xml_script.h"

#if defined(__WINSCW__)

_LIT(KPortDirectoryPath, "c:\\mm\\omxlogicalil\\");

#else

_LIT(KPortDirectoryPath, "e:\\unittest\\mm\\omxlogicalil\\");

#endif

const OMX_VERSIONTYPE KOmxLILVersion = { 1, 1, 1, 0 };

NONSHARABLE_CLASS(CPortBufferHandler) : public CBase

	{

public:

	void AddPortL( OMX_COMPONENTTYPE* aComp,

			TInt aPortNum,

			const TDesC& aFileName,

			OMX_BUFFERSUPPLIERTYPE aSupplier,

			OMX_DIRTYPE aPortDir,

			MOmxScriptTestLogger& aLogger,

			TInt aHeaderLength);

	void AllocateBuffersL(OMX_COMPONENTTYPE* aComp);

	void BufferDone(OMX_COMPONENTTYPE* aComp, OMX_BUFFERHEADERTYPE* aBufHdr, TBool aSource);

	void FreeBuffers(OMX_COMPONENTTYPE* aComp);

	void Start(OMX_COMPONENTTYPE* aComp, TInt aPortNum);

	void Resume(OMX_COMPONENTTYPE* aComp, TInt aPortNum);

	void Pause(OMX_COMPONENTTYPE* aComp, TInt aPortNum);

	void Stop(OMX_COMPONENTTYPE* aComp, TInt aPortNum);

	CPortBufferHandler();

	~CPortBufferHandler();

private:

	NONSHARABLE_CLASS(CPortInfo) : public CBase

		{

	public:

		static CPortInfo* NewL( OMX_COMPONENTTYPE* aComp,

				TInt aPortNum,

				const TDesC& aFileName,

				OMX_BUFFERSUPPLIERTYPE aSupplier,

				OMX_DIRTYPE aPortDir,

				MOmxScriptTestLogger& aLogger,

				TInt aHeaderLength);

		CPortInfo( OMX_COMPONENTTYPE* aComp,

				   TInt aPortNum,

				   OMX_BUFFERSUPPLIERTYPE aSupplier,

				   OMX_DIRTYPE aPortDir,

				   MOmxScriptTestLogger& aLogger,

				   TInt aHeaderLength);

		~CPortInfo();

		void AllocateBuffersL();

		void BufferDone(OMX_BUFFERHEADERTYPE* aBufHdr);

		void FreeBuffers();

		void DeleteAllBuffers();

		static TBool ComparePortNum(const TInt* aPortNum, const CPortInfo& aPortInfo);

		void Start();

		void Stop();

		void Resume();

		void Pause();

		OMX_DIRTYPE& PortDir();

		void LogExtra(const TText8* aFile, TInt aLine, TOmxScriptSeverity aSeverity,

		            TRefByValue<const TDesC16> aFmt,...);

		enum 

			{

			EBufferFree,

			EBufferUnderUse

			};

	private:

		TBuf<KMaxFileName> iFileName;		

		RFs iFs;		

		RFile iFileObject;

		OMX_COMPONENTTYPE* iComp;

		TInt iPortNum;

		TInt iNumBufs;

		OMX_BUFFERSUPPLIERTYPE iSupplier;

		RPointerArray<OMX_U8> iBuffers;

		RPointerArray<OMX_BUFFERHEADERTYPE> iBufferHeaders;

		OMX_DIRTYPE iPortDir;

		TInt iPosInputData;

		TInt iFileHeaderLength;

		TInt iFileFillingLength;

		MOmxScriptTestLogger& iLogger;

	    TBool iEOSReached;

	    TUint32 iTimeStamp;

		};

	NONSHARABLE_CLASS(CComponentInfo) : public CBase

		{

	public:

		CComponentInfo(OMX_COMPONENTTYPE* aComp);

		~CComponentInfo();

		CPortInfo* AddPortL(TInt aPortNum, const TDesC& aFileName,OMX_BUFFERSUPPLIERTYPE aSupplier, OMX_DIRTYPE aPortDir, MOmxScriptTestLogger& aLogger, TInt aHeaderLength);

		void AllocateBuffersL();

		void FillBuffers();

		void BufferDone(OMX_BUFFERHEADERTYPE* aBufHdr, TBool aSource);

		void HoldBuffers();

		void FreeBuffers();

		static TBool CompareComp(const OMX_COMPONENTTYPE* aSource, const CComponentInfo& aComponentInfo);

		void Start(TInt aPortNum);

		void Stop(TInt aPortNum);

		void Resume(TInt aPortNum);

		void Pause(TInt aPortNum);

	private:

		OMX_COMPONENTTYPE* iComp;

		RPointerArray<CPortInfo> iPorts;

		OMX_STATETYPE iState;

		};	

	RPointerArray<CComponentInfo> iComponents;

	};

#endif // PORTBUFFERHANDLER_H