--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/connectionmonitoring/connmon/connectionmonitor/src/CEventQueue.cpp	Thu Dec 17 08:55:21 2009 +0200
@@ -0,0 +1,163 @@
+/*
+* Copyright (c) 2002-2005 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:  Event queue stores an event until all the clients can
+*                receive it.
+*
+*/
+
+#include "ConnMonServ.h"
+#include "ConnMonSess.h"
+#include "CEventQueue.h"
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// CEventQueue::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CEventQueue::ConstructL( CConnMonServer* aServer )
+    {
+    iServer=aServer;
+
+    // Allocate nodes
+    for ( TInt i=0; i < KEventQueueSize; i++ )
+        {
+        TEventNode* node = new( ELeave ) TEventNode;
+        iSlots.AddFirst( *node );
+        }
+
+    // Initialize latest event time
+    iLastEventTime.UniversalTime();
+    }
+
+// Destructor
+CEventQueue::~CEventQueue()
+    {
+    TEventNode* node;
+
+    // Deallocate nodes
+    for ( node=iSlots.First(); node; node=iSlots.First() )
+        {
+        iSlots.Remove( *node );
+        delete node;
+        }
+
+    for ( node=iEvents.First(); node; node=iEvents.First() )
+        {
+        if ( node->iEvent.iExtra.iPtr )
+            {
+            delete node->iEvent.iExtra.iPtr;
+            node->iEvent.iExtra.iPtr = NULL;
+            }
+
+        iEvents.Remove( *node );
+        delete node;
+        }
+
+    iServer = NULL;
+    }
+
+// -----------------------------------------------------------------------------
+// CEventQueue::Add
+// -----------------------------------------------------------------------------
+//
+void CEventQueue::Add( const TEventInfo& aEventInfo, const TUint8* aPtr, TInt aSize  )
+    {
+    TTimeIntervalMicroSeconds microSecond( 1 );
+    iLastEventTime = iLastEventTime + microSecond;
+
+    // Get the first free slot - remove oldest event if queue is full
+    TEventNode* node = iSlots.First();
+
+    if ( !node )
+        {
+        //return;
+        node = iEvents.First();
+        FreeEvent( node );
+        node = iSlots.First();
+        }
+
+    iSlots.Remove( *node );
+
+    // Plug in values
+    node->iEvent.iInfo        = aEventInfo;
+    node->iEvent.iTime        = iLastEventTime;
+    node->iEvent.iExtra.iPtr  = aPtr;
+    node->iEvent.iExtra.iSize = aSize;
+
+    // Add to the event queue
+    iEvents.AddLast( *node );
+
+    // Offer the event to all the clients that are listening
+    // and have requested a new event.
+    TInt numOffered( 0 );
+    iServer->SendEventToSessions( node->iEvent, numOffered );
+
+    // Remove immediately from the queue if all the listeners have got the event
+    if ( numOffered == iServer->NumberOfListeners() )
+        {
+        FreeEvent( node );
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CEventQueue::CheckEvents
+// See if there is a new event in the queue for aSession.
+// -----------------------------------------------------------------------------
+//
+void CEventQueue::CheckEvents( CConnMonSession* aSession )
+    {
+    TSglQueIter< TEventNode > iter( iEvents );
+
+    if ( aSession == 0 )
+        {
+        return;
+        }
+
+    for ( TEventNode* node = iter++; node; node = iter++ )
+        {
+        if ( aSession->CanReceiveEvent() )
+            {
+            if ( aSession->SendEventToClient( node->iEvent ) )
+                {
+                break;
+                }
+            }
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CEventQueue::FreeEvent
+// -----------------------------------------------------------------------------
+//
+void CEventQueue::FreeEvent( TEventNode* aNode )
+    {
+    if ( aNode != 0 )
+        {
+        if ( aNode->iEvent.iExtra.iPtr )
+            {
+            delete aNode->iEvent.iExtra.iPtr;
+            aNode->iEvent.iExtra.iPtr = NULL;
+            }
+
+        iEvents.Remove( *aNode );
+
+        aNode->iEvent.iInfo.Reset();
+        aNode->iEvent.iExtra.Reset();
+
+        iSlots.AddFirst( *aNode );
+        }
+    }
+
+// End-of-file