--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/upnpharvester/mdhserver/src/server/mdhserversession.cpp	Thu Dec 17 08:52:00 2009 +0200
@@ -0,0 +1,176 @@
+/*
+* Copyright (c) 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:      Session implementation class for Metadata Harvester Server
+*
+*/
+
+
+
+
+
+
+// INCLUDE FILES
+#include    <e32base.h>
+#include    <s32mem.h>
+#include    "mdhserversession.h"
+#include    "mdhcommon.h"
+#include    "mdhserver.h"
+#include    "mdhmediaservercontainer.h"
+
+#include    "msdebug.h"
+
+
+// ============================ MEMBER FUNCTIONS =============================
+// ---------------------------------------------------------------------------
+// Two-phase API constructor
+// ---------------------------------------------------------------------------
+//
+CCmMdhSession* CCmMdhSession::NewL( 
+    CCmMdhMediaserverContainer* aMediaserverContainer, CCmMdhServer& aServer )
+    {
+    LOG(_L("[CmMdh Server]\t CCmMdhSession::NewL"));
+    CCmMdhSession* self = 
+        new (ELeave) CCmMdhSession( aMediaserverContainer, aServer );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+// ---------------------------------------------------------------------------
+// Constructor
+// ---------------------------------------------------------------------------
+//
+CCmMdhSession::CCmMdhSession( 
+    CCmMdhMediaserverContainer* aMediaserverContainer, 
+    CCmMdhServer& aServer ): iServer( aServer )
+    {
+        iMediaserverContainer = aMediaserverContainer;
+    }
+
+// ---------------------------------------------------------------------------
+// Constructor
+// ---------------------------------------------------------------------------
+//    
+void CCmMdhSession::ConstructL()
+    {
+    LOG(_L("[CmMdh Server]\t CCmMdhSession::ConstructL"))
+    iServer.IncrementSessions();
+    }
+            
+// ---------------------------------------------------------------------------
+// Destructor
+// ---------------------------------------------------------------------------
+//
+CCmMdhSession::~CCmMdhSession()
+    {
+    LOG(_L("[CmMdh Server]\t CCmMdhSession::~CCmMdhSession"));
+    iServer.DecrementSessions();
+    }
+
+// ---------------------------------------------------------------------------
+// CCmMdhSession::Server
+// Returns a reference to server
+// ---------------------------------------------------------------------------
+//
+CCmMdhServer& CCmMdhSession::Server()
+    {
+    return *static_cast<CCmMdhServer*>
+        (const_cast<CServer2*>(CSession2::Server()));
+    }
+
+// ---------------------------------------------------------------------------
+// CCmMdhSession::CompleteIfBusy
+// Completes message with busy error code if server is busy
+// ---------------------------------------------------------------------------
+TBool CCmMdhSession::CompleteIfBusy(const RMessage2& aMessage)
+    {
+    if (iServer.ServerState()) // operation already in progress
+        {
+        aMessage.Complete(KErrInUse);
+        return ETrue;
+        }
+    return EFalse;    
+    }
+
+// ---------------------------------------------------------------------------
+// CCmMdhSession::ServiceL
+// Implements CSession2 -derived ServiceL -method.
+// (other items were commented in a header).
+// ---------------------------------------------------------------------------
+//
+void CCmMdhSession::ServiceL(const RMessage2& aMessage)
+    {
+    LOG(_L("[CmMdh Server]\t CCmMdhSession::ServiceL"));
+    
+    switch ( aMessage.Function() )
+        {
+        case ECmMdhSearchMediaservers:
+            {
+            LOG(_L("[CmMdh Server]\t ECmMdhSearchMediaServers request"));
+            if ( !CompleteIfBusy(aMessage) ) 
+                {
+                iServer.SetCurrentAsyncMsg( aMessage );
+                iServer.CreateMediaserverContainerL();
+                iServer.MediaserverContainer().SearchMediaserversL();        
+                }
+            break;    
+            }
+        case ECmMdhHarvest:
+            {
+            LOG(_L("[CmMdh Server]\t ECmMdhHarvest request"));
+            iServer.SetCurrentAsyncMsg( aMessage );
+            iServer.CreateMediaserverContainerL();
+            iServer.MediaserverContainer().HarvestMediaserversL();
+            break;
+            }
+        case ECmMdhCancel:
+            {
+            LOG(_L("[CmMdh Server]\t ECmMdhCancel request"));
+            switch ( iServer.ServerState() )
+                {
+                case ECmMdhServerStateSearching:
+                    {
+                    iServer.MediaserverContainer().CancelSearchL();
+                    iServer.DestroyMediaserverContainer();
+                
+                    aMessage.Complete( KErrNone );
+                    break;
+                    }
+                case ECmMdhServerStateHarvesting:
+                    {
+                    iServer.MediaserverContainer().CancelHarvestL();
+                    iServer.DestroyMediaserverContainer();
+                
+                    aMessage.Complete( KErrNone );
+                    break;
+                    }
+                default: 
+                    {
+                    aMessage.Complete( KErrNotReady );
+                    break;
+                    }
+                }
+            break;
+            }
+        default:
+            {
+            // Unknown opcode --> panic client
+            PanicClient( aMessage, ECmMdhClientBadRequest );
+            break;
+            }
+        }    
+    }
+
+// End of File