// 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 "mmrcclientsession.h"
#include "mmrcserverstart.h"
#include "multimediaresourcecontrolobserver.h"
#include "mmrcadaptationproxy.h"
#include "mlogicalchain.h"
#include "audiocontext.h"
/**
 * 
 */
RMMRCClientSession::RMMRCClientSession()
: iLogicalChainLastCommited(NULL),
  iLogicalChainRequested(NULL)
	{
	TRACE_CREATE();
	DP_CONTEXT(----> RMMRCClientSession::RMMRCClientSession *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	DP_OUT();
	}

/**
 * 
 */
RMMRCClientSession::~RMMRCClientSession()
	{
	DP_CONTEXT(----> RMMRCClientSession::~RMMRCClientSession *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	if(iMMRCClientSideServerRequestToAdaptationAO)
		{
		delete iMMRCClientSideServerRequestToAdaptationAO;
		iMMRCClientSideServerRequestToAdaptationAO=0;
		}

	DP_OUT();
	}


/**
// Runs client-side and starts the separate server process
*/
TInt RMMRCClientSession::StartServer()
	{
	DP_CONTEXT(----> RMMRCClientSession::StartServer *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	TInt err = KErrNone;
	err = StartMMRCServer(iServerThread);
	
	DP0_RET(err, "err = %d");
	}

/**
*/
TInt RMMRCClientSession::Open(MMultimediaResourceControlObserver& aCallback)
	{
	DP_CONTEXT(----> RMMRCClientSession::Open *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	TInt err = KErrNone;
	iObserver = &aCallback;
	
	err = CreateSession(KMMRCServerName, TVersion(1,0,0));	 
	
	DP0_RET(err, "err = %d");
	}

/**
*/
TUint64 RMMRCClientSession::LogOn(TProcessId aProcessId)
	{
	DP_CONTEXT(----> RMMRCClientSession::LogOn *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	iCurrentRequestId = 0;
	TUint64 contextId;
	TPckg<TUint64> contextIdPckg(contextId);
	TPckg<TProcessId> processIdPckg(aProcessId);
	TIpcArgs args(&processIdPckg, &contextIdPckg);
	
	SendReceive(EMMRCClientToServerRequestContextId,args);
	
	DP0_RET(contextId, "contextId = %d");
	}


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

	TRequestStatus RequestStatus;
	SendReceive(EMMRCClientToServerCloseSession, TIpcArgs(0), RequestStatus);
	User::WaitForRequest(RequestStatus); 
	if(iMMRCClientSideServerRequestToAdaptationAO)
		{
		delete iMMRCClientSideServerRequestToAdaptationAO;
		iMMRCClientSideServerRequestToAdaptationAO=0;
		}
	
	RHandleBase::Close();
	iServerThread.Close();
	
	DP_OUT();
	}

/**
*/
void RMMRCClientSession::InitializeServerL(RHandleBase& aMsgQueueHandle)
	{
	DP_CONTEXT(----> RMMRCClientSession::InitializeServerL *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	//Send the Client ThreadId
	RThread me;
	const TThreadId& id = me.Id();
	SendReceive(EMMRCClientToServerSetClientThreadId, TIpcArgs(&id));
	
	//Create a client side adaptation proxy on the client schudeler 
	iMMRCClientSideServerRequestToAdaptationAO = CMMRCClientSideServerRequestToAdaptationAO::NewL();
	// send synchronously the pointer to the server
	SendReceive(EMMRCClientToServerSetAdaptationProxy, TIpcArgs(iMMRCClientSideServerRequestToAdaptationAO));
	
	//Send synchronously the Message Queue pointer to the server
	SendReceive(EMMRCClientToServerSetMsgQueueHandle, TIpcArgs(aMsgQueueHandle));
	
	DP_OUT();
	}

/**
*/
TInt RMMRCClientSession::SendResourceRequest(MLogicalChain* aLogicalChainLastCommited, MLogicalChain* aLogicalChainRequested, CAudioContext* aContext)
	{
	DP_CONTEXT(----SSSS> RMMRCClientSession::SendResourceRequest *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();

	TInt err = KErrNone;
	//Only one request at a time!!!
	if(iLogicalChainLastCommited || iLogicalChainRequested)
		{
		err = KErrServerBusy;
		#ifdef _DEBUG	
			RDebug::Print(_L("!!RMMRCClientSession::SendResourceRequest -  Second request but server busy"));
		#endif
		DP0_RET(err, "err = %d");
		}
	
	//Clone the chains; they are realesed on response
	if( err == KErrNone )
		{
		TRAP(err, iLogicalChainLastCommited = aLogicalChainLastCommited->CloneL());
		if( err == KErrNone )
			{
			TRAP(err, iLogicalChainRequested = aLogicalChainRequested->CloneL());
			}
		}
		
	//Send the request
	if ( err == KErrNone )
		{
		// AM To determine when we reached the limit of messages
		err = Send(EMMRCClientToServerRequestResource, TIpcArgs(iLogicalChainLastCommited, iLogicalChainRequested, aContext, aContext->MsgVersion()));
		}
	#ifdef _DEBUG	
	else
		{
		RDebug::Print(_L("!!!!RMMRCClientSession::SendResourceRequest - Error = %d"), err);
		}
	#endif
	
	DP0_RET(err, "err = %d");
	}

/**
 */
 void RMMRCClientSession::ResourceRequestResponse(MLogicalChain* aChainResponse, TMMRCServerToClientMessageResults /*aResult*/, TInt aError)
	{
	DP_CONTEXT(--------> RMMRCClientSession::ResourceRequestResponseL *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	//Check if the response is not null... Should never happen
	if( aChainResponse == NULL && aError == KErrNone)
	//coverity[var_compare_op]	
		{
		RDebug::Print(_L("!!!!RMMRCClientSession::ResourceRequestResponseL -  Chain in input NULL - KErrArgument"));
		__ASSERT_ALWAYS(0, User::Panic(_L("MMRCClientSessionNullResponse"), 1));
		}
	
	iObserver->ReceiveResourceResponse(aChainResponse, aError);
	//coverity[var_deref_model]
	// Coverity incorrectly assumes that aChainResponse is always NULL
	DP_OUT();
	}

/**
*/
TInt RMMRCClientSession::RegisterAsClient(TUid aEventType, const TDesC8& aNotificationRegistrationData)
	{
	DP_CONTEXT(----> RMMRCClientSession::RegisterAsClient *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	TInt err (KErrNone);
	err = SendReceive(EMMRCClientToServerRegisterAsClient, TIpcArgs(&aEventType, &aNotificationRegistrationData));

	
	DP0_RET(err, "err = %d");
	}
	
/**
*/	
TInt RMMRCClientSession::CancelRegisterAsClient(TUid aEventType)
	{
	DP_CONTEXT(----> RMMRCClientSession::CancelRegisterAsClient *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	TInt err (KErrNone);
	err = SendReceive(EMMRCClientToServerCancelRegisterAsClient, TIpcArgs(&aEventType));

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

/**
*/	
TInt RMMRCClientSession::WillResumePlay()
	{
	DP_CONTEXT(----> RMMRCClientSession::WillResumePlay *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	TInt err (KErrNone);
	err = SendReceive(EMMRCClientToServerWillResumePlay, TIpcArgs(0));

	
	DP0_RET(err, "err = %d");
	}
	
void RMMRCClientSession::ResetMessages()
	{
	DP_CONTEXT(----> RMMRCClientSession::ResetMessages *CD1*, CtxDevSound, DPLOCAL);
	DP_IN();
	
	//Clean the logical chains
	if(iLogicalChainLastCommited)
		{
		iLogicalChainLastCommited->Release();
		iLogicalChainLastCommited = NULL;
		}
	if(iLogicalChainRequested)
		{
		iLogicalChainRequested->Release();
		iLogicalChainRequested = NULL;
		}
	
	DP_OUT();
	}		
//EOF