sl@0: /* sl@0: * Copyright (c) 2002-2004 Nokia Corporation and/or its subsidiary(-ies). sl@0: * All rights reserved. sl@0: * This component and the accompanying materials are made available sl@0: * under the terms of "Eclipse Public License v1.0" sl@0: * which accompanies this distribution, and is available sl@0: * at the URL "http://www.eclipse.org/legal/epl-v10.html". sl@0: * sl@0: * Initial Contributors: sl@0: * Nokia Corporation - initial contribution. sl@0: * sl@0: * Contributors: sl@0: * sl@0: * Description: This class is the main interface to the TelephonyAudioRoutingServer. sl@0: * : Specifically handles TelephonyAudioRoutingManager sessions. sl@0: * sl@0: */ sl@0: sl@0: sl@0: sl@0: #include sl@0: #include sl@0: #include "TelephonyAudioRoutingClientServer.h" sl@0: #include "TelephonyAudioRoutingManagerSession.h" sl@0: #include "TelephonyAudioRoutingPolicyRequest.h" sl@0: sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingManagerSession::RTelephonyAudioRoutingManagerSession sl@0: // C++ default constructor can NOT contain any code, that sl@0: // might leave. sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C RTelephonyAudioRoutingManagerSession::RTelephonyAudioRoutingManagerSession() sl@0: : RSessionBase(), iConnected(EFalse) sl@0: { sl@0: // No implementation required sl@0: sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingSession::Connect sl@0: // Connects a policy client to the server. sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C TInt RTelephonyAudioRoutingManagerSession::Connect( sl@0: CTelephonyAudioRoutingManager& aAudioRoutingManager, sl@0: MTelephonyAudioRoutingPolicyObserver& aPolicyObserver) sl@0: { sl@0: sl@0: TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::Connect")); sl@0: sl@0: TInt retry=2; sl@0: TInt err = KErrGeneral; sl@0: sl@0: for (;;) sl@0: { sl@0: err=CreateSession(KTelAudRtngServName,TVersion(0,0,0)); // RSessionBase::CreateSession sl@0: sl@0: if (err!=KErrNotFound && err!=KErrServerTerminated && err!=KErrPermissionDenied) sl@0: break; sl@0: sl@0: if (--retry==0) sl@0: break; sl@0: } sl@0: sl@0: if ( err == KErrNone ) sl@0: { sl@0: // Create active object receive handlers and add it to scheduler sl@0: TRAP(err, StartPolicyRequestHandlersL(aAudioRoutingManager, aPolicyObserver)); sl@0: if ( err == KErrNone ) sl@0: { sl@0: iConnected = ETrue; sl@0: } sl@0: sl@0: SendReceive(ETelAudRtngServInitialize, TIpcArgs()); sl@0: sl@0: } sl@0: sl@0: return err; sl@0: sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingManagerSession::Close sl@0: // Closes connection to the server. sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C void RTelephonyAudioRoutingManagerSession::Close() sl@0: { sl@0: TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::Close")); sl@0: if ( iConnected ) sl@0: { sl@0: sl@0: delete iPolicyRequest; sl@0: RSessionBase::Close(); sl@0: iConnected = EFalse; sl@0: sl@0: sl@0: } sl@0: sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingManagerSession::OutputChangeCompleted sl@0: // Used by policy to notify server that requested output change completed sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C void RTelephonyAudioRoutingManagerSession::OutputChangeCompleted( sl@0: CTelephonyAudioRouting::TAudioOutput aOutput, sl@0: TInt aError) sl@0: { sl@0: TPckgBuf audioOutputPkg; sl@0: audioOutputPkg() = aOutput; sl@0: TPckgBuf errPkg; sl@0: errPkg() = aError; sl@0: sl@0: TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::OutputChangeCompleted to %d"), aOutput); sl@0: SendReceive(ETelAudRtngServOutputChangeComplete, TIpcArgs(&audioOutputPkg, &errPkg)); sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingManagerSession::OutputChanged sl@0: // Used by policy to notify server of audio output changes initiated by policy. sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C void RTelephonyAudioRoutingManagerSession::OutputChanged( sl@0: CTelephonyAudioRouting::TAudioOutput aOutput) sl@0: { sl@0: TPckgBuf audioOutputPkg; sl@0: audioOutputPkg() = aOutput; sl@0: // iAudioOutput = aOutput; sl@0: TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::OutputChanged to %d"), aOutput); sl@0: SendReceive(ETelAudRtngServOutputChangedByPolicy, TIpcArgs(&audioOutputPkg)); sl@0: sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingManagerSession::AvailableOutputsChangedL sl@0: // Used by policy session to notify server if the available audio output change. sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C void RTelephonyAudioRoutingManagerSession::AvailableOutputsChangedL( sl@0: const TArray& aOutputs) sl@0: { sl@0: TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::AvailableOutputsChangedL")); sl@0: TPckgBuf numOfOutputs; sl@0: numOfOutputs()= aOutputs.Count(); sl@0: sl@0: TInt count = aOutputs.Count(); sl@0: TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t AvailableOutputsChangedL: Count = %d "),count); sl@0: for(TInt i = 0; i < count; i++) sl@0: { sl@0: TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t AvailableOutputsChangedL: aOutputs[i] = %d "),aOutputs[i]); sl@0: } sl@0: sl@0: TInt KBufExpandSize8 = 8;//two TInts sl@0: CBufFlat* dataCopyBuffer = CBufFlat::NewL(KBufExpandSize8); sl@0: CleanupStack::PushL(dataCopyBuffer); sl@0: RBufWriteStream stream; sl@0: stream.Open(*dataCopyBuffer); sl@0: CleanupClosePushL(stream); sl@0: sl@0: for (TInt i=0;iPtr(0); sl@0: sl@0: SendReceive(ETelAudRtngDoAvailableOutputsChanged, TIpcArgs(&numOfOutputs, &ptr)); sl@0: stream.Close(); sl@0: CleanupStack::PopAndDestroy(2);//stream, buf sl@0: sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingManagerSession::SetPolicySessionIdL sl@0: // Sets policy session Id. sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C void RTelephonyAudioRoutingManagerSession::SetPolicySessionIdL() sl@0: { sl@0: User::LeaveIfError(SendReceive(ETelAudRtngServSetPolicySessionId, TIpcArgs())); sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingManagerSession::MonitorOutputChangeRequest sl@0: // Used by policy session to get notification whenever any of the clients sends sl@0: // a SetOutput request. sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C void RTelephonyAudioRoutingManagerSession::MonitorOutputChangeRequest() sl@0: { sl@0: TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::MonitorOutputChangeRequest ")); sl@0: sl@0: iPolicyRequest->Cancel(); sl@0: sl@0: SendReceive(ETelAudRtngServMonitorOutputChange, TIpcArgs(&iAudioOutputPkg), iPolicyRequest->iStatus); sl@0: iPolicyRequest->SetActive(); sl@0: sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingManagerSession::CancelRequest sl@0: // Cancel a previously send request. sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C void RTelephonyAudioRoutingManagerSession::CancelRequest(TTelAudRtngServRqst aRequest) sl@0: { sl@0: TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::CancelRequest ")); sl@0: TPckgBuf request; sl@0: request() = aRequest; sl@0: SendReceive(ETelAudRtngServCancelRequest, TIpcArgs(&request)); sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingSession::AudioOutputPkg sl@0: // Accessor method returns iAudioOutputPkg to caller. sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: EXPORT_C TPckgBuf& RTelephonyAudioRoutingManagerSession::AudioOutputPkg() sl@0: { sl@0: return iAudioOutputPkg; sl@0: } sl@0: sl@0: // ----------------------------------------------------------------------------- sl@0: // RTelephonyAudioRoutingManagerSession::StartPolicyRequestHandlersL sl@0: // Start asynchronous request handlers. sl@0: // (other items were commented in a header). sl@0: // ----------------------------------------------------------------------------- sl@0: // sl@0: void RTelephonyAudioRoutingManagerSession::StartPolicyRequestHandlersL( sl@0: CTelephonyAudioRoutingManager& aAudioRoutingManager, sl@0: MTelephonyAudioRoutingPolicyObserver& aPolicyObserver ) sl@0: { sl@0: iPolicyRequest = CTelephonyAudioRoutingPolicyRequest::NewL(*this, aPolicyObserver, aAudioRoutingManager, ETelAudRtngServMonitorOutputChange); sl@0: }