// 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 ESock Test cases from section 3

// 

//

// 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 "TestAsynchHandler.h"

#include "RootServerTest.h"

#include "RootServerTestSection3.h"

#include <es_mbman.h>

// Note: Test step 3.1 was a RRootServ::Connect() test; this is now obsolete

// Test step 3.2 - SetMBufPoolSize After LoadServer

CRootServerTest3_2::CRootServerTest3_2(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.2"));

	}

TVerdict CRootServerTest3_2::doTestStepL( void )

	{

	SetTestStepResult(EPass);	

	INFO_PRINTF1(_L("Test Purpose: SetMBufPoolSize After LoadServer"));

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	INFO_PRINTF2(_L("01 Loading test module: %S"), &KModule1());

	LoadNormalModuleL(asynchHandler, KModule1);

	// uninstall and destroy active scheduler

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	// now try to set the buffer pool size

	INFO_PRINTF1(_L("03 Setting MBufPoolSize"));

	TInt ret = iRootServerSuite->RootSess().SetMBufPoolSize(0,KMBufDefaultHeapSize);

	INFO_PRINTF2(_L("SetMBufPoolSize returned %d"), ret);

	if (KErrInUse != ret) 

		{

		SetTestStepResult(EFail);	

		}

	return TestStepResult();

	}

// Test step 3.5 - Retrieve Module Information

CRootServerTest3_DblLoad::CRootServerTest3_DblLoad(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	}

TVerdict CRootServerTest3_DblLoad::LoadSameModuleTwiceL(TThreadPriority aPriority)

	{

	SetTestStepResult(EPass);	

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	TRSStartModuleParams startParams;

	TTestModuleIniData iniData;

	DefaultStartParams(startParams, iniData);

	startParams.iParams.iName = KModule1;

	startParams.iParams.iPriority = aPriority;

	INFO_PRINTF2(_L("02 Loading module: %S"), &startParams.iParams.iName);

	asynchHandler->TryLoad(startParams, iniData);

	CActiveScheduler::Start();

    if (asynchHandler->iStatus != KErrNone)

		{

		INFO_PRINTF2(_L("LoadServer returned error: <%d> "), asynchHandler->iStatus.Int());

		User::Leave(asynchHandler->iStatus.Int());

		}

	// try to load same module again

	INFO_PRINTF1(_L("03 Trying to load same module again"));

	asynchHandler->TryLoad(startParams, iniData);

	CActiveScheduler::Start();

	INFO_PRINTF2(_L("LoadServer returned %d"), asynchHandler->iStatus.Int());

    if (asynchHandler->iStatus != KErrRSModuleAlreadyExist)

		{

		SetTestStepResult(EFail);	

		}

	// uninstall and destroy active scheduler

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return TestStepResult();

	}

// Test step 3.3 - Load Same Module Twice

CRootServerTest3_3::CRootServerTest3_3(CTE_RootServerServer *aSuite) : CRootServerTest3_DblLoad(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.3"));

	}

TVerdict CRootServerTest3_3::doTestStepL( void )

	{

	INFO_PRINTF1(_L("Test Purpose: Load Same Module Twice (normal priority)"));

	return LoadSameModuleTwiceL(EPriorityNormal);

	}

// Test step 3.4 - Load Same Module Twice with elevated priority

CRootServerTest3_4::CRootServerTest3_4(CTE_RootServerServer *aSuite) : CRootServerTest3_DblLoad(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.4"));

	}

TVerdict CRootServerTest3_4::doTestStepL( void )

	{

	INFO_PRINTF1(_L("Test Purpose: Load Same Module Twice (elevated priority)"));

	return LoadSameModuleTwiceL(EPriorityRealTime);

	}

// Test step 3.5 - Retrieve Module Information

CRootServerTest3_5::CRootServerTest3_5(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.5"));

	}

