devsound/sounddevbt/PlatSec/src/Server/AudioServer/MmfBtDevSoundServer.cpp
changeset 0 40261b775718
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/devsound/sounddevbt/PlatSec/src/Server/AudioServer/MmfBtDevSoundServer.cpp	Tue Feb 02 01:56:55 2010 +0200
@@ -0,0 +1,199 @@
+// Copyright (c) 2004-2009 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:
+//
+
+#include <e32math.h>
+#include "MmfBtDevSoundServer.h"
+#include "MmfBtDevSoundServerStart.h"
+#include "MmfBtDevSoundSession.h"
+
+const TInt KDevSoundShutDownDelay = 0; //0 sec
+
+EXPORT_C CMMFDevSoundServer* CMMFDevSoundServer::NewL(CMMFAudioServer* aAudioServer, TProcessId& aClientPID)
+	{
+	CMMFDevSoundServer* s = new(ELeave) CMMFDevSoundServer(aAudioServer, aClientPID);
+	CleanupStack::PushL(s);
+	s->ConstructL();
+	CleanupStack::Pop();
+	return s;
+	}
+
+CMMFDevSoundServer::CMMFDevSoundServer(CMMFAudioServer* aAudioServer, TProcessId& aClientPID) :
+	CMmfIpcServer(EPriorityStandard), iClientPID(aClientPID)
+	{
+	iAudioServer = aAudioServer;
+	}
+
+void CMMFDevSoundServer::ConstructL()
+	{
+	RProcess client;
+	User::LeaveIfError(client.Open(iClientPID));
+	iClientHasCaps = client.HasCapability(ECapabilityMultimediaDD, KSuppressPlatSecDiagnostic);
+	client.Close();
+
+	iDelayDevSoundShutDown = CDelayDevSoundShutDown::NewL();
+
+	// Call base class to Start server
+	TName name(RThread().Name());
+	StartL(name);
+	}
+
+CMMFDevSoundServer::~CMMFDevSoundServer()
+	{
+	if (iDelayDevSoundShutDown)
+		{
+		iDelayDevSoundShutDown->Cancel();
+		delete iDelayDevSoundShutDown;
+		}
+	}
+
+CMmfIpcSession* CMMFDevSoundServer::NewSessionL(const TVersion& aVersion) const
+	{
+	RMessage2 message(Message());
+	RThread clientThread;
+	message.ClientL(clientThread);
+	RProcess clientProcess;
+	User::LeaveIfError(clientThread.Process(clientProcess));
+
+	TProcessId clientProcessID(clientProcess.Id());
+	clientThread.Close();
+	clientProcess.Close();
+
+	if(iClientPID != clientProcessID)
+		{
+		User::Leave(KErrAccessDenied);
+		}
+
+
+	TVersion v(KMMFDevSoundServerVersion,KMMFDevSoundServerMinorVersionNumber,KMMFDevSoundServerBuildVersionNumber);
+	if(!User::QueryVersionSupported(v, aVersion))
+		User::Leave(KErrNotSupported);
+	
+	CMMFDevSoundSession* devSoundSession = CMMFDevSoundSession::NewL(iAudioServer->PolicyServerHandle());
+	return devSoundSession;
+	}
+
+void CMMFDevSoundServer::IncrementSessionId()
+	{
+	iDevSoundSessionId++;
+	if(iDevSoundSessionId)
+		iDelayDevSoundShutDown->Cancel();
+
+	}
+
+void CMMFDevSoundServer::DecrementSessionId()
+	{
+	iDevSoundSessionId--;
+    if ( iDevSoundSessionId == 0 )
+		{
+		iDelayDevSoundShutDown->SetDelay(TTimeIntervalMicroSeconds32(KDevSoundShutDownDelay));
+ 		}
+	}
+
+void CMMFDevSoundServer::SendEventToClient(TInt aSessionToAlert, TInt /*aSessionToBeLaunched*/)
+	{
+	// For the session requested, send event to client
+	iSessionIter.SetToFirst();
+	CMMFDevSoundSession* session = static_cast<CMMFDevSoundSession*>(iSessionIter++);
+	while (session != NULL)
+		{
+		if (session->DevSoundSessionId() == aSessionToAlert)
+			{
+			break;  // Finished
+			}
+		session = static_cast<CMMFDevSoundSession*>(iSessionIter++);
+		}
+	}
+
+void CMMFDevSoundServer::LaunchRequest(TInt aSessionId)
+	{
+	iSessionIter.SetToFirst();
+	CMMFDevSoundSession* session = static_cast<CMMFDevSoundSession*>(iSessionIter++);
+	while (session != NULL)
+		{
+		if (session->DevSoundSessionId() == aSessionId)
+			{
+			break;  // Finished
+			}
+		session = static_cast<CMMFDevSoundSession*>(iSessionIter++);
+		}
+	}
+
+TBool CMMFDevSoundServer::CheckClientCapabilities()
+	{
+	return iClientHasCaps;
+	}
+
+void CMMFDevSoundServer::SetClientCapabilitiesL(TThreadId aTid)
+	{
+	RThread clientThread;
+	User::LeaveIfError(clientThread.Open(aTid));
+	CleanupClosePushL(clientThread);
+	
+	RProcess clientProcess;
+	User::LeaveIfError(clientThread.Process(clientProcess));
+	CleanupClosePushL(clientProcess);
+	
+	iClientHasCaps = clientProcess.HasCapability(ECapabilityMultimediaDD, KSuppressPlatSecDiagnostic);
+	
+	CleanupStack::PopAndDestroy(2, &clientThread);	// clientProcess, clientThread
+	}
+
+CMMFDevSoundServer::CDelayDevSoundShutDown* CMMFDevSoundServer::CDelayDevSoundShutDown::NewL()
+	{
+	CDelayDevSoundShutDown* self = new(ELeave) CDelayDevSoundShutDown;
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	CleanupStack::Pop();
+	return self;
+	}
+
+CMMFDevSoundServer::CDelayDevSoundShutDown::CDelayDevSoundShutDown() : CActive(0)
+	{
+	}
+        
+void CMMFDevSoundServer::CDelayDevSoundShutDown::ConstructL()
+	{
+	User::LeaveIfError(iTimer.CreateLocal());
+	CActiveScheduler::Add(this);
+	}
+
+CMMFDevSoundServer::CDelayDevSoundShutDown::~CDelayDevSoundShutDown()
+	{
+	Cancel();
+	iTimer.Close();
+	}
+
+
+void CMMFDevSoundServer::CDelayDevSoundShutDown::SetDelay(TTimeIntervalMicroSeconds32 aDelay)
+	{
+	__ASSERT_ALWAYS(!IsActive(),
+	User::Panic(_L("CDelayedShutDown"), 1));
+	iTimer.After(iStatus, aDelay);
+	SetActive();
+	}
+
+void CMMFDevSoundServer::CDelayDevSoundShutDown::RunL()
+	{
+	CActiveScheduler::Stop();
+	}
+
+void CMMFDevSoundServer::CDelayDevSoundShutDown::DoCancel()
+	{
+	iTimer.Cancel();
+	}
+  
+
+        
+