// 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:
// Implementation of the Class COmxComponent
// 
//

#ifndef OMXPROCESSINGUNITBODY_H
#define OMXPROCESSINGUNITBODY_H

#include <e32base.h>
#include <openmax/il/khronos/v1_x/OMX_Component.h>
#include <omxprocessingunit.h>
#include "omxcomponentimpl.h"

enum TOmxPortPanics
	{
	EObserverNotSet,
	EBodyNotCreated
	};

class CMMFBuffer;
class MMdfInputPortObserver;
class MMdfOutputPortObserver;

class COmxProcessingUnit::CBody : public CBase
	{
public:
	virtual ~CBody();
	static CBody* NewL(const TDesC8& aComponentName, 
						MOmxPuCallbacks& aPuCallbacks, 
						COmxProcessingUnit* aParent, 
						const MMdfProcessingUnitObserver& aObserver);

	// Processing unit calls
	TInt GetInputPorts(RPointerArray<MMdfInputPort>& aComponentInputPorts);
	TInt GetOutputPorts(RPointerArray<MMdfOutputPort>& aComponentOutputPorts);
	TInt Configure(const TPuConfig& aConfigurationSetup);
	TInt GetConfig(TPuConfig& aConfigurationSetup);
	void Initialize();
	TInt Pause();
	void Stop();
	void Execute();
	TProcessingUnitState State();
	TInt CreateCustomInterface(TUid aUid);
	TAny* CustomInterface(TUid aUid);
	
	// OMX Processing Unit calls	
	TInt AddInputPort(MMdfInputPort* aInputPort);
	TInt AddOutputPort(MMdfOutputPort* aOutputPort);
	void SetPuState(TProcessingUnitState aState);	
	MMdfProcessingUnitObserver* Observer();

	// OMX calls 
	TInt GetComponentVersion(const TDesC8& aComponentName, OMX_VERSIONTYPE* aComponentVersion, OMX_VERSIONTYPE* aSpecVersion, OMX_UUIDTYPE* aComponentUUID);
	TInt SendCommand(OMX_COMMANDTYPE aCmd, TUint aParam1, TAny* aCmdData);
	TInt GetParameter(OMX_INDEXTYPE aParamIndex, TAny* aComponentParameterStructure);
	TInt SetParameter(OMX_INDEXTYPE aIndex, TAny* aComponentParameterStructure);
	TInt GetConfig(OMX_INDEXTYPE aIndex, TAny* aValue);
	TInt SetConfig(OMX_INDEXTYPE aIndex, TAny* aValue);
	TInt GetExtensionIndex(const TDesC8& aParameterName, OMX_INDEXTYPE* aIndexType);
	TInt GetState(OMX_STATETYPE* aState);
	TInt ComponentTunnelRequest(TUint aPortInput, OMX_HANDLETYPE aOutput, TUint aPortOutput, OMX_TUNNELSETUPTYPE* aTunnelSetup);
	TInt UseBuffer(CMMFBuffer* aBuffer, TUint aPortIndex);
	CMMFBuffer* AllocateBufferL(TUint aPortIndex, TUint aSizeBytes);
	TInt FreeBuffer(CMMFBuffer* aBuffer);
	TInt EmptyThisBuffer(const CMMFBuffer* aBuffer, MOmxInputPortCallbacks* aCallback);
	TInt FillThisBuffer(CMMFBuffer* aBuffer, MOmxOutputPortCallbacks* aCallback);
	TInt SetCallbacks(MOmxPuCallbacks& aPuCallbacks);
	
	TInt EventHandler(OMX_HANDLETYPE aComponent, OMX_EVENTTYPE aEvent, TUint32 aData1,
		 TUint32 aData2, TAny* aExtraInfo);
private:
	CBody();
	void ConstructL(const TDesC8& aComponentName, 
						MOmxPuCallbacks& aPuCallbacks, 
						COmxProcessingUnit* aBody,
						const MMdfProcessingUnitObserver& aObserver);
						
	
	
private:

	void GetExtensionIndexL(const TDesC8& aParameterName, OMX_INDEXTYPE* aIndexType);
	// Processing Unit Data
	CMdfProcessingUnit* iParent;
	MMdfProcessingUnitObserver* iObserver;
	TProcessingUnitState 		iPuState;
	RPointerArray<MMdfInputPort> iInputPorts;
	RPointerArray<MMdfOutputPort> iOutputPorts;	


	COmxBufferManager* iBufferManager;
	OMX_COMPONENTTYPE* iHandle;
	COmxCallbacks* iCallbacks;

	};
	
// Prototypes for 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 // OMXPROCESSINGUNITBODY_H