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