TVerdict CRootServerTest3_5::doTestStepL( void )

	{

	SetTestStepResult(EPass);	

	INFO_PRINTF1(_L("Test Purpose: Retrieve Module Information"));

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	TRSStartModuleParams startParams;

	TTestModuleIniData iniData;

	DefaultStartParams(startParams, iniData);

	startParams.iParams.iName = KModule1;

	INFO_PRINTF2(_L("02 Loading module: %S"), &startParams.iParams.iName);

	asynchHandler->TryLoad(startParams, iniData);

	CActiveScheduler::Start();

    if (asynchHandler->iStatus != KErrNone)

		{

		INFO_PRINTF2(_L("LoadServer returned error: <%d> "), asynchHandler->iStatus.Int());

		User::Leave(asynchHandler->iStatus.Int());

		}

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	// now try to retrieve information about the module

	INFO_PRINTF1(_L("03 Getting module information"));

	TRSModuleInfo info;

	TCFModuleName moduleName = KModule1();

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

	INFO_PRINTF3(_L("GetModuleInfo for %S returned %d"), &moduleName, ret);

	if(KErrNone != ret)

		{

        SetTestStepResult(EFail);		return TestStepResult();

		}

	Log(_L("Filename %S, State %d, NumSubmodules %d"), 

		&info.iParams.iDll, info.iParams.iState, info.iParams.iNumSubModules);

	if (startParams.iParams.iFilename != info.iParams.iDll ||

		ERunning != info.iParams.iState ||

		3 != info.iParams.iNumSubModules)

		{

        SetTestStepResult(EFail);

        return TestStepResult();

		}

	// now ask for info about a non-existent module

	INFO_PRINTF1(_L("04 Getting module information for non-existent module"));

	moduleName = KModule2;

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

	INFO_PRINTF3(_L("GetModuleInfo for %S returned %d"), &moduleName, ret);

	if(KErrRSModuleUnknown != ret)

		{

        SetTestStepResult(EFail);	

        return TestStepResult();

		}

	return TestStepResult();

	}

// Test step 3.6 - CancelLoadModule Before Thread Starts

CRootServerTest3_6::CRootServerTest3_6(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.6"));

	}

TVerdict CRootServerTest3_6::doTestStepL( void )

	{

	SetTestStepResult(EPass);	

	INFO_PRINTF1(_L("Test Purpose: CancelLoadModule Before Thread Starts"));

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	TRSStartModuleParams startParams;

	TTestModuleIniData iniData;

	DefaultStartParams(startParams, iniData);

	startParams.iParams.iName = KModule1;

	iniData.iParams.iInitDelay = isRendezvousDelayTime;

	INFO_PRINTF2(_L("02 Loading module: %S"), &startParams.iParams.iName);

	asynchHandler->TryLoad(startParams, iniData);

//	User::After(5000000);

	INFO_PRINTF2(_L("03 Cancelling Loading module: %S"), &startParams.iParams.iName);

	iRootServerSuite->RootSess().CancelLoadCpm(startParams.iParams.iName);

	CActiveScheduler::Start();

    INFO_PRINTF2(_L("LoadServer status was: <%d> "), asynchHandler->iStatus.Int());

    if ((KErrCancel != asynchHandler->iStatus.Int()) && (KErrNone != asynchHandler->iStatus.Int()))

		{

		SetTestStepResult(EFail);	

		}

    // Unload the CPM anyway in case we were too late to cancel the load.

    TRequestStatus status;

    iRootServerSuite->RootSess().UnloadCpm(status, startParams.iParams.iName, EImmediate);

    User::WaitForRequest(status);

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return TestStepResult();

	}

// Test step 3.7 - CancelLoadServer After Rendezvous

CRootServerTest3_7::CRootServerTest3_7(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.7"));

	}

