--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mmdevicefw/mdf/src/openmax/omxcomponentbody.h	Tue Feb 02 01:56:55 2010 +0200
@@ -0,0 +1,128 @@
+// 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