// 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:

//

/**

 @file 

*/

#ifndef TSU_OMXIL_COMPONENT_BASE_H

#define TSU_OMXIL_COMPONENT_BASE_H

#include <e32msgqueue.h>

#include <testframework.h>

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

#include "tsu_omxil_component_constants.h"

#include <openmax/il/common/omxilstatedefs.h>

// Forward declarations

class COmxILComponentIf;

struct OMX_COMPONENTTYPE;

class RAsyncTestStepOmxILComponentBase;

class CMMFBuffer;

class CAacTestFile : public CBase

	{

public:

	static CAacTestFile* NewL();

	~CAacTestFile();

	TInt ReadTestFileInBuffer(const TDesC& aFileName);

    void ReadNextBuffer(CMMFBuffer& aDataBuffer);

    void ResetPos();

    TInt GetPos();

private:

	CAacTestFile();

	void ConstructL();

private:

	HBufC8* iSourceFile;

	TInt iSourceFileReadPos;

	TBool iFinished;

	};

class CAacOutputTestFile : public CBase

	{

public:

	static CAacOutputTestFile* NewL();

	~CAacOutputTestFile();

	TInt SetUpOutputFile(const TDesC& aFileName);

	TInt WriteDataToFile(const CMMFBuffer& aDataBuffer);

	TInt AddWavHeader();

	void CloseOutputFile();

private:

	CAacOutputTestFile();

	void ConstructL();

private:

	RFs iFileServerSession;

	RFile iOutputFile;

	TInt iWrittenDataTotal;

	TInt iBuffersWrittenCount;

	};

class MTimerObserver

	{

public:

	virtual void TimerExpired() = 0;

	};

class CUtilityTimer : public CTimer

	{

public:

	static CUtilityTimer* NewL(TTimeIntervalMicroSeconds32& aDelay,

							   MTimerObserver& aObserver);

	~CUtilityTimer();

	void InitializeTimer();

private:

    CUtilityTimer(MTimerObserver& aObserver);

    void ConstructL(TTimeIntervalMicroSeconds32& aDelay);

	// from CActive

    void RunL();

	void DoCancel();

private:

    TTimeIntervalMicroSeconds32 iDelay;

	MTimerObserver& iObserver;

    };

class CCallbackHandler : public CActive

	{

public:

	enum TMessageType

		{

		EFillBufferCallback,

		EEmptyBufferCallback,

		EEventCallback

		};

	class TEventParams

		{

	public:

		OMX_EVENTTYPE iEvent;

		TUint iData1;

		TUint iData2;

		TAny* iExtra;

		};

	class TOmxMessage

		{

	public:

		TMessageType iType;

		OMX_HANDLETYPE iComponent;

		union

			{

			OMX_BUFFERHEADERTYPE* iBuffer;

			TEventParams iEventParams;

			};

		};

	static const TInt KMaxMsgQueueEntries = 10;

public:

	static CCallbackHandler* NewL(RAsyncTestStepOmxILComponentBase& aDecoderTest);

	virtual ~CCallbackHandler();

	operator OMX_CALLBACKTYPE*();

	void RunL();

	void DoCancel();

	static OMX_ERRORTYPE FillBufferDone(OMX_HANDLETYPE aComponent,

										TAny* aAppData,

										OMX_BUFFERHEADERTYPE* aBuffer);

	static OMX_ERRORTYPE EmptyBufferDone(OMX_HANDLETYPE aComponent,

										 TAny* aAppData,

										 OMX_BUFFERHEADERTYPE* aBuffer);

	static OMX_ERRORTYPE EventHandler(OMX_HANDLETYPE aComponent,

									  TAny* aAppData,

									  OMX_EVENTTYPE aEvent,

									  TUint32 aData1,

									  TUint32 aData2,

									  TAny* aExtra);

private:

	void ConstructL();

	CCallbackHandler(RAsyncTestStepOmxILComponentBase& aDecoderTest);

	OMX_ERRORTYPE DoFillBufferDone(OMX_HANDLETYPE aComponent,

								   OMX_BUFFERHEADERTYPE* aBuffer);

	OMX_ERRORTYPE DoEmptyBufferDone(OMX_HANDLETYPE aComponent,

									OMX_BUFFERHEADERTYPE* aBuffer);

	OMX_ERRORTYPE DoEventHandler(OMX_HANDLETYPE aComponent,

								 TEventParams aParams);

	//

	//

	//

private:

	RAsyncTestStepOmxILComponentBase& iDecoderTest;

	RMsgQueue<TOmxMessage> iMsgQueue;

	OMX_CALLBACKTYPE iHandle;

	};

class RAsyncTestStepOmxILComponentBase : public RAsyncTestStep

	{

public:

	RAsyncTestStepOmxILComponentBase(const TDesC& aTestName, TInt aComponentUid);

	~RAsyncTestStepOmxILComponentBase();

	// From RAsyncTestStep

	void KickoffTestL();

	void CloseTest();

	//

	virtual void DoFillBufferDoneL(OMX_HANDLETYPE aComponent,

								  OMX_BUFFERHEADERTYPE* aBuffer);

	virtual void DoEmptyBufferDoneL(OMX_HANDLETYPE aComponent,

								   OMX_BUFFERHEADERTYPE* aBuffer);

	virtual void DoEventHandlerL(OMX_HANDLETYPE aComponent,

								OMX_EVENTTYPE aEvent,

								TUint aData1,

								TUint aData2,

								TAny* aExtra) = 0;

	static OMX_ERRORTYPE ConvertSymbianErrorType(TInt aError);

protected:

	void PrintOmxState(OMX_STATETYPE aOmxState);

	// Async Call backs

	static TInt ComponentBaseCallBack(TAny* aPtr);

	void DoComponentBaseCallBack();

	static TInt StopTestCallBack(TAny* aPtr);

	void DoStopTestCallBack();

protected:

	TInt iComponentUid;

	CAsyncCallBack* ipKickoffAOp;

	CAsyncCallBack* ipKickoffStop;

	COmxILComponentIf* ipCOmxILComponent;

	CCallbackHandler* ipCallbackHandler;

	CAacTestFile* ipTestFile;

	TPtrC iTestFileName;

    CAacOutputTestFile* ipOutputTestFile;

	OMX_COMPONENTTYPE* ipCompHandle;

	};

#endif // TSU_OMXIL_COMPONENT_BASE_H