--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/keepalive/flextimer/test/testflextimer/flextimerservermonitor/src/rflextimerservermonitor.cpp	Mon May 24 20:51:35 2010 +0300
@@ -0,0 +1,164 @@
+/*
+ * 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;
+    }