TVerdict CRootServerTest3_7::doTestStepL( void )

	{

	SetTestStepResult(EPass);	

	INFO_PRINTF1(_L("Test Purpose: CancelLoadServer After Rendezvous"));

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	TRSStartModuleParams startParams;

	TTestModuleIniData iniData;

	DefaultStartParams(startParams, iniData);

	startParams.iParams.iName = KModule1;

	INFO_PRINTF2(_L("02 Loading module: %S"), &startParams.iParams.iName);

	asynchHandler->TryLoad(startParams, iniData);

	// now wait for testserver to meet rendezvous before cancelling load (give it 

	User::After(1000000);

	INFO_PRINTF2(_L("03 Cancelling Loading module: %S"), &startParams.iParams.iName);

	iRootServerSuite->RootSess().CancelLoadCpm(startParams.iParams.iName);

	CActiveScheduler::Start();

    INFO_PRINTF2(_L("LoadServer status was: <%d> "), asynchHandler->iStatus.Int());

    if (KErrNone != asynchHandler->iStatus.Int())

		{

		SetTestStepResult(EFail);	

		}

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return TestStepResult();

	}

// Test step 3.8 - Close Session with Pending LoadServer

CRootServerTest3_8::CRootServerTest3_8(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.8"));

	}

TVerdict CRootServerTest3_8::doTestStepL( void )

	{

	SetTestStepResult(EPass);	

	INFO_PRINTF1(_L("Test Purpose: Close Session with Pending LoadServer"));

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	TRSStartModuleParams startParams;

	TTestModuleIniData iniData;

	DefaultStartParams(startParams, iniData);

	startParams.iParams.iName = KModule1;

	iniData.iParams.iInitDelay = isRendezvousDelayTime;

	INFO_PRINTF2(_L("02 Loading module: %S"), &startParams.iParams.iName);

	asynchHandler->TryLoad(startParams, iniData);

	INFO_PRINTF1(_L("03 Closing Session"));

	iRootServerSuite->RootSess().Close();

	INFO_PRINTF1(_L("RRootServ.Close() completed"));

	CActiveScheduler::Start();

	// note that if the session was closed before the module's thread started,

	// the handler should have been KErrCancelled

    INFO_PRINTF2(_L("LoadServer status was: <%d> "), asynchHandler->iStatus.Int());

    if ((KErrCancel != asynchHandler->iStatus.Int()) && (KErrNone != asynchHandler->iStatus.Int()))

		{

		SetTestStepResult(EFail);	

		}

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return TestStepResult();

	}

// Test step 3.9 - Module Exits Before Rendezvous

CRootServerTest3_9::CRootServerTest3_9(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.9"));

	}

TVerdict CRootServerTest3_9::doTestStepL( void )

	{

	SetTestStepResult(EFail);	

	INFO_PRINTF1(_L("Test Purpose: Module Exits Before Rendezvous"));

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	TRSStartModuleParams startParams;

	TTestModuleIniData iniData;

	DefaultStartParams(startParams, iniData);

	startParams.iParams.iName = KModule1;

	iniData.iParams.iInitDelay = EXIT_BEFORE_RENDEZVOUS;

	INFO_PRINTF2(_L("03 Loading module: %S"), &startParams.iParams.iName);

	asynchHandler->TryLoad(startParams, iniData);

	CActiveScheduler::Start();

    INFO_PRINTF2(_L("LoadServer status was: <%d>"), asynchHandler->iStatus.Int());

    if (KErrNone != asynchHandler->iStatus.Int())

		{

		SetTestStepResult(EPass);	

		}

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return TestStepResult();

	}

// Test step 3.10 - Module Panics Before Meeting Rendezvous

CRootServerTest3_10::CRootServerTest3_10(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.10"));

	}

