/*
* Copyright (c) 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:  Harvester Server
*
*/


#include <e32std.h>
#include <e32svr.h>

#include "mpxharvestercommon.h"
#include "mpxharvesterserver.h"
#include "mpxharvesterengine.h"
#include "mpxharvestersession.h"
#include "mpxharvesterserverdefs.h"

// CONSTANTS

// Server Security Policy
const TUint KMPXHarvesterServerRangeCount = 2;
const TInt KMPXHarvesterServerRanges[KMPXHarvesterServerRangeCount] = 
    {
    0,                  //range is [0-EHvsServerOpCount)
    EHvsServerOpCount   //range is [EHvsServerOpCount-KMaxTInt] 
    };
const TUint8 KMPXHarvesterSeverElementsIndex[KMPXHarvesterServerRangeCount] = 
    {
    0,                            
    CPolicyServer::ENotSupported
    };
    
const CPolicyServer::TPolicyElement KMPXHarvesterServerPolicyElements[] = 
    {
    {_INIT_SECURITY_POLICY_C1(ECapabilityWriteDeviceData), 
                              CPolicyServer::EFailClient}
    };
    
const CPolicyServer::TPolicy KMPXHarvesterServerPolicy =
    {
    CPolicyServer::EAlwaysPass, //specifies all connect attempts should pass
    KMPXHarvesterServerRangeCount,                   
    KMPXHarvesterServerRanges,
    KMPXHarvesterSeverElementsIndex,
    KMPXHarvesterServerPolicyElements
    };


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

// ----------------------------------------------------------------------------
// Start Harvester Server
// ----------------------------------------------------------------------------
//
LOCAL_C void StartServerL()
    {
    User::LeaveIfError(User::RenameThread(KMPXHarvesterServerName));
    CActiveScheduler* scheduler = new(ELeave)CActiveScheduler;
    CleanupStack::PushL(scheduler);    
    CActiveScheduler::Install(scheduler);
    CMPXHarvesterServer* server = CMPXHarvesterServer::NewL();
    CleanupStack::PushL(server);    
    RProcess::Rendezvous(KErrNone);
    CActiveScheduler::Start();    
    CleanupStack::PopAndDestroy(server);
    CActiveScheduler::Install(NULL);
    CleanupStack::PopAndDestroy(scheduler);
    }

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

// ----------------------------------------------------------------------------
// Two-phased constructor.
// ----------------------------------------------------------------------------
//
CMPXHarvesterServer* CMPXHarvesterServer::NewL()
    {
    CMPXHarvesterServer *server = new(ELeave) CMPXHarvesterServer(
                                                EMPXHarvesterServerPriority, 
                                                KMPXHarvesterServerPolicy);
    CleanupStack::PushL(server);
    server->ConstructL();
    CleanupStack::Pop(server);
    return server;
    }

// ----------------------------------------------------------------------------
// C++ constructor can NOT contain any code that might leave.
// ----------------------------------------------------------------------------
//
CMPXHarvesterServer::CMPXHarvesterServer(TInt aPriority, const TPolicy &aPolicy)
    : CPolicyServer(aPriority, aPolicy) 
    {}

// ----------------------------------------------------------------------------
// Destructor
// ----------------------------------------------------------------------------
//
CMPXHarvesterServer::~CMPXHarvesterServer()
    {
    delete iEngine;
    }
    
// ----------------------------------------------------------------------------
// Symbian 2nd phase constructor can leave.
// ----------------------------------------------------------------------------
//
void CMPXHarvesterServer::ConstructL()
    {
    StartL(KMPXHarvesterServerName);
    RProcess().SetPriority(::EPriorityBackground);
    iEngine = CMPXHarvesterEngine::NewL();    
    }
    
// ----------------------------------------------------------------------------
// Increments number of sessions this server holds
// ----------------------------------------------------------------------------
//
void CMPXHarvesterServer::AddClient()
    {
    iClients++;
    }
    
 
// ----------------------------------------------------------------------------
// Decrement the number of clients currently connected to the harvester server
// ----------------------------------------------------------------------------
//
void CMPXHarvesterServer::RemoveClient()
    { 
    iClients--; 
    ASSERT(iClients>=0); 
    }

// ----------------------------------------------------------------------------
// Create a new session
// ----------------------------------------------------------------------------
//
CSession2* CMPXHarvesterServer::NewSessionL(const TVersion& aVersion,
                                           const RMessage2& /*aMessage*/) const
    {
    TVersion v(KMPXHarvesterServerMajorVersionNumber,
               KMPXHarvesterServerMinorVersionNumber,
               KMPXHarvesterServerBuildVersionNumber);
    if (!User::QueryVersionSupported(v,aVersion))
        {
        User::Leave(KErrNotSupported);
        }
    return CMPXHarvesterSession::NewL(*(const_cast<CMPXHarvesterServer*>(this)),
                                        *iEngine);
    }

// ----------------------------------------------------------------------------
// Server exe entry
// ----------------------------------------------------------------------------
//
TInt E32Main()
    {
    __UHEAP_MARK;
    //
    CTrapCleanup* cleanup=CTrapCleanup::New();
    TInt r(KErrNoMemory);
    if (cleanup)
        {
        TRAP(r,StartServerL());
        }
        
    delete cleanup;
    __UHEAP_MARKEND;
    return r;
    }