--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/phonebookengines/contactsmodel/tsrc/CContactDbEventQueue.cpp	Tue Feb 02 10:12:17 2010 +0200
@@ -0,0 +1,115 @@
+// Copyright (c) 2003-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:
+//
+
+// INCLUDES
+#include "CContactDbEventQueue.h"
+#include <cntdb.h>
+
+CContactDbEventQueue* CContactDbEventQueue::NewL
+        (CContactDatabase* aDb, TInt aMaxQueueSize)
+    {
+    CContactDbEventQueue* self = new(ELeave) CContactDbEventQueue;
+    CleanupStack::PushL(self);
+    self->ConstructL(aDb,aMaxQueueSize);
+    CleanupStack::Pop(self);
+    return self;
+    }
+
+CContactDbEventQueue::~CContactDbEventQueue()
+    {
+    CTimer::Cancel();
+    if (iNotifier)
+        {
+        delete iNotifier;
+        }
+    }
+    
+void CContactDbEventQueue::PopEvent()
+	{	
+	 if (!iQueue.IsEmpty())
+     	{
+     	iQueue.PopHead();
+     	}
+	}
+
+void CContactDbEventQueue::Clear()
+	{	
+	 while(!iQueue.IsEmpty())
+     	{
+     	iQueue.PopHead();
+     	}
+	}
+
+TBool CContactDbEventQueue::ListenForEvent(TTimeIntervalSeconds aTimeOut, TContactDbObserverEvent& aEvent)
+    {
+    CTimer::Cancel();
+    if (iQueue.IsEmpty())
+        {
+        CTimer::After(aTimeOut.Int() * 1000000);
+        CActiveScheduler::Start();
+        }
+    if (!iQueue.IsEmpty())
+        {
+        aEvent = iQueue.Head();
+        iQueue.PopHead();
+        return ETrue;
+        }
+    else
+        {
+        return EFalse;
+        }
+    }
+
+void CContactDbEventQueue::RunL()
+    {
+    // Timer expired
+    CActiveScheduler::Stop();
+    }
+
+void CContactDbEventQueue::HandleDatabaseEventL
+        (TContactDbObserverEvent aEvent)
+    {
+    const TBool KTimerActive = CTimer::IsActive();
+    CTimer::Cancel();
+	TBool eventPushed = iQueue.Push(aEvent);
+	__ASSERT_ALWAYS(eventPushed,User::Invariant());  // ensure push was successful
+    
+    if (KTimerActive)
+        {
+        CActiveScheduler::Stop();
+        }
+    }
+
+CContactDbEventQueue::CContactDbEventQueue()
+    : CTimer(CActive::EPriorityStandard)
+    {
+    }
+
+void CContactDbEventQueue::ConstructL
+        (CContactDatabase* aDb, TInt aMaxQueueSize)
+    {
+    CTimer::ConstructL();
+    iQueue.ConstructL(aMaxQueueSize);
+    CActiveScheduler::Add(this);
+    
+    if (aDb)
+        {
+        iNotifier = CContactChangeNotifier::NewL(*aDb, this);
+        }
+    }
+
+
+
+