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

CSessionNotifier::CSessionNotifier() :
	iIdReportingOn(ETrue), iRequests(KArrayGranularity, _FOFF(SRequest, id))
	{
	}

CSessionNotifier::~CSessionNotifier()
	{
	CancelAllRequests();
	}

void CSessionNotifier::Notify(TUint32 aId)
	{
	SRequest s;
	s.id = aId;

	// Check if iIdReportingOn is True. If  it's false return KUnspecifiedKey, otherwise return
	// the individual key. One exception to this is where the individual key is KRequestPending.
	// To prevent problems in AO's using key notifications KUnspecifiedKey will be returned to
	// notify for changes to this key.
	TUint32 reportedId = (iIdReportingOn  && (aId != static_cast<TUint32>(KRequestPending))) ? aId : KUnspecifiedKey;
	
	TInt i = iRequests.FindInUnsignedKeyOrder(s);
	if(i>=0)
		{
		iRequests[i].msg.Complete(reportedId);
		iRequests.Remove(i);
		}

	for(i=iGroupRequests.Count()-1; i>=0; i--)
		{
		SGroupRequest& s = iGroupRequests[i];
		if((aId & s.idMask)==(s.partialId & s.idMask))
			{
			s.msg.Complete(reportedId);
			iGroupRequests.Remove(i);
			}
		}
	}

TInt CSessionNotifier::AddRequest(TUint32 aId, TClientRequest aMessage)
	{
	SRequest s;
	s.id = aId;
	s.msg = aMessage;

	return iRequests.InsertInUnsignedKeyOrder(s);
	}

TInt CSessionNotifier::AddRequest(TUint32 aPartialId, TUint32 aIdMask, TClientRequest aMessage)
	{
	SGroupRequest s;
	s.partialId = aPartialId;;
	s.idMask = aIdMask;
	s.msg = aMessage;

	return iGroupRequests.Append(s);
	}

TInt CSessionNotifier::CancelRequest(TUint32 aId)
	{
	SRequest s;
	s.id = aId;
	
	TInt r = iRequests.FindInUnsignedKeyOrder(s);
	if(r>=0)
		{
		iRequests[r].msg.Complete(KUnspecifiedKey);
		iRequests.Remove(r);
		}

	return r>=0 ? KErrNone : KErrNotFound;
	}

TInt CSessionNotifier::CancelRequest(TUint32 aPartialId, TUint32 aIdMask)
	{
	TInt n = 0;
	for(TInt i=iGroupRequests.Count()-1; i>=0; i--)
		{
		SGroupRequest& s = iGroupRequests[i];
		if(aPartialId==s.partialId && aIdMask==s.idMask)
			{
			n++;
			s.msg.Complete(KUnspecifiedKey);
			iGroupRequests.Remove(i);
			}
		}

	return n>0 ? KErrNone : KErrNotFound;
	}

TInt CSessionNotifier::CancelAllRequests()
	{
	TInt n = iRequests.Count();
	while(n-->0)
		iRequests[n].msg.Complete(KUnspecifiedKey);

	iRequests.Reset();

	n = iGroupRequests.Count();
	while(n-->0)
		iGroupRequests[n].msg.Complete(KUnspecifiedKey);

	iGroupRequests.Reset();

	return KErrNone;
	}

void CSessionNotifier::IdReportingOn()
	{
	iIdReportingOn = ETrue;
	}

void CSessionNotifier::IdReportingOff()
	{
	iIdReportingOn = EFalse;
	}