// 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 "mmrcclientimplementation.h"
#include "mmrcclientmsgqueuehandler.h"
#include "multimediaresourcecontrolobserver.h"
#include "audiocontext.h"

#include <a3f/maudiocontextobserver.h>


const TInt KMsgQueueSlots = 8;

 
/**
 */
CMMRCClientImplementation::CMMRCClientImplementation(MMultimediaResourceControlObserver& aCallback) 
: iObserver(aCallback)
	{
	TRACE_CREATE();
	DP_CONTEXT(----> CMMRCClientImplementation::CMMRCClientImplementation *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	DP_OUT();
	}

/**
 */
CMMRCClientImplementation::~CMMRCClientImplementation()
	{
	DP_CONTEXT(----> CMMRCClientImplementation::~CMMRCClientImplementation *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();

	if(iMsgClientQueueHandler)
		{
		delete iMsgClientQueueHandler;
		}
	iMsgQueue.Close();

	DP_OUT();
	}

/**
 */
CMMRCClientImplementation* CMMRCClientImplementation::NewL(MMultimediaResourceControlObserver& aCallback)
	{
	DP_STATIC_CONTEXT(----> CMMRCClientImplementation::NewL *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	CMMRCClientImplementation* self = new (ELeave) CMMRCClientImplementation(aCallback);
	CleanupStack::PushL (self);
	self->ConstructL ();
	CleanupStack::Pop (self);

	DP0_RET(self, "0x%x");
	}

/**
 */
void CMMRCClientImplementation::ConstructL()
	{
	DP_CONTEXT(----> CMMRCClientImplementation::ConstructL *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	TInt error = iMMRCClientSession.Open (iObserver);
	if ( KErrNotFound == error)
		{
		//The server is not found, create it
		error = iMMRCClientSession.StartServer ();
		User::LeaveIfError (error);

		//Try again to create a connection to it
		error = iMMRCClientSession.Open (iObserver);
		#ifdef _DEBUG	
		if(error != KErrNone)
			{
			RDebug::Print(_L("!!!!CMMRCClientImplementation::ConstructL - Open session 2 - error = %d"), error);
			}
		#endif
		User::LeaveIfError (error);
		}
	#ifdef _DEBUG	
	if(error != KErrNone)
		{
		RDebug::Print(_L("!!!!CMMRCClientImplementation::ConstructL - Open session 1 - error = %d"), error);
		}
	#endif
	User::LeaveIfError (error);

	//Create an un-named msg queue, a handle is needed to connect to it.
	error = iMsgQueue.CreateGlobal (KNullDesC, KMsgQueueSlots,	EOwnerProcess);
	#ifdef _DEBUG	
	if(error != KErrNone)
		{
		RDebug::Print(_L("!!!!CMMRCClientImplementation::ConstructL - CreateGlobal - error = %d"), error);
		}
	#endif
	User::LeaveIfError (error);
	iMsgClientQueueHandler = CMMRCClientMsgQueueHandler::NewL (iMsgQueue, *this);

	//Forward the message queue handle to the server, which will connect to it.
	iMMRCClientSession.InitializeServerL(iMsgQueue);
	
	DP_OUT();
	}
/**
 */
TUint64 CMMRCClientImplementation::LogOn(TProcessId aProcessId)
	{
	DP_CONTEXT(----> CMMRCClientImplementation::LogOn *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	TUint64 contextId = iMMRCClientSession.LogOn(aProcessId);
	
	DP0_RET(contextId, "contextId = %d");
	}

/**
 */
void CMMRCClientImplementation::Close()
	{
	DP_CONTEXT(----> CMMRCClientImplementation::Close *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();

	iMMRCClientSession.Close ();

	DP_OUT();
	}

/**
 */
TInt CMMRCClientImplementation::SendResourceRequest(MLogicalChain* aLogicalChainLastCommited, MLogicalChain* aLogicalChainRequested, CAudioContext* aContext)
	{
	DP_CONTEXT(----> CMMRCClientImplementation::SendResourceRequest *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	TInt err = iMMRCClientSession.SendResourceRequest(aLogicalChainLastCommited, aLogicalChainRequested, aContext);
	
	DP0_RET(err, "err = %d");
	}

/**y
 */
void CMMRCClientImplementation::HandleMessage(TMMRCQueueItem& aMessage)
	{
 	DP_CONTEXT(----> CMMRCClientImplementation::HandleMessage *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	#ifdef _DEBUG	
		RDebug::Print(_L("RMMRCClientSession::ResourceRequestResponseL aMessage.iRequestType = %d, aMessage.iResult = %d, aMessage.iErrorCode = %d"), aMessage.iRequestType, aMessage.iResult, aMessage.iErrorCode);
	#endif
	
	switch(aMessage.iRequestType)
	{
	
	case EMMRCRequestCommitUpdate:
		{
		// Ignore this, now this will come directly from adaptation
		// iObserver.ReceiveResourceUpdate(aMessage.iData, aMessage.iErrorCode);
		}
		break;

	case EMMRCRequestCommitResponse:
		{
		// This would remain coming throug MMRC to update client side
		iMMRCClientSession.ResourceRequestResponse(aMessage.iData, aMessage.iResult, aMessage.iErrorCode);
		}
		break;

	case EMMRCRequestResourceUnallocated:
		{
		// Notification used for APR.
		iObserver.CanResume();
		}
		break;
		
	default: //unknown message
		#ifdef _DEBUG	
			ASSERT(0);
			RDebug::Print(_L("!!!!CMMRCClientImplementation::HandleMessage - Unknown message"));
		#endif
		break;
	}
	
	DP_OUT();
	}

/**
 */
TInt CMMRCClientImplementation::RegisterAsClient(TUid aEventType, const TDesC8& aNotificationRegistrationData)
	{
	DP_CONTEXT(----> CMMRCClientImplementation::RegisterAsClient *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	TInt err = iMMRCClientSession.RegisterAsClient(aEventType, aNotificationRegistrationData);

	DP0_RET(err, "err = %d");
	}
	
	
/**
 */
TInt CMMRCClientImplementation::CancelRegisterAsClient(TUid aEventType)
	{
	DP_CONTEXT(----> CMMRCClientImplementation::CancelRegisterAsClient *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();

	TInt err = iMMRCClientSession.CancelRegisterAsClient(aEventType);

	DP0_RET(err, "err = %d");
	}
	

/**
 */
TInt CMMRCClientImplementation::WillResumePlay()
	{
	DP_CONTEXT(----> CMMRCClientImplementation::WillResumePlay *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();

	TInt err = iMMRCClientSession.WillResumePlay();

	DP0_RET(err, "err = %d");
	}
	
void CMMRCClientImplementation::ResetMessages()
	{
	DP_CONTEXT(----> CMMRCClientImplementation::ResetMessages *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();

	iMMRCClientSession.ResetMessages();

	DP_OUT();
	}
//EOF