/*

* 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 the License "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: 

* ThreadMonitor - closes started threads after a specified timeout

*

*/

/**

 @file 

 @released

 @internalComponent

*/

#include <e32std.h>

#ifndef SWI_TEXTSHELL_ROM

#include <eikenv.h>

#include <apgwgnam.h>

#include <apgtask.h>

#include <w32std.h>

#endif

#include "threadmonitor.h"

#include "log.h"

using namespace Swi;

CThreadMonitor* CThreadMonitor::NewL(TThreadId aTThreadId, RWsSession* aWsSession)

    {

	CThreadMonitor* self = CThreadMonitor::NewLC(aTThreadId, aWsSession);

    CleanupStack::Pop(self);

    return self;

    }

CThreadMonitor* CThreadMonitor::NewLC(TThreadId aTThreadId, RWsSession* aWsSession)

    {

	CThreadMonitor* self = new (ELeave) CThreadMonitor(aTThreadId, aWsSession);

	CleanupStack::PushL(self);

	self->ConstructL();

    return self;

    }

CThreadMonitor::CThreadMonitor(TThreadId aTThreadId, RWsSession* aWsSession)

				: iTThreadId(aTThreadId), iWsSession(aWsSession)

     {

     }

CThreadMonitor::~CThreadMonitor()

    {

    iThread.Close();

    }

void CThreadMonitor::ConstructL()

	{

	TInt err = iThread.Open(iTThreadId);

	if(err == KErrNone)

		{

		iThreadAlreadyClosed = EFalse;

		}

	else if (err == KErrNotFound)

		{

		iThreadAlreadyClosed = ETrue;

		}

	else

		{

		User::Leave(err);

		}

	}

void CThreadMonitor::SyncShutdownL(TInt aDelay, TBool aKillOnTimeout, TInt aApplicationShutdownTimeout)

    {

    DEBUG_PRINTF(_L8("Sis Launcher Server - Waiting for application to terminate."));

    if(!iThreadAlreadyClosed)

    	{

		// make the timing loop 'time' dependent (see PDEF107100)

		TTime startTime;

		startTime.UniversalTime();

		TTime currentTime = startTime;

		// If swipolicy.ini has -1 set for RunWaitTimeoutSeconds

		// aDelay will be -1000000.  In this case we wait as long

		// as it takes for the thread to exit.

		TBool noTimeout = (aDelay == -1000000) ? ETrue : EFalse;

		while ((iThread.ExitType() == EExitPending) && 

		((currentTime.MicroSecondsFrom(startTime) < aDelay) || noTimeout))

			{

			User::After(1000000); // 1 second

			currentTime.UniversalTime();

			} 

		// We may need to shut down or kill the app/process.

		if (iThread.ExitType() == EExitPending && aKillOnTimeout)

			{

			#ifdef SWI_TEXTSHELL_ROM

				(void) aApplicationShutdownTimeout;

				DEBUG_PRINTF(_L8("Sis Launcher Server - Application still running after timeout. graceful shutdown skipped."));

			#else

			// iWsSession will be NULL if running textshell in emulator.

			// Here no graceful shutdown will be tried.

			if(NULL != iWsSession)

				{

				DEBUG_PRINTF(_L8("Sis Launcher Server - Application still running after timeout. Attempting graceful shutdown."));

				// Attempt graceful shutdown first if this is an app which handles

				// shutdown events.

				CApaWindowGroupName* wgName = CApaWindowGroupName::NewL(*iWsSession);

				CleanupStack::PushL(wgName);

				TInt wgId = iWsSession->FindWindowGroupIdentifier(0, iThread.Id());

				if (wgId != KErrNotFound)

					{

					wgName->ConstructFromWgIdL(wgId);

					if(wgName->RespondsToShutdownEvent())

						{

						TRequestStatus threadStatus;

						iThread.Logon(threadStatus);

						TApaTask task(*iWsSession);

						task.SetWgId(wgId);

						task.SendSystemEvent(EApaSystemEventShutdown);

						RTimer timer;

						CleanupClosePushL(timer);

						TRequestStatus timerStatus;

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

						timer.After(timerStatus, aApplicationShutdownTimeout);

						User::WaitForRequest(threadStatus,timerStatus);

						if (threadStatus==KRequestPending)

							{

							// Timer completed, cancel rendezvous, process will

							// be killed below.

							iThread.LogonCancel(threadStatus);

							}

						else if (timerStatus==KRequestPending)

							{

							// Rendezvous completed so cancel timer

							timer.Cancel();

							}

						// Catch second request.

						User::WaitForRequest(threadStatus,timerStatus);

						CleanupStack::PopAndDestroy(&timer);

						}

					}

				CleanupStack::PopAndDestroy(wgName);

				}

			#endif

			}

		// If we haven't managed to shut it down gracefully, we need to kill

		// the process.

		if (iThread.ExitType() == EExitPending) 

			{

			DEBUG_PRINTF(_L8("Sis Launcher Server - Application still running. Killing it."));

			RProcess process;

			User::LeaveIfError(iThread.Process(process));

			process.Kill(KErrNone);

			process.Close();

			}

    	}

    }