/*
* 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