// Copyright (c) 2004-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 <f32file.h>
#include <e32math.h>
#include <s32mem.h>
#include "MmfDevSoundProxy.h"
#include "MmfDevSoundServerStart.h"
#include "MmfBase.hrh"
#include "MmfAudioClientServer.h"
#include <mmf/plugin/mmfdevsoundcustominterface.hrh>
#include <ecom/ecom.h>
/**
@internalTechnology
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
@panic EMMFDevSoundProxyConvertDataWithoutInitialize is raised when convertdata is called without initialization
*/
GLDEF_C void Panic(TMMFDevSoundProxyPanicCodes aPanicCode)
{
User::Panic(KMMFDevSoundProxyPanicCategory, aPanicCode);
}
EXPORT_C RMMFDevSoundProxy::RMMFDevSoundProxy()
: iBuffer(NULL), iSeqName(NULL), iMsgQueueHandle(NULL), iAudioServerProxy (NULL)
{
}
EXPORT_C void RMMFDevSoundProxy::Close()
{
RMmfSessionBase::Close();
iState = EIdle;
if(iAudioServerProxy)
{
iAudioServerProxy->Close();
delete iAudioServerProxy;
}
delete iBuffer;
delete iSeqName;
}
EXPORT_C TInt RMMFDevSoundProxy::Open(RHandleBase& aMsgQueueHandle)
{
TInt err = KErrNone;
iMsgQueueHandle = &aMsgQueueHandle;
TRAP(err, iSeqName = HBufC::NewL(KMaxFixedSequenceNameLength));
if(err == KErrNone)
{
TRAP(err, iAudioServerProxy = new (ELeave) RMMFAudioServerProxy());
if(err == KErrNone)
{
err = iAudioServerProxy->Open();
if(err == KErrNone)
{
err = SetReturnedHandle(iAudioServerProxy->GetDevSoundSessionHandle());
}
}
}
if(err)
{
Close();
}
return err;
}
EXPORT_C TInt RMMFDevSoundProxy::SetDevSoundInfo()
{
return SendReceive(EMMFAudioLaunchRequests);
}
EXPORT_C TInt RMMFDevSoundProxy::InitializeL(TMMFState aMode)
{
TMMFDevSoundProxySettings set;
set.iMode = aMode;
TMMFDevSoundProxySettingsPckg pckg(set);
TIpcArgs args(&pckg, *iMsgQueueHandle);
return RSessionBase::SendReceive(EMMFDevSoundProxyInitialize1, args);
}
EXPORT_C TInt RMMFDevSoundProxy::InitializeL(TUid aHWDev, TMMFState aMode)
{
TMMFDevSoundProxySettings set;
set.iHWDev = aHWDev;
set.iMode = aMode;
TMMFDevSoundProxySettingsPckg pckg(set);
TIpcArgs args(&pckg, *iMsgQueueHandle);
return RSessionBase::SendReceive(EMMFDevSoundProxyInitialize2, args);
}
EXPORT_C TInt RMMFDevSoundProxy::InitializeL(TFourCC aDesiredFourCC, TMMFState aMode)
{
TMMFDevSoundProxySettings set;
set.iDesiredFourCC = aDesiredFourCC;
set.iMode = aMode;
TMMFDevSoundProxySettingsPckg pckg(set);
TIpcArgs args(&pckg, *iMsgQueueHandle);
return RSessionBase::SendReceive(EMMFDevSoundProxyInitialize4, args);
}
EXPORT_C TMMFCapabilities RMMFDevSoundProxy::Capabilities()
{
TMMFDevSoundProxySettings set;
TMMFDevSoundProxySettingsPckg pckg(set);
SendReceiveResult(EMMFDevSoundProxyCapabilities,KNullDesC8,KNullDesC8,pckg);
return pckg().iCaps;
}
EXPORT_C TMMFCapabilities RMMFDevSoundProxy::Config()
{
TMMFDevSoundProxySettings set;
TMMFDevSoundProxySettingsPckg pckg(set);
SendReceiveResult(EMMFDevSoundProxyConfig,KNullDesC8,KNullDesC8,pckg);
return pckg().iConfig;
}
EXPORT_C TInt RMMFDevSoundProxy::SetConfigL(const TMMFCapabilities& aConfig)
{
TMMFDevSoundProxySettings set;
set.iConfig = aConfig;
TMMFDevSoundProxySettingsPckg pckg(set);
TInt err = SendReceive(EMMFDevSoundProxySetConfig, pckg);
User::LeaveIfError(err);
return err;
}
EXPORT_C TInt RMMFDevSoundProxy::MaxVolume()
{
TMMFDevSoundProxySettings set;
TMMFDevSoundProxySettingsPckg pckg(set);
SendReceiveResult(EMMFDevSoundProxyMaxVolume,KNullDesC8,KNullDesC8,pckg);
return pckg().iMaxVolume;
}
EXPORT_C TInt RMMFDevSoundProxy::Volume()
{
TMMFDevSoundProxySettings set;
TMMFDevSoundProxySettingsPckg pckg(set);
SendReceiveResult(EMMFDevSoundProxyVolume,KNullDesC8,KNullDesC8,pckg);
return pckg().iVolume;
}
EXPORT_C TInt RMMFDevSoundProxy::SetVolume(TInt aVolume)
{
TMMFDevSoundProxySettings set;
set.iVolume = aVolume;
TMMFDevSoundProxySettingsPckg pckg(set);
return SendReceive(EMMFDevSoundProxySetVolume, pckg);
}
EXPORT_C TInt RMMFDevSoundProxy::MaxGain()
{
TMMFDevSoundProxySettings set;
TMMFDevSoundProxySettingsPckg pckg(set);
SendReceiveResult(EMMFDevSoundProxyMaxGain,KNullDesC8,KNullDesC8,pckg);
return pckg().iMaxGain;
}
EXPORT_C TInt RMMFDevSoundProxy::Gain()
{
TMMFDevSoundProxySettings set;
TMMFDevSoundProxySettingsPckg pckg(set);
SendReceiveResult(EMMFDevSoundProxyGain,KNullDesC8,KNullDesC8,pckg);
return pckg().iGain;
}
EXPORT_C TInt RMMFDevSoundProxy::SetGain(TInt aGain)
{
TMMFDevSoundProxySettings set;
set.iGain = aGain;
TMMFDevSoundProxySettingsPckg pckg(set);
return SendReceive(EMMFDevSoundProxySetGain, pckg);
}
EXPORT_C void RMMFDevSoundProxy::GetPlayBalanceL(TInt& aLeftPercentage, TInt& aRightPercentage)
{
TMMFDevSoundProxySettings set;
TMMFDevSoundProxySettingsPckg pckg(set);
User::LeaveIfError(SendReceiveResult(EMMFDevSoundProxyPlayBalance,KNullDesC8,KNullDesC8,pckg));
aLeftPercentage = pckg().iLeftPercentage;
aRightPercentage = pckg().iRightPercentage;
}
EXPORT_C void RMMFDevSoundProxy::SetPlayBalanceL(TInt aLeftPercentage, TInt aRightPercentage)
{
TMMFDevSoundProxySettings set;
set.iLeftPercentage = aLeftPercentage;
set.iRightPercentage = aRightPercentage;
TMMFDevSoundProxySettingsPckg pckg(set);
User::LeaveIfError(SendReceive(EMMFDevSoundProxySetPlayBalance, pckg));
}
EXPORT_C void RMMFDevSoundProxy::GetRecordBalanceL(TInt& aLeftPercentage, TInt& aRightPercentage)
{
TMMFDevSoundProxySettings set;
TMMFDevSoundProxySettingsPckg pckg(set);
User::LeaveIfError(SendReceiveResult(EMMFDevSoundProxyRecordBalance,KNullDesC8,KNullDesC8,pckg));
aLeftPercentage = pckg().iLeftPercentage;
aRightPercentage = pckg().iRightPercentage;
}
EXPORT_C void RMMFDevSoundProxy::SetRecordBalanceL(TInt aLeftPercentage, TInt aRightPercentage)
{
TMMFDevSoundProxySettings set;
set.iLeftPercentage = aLeftPercentage;
set.iRightPercentage = aRightPercentage;
TMMFDevSoundProxySettingsPckg pckg(set);
User::LeaveIfError(SendReceive(EMMFDevSoundProxySetRecordBalance, pckg));
}
EXPORT_C void RMMFDevSoundProxy::PlayInitL()
{
User::LeaveIfError(SendReceive(EMMFDevSoundProxyPlayInit));
iState = EPlaying;
}
EXPORT_C void RMMFDevSoundProxy::RecordInitL()
{
User::LeaveIfError(SendReceive(EMMFDevSoundProxyRecordInit));
iState = ERecording;
}
EXPORT_C void RMMFDevSoundProxy::PlayData()
{
__ASSERT_ALWAYS(iState == EPlaying, Panic(EMMFDevSoundProxyPlayDataWithoutInitialize));
TMMFDevSoundProxyHwBuf set;
set.iLastBuffer = iBuffer->LastBuffer();
TMMFDevSoundProxyHwBufPckg pckg(set);
SendReceive(EMMFDevSoundProxyPlayData, pckg, iBuffer->Data());
}
EXPORT_C void RMMFDevSoundProxy::RecordData()
{
__ASSERT_ALWAYS(iState == ERecording, Panic(EMMFDevSoundProxyRecordDataWithoutInitialize));
SendReceive(EMMFDevSoundProxyRecordData);
}
EXPORT_C void RMMFDevSoundProxy::Stop()
{
SendReceive(EMMFDevSoundProxyStop);
iState = EIdle;
}
EXPORT_C void RMMFDevSoundProxy::Pause()
{
SendReceive(EMMFDevSoundProxyPause);
}
EXPORT_C void RMMFDevSoundProxy::PlayToneL(TInt aFrequency, const TTimeIntervalMicroSeconds& aDuration)
{
TMMFDevSoundProxySettings set;
set.iFrequencyOne = aFrequency;
set.iDuration = aDuration;
TMMFDevSoundProxySettingsPckg pckg(set);
User::LeaveIfError(SendReceive(EMMFDevSoundProxyPlayTone, pckg));
}
EXPORT_C void RMMFDevSoundProxy::PlayDualToneL(TInt aFrequencyOne, TInt aFrequencyTwo, const TTimeIntervalMicroSeconds& aDuration)
{
TMMFDevSoundProxySettings set;
set.iFrequencyOne = aFrequencyOne;
set.iFrequencyTwo = aFrequencyTwo;
set.iDuration = aDuration;
TMMFDevSoundProxySettingsPckg pckg(set);
User::LeaveIfError(SendReceive(EMMFDevSoundProxyPlayDualTone, pckg));
}
EXPORT_C void RMMFDevSoundProxy::PlayDTMFStringL(const TDesC& aDTMFString)
{
User::LeaveIfError(SendReceive(EMMFDevSoundProxyPlayDTMFString, aDTMFString));
}
EXPORT_C void RMMFDevSoundProxy::PlayToneSequenceL(const TDesC8& aData)
{
User::LeaveIfError(SendReceive(EMMFDevSoundProxyPlayToneSequence, aData));
}
EXPORT_C void RMMFDevSoundProxy::PlayFixedSequenceL(TInt aSequenceNumber)
{
TPckgBuf<TInt> seqNum(aSequenceNumber);
User::LeaveIfError(SendReceive(EMMFDevSoundProxyPlayFixedSequence, seqNum));
}
EXPORT_C void RMMFDevSoundProxy::SetDTMFLengths(TTimeIntervalMicroSeconds32& aToneOnLength,
TTimeIntervalMicroSeconds32& aToneOffLength,
TTimeIntervalMicroSeconds32& aPauseLength)
{
TMMFDevSoundProxySettings set;
set.iToneOnLength = aToneOnLength;
set.iToneOffLength = aToneOffLength;
set.iPauseLength = aPauseLength;
TMMFDevSoundProxySettingsPckg pckg(set);
SendReceive(EMMFDevSoundProxySetDTMFLengths, pckg);
}
EXPORT_C void RMMFDevSoundProxy::SetVolumeRamp(const TTimeIntervalMicroSeconds& aRampDuration)
{
TMMFDevSoundProxySettings set;
set.iDuration = aRampDuration;
TMMFDevSoundProxySettingsPckg pckg(set);
SendReceive(EMMFDevSoundProxySetVolumeRamp, pckg);
}
EXPORT_C void RMMFDevSoundProxy::GetSupportedInputDataTypesL(RArray<TFourCC>& aSupportedDataTypes, const TMMFPrioritySettings& aPrioritySettings)
{
aSupportedDataTypes.Reset();
TMMFPrioritySettings prioritySet = aPrioritySettings;
TMMFPrioritySettingsPckg pckg(prioritySet);
TPckgBuf<TInt> numberOfElementsPckg;
User::LeaveIfError(SendReceiveResult(EMMFDevSoundProxyGetSupportedInputDataTypes, pckg, KNullDesC8, numberOfElementsPckg));
HBufC8* buf = HBufC8::NewLC(numberOfElementsPckg()*sizeof(TFourCC));
TPtr8 ptr = buf->Des();
User::LeaveIfError(SendReceiveResult(EMMFDevSoundProxyCopyFourCCArrayData,KNullDesC8,KNullDesC8,ptr));
RDesReadStream stream(ptr);
CleanupClosePushL(stream);
for (TInt i=0; i<numberOfElementsPckg(); i++)
{
TInt err = aSupportedDataTypes.Append(stream.ReadInt32L());
if (err)
{//note we don't destroy array because we don't own it
//but we do reset it as it is incomplete
aSupportedDataTypes.Reset();
User::Leave(err);
}
}
CleanupStack::PopAndDestroy(2, buf);//stream, buf
}
EXPORT_C void RMMFDevSoundProxy::GetSupportedOutputDataTypesL(RArray<TFourCC>& aSupportedDataTypes, const TMMFPrioritySettings& aPrioritySettings)
{
aSupportedDataTypes.Reset();
TMMFPrioritySettings prioritySet = aPrioritySettings;
TMMFPrioritySettingsPckg pckg(prioritySet);
TPckgBuf<TInt> numberOfElementsPckg;
User::LeaveIfError(SendReceiveResult(EMMFDevSoundProxyGetSupportedOutputDataTypes, pckg, KNullDesC8, numberOfElementsPckg));
HBufC8* buf = HBufC8::NewLC(numberOfElementsPckg()*sizeof(TFourCC));
TPtr8 ptr = buf->Des();
User::LeaveIfError(SendReceiveResult(EMMFDevSoundProxyCopyFourCCArrayData,KNullDesC8,KNullDesC8,ptr));
RDesReadStream stream(ptr);
CleanupClosePushL(stream);
for (TInt i=0; i<numberOfElementsPckg(); i++)
{
TInt err = aSupportedDataTypes.Append(stream.ReadInt32L());
if (err)
{//note we don't destroy array because we don't own it
//but we do reset it as it is incomplete
aSupportedDataTypes.Reset();
User::Leave(err);
}
}
CleanupStack::PopAndDestroy(2, buf);//stream, buf
}
EXPORT_C TInt RMMFDevSoundProxy::SamplesRecorded()
{
TPckgBuf<TInt> numSamples;
SendReceiveResult(EMMFDevSoundProxySamplesRecorded, KNullDesC8, KNullDesC8, numSamples);
return numSamples();
}
EXPORT_C TInt RMMFDevSoundProxy::SamplesPlayed()
{
TPckgBuf<TInt> numSamples;
SendReceiveResult(EMMFDevSoundProxySamplesPlayed, KNullDesC8, KNullDesC8, numSamples);
return numSamples();
}
EXPORT_C void RMMFDevSoundProxy::SetToneRepeats(TInt aRepeatCount, const TTimeIntervalMicroSeconds& aRepeatTrailingSilence)
{
TPckgBuf<TInt> countRepeat(aRepeatCount);
TPckgBuf<TTimeIntervalMicroSeconds> repeatTS(aRepeatTrailingSilence);
SendReceive(EMMFDevSoundProxySetToneRepeats, countRepeat, repeatTS);
}
EXPORT_C void RMMFDevSoundProxy::SetPrioritySettings(const TMMFPrioritySettings& aPrioritySettings)
{
TPckgBuf<TMMFPrioritySettings> prioritySet(aPrioritySettings);
SendReceive(EMMFDevSoundProxySetPrioritySettings, prioritySet);
}
EXPORT_C const TDesC& RMMFDevSoundProxy::FixedSequenceName(TInt aSequenceNumber)
{
TPckgBuf<TInt> seqNum(aSequenceNumber);
TPtr SeqNamePtr = iSeqName->Des();
SeqNamePtr.FillZ();
SendReceiveResult(EMMFDevSoundProxyFixedSequenceName, seqNum, KNullDesC8, SeqNamePtr);
return *iSeqName;
}
EXPORT_C TAny* RMMFDevSoundProxy::CustomInterface(TUid /*aInterfaceId*/)
{
// No custom interfaces are supported at the moment so return NULL.
//TO DO
return NULL;
}
EXPORT_C TInt RMMFDevSoundProxy::FixedSequenceCount()
{
TPckgBuf<TInt> fixSeqCountPckg;
SendReceiveResult(EMMFDevSoundProxyFixedSequenceCount, fixSeqCountPckg);
return fixSeqCountPckg();
}
EXPORT_C TInt RMMFDevSoundProxy::BufferToBeFilledData(TMMFDevSoundProxyHwBufPckg& aSetPckg)
{
// Note that there will only ever be one of these requests outstanding per session
return SendReceiveResult(EMMFDevSoundProxyBTBFData, aSetPckg);
}
EXPORT_C TInt RMMFDevSoundProxy::BufferToBeEmptiedData(TMMFDevSoundProxyHwBufPckg& aSetPckg)
{
// Note that there will only ever be one of these requests outstanding per session
return SendReceiveResult(EMMFDevSoundProxyBTBEData, aSetPckg);
}
EXPORT_C void RMMFDevSoundProxy::SetBuffer(CMMFDataBuffer* aBuffer)
{
if(iBuffer)
{
delete iBuffer;
}
iBuffer = aBuffer;
}
EXPORT_C TInt RMMFDevSoundProxy::GetRecordedBufferL(CMMFDataBuffer& aBuffer)
{
return SendReceiveResult(EMMFDevSoundProxyGetRecordedBuffer, aBuffer.Data());
}
EXPORT_C TInt RMMFDevSoundProxy::RegisterAsClient(TUid aEventType, const TDesC8& aNotificationRegistrationData)
{
TMMFDevSoundProxySettings set;
set.iNotificationEventUid = aEventType;
TMMFDevSoundProxySettingsPckg pckg(set);
return SendReceive(EMMFDevSoundProxyRequestResourceNotification, pckg, aNotificationRegistrationData);
}
EXPORT_C TInt RMMFDevSoundProxy::CancelRegisterAsClient(TUid aEventType)
{
TMMFDevSoundProxySettings set;
set.iNotificationEventUid = aEventType;
TMMFDevSoundProxySettingsPckg pckg(set);
return SendReceiveResult(EMMFDevSoundProxyCancelRequestResourceNotification, pckg);
}
EXPORT_C TInt RMMFDevSoundProxy::GetResourceNotificationData(TUid aEventType, TDes8& aNotificationData)
{
TMMFDevSoundProxySettings set;
set.iNotificationEventUid = aEventType;
TMMFDevSoundProxySettingsPckg pckg(set);
return SendReceiveResult(EMMFDevSoundProxyGetResourceNotificationData, pckg,KNullDesC8,aNotificationData);
}
EXPORT_C TInt RMMFDevSoundProxy::WillResumePlay()
{
return SendReceive(EMMFDevSoundProxyWillResumePlay);
}
EXPORT_C TInt RMMFDevSoundProxy::EmptyBuffers()
{
return SendReceive(EMMFDevSoundProxyEmptyBuffers);
}
EXPORT_C TInt RMMFDevSoundProxy::GetTimePlayed(TTimeIntervalMicroSeconds& aTime)
{
TTimeIntervalMicroSeconds time(0);
TPckgBuf<TTimeIntervalMicroSeconds> timePckg(time);
TInt err = SendReceiveResult(EMMFDevSoundProxyGetTimePlayed, KNullDesC8, KNullDesC8, timePckg);
if(err==KErrNone)
{
aTime = timePckg();
}
return err;
}
// implementation of a simple CustomCommand() scheme
EXPORT_C TInt RMMFDevSoundProxy::SyncCustomCommand(TUid aUid, const TDesC8& aParam1, const TDesC8& aParam2, TDes8* aOutParam)
{
// the UID of the custom command is passed as an integer so as maintain consistency with the async methods below
TInt command = aUid.iUid;
if (aOutParam==NULL)
{
return SendReceive(EMMFDevSoundProxySyncCustomCommand, command, aParam1, aParam2);
}
else
{
return SendReceiveResult(EMMFDevSoundProxySyncCustomCommandResult, command, aParam1, aParam2, *aOutParam);
}
}
EXPORT_C void RMMFDevSoundProxy::AsyncCustomCommand(TUid aUid, TRequestStatus& aStatus, const TDesC8& aParam1, const TDesC8& aParam2, TDes8* aOutParam)
{
// this seemingly only allows 1 simultaneous async call. Need an array of TRequestStatus for more than one call.
// the UID of the custom command is passed as an integer so as to prevent the need of a consistent UID array.
TInt command = aUid.iUid;
if (aOutParam==NULL)
{
SendReceive(EMMFDevSoundProxyAsyncCustomCommand, command, aParam1, aParam2, aStatus);
}
else
{
SendReceiveResult(EMMFDevSoundProxyAsyncCustomCommandResult, command, aParam1, aParam2, *aOutParam, aStatus);
}
}
EXPORT_C TInt RMMFDevSoundProxy::SetClientThreadInfo(TThreadId& aTid)
{
TPckgBuf<TThreadId> threadId(aTid);
return SendReceive(EMMFDevSoundProxySetClientThreadInfo, threadId);
}