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

#include "LogChangeDefinition.h"

#include "LogServDatabaseTransactionInterface.h"

#include "logservpanic.h"

#include "LogServBackupInterface.h"

// Constants

const TInt KLogArrayGranularityObservers = 3;

const TInt KLogArrayGranularityGlobalChanges = 2;

#define UNUSED_VAR(a) a = a

/////////////////////////////////////////////////////////////////////////////////////////

// -----> CLogServDatabaseChangeTracker (source)

/////////////////////////////////////////////////////////////////////////////////////////

CLogServDatabaseChangeTracker::CLogServDatabaseChangeTracker(MLogServDatabaseTransactionInterface& aDatabase, MLogServBackupInterface& aBackupInterface, TInt aPriority)

:	CActive(aPriority), iDatabase(aDatabase), iBackupInterface(aBackupInterface), iObservers(KLogArrayGranularityObservers), iGlobalChanges(KLogArrayGranularityGlobalChanges)

	{

	CActiveScheduler::Add(this);

	}

CLogServDatabaseChangeTracker::~CLogServDatabaseChangeTracker()

	{

	Cancel();

	//

	iBackupInterface.BIObserverRemove(*this);

	iNotifier.Close();

	iObservers.Close();

	iGlobalChanges.Close();

	//

	delete iIdler;

	delete iChanges;

	}

void CLogServDatabaseChangeTracker::ConstructL()

	{

	iBackupInterface.BIObserverAddL(*this, MLogServBackupInterface::EObjectChangeTracker);

	iChanges = CLogChangeDefinition::NewL();

	//

	const TInt error = iNotifier.Open(iDatabase.DTIDatabase());

	User::LeaveIfError(error);

	//

	Request();

	iIdler = CIdle::NewL(CActive::EPriorityIdle);

	}

CLogServDatabaseChangeTracker* CLogServDatabaseChangeTracker::NewL(MLogServDatabaseTransactionInterface& aDatabase, MLogServBackupInterface& aBackupInterface, TInt aPriority)

	{

	CLogServDatabaseChangeTracker* self = new(ELeave) CLogServDatabaseChangeTracker(aDatabase, aBackupInterface, aPriority);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

void CLogServDatabaseChangeTracker::DCISubmitChangedEventContextL(TLogDatabaseChangeType aType, TLogId aEventId)

	{

	__ASSERT_DEBUG(aType != ELogChangeTypeUndefined, Panic(ELogUnrecognizedChangeType2));

	iChanges->AddL(aEventId, aType, KErrGeneral);

	}

void CLogServDatabaseChangeTracker::DCISubmitGlobalChangeContextL(TUid aChangeType, TInt aContextParam1, TInt aContextParam2, TInt aContextParam3)

	{

	const TLogServDatabaseChangeDefinition item(aChangeType, aContextParam1, aContextParam2, aContextParam3);

	User::LeaveIfError(iGlobalChanges.Append(item));

	//

	iIdler->Cancel();

	iIdler->Start(TCallBack(IdleNotifyGlobalChangeEvents, this));

	}

void CLogServDatabaseChangeTracker::DCIRequestChangeNotificationsL(MLogServDatabaseChangeObserver& aObserver)

	{

	const TInt error = iObservers.InsertInAddressOrder(&aObserver);

	User::LeaveIfError(error);

	}

void CLogServDatabaseChangeTracker::DCIRequestChangeNotificationsCancel(MLogServDatabaseChangeObserver& aObserver)

	{

	const TInt error = iObservers.FindInAddressOrder(&aObserver);

	if	(error >= KErrNone)

		iObservers.Remove(error);

	}

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

void CLogServDatabaseChangeTracker::BOHandleEventL(TLogServBackupEvent aEvent)

	{

	switch(aEvent)

		{

	case EBackupStarting:

		{

		Cancel();

		iNotifier.Close();

		break;

		}

	case EBackupEnded:

		{

		const TInt error = iNotifier.Open(iDatabase.DTIDatabase());

		User::LeaveIfError(error);

		Request();

		break;

		}

	default:

		__ASSERT_DEBUG(EFalse, User::Invariant());

		break;

		}

	}

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

void CLogServDatabaseChangeTracker::RunL()

	{

	// We are only interested if a commit has occurred

	const TInt completionCode = iStatus.Int();

	if	(completionCode == RDbNotifier::ECommit)

		{

		LOGTEXT("CLogServDatabaseChangeTracker::RunL() - database commit");

		// Notify all observers

		NotifyObserversL();

		// Reset changes

		iChanges->Reset();

		}

	Request();

	}

void CLogServDatabaseChangeTracker::DoCancel()

	{

	iNotifier.Cancel();

	}

TInt CLogServDatabaseChangeTracker::RunError(TInt /*aError*/)

	{

	// Ignore errors such as leaves from notifying observers

	Request();

	return KErrNone;

	}

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

void CLogServDatabaseChangeTracker::Request()

	{

	iNotifier.NotifyChange(iStatus);

	SetActive();

	}

void CLogServDatabaseChangeTracker::NotifyObserversL()

	{

	LOGTEXT("CLogServDatabaseChangeTracker::NotifyObserversL()");

	//

	const TInt count = iObservers.Count();

	for(TInt i=0; i<count; i++)

		{

		MLogServDatabaseChangeObserver* observer = iObservers[i];

		observer->DCOHandleChangeEventsL(*iChanges);

		}

	// Reduce memory usage

	iChanges->Reset();

	//

	LOGTEXT("CLogServDatabaseChangeTracker::NotifyObserversL() - end");

	}

void CLogServDatabaseChangeTracker::NotifyGlobalChangeEventsL()

	{

	LOGTEXT("CLogServDatabaseChangeTracker::NotifyGlobalChangeEventsL()");

	//

	const TInt count = iGlobalChanges.Count();

	for(TInt i=0; i<count; i++)

		{

		const TLogServDatabaseChangeDefinition& change = iGlobalChanges[i];

		//

		const TInt observerCount = iObservers.Count();

		for(TInt j=0; j<observerCount; j++)

			{

			MLogServDatabaseChangeObserver* observer = iObservers[j];

			observer->DCOHandleGlobalChangeEventL(change);

			}

		}

	// Reduce memory usage

	iGlobalChanges.Reset();

	iGlobalChanges.GranularCompress();

	//

	LOGTEXT("CLogServDatabaseChangeTracker::NotifyGlobalChangeEventsL() - end");

	}

TBool CLogServDatabaseChangeTracker::IdleNotifyGlobalChangeEvents(TAny* aSelf)

	{

	CLogServDatabaseChangeTracker* self = reinterpret_cast<CLogServDatabaseChangeTracker*>(aSelf);

	TRAPD(err, self->NotifyGlobalChangeEventsL());

    UNUSED_VAR(err);

	return EFalse;

	}