/*

* 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: 

*       

*

*/

// INCLUDE FILES

#include "cmsdebug.h"

#include "cmsserver.h"

#include "cmsserversession.h"

#include "cmsphonebookproxy.h"

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

// CCmsServer::New

// 

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

//

CCmsServer* CCmsServer::NewLC()

    {

    PRINT( _L( "Start CCmsServer::NewLC()" ) );

    CCmsServer* self = new CCmsServer( EPriorityHigh );

    CleanupStack::PushL( self );

    self->ConstructL();

    PRINT( _L( "End CCmsServer::NewLC()" ) );

    return self;

    }

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

// CCmsServer::New

// 

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

//

void CCmsServer::ConstructL()

    {

    PRINT( _L( "Start CCmsServer::ConstructL()" ) );

    StartL( KCmsServerLib );

    User::LeaveIfError( iFS.Connect() );

    iPhonebookProxy = CCmsPhonebookProxy::NewL( *this, iFS );

    PRINT( _L( "End CCmsServer::ConstructL()" ) );

    }

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

// CCmsServer::NewSessionL

// 

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

//

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

                                    const RMessage2& /*aMessage*/ ) const

    {

    // Check version number of API against our known version number.

    TVersion thisVersion( KCmsSrvMajorVersionNumber,

                          KCmsSrvMinorVersionNumber,

                          KCmsSrvBuildVersionNumber );

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

        {

        User::Leave( KErrNotSupported );

        }

    return CCmsServerSession::NewL(( CCmsServer* ) this );

    }

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

// CCmsServer::CCmsServer

// 

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

//

CCmsServer::~CCmsServer()

    {

    PRINT( _L( "Start CCmsServer::~CCmsServer()" ) );

    Cancel();

    delete iPhonebookProxy;

    iFS.Close();

    PRINT( _L( "End CCmsServer::~CCmsServer()" ) );

    }

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

// CCmsServer::CCmsServer

// 

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

//

CCmsServer::CCmsServer( TInt aPriority ) : CServer2( aPriority )

    {

    }

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

// CCmsServer::PanicServer

// 

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

//

void CCmsServer::PanicServer( TCmsServerPanic aPanic )

    {

    PRINT1( _L( "CCmsServer::PanicServer() - Panic: %d" ), aPanic );

    _LIT( KCmsServerPanic, "CCmsServer");

    User::Panic( KCmsServerPanic, aPanic );

    }

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

// CCmsServer::FileSession

// 

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

//

RFs& CCmsServer::FileSession()

    {

    return iFS;

    }

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

// CCmsServer::ContactProxy

// 

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

//

CCmsPhonebookProxy& CCmsServer::PhonebookProxyHandle()

    {

    return *iPhonebookProxy;

    }

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

// CCmsServer::StoreOpenComplete

// 

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

//

void CCmsServer::StoreOpenComplete()

    {

    iSessionIter.SetToFirst();

    CSession2* session = iSessionIter;

    while( session != NULL )

        {

    	static_cast<CCmsServerSession*>(session)->StoreOpenComplete();

    	iSessionIter++;

        session = iSessionIter;

        }

    }

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

// CCmsServer::CmsSingleContactOperationComplete

// 

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

//

void CCmsServer::CmsSingleContactOperationComplete( TInt aError )

    {

    iSessionIter.SetToFirst();

    CSession2* session = iSessionIter;

    while( session != NULL )

        {

    	static_cast<CCmsServerSession*>(session)->

    	    CmsSingleContactOperationComplete( aError );

    	iSessionIter++;

        session = iSessionIter;

        }	

    }

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

// CCmsServer::StartThreadL

// 

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

//

TInt CCmsServer::StartThreadL()

    {

    PRINT( _L( "Start CCmsServer::StartThreadL()" ) );

	User::LeaveIfError( User::RenameThread( KCmsServerName ) );

	CCmsScheduler* scheduler = new ( ELeave ) CCmsScheduler;

	CleanupStack::PushL( scheduler );

    if( !CActiveScheduler::Current() )

        {

        PRINT( _L("CCmsServer::StartThreadL(): Scheduler not installed => install" ) );

        CActiveScheduler::Install( scheduler );

        }

    CCmsServer* server = CCmsServer::NewLC();

    //Open all contact stores so that they are ready when

    //the first session is requested

    server->PhonebookProxyHandle().InitStoresL();

    RProcess::Rendezvous( KErrNone );

    CActiveScheduler::Start();

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

	PRINT( _L( "End CCmsServer::StartThreadL()" ) );

	return KErrNone;

    }

// ================= SCHEDULER =======================

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

// CCmsScheduler::Error

// 

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

//

void CCmsScheduler::Error( TInt aError ) const

    {

    //To suppress build warnings

    TInt err = aError;

    PRINT1( _L( "*** CCmsScheduler::Error() - Error: %d ***" ), err );

    }