// Copyright (c) 2006-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 FILES

#include "mmfdevsoundproxy.h"

#ifdef _DEBUG

#include <e32debug.h>

#define SYMBIAN_DEBPRN0(str)                RDebug::Print(str, this)

#define SYMBIAN_DEBPRN1(str, val1)          RDebug::Print(str, this, val1)

#define SYMBIAN_DEBPRN2(str, val1, val2)    RDebug::Print(str, this, val1, val2)

#else

#define SYMBIAN_DEBPRN0(str)

#define SYMBIAN_DEBPRN1(str, val1)

#define SYMBIAN_DEBPRN2(str, val1, val2)

#endif //_DEBUG

// SYMBIAN_CHECK used to add extra asserts when MACRO is added - helps debugging overall A3F

#ifdef SYMBIAN_FULL_STATE_CHECK

   #define SYMBIAN_CHECK(c,p) __ASSERT_ALWAYS(c,p)

#else

   #define SYMBIAN_CHECK(c,p)

#endif 

const TInt KMaxMessageQueueItems = 8;

const TMMFCapabilities KZeroCapabilities = 

	{

	0,0,0,0 // all zero's

	};

// ============================ LOCAL FUNCTIONS ================================

// -----------------------------------------------------------------------------

// This function raises a panic

//

// @param	aError

// 		one of the several panic codes that may be raised by this dll

//

// @panic	EMMFDevSoundProxyPlayDataWithoutInitialize is raised when playdata

//          is called without initialization

// @panic	EMMFDevSoundProxyRecordDataWithoutInitialize is raised when

//          recorddata is called without initialization

//

GLDEF_C void Panic(TMMFDevSoundProxyPanicCodes aPanicCode)

	{

	User::Panic(KMMFDevSoundProxyPanicCategory, aPanicCode);

	}

// ============================ MEMBER FUNCTIONS ===============================

// -----------------------------------------------------------------------------

// RMMFDevsoundProxy::RMMFDevsoundProxy

// C++ default constructor can NOT contain any code, that

// might leave.

// -----------------------------------------------------------------------------

//

