// 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\bench\t_fsrdirscan.cpp

// 

//

#include <f32file.h>

#include <e32test.h>

#include "t_select.h"

#include "t_benchmain.h"

GLDEF_D RTest test(_L("File Server Benchmarks, DirScan"));

//----------------------------------------------------------------------------------------------

//! @SYMTestCaseID      PBASE-T_FSRDIRSCAN-0274

//! @SYMTestType        CIT

//! @SYMPREQ            PREQ000

//! @SYMTestCaseDesc    This test case is measuring performance of the FAT implementation.  

//! @SYMTestActions     0.  Expects the files to exist in order to successful execution

//!						1.	Time finding an entry in each directory with TFindFile

//!						2.	Time finding an entry in each directory with RFile::Open

//!						3.	Time finding an entry in each directory with TFindFile with multiple 

//!							clients accessing the directory

//!						4.	Time finding an entry in each directory with RFile::Open with multiple 

//!							clients accessing the directory

//!						5.	Time finding an entry in each directory with TFindFile with multiple 

//!							clients accessing different directories

//!						6.	Time finding an entry in each directory with RFile::Open with multiple 

//!							clients accessing different directories

//!						7.	Time finding *.txt entries in each directory with TFindFile::FindWildByPath()

//!						8.	Time finding *.txt entries in each directory with TFindFile::FindWildByPath() 

//!							and different clients accessing the same directory

//!						9.	Time finding *.txt entries in each directory with TFindFile::FindWildByPath() 

//!							and different clients accessing different directories

//!						10.	Time finding ffff*.txt entries in each directory with TFindFile::FindWildByPath()

//!						11.	Time finding ffff*.txt entries in each directory with TFindFile::FindWildByPath() 

//!							and different clients accessing the same directory

//!						12.	Time finding ffff*.txt entries in each directory with TFindFile::FindWildByPath() 

//!							and different clients accessing different directories

//!						13.	Time finding last.* entry in each directory with TFindFile::FindWildByPath()

//!						14.	Time finding last.* entry in each directory with TFindFile::FindWildByPath() 

//!							and different clients accessing the same directory

//!						15.	Time finding last.* entry in each directory with TFindFile::FindWildByPath() 

//!							and different clients accessing different directories

//!

//! @SYMTestExpectedResults Finishes if the system behaves as expected, panics otherwise

//! @SYMTestPriority        High

//! @SYMTestStatus          Implemented

//----------------------------------------------------------------------------------------------

LOCAL_D RSemaphore client;

LOCAL_D const TInt KHeapSize = 0x4000;

LOCAL_D TBuf8<4096> buf;

LOCAL_D TDriveList gDriveList;

LOCAL_D TFileName gFindEntryDir;

LOCAL_D TBuf<100> gFindDir;

LOCAL_D TFileName gFindEntryDir2;

LOCAL_D TBuf<100> gFindDir2;

// Concurrent threads

RThread gSpeedy;

RThread gSpeedyII;

TInt ThreadCount = 0;

_LIT(KDirMultipleName2, "dir%d_%d\\");

/** Find entry in directory

*/

LOCAL_C TInt FindEntryAccess2(TAny*)

	{

	RFs fs;

	TInt r  = fs.Connect();

	RTest test(_L("test 2")); 

	fs.SetSessionPath(gSessionPath);

	client.Signal();

	FOREVER

		{

			TEntry entry;

			r = fs.Entry(gFindEntryDir2, entry);

			FailIfError(r);

			r = fs.Entry(gFindDir2,entry);

			FailIfError(r);

		}

	}

/** Starts a concurrent client session

	@param aFunction Thread to be started twice

*/

