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

// This contains RootServer Test cases from section 8

// 

//

// EPOC includes

#include <e32base.h>

#include <es_mbman.h>

// Test system includes

#include <networking/log.h>

#include <networking/teststep.h>

#include <networking/testsuite.h>

#include "TestStepRootServer.h"

#include "TestSuiteRootServer.h"

#include "TestAsynchHandler.h"

#include "RootServerTestSection7.h"

#include "RootServerTest.h"

// Test step 7.1 - OOM loop Test1 - Load, Enumerate, GetInfo

CRootServerTest7_1::CRootServerTest7_1()

{

	// store the name of this test case

	iTestStepName = _L("Test7.1");

}

TVerdict CRootServerTest7_1::doTestStepL( void )

	{

	Log(_L("Test Purpose: OOM loop test 1: Load, Enumerate, GetInfo"));

	TVerdict verdict = EPass;

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

    CTestAsynchHandler* asynchHandler = CTestAsynchHandler::NewLC(&iRootServerSuite->RootSess());

	TInt failure = 1000;

	while(verdict == EPass)

		{

		iRootServerSuite->RootSess().__DbgFailNext(failure);

		failure++;

		TRSStartModuleParams startParams;

		TTestModuleIniData iniData;

		DefaultStartParams(startParams, iniData);

		startParams.iParams.iName = KModule1;

		asynchHandler->TryLoad(startParams, iniData);

    	CActiveScheduler::Start();

		if (asynchHandler->iStatus != KErrNone)

			{

			Log(_L("TryLoad: %d with FailNext(%d)"), asynchHandler->iStatus.Int(), failure);

if(asynchHandler->iStatus == KErrRSModuleAlreadyExist)

	User::Leave(KErrRSModuleAlreadyExist);

			continue;

			}

		TCFModuleName moduleName;

		TRSIter position;

		TInt ret = iRootServerSuite->RootSess().EnumerateModules(position, moduleName);

		if(ret != KErrNone)

			{

			Log(_L("EnumerateModules: %d with FailNext(%d)"), asynchHandler->iStatus.Int(), failure);

			continue;

			}

		if(moduleName != KModule1)

			{

			Log(_L8("EnumerateModules() returned KErrNone but wrong name: %S"), &moduleName);

			verdict = EFail;

			break;

			}

		TRSModuleInfo info;

		ret = iRootServerSuite->RootSess().GetModuleInfo(KModule1(), info);

		if(ret != KErrNone)

			{

			Log(_L("GetModuleInfo: %d with FailNext(%d)"), asynchHandler->iStatus.Int(), failure);

			continue;

			}

		if(info.iParams.iState != ERunning)

			{

			Log(_L("GetModuleInfo() returned KErrNone but wrong state: %d"), info.iParams.iState);

			verdict = EFail;

			}

		// everything worked;

		Log(_L("OOM loop complete"));

		break;

		}

	Log(_L("Resetting heap"));

	iRootServerSuite->RootSess().__DbgFailNext(-1);

	// uninstall and destroy active scheduler

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return verdict;

	}

// Test step 7.2 - OOM loop Test2 - Unload, GetInfo

CRootServerTest7_2::CRootServerTest7_2()

{

	// store the name of this test case

	iTestStepName = _L("Test7.2");

}

TVerdict CRootServerTest7_2::doTestStepL( void )

	{

	Log(_L("Test Purpose: Heap loop Test2 - Unload, GetInfo"));

	TVerdict verdict = EPass;

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

    CTestAsynchHandler* asynchHandler = CTestAsynchHandler::NewLC(&iRootServerSuite->RootSess());

	Log(_L8("01 Loading cpm: %S"), &KModule1());

	LoadNormalModuleL(asynchHandler, KModule1);

	TInt failure = 1;

	while(verdict == EPass)

		{

		iRootServerSuite->RootSess().__DbgFailNext(failure);

		failure++;

		asynchHandler->TryUnLoad(KModule1(), EUnGraceful);

    	CActiveScheduler::Start();

		if (asynchHandler->iStatus != KErrNone)

			{

			Log(_L("TryUnload: %d with FailNext(%d)"), asynchHandler->iStatus.Int(), failure);

			if(asynchHandler->iStatus != KErrRSModuleNotLoaded)

				{

				continue;

				}

			}

		TRSModuleInfo info;

		TInt ret = iRootServerSuite->RootSess().GetModuleInfo(KModule1(), info);

		if(ret == KErrRSModuleUnknown)

			{

			// everything worked;

			Log(_L("OOM loop complete"));

			break;

			}

		else if(ret == KErrNone)

			{

			Log(_L("GetModuleInfo() returned KErrNone for unloaded module"));

			verdict = EFail;

			}

		else 

			{

			Log(_L("GetModuleInfo: %d with FailNext(%d)"), ret, failure);

			continue;

			}

		}

	Log(_L("Resetting heap"));

	iRootServerSuite->RootSess().__DbgFailNext(-1);

	// uninstall and destroy active scheduler

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return verdict;

	}

