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

*/

#include "log.h"

#include "omxilcallbackmanagerifimpl.h"

#include "omxilfsm.h"

#include "omxilportmanagerif.h"

#include <openmax/il/common/omxilstatedefs.h>

XOmxILCallbackManagerIfImpl::XOmxILCallbackManagerIfImpl(OMX_HANDLETYPE apComponentHandle,

														 OMX_PTR apAppData,

														 OMX_CALLBACKTYPE* apCallbacks)

	:

	ipHandle(static_cast<OMX_COMPONENTTYPE*>(apComponentHandle)),

	ipAppData(apAppData),

	ipCallbacks(apCallbacks),

	iRegisteredTunnels(),

	iBufferMarkPropagationPorts(),

	iBufferMarks(),

	ipPortManager(0),

	ipFsm(0)

	{

    DEBUG_PRINTF(_L8("XOmxILCallbackManagerIfImpl::XOmxILCallbackManagerIfImpl"));

	}

XOmxILCallbackManagerIfImpl::~XOmxILCallbackManagerIfImpl()

	{

    DEBUG_PRINTF(_L8("XOmxILCallbackManagerIfImpl::~XOmxILCallbackManagerIfImpl"));

	// These pointers are cleared to make sure that any further calls on this

	// object will fail (e.g., from a threaded PF)

	ipHandle	= 0;

	ipAppData	= 0;

	ipCallbacks = 0;

	iRegisteredTunnels.Close();

	iBufferMarkPropagationPorts.Close();

	iBufferMarks.Close();

	ipPortManager = 0;

	ipFsm = 0;

	}

void

XOmxILCallbackManagerIfImpl::DoSetPortManager(MOmxILPortManagerIf& apPortManager)

	{

	ipPortManager = &apPortManager;

	}

void

