// 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_sesfs.cpp

// 

//

#define __E32TEST_EXTENSION__

#include "t_sess.h"

GLDEF_D TFileName tPath;

GLREF_D TFileName gExeFileName;

LOCAL_C void printDriveAtt(TInt aDrive,TUint anAtt);

LOCAL_C void printDriveInfo(TInt aDrive,TDriveInfo& anInfo);

LOCAL_C void DriveInfo(TInt aDrive,TDriveInfo& anInfo);

void TSessionTest::Initialise(RFs& aFs)

//

//	Initialise iFs

//

	{

	iFs=aFs;

	}

void TSessionTest::RunTests()

//

//	Run tests on iFs file server session

//

	{

	testDriveList();

	testDriveInfo();

	testVolumeInfo();

	testSetVolume();

	testPath();

	CreateTestDirectory(_L("\\SESSION_TEST\\TFSRV\\"));

	testInitialisation();

	testSubst();

	CopyFileToTestDirectory();

	MakeAndDeleteFiles();

	}

void TSessionTest::testDriveList()

//

// Test the drive list.

//

	{

	test.Start(_L("The drive list"));

	TDriveList list;

	TDriveInfo info;

	TInt r=iFs.DriveList(list);

	test_KErrNone(r);

	for (TInt i=0;i<KMaxDrives;i++)

		{

		if (list[i])

			{

			r = iFs.Drive(info, i);

			test_KErrNone(r);

			printDriveAtt(i,info.iDriveAtt);

			}

		}

	test.End();

	}

void TSessionTest::testDriveInfo()

//

// Test the drive info.

//

	{

	test.Start(_L("The drive info"));

	TDriveList list;

	TInt r=iFs.DriveList(list);

	test_KErrNone(r);

	for (TInt i=0;i<KMaxDrives;i++)

		{

		TInt att=list[i];

		if (att)

			{

			TDriveInfo d;

			r=iFs.Drive(d,i);

			test_KErrNone(r);

			printDriveInfo(i,d);

			test.Printf(_L("\n"));

			DriveInfo(i,d);

			}

		}

	test.End();

	}

void TSessionTest::testVolumeInfo()

//

// Test volume info.

//

	{

	test.Start(_L("The volume info"));

	TDriveList list;

	TInt r=iFs.DriveList(list);

	test_KErrNone(r);

	for (TInt i=0;i<KMaxDrives;i++)

		{

		TVolumeInfo v;

		TDriveInfo d;

		switch (r=iFs.Volume(v,i))

			{

			case KErrNone:

				printDriveInfo(i,v.iDrive);

				test.Printf(_L("   VOL=\"%S\" ID=%08x\n"),&v.iName,v.iUniqueID);

				test.Printf(_L("   SIZE=%ldK FREE=%ldK\n"),v.iSize/1024,v.iFree/1024);

				break;

			case KErrNotReady:

				r=iFs.Drive(d, i);

				test_KErrNone(r);

				if (d.iType == EMediaNotPresent)

					test.Printf(_L("%c: Medium not present - cannot perform test.\n"), i + 'A');

				else

					test.Printf(_L("medium found (type %d) but drive %c: not ready\nPrevious test may have hung; else, check hardware.\n"), (TInt)d.iType, i + 'A');

				break;

			case KErrPathNotFound:

				test.Printf(_L("%c: Not Found\n"), i + 'A');

				break;

			case KErrCorrupt:

				test.Printf(_L("%c: Media corruption; previous test may have aborted; else, check hardware\n"), i + 'A');

			default:

				test.Printf(_L("%c: Error %d - aborting test.\n"),i + 'A', r);

				test(0);

			}

		test.Printf(_L("\n"));

		}

	test.End();

	}

void TSessionTest::testPath()

//

// Test the path handling.

//

	{

	test.Start(_L("Test path handling"));

	TInt r;

	TFileName p;

	r=iFs.SessionPath(p);

	test_KErrNone(r);

	test.Printf(_L("SESSION=\"%S\"\n"),&p);

	r=iFs.SetSessionPath(_L("A:\\TEST\\"));

	test_KErrNone(r);

	r=iFs.SessionPath(p);

	test_KErrNone(r);

	test(p==_L("A:\\TEST\\"));

	r=iFs.SetSessionPath(gTestSessionPath);

	test_KErrNone(r);

	test.End();

	}

