/*

* 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:  Sensor server client side connector class

*

*/

#include <e32svr.h>

#include <data_caging_path_literals.hrh>  

#include "sensrvdefines.h"

#include "sensrvclient.h"

#include "sensrvclientserver.h"

#include "sensrvtrace.h"

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

// RSensrvClient::Connect

// Connects to server

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

//

TInt RSensrvClient::Connect()

    {

   COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::Connect()" ) ) );

    // Try this twice

    TInt retry(KSensrvClientTryCount);

    TInt err(KErrNone);

    while (retry > 0)

        {

        // Try to create a Sensor Server session

        err = CreateSession( KSensrvProcessName, 

                             ServerVersion(), 

                             KSensrvDefaultAsyncSlots );

        COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::Connect - CreateSession returned: %d" ), err ) );        

        if ( err != KErrNotFound && err != KErrServerTerminated )

            {

            // KErrNone or unrecoverable error

            if (err != KErrNone)

                {

                ERROR_TRACE( ( _L( "Sensrv Client - RSensrvClient::Connect - ERROR: CreateSession unrecoverable error: %d" ), err ) );

                }

            retry = 0;

            }

        else

            {

            // Return code was KErrNotFound or KErrServerTerminated.

            // Try to start a new Sensor Server

            err = StartServer();

            COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::Connect - StartServer returned: %d" ), err ) );        

            if ( err != KErrNone && err != KErrAlreadyExists )

                {

                // Unrecoverable error

                ERROR_TRACE( ( _L( "Sensrv Client - RSensrvClient::Connect - ERROR: StartServer unrecoverable error: %d" ), err ) );

                retry = 0;

                }

            }

        retry--;

        }

    COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::Connect - return %d" ), err ) );        

    return err;

    }

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

// RSensrvClient::SendReceiveSync

// Send message to server

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

//

TInt RSensrvClient::SendReceiveSync( TSensrvServerRequest aRequest, const TIpcArgs& aArgs ) const

    {

    COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::SendReceiveSync()" ) ) );

    return SendReceive( aRequest, aArgs );

    }

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

// RSensrvClient::SendReceiveSync

// Send asynchronous message to server

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

//

void RSensrvClient::SendReceiveAsync( TSensrvServerRequest aRequest, const TIpcArgs& aArgs, TRequestStatus& aStatus ) const

    {

    COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::SendReceiveAsync()" ) ) );

    SendReceive( aRequest, aArgs, aStatus );

    }

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

// RSensrvClient::StartServer

// Starts server.

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

//

TInt RSensrvClient::StartServer() const

    {

    COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::StartServer()" ) ) );

    RProcess server;

    const TUidType serverUid( KNullUid, KSensrvUid2, KNullUid );

    TInt err = server.Create( ServerLocation(), // sensorserver.exe

                           KNullDesC, // A descriptor containing data passed as 

                                      // an argument to the thread function of 

                                      // the new process's main thread, when it 

                                      // is first scheduled.

                           serverUid, // Sensor server UID

                           EOwnerProcess ); // Ownership of this process handle 

    // Return error code if we couldn't create a process

    if ( err == KErrNone )

        {

        // Rendezvous is used to detect server start

        TRequestStatus stat;

        server.Rendezvous( stat );

        if ( stat != KRequestPending )

            {

            ERROR_TRACE( ( _L( "Sensrv Client - RSensrvClient::StartServer - ERROR: Rendezvous failure: %d" ), stat.Int() ) );

            server.Kill( 0 ); // Abort startup

            }

        else

            {

            server.Resume();  // Logon OK - start the server

            }

        COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::StartServer - Waiting server startup" ) ) );

        User::WaitForRequest( stat ); // Wait for start or death

        COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::StartServer - Server startup wait finished" ) ) );

        // We can't use the 'exit reason' if the server paniced as this

        // is the panic 'reason' and may be '0' which cannot be distinguished

        // from KErrNone

        if ( server.ExitType() == EExitPanic ) 

            {

            ERROR_TRACE( ( _L( "Sensrv Client - RSensrvClient::StartServer - ERROR: Server paniced at startup" ) ) );

            err = KErrGeneral;

            }

        else

            {

            err = stat.Int();

            }

        // We can close the handle now

        server.Close();        

        }

    COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::StartServer - return %d" ), err ) );

    return err;

    }

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

// RSensrvClient::ServerLocation

// Returns server location

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

//

TFullName RSensrvClient::ServerLocation() const

    {

    TFullName fullPathAndName( KSensrvExeDrive );

    fullPathAndName.Append( KDC_PROGRAMS_DIR );

    fullPathAndName.Append( KSensrvExeName );

    COMPONENT_TRACE( ( _L( "Sensrv Client - RSensrvClient::ServerLocation - return %S" ), &fullPathAndName ) );

    return fullPathAndName;

    }

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

// RSensrvClient::ServerVersion

// Return version of server

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

//

TVersion RSensrvClient::ServerVersion() const 

    {

    return TVersion( KSensrvVersionMajor, KSensrvVersionMinor, KSensrvVersionBuild );

    }

//  End of File