--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/watchdog/src/servermonitor.cpp	Tue Oct 05 13:15:12 2010 +0530
@@ -0,0 +1,294 @@
+/*
+* Copyright (c) 2009 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: Monitoring application for servers restarting & IAD
+*
+*/
+
+
+#include "servermonitor.h"
+
+_LIT(KStar , "*");
+_LIT(KExtension, ".exe");
+_LIT(KSemaphore, "Semaphore");
+
+// ======== MEMBER FUNCTIONS ========
+// ---------------------------------------------------------------------------
+// Constructor.
+// ---------------------------------------------------------------------------
+//
+CServerMonitor* CServerMonitor::NewL( TDesC& aServerName , TUid aServerUid )
+    {   
+    CServerMonitor* self = new ( ELeave ) CServerMonitor();
+    CleanupStack::PushL( self );
+    self->ConstructL( aServerName , aServerUid );
+    CleanupStack::Pop( self );
+
+    return self;
+    }
+
+// ---------------------------------------------------------------------------
+// C++ constructor.
+// ---------------------------------------------------------------------------
+//
+CServerMonitor::CServerMonitor() : 
+    CActive( CActive::EPriorityStandard ), iState(EIdle)
+    {
+    // Add to active scheduler.
+    CActiveScheduler::Add( this );
+    }
+
+// ---------------------------------------------------------------------------
+// 2nd phase constructor.
+// ---------------------------------------------------------------------------
+//
+void CServerMonitor::ConstructL( TDesC& aServerName , TUid aServerUid )
+    {
+        
+    TFullName name;
+    //Update the member variables
+    iServerName = HBufC::NewL( aServerName.Length() );
+    TPtr servernameptr = iServerName->Des();
+    servernameptr.Copy( aServerName );
+    
+    iServerUid.iUid = aServerUid.iUid;
+    // find Harvester Server
+    // Append * to the server name for the findprocess
+    HBufC* servername = HBufC::NewL( iServerName->Length() + 1 );
+    TPtr nameptr = servername->Des();
+    nameptr.Copy( aServerName );
+    nameptr.Append( KStar );
+    
+    TFindProcess findProcess( *servername );
+    if ( findProcess.Next(name) == KErrNone )
+        {              
+        User::LeaveIfError( iProcess.Open(name) );
+        iState = ERunning;
+        // logon to get termination signal
+        iProcess.Logon(iStatus);        
+        SetActive();
+        }        
+    else
+        { 
+        // start new Harvester            
+        StartL();
+        }
+    
+    delete servername;
+    
+    }
+
+void CServerMonitor::StartL()
+    {  
+
+    // Double check that harvester server is not already running
+    TFullName name;
+    TInt res( KErrNone );
+    // Append * to the server name for the findprocess
+    HBufC* servername = HBufC::NewL( iServerName->Length() + 1 );
+    TPtr servernameptr = servername->Des();
+    servernameptr.Copy( *iServerName );
+    servernameptr.Append( KStar );
+    // find really Harvester Server, using TFindServer to avoid logon a dead process
+    TFindServer findServer( *servername );
+    
+    if ( findServer.Next(name) == KErrNone )
+        {
+        TFindProcess findProcess( *servername );
+        if ( findProcess.Next(name) == KErrNone )
+            {            
+            iProcess.Close();
+            res = iProcess.Open(name);
+            if ( res != KErrNone )
+                {
+                delete servername;
+                return;
+                }
+            iState = EWaitingRendezvous;
+            SetActive();
+            delete servername;
+            return;
+            }
+        }  
+    
+    // close the panic process
+    TFindProcess findProcess( *servername );
+    if ( findProcess.Next(name) == KErrNone )
+        {                
+        iProcess.Close();
+        }
+    delete servername;
+    servername = NULL;
+    // Create the server process
+    StartServerProcessL(); 
+    }    
+
+// ---------------------------------------------------------------------------
+// Destructor
+// ---------------------------------------------------------------------------
+//
+CServerMonitor::~CServerMonitor()
+    {
+    delete iServerName;
+    Cancel();
+    }
+
+// ---------------------------------------------------------------------------
+// Active object's request handling.
+// ---------------------------------------------------------------------------
+//
+void CServerMonitor::RunL()
+    {    	
+    	switch (iState)
+    	{
+          case EIdle:
+              {
+              break;
+              }
+              
+          case EWaitingRendezvous:          
+              {
+              iState = ERunning;              
+              // logon to get termination signal
+              TRAPD(err,iProcess.Logon(iStatus));
+              if ( err == KErrNone )
+                 SetActive();
+              break;
+              }             
+              
+          case ERunning:
+              {
+              // server died unexpectedly, start it    
+              StartL();
+              break;
+              }            
+          default:
+              break; 
+          
+    	}
+    
+    }
+
+// ---------------------------------------------------------------------------
+// Active object's request error handling.
+// ---------------------------------------------------------------------------
+//
+TInt CServerMonitor::RunError( TInt /*aError*/ )
+    {
+    return KErrNone;
+    }
+
+// ---------------------------------------------------------------------------
+// Cancel the request.
+// ---------------------------------------------------------------------------
+//
+void CServerMonitor::DoCancel()
+    {
+    iProcess.LogonCancel(iStatus);
+    iProcess.Close();
+    }
+
+// ---------------------------------------------------------------------------
+// StartServerProcess
+// ---------------------------------------------------------------------------
+//
+void CServerMonitor::StartServerProcessL()
+    {
+    RSemaphore semaphore;
+    HBufC* semaphorename = HBufC::NewL( iServerName->Length() + 10 );
+    TPtr semptr = semaphorename->Des();
+    semptr.Copy( *iServerName );
+    semptr.Append( KSemaphore );
+    
+    TInt result = semaphore.CreateGlobal( *semaphorename, 0 );
+    if (result != KErrNone)
+        {
+        delete semaphorename;
+        return ;
+        }
+
+    TRAP(result, CreateServerProcess());
+    if (result != KErrNone)
+        {
+        return ;
+        }
+
+    semaphore.Wait();
+    semaphore.Close();
+    delete semaphorename;
+    return ;
+    }
+        
+// ---------------------------------------------------------------------------
+// CreateServerProcess
+// ---------------------------------------------------------------------------
+//
+void CServerMonitor::CreateServerProcess()
+    {
+    TInt result;
+
+    const TUidType serverUid( KNullUid, KNullUid, iServerUid);
+    
+    HBufC* servernameext = HBufC::NewL( iServerName->Length() + 4 );
+    TPtr ptr = servernameext->Des();
+    ptr.Copy( *iServerName );
+    ptr.Append( KExtension );
+    //result = iProcess.Create( *iServerName, KNullDesC, serverUid);
+    result = iProcess.Create( *iServerName, KNullDesC);
+    if (result != KErrNone)
+        {
+        delete servernameext;
+        return ;
+        }
+
+
+    // start process and wait until it is constructed                
+    iProcess.Rendezvous(iStatus);
+    
+    if( iStatus != KRequestPending )
+        {
+        iProcess.Kill( 0 );   // abort startup
+        }
+    else
+        {    
+        iProcess.Resume();    // logon OK - start the server   
+        iState = EWaitingRendezvous;
+        SetActive();
+        
+        }
+    delete servernameext;
+    return ;
+    }
+
+// ---------------------------------------------------------------------------
+// CreateServerProcess
+// ---------------------------------------------------------------------------
+//
+void CServerMonitor::ShutdownServer()
+    {
+    HBufC* servername = HBufC16::NewLC( iServerName->Length() + 5 );
+    TPtr servernameptr = servername->Des();
+    servernameptr.Copy( *iServerName );
+    servernameptr.Append( KExtension );
+    servernameptr.Append( KStar );
+    TFindProcess processFinder( *servername );
+    TFullName result;
+    RProcess processHandle;
+    while ( processFinder.Next(result) == KErrNone) 
+    {
+       User::LeaveIfError(processHandle.Open ( processFinder, EOwnerThread));
+       processHandle.Kill(KErrNone);
+       processHandle.Close();
+    }
+    CleanupStack::PopAndDestroy( servername );
+    }