EXPORT_C RMMFDevSoundProxy::RMMFDevSoundProxy() :

	iBuffer(NULL),

	iSeqName(NULL),

	iDestinationPckg(TMMFMessageDestination(KUidInterfaceMMFDevSound,

											KMMFObjectHandleDevSound)),

	iState(EIdle),

	iAudioServerProxy(NULL),

	iDevSoundObserver(NULL),

	iMsgQueueHandler(NULL),

	iCustIntPckg()

	{

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::Close

// Close the server session

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C void RMMFDevSoundProxy::Close()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Close - Enter"));

	if (iAudioServerProxy)

		{

		if (iAudioServerProxy->Handle() != NULL)

			{

			TMMFDevSoundProxySettings set;

			TMMFDevSoundProxySettingsPckg pckg(set);

			TInt err = SendReceive(EMMFDevSoundProxyClose,

						iDestinationPckg,

						pckg);

			}

		iAudioServerProxy->Close();

		delete iAudioServerProxy;

		iAudioServerProxy = NULL;

		}

	RMmfSessionBase::Close();

	iState = EIdle;

	if (iMsgQueueHandler)

		{

		iMsgQueueHandler->Cancel();

		delete iMsgQueueHandler;

		iMsgQueueHandler = NULL;

		}

	iMsgQueue.Close();

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Close - Exit"));

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::Open

// Open a DevSound server session

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TInt RMMFDevSoundProxy::Open()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Open - Enter"));

	TInt err = iMsgQueue.CreateGlobal(KNullDesC, KMaxMessageQueueItems, EOwnerThread);

	// global, accessible to all that have its handle

	if (err == KErrNone)

		{

		iAudioServerProxy = NULL;

		iMsgQueueHandler = NULL;

		iBuffer = NULL;

		iAudioServerProxy = new RMMFAudioServerProxy();

		if (iAudioServerProxy == NULL)

			{

			err = KErrNoMemory;

			}

		}

	if (err == KErrNone)	

		{

		err = iAudioServerProxy->Open();

		}

	if (err == KErrNone)

		{

		err = SetReturnedHandle(iAudioServerProxy->GetDevSoundSessionHandle());

		}

	if (err)

		{	

		Close();

		}

	SYMBIAN_DEBPRN1(_L("RMMFDevSoundProxy[0x%x]::Open - Exit [%d]"), err);

	return err;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::PostOpen

// Finish opening process

// -----------------------------------------------------------------------------

//

EXPORT_C TInt RMMFDevSoundProxy::PostOpen()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::PostOpen - Enter"));

	TInt err = SendReceive(EMMFDevSoundProxyPostOpen, iDestinationPckg);

	SYMBIAN_DEBPRN1(_L("RMMFDevSoundProxy[0x%x]::PostOpen - Exit [%d]"), err);

	return err;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::SetDevSoundInfo

// Launch DevSound that might have been waiting for audio policy.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TInt RMMFDevSoundProxy::SetDevSoundInfo()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::SetDevSoundInfo - Enter"));

	TInt err = SendReceive(EMMFAudioLaunchRequests);

	SYMBIAN_DEBPRN1(_L("RMMFDevSoundProxy[0x%x]::SetDevSoundInfo - Exit [%d]"), err);

	return err;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::InitializeL

// Initialize DevSound for a specific mode.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C void RMMFDevSoundProxy::InitializeL(

							MDevSoundObserver& aDevSoundObserver,

							TMMFState aMode,

							MMMFDevSoundCustomInterfaceObserver& aDevSoundCIObserver)

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::InitializeL - Enter"));

	TInt err = KErrNone;

	iDevSoundObserver = &aDevSoundObserver;

	if (!(iState==EIdle || iState==EInitialized))

		{

		err = KErrNotReady;

		}

	else

		{

		TMMFDevSoundProxySettings set;

		set.iMode = aMode;

		TMMFDevSoundProxySettingsPckg pckg(set);

		TIpcArgs args(&iDestinationPckg, &pckg, iMsgQueue);

		err = RSessionBase::SendReceive(EMMFDevSoundProxyInitialize1, args);		

		if (err == KErrNone)

			{

			StartReceivingMsgQueueHandlerEventsL(aDevSoundCIObserver);

			iState = EInitializing;

			}	

		}

	SYMBIAN_DEBPRN1(_L("RMMFDevSoundProxy[0x%x]::InitializeL - Exit [%d]"), err);

	User::LeaveIfError(err);

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::InitializeL

// Initialize DevSound with specific HwDevice id and mode.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C void RMMFDevSoundProxy::InitializeL(

								MDevSoundObserver& /*aDevSoundObserver*/,

								TUid /*aHWDev*/,

								TMMFState /*aMode*/,

								MMMFDevSoundCustomInterfaceObserver& /*aDevSoundCIObserver*/)

	{

	TInt err = KErrNotSupported;

	User::LeaveIfError(err);

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::InitializeL

// Initialize DevSound for the specific FourCC and mode.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C void RMMFDevSoundProxy::InitializeL(

								MDevSoundObserver& aDevSoundObserver,

								TFourCC aDesiredFourCC,

								TMMFState aMode,

								MMMFDevSoundCustomInterfaceObserver& aDevSoundCIObserver)

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::InitializeL - Enter"));

	TInt err = KErrNone;

	if(aMode == EMMFStateTonePlaying)

		{

		User::Leave(KErrNotSupported);

		}

	iDevSoundObserver = &aDevSoundObserver;

	if (!(iState==EIdle || iState==EInitialized))

		{

		err = KErrNotReady;

		}

	else

		{

		TMMFDevSoundProxySettings set;

		set.iDesiredFourCC = aDesiredFourCC;

		set.iMode = aMode;

		TMMFDevSoundProxySettingsPckg pckg(set);

		TIpcArgs args(&iDestinationPckg, &pckg, iMsgQueue);

		err = RSessionBase::SendReceive(EMMFDevSoundProxyInitialize4, args);

		if (err == KErrNone)

			{

			StartReceivingMsgQueueHandlerEventsL(aDevSoundCIObserver);

			iState = EInitializing;

			}	

		}

	SYMBIAN_DEBPRN1(_L("RMMFDevSoundProxy[0x%x]::InitializeL - Exit [%d]"), err);

	User::LeaveIfError(err);

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::Capabilities

