sl@0: // Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include <ecom/implementationproxy.h>
sl@0: #include <ecom/implementationproxy.h>
sl@0: #include <ecom/ecom.h>
sl@0: #include <s32mem.h>
sl@0: 
sl@0: #include "aacdecoderconfigci.h"
sl@0: 
sl@0: 
sl@0: // MUX //
sl@0: 
sl@0: TInt CMMFAacDecoderConfigMux::OpenInterface(TUid /*aInterfaceId*/)
sl@0: 	{
sl@0: 	// attempt to open the interface link with the
sl@0: 	// remote slave device
sl@0: 	iRemoteHandle = -1;
sl@0: 	TUid slaveId = {KMmfUidCustomInterfaceAacDecoderConfigDeMux};
sl@0: 
sl@0: 	TInt handle = iUtility->OpenSlave(slaveId, KNullDesC8);
sl@0: 	if (handle >= 0)
sl@0: 		{
sl@0: 		iRemoteHandle = handle;
sl@0: 		}
sl@0: 
sl@0: 	return iRemoteHandle;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigMux::Release()
sl@0: 	{
sl@0: 	// close the slave device if it exists
sl@0: 	if (iRemoteHandle > 0)
sl@0: 		{
sl@0: 		// we assume the slave is closed correctly
sl@0: 		iUtility->CloseSlave(iRemoteHandle);
sl@0: 		}
sl@0: 
sl@0: 	TUid key = iKey;
sl@0: 	delete this;
sl@0: 
sl@0: 	// tell ECom to destroy us
sl@0: 	REComSession::DestroyedImplementation(key);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigMux::PassDestructorKey(TUid aDestructorKey)
sl@0: 	{
sl@0: 	// store the destructor key
sl@0: 	iKey = aDestructorKey;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigMux::CompleteConstructL(MMMFDevSoundCustomInterfaceMuxUtility* aCustomUtility)
sl@0: 	{
sl@0: 	// store a pointer to the utility
sl@0: 	iUtility = aCustomUtility;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: MMMFDevSoundCustomInterfaceMuxPlugin* CMMFAacDecoderConfigMux::NewL()
sl@0: 	{
sl@0: 	CMMFAacDecoderConfigMux* self = new (ELeave) CMMFAacDecoderConfigMux;
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TAny* CMMFAacDecoderConfigMux::CustomInterface(TUid /*aInterfaceId*/)
sl@0: 	{
sl@0: 	MAacDecoderConfig* interface = this;
sl@0: 	return interface;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CMMFAacDecoderConfigMux::CMMFAacDecoderConfigMux() :
sl@0: iRemoteHandle(-1)
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CMMFAacDecoderConfigMux::~CMMFAacDecoderConfigMux()
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: 
sl@0: // from MAacDecoderConfig
sl@0: TInt CMMFAacDecoderConfigMux::SetAudioConfig(TAudioConfig& aAudioConfig)
sl@0: 	{
sl@0: 	TInt result = -1;
sl@0: 
sl@0: 	if (iRemoteHandle > 0)
sl@0: 		{
sl@0: 		// send the status in the sync command
sl@0: 		TPckgBuf<TAudioConfig> audioConfig(aAudioConfig);
sl@0: 
sl@0: 		// any return code other than zero is an error
sl@0: 		result = iUtility->SendSlaveSyncCommand(iRemoteHandle,
sl@0: 												EMMFDevSoundCIAacDecoderConfigSetAudioConfig,
sl@0: 												audioConfig);
sl@0: 		}
sl@0: 
sl@0: 	return result;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: // from MAacDecoderConfig
sl@0: TInt CMMFAacDecoderConfigMux::GetSupportedAudioConfigs(RArray<TAudioConfig>& aSupportedAudioConfigs)
sl@0: 	{
sl@0: 	TInt result = KErrNone;
sl@0: 
sl@0: 	if (iRemoteHandle == -1)
sl@0: 		{
sl@0: 		return KErrBadHandle;
sl@0: 		}
sl@0: 
sl@0: 	// first clear out the array
sl@0: 	aSupportedAudioConfigs.Reset();
sl@0: 
sl@0: 	// now fetch the count from the server
sl@0: 	TInt count = -1;
sl@0: 	count = iUtility->SendSlaveSyncCommand(iRemoteHandle,
sl@0: 										   EMMFDevSoundCIAacDecoderConfigGetSupportedAudioConfig,
sl@0: 										   KNullDesC8);
sl@0: 
sl@0: 	// if count is negative then the server side left with an error
sl@0: 	if (count < 0)
sl@0: 		{
sl@0: 		result = KErrNotReady;
sl@0: 		}
sl@0: 
sl@0: 	// no point getting the data if the count is zero
sl@0: 	if ( (count != 0) && (result == KErrNone) )
sl@0: 		{
sl@0: 		// allocate a temporary buffer to hold the audio configuration
sl@0: 		HBufC8* buf = NULL;
sl@0: 		TRAP(result, buf = HBufC8::NewL(count * sizeof(TAudioConfig)));
sl@0: 
sl@0: 		if (result != KErrNone)
sl@0: 			{
sl@0: 			return result;
sl@0: 			}
sl@0: 
sl@0: 		TPtr8 ptr = buf->Des();
sl@0: 
sl@0: 		// fetch the audio configurations - but send over the received count to be sure
sl@0: 		TPckgBuf<TInt> countBuf(count);
sl@0: 		iUtility->SendSlaveSyncCommandResult(iRemoteHandle,
sl@0: 											 EMMFDevSoundCIAacDecoderConfigGetSupportedAudioConfigArray,
sl@0: 											 countBuf,
sl@0: 											 ptr);
sl@0: 
sl@0: 		if (result != KErrNone)
sl@0: 			{
sl@0: 			return result;
sl@0: 			}
sl@0: 
sl@0: 		// stream data into the pointer
sl@0: 		RDesReadStream stream(ptr);
sl@0: 
sl@0: 		TInt err = KErrNone;
sl@0: 		for (TInt i = 0; i < count; i++)
sl@0: 			{
sl@0: 			TAudioConfig audioConfig;
sl@0: 
sl@0: 			TRAP(result, audioConfig.iAudioObjectType = static_cast<TAudioConfig::TAudioObjectType>(stream.ReadInt32L());
sl@0: 
sl@0: 			err = aSupportedAudioConfigs.Append(audioConfig));
sl@0: 
sl@0: 			if ( (err != KErrNone) || (result != KErrNone) )
sl@0: 				{
sl@0: 				// note we don't destroy array because we don't own it
sl@0: 				// but we do reset it if it is incomplete
sl@0: 				aSupportedAudioConfigs.Reset();
sl@0: 				result = KErrCorrupt;
sl@0: 				}
sl@0: 			}
sl@0: 
sl@0: 		stream.Close();
sl@0: 		stream.Release();
sl@0: 		delete buf;
sl@0: 		}
sl@0: 
sl@0: 	return result;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: 
sl@0: // DEMUX //
sl@0: 
sl@0: TInt CMMFAacDecoderConfigDeMux::OpenInterface(TUid /*aInterfaceId*/)
sl@0: 	{
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigDeMux::Release()
sl@0: 	{
sl@0: 	TUid key = iKey;
sl@0: 
sl@0: 	delete this;
sl@0: 
sl@0: 	// tell ECom to destroy us
sl@0: 	REComSession::DestroyedImplementation(key);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigDeMux::PassDestructorKey(TUid aDestructorKey)
sl@0: 	{
sl@0: 	// store the destructor key
sl@0: 	iKey = aDestructorKey;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigDeMux::SetInterfaceTarget(MMMFDevSoundCustomInterfaceTarget* aTarget)
sl@0: 	{
sl@0: 	iTarget = aTarget;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigDeMux::CompleteConstructL(MMMFDevSoundCustomInterfaceDeMuxUtility* aCustomUtility)
sl@0: 	{
sl@0: 	// store a pointer to the utility
sl@0: 	iUtility = aCustomUtility;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigDeMux::RefreshL()
sl@0: 	{
sl@0: 	// refetch the aac decoder config custom interface if we already have a target
sl@0: 	if (iTarget)
sl@0: 		{
sl@0: 		iInterfaceAacDecoderConfig = static_cast <MAacDecoderConfig*> (iTarget->CustomInterface(KUidAacDecoderConfig));
sl@0: 
sl@0: 		if (!iInterfaceAacDecoderConfig)
sl@0: 			{
sl@0: 			iInterfaceAacDecoderConfig = NULL;
sl@0: 			User::Leave(KErrNotSupported);
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: 
sl@0: MMMFDevSoundCustomInterfaceDeMuxPlugin* CMMFAacDecoderConfigDeMux::NewL()
sl@0: 	{
sl@0: 	CMMFAacDecoderConfigDeMux* self = new (ELeave) CMMFAacDecoderConfigDeMux;
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CMMFAacDecoderConfigDeMux::CMMFAacDecoderConfigDeMux()
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CMMFAacDecoderConfigDeMux::~CMMFAacDecoderConfigDeMux()
sl@0: 	{
sl@0: 	iSupportedAudioConfigs.Reset();
sl@0: 	iSupportedAudioConfigs.Close();
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt CMMFAacDecoderConfigDeMux::DoOpenSlaveL(TUid /*aInterface*/, const TDesC8& /*aPackageBuf*/)
sl@0: 	{
sl@0: 	// fetch the Aac Decoder Config Hw Device custom interface
sl@0: 	iInterfaceAacDecoderConfig = static_cast<MAacDecoderConfig*> (iTarget->CustomInterface(KUidAacDecoderConfig)); 
sl@0: 
sl@0: 	if (!iInterfaceAacDecoderConfig)
sl@0: 		{
sl@0: 		iInterfaceAacDecoderConfig = NULL;
sl@0: 		User::Leave(KErrNotSupported);
sl@0: 		}
sl@0: 
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigDeMux::DoCloseSlaveL(TInt /*aHandle*/)
sl@0: 	{
sl@0: 	// nothing to do
sl@0: 	}
sl@0: 
sl@0: 
sl@0: // original RMessage is supplied so that remote demux plugin can extract necessary details
sl@0: // using DeMux utility
sl@0: TInt CMMFAacDecoderConfigDeMux::DoSendSlaveSyncCommandL(const RMmfIpcMessage& aMessage)
sl@0: 	{
sl@0: 	TMMFDevSoundCIMessageData data;
sl@0: 	TInt result = KErrNotSupported;
sl@0: 
sl@0: 	// decode message
sl@0: 	iUtility->GetSyncMessageDataL(aMessage, data);
sl@0: 
sl@0: 	switch (data.iCommand)
sl@0: 		{
sl@0: 		case EMMFDevSoundCIAacDecoderConfigSetAudioConfig:
sl@0: 			{
sl@0: 			TPckgBuf<MAacDecoderConfig::TAudioConfig> audioConfig; 
sl@0: 			iUtility->ReadFromInputDesL(aMessage, &audioConfig);
sl@0: 
sl@0: 			result = DoSetAudioConfigL(audioConfig());
sl@0: 
sl@0: 			break;
sl@0: 			}
sl@0: 		case EMMFDevSoundCIAacDecoderConfigGetSupportedAudioConfig:
sl@0: 			{
sl@0: 			// reset the current AudioConfig array
sl@0: 			iSupportedAudioConfigs.Reset();
sl@0: 			result = DoGetSupportedAudioConfigsL(iSupportedAudioConfigs);
sl@0: 
sl@0: 			// send back the array count
sl@0: 			TInt count = iSupportedAudioConfigs.Count();
sl@0: 			result = count;
sl@0: 
sl@0: 			break;
sl@0: 			}
sl@0: 		default:
sl@0: 			{
sl@0: 			User::Leave(KErrNotSupported);
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: 	return result;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt CMMFAacDecoderConfigDeMux::DoSendSlaveSyncCommandResultL(const RMmfIpcMessage& aMessage)
sl@0: 	{
sl@0: 	TMMFDevSoundCIMessageData data;
sl@0: 	TInt result = KErrNotSupported;
sl@0: 
sl@0: 	// decode message
sl@0: 	iUtility->GetSyncMessageDataL(aMessage, data);
sl@0: 
sl@0: 	switch (data.iCommand)
sl@0: 		{
sl@0: 		case EMMFDevSoundCIAacDecoderConfigGetSupportedAudioConfigArray:
sl@0: 			{
sl@0: 
sl@0: 			DoCopyAudioConfigsBufferToClientL(aMessage);
sl@0: 
sl@0: 			break;
sl@0: 			}
sl@0: 		default:
sl@0: 			{
sl@0: 			User::Leave(KErrNotSupported);
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: 	return result;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigDeMux::DoSendSlaveAsyncCommandL(const RMmfIpcMessage& /*aMessage*/)
sl@0: 	{
sl@0: 	// not used in this interface
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFAacDecoderConfigDeMux::DoSendSlaveAsyncCommandResultL(const RMmfIpcMessage& /*aMessage*/)
sl@0: 	{
sl@0: 	// not used in this interface
sl@0: 	}
sl@0: 
sl@0: 
sl@0: // Aac Decoder Config custom interface implementation
sl@0: TInt CMMFAacDecoderConfigDeMux::DoSetAudioConfigL(MAacDecoderConfig::TAudioConfig& aAudioConfig)
sl@0: 	{
sl@0: 	TInt result = KErrNotFound;
sl@0: 
sl@0: 	if (iInterfaceAacDecoderConfig)
sl@0: 		{
sl@0: 		result = iInterfaceAacDecoderConfig->SetAudioConfig(aAudioConfig);
sl@0: 		}
sl@0: 
sl@0: 	return result;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: // Aac Decoder Config custom interface implementation
sl@0: TInt CMMFAacDecoderConfigDeMux::DoGetSupportedAudioConfigsL(RArray<MAacDecoderConfig::TAudioConfig>& aSupportedAudioConfigs)
sl@0: 	{
sl@0: 	TInt result = KErrNotFound;
sl@0: 
sl@0: 	if (iInterfaceAacDecoderConfig)
sl@0: 		{
sl@0: 		result = iInterfaceAacDecoderConfig->GetSupportedAudioConfigs(aSupportedAudioConfigs);
sl@0: 		}
sl@0: 
sl@0: 	return result;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: // Aac Decoder Config custom interface implementation
sl@0: void CMMFAacDecoderConfigDeMux::DoCopyAudioConfigsBufferToClientL(const RMmfIpcMessage& aMessage)
sl@0: 	{
sl@0: 	if (!iInterfaceAacDecoderConfig)
sl@0: 		{
sl@0: 		User::Leave(KErrNotReady);
sl@0: 		}
sl@0: 
sl@0: 	// check our count is the same as the client's
sl@0: 	TPckgBuf<TInt> countBuffer;
sl@0: 	iUtility->ReadFromInputDesL(aMessage, &countBuffer);
sl@0: 
sl@0: 	TInt count = countBuffer();
sl@0: 	if (count != iSupportedAudioConfigs.Count())
sl@0: 		{
sl@0: 		User::Leave(KErrCorrupt);
sl@0: 		}
sl@0: 
sl@0: 	// send back the array - the client has the count already
sl@0: 	const TInt KBufExpandSize8 = 8; //two TInt's
sl@0: 	CBufFlat* dataCopyBuffer = CBufFlat::NewL(KBufExpandSize8);
sl@0: 	CleanupStack::PushL(dataCopyBuffer);
sl@0: 	RBufWriteStream stream;
sl@0: 	stream.Open(*dataCopyBuffer);
sl@0: 	CleanupClosePushL(stream);
sl@0: 
sl@0: 	for (TInt i = 0; i < count; i++)
sl@0: 		{
sl@0: 		stream.WriteInt32L(iSupportedAudioConfigs[i].iAudioObjectType);
sl@0: 		}
sl@0: 
sl@0: 	// write the data to the supplied descriptor buffer
sl@0: 	TPtr8 ptrBuf = dataCopyBuffer->Ptr(0);
sl@0: 	iUtility->WriteToOutputDesL(aMessage, ptrBuf);
sl@0: 	stream.Close();
sl@0: 
sl@0: 	CleanupStack::PopAndDestroy(2, dataCopyBuffer); // dataCopyBuffer, stream
sl@0: 	}
sl@0: 
sl@0: 
sl@0: //
sl@0: // ImplementationTable
sl@0: //
sl@0: const TImplementationProxy ImplementationTable[] = 
sl@0: 	{
sl@0: 	IMPLEMENTATION_PROXY_ENTRY(KMmfUidCustomInterfaceAacDecoderConfigMux,	CMMFAacDecoderConfigMux::NewL),
sl@0: 	IMPLEMENTATION_PROXY_ENTRY(KMmfUidCustomInterfaceAacDecoderConfigDeMux,	CMMFAacDecoderConfigDeMux::NewL),
sl@0: 	};
sl@0: 
sl@0: //
sl@0: // ImplementationGroupProxy
sl@0: //
sl@0: EXPORT_C const TImplementationProxy* ImplementationGroupProxy(TInt& aTableCount)
sl@0: 	{
sl@0: 	aTableCount = sizeof(ImplementationTable) / sizeof(TImplementationProxy);
sl@0: 
sl@0: 	return ImplementationTable;
sl@0: 	}