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

// Implements the handling of run mode events for a particular target executable

// 

#include <e32base.h>

#include <e32property.h>

#include <e32test.h>

#include "t_rmdebug_app.h"

#include "t_agent_eventhandler.h"

#include "t_multi_agent.h"

#include "t_debug_logging.h" 

using namespace Debug;

CAgentAsyncEvent::CAgentAsyncEvent(CMultiAgent& aDriver, const TDesC& aExeName, const TDesC& aExeConfig):

	CActive(EPriorityStandard), iDriver(aDriver)

	{

	}

CAgentAsyncEvent* CAgentAsyncEvent::NewLC(CMultiAgent& aDriver, const TDesC& aExeName, const TDesC& aExeConfig)

	{

	CAgentAsyncEvent* self = new(ELeave) CAgentAsyncEvent(aDriver, aExeName, aExeConfig);

	CleanupStack::PushL(self);

	self->ConstructL(aExeName, aExeConfig);

	return self;

	}

CAgentAsyncEvent* CAgentAsyncEvent::NewL(CMultiAgent& aDriver, const TDesC& aExeName, const TDesC& aExeConfig)

	{

	CAgentAsyncEvent* self = CAgentAsyncEvent::NewLC(aDriver, aExeName, aExeConfig);

	CleanupStack::Pop(); // self

	return self;

	}

void CAgentAsyncEvent::ConstructL(const TDesC& aExeName, const TDesC& aExeConfig)

	{

	iExeName.CreateL(aExeName);

	iExeConfig.CreateL(aExeConfig);

	CActiveScheduler::Add(this);

	}

CAgentAsyncEvent::~CAgentAsyncEvent()

	{

	LOG_MSG2("~CAgentAsyncEvent(), this = 0x%08x", this);

	iSEventInfo.iEventInfoBuf.Delete(0, sizeof(TEventInfo));

	iExeName.Close();

	iExeConfig.Close();

	iProc.Close();

	Cancel(); // Cancel any request, if outstanding

	}

/*

 * Issue request to DSS and notify the active scheduler

 */

void CAgentAsyncEvent::Watch()

	{

	LOG_MSG2("ENTER: CAgentAsyncEvent::Watch, this = 0x%08x", this);

	iDriver.DebugDriver().GetEvent(GetExecutable(), iStatus, iSEventInfo.iEventInfoBuf);

	if (!IsActive())

		{

		LOG_MSG("CAgentAsyncEvent::Watch(): SetActive()");

		SetActive();

		}

	LOG_MSG("EXIT: CAgentAsyncEvent::Watch");

	}

void CAgentAsyncEvent::RunL()

	{

	LOG_MSG4("ENTER: CAgentAsyncEvent::RunL iDebugType=%d, iStatus.Int() %d, this 0x%x08", 

			 iSEventInfo.iEventInfo.iEventType, iStatus.Int(), this);

    LOG_MSG2("%S", &TPtr8((TUint8*)GetExecutable().Ptr(), 2*GetExecutable().Length(), 2*GetExecutable().Length()));	

	iDriver.HandleEvent(iSEventInfo.iEventInfo);

	LOG_MSG2("iDriver.GetNumApps() %d: ", iDriver.GetNumApps());

	LOG_MSG2("iDriver.iLaunchCompleted  %d: ", iDriver.GetLaunchCompleted());

	if (iDriver.GetLaunchCompleted() < iDriver.GetNumApps())

		{

		// Do not call Watch() if target has run to completion but test is still on going

		if (iSEventInfo.iEventInfo.iEventType != EEventsRemoveProcess)

			{

			LOG_MSG("CAgentAsyncEvent::RunL Setting Watch()");

			Watch();

			}

		}

	else

		{

		// Stop event handling for all targets

		LOG_MSG("CAgentAsyncEvent::RunL CActiveScheduler::Stop() & Cancel");

		CActiveScheduler::Stop();

		}

	LOG_MSG2("EXIT: CAgentAsyncEvent::RunL", KNullDesC);

	}

void CAgentAsyncEvent::DoCancel()

	{

	LOG_MSG("CAgentAsyncEvent::DoCancel");

	}

TInt CAgentAsyncEvent::RunError(TInt aError)

	{

	LOG_MSG3(" RunL() has left with error %d, this 0x%08X", aError, this);

	return aError; 

	// Can we handle this error? Not at the moment!

	}