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