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