// Returns the capabilities of the DevSound server.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TMMFCapabilities RMMFDevSoundProxy::Capabilities()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Capabilities - Enter"));

	// TODO should we use the following ? SYMBIAN_CHECK(iState>=EInitialized, Panic(EMMFDevSoundProxyCapabilitiesInWrongState));

	if (iState < EInitialized)

		{

		// call has been made before we are initialized. Not much we can do, so return

		// dummy values but hit debugger on the emulator

		__DEBUGGER()

		RDebug::Print(_L("BRDBG:CapabilitiesCalledWhenNotInitialised")); // TODO Remove or redo as trace

		SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Capabilities - Exit"));

		return KZeroCapabilities;

		}

	TMMFDevSoundProxySettings set;

	TMMFDevSoundProxySettingsPckg pckg(set);

	TInt err = SendReceiveResult(EMMFDevSoundProxyCapabilities,

					iDestinationPckg,

					KNullDesC8,

					pckg);

	if (err == KErrNone)

		{

		SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Capabilities - Exit"));

		return pckg().iCaps;

		}

	else

		{

		SYMBIAN_DEBPRN1(_L("RMMFDevSoundProxy[0x%x]::Capabilities - Exit [%d]"), err);

		return KZeroCapabilities;

		}

	}

// -----------------------------------------------------------------------------

// TMMFCapabilities RMMFDevSoundProxy::Config

// Returns the current configuration of the DevSound.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TMMFCapabilities RMMFDevSoundProxy::Config()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Config - Enter"));

	// TODO should we use the following ? SYMBIAN_CHECK(iState>=EInitialized, Panic(EMMFDevSoundProxyConfigInWrongState));

	if (iState < EInitialized)

		{

		// call has been made before we are initialized. Not much we can do, so return

		// dummy values but hit debugger on the emulator

		__DEBUGGER()

		RDebug::Print(_L("BRDBG:ConfigCalledWhenNotInitialised")); // TODO Remove or redo as trace

		SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Config - Exit"));

		return KZeroCapabilities;

		}

	TMMFDevSoundProxySettings set;

	TMMFDevSoundProxySettingsPckg pckg(set);

	SendReceiveResult(EMMFDevSoundProxyConfig,

					iDestinationPckg,

					KNullDesC8,

					pckg);

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Config - Exit"));

	return pckg().iConfig;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::SetConfigL

// Configures the DevSound server.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C void RMMFDevSoundProxy::SetConfigL(

	const TMMFCapabilities& aConfig )

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::SetConfigL - Enter"));

	TInt err = KErrNone;

	if (iState==EInitialized)

		{

		TMMFDevSoundProxySettings set;

		set.iConfig = aConfig;

		TMMFDevSoundProxySettingsPckg pckg(set);

		err = SendReceive(EMMFDevSoundProxySetConfig,

							iDestinationPckg,

							pckg);

		}

	else

		{

		RDebug::Print(_L("BRDBG:SetConfigCalledWhenNotInitialised")); // TODO Remove or redo as trace				

		err = KErrNotReady;

		}

	SYMBIAN_DEBPRN1(_L("RMMFDevSoundProxy[0x%x]::SetConfigL - Exit [%d]"), err);

	User::LeaveIfError(err);

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::MaxVolume

