// 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 "MmfBtAudioServer.h"

#include "MmfBtAudioServerStart.h"

#include "MmfBtDevSoundSession.h"

#include "MmfBtAudioServerSession.h"

#include "MmfBtDevSoundServer.h"

#include "MmfBtDevSoundServerStart.h"

#include "../../../../inc/common/mmfBtBase.hrh"

static const TUid KUidDevSoundServer = {KUidMmfBtDevSoundServerDllUnicodeDefine};

const TInt KAudioServerShutDownDelay = 50000000; //50 sec

CMMFAudioServer* CMMFAudioServer::NewL()

	{

	CMMFAudioServer* s = new(ELeave) CMMFAudioServer();

	CleanupStack::PushL(s);

	s->ConstructL();

	CleanupStack::Pop();

	return s;

	}

CMMFAudioServer::CMMFAudioServer() :

	CMmfIpcServer(EPriorityStandard)

	{

	}

void CMMFAudioServer::ConstructL()

	{

	iDelayAudioServerShutDown = CDelayAudioServerShutDown::NewL();

	// Call base class to Start server

	StartL(KAudioServerName);

	}

CMMFAudioServer::~CMMFAudioServer()

	{

	if (iDelayAudioServerShutDown)

		{

		iDelayAudioServerShutDown->Cancel();

		delete iDelayAudioServerShutDown;

		}

	iDevSoundServList.Close();

	iPolicyServerHandle.Close();

	}

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

	{

	TVersion v(KMMFAudioServerVersion,KMMFAudioServerMinorVersionNumber,KMMFAudioServerBuildVersionNumber);

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

		User::Leave(KErrNotSupported);

	for(TInt i=0; i<iDevSoundServList.Count(); i++)

		{

		CStartAndMonitorDevSoundThread* devSoundMonitorThread = iDevSoundServList[i];

		if(!devSoundMonitorThread->IsActive())

			{

			iDevSoundServList.Remove(i);

			delete devSoundMonitorThread;

			}

		iDevSoundServList.Compress();

		}

	TName devSoundServerName;

	User::LeaveIfError(StartDevSoundServerL(devSoundServerName));

	CMMFAudioServerSession* audioServerSession = CMMFAudioServerSession::NewL(devSoundServerName);

	return audioServerSession;

	}

void CMMFAudioServer::IncrementSessionId()

	{

	iAudioServerSessionId++;

	}

void CMMFAudioServer::DecrementSessionId()

	{

	iAudioServerSessionId--;

	}

void CMMFAudioServer::IncrementDevSoundCount()

	{

	iDevSoundCount++;

	if(iDevSoundCount)

		iDelayAudioServerShutDown->Cancel(); //in the case we started the shutdown due to no more DevSound

	}

void CMMFAudioServer::DecrementDevSoundCount()

	{

	iDevSoundCount--;

    if ( iDevSoundCount == 0 )

		{

		iDelayAudioServerShutDown->SetDelay(TTimeIntervalMicroSeconds32(KAudioServerShutDownDelay));

 		}

	}

void CMMFAudioServer::SendEventToClient(TInt aSessionToAlert, TInt /*aSessionToBeLaunched*/)

	{

	// For the session requested, send event to client

	iSessionIter.SetToFirst();

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

	while (session != NULL)

		{

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

			{

			break;  // Finished

			}

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

		}

	}

void CMMFAudioServer::LaunchRequest(TInt aSessionId)

	{

	iSessionIter.SetToFirst();

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

	while (session != NULL)

		{

		if (session->AudioServerSessionId() == aSessionId)

			{

			break;  // Finished

			}

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

		}

	}

TInt CMMFAudioServer::StartDevSoundServerL(TName& aDevSoundName) const

	{

	RMessage2 message(Message());

	CStartAndMonitorDevSoundThread* monitorDevSound = NULL;

	TRAPD(err, monitorDevSound = CStartAndMonitorDevSoundThread::NewL(const_cast<CMMFAudioServer*>(this)));

	if(err != KErrNone)

		{

		delete monitorDevSound;

		return err;

		}

	iDevSoundServList.Append(monitorDevSound);

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

	mutableThis->iGlobalNum+=1;

	return monitorDevSound->StartDevSoundServerL(message, aDevSoundName, iGlobalNum);

	}

