/*

* 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