// 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();

	}