/*

 * Copyright (c) 2006 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:   Methods for CTelephonyAudioRoutingManager class

 *

 */

 // INCLUDE FILES

 #include <e32base.h>

 #include <e32svr.h>

 #include <e32std.h>

 #include "TelephonyAudioRoutingManager.h"

 #include "TelephonyAudioRoutingClientServer.h"

 #include "TelephonyAudioRoutingServer.h"

 #include "TelephonyAudioRoutingManagerSession.h"

 const TUid KTelAudRtngServerUid = {0x10207A93};

 const TInt KTelAudRtngServerStackSize=0x2000;			//  8KB

 const TInt KTelAudRtngServerInitHeapSize=0x1000;		//  4KB

 const TInt KTelAudRtngServerMaxHeapSize=0x1000000;		// 16MB

 // ================= MEMBER FUNCTIONS =======================

 // C++ default constructor can NOT contain any code, that

 // might leave.

 //

 CTelephonyAudioRoutingManager::CTelephonyAudioRoutingManager(

 	MTelephonyAudioRoutingPolicyObserver& aObserver)

 	: iObserver(aObserver)

     {

     }

 // -----------------------------------------------------------------------------

 // CAudioOutputProxy::ConstructL

 // Symbian 2nd phase constructor can leave.

 // -----------------------------------------------------------------------------

 //

 void CTelephonyAudioRoutingManager::ConstructL(

 const TArray<CTelephonyAudioRouting::TAudioOutput>& aArray)

 	{

 	TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingManager::ConstructL "));

 	User::LeaveIfError(StartServer());

 	iMgrSession = new (ELeave)RTelephonyAudioRoutingManagerSession;

 	User::LeaveIfError(iMgrSession->Connect(*this, iObserver));

 	iMgrSession->SetPolicySessionIdL();	

 	iMgrSession->MonitorOutputChangeRequest();

 	iMgrSession->AvailableOutputsChangedL(aArray); 

 	}

 // Two-phased constructor.

 EXPORT_C CTelephonyAudioRoutingManager* CTelephonyAudioRoutingManager::NewL(

 MTelephonyAudioRoutingPolicyObserver& aObserver,

 const TArray<CTelephonyAudioRouting::TAudioOutput>& aArray)

     {

 	CTelephonyAudioRoutingManager* self = new(ELeave) CTelephonyAudioRoutingManager(aObserver);

 	CleanupStack::PushL(self);

 	self->ConstructL(aArray);

 	CleanupStack::Pop(self);

 	return self;

     }

 // Destructor

 CTelephonyAudioRoutingManager::~CTelephonyAudioRoutingManager()

     { 

 	TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingManager::~CTelephonyAudioRoutingManager "));    

     if (iMgrSession) 

         {

         iMgrSession->Close();        

         }

     delete iMgrSession;

     iServer.Close();

     }

 // ---------------------------------------------------------

 // CAudioOutput::OutputChanged

 // Policy is sending out notification that the output has changed 

 // (a change initiated by policy)

 // (other items were commented in a header).

 // ---------------------------------------------------------

 //

 EXPORT_C void CTelephonyAudioRoutingManager::OutputChanged(CTelephonyAudioRouting::TAudioOutput aOutput)

 	{

 	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingManager::OutputChanged to: %d"), aOutput);	

     iMgrSession->OutputChanged(aOutput);

 	}

 // ---------------------------------------------------------

 // CAudioOutput::AvailableOutputsChanged

 // Policy is sending out notification that the available outputs have changed

 // (other items were commented in a header).

 // ---------------------------------------------------------

 //

 EXPORT_C void CTelephonyAudioRoutingManager::AvailableOutputsChanged(const TArray<CTelephonyAudioRouting::TAudioOutput>& aArray)

 	{

 	TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingManager::AvailableOutputsChanged "));

     TRAPD(err,iMgrSession->AvailableOutputsChangedL(aArray));

    	if (err != KErrNone)

 		{

 		TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingManager::AvailableOutputsChanged: ERROR from Adaptation: %d "), err);			

 		}		

 	}

 // ---------------------------------------------------------

 // CAudioOutput::OutputChangeRequestCompleted

 // Policy is sending out notification that the request change in output has been completed

 // (other items were commented in a header).

 // ---------------------------------------------------------

 //	

 EXPORT_C void CTelephonyAudioRoutingManager::OutputChangeRequestCompleted(CTelephonyAudioRouting::TAudioOutput aOutput, TInt aError)

 	{

 	TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingManager::OutputChangeRequestCompleted "));	

 	if (aError != KErrNone)

 	{

 		TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingManager::OutputChangeRequestCompleted: ERROR from Adaptation: %d "), aError);			

 	}

     iMgrSession->OutputChangeCompleted(aOutput, aError);

 	}

 // -----------------------------------------------------------------------------

 // CStartTelephonyAudioRoutingServer::StartServer

 // Start TelephonyAudioRouting Server

 // (other items were commented in a header).

 // -----------------------------------------------------------------------------

 //	

 TInt CTelephonyAudioRoutingManager::StartServer()                                                                        

     {       

     TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingManager::StartServer "));

 	const TUidType serverUid(KNullUid,KNullUid,KTelAudRtngServerUid);

 	TThreadFunction serverFunc=CTelephonyAudioRoutingServer::StartThreadL;

 	TInt err(KErrNone);

 	TName name(KTelAudRtngServName);

 	err = iServer.Create(name, serverFunc, KTelAudRtngServerStackSize,

 	        	KTelAudRtngServerInitHeapSize, KTelAudRtngServerMaxHeapSize,

 	        	/*&start*/ NULL, EOwnerProcess);

 	if(err != KErrNone)

 		return err;

 	// Synchronise with the server

 	TRequestStatus reqStatus;

 	iServer.Rendezvous(reqStatus);

 	if (reqStatus!=KRequestPending)

 		{

 		iServer.Kill(0);

 		}

 	else

 		{

 		// Start the test harness

 		iServer.Resume();

 		// Server will call the reciprocal static synchronise call	

 		}

 	User::WaitForRequest(reqStatus); // wait for start or death

 	if(reqStatus.Int() != KErrNone)

 		{

 		iServer.Close();

 		return reqStatus.Int();

 		}

 	return KErrNone;

     }    

 // End of File