/*

* Copyright (c) 2002-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:  RCFClientSession class implementation.

*

*/

#include "CFClientSession.h"

#include <e32svr.h>

#include <e32math.h>

#include <s32mem.h>

#include <f32file.h>

#include <centralrepository.h>

#include <cfcontextdataobject.h>

#include "cfcontextsubscriptionlistener.h"

#include "CFContextSubscriptionImpl.h"

#include "CFActionSubscriptionImpl.h"

#include "CFContextQueryImpl.h"

#include "cfcommon.h"

#include "CFContextObjectImpl.h"

#include "cftrace.h"

#include "ContextFrameworkPrivateCRKeys.h"

// CONSTANTS

//Fix for BHLS-7UPEA8

static const TUint KDefaultMessageSlots = 5;

static const TInt KCreateSessionRetryCount = 10;

static const TInt KCreateSessionDelay = 100000; // 0.1 seconds

RCFClientSession::RCFClientSession()

    {

    FUNC_LOG;

    }

// METHODS

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

// RCFClientSession::ConnectL

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

//

void RCFClientSession::ConnectL()

    {

    FUNC_LOG;

    TInt err = KErrNone;

#ifdef CFW_SERVER_START_THROUGH_CLIENT

    err = StartServer();

    ERROR_1( err, "CF server start failed with code: %d", err );

    User::LeaveIfError( err );

#endif

    RThread client;

    CleanupClosePushL( client );

    INFO_1( "Client [%x] session connecting to Context FW...",

        client.SecureId().iId );

    TInt retry = 0;

    do

        {

        err = CreateSession( KContextServerName,

            Version(),

            KDefaultMessageSlots );

        retry++;

        ERROR_2( err, "CF server session creation failed with code: %d. Retry count: %d", err, retry );

        if( err != KErrNone && retry < KCreateSessionRetryCount )

            {

            // Wait for a while so that CFW server is started

            User::After( KCreateSessionDelay );

            }

        }

    while( err != KErrNone && retry < KCreateSessionRetryCount );

    ERROR_1( err, "CF server session creation failed with code: %d", err );

    User::LeaveIfError( err );

    INFO_1( "Client [%x] session connecting to Context FW... OK",

        client.SecureId().iId );

    CleanupStack::PopAndDestroy( &client );

    }

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

// RCFClientSession::Version

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

//

TVersion RCFClientSession::Version() const

    {

    FUNC_LOG;

    return( TVersion( KContextServMajorVersionNumber,

        KContextServMinorVersionNumber,

        KContextServBuildVersionNumber ) );

    }

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

// RCFClientSession::SendSync

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

//

TInt RCFClientSession::SendSync( TInt aFunction ) const

    {

    FUNC_LOG;

    INFO_1( "SendSync: OpCode [%d]", aFunction );

    return SendReceive( aFunction );

    }

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

// RCFClientSession::SendSync

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

//

TInt RCFClientSession::SendSync( TInt aFunction, const TIpcArgs& aArgs ) const

    {

    FUNC_LOG;

    INFO_1( "SendSync: OpCode [%d]", aFunction );

    return SendReceive( aFunction, aArgs );

    }

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

// RCFClientSession::SendAsync

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

//

void RCFClientSession::SendAsync( TInt aFunction,

    const TIpcArgs& aArgs,

    TRequestStatus& aStatus ) const

    {

    FUNC_LOG;

    INFO_1( "SendAsync: OpCode [%d]", aFunction );

    SendReceive( aFunction, aArgs, aStatus );

    }

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

// RCFClientSession::StartServer

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

//

TInt RCFClientSession::StartServer()

    {

    FUNC_LOG;

    TInt result;

    TFindServer findContextServer( KContextServerName );

    TFullName name;

    result = findContextServer.Next( name );

    if( result == KErrNone )

        {

        // Server already running

        INFO( "CF server already running" );

        return KErrNone;

        }

    // Create process for server and start the process

    RProcess server;

    result = server.Create( KContextServerName, KNullDesC );

    if( result != KErrNone )

        {

        return result;

        }

    INFO_1( "CF server process created with code: %d", result );

    TRequestStatus status;

    server.Rendezvous( status );

    server.Resume();

    // Wait for rendesvouz

    User::WaitForRequest( status );

    INFO_1( "CF server rendezvous: %d", status.Int() );

    // Close process handle since it is not needed anymore

    server.Close();

    return status.Int();

    }

// End of file