CMMFAudioServer::CDelayAudioServerShutDown* CMMFAudioServer::CDelayAudioServerShutDown::NewL()

	{

	CDelayAudioServerShutDown* self = new(ELeave) CDelayAudioServerShutDown;

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CMMFAudioServer::CDelayAudioServerShutDown::CDelayAudioServerShutDown() : CActive(0)

	{

	}

void CMMFAudioServer::CDelayAudioServerShutDown::ConstructL()

	{

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

	CActiveScheduler::Add(this);

	}

CMMFAudioServer::CDelayAudioServerShutDown::~CDelayAudioServerShutDown()

	{

	Cancel();

	iShutDownTimer.Close();

	}

void CMMFAudioServer::CDelayAudioServerShutDown::SetDelay(TTimeIntervalMicroSeconds32 aDelay)

	{

	__ASSERT_ALWAYS(!IsActive(), User::Panic(_L("CDelayedShutDown"), 1));

	iShutDownTimer.After(iStatus, aDelay);

	SetActive();

	}

void CMMFAudioServer::CDelayAudioServerShutDown::RunL()

	{

	CActiveScheduler::Stop();

	}

void CMMFAudioServer::CDelayAudioServerShutDown::DoCancel()

	{

	iShutDownTimer.Cancel();

	}

CStartAndMonitorDevSoundThread* CStartAndMonitorDevSoundThread::NewL(CMMFAudioServer* aAudioServer)

	{

	CStartAndMonitorDevSoundThread* self = new(ELeave) CStartAndMonitorDevSoundThread(aAudioServer);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

void CStartAndMonitorDevSoundThread::ConstructL()

	{

	CActiveScheduler::Add(this);

	}

TInt CStartAndMonitorDevSoundThread::StartDevSoundServerL(RMessage2& aMessage, TName& aDevSoundName, TInt aUniqueNum)

	{

	RThread clientThread;

	aMessage.ClientL(clientThread);

	RProcess clientProcess;

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

	TProcessId clientProcessId(clientProcess.Id());

	clientThread.Close();

	clientProcess.Close();

	TDevSoundServerStart start(iAudioServer, clientProcessId);//Pass to DevSoundServer the clien't process ID 

	const TUidType serverUid(KNullUid,KNullUid,KUidDevSoundServer);

	TThreadFunction serverFunc=CMMFDevSoundServer::StartThread;

	//

	// To deal with the unique thread (+semaphore!) naming in EPOC, and that we may

	// be trying to restart a server that has just exited we attempt to create a

	// unique thread name for the server.

	//

	TInt err = KErrNone;

	TName name(KDevSoundServerName);

	name.AppendNum(TInt(this),EHex);

	name.Append(TChar('.'));

	name.AppendNum(aUniqueNum,EHex);

	err = iServer.Create(name, serverFunc, KDevSoundServerStackSize,

	                	KDevSoundServerInitHeapSize, KDevSoundServerMaxHeapSize,

	                	&start, 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();

		}

	aDevSoundName = iServer.Name();

	iServer.Logon(iStatus);

	SetActive();

	iAudioServer->IncrementDevSoundCount();

	return KErrNone;

	}

CStartAndMonitorDevSoundThread::CStartAndMonitorDevSoundThread(CMMFAudioServer* aAudioServer): CActive(0)

	{

	iAudioServer = aAudioServer;

	}

CStartAndMonitorDevSoundThread::~CStartAndMonitorDevSoundThread()

	{

	Cancel();

	}

void CStartAndMonitorDevSoundThread::RunL()

	{

	iServer.Close();

	iAudioServer->DecrementDevSoundCount();

	}

void CStartAndMonitorDevSoundThread::DoCancel()

	{

	iServer.LogonCancel(iStatus);

	}