loggingservices/eventlogger/LogServ/inc/LogServDatabaseChangeTracker.h
changeset 0 08ec8eefde2f
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/loggingservices/eventlogger/LogServ/inc/LogServDatabaseChangeTracker.h	Fri Jan 22 11:06:30 2010 +0200
@@ -0,0 +1,121 @@
+// Copyright (c) 2002-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:
+//
+
+#ifndef __LOGSERVDATABASECHANGETRACKER_H__
+#define __LOGSERVDATABASECHANGETRACKER_H__
+
+#include <d32dbms.h>
+#include "LogServBackupObserver.h"
+#include "LogServDatabaseChangeInterface.h"
+#include "LogServDatabaseChangeDefinition.h"
+
+// Classes referenced
+class CLogChangeDefinition;
+class MLogServBackupInterface;
+class MLogServDatabaseTransactionInterface;
+
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// -----> CLogServDatabaseChangeTracker (header)
+/////////////////////////////////////////////////////////////////////////////////////////
+/**
+@internalComponent
+*/
+class CLogServDatabaseChangeTracker : public CActive, public MLogServBackupObserver, public MLogServDatabaseChangeInterface
+	{
+/////////////////////////////////////////////////////////////////////////////////////////
+public:
+/////////////////////////////////////////////////////////////////////////////////////////
+	static CLogServDatabaseChangeTracker* NewL(MLogServDatabaseTransactionInterface& aDatabase, MLogServBackupInterface& aBackupInterface, TInt aPriority);
+	~CLogServDatabaseChangeTracker();
+
+/////////////////////////////////////////////////////////////////////////////////////////
+private: // INTERNAL CONSTRUCT
+/////////////////////////////////////////////////////////////////////////////////////////
+	CLogServDatabaseChangeTracker(MLogServDatabaseTransactionInterface& aDatabase, MLogServBackupInterface& aBackupInterface, TInt aPriority);
+	void ConstructL();
+
+/////////////////////////////////////////////////////////////////////////////////////////
+private: // FROM MLogServDatabaseChangeInterface
+/////////////////////////////////////////////////////////////////////////////////////////
+	void DCISubmitChangedEventContextL(TLogDatabaseChangeType aType, TLogId aEventId);
+	void DCISubmitGlobalChangeContextL(TUid aChangeType, TInt aContextParam1, TInt aContextParam2, TInt aContextParam3);
+	//
+	void DCIRequestChangeNotificationsL(MLogServDatabaseChangeObserver& aObserver);
+	void DCIRequestChangeNotificationsCancel(MLogServDatabaseChangeObserver& aObserver);
+
+/////////////////////////////////////////////////////////////////////////////////////////
+private: // FROM MLogServBackupObserver
+/////////////////////////////////////////////////////////////////////////////////////////
+	void BOHandleEventL(TLogServBackupEvent aEvent);
+
+/////////////////////////////////////////////////////////////////////////////////////////
+private: // FROM CActive
+/////////////////////////////////////////////////////////////////////////////////////////
+	void RunL();
+	void DoCancel();
+	TInt RunError(TInt aError);
+
+/////////////////////////////////////////////////////////////////////////////////////////
+private: // INTERNAL METHODS
+/////////////////////////////////////////////////////////////////////////////////////////
+	void Request();
+	void NotifyObserversL();
+	void NotifyGlobalChangeEventsL();
+	static TBool IdleNotifyGlobalChangeEvents(TAny* aSelf);
+
+/////////////////////////////////////////////////////////////////////////////////////////
+private: // MEMBER DATA
+/////////////////////////////////////////////////////////////////////////////////////////
+
+	/**
+	 * Watches the database for change events
+	 */
+	MLogServDatabaseTransactionInterface& iDatabase;
+
+	/**
+	 * Watches the database for change events
+	 */
+	MLogServBackupInterface& iBackupInterface;
+
+	/**
+	 * Watches the database for change events
+	 */
+	RDbNotifier iNotifier;
+
+	/**
+	 * Observers
+	 */
+	RPointerArray<MLogServDatabaseChangeObserver> iObservers;
+
+	/**
+	 * Track changes
+	 */
+	CLogChangeDefinition* iChanges;
+
+	/**
+	 * Used to ensure any global changes are pushed to clients
+	 * only after all other active object operations are complete.
+	 */
+	CIdle* iIdler;
+
+	/**
+	 * A queue of global change events
+	 */
+	RArray<TLogServDatabaseChangeDefinition> iGlobalChanges;
+	};
+
+
+#endif