// Returns the maximum volume supported by DevSound server for playing back..

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TInt RMMFDevSoundProxy::MaxVolume()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::MaxVolume - Enter"));

	TMMFDevSoundProxySettings set;

	TMMFDevSoundProxySettingsPckg pckg(set);

	SendReceiveResult(EMMFDevSoundProxyMaxVolume,

					iDestinationPckg,

					KNullDesC8,

					pckg);

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::MaxVolume - Exit"));

	return pckg().iMaxVolume;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::Volume

// Returns the current volume.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TInt RMMFDevSoundProxy::Volume()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Volume - Enter"));

	TMMFDevSoundProxySettings set;

	TMMFDevSoundProxySettingsPckg pckg(set);

	SendReceiveResult(EMMFDevSoundProxyVolume,

					iDestinationPckg,

					KNullDesC8,

					pckg);

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Volume - Exit"));

	return pckg().iVolume;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::SetVolume

// Sets the current volume.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TInt RMMFDevSoundProxy::SetVolume(TInt aVolume )

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::SetVolume - Enter"));

	TMMFDevSoundProxySettings set;

	set.iVolume = aVolume;

	TMMFDevSoundProxySettingsPckg pckg(set);

	TInt err = SendReceive(EMMFDevSoundProxySetVolume,

					iDestinationPckg,

					pckg);

	SYMBIAN_DEBPRN1(_L("RMMFDevSoundProxy[0x%x]::SetVolume - Exit [%d]"), err);

	return err;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::MaxGain

// Returns maximum gain supported by DevSound server for recording.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TInt RMMFDevSoundProxy::MaxGain()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::MaxGain - Enter"));

	TMMFDevSoundProxySettings set;

	TMMFDevSoundProxySettingsPckg pckg(set);

	SendReceiveResult(EMMFDevSoundProxyMaxGain,

					iDestinationPckg,

					KNullDesC8,

					pckg);

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::MaxGain - Exit"));

	return pckg().iMaxGain;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::Gain

// Returns the current gain.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TInt RMMFDevSoundProxy::Gain()

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Gain - Enter"));

	TMMFDevSoundProxySettings set;

	TMMFDevSoundProxySettingsPckg pckg(set);

	SendReceiveResult(EMMFDevSoundProxyGain,

				iDestinationPckg,

				KNullDesC8,

				pckg);

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::Gain - Exit"));

	return pckg().iGain;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::SetGain

// Sets the current gain.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C TInt RMMFDevSoundProxy::SetGain(

	TInt aGain )

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::SetGain - Enter"));

	TMMFDevSoundProxySettings set;

	set.iGain = aGain;

	TMMFDevSoundProxySettingsPckg pckg(set);

	TInt err = SendReceive(EMMFDevSoundProxySetGain,

					iDestinationPckg,

					pckg);

	SYMBIAN_DEBPRN1(_L("RMMFDevSoundProxy[0x%x]::SetGain - Exit [%d]"), err);

	return err;

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::GetPlayBalanceL

// Returns play balance.

// (other items were commented in a header).

// -----------------------------------------------------------------------------

//

EXPORT_C void RMMFDevSoundProxy::GetPlayBalanceL(

		TInt& aLeftPercentage,

		TInt& aRightPercentage )

	{

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::GetPlayBalanceL - Enter"));

	TMMFDevSoundProxySettings set;

	TMMFDevSoundProxySettingsPckg pckg(set);

	User::LeaveIfError(SendReceiveResult(EMMFDevSoundProxyPlayBalance,

									iDestinationPckg,

									KNullDesC8,

									pckg));

	aLeftPercentage = pckg().iLeftPercentage;

	aRightPercentage = pckg().iRightPercentage;

	SYMBIAN_DEBPRN0(_L("RMMFDevSoundProxy[0x%x]::GetPlayBalanceL - Exit"));

	}

// -----------------------------------------------------------------------------

// RMMFDevSoundProxy::SetPlayBalanceL

// Sets playbalance.

// (other items were commented in a header).

// -----------------------------------------------------------------------------