LOCAL_C void DoTest(TThreadFunction aFunction)

	{

	TBuf<20> buf = _L("Speedy");

	buf.AppendNum(ThreadCount++);

	TInt r = gSpeedy.Create(buf, aFunction, KDefaultStackSize, KHeapSize, KHeapSize, NULL);

	FailIfError(r);

	buf = _L("Speedy");

	buf.AppendNum(ThreadCount++);

	r = gSpeedyII.Create(buf, aFunction, KDefaultStackSize, KHeapSize, KHeapSize, NULL);

	FailIfError(r);

	gSpeedy.SetPriority(EPriorityLess);

    gSpeedyII.SetPriority(EPriorityLess);

	gSpeedy.Resume();

	gSpeedyII.Resume();

	client.Wait();

	client.Wait();

	}

/**  Starts a concurrent client session in different directories

	@param aFunction Thread to be started 

*/

LOCAL_C void DoTest2(TThreadFunction aFunction)

	{

	TBuf<20> buf = _L("Speedy");

	buf.AppendNum(ThreadCount++);

	TInt r = gSpeedy.Create(buf, aFunction, KDefaultStackSize, KHeapSize, KHeapSize, NULL);

	FailIfError(r);

	buf = _L("Speedy");

	buf.AppendNum(ThreadCount++);

	r = gSpeedyII.Create(buf, FindEntryAccess2, KDefaultStackSize, KHeapSize, KHeapSize, NULL);

	FailIfError(r);

 	gSpeedy.SetPriority(EPriorityLess);

    gSpeedyII.SetPriority(EPriorityLess);

	gSpeedy.Resume();

	gSpeedyII.Resume();

	client.Wait();

	client.Wait();

	}

/** Kills the concurrent session

*/

LOCAL_C void DoTestKill()

	{

	TInt r = 0;

	gSpeedy.Kill(KErrNone);

	FailIfError(r);

	gSpeedy.Close();	

	gSpeedyII.Kill(KErrNone);

	FailIfError(r);

	gSpeedyII.Close();	

	}

/** Find entry in directory

*/

LOCAL_C TInt FindEntryAccess(TAny*)

	{

	RFs fs;

	TInt r = fs.Connect();

	RTest test(_L("test 2")); 

	r = fs.SetSessionPath(gSessionPath);

	client.Signal();

	FOREVER

		{

		TEntry entry;

		r = fs.Entry(gFindEntryDir,entry);

		FailIfError(r);

		r = fs.Entry(gFindDir,entry);

		FailIfError(r);

		}

	}

/** Find last.txt with TFindFile and with two threads accessing the current directory 

	and looking for the same file

	@param aN 		Number of files in the directory

	@param aStep 	Test step

*/

