diff -r 000000000000 -r 7f85d04be362 upnpharvester/mdhserver/src/server/mdhconnectionmonitor.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/upnpharvester/mdhserver/src/server/mdhconnectionmonitor.cpp	Thu Dec 17 08:52:00 2009 +0200
@@ -0,0 +1,193 @@
+/*
+* Copyright (c) 2006-2007 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:      UPnP Connection Monitor class implementation.
+*
+*/
+
+
+
+
+
+
+// INCLUDE FILES
+#include <nifvar.h>
+
+#include "mdhconnectionmonitor.h"
+
+// ========================== MEMBER FUNCTIONS ===============================
+
+// ---------------------------------------------------------------------------
+// CMdHConnectionMonitor::CMdHConnectionMonitor
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// ---------------------------------------------------------------------------
+//
+CMdHConnectionMonitor::CMdHConnectionMonitor(
+    MMdHConnectionMonitorObserver& aObserver, TInt aAccessPoint ) :
+    iObserver( aObserver ),
+    iAccessPoint( aAccessPoint )
+    {
+    }
+
+
+// ---------------------------------------------------------------------------
+// CMdHConnectionMonitor::NewL
+// Two-phased constructor.
+// ---------------------------------------------------------------------------
+//
+EXPORT_C CMdHConnectionMonitor* CMdHConnectionMonitor::NewL(
+    MMdHConnectionMonitorObserver& aObserver, TInt aAccessPoint )
+    {
+    CMdHConnectionMonitor* self = new(ELeave) CMdHConnectionMonitor(
+        aObserver, aAccessPoint );
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    CleanupStack::Pop(self);
+    return self;    
+    }
+
+
+// ---------------------------------------------------------------------------
+// CMdHConnectionMonitor::ConstructL
+// Symbian 2nd phase constructor can leave.
+// ---------------------------------------------------------------------------
+//
+void CMdHConnectionMonitor::ConstructL()
+    {    
+    iConnectionMonitor.ConnectL();
+
+    iConnectionMonitor.NotifyEventL( *this );
+
+    // Get the count of connections
+    TRequestStatus status = KRequestPending;
+    TUint connectionCount = 0;
+    iConnectionMonitor.GetConnectionCount(connectionCount, status);
+    User::WaitForRequest( status ); 
+    
+    // Go through available connections and check to see
+    // if connection with iAccessPoint IAP is already running
+    if( status == KErrNone )
+        {
+        for( TUint i=1; i < connectionCount+1;  i++ )
+            {
+            TUint connectionId;
+            TUint subConnectionCount;
+            TUint iapId = 0;
+
+            iConnectionMonitor.GetConnectionInfo( 
+                                            i,
+                                            connectionId, 
+                                            subConnectionCount);
+
+            TRequestStatus status = KRequestPending;
+
+            iConnectionMonitor.GetUintAttribute( 
+                                            connectionId, 
+                                            0, 
+                                            KIAPId, 
+                                            (TUint &) iapId,
+                                            status );
+            User::WaitForRequest( status ); 
+
+            // Save connectionId if same iap
+            if( status == KErrNone && iAccessPoint == iapId )
+                {
+                iConnectionId = connectionId;
+                }
+            }    
+        }    
+
+    }
+
+    
+// ---------------------------------------------------------------------------
+// CMdHConnectionMonitor::~CMdHConnectionMonitor()
+// Destructor
+// ---------------------------------------------------------------------------
+//
+CMdHConnectionMonitor::~CMdHConnectionMonitor()
+    {
+    iConnectionMonitor.CancelNotifications();
+
+    // Disconnect from CM server
+    iConnectionMonitor.Close();
+    }
+
+
+
+// ---------------------------------------------------------------------------
+// CMdHConnectionMonitor::EventL()
+// Connection monitor observer
+// ---------------------------------------------------------------------------
+//
+void CMdHConnectionMonitor::EventL( const CConnMonEventBase& aConnMonEvent )
+    {
+
+    TUint connectionId = 0;
+
+    switch ( aConnMonEvent.EventType() )
+        {
+        case EConnMonCreateConnection:
+            {
+            TUint iapId = 0;
+
+            const CConnMonCreateConnection* eventCreate; 
+            eventCreate = (const CConnMonCreateConnection*)&aConnMonEvent;
+            connectionId = eventCreate->ConnectionId();
+
+            TRequestStatus status = KRequestPending;
+
+            // Get IAP id
+            iConnectionMonitor.GetUintAttribute( 
+                                            eventCreate->ConnectionId(), 
+                                            0, 
+                                            KIAPId, 
+                                            iapId, 
+                                            status );
+            User::WaitForRequest( status ); 
+
+            // Save connectionId if same iap
+            if( iAccessPoint == iapId )
+                {
+                iConnectionId = connectionId;
+                }
+
+            break;
+            }
+
+        // Connection is deleted
+        case EConnMonDeleteConnection:
+            {
+            const CConnMonDeleteConnection* eventDelete; 
+            eventDelete = 
+                    ( const CConnMonDeleteConnection* ) &aConnMonEvent;
+            connectionId = eventDelete->ConnectionId();
+
+            // If connection id same as in createConnection
+            if( connectionId == iConnectionId )
+                {
+                // Callback function
+                iObserver.ConnectionLost();
+                }
+
+            break;
+            }
+         default:
+            {
+            break;
+            }
+        }
+    }
+
+// end of file