--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/upnp/upnpstack/messagehandler/src/upnpmessagehandler.cpp	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,235 @@
+/** @file
+ * Copyright (c) 2005-2006 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:  Message handler
+ *
+ */
+
+// INCLUDE FILES
+#include "upnpmessagehandler.h"
+#define KLogFile _L("UpnpMessageHandler.txt")
+#include "upnpcustomlog.h"
+
+const TVersion KServerSupportedVersion( KMessageHandlerMajorVersionNumber,
+    KMessageHandlerMinorVersionNumber, KMessageHandlerBuildVersionNumber );
+
+// ================= MEMBER FUNCTIONS =======================
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::CUpnpMessageHandler
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// -----------------------------------------------------------------------------
+//
+CUpnpMessageHandler::CUpnpMessageHandler()
+    {
+    LOG_FUNC_NAME;
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::~CUpnpMessageHandler
+// Destructor.
+// -----------------------------------------------------------------------------
+//
+CUpnpMessageHandler::~CUpnpMessageHandler()
+    {
+    LOG_FUNC_NAME;
+    iObservers.Close();
+    delete iEngine;
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::NewLC
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+//
+CUpnpSymbianServerBase* CUpnpMessageHandler::NewLC()
+    {
+    LOG_FUNC_NAME;
+    CUpnpMessageHandler* messageHandler = new (ELeave) CUpnpMessageHandler();
+    CleanupStack::PushL( messageHandler );
+    messageHandler->ConstructL() ;
+    return messageHandler;
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::ConstructL
+// Symbian 2nd phase constructor can leave.
+// -----------------------------------------------------------------------------
+//
+void CUpnpMessageHandler::ConstructL()
+    {
+    LOG_FUNC_NAME;
+    BaseConstructL();
+    iEngine = CUpnpMessageHandlerEngine::NewL( *this );
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::ServerName
+// Return name of the server
+// -----------------------------------------------------------------------------
+//
+const TDesC& CUpnpMessageHandler::ServerName() const
+    {
+    return KMessageHandlerName;
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::NewSessionL
+// Create new session.
+// -----------------------------------------------------------------------------
+//
+CSession2* CUpnpMessageHandler::NewSessionL( const RMessage2& /*aMsg*/) const
+    {
+    LOG_FUNC_NAME;
+    return CUpnpMessageHandlerSession::NewL(
+        *const_cast<CUpnpMessageHandler*> ( this ), *iEngine );
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::SupportedVersion
+// Gets server supported version.
+// -----------------------------------------------------------------------------
+//
+TVersion CUpnpMessageHandler::SupportedVersion() const
+    {
+    return KServerSupportedVersion;
+    }
+
+// ============================= LOCAL FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// E32Main entry point.
+// Returns: KErrNone
+// -----------------------------------------------------------------------------
+//
+TInt E32Main()
+    {
+    return CUpnpMessageHandler::StartServer( KMessageHandlerThreadName,
+        CUpnpMessageHandler::NewLC );
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::DeviceListUpdateL
+// Update device list.
+// -----------------------------------------------------------------------------
+//
+void CUpnpMessageHandler::DeviceListUpdateL()
+    {
+    LOG_FUNC_NAME;
+    // Inform every Observer (every session) that the device list has changed
+    for ( TInt i(0); i < iObservers.Count(); i++ )
+        {
+        iObservers[i]->DeviceListChangeL();
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::AddObserverL
+// Add observer.
+// -----------------------------------------------------------------------------
+//
+void CUpnpMessageHandler::AddObserverL( MMessageHandlerObserver* aObserver )
+    {
+    LOG_FUNC_NAME;
+    iObservers.InsertL( aObserver, iObservers.Count() );
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::RemoveObserver
+// Remove observer.
+// -----------------------------------------------------------------------------
+//
+void CUpnpMessageHandler::RemoveObserver( MMessageHandlerObserver* aObserver )
+    {
+    LOG_FUNC_NAME;
+    LOGS1( "CUpnpMessageHandler::RemoveObserver - Count: %d", iObservers.Count());
+
+    for ( TInt i(0); i < iObservers.Count(); i++ )
+        {
+        if ( iObservers[i] == aObserver )
+            {
+            LOGS1( "CUpnpMessageHandler::RemoveObserver - Removed osb: %d",i);
+            iObservers.Remove( i );
+            iObservers.Compress();
+            }
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::RunError
+// RunError is called when RunL leaves.
+// -----------------------------------------------------------------------------
+//
+TInt CUpnpMessageHandler::RunError( TInt aError )
+    {
+    LOG_FUNC_NAME;
+    iStartingError = aError;
+    return CUpnpSymbianServerBase::RunError( aError );
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::IsSsdpStarted
+// Set function for iSsdpStarted
+// -----------------------------------------------------------------------------
+//     
+TBool CUpnpMessageHandler::IsSsdpStarted()
+    {
+    return iSsdpStarted;
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::GetError
+// -----------------------------------------------------------------------------
+//
+TInt CUpnpMessageHandler::StartingError()
+    {
+    return iStartingError;
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::SetStarted
+// Set function for iSsdpStarted
+// -----------------------------------------------------------------------------
+//
+void CUpnpMessageHandler::SetSsdpStarted( TBool aStarted )
+    {
+    iSsdpStarted = aStarted;
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::Sessions
+// Returns client sessions
+// -----------------------------------------------------------------------------
+//
+TDblQueIter< CSession2 >& CUpnpMessageHandler::Sessions()
+    {
+    return iSessionIter;
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpMessageHandler::IPListChange
+// Notify all observers
+// -----------------------------------------------------------------------------
+//
+void CUpnpMessageHandler::IPListChange()
+    {
+#ifdef RD_UPNP_REMOTE_ACCESS
+    for(TInt i(0); i < iObservers.Count(); i++)
+        {
+        iObservers[i]->IPListChange();
+        }
+#endif    
+    }
+
+// End of File