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

 	}