void TSessionTest::testInitialisation()

//

//	Tests that calls to CheckedClose() are OK, ie, tests bug fix

//

	{

	test.Next(_L("Test calls to CheckedClose are OK"));

	RFile file;

	RDir dir;

	TInt count;

	RFormat format;

	TInt r=format.Open(iFs,_L("Z:\\"),EFullFormat,count);

	test_Value(r, r==KErrAccessDenied || r==KErrInUse);

	r=dir.Open(iFs,_L("\\SESSION_TEST\\ERRORTEST\\"),KEntryAttMatchMask);

	test_Value(r, r==KErrPathNotFound);

	r=file.Open(iFs,_L("\\SESSION_TEST\\SessionTest1.txt"),EFileRead);

	test_Value(r, r==KErrNotFound);

	r=dir.Open(iFs,_L("\\SESSION_TEST\\ERRORTEST2\\"),KEntryAttMatchMask);

	test_Value(r, r==KErrPathNotFound);		

	r=file.Open(iFs,_L("\\SESSION_TEST\\SessionTest2.txt"),EFileRead);

	test_Value(r, r==KErrNotFound);

	r=dir.Open(iFs,_L("\\SESSION_TEST\\ERRORTEST3\\"),KEntryAttMatchMask);

	test_Value(r, r==KErrPathNotFound);		

	r=file.Open(iFs,_L("\\SESSION_TEST\\SessionTest3.txt"),EFileRead);

	test_Value(r, r==KErrNotFound);

	r=file.Open(iFs,_L("\\SESSION_TEST\\SessionTest4.txt"),EFileRead);

	test_Value(r, r==KErrNotFound);

	format.Close();

	dir.Close();

	file.Close();

	}

void TSessionTest::testSubst()

//

// Test the substitute functions.

