--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/devsoundextensions/telephonyaudiorouting/TelephonyAudioRoutingManager/src/TelephonyAudioRoutingManager.cpp	Tue Feb 02 01:56:55 2010 +0200
@@ -0,0 +1,192 @@
+/*
+* 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