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

#include "MmfBtAudioPolicyStart.h"

#include "MmfBtAudioPolicySession.h"

const TInt KTimeOutInterval = 1000000;

CMMFAudioPolicyServer* CMMFAudioPolicyServer::NewL()

	{

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

	CleanupStack::PushL(s);

	s->ConstructL();

	CleanupStack::Pop();

	return s;

	}

CMMFAudioPolicyServer::CMMFAudioPolicyServer() :

	CMmfIpcServer(EPriorityStandard)

	{

	}

void CMMFAudioPolicyServer::ConstructL()

	{

	// Create AudioPolicy singleton

	iAudioPolicy = CAudioPolicy::NewL(this);

	TCallBack callBack(SendNotification,this);

	iNotificationTimer = CNotificationTimer::NewL(callBack);

	// Call base class to Start server

	StartL(KNullDesC);

	}

CMMFAudioPolicyServer::~CMMFAudioPolicyServer()

	{

	if(iNotificationTimer != NULL)

		{

		StopNotificationTimer();

		}

	delete iAudioPolicy;

	delete iNotificationTimer;

	}

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

	{

	TVersion v(KMMFAudioPolicyVersion,KMMFAudioPolicyMinorVersionNumber,KMMFAudioPolicyBuildVersionNumber);

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

		User::Leave(KErrNotSupported);

	CMMFAudioPolicySession* aAudioPolicySession = CMMFAudioPolicySession::NewL();

	return aAudioPolicySession;

	}

void CMMFAudioPolicyServer::IncrementSessionId()

	{

	iPolicySessionId++;

	}

void CMMFAudioPolicyServer::SendEventToClient(TInt aSessionToAlert, TInt /*aSessionToBeLaunched*/, TMMFAudioPolicyEvent& aEvent)

	{

	TMMFAudioPolicyEvent eventForClient;

	eventForClient.iEventType = aEvent.iEventType;

	eventForClient.iErrorCode = aEvent.iErrorCode;

	eventForClient.iState = aEvent.iState;

	// For the session requested, send event to client

	iSessionIter.SetToFirst();

	CMMFAudioPolicySession* session = STATIC_CAST(CMMFAudioPolicySession*, iSessionIter++);

	while (session != NULL)

		{

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

			{

			session->SendEventToClient(eventForClient);

			break;  // Finished

			}

		session = STATIC_CAST(CMMFAudioPolicySession*, iSessionIter++);

		}

	}

void CMMFAudioPolicyServer::LaunchRequest(TInt aSessionId, TMMFAudioPolicyEvent& aEvent)

	{

	iSessionIter.SetToFirst();

	CMMFAudioPolicySession* session = STATIC_CAST(CMMFAudioPolicySession*, iSessionIter++);

	while (session != NULL)

		{

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

			{

			session->SendEventToClient(aEvent);

			break;  // Finished

			}

		session = STATIC_CAST(CMMFAudioPolicySession*, iSessionIter++);

		}

	}

void CMMFAudioPolicyServer::IncrementSessionCount()

	{

	iPolicySessionCount++;

	}

CMMFAudioPolicyServer::CNotificationTimer *CMMFAudioPolicyServer::CNotificationTimer::NewL(TCallBack aCallBack)	

	{

	CNotificationTimer* self = new(ELeave) CNotificationTimer(aCallBack);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(); // self

	return self;

	}

CMMFAudioPolicyServer::CNotificationTimer::CNotificationTimer(TCallBack aCallBack)

: CTimer(EPriorityHigh),iCallBack(aCallBack)

	{

	CActiveScheduler::Add(this);

	}

void CMMFAudioPolicyServer::CNotificationTimer::RunL()

	{

	iCallBack.CallBack();

	}

void CMMFAudioPolicyServer::DecrementSessionCount()

	{

	iPolicySessionCount--;

	}

TInt CMMFAudioPolicyServer::PolicySessionCount() 

	{

	return iPolicySessionCount;

	}

void CMMFAudioPolicyServer::StartNotificationTimer()

	{

	iNotificationTimer->After(KTimeOutInterval);

	}

void CMMFAudioPolicyServer::StopNotificationTimer()

	{

	iNotificationTimer->Cancel();			

	}

TInt CMMFAudioPolicyServer::SendNotification(TAny* aAny)

	{

	CMMFAudioPolicyServer* policyServer = reinterpret_cast<CMMFAudioPolicyServer*>(aAny);

	policyServer->iAudioPolicy->DoSendNotification();

	return KErrNone;

	}

TBool CMMFAudioPolicyServer::IsTimerActive() const 

	{

	return iNotificationTimer->IsActive();

	}