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

   @internalComponent

*/

#ifndef OMXILINCONTEXTCALLBACKMANAGER_H

#define OMXILINCONTEXTCALLBACKMANAGER_H

#include "omxilcallbackmanager.h"

/**

   OpenMAX IL call backs and buffer marks manager. This is a synchronous

   implementation of MOmxILCallbackManagerIf.

 */

NONSHARABLE_CLASS(COmxILInContextCallbackManager) :

	public CBase,

	public MOmxILCallbackManagerIf,

	private XOmxILCallbackManagerIfImpl

	{

public:

	IMPORT_C static COmxILInContextCallbackManager* NewL(

		OMX_HANDLETYPE apComponentHandle,

		OMX_PTR apAppData,

		OMX_CALLBACKTYPE* apCallbacks);

	IMPORT_C ~COmxILInContextCallbackManager();

	IMPORT_C void SetPortManager(COmxILPortManager& apPortManager);

	IMPORT_C void SetFsm(COmxILFsm& apFsm);

	//

	// Methods for Callback Registration (from MOmxILCallbackManagerIf)

	//

	IMPORT_C OMX_ERRORTYPE RegisterComponentHandle(

		OMX_HANDLETYPE aComponentHandle);

	IMPORT_C OMX_ERRORTYPE RegisterILClientCallbacks(

		const OMX_CALLBACKTYPE* apCallbacks,

		const OMX_PTR apAppData);

	IMPORT_C OMX_ERRORTYPE RegisterTunnelCallback(

		OMX_U32 aLocalPortIndex,

		OMX_DIRTYPE aLocalPortDirection,

		OMX_HANDLETYPE aTunnelledComponentHandle,

		OMX_U32 aTunnelledPortIndex

		);

	IMPORT_C OMX_ERRORTYPE DeregisterTunnelCallback(

		OMX_U32 aLocalPortIndex);

	IMPORT_C OMX_ERRORTYPE RegisterBufferMarkPropagationPort(

		OMX_U32 aPortIndex,

		OMX_U32 aPropagationPortIndex);

	IMPORT_C TBool BufferRemovalIndication(

		OMX_BUFFERHEADERTYPE* apBufferHeader,

		OMX_DIRTYPE aDirection);

	//

	// Methods for Callback Notification (from MOmxILCallbackManagerIf)

	//

	IMPORT_C OMX_ERRORTYPE TransitionCompleteNotification(

		OMX_STATETYPE aOmxState);

	IMPORT_C OMX_ERRORTYPE CommandCompleteNotification(

		OMX_COMMANDTYPE aOmxCommand,

		OMX_U32 aOmxPortIndex);

	//

	// Methods for Callback Notification (from MOmxILCallbackManagerIf)

	//

	IMPORT_C OMX_ERRORTYPE ErrorEventNotification(

		OMX_ERRORTYPE aOmxError);

	IMPORT_C OMX_ERRORTYPE EventNotification(

		OMX_EVENTTYPE aEvent,

		TUint32 aData1,

		TUint32 aData2,

		OMX_STRING aExtraInfo);

	IMPORT_C OMX_ERRORTYPE BufferDoneNotification(

		OMX_BUFFERHEADERTYPE* apBufferHeader,

		OMX_U32 aLocalPortIndex,

		OMX_DIRTYPE aLocalPortDirection);

	IMPORT_C OMX_ERRORTYPE ClockBufferDoneNotification(

		OMX_BUFFERHEADERTYPE* apBufferHeader,

		OMX_U32 aLocalPortIndex,

		OMX_DIRTYPE aLocalPortDirection);

	IMPORT_C OMX_ERRORTYPE PortSettingsChangeNotification(

		OMX_U32 aLocalPortIndex,

		TUint aPortSettingsIndex,

		const TDesC8& aPortSettings);

private:

	class TOmxILBuffer

		{

	public:

		OMX_BUFFERHEADERTYPE* ipBufferHeader;

		OMX_U32 iLocalPortIndex;

		OMX_DIRTYPE iLocalPortDirection;

	// Default Constructor

	inline TOmxILBuffer();

	// Constructor

	inline TOmxILBuffer(

		OMX_BUFFERHEADERTYPE* apBufferHeader,

		OMX_U32 aLocalPortIndex,

		OMX_DIRTYPE aLocalPortDirection);

		};

private:

	// Convenience typedef

	typedef RArray<TOmxILBuffer> RCbMgrBufferQueue;

private:

	COmxILInContextCallbackManager(OMX_HANDLETYPE apComponentHandle,

								   OMX_PTR apAppData,

								   OMX_CALLBACKTYPE* apCallbacks);

	void ConstructL();

	void LockCallbackManager();

	void UnlockCallbackManager();

	void SignalOrPropagateBufferMarks(

		OMX_BUFFERHEADERTYPE* apBufferHeader,

		OMX_U32 aLocalPortIndex);

	void ProcessBufferDoneNotification(

		OMX_BUFFERHEADERTYPE* apBufferHeader,

		OMX_U32 aLocalPortIndex,

		OMX_DIRTYPE aLocalPortDirection);

	void FlushQueue(RCbMgrBufferQueue& aQueue);

	TBool RemoveBuffersByBufferHeader(

		RCbMgrBufferQueue& aQueue,

		OMX_BUFFERHEADERTYPE* apBufferHeader,

		const OMX_DIRTYPE aDirection);

	void FlushBuffersByPortIndex(RCbMgrBufferQueue& aQueue,

								 const OMX_U32 aLocalPortIndex);

private:

	RFastLock iLock;

	// Queue of buffer done notifications that need to be queued during

	// OMX_StatePaused state

	RCbMgrBufferQueue iPendingQueue;

	// Flag to enable unconditional flushing of buffer done notifications

	TBool iFlushPendingQueue;

	OMX_STATETYPE iCurrentState;

	OMX_STATETYPE iPreviousState;

	};

inline

COmxILInContextCallbackManager::TOmxILBuffer::TOmxILBuffer()

	:

	ipBufferHeader(0),

	iLocalPortIndex(0),

	iLocalPortDirection(OMX_DirMax)

	{

	}

inline

COmxILInContextCallbackManager::TOmxILBuffer::TOmxILBuffer(

	OMX_BUFFERHEADERTYPE* apBufferHeader,

	OMX_U32 aLocalPortIndex,

	OMX_DIRTYPE aLocalPortDirection

	)

	:

	ipBufferHeader(apBufferHeader),

	iLocalPortIndex(aLocalPortIndex),

	iLocalPortDirection(aLocalPortDirection)

	{

	}

#endif // OMXILINCONTEXTCALLBACKMANAGER_H