// Copyright (c) 2006-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\bench\t_fsrmkdir.cpp
//
//
#include <f32file.h>
#include <e32test.h>
#include "t_select.h"
#include "t_benchmain.h"
GLDEF_D RTest test(_L("FS Benchmarks, mkdir"));
//----------------------------------------------------------------------------------------------
//! @SYMTestCaseID PBASE-T_FSRMKDIR-0277
//! @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 the creation of a directory in each directory with RFs::MkDir
//! 2. Time the creation of a directory (with RFs::MkDir) in each directory
//! with different clients accessing the directory
//! 3. Time the creation of a directory (with RFs::MkDir) in each directory
//! with different clients accessing different directories
//!
//! @SYMTestExpectedResults Finishes if the system behaves as expected, panics otherwise
//! @SYMTestPriority High
//! @SYMTestStatus Implemented
//----------------------------------------------------------------------------------------------
LOCAL_D RSemaphore client,write_screen;
LOCAL_D const TInt KHeapSize = 0x4000;
LOCAL_D TBuf8<4096> buf;
LOCAL_D TDriveList gDriveList;
LOCAL_D TFileName gDelEntryDir;
LOCAL_D TFileName gDelEntryDir2;
// Concurrent thread
RThread gSpeedy;
RThread gSpeedyII;
TInt gT1;
TInt gT2;
TBool gKillMe=EFalse;
LOCAL_D TInt ThreadCount=0;
_LIT(KDirMultipleName2, "dir%d_%d\\");
_LIT(KNewDir, "new_dir\\");
_LIT(KDeleteMe,"delete%d.me");
_LIT(KDeleteMe2,"blabla%d.rhd");
/** Delete entry in directory
*/
LOCAL_C TInt DeleteEntryAccess2(TAny* )
{
RFs fs;
TInt r = fs.Connect();
TBuf<100> dirfile;
TBuf<50> filename;
RFile file;
RTest test(_L("test 2"));
fs.SetSessionPath(gSessionPath);
filename.Format(KDeleteMe2, gT2);
dirfile = gDelEntryDir2;
dirfile.Append(filename);
client.Signal();
FOREVER
{
if(!gKillMe)
{
r = file.Create(fs, dirfile, EFileShareAny|EFileWrite);
if(r == KErrAlreadyExists)
r=file.Open(fs, dirfile, EFileShareAny|EFileWrite);
file.Close();
FailIfError(r);
r = fs.Delete(dirfile);
if((r != KErrNone) && (r != KErrInUse))
{
test.Printf(_L("error = %d\n"), r);
}
test(r == KErrNone || r == KErrInUse);
}
}
}
/** Delete entry in directory
*/
LOCAL_C TInt DeleteEntryAccess(TAny*)
{
RFs fs2;
TInt r = fs2.Connect();
TBuf<100> dirfile;
TBuf<50> filename;
RFile file2;
RTest test(_L("test 2"));
r = fs2.SetSessionPath(gSessionPath);
filename.Format(KDeleteMe, gT1);
dirfile = gDelEntryDir;
dirfile.Append(filename);
client.Signal();
FOREVER
{
if(!gKillMe)
{
r = file2.Create(fs2, dirfile, EFileShareAny|EFileWrite);
if(r == KErrAlreadyExists)
r = file2.Open(fs2, dirfile, EFileShareAny|EFileWrite);
file2.Close();
FailIfError(r);
r = fs2.Delete(dirfile);
if((r != KErrNone) && (r != KErrInUse))
{
test.Printf(_L("error = %d\n"), r);
}
test(r == KErrNone || r == KErrInUse);
}
}
}
/** Starts two concurrent client sessions in different directories
*/
LOCAL_C void DoTest2(TThreadFunction aFunction)
{
gKillMe = EFalse;
TBuf<20> buf = _L("Speedy");
buf.AppendNum(ThreadCount++);
gT1 = ThreadCount;
TInt r = gSpeedy.Create(buf, aFunction, KDefaultStackSize, KHeapSize, KHeapSize, NULL);
FailIfError(r);
buf = _L("Speedy");
buf.AppendNum(ThreadCount++);
gT2 = ThreadCount;
r = gSpeedyII.Create(buf, DeleteEntryAccess2, 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()
{
gKillMe = ETrue;
User::After(10000000);
gSpeedy.Kill(KErrNone);
gSpeedy.Close();
gSpeedyII.Kill(KErrNone);
gSpeedyII.Close();
}
/** Time the creation of a directory inside each type of directory
@param aN Number of files in the directory
@param aStep Test step
*/
LOCAL_C void MakeDir(TInt aN, TInt aStep)
{
TBuf16<100> dir1;
TBuf16<100> dir2;
TBuf16<100> dir3;
TBuf16<100> dir4;
TInt r=0;
TTime startTime;
TTime endTime;
TTimeIntervalMicroSeconds timeTaken(0);
TInt timeTaken1 = -1, timeTaken2 = -1, timeTaken3 = -1;
if(aN <= gFilesLimit)
{
dir1 = gSessionPath;
dir2 = gSessionPath;
dir3 = gSessionPath;
dir4.Format(KDirMultipleName2, 1, aN);
dir1.Append(dir4);
dir4.Format(KDirMultipleName2, 2, aN);
dir2.Append(dir4);
dir4.Format(KDirMultipleName2, 3, aN);
dir3.Append(dir4);
dir1.Append(KNewDir);
dir2.Append(KNewDir);
dir3.Append(KNewDir);
if(gTypes >= 1)
{
dir4.Format(KDirMultipleName, 1, aN);
startTime.HomeTime();
r = TheFs.MkDir(dir1);
FailIfError(r);
endTime.HomeTime();
timeTaken = endTime.MicroSecondsFrom(startTime);
timeTaken1 = I64LOW(timeTaken.Int64() / gTimeUnit);
TheFs.RmDir(dir1);
}
if(gTypes >= 2)
{
startTime.HomeTime();
r = TheFs.MkDir(dir2);
FailIfError(r);
endTime.HomeTime();
timeTaken = endTime.MicroSecondsFrom(startTime);
timeTaken2 = I64LOW(timeTaken.Int64() / gTimeUnit);
TheFs.RmDir(dir2);
}
if(gTypes>=3)
{
startTime.HomeTime();
r = TheFs.MkDir(dir3);
FailIfError(r);
endTime.HomeTime();
timeTaken = endTime.MicroSecondsFrom(startTime);
timeTaken3 = I64LOW(timeTaken.Int64() / gTimeUnit);
TheFs.RmDir(dir3);
}
}
PrintResult(aStep, 1, aN);
PrintResultTime(aStep, 2, timeTaken1);
PrintResultTime(aStep, 3, timeTaken2);
PrintResultTime(aStep, 4, timeTaken3);
}
/** Time the creation of a directory inside each type of directory with multiple threads ongoing
@param aN Number of files in the directory
@param aStep Test step
*/
LOCAL_C void MakeDirM(TInt aN, TInt aStep)
{
TBuf16<100> dir1;
TBuf16<100> dir2;
TBuf16<100> dir3;
TBuf16<100> dir4;
TInt r = 0;
TTime startTime;
TTime endTime;
TTimeIntervalMicroSeconds timeTaken(0);
TInt timeTaken1 = -1, timeTaken2 = -1, timeTaken3 = -1;
if(aN <= gFilesLimit)
{
dir1 = gSessionPath;
dir2 = gSessionPath;
dir3 = gSessionPath;
dir4.Format(KDirMultipleName2, 1, aN);
dir1.Append(dir4);
dir4.Format(KDirMultipleName2, 2, aN);
dir2.Append(dir4);
dir4.Format(KDirMultipleName2, 3, aN);
dir3.Append(dir4);
if(gTypes >= 1)
{
gDelEntryDir = dir1;
gDelEntryDir2 = dir1;
dir1.Append(KNewDir);
DoTest2(DeleteEntryAccess);
startTime.HomeTime();
r = TheFs.MkDir(dir1);
FailIfError(r);
endTime.HomeTime();
DoTestKill();
timeTaken = endTime.MicroSecondsFrom(startTime);
timeTaken1 = I64LOW(timeTaken.Int64() / gTimeUnit);
TheFs.RmDir(dir1);
}
if(gTypes >= 2)
{
gDelEntryDir = dir2;
gDelEntryDir2 = dir2;
dir2.Append(KNewDir);
DoTest2(DeleteEntryAccess);
startTime.HomeTime();
r = TheFs.MkDir(dir2);
FailIfError(r);
endTime.HomeTime();
DoTestKill();
timeTaken = endTime.MicroSecondsFrom(startTime);
timeTaken2 = I64LOW(timeTaken.Int64() / gTimeUnit);
TheFs.RmDir(dir2);
}
if(gTypes >= 3)
{
gDelEntryDir = dir3;
gDelEntryDir2 = dir3;
dir3.Append(KNewDir);
DoTest2(DeleteEntryAccess);
startTime.HomeTime();
r = TheFs.MkDir(dir3);
FailIfError(r);
endTime.HomeTime();
DoTestKill();
timeTaken = endTime.MicroSecondsFrom(startTime);
timeTaken3 = I64LOW(timeTaken.Int64() / gTimeUnit);
TheFs.RmDir(dir3);
}
}
PrintResult(aStep, 1, aN);
PrintResultTime(aStep, 2, timeTaken1);
PrintResultTime(aStep, 3, timeTaken2);
PrintResultTime(aStep, 4, timeTaken3);
}
/** Times the creation of a directory
Precondition: This test expectsthe drive already filled with the right files
@param aSelector Configuration in case of manual execution
*/
LOCAL_C TInt TestMake(TAny* aSelector)
{
TInt i = 100;
TInt testStep;
Validate(aSelector);
test.Printf(_L("#~TS_Title_%d,%d: MkDir, RFs::MkDir\n"), gTestHarness, gTestCase);
i = 100;
testStep = 1;
while(i <= KMaxFiles)
{
if(i == 100 || i == 1000 || i == 5000 || i == 10000)
{
MakeDir(i, testStep++);
}
i += 100;
}
gTestCase++;
return(KErrNone);
}
/** Tests the creation of a directory with 2 threads accessing the directory
@param aSelector Configuration in case of manual execution
*/
LOCAL_C TInt TestMakeMultSame(TAny* aSelector)
{
TInt i;
TInt testStep;
Validate(aSelector);
test.Printf(_L("#~TS_Title_%d,%d: MkDir with mult clients accessing same dir, RFs::MkDir\n"), gTestHarness, gTestCase);
i = 100;
testStep = 1;
while(i <= KMaxFiles)
{
if(i == 100 || i == 1000 || i == 5000 || i == 10000)
{
MakeDirM(i, testStep++);
}
i += 100;
}
gTestCase++;
return(KErrNone);
}
/** Tests the creation of a directory with 2 threads accessing different directories
(the current and one with 300 files)
@param aSelector Configuration in case of manual execution
*/
LOCAL_C TInt TestMakeMultDif(TAny* aSelector)
{
TInt i = 100;
TBuf16<50> directory;
TBuf16<50> dirtemp;
TInt testStep;
Validate(aSelector);
CreateDirWithNFiles(300,3);
directory = gSessionPath;
dirtemp.Format(KDirMultipleName2, 3, 300);
directory.Append(dirtemp);
gDelEntryDir2 = directory;
test.Printf(_L("#~TS_Title_%d,%d: MkDir with mult clients accessing dif dirs, RFs::MkDir\n"), gTestHarness, gTestCase);
i = 100;
testStep = 1;
while(i <= KMaxFiles)
{
if(i == 100 || i == 1000 || i == 5000 || i == 10000)
{
directory = gSessionPath;
dirtemp.Format(KDirMultipleName2, 2, i);
directory.Append(dirtemp);
gDelEntryDir = directory;
DoTest2(DeleteEntryAccess);
MakeDir(i, testStep++);
DoTestKill();
}
i += 100;
}
gTestCase++;
return(KErrNone);
}
/** Goes automatically through all the options
@param aSelector Configuration in case of manual execution
*/
LOCAL_C TInt TestAll(TAny* aSelector)
{
Validate(aSelector);
TestMake(aSelector);
TestMakeMultSame(aSelector);
TestMakeMultDif(aSelector);
return(KErrNone);
}
/** Call all tests
*/
GLDEF_C void CallTestsL()
{
TInt r = client.CreateLocal(0);
FailIfError(r);
gFileSize = 8;
CSelectionBox* TheSelector = CSelectionBox::NewL(test.Console());
// Each test case of the suite has an identifyer for parsing purposes of the results
gTestHarness = 6;
gTestCase = 1;
PrintHeaders(1, _L("t_fsrmkdir. Mkdir"));
if(gMode == 0)
{ // Manual
gSessionPath=_L("?:\\");
TCallBack createFiles(TestFileCreate, TheSelector);
TCallBack MkDir(TestMake, TheSelector);
TCallBack makeMultSame(TestMakeMultSame, TheSelector);
TCallBack makeMultDif(TestMakeMultDif, TheSelector);
TCallBack makeAll(TestAll, TheSelector);
TheSelector->AddDriveSelectorL(TheFs);
TheSelector->AddLineL(_L("Create all files"), createFiles);
TheSelector->AddLineL(_L("Mkdir "), MkDir);
TheSelector->AddLineL(_L("Mkdir mult clients same dir "), makeMultSame);
TheSelector->AddLineL(_L("Mkdir mult clients dif dir"), makeMultDif);
TheSelector->AddLineL(_L("Execute all options"), makeAll);
TheSelector->Run();
}
else
{ // Automatic
TestAll(TheSelector);
}
client.Close();
test.Printf(_L("#~TestEnd_%d\n"), gTestHarness);
delete TheSelector;
}