1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/mm/mmresourcemgmt/mmresctrl/src/mmrcclient/mmrcclientimplementation.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,246 @@
1.4 +// Copyright (c) 2006-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +//
1.18 +
1.19 +#include "mmrcclientimplementation.h"
1.20 +#include "mmrcclientmsgqueuehandler.h"
1.21 +#include "multimediaresourcecontrolobserver.h"
1.22 +#include "audiocontext.h"
1.23 +
1.24 +#include <a3f/maudiocontextobserver.h>
1.25 +
1.26 +
1.27 +const TInt KMsgQueueSlots = 8;
1.28 +
1.29 +
1.30 +/**
1.31 + */
1.32 +CMMRCClientImplementation::CMMRCClientImplementation(MMultimediaResourceControlObserver& aCallback)
1.33 +: iObserver(aCallback)
1.34 + {
1.35 + TRACE_CREATE();
1.36 + DP_CONTEXT(----> CMMRCClientImplementation::CMMRCClientImplementation *CD1*, CtxDevSound, DPLOCAL);
1.37 + DP_IN();
1.38 + DP_OUT();
1.39 + }
1.40 +
1.41 +/**
1.42 + */
1.43 +CMMRCClientImplementation::~CMMRCClientImplementation()
1.44 + {
1.45 + DP_CONTEXT(----> CMMRCClientImplementation::~CMMRCClientImplementation *CD1*, CtxDevSound, DPLOCAL);
1.46 + DP_IN();
1.47 +
1.48 + if(iMsgClientQueueHandler)
1.49 + {
1.50 + delete iMsgClientQueueHandler;
1.51 + }
1.52 + iMsgQueue.Close();
1.53 +
1.54 + DP_OUT();
1.55 + }
1.56 +
1.57 +/**
1.58 + */
1.59 +CMMRCClientImplementation* CMMRCClientImplementation::NewL(MMultimediaResourceControlObserver& aCallback)
1.60 + {
1.61 + DP_STATIC_CONTEXT(----> CMMRCClientImplementation::NewL *CD1*, CtxDevSound, DPLOCAL);
1.62 + DP_IN();
1.63 +
1.64 + CMMRCClientImplementation* self = new (ELeave) CMMRCClientImplementation(aCallback);
1.65 + CleanupStack::PushL (self);
1.66 + self->ConstructL ();
1.67 + CleanupStack::Pop (self);
1.68 +
1.69 + DP0_RET(self, "0x%x");
1.70 + }
1.71 +
1.72 +/**
1.73 + */
1.74 +void CMMRCClientImplementation::ConstructL()
1.75 + {
1.76 + DP_CONTEXT(----> CMMRCClientImplementation::ConstructL *CD1*, CtxDevSound, DPLOCAL);
1.77 + DP_IN();
1.78 +
1.79 + TInt error = iMMRCClientSession.Open (iObserver);
1.80 + if ( KErrNotFound == error)
1.81 + {
1.82 + //The server is not found, create it
1.83 + error = iMMRCClientSession.StartServer ();
1.84 + User::LeaveIfError (error);
1.85 +
1.86 + //Try again to create a connection to it
1.87 + error = iMMRCClientSession.Open (iObserver);
1.88 + #ifdef _DEBUG
1.89 + if(error != KErrNone)
1.90 + {
1.91 + RDebug::Print(_L("!!!!CMMRCClientImplementation::ConstructL - Open session 2 - error = %d"), error);
1.92 + }
1.93 + #endif
1.94 + User::LeaveIfError (error);
1.95 + }
1.96 + #ifdef _DEBUG
1.97 + if(error != KErrNone)
1.98 + {
1.99 + RDebug::Print(_L("!!!!CMMRCClientImplementation::ConstructL - Open session 1 - error = %d"), error);
1.100 + }
1.101 + #endif
1.102 + User::LeaveIfError (error);
1.103 +
1.104 + //Create an un-named msg queue, a handle is needed to connect to it.
1.105 + error = iMsgQueue.CreateGlobal (KNullDesC, KMsgQueueSlots, EOwnerProcess);
1.106 + #ifdef _DEBUG
1.107 + if(error != KErrNone)
1.108 + {
1.109 + RDebug::Print(_L("!!!!CMMRCClientImplementation::ConstructL - CreateGlobal - error = %d"), error);
1.110 + }
1.111 + #endif
1.112 + User::LeaveIfError (error);
1.113 + iMsgClientQueueHandler = CMMRCClientMsgQueueHandler::NewL (iMsgQueue, *this);
1.114 +
1.115 + //Forward the message queue handle to the server, which will connect to it.
1.116 + iMMRCClientSession.InitializeServerL(iMsgQueue);
1.117 +
1.118 + DP_OUT();
1.119 + }
1.120 +/**
1.121 + */
1.122 +TUint64 CMMRCClientImplementation::LogOn(TProcessId aProcessId)
1.123 + {
1.124 + DP_CONTEXT(----> CMMRCClientImplementation::LogOn *CD1*, CtxDevSound, DPLOCAL);
1.125 + DP_IN();
1.126 +
1.127 + TUint64 contextId = iMMRCClientSession.LogOn(aProcessId);
1.128 +
1.129 + DP0_RET(contextId, "contextId = %d");
1.130 + }
1.131 +
1.132 +/**
1.133 + */
1.134 +void CMMRCClientImplementation::Close()
1.135 + {
1.136 + DP_CONTEXT(----> CMMRCClientImplementation::Close *CD1*, CtxDevSound, DPLOCAL);
1.137 + DP_IN();
1.138 +
1.139 + iMMRCClientSession.Close ();
1.140 +
1.141 + DP_OUT();
1.142 + }
1.143 +
1.144 +/**
1.145 + */
1.146 +TInt CMMRCClientImplementation::SendResourceRequest(MLogicalChain* aLogicalChainLastCommited, MLogicalChain* aLogicalChainRequested, CAudioContext* aContext)
1.147 + {
1.148 + DP_CONTEXT(----> CMMRCClientImplementation::SendResourceRequest *CD1*, CtxDevSound, DPLOCAL);
1.149 + DP_IN();
1.150 +
1.151 + TInt err = iMMRCClientSession.SendResourceRequest(aLogicalChainLastCommited, aLogicalChainRequested, aContext);
1.152 +
1.153 + DP0_RET(err, "err = %d");
1.154 + }
1.155 +
1.156 +/**y
1.157 + */
1.158 +void CMMRCClientImplementation::HandleMessage(TMMRCQueueItem& aMessage)
1.159 + {
1.160 + DP_CONTEXT(----> CMMRCClientImplementation::HandleMessage *CD1*, CtxDevSound, DPLOCAL);
1.161 + DP_IN();
1.162 +
1.163 + #ifdef _DEBUG
1.164 + RDebug::Print(_L("RMMRCClientSession::ResourceRequestResponseL aMessage.iRequestType = %d, aMessage.iResult = %d, aMessage.iErrorCode = %d"), aMessage.iRequestType, aMessage.iResult, aMessage.iErrorCode);
1.165 + #endif
1.166 +
1.167 + switch(aMessage.iRequestType)
1.168 + {
1.169 +
1.170 + case EMMRCRequestCommitUpdate:
1.171 + {
1.172 + // Ignore this, now this will come directly from adaptation
1.173 + // iObserver.ReceiveResourceUpdate(aMessage.iData, aMessage.iErrorCode);
1.174 + }
1.175 + break;
1.176 +
1.177 + case EMMRCRequestCommitResponse:
1.178 + {
1.179 + // This would remain coming throug MMRC to update client side
1.180 + iMMRCClientSession.ResourceRequestResponse(aMessage.iData, aMessage.iResult, aMessage.iErrorCode);
1.181 + }
1.182 + break;
1.183 +
1.184 + case EMMRCRequestResourceUnallocated:
1.185 + {
1.186 + // Notification used for APR.
1.187 + iObserver.CanResume();
1.188 + }
1.189 + break;
1.190 +
1.191 + default: //unknown message
1.192 + #ifdef _DEBUG
1.193 + ASSERT(0);
1.194 + RDebug::Print(_L("!!!!CMMRCClientImplementation::HandleMessage - Unknown message"));
1.195 + #endif
1.196 + break;
1.197 + }
1.198 +
1.199 + DP_OUT();
1.200 + }
1.201 +
1.202 +/**
1.203 + */
1.204 +TInt CMMRCClientImplementation::RegisterAsClient(TUid aEventType, const TDesC8& aNotificationRegistrationData)
1.205 + {
1.206 + DP_CONTEXT(----> CMMRCClientImplementation::RegisterAsClient *CD1*, CtxDevSound, DPLOCAL);
1.207 + DP_IN();
1.208 +
1.209 + TInt err = iMMRCClientSession.RegisterAsClient(aEventType, aNotificationRegistrationData);
1.210 +
1.211 + DP0_RET(err, "err = %d");
1.212 + }
1.213 +
1.214 +
1.215 +/**
1.216 + */
1.217 +TInt CMMRCClientImplementation::CancelRegisterAsClient(TUid aEventType)
1.218 + {
1.219 + DP_CONTEXT(----> CMMRCClientImplementation::CancelRegisterAsClient *CD1*, CtxDevSound, DPLOCAL);
1.220 + DP_IN();
1.221 +
1.222 + TInt err = iMMRCClientSession.CancelRegisterAsClient(aEventType);
1.223 +
1.224 + DP0_RET(err, "err = %d");
1.225 + }
1.226 +
1.227 +
1.228 +/**
1.229 + */
1.230 +TInt CMMRCClientImplementation::WillResumePlay()
1.231 + {
1.232 + DP_CONTEXT(----> CMMRCClientImplementation::WillResumePlay *CD1*, CtxDevSound, DPLOCAL);
1.233 + DP_IN();
1.234 +
1.235 + TInt err = iMMRCClientSession.WillResumePlay();
1.236 +
1.237 + DP0_RET(err, "err = %d");
1.238 + }
1.239 +
1.240 +void CMMRCClientImplementation::ResetMessages()
1.241 + {
1.242 + DP_CONTEXT(----> CMMRCClientImplementation::ResetMessages *CD1*, CtxDevSound, DPLOCAL);
1.243 + DP_IN();
1.244 +
1.245 + iMMRCClientSession.ResetMessages();
1.246 +
1.247 + DP_OUT();
1.248 + }
1.249 +//EOF