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

// f32test\fsstress\t_sess.cpp

//

//

#include "t_sess.h"

#include "t_server.h"

#include "t_chlffs.h"

GLDEF_D RTest test(_L("T_SESS"));

GLDEF_D TFileName gTestSessionPath;

// These objects are too large to be placed on the stack - ~15 sessions is enough

// to cause a stack overflow on ARM4.

const TInt KMaxNumberSessions=25;

RFs gSession[KMaxNumberSessions];

TSessionTest gTestObject[KMaxNumberSessions];

LOCAL_C void SetSessionPath(RFs aFs,TChar aDriveLetter)

//

//	Set the session path for a RFs connection to aDrive

//

	{

	gTestSessionPath=(_L("?:\\SESSION_TEST\\"));

	gTestSessionPath[0]=(TText)aDriveLetter;

	TInt r=aFs.SetSessionPath(gTestSessionPath);

	test(r==KErrNone);

	r=aFs.MkDirAll(gTestSessionPath);

	test(r==KErrNone || r==KErrAlreadyExists);

	}

GLDEF_C void CallTestsL()

//

//	This test makes a number of fileserver connections (sessions)

//	The fileserver is stressed by running these sessions concurrently, swapping

//	between them whilst testing various fileserver API functions

//	Further testing of the fileserver is performed by closing connections one by

//	one whilst ensuring their closure does not affect the other connected sessions

//

    {

	test.Title();

	TChar driveLetter;

	if (IsSessionDriveLFFS(TheFs,driveLetter))

		{

		test.Printf(_L("CallTestsL: Skipped: test does not run on LFFS.\n"));

		return;

		}

	test.Start(_L("Starting T_SESSION tests..."));

//	Create an array of fileserver sessions

//	Create an array of TSessionTest objects

	TInt i=0;

	TInt r;

	for (; i<KMaxNumberSessions; i++)

		{

		r=gSession[i].Connect();

		test(r==KErrNone);

		SetSessionPath(gSession[i],driveLetter);

		gSession[i].ResourceCountMarkStart();

		gTestObject[i].Initialise(gSession[i]);

		gTestObject[i].RunTests();	//	Run the set of tests for each session

		}							//	Leave each session open

	for (i=0; i<(KMaxNumberSessions-1); i++)

		{

	//	Alternate tests between open sessions

		gTestObject[i].testSetVolume();

		gTestObject[i+1].testInitialisation();

		gTestObject[i].testSubst();

		gTestObject[i+1].testInitialisation();

		gTestObject[i].testInitialisation();

		gTestObject[i].testDriveList();

		gTestObject[i+1].CopyFileToTestDirectory();

		gTestObject[i].MakeAndDeleteFiles();

	//	Close gSession[i] and check that session[i+1] is OK

		gSession[i].ResourceCountMarkEnd();

		gSession[i].Close();

		gTestObject[i+1].testInitialisation();

		gTestObject[i+1].testSetVolume();

		gTestObject[i+1].testInitialisation();

		gTestObject[i+1].testSubst();

		gTestObject[i+1].testDriveList();

	//	Reconnect gSession[i]

		r=gSession[i].Connect();

		test(r==KErrNone);

		SetSessionPath(gSession[i],driveLetter);

		gSession[i].ResourceCountMarkStart();

		gTestObject[i].Initialise(gSession[i]);

		gTestObject[i].testSetVolume();

		gTestObject[i+1].testInitialisation();

		gTestObject[i].testSubst();

		gTestObject[i+1].testInitialisation();

		gTestObject[i].testInitialisation();

		gTestObject[i].testDriveList();

	//	Close gSession[i+1] and check that session[i] is OK

		gSession[i+1].ResourceCountMarkEnd();

		gSession[i+1].Close();

		gTestObject[i].testInitialisation();

		gTestObject[i].testSetVolume();

		gTestObject[i].testInitialisation();

		gTestObject[i].testSubst();

		gTestObject[i].testDriveList();

	//	Reconnect gSession[i+1]

		r=gSession[i+1].Connect();

		test(r==KErrNone);

		SetSessionPath(gSession[i+1],driveLetter);

		gSession[i].ResourceCountMarkStart();

		gTestObject[i+1].Initialise(gSession[i+1]);

		gTestObject[i].testSetVolume();

		gTestObject[i+1].testInitialisation();

		gTestObject[i].testSubst();

		gTestObject[i+1].testInitialisation();

	//	Close session[i] and check that session[i+1] is OK

		gSession[i].ResourceCountMarkEnd();

		gSession[i].Close();

		gTestObject[i+1].testInitialisation();

		gTestObject[i+1].testSetVolume();

		gTestObject[i+1].testInitialisation();

		gTestObject[i+1].testSubst();

		gTestObject[i+1].testDriveList();

		if (i==KMaxNumberSessions-1)	//	Tidy up by closing remaining open session

			{

			gSession[i].ResourceCountMarkEnd();

			gSession[i+1].Close();

			}

		}

//	Set up the arrays again and open sessions ready for more testing

	for (i=0; i<KMaxNumberSessions; i++)

		{

		r=gSession[i].Connect();

		test(r==KErrNone);

		SetSessionPath(gSession[i],driveLetter);

		gSession[i].ResourceCountMarkStart();

		gTestObject[i].Initialise(gSession[i]);

		}

	for (i=0; i<KMaxNumberSessions-1; i++)

		{

		gTestObject[i].testInitialisation();

		gTestObject[i+1].testSubst();

		gTestObject[i].testDriveList();

		gSession[i].ResourceCountMarkEnd();

		gSession[i].Close();

		gTestObject[i+1].testInitialisation();

		gTestObject[i+1].testSetVolume();

		if (i==KMaxNumberSessions-1)	//	Tidy up by closing remaining open session

			{

			gSession[i+1].ResourceCountMarkEnd();

			gSession[i+1].Close();

			}

		}

	test.End();

	test.Close();

	return;

    }