TVerdict CRootServerTest3_10::doTestStepL( void )

	{

	SetTestStepResult(EFail);	

	INFO_PRINTF1(_L("Test Purpose: Module Panics Before Meeting Rendezvous"));

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	TRSStartModuleParams startParams;

	TTestModuleIniData iniData;

	DefaultStartParams(startParams, iniData);

	startParams.iParams.iName = KModule1;

#ifdef SYMBIAN_C32ROOT_API_V3

	startParams.iParams.iControlFlags = TRSStartModuleParamContainer::KCF_UnstableModule;

#endif

	iniData.iParams.iInitDelay = PANIC_BEFORE_RENDEZVOUS;

	// make sure WINS doesn't stop at panic

	TBool jitDbg = User::JustInTime();

	User::SetJustInTime(EFalse);

	INFO_PRINTF2(_L("03 Loading module: %S"), &startParams.iParams.iName);

	asynchHandler->TryLoad(startParams, iniData);

	CActiveScheduler::Start();

    INFO_PRINTF2(_L("LoadServer status was: <%d> "), asynchHandler->iStatus.Int());

    if (KErrNone != asynchHandler->iStatus.Int())

		{

		SetTestStepResult(EPass);	

		}

	// Restore enclosing JIT status

	User::SetJustInTime(jitDbg);

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return TestStepResult();

	}

// Test step 3.11 - Module Panics After Meeting Rendezvous

CRootServerTest3_11::CRootServerTest3_11(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.11"));

	}

TVerdict CRootServerTest3_11::doTestStepL( void )

	{

										SetTestStepResult(EFail);	

	INFO_PRINTF1(_L("Test Purpose: Module Panics After Meeting Rendezvous"));

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	TRSStartModuleParams startParams;

	TTestModuleIniData iniData;

	DefaultStartParams(startParams, iniData);

	startParams.iParams.iName = KModule1;

#ifdef SYMBIAN_C32ROOT_API_V3

	startParams.iParams.iControlFlags = TRSStartModuleParamContainer::KCF_UnstableModule;

#endif

	iniData.iParams.iInitDelay = PANIC_AFTER_RENDEZVOUS;

	// make sure WINS doesn't stop at panic

	TBool jitDbg = User::JustInTime();

	User::SetJustInTime(EFalse);

	INFO_PRINTF2(_L("03 Loading module: %S"), &startParams.iParams.iName);

	asynchHandler->TryLoad(startParams, iniData);

	CActiveScheduler::Start();

    INFO_PRINTF2(_L("LoadServer status was: <%d> "), asynchHandler->iStatus.Int());

    if (KErrServerTerminated == asynchHandler->iStatus.Int())

		{

		SetTestStepResult(EPass);	

		}

	// Restore enclosing JIT status

	User::SetJustInTime(jitDbg);

	// destroy active scheduler

	CleanupStack::PopAndDestroy(asynchHandler);

	CleanupStack::PopAndDestroy(scheduler);

	return TestStepResult();

	}

// Test step 3.12 - Load 2 modules sharing the same heap

CRootServerTest3_12::CRootServerTest3_12(CTE_RootServerServer *aSuite) : CTestStepRootServer(aSuite)

	{

	// store the name of this test case

	SetTestStepName(_L("Test3.12"));

	}

TVerdict CRootServerTest3_12::doTestStepL( void )

	{

	INFO_PRINTF1(_L("Test Purpose: Load 2 modules sharing the same heap"));

	SetTestStepResult(EPass);	

	// Create scheduler/active object framework 

	CSelfPopScheduler* scheduler = CSelfPopScheduler::CreateLC();

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

	TRSStartModuleParams startParams;

	TTestModuleIniData iniData;

	DefaultStartParams(startParams, iniData);

	_LIT8(KShareModule1, "Test ModuleShare1");

	_LIT8(KShareModule2, "Test ModuleShare2");

	startParams.iParams.iName = KShareModule1;

	asynchHandler->TryLoad(startParams, iniData);

    CActiveScheduler::Start();

   	if (asynchHandler->iStatus != KErrNone)

		{

		INFO_PRINTF2(_L("LoadServer returned error: <%d> "), asynchHandler->iStatus.Int());

		User::Leave(asynchHandler->iStatus.Int());

		}

	//*****************step 3************************