// Copyright (c) 2006-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 "mmfdevsoundserver.h"

 #include "mmfdevsoundserverstart.h"

 #include "mmfdevsoundsession.h"

 #include "mmfdevsoundserverconsts.h"

 const TInt KDevSoundShutDownDelay = 0; //no delay

 _LIT(KMMFDevSoundServerName, "MMFDevSoundServer-");

 // ======== LOCAL FUNCTIONS ========

 void Panic(TInt aPanicCode)

 	{

 	_LIT(KDevSoundServerPanicCategory, "mmfdevsoundserver");

 	User::Panic(KDevSoundServerPanicCategory, aPanicCode);

 	}

 /**

 	CMMFDevSoundServer* CMMFDevSoundServer::NewL

 	Two-phased constructor.

  */

 EXPORT_C CMMFDevSoundServer* CMMFDevSoundServer::NewL(

 	MGlobalProperties* aGlobalProperties,

 	TProcessId& aClientPID)

 	{

 	CMMFDevSoundServer* self = new(ELeave) CMMFDevSoundServer(aGlobalProperties,

 															aClientPID);

 	CleanupStack::PushL(self);

 	self->ConstructL();

 	CleanupStack::Pop(self);

 	return self;

 	}

 /**

  	CMMFDevSoundServer::CMMFDevSoundServer

 	C++ default constructor can NOT contain any code, that might leave.

  */

 CMMFDevSoundServer::CMMFDevSoundServer(

 	MGlobalProperties* aGlobalProperties,

 	TProcessId& aClientPID) :

 	CMmfIpcServer(EPriorityStandard, EGlobalSharableSessions),

 	iClientPID(aClientPID),

 	iActualClientPID(aClientPID)

 	{

 	iGlobalProperties = aGlobalProperties;

 	}

 /**

  	CMMFDevSoundServer::ConstructL

  	Symbian 2nd phase constructor can leave.

  */

 void CMMFDevSoundServer::ConstructL()

 	{

 	RProcess client;

 	User::LeaveIfError(client.Open(iClientPID));

 	client.Close();

 	iDelayDevSoundShutDown = CDelayDevSoundShutDown::NewL();

 	// Call base class to Start server

 	StartL(KNullDesC);

 	}

 /**

 	CMMFDevSoundServer::~CMMFDevSoundServer

 	Destructor

 */

 CMMFDevSoundServer::~CMMFDevSoundServer()

 	{

 	if (iDelayDevSoundShutDown)

 		{

 		iDelayDevSoundShutDown->Cancel();

 		delete iDelayDevSoundShutDown;

 		}

 	}

 /**

  	CMMFDevSoundServer::NewSessionL

  	Creates new session

  	(other items were commented in a header).

  */

 CMmfIpcSession* CMMFDevSoundServer::NewSessionL(const TVersion& aVersion) const

 	{

 	CMmfIpcSession* devSoundSession = NULL;

 	TRAPD(error, devSoundSession = CreateNewSessionL(aVersion));

 	if (error!=KErrNone)

 		{

 		// session create failed, so flag for subsequent destruction of server

 		CMMFDevSoundServer* mutableThis = const_cast<CMMFDevSoundServer*>(this);

 		mutableThis->CheckForNoSessionsLeft();

 		User::Leave(error);

 		}

 	return devSoundSession;

 	}

 /**

  	CMMFDevSoundServer::CreateNewSessionL

  	Guts of what would otherwise be in NewSessionL() itself

  */

 CMmfIpcSession* CMMFDevSoundServer::CreateNewSessionL(const TVersion& aVersion) const

 	{

 	TVersion version(KMMFDevSoundServerVersion,

 			KMMFDevSoundServerMinorVersionNumber,

 			KMMFDevSoundServerBuildVersionNumber);

 	if(!User::QueryVersionSupported(version, aVersion))

 		{

 		User::Leave(KErrNotSupported);

 		}

 	CMMFDevSoundSession* devSoundSession =

 					CMMFDevSoundSession::NewL(*iGlobalProperties);

 	return devSoundSession;

 	}

 /**

  	CMMFDevSoundServer::IncrementSessionId

  	Increments session count

  	(other items were commented in a header).

  */

 void CMMFDevSoundServer::IncrementSessionId()

 	{

 	iDevSoundSessionId++;

 	if (iDevSoundSessionId)

 		{

 		iDelayDevSoundShutDown->Cancel();

 		}

 	}

 /**

  	CMMFDevSoundServer::DecrementSessionId

  	Decrements session count

  	(other items were commented in a header).

  */

 void CMMFDevSoundServer::DecrementSessionId()

 	{

 	iDevSoundSessionId--;

 	CheckForNoSessionsLeft();

 	}

 /**

  	CMMFDevSoundServer::CheckForNoSessionsLeft

  	If no sessions are left, we kick off timer, which closes down server after timeout

  	really meaning the server closes asynchronously

  */

 void CMMFDevSoundServer::CheckForNoSessionsLeft()

 	{

 	if (iDevSoundSessionId == 0)

 		{

 		iDelayDevSoundShutDown->SetDelay(

 					TTimeIntervalMicroSeconds32(KDevSoundShutDownDelay));

 		}

 	}

 /**

  	CMMFDevSoundServer::SendEventToClient

  	For the session requested, send event to client

  	(other items were commented in a header).

  */

 void CMMFDevSoundServer::SendEventToClient(TInt aSessionToAlert,

 									TInt /*aSessionToBeLaunched*/)

 	{

 	iSessionIter.SetToFirst();

 	CMMFDevSoundSession* session =

 						static_cast<CMMFDevSoundSession*>(iSessionIter++);

 	while (session != NULL)

 		{

 		if (session->DevSoundSessionId() == aSessionToAlert)

 			{

 			break;  // Finished

 			}

 		session = static_cast<CMMFDevSoundSession*>(iSessionIter++);

 		}

 	}

 /**

  	CMMFDevSoundServer::LaunchRequest

  	Launches the DevSound servers waiting for Audio Policy.

  	(other items were commented in a header).

  */

 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++);

 		}

 	}

 void CMMFDevSoundServer::RenamePrioritizeServer()

 	{

 	//Rename devsound server name

 	RThread devsoundServerThread;

 	TThreadId threadId;

 	TName name;

 	name.Append(KMMFDevSoundServerName); 

 	threadId = devsoundServerThread.Id();

 	name.AppendNum(threadId.Id(),EHex);

 	//We are ignoring the error code returned from User::RenameThread

 	//as it is not important here, may be for profiling

 	User::RenameThread(name);

 	//Set the devsound priority

 	TThreadPriority devsoundServerPriority = static_cast<TThreadPriority>(KDevsoundServerPriority);

 	devsoundServerThread.SetPriority(devsoundServerPriority);

 	}

 /**

  	CMMFDevSoundServer* CMMFDevSoundServer::NewL

  	Two-phased constructor.

  */

 CMMFDevSoundServer::CDelayDevSoundShutDown*

 CMMFDevSoundServer::CDelayDevSoundShutDown::NewL()

 	{

 	CDelayDevSoundShutDown* self = new(ELeave) CDelayDevSoundShutDown;

 	CleanupStack::PushL(self);

 	self->ConstructL();

 	CleanupStack::Pop(self);

 	return self;

 	}

 /**

 	CMMFDevSoundServer::CDelayDevSoundShutDown::CDelayDevSoundShutDown

 	C++ constructor

 	(other items were commented in a header).

  */

 CMMFDevSoundServer::CDelayDevSoundShutDown::CDelayDevSoundShutDown()

 	: CActive(0)

 	{

 	}

 /**

  	CMMFDevSoundServer::CDelayDevSoundShutDown::ConstructL

  	Symbian 2nd phase constructor can leave.

  */

 void CMMFDevSoundServer::CDelayDevSoundShutDown::ConstructL()

 	{

 	User::LeaveIfError(iTimer.CreateLocal());

 	CActiveScheduler::Add(this);

 	}

 /**

  	CMMFDevSoundServer::CDelayDevSoundShutDown::~CDelayDevSoundShutDown

  	Destructor

  */

 CMMFDevSoundServer::CDelayDevSoundShutDown::~CDelayDevSoundShutDown()

 	{

 	Cancel();

 	iTimer.Close();

 	}

 /**

  	CMMFDevSoundServer::CDelayDevSoundShutDown::SetDelay

  	Request a timeout after aDelay

  	(other items were commented in a header).

  */

 void CMMFDevSoundServer::CDelayDevSoundShutDown::SetDelay(

 		TTimeIntervalMicroSeconds32 aDelay)

 	{

 	__ASSERT_ALWAYS(!IsActive(), Panic(EMMFDevSoundServerIsActive));

 	iTimer.After(iStatus, aDelay);

 	SetActive();

 	}

 /**

  	CMMFDevSoundServer::CDelayDevSoundShutDown::RunL

  	Called by Active object framework after timer expires

  	(other items were commented in a header).

  */

 void CMMFDevSoundServer::CDelayDevSoundShutDown::RunL()

 	{

 	CActiveScheduler::Stop();

 	}

 /**

  	CMMFDevSoundServer::CDelayDevSoundShutDown::DoCancel

  	Called by Active object framework when user cancels active object.

  	(other items were commented in a header).

  */

 void CMMFDevSoundServer::CDelayDevSoundShutDown::DoCancel()

 	{

 	iTimer.Cancel();

 	}

 /**

  	CMMFDevSoundServer::SetClientProcessIdL

  */

 void CMMFDevSoundServer::SetClientProcessIdL(TThreadId aTid)

 	{

 	RThread clientThread;

 	User::LeaveIfError(clientThread.Open(aTid));

 	CleanupClosePushL(clientThread);

 	RProcess clientProcess;

 	User::LeaveIfError(clientThread.Process(clientProcess));

 	CleanupClosePushL(clientProcess);

 	iActualClientPID = clientProcess.Id();

 	CleanupStack::PopAndDestroy(2, &clientThread);	// clientProcess, clientThread		

 	}

 //GLOBAL FUNCTIONS

 /**

  	This function raises a panic on the client of the DevSound Server

  	@param  aError

 			one of the several panic codes that may be raised by this dll on

 			the client

  	@panic  EMMFDevSoundPlayDataWithoutInitialize is raised when playdata is

 			called without initialization

  	@panic  EMMFDevSoundRecordDataWithoutInitialize is raised when recorddata

 			is called without initialization

  */

 GLDEF_C void PanicClient(const RMmfIpcMessage& aMessage,

 					TMMFDevSoundClientPanicCodes aPanicCode)

 	{

 	aMessage.Panic(KMMFDevSoundClientPanicCategory, aPanicCode);

 	}

 //  End of File