/*
* Copyright (c) 2007-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:  Harvester session watcher
*
*/

#include "harvestersessionwatcher.h"

// ---------------------------------------------------------------------------
// NewL
// ---------------------------------------------------------------------------
//
CHarvesterSessionWatcher* CHarvesterSessionWatcher::NewL( MHarvesterSessionObserver& aObserver )
	{
    CHarvesterSessionWatcher* self = new ( ELeave ) CHarvesterSessionWatcher( aObserver );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );

    return self;
	}

// ---------------------------------------------------------------------------
// ~CHarvesterSessionWatcher
// ---------------------------------------------------------------------------
//
CHarvesterSessionWatcher::~CHarvesterSessionWatcher() // destruct
	{   
    Cancel();
    iObserver = NULL;
 	}

// ---------------------------------------------------------------------------
// CHarvesterSessionWatcher
// First-phase C++ constructor
// ---------------------------------------------------------------------------
//
CHarvesterSessionWatcher::CHarvesterSessionWatcher( MHarvesterSessionObserver& aObserver )
    : CActive( CActive::EPriorityStandard ), iState( EIdle ), iObserver( &aObserver )
  	{
    // Add to active scheduler.
    CActiveScheduler::Add( this );
	}

// ---------------------------------------------------------------------------
// ConstructL
// ---------------------------------------------------------------------------
//
void CHarvesterSessionWatcher::ConstructL() // second-phase constructor
	{
    _LIT( KHarvesterServerProcess, "HarvesterServer*" );
    TFullName name;
        
    // find Harvester Server
    TFindProcess findProcess( KHarvesterServerProcess );
    if ( findProcess.Next(name) == KErrNone )
        {                      
        User::LeaveIfError( iProcess.Open(name) );
        iState = ERunning;
        // logon to get termination signal
        iProcess.Logon( iStatus );        
        SetActive();
        }
    else
        {
        User::Leave( KErrCommsBreak );
        }
	}

// ---------------------------------------------------------------------------
// DoCancel
// ---------------------------------------------------------------------------
//
void CHarvesterSessionWatcher::DoCancel()
	{
    iState = ESCancelled;
    iProcess.LogonCancel( iStatus );
    iProcess.Close();
	}

// ---------------------------------------------------------------------------
// RunL
// ---------------------------------------------------------------------------
//
void CHarvesterSessionWatcher::RunL()
	{ 
    switch (iState)
        {
          case EIdle:
          case ESCancelled:
              {
              break;
              }       
              
          case ERunning:
              {
              // server terminated, notify clients
              if( iObserver )
                  {
                  iObserver->HarvesterServerTerminated();
                  }
              break;
              }
            
          default:
              break; 
        }
	}
	
// ---------------------------------------------------------------------------
// RunError
// ---------------------------------------------------------------------------
//	
TInt CHarvesterSessionWatcher::RunError( TInt /*aError*/ )
    {   
    return KErrNone;
    }