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

#define OMXILGENERICILIFBODYIMPL_H

#include "momxilcomponentifobserver.h"

#include <e32msgqueue.h>

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

class COmxBufferManager : public CBase

	{

public:

	class COmxBuffer : public CBase

		{

	public:

		static COmxBuffer* NewL(OMX_BUFFERHEADERTYPE* aBufferHeader, CMMFBuffer* aBuffer);

		~COmxBuffer();

		CMMFBuffer* MmfBuffer() const;

		OMX_BUFFERHEADERTYPE* BufferHeader() const;

		void SetPortObserver(MOmxILComponentIfObserver* aObserver);

		MOmxILComponentIfObserver* PortObserver() const;

	private:

		COmxBuffer();

		void ConstructL(OMX_BUFFERHEADERTYPE* aBufferHeader, CMMFBuffer* aBuffer);

		OMX_BUFFERHEADERTYPE* iBufferHeader;

		CMMFBuffer* iMmfBuffer;

		TBool iOwnsMmfBuffer;

		MOmxILComponentIfObserver* iPortObserver;

		};

public:

	COmxBufferManager(OMX_COMPONENTTYPE* aHandle);

	~COmxBufferManager();

	// Buffer lookup

	COmxBuffer* FindBuffer(const CMMFBuffer* aBuffer) const;

	COmxBuffer* FindBuffer(OMX_BUFFERHEADERTYPE* aBuffer) const;

	// OMX Calls

	TInt UseBuffer(CMMFBuffer& aBuffer, TUint nPortIndex);

	CMMFBuffer* AllocateBufferL(TUint nPortIndex, TUint nSizeBytes);

	TInt FreeBuffer(CMMFBuffer* aBuffer);

	TInt EmptyThisBuffer(const CMMFBuffer* aBuffer, MOmxILComponentIfObserver* aObserver);

	TInt FillThisBuffer(CMMFBuffer* aBuffer, MOmxILComponentIfObserver* aObserver);

	// Store OMX buffer pointer

	void StoreBufferL(OMX_BUFFERHEADERTYPE* aBufferHeader, CMMFBuffer* aBuffer);	

private:	

	RPointerArray<COmxBuffer> iBuffers;

	OMX_COMPONENTTYPE* iHandle;

	};

class COmxCallbacks : public CActive

	{

public:

	enum TMessageType 

		{

		EFillBufferCallback,

		EEmptyBufferCallback,

		EEventCallback

		};	

	class TEventParams

		{

	public:		

	 	OMX_EVENTTYPE iEvent; 

		TUint32 iData1;

		TUint32 iData2;

		TAny* iExtraData;

		};

	class TOmxMessage

		{

	public:

		TMessageType iType;

		OMX_HANDLETYPE iComponent;

		union 

			{

			COmxBufferManager::COmxBuffer* iBuffer;

			TEventParams iEventParams;

			};	

		};

public:

	static COmxCallbacks* NewL(MOmxILComponentIfObserver& aObserver);

	operator OMX_CALLBACKTYPE*();

	void RunL();

	void DoCancel();

	TInt FillBufferDone(OMX_HANDLETYPE aComponent, COmxBufferManager::COmxBuffer* aBuffer);

	TInt EmptyBufferDone(OMX_HANDLETYPE aComponent, COmxBufferManager::COmxBuffer* aBuffer);

	TInt EventHandler(OMX_HANDLETYPE aComponent, const TEventParams& aParams);

	virtual ~COmxCallbacks();

private:

	void ConstructL();

	COmxCallbacks(MOmxILComponentIfObserver& aObserver);

private:

	OMX_CALLBACKTYPE iHandle;

	RMsgQueue<TOmxMessage> iMsgQueue;

	MOmxILComponentIfObserver& iParent; 

	};

// OMX callback handler functions

OMX_ERRORTYPE EventHandler(OMX_OUT OMX_HANDLETYPE aComponent, 

					OMX_OUT TAny* aAppData,

        			OMX_OUT OMX_EVENTTYPE aEvent, 

        			OMX_OUT TUint32 aData1,

        			OMX_OUT TUint32 aData2,

        			OMX_OUT TAny* aExtra);

OMX_ERRORTYPE EmptyBufferDone(

       OMX_HANDLETYPE aComponent,

       TAny* aAppData,

       OMX_BUFFERHEADERTYPE* aBuffer);

OMX_ERRORTYPE FillBufferDone(

       OMX_HANDLETYPE aComponent,

       TAny* aAppData,

       OMX_BUFFERHEADERTYPE* aBuffer);

#endif // OMXILGENERICILIFBODYIMPL_H