// Test step 7.3 - OOM loop Test 3 - Bind

CRootServerTest7_3::CRootServerTest7_3()

{

	// store the name of this test case

	iTestStepName = _L("Test7.3");

}

TVerdict CRootServerTest7_3::doTestStepL( void )

	{

	Log(_L("Test Purpose: Heap loop Test3 - Bind, EnumerateBindings"));

	TVerdict verdict = EPass;

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

    CTestAsynchHandler* asynchHandler = CTestAsynchHandler::NewLC(&iRootServerSuite->RootSess());

	Log(_L8("01 Loading cpm: %S"), &KModule1());

	LoadNormalModuleL(asynchHandler, KModule1);

	TCFSubModuleAddress fullName1;

	fullName1.SetModule(KModule1());

	fullName1.SetSubModule(KSubModule1());

	TInt failure = 1;

	while(verdict == EPass)

		{

		Log(_L("Failing after %d Allocs"), failure);

		iRootServerSuite->RootSess().__DbgFailNext(failure);

		failure++;

		TInt ret = TryHierachicalBind(asynchHandler, KModule1, KSubModule1, KModule1, KSubModule2);

		if(ret != KErrNone)

			continue;

		Log(_L("02 Enumerate bindings"));

		TRSBindingInfo bindInfo;

		TRSIter position;

		ret = iRootServerSuite->RootSess().EnumerateBindings(fullName1, position, bindInfo);

		if(ret != KErrNone)

			continue;

		// everything worked;

		Log(_L("OOM loop complete"));

		break;

		}		

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return verdict;

	}

// Test step 7.4 - OOM loop Test 4 - Unbind

CRootServerTest7_4::CRootServerTest7_4()

{

	// store the name of this test case

	iTestStepName = _L("Test7.4");

}

TVerdict CRootServerTest7_4::doTestStepL( void )

	{

	Log(_L("Test Purpose: Heap loop Test4 - Unbind, EnumerateBindings"));

	TVerdict verdict = EPass;

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

    CTestAsynchHandler* asynchHandler = CTestAsynchHandler::NewLC(&iRootServerSuite->RootSess());

	Log(_L8("01 Loading and binding cpm: %S"), &KModule1());

	LoadNormalModuleL(asynchHandler, KModule1);

	TInt ret = TryHierachicalBind(asynchHandler, KModule1, KSubModule1, KModule1, KSubModule2);

	if(ret != KErrNone)

		{

		Log(_L("Binding CPM failed with %d"), ret);

		User::Leave(ret);

		}

	TCFSubModuleAddress fullName1;

	fullName1.SetModule(KModule1());

	fullName1.SetSubModule(KSubModule1());

	TInt failure = 1;

	while(verdict == EPass)

		{

		iRootServerSuite->RootSess().__DbgFailNext(failure);

		failure++;

		TRSUnBindingInfo unbindInfo;

		unbindInfo.iParams.iAddress1.SetModule(KModule1());

		unbindInfo.iParams.iAddress1.SetSubModule(KSubModule1());

		unbindInfo.iParams.iAddress2.SetModule(KModule1());

		unbindInfo.iParams.iAddress2.SetSubModule(KSubModule2());

		asynchHandler->TryUnBind( unbindInfo );

		CActiveScheduler::Start();

		if (asynchHandler->iStatus != KErrNone)

			{

			Log(_L("TryUnload: %d with FailNext(%d)"), asynchHandler->iStatus.Int(), failure);

			continue;

			}

		Log(_L("03 Enumerate bindings"));

		TRSBindingInfo bindInfo;

		TRSIter position;

		ret = iRootServerSuite->RootSess().EnumerateBindings(fullName1, position, bindInfo);

		if(ret == KErrEof)

			{

			Log(_L("OOM loop complete"));

			break;

			}

		else if(ret == KErrNone)

			{

			Log(_L("EnumerateBindings returned KErrNone for unbound submodules"));

			verdict = EFail;

			}

		else 

			{

			Log(_L("EnumerateBindings: %d with FailNext(%d)"), ret, failure);

			continue;

			}

		}		

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return verdict;

	}