/*
* Copyright (c) 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:      Metadata Harvester server's client
*
*/







// INCLUDE FILES

#include    "mdhclientsession.h"
#include    "mdhcommon.h"
#include    "msdebug.h"


// CONSTANTS
// Number of retries to start server
const TInt KServerRetries = 2;

// =========================== LOCAL FUNCTIONS ===============================

// ---------------------------------------------------------------------------
// StartServer
// Starts the CM Metadata Harvester server.
// Returns: TInt error: Error status of the CM Metadata Harvester startup.
// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
// StartServer
// Creates a new process for the server and starts it up.
// ---------------------------------------------------------------------------
//
static TInt StartServer()
    {
    LOG(_L("[CmMdh Server]\t StartServer\n"));
    
    TInt result( KErrNone );
    // create server - if one of this name does not already exist
    TFindServer findServer( KCmMdhServerName );
    TFullName name;
    if ( findServer.Next( name ) != KErrNone ) // we don't exist already
        {
        
        TRequestStatus status( KRequestPending );
        RProcess server;
        // Create the server process
        result = server.Create( KCmMdhServerExe, KNullDesC );       
        if( result != KErrNone )
            {
            return result;
            }
    
        // Process created successfully
        server.Resume(); // start it going
        server.Rendezvous( status );
        
        // Wait until the completion of the server creation
        // server signals us when it's up
        User::WaitForRequest( status );
        
        
        if( status != KErrNone )
            {
            server.Close();
            return status.Int();
            }
            
        
        // Server created successfully
        server.Close(); // we can close the handle to server process now
        }
    return result;
    }


// ========================== MEMBER FUNCTIONS ===============================

// ---------------------------------------------------------------------------
// RCmMdhSession::RCmMdhSession
// C++ default constructor can NOT contain any code, that
// might leave.
// ---------------------------------------------------------------------------
//
RCmMdhSession::RCmMdhSession()
    {
    }


// ---------------------------------------------------------------------------
// RCmMdhSession::Connect
// Starts and creates a session of CM Metadata Harvester 
// ---------------------------------------------------------------------------
//
TInt RCmMdhSession::Connect()
    {
    TInt tryLoop = 0;
    TInt errCode = 0;

    for ( tryLoop = 0; tryLoop < KServerRetries; tryLoop++ )
        {
        errCode = CreateSession(KCmMdhServerName, 
            TVersion( KCmMdhServerMajor, KCmMdhServerMinor, 
                    KCmMdhServerBuild ) );
        //gives MessageSlots of -1
        //this uses global pool rather than local pool

        TRACE(Print(_L("[CmMdh Server]\t RCmMdhSession::Connect New Session \
                            created with status %d\n"), errCode));
        if( errCode == KErrNotSupported )
            {
            TRACE(Print(_L("[CmMdh Server]\t Version not supported!\n") ));
            return errCode;            
            }
        if ( errCode != KErrNotFound &&  errCode != KErrServerTerminated )
            {
            return errCode;
            }

        errCode = StartServer();

        if ( errCode != KErrNone && errCode != KErrAlreadyExists )
            {
            return errCode;
            }
            
        }
    return errCode;
    }

// ---------------------------------------------------------------------------
// RCmMdhSession::SearchMediaServers
// Searchs for neighborhood media servers
// ---------------------------------------------------------------------------
//
void RCmMdhSession::SearchMediaservers( TRequestStatus& aStatus )
    {
    LOG(_L("[CmMdh Server]\t RCmMdhSession::SearchMediaservers\n"));
    
    SendReceive(ECmMdhSearchMediaservers, TIpcArgs(), aStatus);
    }
    
    
// ---------------------------------------------------------------------------
// RCmMdhSession::Harvest
// Harvests and synchronizes metadata from found mediaservers
// ---------------------------------------------------------------------------
//
void RCmMdhSession::Harvest( TRequestStatus& aStatus )
    {
    LOG(_L("[CmMdh Server]\t RCmMdhSession::SearchMediaServers\n"));
    
    SendReceive(ECmMdhHarvest, TIpcArgs(), aStatus);
    }

// ---------------------------------------------------------------------------
// RCmMdhSession::Cancel
// ---------------------------------------------------------------------------
//
void RCmMdhSession::Cancel()
    {
    LOG(_L("[CmMdh Server]\t RCmMdhSession::Cancel\n"));
    
    SendReceive(ECmMdhCancel, TIpcArgs());
    }