os/mm/devsoundextensions/telephonyaudiorouting/Server/src/TelephonyAudioRoutingServerSession.cpp
1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/mm/devsoundextensions/telephonyaudiorouting/Server/src/TelephonyAudioRoutingServerSession.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,788 @@
1.4 +/*
1.5 +* Copyright (c) 2006 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: Server-side session implementation
1.18 +*
1.19 +*/
1.20 +
1.21 +
1.22 +
1.23 +#include <e32std.h>
1.24 +#include <e32svr.h>
1.25 +#include <s32mem.h> // for stream classes
1.26 +#include "TelephonyAudioRoutingServerSession.h"
1.27 +
1.28 +const TInt KMaxNumberOfOutputs = 100;
1.29 +
1.30 +// ============================ MEMBER FUNCTIONS ===============================
1.31 +
1.32 +// -----------------------------------------------------------------------------
1.33 +// CTelephonyAudioRoutingServerSession::CTelephonyAudioRoutingServerSession
1.34 +// C++ default constructor can NOT contain any code, that
1.35 +// might leave.
1.36 +// -----------------------------------------------------------------------------
1.37 +//
1.38 +CTelephonyAudioRoutingServerSession::CTelephonyAudioRoutingServerSession(
1.39 + TInt aSessionId)
1.40 + :iSessionId(aSessionId),
1.41 + iMessageArray()
1.42 + {
1.43 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::CTelephonyAudioRoutingServerSession "),this);
1.44 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t iMessageArrayCount = %d "),iMessageArray.Count());
1.45 +
1.46 + }
1.47 +
1.48 +// Destructor
1.49 +CTelephonyAudioRoutingServerSession::~CTelephonyAudioRoutingServerSession()
1.50 + {
1.51 +
1.52 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::~CTelephonyAudioRoutingServerSession "),this);
1.53 +
1.54 + if (&Server() != NULL)
1.55 + {
1.56 + Server().RemoveSession(iSessionId);
1.57 + }
1.58 +
1.59 + iSessionAvailableOutputs.Close();
1.60 + iMessageArray.Close();
1.61 +
1.62 + }
1.63 +
1.64 +// -----------------------------------------------------------------------------
1.65 +// CTelephonyAudioRoutingServerSession::Server
1.66 +// Creates the server.
1.67 +// (other items were commented in a header).
1.68 +// -----------------------------------------------------------------------------
1.69 +//
1.70 +CTelephonyAudioRoutingServer& CTelephonyAudioRoutingServerSession::Server()
1.71 + {
1.72 + return *static_cast<CTelephonyAudioRoutingServer*>(const_cast<CServer2*>(CSession2::Server()));
1.73 + }
1.74 +
1.75 +// -----------------------------------------------------------------------------
1.76 +// CTelephonyAudioRoutingServerSession::ServiceError
1.77 +// Handle an error from ServiceL
1.78 +// (other items were commented in a header).
1.79 +// -----------------------------------------------------------------------------
1.80 +//
1.81 +void CTelephonyAudioRoutingServerSession::ServiceError(
1.82 + const RMessage2& aMessage,
1.83 + TInt aError)
1.84 + {
1.85 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::ServiceError - %d "), aError);
1.86 + PanicClient (aMessage, EPanicIllegalFunction);
1.87 + }
1.88 +
1.89 +// -----------------------------------------------------------------------------
1.90 +// CTelephonyAudioRoutingServerSession::ServiceL
1.91 +// Handles the servicing of a client request that has been passed to the server.
1.92 +// (other items were commented in a header).
1.93 +// -----------------------------------------------------------------------------
1.94 +//
1.95 +void CTelephonyAudioRoutingServerSession::ServiceL (
1.96 + const RMessage2& aMessage)
1.97 + {
1.98 +
1.99 + switch (aMessage.Function())
1.100 + {
1.101 + case ETelAudRtngServDoSetOutput:
1.102 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServDoSetOutput "),this);
1.103 + DoSetOutputL(aMessage);
1.104 + break;
1.105 +
1.106 + case ETelAudRtngServNotifyIfOutputChanged:
1.107 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServNotifyIfOutputChanged "),this);
1.108 + NotifyIfOutputChangedL(aMessage);
1.109 + break;
1.110 +
1.111 + case ETelAudRtngServNotifyIfAvailOutputsChanged:
1.112 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServNotifyIfAvailOutputsChanged "),this);
1.113 + NotifyIfAvailOutputsChangedL(aMessage);
1.114 + break;
1.115 +
1.116 + case ETelAudRtngServGetNoOutputs:
1.117 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServGetNoOutputs "),this);
1.118 + GetNoOfAvailableOutputs(aMessage);
1.119 + break;
1.120 +
1.121 + case ETelAudRtngServGetAvailableOutputs:
1.122 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServGetAvailableOutputs "),this);
1.123 + GetAvailableOutputsL(aMessage);
1.124 + break;
1.125 +
1.126 + case ETelAudRtngServMonitorOutputChange:
1.127 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServMonitorOutputChange "),this);
1.128 + MonitorOutputChangeL(aMessage);
1.129 + break;
1.130 +
1.131 + case ETelAudRtngServSetPolicySessionId:
1.132 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServSetPolicySessionId "),this);
1.133 + SetPolicySessionId(aMessage);
1.134 + break;
1.135 +
1.136 + case ETelAudRtngServOutputChangeComplete:
1.137 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServOutputChangeComplete "),this);
1.138 + OutputChangeCompleteL(aMessage);
1.139 + break;
1.140 +
1.141 + case ETelAudRtngDoAvailableOutputsChanged:
1.142 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngDoAvailableOutputsChanged "),this);
1.143 + DoAvailableOutputsChangedL(aMessage);
1.144 + break;
1.145 +
1.146 + case ETelAudRtngServCancelRequest:
1.147 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServCancelRequest "),this);
1.148 + CancelRequestL(aMessage);
1.149 + break;
1.150 +
1.151 + case ETelAudRtngServInitialize:
1.152 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServInitialize "),this);
1.153 + InitializeL(aMessage);
1.154 + break;
1.155 +
1.156 + case ETelAudRtngServOutputChangedByPolicy:
1.157 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServOutputChangedByPolicy "),this);
1.158 + OutputChangedL(aMessage);
1.159 + break;
1.160 +
1.161 + case ETelAudRtngServGetDefaultValues:
1.162 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - ETelAudRtngServGetDefaultValues "),this);
1.163 + GetDefaultValuesL(aMessage);
1.164 + break;
1.165 +
1.166 + default:
1.167 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL - default !! "),this);
1.168 + PanicClient (aMessage, EPanicIllegalFunction);
1.169 + }
1.170 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::ServiceL EXIT"), this);
1.171 + }
1.172 +
1.173 +// -----------------------------------------------------------------------------
1.174 +// CTelephonyAudioRoutingServerSession::InitializeL
1.175 +// Session initialization.
1.176 +// (other items were commented in a header).
1.177 +// -----------------------------------------------------------------------------
1.178 +//
1.179 +void CTelephonyAudioRoutingServerSession::InitializeL(
1.180 + const RMessage2& aMessage)
1.181 + {
1.182 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::IntitializeL enter"),this);
1.183 + iConnected = ETrue;
1.184 + Server().AddSession();
1.185 + aMessage.Complete(KErrNone);
1.186 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::IntitializeL exit"),this);
1.187 + }
1.188 +
1.189 +// -----------------------------------------------------------------------------
1.190 +// CTelephonyAudioRoutingServerSession::CancelRequestL
1.191 +// Cancel the outstanding request.
1.192 +// (other items were commented in a header).
1.193 +// -----------------------------------------------------------------------------
1.194 +//
1.195 +void CTelephonyAudioRoutingServerSession::CancelRequestL(
1.196 + const RMessage2& aMessage)
1.197 + {
1.198 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::CancelRequestL"),this);
1.199 + TTelAudRtngServRqst req;
1.200 + req = (TTelAudRtngServRqst) aMessage.Int1();
1.201 + TPckgBuf<TInt> count;
1.202 + aMessage.ReadL( 0, count);
1.203 + req = (TTelAudRtngServRqst)count();
1.204 + aMessage.Complete(KErrNone);
1.205 + TInt messageCount = iMessageArray.Count();
1.206 + TInt messageIndex = 0;
1.207 +
1.208 + if(messageCount > 0)
1.209 + {
1.210 + for(TInt i=0;i< messageCount; i++)
1.211 + {
1.212 + if(iMessageArray[i].Function()== req)
1.213 + {
1.214 + messageIndex=i;
1.215 + break;
1.216 + }
1.217 +
1.218 + }
1.219 + iMessageArray[messageIndex].Complete(KErrCancel);
1.220 + iMessageArray.Remove(messageIndex);
1.221 + }
1.222 + }
1.223 +
1.224 +// -----------------------------------------------------------------------------
1.225 +// CTelephonyAudioRoutingServerSession::DoSetOutputL
1.226 +// Send a request to audio policy to set audio output.
1.227 +// (other items were commented in a header).
1.228 +// -----------------------------------------------------------------------------
1.229 +//
1.230 +void CTelephonyAudioRoutingServerSession::DoSetOutputL (
1.231 + const RMessage2& aMessage)
1.232 + {
1.233 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::DoSetOutputL "),this);
1.234 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t Appending aMessage to iMessageArray. Current count = %d "),iMessageArray.Count());
1.235 + iMessageArray.AppendL(aMessage);
1.236 + Server().DoSetOutputL(iSessionId,aMessage);
1.237 + }
1.238 +
1.239 +// -----------------------------------------------------------------------------
1.240 +// CTelephonyAudioRoutingServerSession::NotifyIfOutputChangedL
1.241 +// Add a message to message queue. Complete the message when output changes
1.242 +// (other items were commented in a header).
1.243 +// -----------------------------------------------------------------------------
1.244 +//
1.245 +void CTelephonyAudioRoutingServerSession::NotifyIfOutputChangedL (
1.246 + const RMessage2& aMessage)
1.247 + {
1.248 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::NotifyIfOutputChangedL "),this);
1.249 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t Appending aMessage to iMessageArray. Current count = %d "),iMessageArray.Count());
1.250 + iMessageArray.AppendL(aMessage);
1.251 + }
1.252 +
1.253 +// -----------------------------------------------------------------------------
1.254 +// CTelephonyAudioRoutingServerSession::NotifyIfAvailOutputsChangedL
1.255 +// Add a message to message queue. Complete the message when available audio
1.256 +// outputs change
1.257 +// (other items were commented in a header).
1.258 +// -----------------------------------------------------------------------------
1.259 +//
1.260 +void CTelephonyAudioRoutingServerSession::NotifyIfAvailOutputsChangedL (
1.261 + const RMessage2& aMessage)
1.262 + {
1.263 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::NotifyIfAvailOutputsChangedL "),this);
1.264 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t Appending aMessage to iMessageArray. Current count = %d "),iMessageArray.Count());
1.265 + iMessageArray.AppendL(aMessage);
1.266 + }
1.267 +
1.268 +// -----------------------------------------------------------------------------
1.269 +// CTelephonyAudioRoutingServerSession::SetPolicySessionId
1.270 +// Set the policy session Id.
1.271 +// (other items were commented in a header).
1.272 +// -----------------------------------------------------------------------------
1.273 +//
1.274 +void CTelephonyAudioRoutingServerSession::SetPolicySessionId(
1.275 + const RMessage2& aMessage)
1.276 + {
1.277 + if(!iPolicyFlag)
1.278 + {
1.279 + Server().SetPolicySessionId(iSessionId);
1.280 + iPolicyFlag = ETrue;
1.281 + }
1.282 +
1.283 + aMessage.Complete(KErrNone);
1.284 + }
1.285 +
1.286 +// -----------------------------------------------------------------------------
1.287 +// CTelephonyAudioRoutingServerSession::OutputChangeCompleteL
1.288 +// Used by policy session to indicate that the SetOutput request is complete.
1.289 +// (other items were commented in a header).
1.290 +// -----------------------------------------------------------------------------
1.291 +//
1.292 +void CTelephonyAudioRoutingServerSession::OutputChangeCompleteL(
1.293 + const RMessage2& aMessage)
1.294 + {
1.295 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::OutputChangeCompleteL "),this);
1.296 + TPckgBuf<CTelephonyAudioRouting::TAudioOutput> xPackage;
1.297 + aMessage.ReadL( 0, xPackage);
1.298 + CTelephonyAudioRouting::TAudioOutput audioOutput = xPackage();
1.299 +
1.300 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChangeComplete: AudioOutput = %d"), audioOutput);
1.301 +
1.302 + TPckgBuf<TInt> errPkg;
1.303 + aMessage.ReadL(1, errPkg);
1.304 + TInt err = errPkg();
1.305 +
1.306 + if (Server().CurrentAudioOutput() != CTelephonyAudioRouting::ENone)
1.307 + {
1.308 + Server().PreviousAudioOutput() = Server().CurrentAudioOutput();
1.309 +
1.310 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChangeComplete: iPreviousAudioOutput set to: %d"), Server().PreviousAudioOutput());
1.311 + }
1.312 +
1.313 + Server().CurrentAudioOutput() = audioOutput;
1.314 +
1.315 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChangeCompleteL: Server will be sent audioOutput = %d"), audioOutput);
1.316 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChangeCompleteL: previousAudioOutput = %d"), Server().PreviousAudioOutput());
1.317 + aMessage.Complete(KErrNone);
1.318 + Server().SetOutputCompleteL(audioOutput, err);
1.319 + }
1.320 +
1.321 +// -----------------------------------------------------------------------------
1.322 +// CTelephonyAudioRoutingServerSession::MonitorOutputChangeL
1.323 +// Used by policy session to listen to any SetOutput request from other sessions.
1.324 +// (other items were commented in a header).
1.325 +// -----------------------------------------------------------------------------
1.326 +//
1.327 +void CTelephonyAudioRoutingServerSession::MonitorOutputChangeL (
1.328 + const RMessage2& aMessage)
1.329 + {
1.330 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::MonitorOutputChangeL "),this);
1.331 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t Appending aMessage to iMessageArray. Current count = %d "),iMessageArray.Count());
1.332 +
1.333 + TRAPD(err, iMessageArray.AppendL(aMessage));
1.334 + if (err != KErrNone)
1.335 + {
1.336 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t MonitorOutputChangeL ERROR: %d "),err);
1.337 + PanicClient (aMessage, EPanicIllegalFunction);
1.338 + }
1.339 + }
1.340 +
1.341 +// -----------------------------------------------------------------------------
1.342 +// CTelephonyAudioRoutingServerSession::GetNoOfAvailableOutputs
1.343 +// Returns the number of available outputs to client-side session.
1.344 +// (other items were commented in a header).
1.345 +// -----------------------------------------------------------------------------
1.346 +//
1.347 +void CTelephonyAudioRoutingServerSession::GetNoOfAvailableOutputs (
1.348 + const RMessage2& aMessage)
1.349 + {
1.350 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::GetNoOfAvailableOutputs"),this);
1.351 + TPckgBuf<TInt> xPackage;
1.352 + xPackage() = (Server().AvailableOutputs()).Count();
1.353 +
1.354 + TInt res = aMessage.Write(0, xPackage);
1.355 + if (res != KErrNone)
1.356 + {
1.357 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t GetNoOfAvailableOutputs WRITE ERROR: %d"),res);
1.358 + PanicClient(aMessage, EPanicIllegalFunction);
1.359 + }
1.360 +
1.361 + else
1.362 + aMessage.Complete(KErrNone);
1.363 +
1.364 + }
1.365 +
1.366 +// -----------------------------------------------------------------------------
1.367 +// CTelephonyAudioRoutingServerSession::GetAvailableOutputsL
1.368 +// Returns the available audio outputs to client-side session.
1.369 +// (other items were commented in a header).
1.370 +// -----------------------------------------------------------------------------
1.371 +//
1.372 +void CTelephonyAudioRoutingServerSession::GetAvailableOutputsL (
1.373 + const RMessage2& aMessage)
1.374 + {
1.375 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::GetAvailableOutputsL "),this);
1.376 + TInt KBufExpandSize8 = 8;//two TInts
1.377 + CBufFlat* dataCopyBuffer = CBufFlat::NewL(KBufExpandSize8);
1.378 + CleanupStack::PushL(dataCopyBuffer);
1.379 + RBufWriteStream stream;
1.380 + stream.Open(*dataCopyBuffer);
1.381 + CleanupClosePushL(stream);
1.382 +
1.383 + // Write out server's available outputs to caller:
1.384 + CTelephonyAudioRouting::TAudioOutput output;
1.385 + TInt count = (Server().AvailableOutputs()).Count();
1.386 + for (TInt i=0;i<count;i++)
1.387 + {
1.388 + output = ( Server().AvailableOutputs() )[i];
1.389 + stream.WriteInt32L(output);
1.390 + }
1.391 + aMessage.WriteL(0, dataCopyBuffer->Ptr(0));
1.392 + stream.Close();
1.393 + CleanupStack::PopAndDestroy(2); // dataCopyBuffer, stream
1.394 +
1.395 + aMessage.Complete(KErrNone);
1.396 +
1.397 + }
1.398 +
1.399 +// -----------------------------------------------------------------------------
1.400 +// CTelephonyAudioRoutingServerSession::DoAvailableOutputsChangedL
1.401 +// Notify the client-side session that available outputs have changed.
1.402 +// (other items were commented in a header).
1.403 +// -----------------------------------------------------------------------------
1.404 +//
1.405 +void CTelephonyAudioRoutingServerSession::DoAvailableOutputsChangedL (
1.406 + const RMessage2& aMessage)
1.407 +{
1.408 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::DoAvailableOutputsChangedL"),this);
1.409 + TInt err(KErrNone);
1.410 + TBool validData(ETrue);
1.411 + TPckgBuf<TInt> count;
1.412 + TRAP(err,aMessage.ReadL( 0, count));
1.413 + if (err != KErrNone)
1.414 + {
1.415 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t DoAvailableOutputsChangedL(1) ERROR: %d "),err);
1.416 + PanicClient (aMessage, EPanicIllegalFunction);
1.417 + return;
1.418 + }
1.419 +
1.420 + if ((count() <0) || (count() > KMaxNumberOfOutputs))
1.421 + {
1.422 + validData = EFalse;
1.423 + iSessionAvailableOutputs.Reset();
1.424 + }
1.425 +
1.426 + if (validData)
1.427 + {
1.428 + HBufC8* buf = HBufC8::NewLC(count()*sizeof(CTelephonyAudioRouting::TAudioOutput));
1.429 + TPtr8 ptr = buf->Des();
1.430 +
1.431 + TRAP(err,aMessage.ReadL(1, ptr ));
1.432 + if (err != KErrNone)
1.433 + {
1.434 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t DoAvailableOutputsChangedL(2) ERROR: %d "),err);
1.435 + PanicClient (aMessage, EPanicIllegalFunction);
1.436 + return;
1.437 + }
1.438 +
1.439 + RDesReadStream stream(ptr);
1.440 + CleanupClosePushL(stream);
1.441 + iSessionAvailableOutputs.Reset();
1.442 + TInt element(0);
1.443 +
1.444 + for (TInt i=0; i<count(); i++)
1.445 + {
1.446 +
1.447 + TRAP(err, element = stream.ReadInt16L());
1.448 + if (err != KErrNone)
1.449 + {
1.450 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t DoAvailableOutputsChangedL(3) ERROR: %d "),err);
1.451 + PanicClient (aMessage, EPanicIllegalFunction);
1.452 + return;
1.453 + }
1.454 +
1.455 + err = iSessionAvailableOutputs.Append((CTelephonyAudioRouting::TAudioOutput)element);
1.456 + if (err)
1.457 + {
1.458 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t DoAvailableOutputsChangedL(4) ERROR: %d "),err);
1.459 + iSessionAvailableOutputs.Reset();
1.460 + PanicClient (aMessage, EPanicIllegalFunction);
1.461 + return;
1.462 + }
1.463 +
1.464 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t DoAvailableOutputsChanged: Avail Outputs to be sent to server: iSessionAvailableOutputs[i] = %d "),iSessionAvailableOutputs[i]);
1.465 + } // end For
1.466 +
1.467 + stream.Close();
1.468 + CleanupStack::PopAndDestroy(2); // buf, stream
1.469 +
1.470 + } // end if
1.471 +
1.472 + aMessage.Complete(KErrNone);
1.473 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t [%x]DoAvailableOutputsChangedL: calling Server::AvailableOutputsChanged"),this);
1.474 + Server().AvailableOutputsChangedL(iSessionAvailableOutputs.Array());
1.475 +}
1.476 +
1.477 +// -----------------------------------------------------------------------------
1.478 +// CTelephonyAudioRoutingServerSession::SetOutputComplete
1.479 +// Notifies the client-side session that the SetOutput request is complete.
1.480 +// (other items were commented in a header).
1.481 +// -----------------------------------------------------------------------------
1.482 +//
1.483 +void CTelephonyAudioRoutingServerSession::SetOutputComplete(
1.484 + CTelephonyAudioRouting::TAudioOutput aOutput,
1.485 + TInt aError,
1.486 + TBool aShowNote)
1.487 + {
1.488 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::SetOutputComplete "),this);
1.489 +
1.490 + TPckgBuf<CTelephonyAudioRouting::TAudioOutput> xPackage;
1.491 + xPackage() = aOutput;
1.492 +
1.493 +
1.494 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::SetOutputComplete: iPreviousAudioOutput Write out: %d"), Server().PreviousAudioOutput());
1.495 +
1.496 + TPckgBuf<CTelephonyAudioRouting::TAudioOutput> yPackage;
1.497 + yPackage() = Server().PreviousAudioOutput();
1.498 +
1.499 + TPckgBuf<TInt> errorPackage;
1.500 + errorPackage() = aError;
1.501 +
1.502 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::SetOutputComplete: ShowNote Val to pass to client: %d"), aShowNote);
1.503 + TPckgBuf<TBool> showNotePackage;
1.504 + showNotePackage() = aShowNote;
1.505 +
1.506 + TInt messageCount = iMessageArray.Count();
1.507 + TInt messageIndex = -1;
1.508 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t iMessageArrayCount = %d "),iMessageArray.Count());
1.509 +
1.510 + for(TInt i=0;i< messageCount; i++)
1.511 + {
1.512 + if(iMessageArray[i].Function()== ETelAudRtngServDoSetOutput)
1.513 + {
1.514 + messageIndex = i;
1.515 + break;
1.516 + }
1.517 + }
1.518 +
1.519 + if (messageIndex != -1)
1.520 + {
1.521 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t Current Index = %d "), messageIndex);
1.522 +
1.523 + TInt res = iMessageArray[messageIndex].Write(0, xPackage);
1.524 + TInt res2 = iMessageArray[messageIndex].Write(1, yPackage);
1.525 + TInt res3 = iMessageArray[messageIndex].Write(2, errorPackage);
1.526 + TInt res4 = iMessageArray[messageIndex].Write(3, showNotePackage);
1.527 +
1.528 + if ( (res != KErrNone) || (res2 != KErrNone) || (res3 != KErrNone) || (res4 != KErrNone))
1.529 + {
1.530 + PanicClient(iMessageArray[messageIndex], EPanicIllegalFunction);
1.531 + }
1.532 + else
1.533 + {
1.534 + iMessageArray[messageIndex].Complete(ETelAudRtngServSetOutputComplete);
1.535 + iMessageArray.Remove(messageIndex);
1.536 + }
1.537 + }
1.538 + }
1.539 +
1.540 +// -----------------------------------------------------------------------------
1.541 +// CTelephonyAudioRoutingServerSession::OutputChangeRequested
1.542 +// Notification that client is requesting to change audio output
1.543 +// (other items were commented in a header).
1.544 +// -----------------------------------------------------------------------------
1.545 +//
1.546 +void CTelephonyAudioRoutingServerSession::OutputChangeRequested(
1.547 + CTelephonyAudioRouting::TAudioOutput aOutput)
1.548 + {
1.549 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::OutputChangeRequested"),this);
1.550 +
1.551 + TPckgBuf<CTelephonyAudioRouting::TAudioOutput> xPackage;
1.552 + xPackage() = aOutput;
1.553 +
1.554 + TInt messageCount = iMessageArray.Count();
1.555 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t iMessageArrayCount = %d "),iMessageArray.Count());
1.556 +
1.557 + TInt messageIndex = -1;
1.558 +
1.559 + for(TInt i=0;i< messageCount; i++)
1.560 + {
1.561 + if(iMessageArray[i].Function()== ETelAudRtngServNotifyIfOutputChanged && !iPolicyFlag)
1.562 + {
1.563 + messageIndex=i;
1.564 + break;
1.565 + }
1.566 +
1.567 + if(iMessageArray[i].Function()== ETelAudRtngServMonitorOutputChange && iPolicyFlag)
1.568 + {
1.569 + messageIndex=i;
1.570 + break;
1.571 + }
1.572 + }
1.573 +
1.574 + if (messageIndex != -1) // Don't perform if message not found
1.575 + {
1.576 + TInt res = iMessageArray[messageIndex].Write(0, xPackage);
1.577 + if (res != KErrNone)
1.578 + {
1.579 + PanicClient(iMessageArray[messageIndex], EPanicIllegalFunction);
1.580 + }
1.581 +
1.582 + else
1.583 + {
1.584 + iMessageArray[messageIndex].Complete(ETelAudRtngServOutputChangeRequested);
1.585 + iMessageArray.Remove(messageIndex);
1.586 + }
1.587 + }
1.588 +#ifdef _DEBUG
1.589 + else
1.590 + {
1.591 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::OutputChangeRequested: ServerSession NOT Handling this msg! "),this);
1.592 + }
1.593 +#endif
1.594 +
1.595 + }
1.596 +
1.597 +// -----------------------------------------------------------------------------
1.598 +// CTelephonyAudioRoutingServerSession::OutputChangedL
1.599 +// Telephony Audio Routing Manager uses to notify TAR that policy has initiated an output change.
1.600 +// (other items were commented in a header).
1.601 +// -----------------------------------------------------------------------------
1.602 +//
1.603 +void CTelephonyAudioRoutingServerSession::OutputChangedL(
1.604 + const RMessage2& aMessage)
1.605 + {
1.606 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::OutputChangedL Enter"),this);
1.607 +
1.608 + TPckgBuf<CTelephonyAudioRouting::TAudioOutput> xPackage;
1.609 +
1.610 + aMessage.ReadL( 0, xPackage);
1.611 + CTelephonyAudioRouting::TAudioOutput audioOutput = xPackage();
1.612 +
1.613 + Server().PreviousAudioOutput() = Server().CurrentAudioOutput();
1.614 +
1.615 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChangedL: iCurrentAudioOutput was: %d"), Server().CurrentAudioOutput());
1.616 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChangedL: iPreviousAudioOutput set to: %d"), Server().PreviousAudioOutput());
1.617 +
1.618 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChangedL: iCurrentAudioOutput set to: %d"), audioOutput);
1.619 + Server().CurrentAudioOutput() = audioOutput;
1.620 + Server().SetShowNoteMode(ETrue); // Always set if output changes initiated by adaptation
1.621 +
1.622 + aMessage.Complete(KErrNone);
1.623 +
1.624 + // Server needs to send notification of output change to clients
1.625 + Server().OutputChanged(audioOutput);
1.626 +
1.627 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::OutputChangedL Exit"),this);
1.628 +
1.629 + }
1.630 +
1.631 +// -----------------------------------------------------------------------------
1.632 +// CTelephonyAudioRoutingServerSession::OutputChanged
1.633 +// Notification to be sent to all clients about the change of audio output.
1.634 +// (other items were commented in a header).
1.635 +// -----------------------------------------------------------------------------
1.636 +//
1.637 +void CTelephonyAudioRoutingServerSession::OutputChanged(
1.638 + CTelephonyAudioRouting::TAudioOutput aOutput,
1.639 + TBool aShowNote)
1.640 + {
1.641 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::OutputChanged"), this);
1.642 +
1.643 + TPckgBuf<CTelephonyAudioRouting::TAudioOutput> xPackage;
1.644 + TPckgBuf<CTelephonyAudioRouting::TAudioOutput> yPackage;
1.645 +
1.646 + TPckgBuf<TInt> errorPackage;
1.647 + errorPackage() = KErrNone;
1.648 +
1.649 + TPckgBuf<TBool> zPackage;
1.650 +
1.651 + xPackage() = aOutput;
1.652 +
1.653 + // Provide client with previous output value:
1.654 + CTelephonyAudioRouting::TAudioOutput prevOutput = Server().PreviousAudioOutput();
1.655 + yPackage() = prevOutput;
1.656 +
1.657 + // Provide client with showNote:
1.658 + zPackage() = aShowNote;
1.659 +
1.660 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChanged Current output: %d"), aOutput);
1.661 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChanged Previous output: %d"), yPackage());
1.662 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession::OutputChanged aShowNote: %d"), zPackage());
1.663 +
1.664 + TInt messageCount = iMessageArray.Count();
1.665 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t iMessageArrayCount = %d "),iMessageArray.Count());
1.666 +
1.667 + TInt messageIndex = -1;
1.668 +
1.669 + for(TInt i=0;i< messageCount; i++)
1.670 + {
1.671 + if(iMessageArray[i].Function()== ETelAudRtngServNotifyIfOutputChanged)
1.672 + {
1.673 + messageIndex = i;
1.674 + break;
1.675 + }
1.676 + }
1.677 +
1.678 + if (messageIndex != -1)
1.679 + {
1.680 + TInt res = iMessageArray[messageIndex].Write(0, xPackage);
1.681 + TInt res2 = iMessageArray[messageIndex].Write(1, yPackage);
1.682 + TInt res3 = iMessageArray[messageIndex].Write(2, errorPackage);
1.683 + TInt res4 = iMessageArray[messageIndex].Write(3, zPackage);
1.684 +
1.685 + if ( (res != KErrNone) || (res2 != KErrNone) || (res3 != KErrNone) || (res3 != KErrNone) )
1.686 + {
1.687 + PanicClient(iMessageArray[messageIndex], EPanicIllegalFunction);
1.688 + }
1.689 +
1.690 + else
1.691 + {
1.692 + iMessageArray[messageIndex].Complete(ETelAudRtngServOutputChanged);
1.693 + iMessageArray.Remove(messageIndex);
1.694 + }
1.695 + }
1.696 +#ifdef _DEBUG
1.697 + else
1.698 + {
1.699 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::OutputChanged: ServerSession NOT Handling this msg! "),this);
1.700 + }
1.701 +#endif
1.702 +
1.703 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::OutputChanged Exit"), this);
1.704 + }
1.705 +// -----------------------------------------------------------------------------
1.706 +// CTelephonyAudioRoutingServerSession::AvailableOutputsChanged
1.707 +// Notifies the client-side session that available audio outputs have changed.
1.708 +// (other items were commented in a header).
1.709 +// -----------------------------------------------------------------------------
1.710 +//
1.711 +void CTelephonyAudioRoutingServerSession::AvailableOutputsChanged(
1.712 + const TArray<CTelephonyAudioRouting::TAudioOutput>& aOutputs)
1.713 + {
1.714 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::AvailableOutputsChanged Enter "),this);
1.715 + TInt count = aOutputs.Count();
1.716 + iSessionAvailableOutputs.Reset();
1.717 +
1.718 + for(TInt i=0;i<count;i++)
1.719 + iSessionAvailableOutputs.Append(aOutputs[i]);
1.720 +
1.721 + TInt messageCount = iMessageArray.Count();
1.722 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t iMessageArrayCount = %d "),iMessageArray.Count());
1.723 +
1.724 + TInt messageIndex = -1;
1.725 +
1.726 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::AvailableOutputsChanged: Find msg "),this);
1.727 +
1.728 + for(TInt i=0;i< messageCount; i++)
1.729 + {
1.730 + if(iMessageArray[i].Function()== ETelAudRtngServNotifyIfAvailOutputsChanged)
1.731 + {
1.732 + messageIndex=i;
1.733 + break;
1.734 + }
1.735 + }
1.736 +
1.737 + if (messageIndex != -1) // Don't perform if message not found
1.738 + {
1.739 + iMessageArray[messageIndex].Complete(ETelAudRtngServAvailableOutputsChanged);
1.740 + iMessageArray.Remove(messageIndex);
1.741 + }
1.742 +
1.743 +#ifdef _DEBUG
1.744 + else
1.745 + {
1.746 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::AvailableOutputsChanged: ServerSession NOT Handling this msg! "),this);
1.747 + }
1.748 +#endif
1.749 +
1.750 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::AvailableOutputsChanged Exit "),this);
1.751 +
1.752 + }
1.753 +
1.754 +TInt CTelephonyAudioRoutingServerSession::SessionId()
1.755 + {
1.756 + return iSessionId;
1.757 + }
1.758 +
1.759 +// -----------------------------------------------------------------------------
1.760 +// CTelephonyAudioRoutingServerSession::GetDefaultValuesL
1.761 +// Gets default values from server for the client-side session
1.762 +// (other items were commented in a header).
1.763 +// -----------------------------------------------------------------------------
1.764 +//
1.765 +void CTelephonyAudioRoutingServerSession::GetDefaultValuesL(
1.766 + const RMessage2& aMessage)
1.767 + {
1.768 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingServerSession[%x]::GetDefaultValuesL "),this);
1.769 +
1.770 + TTelephonyAudioRoutingDefaultParams defaultParams;
1.771 +
1.772 + // Fill class with default values from server:
1.773 + defaultParams.iCurrentAudio = Server().CurrentAudioOutput();
1.774 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t GetDefaultValuesL: Current audio output = %d"),defaultParams.iCurrentAudio);
1.775 +
1.776 + defaultParams.iPreviousAudio = Server().PreviousAudioOutput();
1.777 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t GetDefaultValuesL: Previous audio output = %d"),defaultParams.iPreviousAudio);
1.778 +
1.779 + defaultParams.iShowNoteMode = Server().ShowNoteMode();
1.780 + TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t GetDefaultValuesL: Show Note Mode = %d"),defaultParams.iShowNoteMode);
1.781 +
1.782 + // Package default params and write out:
1.783 + TPckgBuf<TTelephonyAudioRoutingDefaultParams> defaultParamsPkg;
1.784 + defaultParamsPkg() = defaultParams;
1.785 + aMessage.WriteL(0, defaultParamsPkg);
1.786 + aMessage.Complete(KErrNone);
1.787 +
1.788 + }
1.789 +
1.790 +
1.791 +// End of file.