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

//

#include <mdf/mdfpuconfig.h>

#include "pcmprocessingunit.h"

#include "pcminputport.h"

#include "pcmoutputport.h"

#include <mmf/server/taskconfig.h>

const TInt KPcmInputPortIndex = 0;

const TInt KPcmOutputPortIndex = 1;

_LIT8(KPcmILComponentName, "OMX.SYMBIAN.AUDIO.CODEC.PCM");

CPcmProcessingUnit::CPcmProcessingUnit()

	{

	}

CPcmProcessingUnit* CPcmProcessingUnit::NewP8P16L()

	{

	CPcmProcessingUnit* self = new (ELeave) CPcmProcessingUnit;

	CleanupStack::PushL(self);

	self->ConstructL(EPCM8, EPCM16);

	CleanupStack::Pop(self);

	return self;

	}

CPcmProcessingUnit* CPcmProcessingUnit::NewP16P8L()

	{

	CPcmProcessingUnit* self = new (ELeave) CPcmProcessingUnit;

	CleanupStack::PushL(self);

	self->ConstructL(EPCM16, EPCM8);

	CleanupStack::Pop(self);

	return self;

	}

CPcmProcessingUnit* CPcmProcessingUnit::NewPU8P16L()

	{

	CPcmProcessingUnit* self = new (ELeave) CPcmProcessingUnit;

	CleanupStack::PushL(self);

	self->ConstructL(EPCMU8, EPCM16);

	CleanupStack::Pop(self);

	return self;

	}

CPcmProcessingUnit* CPcmProcessingUnit::NewP16PU8L()

	{

	CPcmProcessingUnit* self = new (ELeave) CPcmProcessingUnit;

	CleanupStack::PushL(self);

	self->ConstructL(EPCM16, EPCMU8);

	CleanupStack::Pop(self);

	return self;

	}

void CPcmProcessingUnit::ConstructL(TPcmDataType aSrcDataType, TPcmDataType aDestDataType)

	{

	iSrcDataType = aSrcDataType;

	iDestDataType = aDestDataType;

	}

CPcmProcessingUnit::~CPcmProcessingUnit()

	{

	// Delete input and output ports	

	delete iInputPort;

	iInputPort = NULL;

	delete iOutputPort;

	iOutputPort = NULL;		

	}

TInt CPcmProcessingUnit::Create(const MMdfProcessingUnitObserver& aProcessingUnitObserver)

	{

	TInt err = KErrNone;

	// Create underlying OMX component

	TRAP(err, COmxProcessingUnit::ConstructL(KPcmILComponentName, aProcessingUnitObserver));

	if (err == KErrNone)

		{

		SetPuState(EProcessingUnitLoaded);

		// Create Input and output ports

		TRAP(err, iInputPort  = CPcmInputPort::NewL(KPcmInputPortIndex, this, iSrcDataType));

		if(err != KErrNone)

			{

			return err;

			}

		TRAPD(err, iOutputPort = CPcmOutputPort::NewL(KPcmOutputPortIndex, this, iDestDataType));

		if(err != KErrNone)

			{

			return err;

			}		

		// Add them to processing unit

		err = AddInputPort(iInputPort);

		if (err != KErrNone)

			{

			return err;

			}

		err = AddOutputPort(iOutputPort);					

		}

	return err;

	}

TInt CPcmProcessingUnit::Configure(const TPuConfig& /*aConfig*/)

	{

	return KErrNone;

	}