LOCAL_C void FindFileM1(TInt aN, TInt aStep) 

	{

	TBuf16<100> dir1;

	TBuf16<100> dir2;

	TBuf16<100> dir3;

    TBuf16<100> dir4;

    TBuf16<100> dirtemp;

	TInt r = 0;

	TFindFile find(TheFs);

	TTime startTime;

	TTime endTime;

	TTimeIntervalMicroSeconds timeTaken(0);

	TInt timeTaken1 = -1, timeTaken2 = -1, timeTaken3 = -1; 

	if(aN <= gFilesLimit) 

		{

		dir1 = gSessionPath;

		dir2 = gSessionPath;

		dir3 = gSessionPath;

		dirtemp.Format(KDirMultipleName2, 1, aN);

		dir1.Append(dirtemp);

		gFindDir = dir1;

		dirtemp.Format(KDirMultipleName2, 2, aN);

		dir2.Append(dirtemp);

		dirtemp.Format(KDirMultipleName2, 3, aN);

		dir3.Append(dirtemp);

		dir1.Append(KCommonFile);

		dir2.Append(KCommonFile);

		dir3.Append(KCommonFile);

		if(gTypes >= 1) 

			{	

			gFindEntryDir = dir1;

			DoTest(FindEntryAccess);

			dir4.Format(KDirMultipleName, 1, aN);

			startTime.HomeTime();

			r = find.FindByPath(dir1, &dir4);

			FailIfError(r);

			endTime.HomeTime();

			DoTestKill();

			timeTaken = endTime.MicroSecondsFrom(startTime);

			timeTaken1 = I64LOW(timeTaken.Int64() / gTimeUnit);

			}

		if(gTypes >= 2) 

			{	

			dir4 = gSessionPath;

			dirtemp.Format(KDirMultipleName, 2, aN);

			dir4.Append(dirtemp);

			gFindDir = dir4;

			gFindEntryDir = dir2;

			DoTest(FindEntryAccess);

			startTime.HomeTime();

			r = find.FindByPath(dir2, &dir4);

			FailIfError(r);

			endTime.HomeTime();

			timeTaken = endTime.MicroSecondsFrom(startTime);

			DoTestKill();

			timeTaken2 = I64LOW(timeTaken.Int64() / gTimeUnit);

			}

		if(gTypes >= 3) 

			{	

			dir4 = gSessionPath;

			dirtemp.Format(KDirMultipleName, 3, aN);

			dir4.Append(dirtemp);

			gFindDir = dir4;

			gFindEntryDir = dir3;

			DoTest(FindEntryAccess);

			startTime.HomeTime();

			r = find.FindByPath(dir3, &dir4);

			FailIfError(r);

			endTime.HomeTime();

			DoTestKill();

			timeTaken = endTime.MicroSecondsFrom(startTime);

			timeTaken3 = I64LOW(timeTaken.Int64() / gTimeUnit);

			}

		}

	PrintResult(aStep, 1, aN);

	PrintResultTime(aStep, 2, timeTaken1);

	PrintResultTime(aStep, 3, timeTaken2);

	PrintResultTime(aStep, 4, timeTaken3);

	}

/** Find last.txt by opening it and with two threads accessing the current directory 

	and looking for the same file

	@param aN 		Number of files in the directory

	@param aStep 	Test step

*/

LOCAL_C void FindFileM2(TInt aN, TInt aStep) 

	{

	TBuf16<100> dir1;

	TBuf16<100> dir2;

	TBuf16<100> dir3;

	TBuf16<100> dirtemp;

	TInt r = 0;

	TTime startTime;

	TTime endTime;

	TTimeIntervalMicroSeconds timeTaken(0);

	RFile file;

	TInt timeTaken1 = -1, timeTaken2 = -1, timeTaken3 = -1; 

	if(aN <= gFilesLimit) 

		{

		dir1 = gSessionPath;

		dir2 = gSessionPath;

		dir3 = gSessionPath;

		dirtemp.Format(KDirMultipleName2, 1, aN);

		dir1.Append(dirtemp);

		gFindDir = dir1;

		dirtemp.Format(KDirMultipleName2, 2, aN);

		dir2.Append(dirtemp);

		dirtemp.Format(KDirMultipleName2, 3, aN);

		dir3.Append(dirtemp);

		dir1.Append(KCommonFile);

		if(gTypes >= 1) 

			{	

			gFindEntryDir = dir1;

			DoTest(FindEntryAccess);

			User::After(200);

			startTime.HomeTime();

			r = file.Open(TheFs,dir1,EFileShareAny|EFileWrite);

			FailIfError(r);

			endTime.HomeTime();

			timeTaken = endTime.MicroSecondsFrom(startTime);

			file.Close();

			DoTestKill();

			timeTaken1 = I64LOW(timeTaken.Int64() / gTimeUnit);

			}

		if(gTypes >= 2) 

			{	

			gFindDir = dir2;

			dir2.Append(KCommonFile);

			gFindEntryDir = dir2;

			DoTest(FindEntryAccess);

			User::After(200);

			startTime.HomeTime();

			r = file.Open(TheFs, dir2, EFileShareAny|EFileWrite);

			FailIfError(r);

			endTime.HomeTime();

			timeTaken = endTime.MicroSecondsFrom(startTime);

			file.Close();

			DoTestKill();

			timeTaken2 = I64LOW(timeTaken.Int64() / gTimeUnit);

			}

		if(gTypes >= 3) 

			{	

			gFindDir = dir3;	

			dir3.Append(KCommonFile);

			gFindEntryDir = dir3;

			DoTest(FindEntryAccess);

			User::After(200);

			startTime.HomeTime();

			r = file.Open(TheFs, dir3, EFileShareAny|EFileWrite);

			FailIfError(r);

			endTime.HomeTime();

			timeTaken = endTime.MicroSecondsFrom(startTime);

			DoTestKill();

			timeTaken3 = I64LOW(timeTaken.Int64() / gTimeUnit);

			file.Close();

		}

	}

	PrintResult(aStep, 1, aN);

	PrintResultTime(aStep, 2, timeTaken1);

	PrintResultTime(aStep, 3, timeTaken2);

	PrintResultTime(aStep, 4, timeTaken3);

	}

