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

// omxinputport.cpp

// 

//

#include <omxprocessingunit.h>

#include <omxinputport.h>

#include <mdf/mdfpuconfig.h>

#include "omxcomponentbody.h"

#include "omxinputportbody.h"

_LIT(KOmxInputPort, "OmxInputPortBody");

COmxInputPort::CBody* COmxInputPort::CBody::NewL(TInt aIndex, COmxProcessingUnit* aComponent, COmxInputPort* aParent)

	{

	return new (ELeave) CBody(aIndex, aComponent, aParent);	

	}  

COmxInputPort::CBody::CBody(TInt aIndex, COmxProcessingUnit* aComponent, COmxInputPort* aParent) :

	iPortIndex(aIndex),

	iComponent(aComponent),	

	iParent(aParent)

	{

	}

TInt COmxInputPort::CBody::MipConfigure(const TPuConfig& /*aConfig*/)

	{

	return KErrNotSupported;	

	}	

TInt COmxInputPort::CBody::MipGetConfig(TPuConfig& /*aConfig*/)

	{

	return KErrNotSupported;	

	}	

void COmxInputPort::CBody::MipInitialize()

	{	

	}

CMMFBuffer* COmxInputPort::CBody::MipCreateBuffer(TInt aBufferSize)

	{

	CMMFBuffer* buffer = NULL;

	TInt err = KErrNone;

	TRAP(err, buffer = Component()->OmxAllocateBufferL(iPortIndex, aBufferSize));	

	return buffer;

	}

TInt COmxInputPort::CBody::MipUseBuffer(CMMFBuffer& aBuffer)

	{

	return Component()->OmxUseBuffer(&aBuffer, iPortIndex);		

	}

TInt COmxInputPort::CBody::MipFreeBuffer(CMMFBuffer* aBuffer)

	{

	return Component()->OmxFreeBuffer(aBuffer);		

	}

TInt COmxInputPort::CBody::MipTunnelRequest(const MMdfOutputPort& /*aOutputPortToBeConnectedTo*/,

		TTunnelFlags& /*aTunnelFlags*/, TSupplierType& /*aSupplierType*/) 

	{

	return KErrNotSupported;

	}

void COmxInputPort::CBody::MipWriteData(CMMFBuffer& aInputBuffer)

	{

	Component()->OmxEmptyThisBuffer(&aInputBuffer, this);	

	}

void COmxInputPort::CBody::MipDisconnectTunnel()

	{

	// here, as this can reasonably be called by the device adapter

	// during unloading of a PU which has been loaded but never initialised,

	// we use a conditional instead of an ASSERT	

	if(iObserver) 

		{

		iObserver->MipoDisconnectTunnelComplete(iParent, KErrNone);

		}

	}

void COmxInputPort::CBody::MipRestartTunnel()

	{

	__ASSERT_ALWAYS(iObserver, User::Panic(KOmxInputPort, EObserverNotSet));

	iObserver->MipoRestartTunnelComplete(iParent, KErrNone);

	}		

TBool COmxInputPort::CBody::MipIsTunnelled() const

	{

	if (!iConnectedPort)

		{

		return EFalse;

		}		

	return ETrue;

	}

TInt COmxInputPort::CBody::MipIndex() const

	{

	return iPortIndex;

	}

TUint32 COmxInputPort::CBody::MipBufferSize() const

	{

	OMX_PARAM_PORTDEFINITIONTYPE portInfo;

	portInfo.nPortIndex = 0;

	Component()->OmxGetParameter(OMX_IndexParamPortDefinition, &portInfo);	

	return portInfo.nBufferSize;

	}

void COmxInputPort::CBody::MipSetObserver(const MMdfInputPortObserver& aOutputPortObserver)

	{

	iObserver = const_cast<MMdfInputPortObserver*>(&aOutputPortObserver);

	}

TInt COmxInputPort::CBody::EmptyBufferDone(OMX_HANDLETYPE /*aComponent*/, const CMMFBuffer* aBuffer)

	{

	__ASSERT_ALWAYS(iObserver, User::Panic(KOmxInputPort, EObserverNotSet));

	iObserver->MipoWriteDataComplete(iParent, const_cast<CMMFBuffer*>(aBuffer),KErrNone);

	return KErrNone;

	}

TInt COmxInputPort::CBody::MipCreateCustomInterface(TUid /*aUid*/)

	{

	return KErrNotSupported;	

	}

TAny* COmxInputPort::CBody::MipCustomInterface(TUid /*aUid*/)

	{

	return NULL;

	}

MMdfInputPortObserver* COmxInputPort::CBody::Observer() const

	{

	return iObserver;

	}

COmxProcessingUnit* COmxInputPort::CBody::Component() const

	{

	return iComponent;

	}