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

//

/**

 @file notificationtester.cpp

*/

#include "notificationtester.h"

CNotificationTester* CNotificationTester::NewL(const TDesC &aThreadName, CommsDat::CMDBSession* aSession, CommsDat::CMDBElement* aElement)

	{

	CNotificationTester* self = new(ELeave) CNotificationTester(aSession, aElement);

	CleanupStack::PushL(self);

	self->ConstructL(aThreadName);

	CleanupStack::Pop(self);

	return self;

	}

CNotificationTester::CNotificationTester(CommsDat::CMDBSession* aSession, CommsDat::CMDBElement* aElement)

:CActive(0)

	{

	iSession = aSession;

	iElement = aElement;

	}

void CNotificationTester::ConstructL(const TDesC &aThreadName)

	{

	iThreadRunning = EFalse;

	iThread.Create(aThreadName, &ThreadFunction, KDefaultStackSize, NULL, this);

	TRequestStatus waitSchedulerInstallation;  		// Create a rendezvous to ensure that thread

	iThread.Rendezvous(waitSchedulerInstallation);  // completes installation of scheduler before ConstructL finishes

	iThread.Resume(); 

	User::WaitForRequest(waitSchedulerInstallation);

	}

CNotificationTester::~CNotificationTester()

	{

	Cancel();

	iThread.Close();

	}

void CNotificationTester::SetTester()

	{

	if(iThread.ExitReason() >0 )

		{

		iReason = iThread.ExitReason();

		return;

		}

	iElement->RequestNotification(*iSession, iStatus);

	SetActive();

	}

void CNotificationTester::LogOn(TRequestStatus &aStatus)

	{

	iThread.Logon(aStatus);

	}

void CNotificationTester::RunL()

	{

	CActiveScheduler::Stop();

	}

void CNotificationTester::DoCancel()

	{

	if((iElement != NULL) && (iSession != NULL))

		iElement->CancelNotification(*iSession, iStatus);

	}

void CNotificationTester::CancelNotification(TRequestStatus& /*aStatus*/)	

	{

	// Note: this method is not called in the same thread that originally created and

	// registered the CNotificationTester.  Consequently, issuing Cancel() here will perform

	// the DoCancel(), which will complete the CNotificationTester in the creating thread,

	// but then erroneously perform a User::WaitForRequest() in the *current* thread, swallowing

	// the next unsuspecting completion signal in the current thread.

	DoCancel();

	}

TInt CNotificationTester::ThreadFunction(TAny *aPtr)

	{

	CTrapCleanup* cleanup=CTrapCleanup::New();

	TRAPD(errCode, DoThreadFunctionL(aPtr));

	delete cleanup;

	return errCode;

	}

TInt CNotificationTester::DoThreadFunctionL(TAny *aPtr)

	{

	CActiveScheduler* scheduler=new (ELeave) CActiveScheduler;

    CleanupStack::PushL(scheduler);

    CActiveScheduler::Install(scheduler);

    ((CNotificationTester *)aPtr)->iThreadRunning = ETrue;	

	CActiveScheduler::Add((CActive *)aPtr);

	CNotificationTester *tester = (CNotificationTester*)(aPtr);

	tester->SetTester();

	RThread::Rendezvous(KErrNone); // Signal the main thread that notification has been requested

	CActiveScheduler::Start();

	CleanupStack::PopAndDestroy(scheduler);	

	return KErrNone;

	}