/** Find last.txt with TFindFile and without any other process

	@param aN 		Number of files in the directory

	@param aStep 	Test step

*/

LOCAL_C void FindFile1(TInt aN, TInt aStep) 

	{

	TBuf16<100> dir1;

	TBuf16<100> dir2;

	TBuf16<100> dir3;

    TBuf16<100> dir4;

    TBuf16<100> dirtemp;

	TInt r = 0;

	TFindFile find(TheFs);

	TTime startTime;

	TTime endTime;

	TTimeIntervalMicroSeconds timeTaken(0);

	TInt timeTaken1 = -1, timeTaken2 = -1, timeTaken3 = -1; 

	if(aN <= gFilesLimit) 

		{

		dir1 = gSessionPath;

		dir2 = gSessionPath;

		dir3 = gSessionPath;

		dirtemp.Format(KDirMultipleName2, 1, aN);

		dir1.Append(dirtemp);

		dirtemp.Format(KDirMultipleName2, 2, aN);

		dir2.Append(dirtemp);

		dirtemp.Format(KDirMultipleName2, 3, aN);

		dir3.Append(dirtemp);

		dir1.Append(KCommonFile);

		dir2.Append(KCommonFile);

		dir3.Append(KCommonFile);

		r = TheFs.SetSessionPath(gSessionPath);

		FailIfError(r);

		if(gTypes >= 1) 

			{	

			dir4.Format(KDirMultipleName, 1, aN);

			startTime.HomeTime();

			r = find.FindByPath(dir1, &dir4);

			FailIfError(r);

			endTime.HomeTime();

			timeTaken = endTime.MicroSecondsFrom(startTime);

			timeTaken1 = I64LOW(timeTaken.Int64() / gTimeUnit);

			}

		if(gTypes >= 2) 

			{	

			dir4.Format(KDirMultipleName, 2, aN);

			startTime.HomeTime();

			r = find.FindByPath(dir2, &dir4);

			FailIfError(r);

			endTime.HomeTime();

			timeTaken = endTime.MicroSecondsFrom(startTime);

			timeTaken2 = I64LOW(timeTaken.Int64() / gTimeUnit);

			}

		if(gTypes >= 3) 

			{	

			dir4.Format(KDirMultipleName, 3, aN);

			startTime.HomeTime();

			r = find.FindByPath(dir3, &dir4);

			FailIfError(r);

			endTime.HomeTime();

			timeTaken = endTime.MicroSecondsFrom(startTime);

			timeTaken3 = I64LOW(timeTaken.Int64() / gTimeUnit);

			}

		}

	PrintResult(aStep, 1, aN);

	PrintResultTime(aStep, 2, timeTaken1);

	PrintResultTime(aStep, 3, timeTaken2);

	PrintResultTime(aStep, 4, timeTaken3);

	}

/** Find last.txt by opening it and without any other process

	@param aN 		Number of files in the directory

	@param aStep 	Test step

*/

LOCAL_C void FindFile2(TInt aN, TInt aStep) 

	{

	TBuf16<100> dir1;

	TBuf16<100> dir2;

	TBuf16<100> dir3;

	TBuf16<100> dirtemp;