sl@0: // Copyright (c) 2006-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 "mmrcclientimplementation.h"
sl@0: #include "mmrcclientmsgqueuehandler.h"
sl@0: #include "multimediaresourcecontrolobserver.h"
sl@0: #include "audiocontext.h"
sl@0: 
sl@0: #include <a3f/maudiocontextobserver.h>
sl@0: 
sl@0: 
sl@0: const TInt KMsgQueueSlots = 8;
sl@0: 
sl@0:  
sl@0: /**
sl@0:  */
sl@0: CMMRCClientImplementation::CMMRCClientImplementation(MMultimediaResourceControlObserver& aCallback) 
sl@0: : iObserver(aCallback)
sl@0: 	{
sl@0: 	TRACE_CREATE();
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::CMMRCClientImplementation *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  */
sl@0: CMMRCClientImplementation::~CMMRCClientImplementation()
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::~CMMRCClientImplementation *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 
sl@0: 	if(iMsgClientQueueHandler)
sl@0: 		{
sl@0: 		delete iMsgClientQueueHandler;
sl@0: 		}
sl@0: 	iMsgQueue.Close();
sl@0: 
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  */
sl@0: CMMRCClientImplementation* CMMRCClientImplementation::NewL(MMultimediaResourceControlObserver& aCallback)
sl@0: 	{
sl@0: 	DP_STATIC_CONTEXT(----> CMMRCClientImplementation::NewL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	CMMRCClientImplementation* self = new (ELeave) CMMRCClientImplementation(aCallback);
sl@0: 	CleanupStack::PushL (self);
sl@0: 	self->ConstructL ();
sl@0: 	CleanupStack::Pop (self);
sl@0: 
sl@0: 	DP0_RET(self, "0x%x");
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  */
sl@0: void CMMRCClientImplementation::ConstructL()
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::ConstructL *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	TInt error = iMMRCClientSession.Open (iObserver);
sl@0: 	if ( KErrNotFound == error)
sl@0: 		{
sl@0: 		//The server is not found, create it
sl@0: 		error = iMMRCClientSession.StartServer ();
sl@0: 		User::LeaveIfError (error);
sl@0: 
sl@0: 		//Try again to create a connection to it
sl@0: 		error = iMMRCClientSession.Open (iObserver);
sl@0: 		#ifdef _DEBUG	
sl@0: 		if(error != KErrNone)
sl@0: 			{
sl@0: 			RDebug::Print(_L("!!!!CMMRCClientImplementation::ConstructL - Open session 2 - error = %d"), error);
sl@0: 			}
sl@0: 		#endif
sl@0: 		User::LeaveIfError (error);
sl@0: 		}
sl@0: 	#ifdef _DEBUG	
sl@0: 	if(error != KErrNone)
sl@0: 		{
sl@0: 		RDebug::Print(_L("!!!!CMMRCClientImplementation::ConstructL - Open session 1 - error = %d"), error);
sl@0: 		}
sl@0: 	#endif
sl@0: 	User::LeaveIfError (error);
sl@0: 
sl@0: 	//Create an un-named msg queue, a handle is needed to connect to it.
sl@0: 	error = iMsgQueue.CreateGlobal (KNullDesC, KMsgQueueSlots,	EOwnerProcess);
sl@0: 	#ifdef _DEBUG	
sl@0: 	if(error != KErrNone)
sl@0: 		{
sl@0: 		RDebug::Print(_L("!!!!CMMRCClientImplementation::ConstructL - CreateGlobal - error = %d"), error);
sl@0: 		}
sl@0: 	#endif
sl@0: 	User::LeaveIfError (error);
sl@0: 	iMsgClientQueueHandler = CMMRCClientMsgQueueHandler::NewL (iMsgQueue, *this);
sl@0: 
sl@0: 	//Forward the message queue handle to the server, which will connect to it.
sl@0: 	iMMRCClientSession.InitializeServerL(iMsgQueue);
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: /**
sl@0:  */
sl@0: TUint64 CMMRCClientImplementation::LogOn(TProcessId aProcessId)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::LogOn *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	TUint64 contextId = iMMRCClientSession.LogOn(aProcessId);
sl@0: 	
sl@0: 	DP0_RET(contextId, "contextId = %d");
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  */
sl@0: void CMMRCClientImplementation::Close()
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::Close *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 
sl@0: 	iMMRCClientSession.Close ();
sl@0: 
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  */
sl@0: TInt CMMRCClientImplementation::SendResourceRequest(MLogicalChain* aLogicalChainLastCommited, MLogicalChain* aLogicalChainRequested, CAudioContext* aContext)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::SendResourceRequest *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	TInt err = iMMRCClientSession.SendResourceRequest(aLogicalChainLastCommited, aLogicalChainRequested, aContext);
sl@0: 	
sl@0: 	DP0_RET(err, "err = %d");
sl@0: 	}
sl@0: 
sl@0: /**y
sl@0:  */
sl@0: void CMMRCClientImplementation::HandleMessage(TMMRCQueueItem& aMessage)
sl@0: 	{
sl@0:  	DP_CONTEXT(----> CMMRCClientImplementation::HandleMessage *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	#ifdef _DEBUG	
sl@0: 		RDebug::Print(_L("RMMRCClientSession::ResourceRequestResponseL aMessage.iRequestType = %d, aMessage.iResult = %d, aMessage.iErrorCode = %d"), aMessage.iRequestType, aMessage.iResult, aMessage.iErrorCode);
sl@0: 	#endif
sl@0: 	
sl@0: 	switch(aMessage.iRequestType)
sl@0: 	{
sl@0: 	
sl@0: 	case EMMRCRequestCommitUpdate:
sl@0: 		{
sl@0: 		// Ignore this, now this will come directly from adaptation
sl@0: 		// iObserver.ReceiveResourceUpdate(aMessage.iData, aMessage.iErrorCode);
sl@0: 		}
sl@0: 		break;
sl@0: 
sl@0: 	case EMMRCRequestCommitResponse:
sl@0: 		{
sl@0: 		// This would remain coming throug MMRC to update client side
sl@0: 		iMMRCClientSession.ResourceRequestResponse(aMessage.iData, aMessage.iResult, aMessage.iErrorCode);
sl@0: 		}
sl@0: 		break;
sl@0: 
sl@0: 	case EMMRCRequestResourceUnallocated:
sl@0: 		{
sl@0: 		// Notification used for APR.
sl@0: 		iObserver.CanResume();
sl@0: 		}
sl@0: 		break;
sl@0: 		
sl@0: 	default: //unknown message
sl@0: 		#ifdef _DEBUG	
sl@0: 			ASSERT(0);
sl@0: 			RDebug::Print(_L("!!!!CMMRCClientImplementation::HandleMessage - Unknown message"));
sl@0: 		#endif
sl@0: 		break;
sl@0: 	}
sl@0: 	
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  */
sl@0: TInt CMMRCClientImplementation::RegisterAsClient(TUid aEventType, const TDesC8& aNotificationRegistrationData)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::RegisterAsClient *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 	
sl@0: 	TInt err = iMMRCClientSession.RegisterAsClient(aEventType, aNotificationRegistrationData);
sl@0: 
sl@0: 	DP0_RET(err, "err = %d");
sl@0: 	}
sl@0: 	
sl@0: 	
sl@0: /**
sl@0:  */
sl@0: TInt CMMRCClientImplementation::CancelRegisterAsClient(TUid aEventType)
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::CancelRegisterAsClient *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 
sl@0: 	TInt err = iMMRCClientSession.CancelRegisterAsClient(aEventType);
sl@0: 
sl@0: 	DP0_RET(err, "err = %d");
sl@0: 	}
sl@0: 	
sl@0: 
sl@0: /**
sl@0:  */
sl@0: TInt CMMRCClientImplementation::WillResumePlay()
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::WillResumePlay *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 
sl@0: 	TInt err = iMMRCClientSession.WillResumePlay();
sl@0: 
sl@0: 	DP0_RET(err, "err = %d");
sl@0: 	}
sl@0: 	
sl@0: void CMMRCClientImplementation::ResetMessages()
sl@0: 	{
sl@0: 	DP_CONTEXT(----> CMMRCClientImplementation::ResetMessages *CD1*, CtxDevSound, DPLOCAL);
sl@0: 	DP_IN();
sl@0: 
sl@0: 	iMMRCClientSession.ResetMessages();
sl@0: 
sl@0: 	DP_OUT();
sl@0: 	}
sl@0: //EOF