// 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 "MmfAudioPolicyServer.h"
#include "MmfAudioPolicyStart.h"
#include "MmfAudioPolicySession.h"


#if defined(_DEBUG) && defined(__WINS__)
	const TInt KTimeOutInterval =2*1000000;  // 2 seconds
#else
	const TInt KTimeOutInterval =1000000;	// 1 second
#endif

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, const TMMFAudioPolicyEvent& aEvent)
	{
// For the session requested, send event to client
	iSessionIter.SetToFirst();
	CMMFAudioPolicySession* session = static_cast<CMMFAudioPolicySession*>(iSessionIter++);
	ASSERT(session != NULL);
	do
		{
		if (session->PolicySessionId() == aSessionToAlert)
			{
			session->SendEventToClient(aEvent);
			return;  // Finished
			}
		session = static_cast<CMMFAudioPolicySession*>(iSessionIter++);
		} while (session != NULL);
	ASSERT(EFalse); // invalid session Id
	}
	
void CMMFAudioPolicyServer::LaunchRequest(TInt aSessionId,const TMMFAudioPolicyEvent& aEvent)
	{
	SendEventToClient(aSessionId, aEvent);
	}

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(TBool aZeroDelay)
	{
	iNotificationTimer->After(aZeroDelay? 0 : KTimeOutInterval);
	}
	
void CMMFAudioPolicyServer::StopNotificationTimer()
	{
	iNotificationTimer->Cancel();			
	}

TInt CMMFAudioPolicyServer::SendNotification(TAny* aAny)
	{
	CMMFAudioPolicyServer* policyServer = reinterpret_cast<CMMFAudioPolicyServer*>(aAny);
	policyServer->iAudioPolicy->NotifyNextClient();
	return KErrNone;
	}

TBool CMMFAudioPolicyServer::IsTimerActive() const 
	{
	return iNotificationTimer->IsActive();
	}