XOmxILCallbackManagerIfImpl::DoSetFsm(COmxILFsm& apFsm)

	{

	ipFsm = &apFsm;

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoRegisterComponentHandle(OMX_HANDLETYPE aComponentHandle)

	{

    DEBUG_PRINTF(_L8("XOmxILCallbackManagerIfImpl::DoRegisterComponentHandle"));

	__ASSERT_DEBUG(aComponentHandle,

				   User::Panic(KOmxILCallbackManagerIfImplPanicCategory, 1));

	ipHandle = static_cast<OMX_COMPONENTTYPE *>(aComponentHandle);

	return OMX_ErrorNone;

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoRegisterILClientCallbacks(const OMX_CALLBACKTYPE* apCallbacks,

														 const OMX_PTR apAppData)

	{

    DEBUG_PRINTF(_L8("XOmxILCallbackManagerIfImpl::DoRegisterILClientCallbacks"));

	ipAppData   = const_cast<OMX_PTR>(apAppData);

	ipCallbacks = const_cast<OMX_CALLBACKTYPE*>(apCallbacks);

	return OMX_ErrorNone;

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoRegisterTunnelCallback(

	OMX_U32 aLocalPortIndex,

	OMX_DIRTYPE aLocalPortDirection,

	OMX_HANDLETYPE aTunnelledComponentHandle,

	OMX_U32 aTunnelledPortIndex)

	{

	DEBUG_PRINTF(_L8("XOmxILCallbackManagerIfImpl::DoRegisterTunnelCallback"));

	OMX_ERRORTYPE omxError = OMX_ErrorNone;

	if (aTunnelledComponentHandle)

		{

		// Register tunnelled port

		TInt err = iRegisteredTunnels.Append(

			TTunnelRegistrationInfo(aLocalPortIndex,

									aLocalPortDirection,

									aTunnelledComponentHandle,

									aTunnelledPortIndex));

		if (KErrNone != err)

			{

			switch (err)

				{

			case KErrNoMemory:

				{

				omxError = OMX_ErrorInsufficientResources;

				}

				break;

			default:

				{

				omxError = OMX_ErrorUndefined;

				}

				};

			}

		}

	else

		{

		// Deregister tunnelled port

		const TUint tunnelCount = iRegisteredTunnels.Count();

		for (TUint i=0; i<tunnelCount; ++i)

			{

			if (iRegisteredTunnels[i].iLocalPortIndex ==

				aLocalPortIndex)

				{

				iRegisteredTunnels.Remove(i);

				break;

				}

			}

		}

	return omxError;

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoRegisterBufferMarkPropagationPort(

	OMX_U32 aPortIndex,

	OMX_U32 aPropagationPortIndex)

	{

	DEBUG_PRINTF3(_L8("XOmxILCallbackManagerIfImpl::DoRegisterBufferMarkPropagationPort : aPortIndex[%d] aPropagationPortIndex[%d] "),aPortIndex, aPropagationPortIndex);

	TInt err = iBufferMarkPropagationPorts.Append(

		TBufferMarkPropagationInfo(aPortIndex,

								   aPropagationPortIndex));

	OMX_ERRORTYPE omxError = OMX_ErrorNone;

	if (KErrNone != err)

		{

		switch (err)

			{

		case KErrNoMemory:

			{

			omxError = OMX_ErrorInsufficientResources;

			}

			break;

		default:

			{

			omxError = OMX_ErrorUndefined;

			}

			};

		}

	return omxError;

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoTransitionCompleteNotification(OMX_STATETYPE aOmxState)

	{

    DEBUG_PRINTF(_L8("XOmxILCallbackManagerIfImpl::DoTransitionCompleteNotification"));

	return DoEventNotification(OMX_EventCmdComplete,

							   OMX_CommandStateSet,

							   aOmxState,

							   0);

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoCommandCompleteNotification(OMX_COMMANDTYPE aOmxCommand,

														   OMX_U32 aOmxPortIndex)

	{

    DEBUG_PRINTF(_L8("XOmxILCallbackManagerIfImpl::DoCommandCompleteNotification"));

	return DoEventNotification(OMX_EventCmdComplete,

							   aOmxCommand,

							   aOmxPortIndex,

							   0);

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoErrorEventNotification(OMX_ERRORTYPE aOmxError)

	{

    DEBUG_PRINTF2(_L8("XOmxILCallbackManagerIfImpl::DoErrorEventNotification : aOmxError[%X] "), aOmxError);

	return DoEventNotification(OMX_EventError,

							   aOmxError,

							   0,

							   0);

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoEventNotification(OMX_EVENTTYPE aEvent,

												 TUint32 aData1,

												 TUint32 aData2,

												 OMX_STRING aExtraInfo)

	{

    DEBUG_PRINTF5(_L8("XOmxILCallbackManagerIfImpl::DoEventNotification : Handle[%X] aEvent[%u] aData1[%u] aData2[%u]"), ipHandle, aEvent, aData1, aData2);

	__ASSERT_DEBUG(ipHandle && ipCallbacks, User::Panic(KOmxILCallbackManagerIfImplPanicCategory, 1));

	ipCallbacks->EventHandler(ipHandle,

							  ipAppData,

							  aEvent,

							  aData1,

							  aData2,

							  aExtraInfo);

	return OMX_ErrorNone;

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoBufferDoneNotification(OMX_BUFFERHEADERTYPE* apBufferHeader,

													  OMX_U32 aLocalPortIndex,

													  OMX_DIRTYPE aLocalPortDirection)

	{

    DEBUG_PRINTF5(_L8("XOmxILCallbackManagerIfImpl::DoBufferDoneNotification : HANDLE [%X] BUFFER [%X] PORT[%d] DIR[%d]"), ipHandle, apBufferHeader, aLocalPortIndex, aLocalPortDirection);

	__ASSERT_ALWAYS(apBufferHeader &&

					(OMX_DirInput == aLocalPortDirection ||

					 OMX_DirOutput == aLocalPortDirection),

					User::Panic(KOmxILCallbackManagerIfImplPanicCategory, 1));

	__ASSERT_ALWAYS(apBufferHeader->nOffset + apBufferHeader->nFilledLen

					<= apBufferHeader->nAllocLen,

					User::Panic(KOmxILCallbackManagerIfImplPanicCategory, 1));

	__ASSERT_DEBUG(ipHandle && ipCallbacks, User::Panic(KOmxILCallbackManagerIfImplPanicCategory, 1));

	// Look for buffer marks to be signalled or propagated

	SignalOrPropagateBufferMarks(apBufferHeader,

								 aLocalPortDirection);

	// find out whether the port is tunnelled or not

	TBool tunnelled = EFalse;

	TUint tunnelInfoArrayIndex = 0;

	const TUint tunnelCount = iRegisteredTunnels.Count();

	for (TUint i=0; i<tunnelCount; ++i)

		{

		if (iRegisteredTunnels[i].iLocalPortIndex ==

			aLocalPortIndex)

			{

			tunnelled = ETrue;

			tunnelInfoArrayIndex = i;

			break;

			}

		}

	if (tunnelled)

		{

		OMX_COMPONENTTYPE* ipTunnelledComponent =

			static_cast<OMX_COMPONENTTYPE*>(

				iRegisteredTunnels[tunnelInfoArrayIndex].

				iTunnelledComponentHandle);

		__ASSERT_DEBUG(ipTunnelledComponent,

					   User::Panic(KOmxILCallbackManagerIfImplPanicCategory, 1));

		// From OMX_Core.h "Callbacks should not return an error to the

		// component, so if an error occurs, the application shall handle it

		// internally". Callback return error ignored here.

		if (OMX_DirInput == aLocalPortDirection)

			{

			OMX_FillThisBuffer(ipTunnelledComponent, apBufferHeader);

			}

		else

			{

			OMX_EmptyThisBuffer(ipTunnelledComponent, apBufferHeader);

			}

		}

	else

		{

		OMX_ERRORTYPE (*fp2CBackHandler)

			(OMX_HANDLETYPE, OMX_PTR, OMX_BUFFERHEADERTYPE*) =

			(aLocalPortDirection == OMX_DirInput ?

			 ipCallbacks->EmptyBufferDone :

			 ipCallbacks->FillBufferDone);

		// From OMX_Core.h "Callbacks should not return an error to the

		// component, so if an error occurs, the application shall handle it

		// internally". Callback return error ignored here.

#ifdef OMX_DEBUG_TRACING_ON

		if (aLocalPortDirection == OMX_DirInput)

			{

			OMX_TRACE_EMPTYBUFFERDONE_IN(ipHandle, ipAppData, apBufferHeader);

			}

		else

			{

			OMX_TRACE_FILLBUFFERDONE_IN(ipHandle, ipAppData, apBufferHeader);

			}

#endif

		fp2CBackHandler(ipHandle,

						ipAppData,

						apBufferHeader);

#ifdef OMX_DEBUG_TRACING_ON

        if (aLocalPortDirection == OMX_DirInput)

            {

            OMX_TRACE_EMPTYBUFFERDONE_OUT(ipHandle, ipAppData, apBufferHeader, 0);

            }

        else

            {

            OMX_TRACE_FILLBUFFERDONE_OUT(ipHandle, ipAppData, apBufferHeader, 0);

            }

#endif

		}

	return OMX_ErrorNone;

	}

OMX_ERRORTYPE

XOmxILCallbackManagerIfImpl::DoPortSettingsChangeNotification(

	OMX_U32 aLocalPortIndex,

	TUint aPortSettingsIndex,

	const TDesC8& aPortSettings)

	{

    DEBUG_PRINTF2(_L8("XOmxILCallbackManagerIfImpl::DoPortSettingsChangeNotification : aLocalPortIndex[%d]"), aLocalPortIndex);

	__ASSERT_DEBUG(ipHandle &&

				   ipCallbacks &&

				   ipPortManager,

				   User::Panic(KOmxILCallbackManagerIfImplPanicCategory, 1));

	HBufC8* pPortSettings = HBufC8::New(aPortSettings.Length());

	if (!pPortSettings)

		{

		return OMX_ErrorInsufficientResources;

		}

	*pPortSettings = aPortSettings;

	// This is an event that the port may want to convey to the IL Client...

	OMX_EVENTTYPE eventForILClient = OMX_EventMax;

	OMX_ERRORTYPE omxRetError =

		ipPortManager->PortSettingsChangeIndication(aLocalPortIndex,

													aPortSettingsIndex,

													*pPortSettings,

													eventForILClient);

	delete pPortSettings;

	pPortSettings = NULL;

	// Inform the IL Client that some value in one of the ports' configuration

	// structures has changed...

	if (OMX_EventMax != eventForILClient)

		{

		// Only allow these two port events...

		__ASSERT_ALWAYS(eventForILClient == OMX_EventPortSettingsChanged ||

						eventForILClient == OMX_EventPortFormatDetected,

						User::Panic(KOmxILCallbackManagerIfImplPanicCategory, 1));

		// From OMX_Core.h "Callbacks should not return an error to the component,

		// so if an error occurs, the application shall handle it

		// internally". Callback return error ignored here.

		ipCallbacks->EventHandler(ipHandle,

								  ipAppData,

								  eventForILClient,

								  aLocalPortIndex,

								  0,

								  0);

		}

	return OMX_ErrorNone;

	}

void

XOmxILCallbackManagerIfImpl::SignalOrPropagateBufferMarks(

	OMX_BUFFERHEADERTYPE* apBufferHeader,

	OMX_U32 aLocalPortIndex)

	{

    DEBUG_PRINTF(_L8("XOmxILCallbackManagerIfImpl::SignalOrPropagateBufferMarks()"));

	// Look for buffer marks to be signalled or propagated

	if (apBufferHeader->hMarkTargetComponent)

		{

		// See if this component is the buffer mark target component...

		if (apBufferHeader->hMarkTargetComponent == ipHandle)

			{

			// Inform the IL Client that a marked buffer has been processed...

			ipCallbacks->EventHandler(ipHandle,

									  ipAppData,

									  OMX_EventMark,

									  0,

									  0,

									  apBufferHeader->pMarkData);

			// At this point, the mark has been delivered to the IL

			// Client...Remove the mark from the processed header...

			apBufferHeader->hMarkTargetComponent = 0;

			apBufferHeader->pMarkData = 0;

			}

		else

			{

			// Propagate the mark...

			// First find the buffer mark propagation port...

			const TInt index = iBufferMarkPropagationPorts.Find(

				TBufferMarkPropagationInfo(aLocalPortIndex),

				TIdentityRelation<TBufferMarkPropagationInfo>(

					&TBufferMarkPropagationInfo::Compare));

			// Note that sink components don't propagate marks...

			if (index != KErrNotFound)

				{

				const TBufferMarkPropagationInfo& propInfo =

					iBufferMarkPropagationPorts[index];

				// Let's check for the special case: The case for a source

				// component where the output port is both the port that marks

				// the headers and the port that propagates them ... Therefore

				// no need to store the mark for later propagation...

				if (propInfo.iPropagationPortIndex != aLocalPortIndex)

					{

					// Now, store temporarily the mark so the next time we send

					// a buffer done callback in that propagation port, we mark

					// that header accordingly...

					// Unsuccessful insertion is ignored.

					iBufferMarks.Append(

						TOutputPortBufferMarkInfo(

							propInfo.iPropagationPortIndex,

							apBufferHeader->hMarkTargetComponent,

							apBufferHeader->pMarkData));

					// At this point the mark has been set for propagation to

					// an output port. Remove the mark from the processed

					// header...

					apBufferHeader->hMarkTargetComponent = 0;

					apBufferHeader->pMarkData = 0;

					}

				}

			}

		}

	else

		{

		if(iBufferMarks.Count() != 0)

			{

			// Let's see if we have a mark waiting to go out...This will find the

			// first mark in the local list of marks ...

			const TInt index = iBufferMarks.Find(

				TOutputPortBufferMarkInfo(aLocalPortIndex),

				TIdentityRelation<TOutputPortBufferMarkInfo>(

					&TOutputPortBufferMarkInfo::Compare));

			if (index != KErrNotFound)

				{

				const TOutputPortBufferMarkInfo& markInfo =

					iBufferMarks[index];

				// Mark the header...

				apBufferHeader->hMarkTargetComponent = markInfo.ipMarkTargetComponent;

				apBufferHeader->pMarkData                        = markInfo.ipMarkData;

				// Remove the mark info from the local store

				iBufferMarks.Remove(index);

				}

			}

		}

	}

void

XOmxILCallbackManagerIfImpl::HandleInsufficientResources()

	{

    DEBUG_PRINTF3(_L8("XOmxILCallbackManagerIfImpl::HandleInsufficientResources : ipCallbacks[%X] ipHandle[%X]"), ipCallbacks, ipHandle);

	if (ipCallbacks && ipHandle)

		{

		// This is a best-effort action, let's try to inform the IL Client of

		// the lack of resources...

		ipCallbacks->EventHandler(ipHandle,

								  ipAppData,

								  OMX_EventError,

					  			  (OMX_U32)OMX_ErrorInsufficientResources,

								  0,

								  0);

		}

	}