os/mm/devsoundextensions/telephonyaudiorouting/Session/src/TelephonyAudioRoutingManagerSession.cpp
1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/mm/devsoundextensions/telephonyaudiorouting/Session/src/TelephonyAudioRoutingManagerSession.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,247 @@
1.4 +/*
1.5 +* Copyright (c) 2002-2004 Nokia Corporation and/or its subsidiary(-ies).
1.6 +* All rights reserved.
1.7 +* This component and the accompanying materials are made available
1.8 +* under the terms of "Eclipse Public License v1.0"
1.9 +* which accompanies this distribution, and is available
1.10 +* at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.11 +*
1.12 +* Initial Contributors:
1.13 +* Nokia Corporation - initial contribution.
1.14 +*
1.15 +* Contributors:
1.16 +*
1.17 +* Description: This class is the main interface to the TelephonyAudioRoutingServer.
1.18 +* : Specifically handles TelephonyAudioRoutingManager sessions.
1.19 +*
1.20 +*/
1.21 +
1.22 +
1.23 +
1.24 +#include <e32math.h>
1.25 +#include <s32mem.h>
1.26 +#include "TelephonyAudioRoutingClientServer.h"
1.27 +#include "TelephonyAudioRoutingManagerSession.h"
1.28 +#include "TelephonyAudioRoutingPolicyRequest.h"
1.29 +
1.30 +
1.31 +// -----------------------------------------------------------------------------
1.32 +// RTelephonyAudioRoutingManagerSession::RTelephonyAudioRoutingManagerSession
1.33 +// C++ default constructor can NOT contain any code, that
1.34 +// might leave.
1.35 +// -----------------------------------------------------------------------------
1.36 +//
1.37 +EXPORT_C RTelephonyAudioRoutingManagerSession::RTelephonyAudioRoutingManagerSession()
1.38 + : RSessionBase(), iConnected(EFalse)
1.39 + {
1.40 + // No implementation required
1.41 +
1.42 + }
1.43 +
1.44 +// -----------------------------------------------------------------------------
1.45 +// RTelephonyAudioRoutingSession::Connect
1.46 +// Connects a policy client to the server.
1.47 +// (other items were commented in a header).
1.48 +// -----------------------------------------------------------------------------
1.49 +//
1.50 +EXPORT_C TInt RTelephonyAudioRoutingManagerSession::Connect(
1.51 + CTelephonyAudioRoutingManager& aAudioRoutingManager,
1.52 + MTelephonyAudioRoutingPolicyObserver& aPolicyObserver)
1.53 + {
1.54 +
1.55 + TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::Connect"));
1.56 +
1.57 + TInt retry=2;
1.58 + TInt err = KErrGeneral;
1.59 +
1.60 + for (;;)
1.61 + {
1.62 + err=CreateSession(KTelAudRtngServName,TVersion(0,0,0)); // RSessionBase::CreateSession
1.63 +
1.64 + if (err!=KErrNotFound && err!=KErrServerTerminated && err!=KErrPermissionDenied)
1.65 + break;
1.66 +
1.67 + if (--retry==0)
1.68 + break;
1.69 + }
1.70 +
1.71 + if ( err == KErrNone )
1.72 + {
1.73 + // Create active object receive handlers and add it to scheduler
1.74 + TRAP(err, StartPolicyRequestHandlersL(aAudioRoutingManager, aPolicyObserver));
1.75 + if ( err == KErrNone )
1.76 + {
1.77 + iConnected = ETrue;
1.78 + }
1.79 +
1.80 + SendReceive(ETelAudRtngServInitialize, TIpcArgs());
1.81 +
1.82 + }
1.83 +
1.84 + return err;
1.85 +
1.86 + }
1.87 +
1.88 +// -----------------------------------------------------------------------------
1.89 +// RTelephonyAudioRoutingManagerSession::Close
1.90 +// Closes connection to the server.
1.91 +// (other items were commented in a header).
1.92 +// -----------------------------------------------------------------------------
1.93 +//
1.94 +EXPORT_C void RTelephonyAudioRoutingManagerSession::Close()
1.95 + {
1.96 + TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::Close"));
1.97 + if ( iConnected )
1.98 + {
1.99 +
1.100 + delete iPolicyRequest;
1.101 + RSessionBase::Close();
1.102 + iConnected = EFalse;
1.103 +
1.104 +
1.105 + }
1.106 +
1.107 + }
1.108 +
1.109 +// -----------------------------------------------------------------------------
1.110 +// RTelephonyAudioRoutingManagerSession::OutputChangeCompleted
1.111 +// Used by policy to notify server that requested output change completed
1.112 +// (other items were commented in a header).
1.113 +// -----------------------------------------------------------------------------
1.114 +//
1.115 +EXPORT_C void RTelephonyAudioRoutingManagerSession::OutputChangeCompleted(
1.116 + CTelephonyAudioRouting::TAudioOutput aOutput,
1.117 + TInt aError)
1.118 + {
1.119 + TPckgBuf<CTelephonyAudioRouting::TAudioOutput> audioOutputPkg;
1.120 + audioOutputPkg() = aOutput;
1.121 + TPckgBuf<TInt> errPkg;
1.122 + errPkg() = aError;
1.123 +
1.124 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::OutputChangeCompleted to %d"), aOutput);
1.125 + SendReceive(ETelAudRtngServOutputChangeComplete, TIpcArgs(&audioOutputPkg, &errPkg));
1.126 + }
1.127 +
1.128 +// -----------------------------------------------------------------------------
1.129 +// RTelephonyAudioRoutingManagerSession::OutputChanged
1.130 +// Used by policy to notify server of audio output changes initiated by policy.
1.131 +// (other items were commented in a header).
1.132 +// -----------------------------------------------------------------------------
1.133 +//
1.134 +EXPORT_C void RTelephonyAudioRoutingManagerSession::OutputChanged(
1.135 + CTelephonyAudioRouting::TAudioOutput aOutput)
1.136 + {
1.137 + TPckgBuf<CTelephonyAudioRouting::TAudioOutput> audioOutputPkg;
1.138 + audioOutputPkg() = aOutput;
1.139 +// iAudioOutput = aOutput;
1.140 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::OutputChanged to %d"), aOutput);
1.141 + SendReceive(ETelAudRtngServOutputChangedByPolicy, TIpcArgs(&audioOutputPkg));
1.142 +
1.143 + }
1.144 +
1.145 +// -----------------------------------------------------------------------------
1.146 +// RTelephonyAudioRoutingManagerSession::AvailableOutputsChangedL
1.147 +// Used by policy session to notify server if the available audio output change.
1.148 +// (other items were commented in a header).
1.149 +// -----------------------------------------------------------------------------
1.150 +//
1.151 +EXPORT_C void RTelephonyAudioRoutingManagerSession::AvailableOutputsChangedL(
1.152 + const TArray<CTelephonyAudioRouting::TAudioOutput>& aOutputs)
1.153 + {
1.154 + TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::AvailableOutputsChangedL"));
1.155 + TPckgBuf<TInt> numOfOutputs;
1.156 + numOfOutputs()= aOutputs.Count();
1.157 +
1.158 + TInt count = aOutputs.Count();
1.159 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t AvailableOutputsChangedL: Count = %d "),count);
1.160 + for(TInt i = 0; i < count; i++)
1.161 + {
1.162 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t AvailableOutputsChangedL: aOutputs[i] = %d "),aOutputs[i]);
1.163 + }
1.164 +
1.165 + TInt KBufExpandSize8 = 8;//two TInts
1.166 + CBufFlat* dataCopyBuffer = CBufFlat::NewL(KBufExpandSize8);
1.167 + CleanupStack::PushL(dataCopyBuffer);
1.168 + RBufWriteStream stream;
1.169 + stream.Open(*dataCopyBuffer);
1.170 + CleanupClosePushL(stream);
1.171 +
1.172 + for (TInt i=0;i<aOutputs.Count();i++)
1.173 + {
1.174 + stream.WriteInt16L(aOutputs[i]);
1.175 + }
1.176 +
1.177 + TPtr8 ptr = dataCopyBuffer->Ptr(0);
1.178 +
1.179 + SendReceive(ETelAudRtngDoAvailableOutputsChanged, TIpcArgs(&numOfOutputs, &ptr));
1.180 + stream.Close();
1.181 + CleanupStack::PopAndDestroy(2);//stream, buf
1.182 +
1.183 + }
1.184 +
1.185 +// -----------------------------------------------------------------------------
1.186 +// RTelephonyAudioRoutingManagerSession::SetPolicySessionIdL
1.187 +// Sets policy session Id.
1.188 +// (other items were commented in a header).
1.189 +// -----------------------------------------------------------------------------
1.190 +//
1.191 +EXPORT_C void RTelephonyAudioRoutingManagerSession::SetPolicySessionIdL()
1.192 + {
1.193 + User::LeaveIfError(SendReceive(ETelAudRtngServSetPolicySessionId, TIpcArgs()));
1.194 + }
1.195 +
1.196 +// -----------------------------------------------------------------------------
1.197 +// RTelephonyAudioRoutingManagerSession::MonitorOutputChangeRequest
1.198 +// Used by policy session to get notification whenever any of the clients sends
1.199 +// a SetOutput request.
1.200 +// (other items were commented in a header).
1.201 +// -----------------------------------------------------------------------------
1.202 +//
1.203 +EXPORT_C void RTelephonyAudioRoutingManagerSession::MonitorOutputChangeRequest()
1.204 + {
1.205 + TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::MonitorOutputChangeRequest "));
1.206 +
1.207 + iPolicyRequest->Cancel();
1.208 +
1.209 + SendReceive(ETelAudRtngServMonitorOutputChange, TIpcArgs(&iAudioOutputPkg), iPolicyRequest->iStatus);
1.210 + iPolicyRequest->SetActive();
1.211 +
1.212 + }
1.213 +
1.214 +// -----------------------------------------------------------------------------
1.215 +// RTelephonyAudioRoutingManagerSession::CancelRequest
1.216 +// Cancel a previously send request.
1.217 +// (other items were commented in a header).
1.218 +// -----------------------------------------------------------------------------
1.219 +//
1.220 +EXPORT_C void RTelephonyAudioRoutingManagerSession::CancelRequest(TTelAudRtngServRqst aRequest)
1.221 + {
1.222 + TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::CancelRequest "));
1.223 + TPckgBuf<TInt> request;
1.224 + request() = aRequest;
1.225 + SendReceive(ETelAudRtngServCancelRequest, TIpcArgs(&request));
1.226 + }
1.227 +
1.228 +// -----------------------------------------------------------------------------
1.229 +// RTelephonyAudioRoutingSession::AudioOutputPkg
1.230 +// Accessor method returns iAudioOutputPkg to caller.
1.231 +// (other items were commented in a header).
1.232 +// -----------------------------------------------------------------------------
1.233 +//
1.234 +EXPORT_C TPckgBuf<CTelephonyAudioRouting::TAudioOutput>& RTelephonyAudioRoutingManagerSession::AudioOutputPkg()
1.235 + {
1.236 + return iAudioOutputPkg;
1.237 + }
1.238 +
1.239 +// -----------------------------------------------------------------------------
1.240 +// RTelephonyAudioRoutingManagerSession::StartPolicyRequestHandlersL
1.241 +// Start asynchronous request handlers.
1.242 +// (other items were commented in a header).
1.243 +// -----------------------------------------------------------------------------
1.244 +//
1.245 +void RTelephonyAudioRoutingManagerSession::StartPolicyRequestHandlersL(
1.246 + CTelephonyAudioRoutingManager& aAudioRoutingManager,
1.247 + MTelephonyAudioRoutingPolicyObserver& aPolicyObserver )
1.248 + {
1.249 + iPolicyRequest = CTelephonyAudioRoutingPolicyRequest::NewL(*this, aPolicyObserver, aAudioRoutingManager, ETelAudRtngServMonitorOutputChange);
1.250 + }