/*

 * Copyright (c) 2010 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:

 *      Client implementation for FlexTimerServerMonitor

 *

 */

/*

 * %version: 1 %

 */

#include "rflextimerservermonitor.h"

#include "flextimerservermonitorcommon.h"

#include "OstTraceDefinitions.h"

#ifdef OST_TRACE_COMPILER_IN_USE

#include "rflextimerservermonitorTraces.h"

#endif

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

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

// Constructs the object.

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

//

EXPORT_C RFlexTimerServerMonitor::RFlexTimerServerMonitor()

    {

    }

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

// Destructs the object.

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

//

EXPORT_C RFlexTimerServerMonitor::~RFlexTimerServerMonitor()

    {

    Close();

    }

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

// Connects to the server and create a session.

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

//

EXPORT_C TInt RFlexTimerServerMonitor::Connect()

    {

    // Starts the server, if it does not already exist in the system.

    TInt ret = StartServer();

    if ( ret == KErrNone )

        { // No session, create it

        ret = CreateSession( 

            KFlexTimerServerMonitorServerName,

            Version(),

            KFlexTimerServerMonitorServerMessageSlots );

        }

    return ret;

    }

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

// Start monitoring FlexTimer server crashes

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

//

EXPORT_C TInt RFlexTimerServerMonitor::StartMonitoring()

    {

    return SendReceive( EFlexTimerServerMonitorStartMonitoring );

    }

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

// Get the status of the monitoring; has FlexTimer server crashed while

// monitoring or not.

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

//

EXPORT_C TInt RFlexTimerServerMonitor::GetStatus( TBool& aHasServerCrashed )

    {

    TPckgBuf<TBool> pckg;

    TIpcArgs args( &pckg );

    TInt ret = SendReceive( EFlexTimerServerMonitorHasServerCrashed, args );

    // Extract the value returned from the server.

    aHasServerCrashed = pckg();

    return ret;

    }

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

// Stop monitoring FlexTimer server crashes

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

//

EXPORT_C TInt RFlexTimerServerMonitor::StopMonitoring()

    {

    return SendReceive( EFlexTimerServerMonitorStopMonitoring );

    }

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

// Gets the version number.

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

//

TVersion RFlexTimerServerMonitor::Version() const

    {

    return ( TVersion( KFlexTimerServerMonitorMajorVersionNumber,

                       KFlexTimerServerMonitorMinorVersionNumber,

                       KFlexTimerServerMonitorBuildVersionNumber ) );

    }

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

// Connects to the server. If server does not exist, it is created.

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

//

TInt RFlexTimerServerMonitor::StartServer()

    {

    TFindServer findServer( KFlexTimerServerMonitorServerName );

    TFullName serverName;

    // See if the server is already started. 

    TInt ret = findServer.Next( serverName );

    if ( ret != KErrNone )

        {

        //Server was not found so create one.

        RProcess serverProcess;

        TBuf<1> serverParameters;

        // Load the executable for the server.

        ret = serverProcess.Create( KFlexTimerServerMonitorServerExe,

                                    serverParameters,

                                    EOwnerThread );

        if ( ret == KErrNone )

            {

            // Server has been created successfully. It is initially 

            // in suspended state. Now resume the server process.

            // Wait until the server process has been started.

            TRequestStatus status;

            serverProcess.Rendezvous( status );

            serverProcess.Resume();

            User::WaitForRequest( status );

            // Check if server has panicked during initialization.

            ret = serverProcess.ExitType();

            if ( ret == EExitPanic )

                {

                ret = KErrServerTerminated;

                }

            else

                {

                ret = status.Int();

                }

            // The server process stands on its own. This handle can

            // be closed. 

            serverProcess.Close();

            }

        }

    return ret;

    }