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

#include "ThreadWatch.h"
#include "Starter.h"

/**
 * class CThreadWatcher
 **/
CThreadWatcher::~CThreadWatcher()
	{
	Cancel();
	}

CThreadWatcher::CThreadWatcher(TInt appType, TFullName aFullName, CStarter* aOwner, TUint32 aAppUid, TBool aViewless)
	: CActive(EPriorityStandard), iAppType(appType), iFullName(aFullName), iOwner(aOwner), iAppUid(aAppUid), iViewless(aViewless)
	{}
	
void CThreadWatcher::ConstructL(const TThreadId aThreadId)
	{
	iMonitoringThread = ETrue;
	User::LeaveIfError(iThread.Open(aThreadId)); // Queue logon request
	iThread.Logon(iStatus);
	CActiveScheduler::Add(this);
	SetActive(); // Tell scheduler we're active
	}

CThreadWatcher* CThreadWatcher::NewL(TInt appType, const TThreadId aThreadId, TFullName aFullName, CStarter* aOwner, TUint32 aAppUid, TBool aViewless)
	{
	CThreadWatcher* self = new (ELeave) CThreadWatcher(appType, aFullName, aOwner, aAppUid, aViewless);
	CleanupStack::PushL(self);
	self->ConstructL(aThreadId);
	CleanupStack::Pop(); // self;
	return self;
	}

void CThreadWatcher::DoCancel()

	{
	iThread.LogonCancel(iStatus);
	iThread.Close();
	}

void CThreadWatcher::RunL()
	{
	iThread.Close();
	if(iMonitoringThread) 
		{
		TRAPD(err, RestartThreadL()); //ignore error
		}
	}

void CThreadWatcher::RestartThreadL()
	{
	TThreadId threadId;
	iOwner->RestartMonitoredThreadL(iAppType, threadId, iFullName, iAppUid, iViewless);
	User::LeaveIfError(iThread.Open(threadId)); // Queue logon request
	iThread.Logon(iStatus);
	iStatus = KRequestPending;
	SetActive(); // Tell scheduler we're active
	}