/*

* Copyright (c) 2009 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: This file contains the implementation of the

*              CHtiIPCommServer class.

*              CHtiIPCommServer handles Symbian server side operations

*              such as server starting and client session creation.

*

*/

// INCLUDE FILES

#include "HtiIPCommServerCommon.h"

#include "HtiIPCommServer.h"

#include "HtiIPCommServerSession.h"

#include "HtiIPCommlogging.h"

CHtiIPCommServer::CHtiIPCommServer()

    :CServer2( EPriorityUserInput, EUnsharableSessions ),

    iConnectionManager( NULL ),

    iRunning( EFalse ),

    iNrOfSessions( 0 )

    {

    // NOTE: Server needs to have highest priority of all our active

    // objects to be able to service client requests while other active

    // objects are running.

    //

    // This also affects closing of sessions. If priorities

    // are the same ~CHtiIPCommServerSession does not get called before active

    // object completes.

    }

CHtiIPCommServer::~CHtiIPCommServer()

    {

    delete iConnectionManager;

    }

CHtiIPCommServer* CHtiIPCommServer::NewLC()

    {

    CHtiIPCommServer* self=new(ELeave) CHtiIPCommServer;

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

void CHtiIPCommServer::ConstructL()

    {

    iConnectionManager = CHtiConnectionManager::NewL( this );

    StartL( KIPCommServerName );

    }

CSession2* CHtiIPCommServer::NewSessionL( const TVersion&, const RMessage2&) const

    {

    // There should be only one session

    if ( iNrOfSessions )

        User::Leave( KErrAlreadyExists );

    return new(ELeave) CHtiIPCommServerSession( (CHtiIPCommServer*)this );

    }

void CHtiIPCommServer::SessionOpened()

    {

    iNrOfSessions++;

    }

void CHtiIPCommServer::SessionClosed()

    {

    // Die if no more sessions

    if ( --iNrOfSessions == 0 )

        {

        HTI_LOG_TEXT( "HtiIPCommServer no more sessions - dying..." );

        CloseServer();

        }

    }

void CHtiIPCommServer::CloseServer()

    {

    // Can be called from CHtiIPCommServer::SessionClosed and

    // CHtiConnectionManager::TimerExpiredL

    // So this can actually be called twice if it is called from

    // TimerExpiredL - hence the iRunning variable :)

    if ( iRunning )

        {

        iRunning = EFalse;

        CActiveScheduler::Stop();

        HTI_LOG_TEXT( "CActiveScheduler::Stop() called" );

        }

    }

static void RunServerL()

    {

    // naming the server thread after the server helps to debug panics

    User::LeaveIfError( RThread::RenameMe( KIPCommServerName ) );

    // create and install the active scheduler we need

    CActiveScheduler* as = new ( ELeave ) CActiveScheduler;

    CleanupStack::PushL( as );

    CActiveScheduler::Install( as );

    // create the server (leave it on the cleanup stack)

    CHtiIPCommServer* server = CHtiIPCommServer::NewLC();

    // Rendezvous with the client (RHtiIPCommServer::Connect)

    RProcess::Rendezvous(KErrNone);

    server->iRunning = ETrue;

    CActiveScheduler::Start();

    CleanupStack::PopAndDestroy(2);     // server, as

    }

// Server process entry-point

TInt E32Main()

    {

    HTI_LOG_TEXT( "*** Starting HtiIPCommServer ***" );

    __UHEAP_MARK;

    CTrapCleanup* cleanup = CTrapCleanup::New();

    TInt r = KErrNoMemory;

    if ( cleanup )

        {

        TRAP( r, RunServerL() );

        delete cleanup;

        }

    __UHEAP_MARKEND;

    HTI_LOG_TEXT( "*** HtiIPCommServer died! ***" );

    return r;

    }