//

	{

	test.Printf(_L("Test subst"));

	TVolumeInfo v;

	TInt r=iFs.Volume(v);

	test_KErrNone(r);

	TDriveInfo origDI;

	r=iFs.Drive(origDI);

	test_KErrNone(r);

	TDriveInfo driveInfo;

	r=iFs.Drive(driveInfo,EDriveO);

	test_KErrNone(r);

	testSetVolume();

	if (driveInfo.iDriveAtt==KDriveAttLocal)

		{	

		return;	//	Subst local drives fails

		}

	TFileName n;

	r=iFs.Subst(n,EDriveO);

	test_KErrNone(r);

	test(n.Length()==0);

	r=iFs.SetSubst(gTestSessionPath,EDriveO);

	test_KErrNone(r);

	r=iFs.Subst(n,EDriveO);

	test_KErrNone(r);

	test(n==gTestSessionPath);

	TVolumeInfo w;

	r=iFs.Volume(w,EDriveO);

	test_KErrNone(r);

	test(w.iDrive.iType==v.iDrive.iType);

	test(w.iDrive.iConnectionBusType==v.iDrive.iConnectionBusType);

	test(w.iDrive.iDriveAtt==KDriveAttSubsted);

	test(w.iDrive.iMediaAtt==v.iDrive.iMediaAtt);

	test(w.iUniqueID==v.iUniqueID);

#ifdef __WINS__

#endif

#ifdef __WINS__

#endif

	test(w.iName==v.iName);

	TDriveList driveList;

	r=iFs.DriveList(driveList);

	test_KErrNone(r);

	test(driveList[EDriveO]==KDriveAttSubsted);

	TDriveInfo d;

	r=iFs.Drive(d,EDriveO);

	test_KErrNone(r);

	test(d.iDriveAtt==KDriveAttSubsted);

	test(d.iMediaAtt==origDI.iMediaAtt);

	test(d.iType==origDI.iType);

	test(d.iConnectionBusType==origDI.iConnectionBusType);

	test.Next(_L("Test real name"));

	r=iFs.RealName(_L("O:\\FILE.XXX"),n);

	test_KErrNone(r);

	TFileName substedPath=gTestSessionPath;

	substedPath.Append(_L("FILE.XXX"));

	test(n.CompareF(substedPath)==KErrNone);

//

	test.Next(_L("Test MkDir, Rename and RmDir on Substed drive"));

	_LIT(KTurgid,"turgid\\");

	TFileName dir=gTestSessionPath;

	dir+=KTurgid;

	r=iFs.MkDirAll(dir);

	test_KErrNone(r);

	dir+=_L("subdir\\");

	r=iFs.MkDir(dir);

	test_KErrNone(r);

	r=iFs.RmDir(_L("O:\\turgid\\subdir\\"));

	test_KErrNone(r);

	r=iFs.Rename(_L("O:\\turgid"), _L("O:\\facile"));

	test_KErrNone(r);

	r=iFs.MkDir(_L("O:\\insipid\\"));

	test_KErrNone(r);

	r=iFs.Rename(_L("O:\\insipid"), _L("O:\\glib"));

	test_KErrNone(r);

	r=iFs.RmDir(_L("O:\\facile\\"));

	test_KErrNone(r);

	_LIT(KGlib,"glib\\");

	dir=gTestSessionPath;

	dir+=KGlib;

	r=iFs.RmDir(dir);

	test_KErrNone(r);

	test.Next(_L("Test file operations on Substed drive"));

	_LIT(File1,"File1.txt");

	_LIT(File2,"File2.txt");

	_LIT(SubstRoot,"O:\\");

	_LIT(Subdir,"subdir\\");

	TFileName name1,name2;

	name1=gTestSessionPath;

	name1+=File1;

	RFile f1;

	r=f1.Create(iFs,name1,EFileShareExclusive|EFileWrite);

	test_KErrNone(r);

	name2=SubstRoot;

	name2+=File2;

	TBool isValid=iFs.IsValidName(name2);

	test(isValid);

	r=f1.Rename(name2);

	test_KErrNone(r);

	f1.Close();

	r=f1.Create(iFs,name1,EFileShareExclusive|EFileWrite);

	test_KErrNone(r);

	f1.Close();

	r=iFs.Replace(name2,name1);

	test_KErrNone(r);

	r=iFs.Delete(name1);

	test_KErrNone(r);

	test.Next(_L("Test notifications on Substed drive"));

	name1=gTestSessionPath;

	name1+=Subdir;

	name2=SubstRoot;

	name2+=Subdir;

	// set up some extended notifications

	TRequestStatus status1;

	TRequestStatus status2;

	TRequestStatus status3;

	iFs.NotifyChange(ENotifyDir,status1,name1);

	test(status1==KRequestPending);

	iFs.NotifyChange(ENotifyDir,status2,name2);

	test(status2==KRequestPending);

	r=iFs.MkDirAll(name1);

	test_KErrNone(r);

	User::WaitForRequest(status1);

	User::WaitForRequest(status2);

	test(status1==KErrNone && status2==KErrNone);

	iFs.NotifyChange(ENotifyDir,status1,name1);

	test(status1==KRequestPending);

	iFs.NotifyChange(ENotifyDir,status2,name2);

	test(status2==KRequestPending);

	iFs.NotifyChange(ENotifyAll,status3,name2);

	test(status3==KRequestPending);

	r=f1.Temp(iFs,name2,n,EFileShareAny|EFileWrite);

	test_KErrNone(r);

	User::WaitForRequest(status3);

	test(status3==KErrNone && status1==KRequestPending && status2==KRequestPending);

	f1.Close();

	iFs.NotifyChangeCancel();

	test(status1==KErrCancel && status2==KErrCancel);

	User::WaitForRequest(status1);

	User::WaitForRequest(status2);

	r=iFs.Delete(n);

	test_KErrNone(r);

	r=iFs.RmDir(name1);

	test_KErrNone(r);

//

	test.Next(_L("Test file systems on Substed drive"));

	// test cannot mount file system on substituted drive

	TInt sessionDrv;

	r=iFs.CharToDrive(gTestSessionPath[0],sessionDrv);

	test_KErrNone(r);

	r=iFs.FileSystemName(n,sessionDrv);

	test_Value(r, r==KErrNone || r==KErrNotFound);

	r=iFs.MountFileSystem(n,EDriveO);

	test_Value(r, r==KErrAccessDenied);

	// test file system name on substitued drive is null

	r=iFs.FileSystemName(n,EDriveO);

	test_Value(r, r==KErrNotFound && n==KNullDesC);

	// test cannot format a substitued drive

	RFormat format;

	TInt count;

	r=format.Open(iFs,SubstRoot,EHighDensity,count);

	test_Value(r, r==KErrAccessDenied);

	r=iFs.SetSubst(_L(""),EDriveO);

	test_KErrNone(r);

	r=iFs.Subst(n,EDriveO);

	test_KErrNone(r);

	test(n==_L(""));

	r=iFs.Drive(d,EDriveO);

	test_KErrNone(r);

	test(d.iDriveAtt==0);

	}

