/*

 * Copyright (c) 2008 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:  ?Description

 *

 */

// INCLUDE FILES

#include <sqldb.h>

#include <eikenv.h>

#include <eikappui.h>

#include "casrv.h"

#include "casrvdef.h"

#include "casrvsession.h"

#include "casrvengutils.h"

#include "castorageproxy.h"

#include "casrvmanager.h"

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

/**

 * Stop the Active Scheduler.

 * @param aPtr Not used.

 * @return KErrNone.

 */

LOCAL_C TInt StopScheduler( TAny* /*aPtr*/)

    {

    // Called by the exit timer, after all clients disconnected (plus a small

    // delay). Stop the scheduler, this will enable he thread exit.

    CActiveScheduler::Stop();

    return KErrNone;

    }

/**

 * Create a server.

 * @param Pointer to created server (if created) returned here.

 * @return Error code.

 */

LOCAL_C TInt CreateServer( CCaSrv*& aServer )

    {

    // The TRAP is not working in the same stack frame where the

    // CTrapCleanup was created. This is why we need this function.

    TRAPD( err, aServer = CCaSrv::NewL() );

    return err;

    }

// ==================== GLOBAL FUNCTIONS ====================

// ---------------------------------------------------------

//

// ---------------------------------------------------------

//

EXPORT_C TInt RunCaServer()

    {

    __UHEAP_MARK;

    CTrapCleanup* trapCleanup = NULL;

    CActiveScheduler* activeScheduler = NULL;

    CCaSrv* server = NULL;

    TInt err = User::RenameThread( KCaSrvName );

    if( !err )

        {

        // Create a trap cleanup, make and install an active scheduler.

        err = KErrNoMemory;

        trapCleanup = CTrapCleanup::New();

        if( trapCleanup )

            {

            activeScheduler = new CActiveScheduler();

            if( activeScheduler )

                {

                CActiveScheduler::Install( activeScheduler );

                err = CreateServer( server ); // Not pushed (no leaving).

                if( !err )

                    {

                    err = server->Start( KCaSrvName );

                    }

                }

            else

                {

                err = KErrNoMemory;

                }

            }

        }

    // Let the caller know how it went.

    RProcess::Rendezvous( err );

    if( !err )

        {

        CActiveScheduler::Start(); // Start off. Exit timer will stop it.

        }

    CActiveScheduler::Install( NULL );

    delete activeScheduler;

    delete server;

    delete trapCleanup;

    __UHEAP_MARKEND;

    return err;

    }

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

// ---------------------------------------------------------

//

// ---------------------------------------------------------

//

CCaSrv* CCaSrv::NewL()

    {

    CCaSrv* srv = new ( ELeave ) CCaSrv();

    CleanupStack::PushL( srv );

    srv->ConstructL();

    CleanupStack::Pop( srv );

    return srv;

    }

// ---------------------------------------------------------

//

// ---------------------------------------------------------

//

CCaSrv::~CCaSrv()

    {

    // Cancel requests and delete all sessions first.

    // Base class would do it for us but that's too late - our sessions

    // call the server back (SessionClosed, RemoveContainer, etc.).

    Cancel();

    CSession2* session;

    iSessionIter.SetToFirst();

    while( ( session = iSessionIter++ ) != NULL )

        {

        delete session;

        }

    delete iSrvManager;

    delete iSrvEngUtils;

    delete iStorageProxy;

    }

// ---------------------------------------------------------

//

// ---------------------------------------------------------

//

CCaStorageProxy* CCaSrv::GetStorageProxy()

    {

    return iStorageProxy;

    }

// ---------------------------------------------------------

//

// ---------------------------------------------------------

//

CCaSrv::CCaSrv() :

    CServer2( EPriorityNormal, CServer2::TServerType( EIpcSession_Sharable ) )

    {

    }

// ---------------------------------------------------------

//

// ---------------------------------------------------------

//

void CCaSrv::ConstructL()

    {

    iSessionCount = 0;

    iStorageProxy = CCaStorageProxy::NewL();

    iSrvEngUtils = CCaSrvEngUtils::NewL();

    TRAPD( err, iSrvManager = CCaSrvManager::NewL(

            *iStorageProxy, iSrvEngUtils ) );

    if( KSqlErrNotDb <= err && err <= KSqlErrGeneral )

        {

        //problem in loading one of plugins, probably data base is corrupted

        //lets load it from ROM and try again

        iStorageProxy->LoadDataBaseFromRomL();

        iSrvManager = CCaSrvManager::NewL( *iStorageProxy, iSrvEngUtils );

        }

    }

// ---------------------------------------------------------

//

// ---------------------------------------------------------

//

CSession2* CCaSrv::NewSessionL( const TVersion& aVersion,

        const RMessage2& /*aMessage*/) const

    {

    TVersion version( KCaMajorVersion, KCaMinorVersion, KCaBuild );

    if( !User::QueryVersionSupported( version, aVersion ) )

        {

        User::Leave( KErrNotSupported );

        }

    CSession2* session;

    session = CCaSrvSession::NewL( const_cast<CCaSrv&> ( *this ) );

    return session;

    }

// ---------------------------------------------------------

//

// ---------------------------------------------------------

//

void CCaSrv::IncreaseSessionCount()

    {

    iSessionCount++;

    }

// ---------------------------------------------------------

//

// ---------------------------------------------------------

//

void CCaSrv::DecreaseSessionCount()

    {

    iSessionCount--;

    }

//  End of File