--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mmdevicefw/mdf/inc/openmax/omxprocessingunit.h	Tue Feb 02 01:56:55 2010 +0200
@@ -0,0 +1,135 @@
+// 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:
+//
+
+/**
+ @file
+ @publishedPartner
+ @released
+*/
+
+#ifndef OMXPROCESSINGUNIT_H
+#define OMXPROCESSINGUNIT_H
+
+#include <e32std.h>
+#include <e32base.h>
+#include <mdf/mdfprocessingunit.h>
+#include <openmax/il/khronos/v1_x/OMX_Component.h>
+
+class COmxInputPort;
+class COmxOutputPort;
+
+/**
+OpenMAX Processing Unit observer class.
+*/
+class MOmxPuCallbacks
+	{
+public:
+	virtual TInt MopcEventHandler(OMX_HANDLETYPE aComponent, OMX_EVENTTYPE aEvent, TUint32 aData1, TUint32 aData2, TAny* aExtraInfo) =0;
+	};
+
+/**
+OpenMAX Input Port observer class.
+*/
+class MOmxInputPortCallbacks
+	{
+public:
+	/**
+	 * Returns the buffer that has been emptied.
+	 * @param 	aComponent
+	 *	   	The handle to the OpenMAX component sending the callback.
+	 * @param 	aBuffer
+	 * 		The buffer returned by the OpenMAX component.
+	 * @return	
+	 *		KErrNone, if successful; otherwise one of the other system-wide error codes. 
+	 *
+	 */
+	virtual TInt EmptyBufferDone(OMX_HANDLETYPE aComponent, const CMMFBuffer* aBuffer) =0;	
+	};
+
+
+/**
+OpenMAX Output Port observer class.
+*/
+class MOmxOutputPortCallbacks
+	{
+public:
+	/**
+	 * Returns the buffer that has been filled.
+	 * @param 	aComponent
+	 *	   	The handle to the OpenMAX component sending the callback.
+	 * @param 	aBuffer
+	 * 		The buffer returned by the OpenMAX component.
+	 * @return	
+	 *		KErrNone, if successful; otherwise one of the other system-wide error codes. 
+	 */
+	virtual TInt FillBufferDone(OMX_HANDLETYPE aComponent, CMMFBuffer* aBuffer) =0;
+	};
+
+/**
+OpenMAX Processing Unit class.
+*/
+class COmxProcessingUnit : public CMdfProcessingUnit, public MOmxPuCallbacks
+	{
+public:
+	class CBody;
+public:
+	// from CMdfProcessingUnit
+	IMPORT_C TInt Create(const MMdfProcessingUnitObserver& aProcessingUnitObserver);
+	IMPORT_C TInt GetInputPorts(RPointerArray<MMdfInputPort>& aComponentInputPorts);
+	IMPORT_C TInt GetOutputPorts(RPointerArray<MMdfOutputPort>& aComponentOutputPorts);
+	IMPORT_C TInt Configure(const TPuConfig& aConfigurationSetup);
+	IMPORT_C TInt GetConfig(TPuConfig& aConfigurationSetup);
+	IMPORT_C void Initialize();
+	IMPORT_C void Execute ();
+	IMPORT_C TInt Pause ();
+	IMPORT_C void Stop ();
+	IMPORT_C TProcessingUnitState State();
+	IMPORT_C TInt CreateCustomInterface(TUid aUid);
+	IMPORT_C TAny* CustomInterface(TUid aUid);
+	IMPORT_C ~COmxProcessingUnit();
+
+	// from MOmxPuCallbacks
+	IMPORT_C TInt MopcEventHandler(OMX_HANDLETYPE aComponent, OMX_EVENTTYPE aEvent, TUint32 aData1, TUint32 aData2, TAny* aExtraInfo);
+
+	// Accessors for Omx Component
+	IMPORT_C TInt OmxGetComponentVersion(const TDesC8& aComponentName, OMX_VERSIONTYPE* aComponentVersion, OMX_VERSIONTYPE* aSpecVersion, OMX_UUIDTYPE* aComponentUUID);
+	IMPORT_C TInt OmxSendCommand(OMX_COMMANDTYPE aCmd, TUint32 aParam1, TAny* aCmdData);
+	IMPORT_C TInt OmxGetParameter(OMX_INDEXTYPE aParamIndex, TAny* aComponentParameterStructure);
+	IMPORT_C TInt OmxSetParameter(OMX_INDEXTYPE aIndex, TAny* aComponentParameterStructure);
+	IMPORT_C TInt OmxGetConfig(OMX_INDEXTYPE aIndex, TAny* aValue);
+	IMPORT_C TInt OmxSetConfig(OMX_INDEXTYPE aIndex, TAny* aValue);
+	IMPORT_C TInt OmxGetExtensionIndex(const TDesC8& aParameterName, OMX_INDEXTYPE* aIndexType);
+	IMPORT_C TInt OmxGetState(OMX_STATETYPE* aState);
+	IMPORT_C TInt OmxComponentTunnelRequest(TUint32 aPortInput, OMX_HANDLETYPE aOutput, TUint32 aPortOutput, OMX_TUNNELSETUPTYPE* aTunnelSetup);
+	IMPORT_C TInt OmxUseBuffer(CMMFBuffer* aBuffer, TUint32 aPortIndex);
+	IMPORT_C CMMFBuffer* OmxAllocateBufferL(TUint32 aPortIndex, TUint32 aSizeBytes);
+	IMPORT_C TInt OmxFreeBuffer(CMMFBuffer* aBuffer);
+	IMPORT_C TInt OmxEmptyThisBuffer(const CMMFBuffer* aBuffer, MOmxInputPortCallbacks* aObserver);
+	IMPORT_C TInt OmxFillThisBuffer(CMMFBuffer* aBuffer, MOmxOutputPortCallbacks* aObserver);
+	IMPORT_C TInt OmxSetCallbacks(MOmxPuCallbacks& aPuCallbacks);
+
+protected:
+	IMPORT_C void ConstructL(const TDesC8& aComponentName, const MMdfProcessingUnitObserver& aProcessingUnitObserver);
+	IMPORT_C COmxProcessingUnit();
+	IMPORT_C TInt AddInputPort(MMdfInputPort* aInputPort);
+	IMPORT_C TInt AddOutputPort(MMdfOutputPort* aOutputPort);
+	IMPORT_C void SetPuState(TProcessingUnitState aState);	
+	IMPORT_C const MMdfProcessingUnitObserver* Observer();
+private:
+	CBody*	iBody;
+	};
+
+#endif // OMXPROCESSINGUNIT_H
+