diff -r 000000000000 -r 40261b775718 mmresourcemgmt/mmresctrl/src/mmrcclient/mmrcclientsession.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mmresourcemgmt/mmresctrl/src/mmrcclient/mmrcclientsession.cpp	Tue Feb 02 01:56:55 2010 +0200
@@ -0,0 +1,272 @@
+// 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
+