LOCAL_C TInt CreateFileX(const TDesC& aBaseName,TInt aX, RFs iFs)

//

// Create a large file. Return KErrEof or KErrNone

//

	{

	TBuf<128> fileName=aBaseName;

	fileName.AppendNum(aX);

	RFile file;

	TInt r=file.Replace(iFs,fileName,EFileWrite);

	if (r==KErrDiskFull)

		return(r);

	if (r!=KErrNone)

		{

		test.Printf(_L("ERROR:: Replace returned %d\n"),r);

		return(KErrDiskFull);

		}

	r=file.SetSize(65536);

	if (r==KErrDiskFull)

		{

		file.Close();

		return(r);

		}

	if (r!=KErrNone)

		{

		test.Printf(_L("ERROR:: SetSize returned %d\n"),r);

		file.Close();

		return(KErrDiskFull);

		}

	file.Close();

//	r=iFs.CheckDisk(fileName);

//	if (r!=KErrNone && r!=KErrNotSupported)

//		{

//		test.Printf(_L("ERROR:: CheckDisk returned %d\n"),r);

//		test.Getch();

//		return(KErrDiskFull);

//		}

	test.Printf(_L("Created file %d size 64k\n"),aX);

	return(KErrNone);

	}

LOCAL_C TInt DeleteFileX(TBuf<128>& aBaseName,TInt aX, RFs iFs)

//

// Delete a file.

//

	{

	TBuf<128> fileName=aBaseName;

	fileName.AppendNum(aX);

	TInt r=iFs.Delete(fileName);

	test_KErrNone(r);

//	r=iFs.CheckDisk(fileName);

//	if (r!=KErrNone && r!=KErrNotSupported)

//		{

//		test.Printf(_L("ERROR:: CheckDisk returned %d\n"),r);

//		test_KErrNone(r);

//		}

	test.Printf(_L("Deleted File %d\n"),aX);

	return(KErrNone);

	}

void TSessionTest::MakeAndDeleteFiles()

//

// Create and delete large files in a randomish order

//

	{

	test.Start(_L("Create and delete large files"));

	TInt r=iFs.MkDirAll(_L("\\SESSION_TEST\\SMALLDIRECTORY\\"));

	test_Value(r, r==KErrNone || r==KErrAlreadyExists);

	TBuf<128> fileName=_L("\\SESSION_TEST\\SMALLDIRECTORY\\FILE");

	r=CreateFileX(fileName,0,iFs);

	test_KErrNone(r);

	r=CreateFileX(fileName,1,iFs);

	test_KErrNone(r);

	r=DeleteFileX(fileName,0,iFs);	

	test_KErrNone(r);

	r=CreateFileX(fileName,2,iFs);

	test_KErrNone(r);

	r=CreateFileX(fileName,1,iFs);

	test_KErrNone(r);

	r=CreateFileX(fileName,3,iFs);

	test_KErrNone(r);

	r=DeleteFileX(fileName,1,iFs);	

	test_KErrNone(r);

	r=CreateFileX(fileName,4,iFs);

	test_KErrNone(r);

	r=DeleteFileX(fileName,2,iFs);	

	test_KErrNone(r);

	r=DeleteFileX(fileName,3,iFs);	

	test_KErrNone(r);

	r=DeleteFileX(fileName,4,iFs);	

	test_KErrNone(r);

	r=CreateFileX(fileName,1,iFs);

	test_KErrNone(r);

	r=DeleteFileX(fileName,1,iFs);	

	test_KErrNone(r);

	r=iFs.CheckDisk(fileName);

	test_Value(r, r==KErrNone || r==KErrNotSupported);

	test.End();

	}

void TSessionTest::FillUpDisk()

//

// Test that a full disk is ok

//