// Copyright (c) 2004-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:

// cwatcherlauncher.cpp

//

#include "cwatcherlauncher.h"

#include <ecom/ecom.h>

#include <watcher.h>

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS 

#include "cwatcher.h"

#endif

const TInt KWatcherMaxStartCount = 5;

CWatcherLauncher* CWatcherLauncher::NewL(const TDesC& aWatcherName, TUid aWatcherUid, RFs& aFs, CWatcherLog& aLog)

	{

	CWatcherLauncher* self = new (ELeave) CWatcherLauncher(aWatcherUid, aFs, aLog);

	CleanupStack::PushL(self);

	self->ConstructL(aWatcherName);

	CleanupStack::Pop(self);

	return self;

	}

CWatcherLauncher::CWatcherLauncher(TUid aWatcherUid, RFs& aFs, CWatcherLog& aLog)

: CActive(CActive::EPriorityStandard), iWatcherUid(aWatcherUid), iFs(aFs), iLog(aLog)

	{

	CActiveScheduler::Add(this);	

	}

void CWatcherLauncher::ConstructL(const TDesC& aWatcherName)

	{

	// Create timer for use in RunError(). Closed if RunL() doesn't leave

	User::LeaveIfError(iTimer.CreateLocal());

	// iWatcherName is used for logging only. Deleted if RunL() doesn't leave

	iWatcherName = aWatcherName.AllocL();

	// Defer launching of the watcher to RunL()

	TRequestStatus* status = &iStatus;

	User::RequestComplete(status, KErrNone);

	SetActive();

	}

CWatcherLauncher::~CWatcherLauncher()

	{

	Cancel();

	delete iWatcher;

	delete iWatcherName;

	iTimer.Close();

	REComSession::DestroyedImplementation(iDtor_ID_Key);

	}

// methods from CActive

void CWatcherLauncher::RunL()

	{

	iLog.Printf(_L("Watcher %S starting..."), iWatcherName);

	// Create the new watcher object - 	get the instantiation of the active 

	// object form the ECOM server.

	TWatcherParams params(iFs, iLog);

	iWatcher = reinterpret_cast<CActive*>

						(REComSession::CreateImplementationL(

														iWatcherUid,

														iDtor_ID_Key,

														&params));

	// Members no longer required...

	iTimer.Close();

	delete iWatcherName;

	iWatcherName = NULL;

	}

void CWatcherLauncher::DoCancel()

	{

	iTimer.Cancel();

	}

TInt CWatcherLauncher::RunError(TInt aError)

	{

	iLog.Printf(_L("Watcher %S construction error: %d [startCount=%d]"), iWatcherName, aError, iStartCount);

	// Restart the watcher if iStartCount < KWatcherMaxStartCount

	if( iStartCount < KWatcherMaxStartCount )

		{

		++iStartCount;

		iLog.Printf(_L("Watcher %S restarting in %d secs"), iWatcherName, KWatcherDelay/1000000);

		iTimer.After(iStatus, KWatcherDelay);

		SetActive();

		}

	else

		{

		iLog.Printf(_L("Watcher %S permanent fail"), iWatcherName);

		iTimer.Close();

		}

	return KErrNone;

	}