// Copyright (c) 2005-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 OMX_COMPONENTIMPL_H

#define OMX_COMPONENTIMPL_H

#include <e32msgqueue.h>

class CMMFBuffer;

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 SetInputPortCallbacks(MOmxInputPortCallbacks* aCallbacks);

		void SetOutputPortCallbacks(MOmxOutputPortCallbacks* aCallbacks);

		MOmxInputPortCallbacks* InputPortCallbacks() const;

		MOmxOutputPortCallbacks* OutputPortCallbacks() const;

	private:

		COmxBuffer();

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

		OMX_BUFFERHEADERTYPE* iBufferHeader;

		CMMFBuffer* iMmfBuffer;

		TBool iOwnsMmfBuffer;

		MOmxInputPortCallbacks* iInputPortCallbacks;

		MOmxOutputPortCallbacks* iOutputPortCallbacks;

		};

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, MOmxInputPortCallbacks* aObserver);

	TInt FillThisBuffer(CMMFBuffer* aBuffer, MOmxOutputPortCallbacks* 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; 

		TUint iData1;

		TUint iData2;

		TAny* iExtra;

		};

	class TOmxMessage

		{

	public:

		TMessageType iType;

		OMX_HANDLETYPE iComponent;

		union 

			{

			COmxBufferManager::COmxBuffer* iBuffer;

			TEventParams iEventParams;

			};	

		};

public:

	static COmxCallbacks* NewL(MOmxPuCallbacks& aPuCallbacks);

	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, TEventParams aParams);

	virtual ~COmxCallbacks();

private:

	void ConstructL();

	COmxCallbacks(MOmxPuCallbacks& aPuCallbacks);

	int iState;

	MOmxPuCallbacks* iPuCallbacks;

	RMsgQueue<TOmxMessage> iMsgQueue;

	OMX_CALLBACKTYPE iHandle;

	};

#endif // OMX_COMPONENTIMPL_H