// 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\server\t_hungfs.cpp

// this test will either run with a secure mmc or will simulate a

// mmc card.

// 

//

#include <f32file.h>

#include <e32test.h>

#include "t_server.h"

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

GLREF_D RFs TheFs;

LOCAL_D RFile SubFile1;

LOCAL_D TInt HungReturnCodeC;

LOCAL_D RSemaphore HungSemaphoreC;

LOCAL_D TInt HungReturnCodeNC;

LOCAL_D RSemaphore HungSemaphoreNC;

GLREF_C void Format(TInt aDrive);

LOCAL_D const TInt KControlIoLockMount=5;

LOCAL_D const TInt KControlIoClearLockMount=6;

LOCAL_D const TInt KControlIoCNotifier=7;

LOCAL_D const TInt KControlIoClearCNotifier=8;

LOCAL_D const TInt KControlIoCancelNCNotifier=KMaxTInt-1;

LOCAL_D TBool isSecureMmc;

LOCAL_D TFileName gLockedPath;

LOCAL_D TFileName gLockedBase;

LOCAL_D TInt gLockedDrive;

GLREF_D TFileName gSessionPath;

LOCAL_D TInt gSessionDrive;

TBuf8<16> KPassword8=_L8("abc");

TBuf16<8> KPassword=_L("abc");

_LIT(File1,"file1");

_LIT(File2,"file2");

_LIT(Dir1,"\\dir1\\");

_LIT(NotifyDir,"\\not\\");

_LIT(NotifyDir2,"\\abc\\");

_LIT(HungDirNC,"\\hungnc\\");

_LIT(HungDirC,"\\hungc\\");

LOCAL_D const TInt KHeapSize=0x2000;

struct SNonCriticalInfo

	{

	TBool iSameSession;

	TBool iUseRFile;

	};

LOCAL_C TInt ThreadFunctionNC(TAny* aInfo)

//

// Thread entry point to put up non-critical notifier

//

	{

	RFs fs;

	TInt r;

	TBuf8<8> mmcBuf;

	// pad out password if using lockable mmc

	if(isSecureMmc)

		{

		TUint8 pBuf[]={0x61,0x00,0x62,0x00,0x63,00};

		mmcBuf.SetLength(6);

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

			mmcBuf[i]=pBuf[i];

		}

	SNonCriticalInfo* info=NULL;

	if(aInfo!=NULL)

		info=(SNonCriticalInfo*)aInfo;

	r=fs.Connect();

	if(isSecureMmc)

		{

		if(info && info->iSameSession)

			r=TheFs.LockDrive(gLockedDrive,NULL,mmcBuf,EFalse);

		else

			{

			r=fs.LockDrive(gLockedDrive,NULL,mmcBuf,EFalse);

			RDebug::Print(_L("l=%d"),r);

			}

		}

	else

		{

		if(info && info->iSameSession)

			r=TheFs.ControlIo(gLockedDrive,KControlIoLockMount,KPassword8);

		else

			r=fs.ControlIo(gLockedDrive,KControlIoLockMount,KPassword8);

		}

//	UserSvr::ForceRemountMedia(ERemovableMedia0);

	User::After(300000);

	HungSemaphoreNC.Signal();

	TFileName hungDir=gLockedBase;

	hungDir+=HungDirNC;

	if(info && info->iSameSession)

		r=TheFs.RmDir(hungDir);

	else if(info && info->iSameSession && info->iUseRFile)

		{

		TBuf8<16> buf=_L8("abc");

		r=SubFile1.Write(buf);

		}

	else

		{

		r=fs.RmDir(hungDir);

		RDebug::Print(_L("rd=%d"),r);

		}

	HungReturnCodeNC=r;

	if(isSecureMmc)

		{

		r=fs.UnlockDrive(gLockedDrive,mmcBuf,EFalse);

		r=fs.ClearPassword(gLockedDrive,mmcBuf);

		}

	else

		r=fs.ControlIo(gLockedDrive,KControlIoClearLockMount,KPassword8);

	HungSemaphoreNC.Signal();

	fs.Close();

	return(KErrNone);

	}

LOCAL_C TInt ThreadFunctionC(TAny* aDrive)

//

// Thread entry point to put up a critical notifier

//

	{

	RFs fs;

	TInt r=fs.Connect();

	TInt drive;

#if defined(__WINS__)

	drive=EDriveY;

#else	

	drive=EDriveC;

#endif

	// can only get critcal notifer up using ControIo

	// assumes fat file system running on one of the drives named below

	r=fs.ControlIo(drive,KControlIoCNotifier);

	TBool isRemovable=*(TBool*)aDrive;

	TFileName hungDir=(_L("?:"));

#if defined(__WINS__)

	if(isRemovable)

		hungDir[0]=(TText)('A'+EDriveX);

	else

		hungDir[0]=(TText)('A'+EDriveY);

#else

	if(isRemovable)

		hungDir[0]=(TText)('A'+EDriveD);

	else

		hungDir[0]=(TText)('A'+EDriveC);

#endif

	hungDir+=HungDirC;

	r=fs.RmDir(hungDir);

	r=fs.MkDir(hungDir);

	HungReturnCodeC=r;

	r=fs.ControlIo(drive,KControlIoClearCNotifier);

	HungSemaphoreC.Signal();

	r=fs.RmDir(hungDir);

	fs.Close();

	return(KErrNone);

	}

LOCAL_C void PutNonCriticalNotifier(TAny* aInfo,RThread& aThread)

//

// put up a non-critical notifier on a removable media

//

	{

	TInt r=aThread.Create(_L("ThreadNC"),ThreadFunctionNC,KDefaultStackSize,KMinHeapSize,KMinHeapSize,aInfo);

	aThread.SetPriority(EPriorityMore);

	aThread.Resume();

	HungSemaphoreNC.Wait();

	User::After(1000000);

	}

LOCAL_C void PutCriticalNotifier(TBool aBool,RThread& aThread)

//

// put up a critical notifier on the specified drive

//

	{

	TInt r=aThread.Create(_L("ThreadC"),ThreadFunctionC,KDefaultStackSize,KMinHeapSize,KMinHeapSize,&aBool);

	aThread.SetPriority(EPriorityMore);

	aThread.Resume();

	User::After(1000000);

	}

void TestNotifiers()

//

// Test non-critical notifier is cancelled when the critical notifier is put up

// Needs to be carried out on platform with password notifier which handles requests

// asynchronously and uses CAtaDisk in fat file system on c: drive ie. not internal ram

// drive

//

	{

	test.Next(_L("TestNotifiers"));

	if(isSecureMmc)

		return;

	RThread threadNC,threadC;

	PutNonCriticalNotifier(NULL,threadNC);

	PutCriticalNotifier(EFalse,threadC);

	// get rid of critical notifier

	test.Printf(_L("Press cancel on for critcal notifier\n"));

	test.Printf(_L("Press any character\n"));

	test.Getch();

	TRequestStatus deathStat;

	threadNC.Logon( deathStat );

	HungSemaphoreC.Wait();

	// test(HungReturnCodeNC==KErrAbort);

	TRequestStatus deathStat2;

	threadC.Logon(deathStat2);

	HungSemaphoreNC.Wait();

	//test(HungReturnCodeNC==KErrLocked);

	User::WaitForRequest(deathStat2);

	threadNC.Close();

	threadC.Close();

	}

void TestCriticalFunctions() 

//

// test that only a subset of functions are supported when the critical notifier is up

//

	{

	test.Next(_L("test functions supported with critical notifier"));

	// used for EFsSubClose

	RFile file;

	TInt r=file.Create(TheFs,File1,EFileShareAny|EFileWrite);

	if(r==KErrAlreadyExists)

		{

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

		}

	TBuf8<16> buf=_L8("abcdefghijklmnop");

	r=file.Write(buf);

	r=TheFs.MkDir(NotifyDir);

	RThread thread;

	PutCriticalNotifier(ETrue,thread);

	// test functions that are supported with critical notifier

	// EFsNotifyChange

	test.Next(_L("test functions that are supported with critical notifier"));

	TRequestStatus status;

	TheFs.NotifyChange(ENotifyAll,status);

	test(status==KRequestPending);

	// EFsNotifyChangeCancel

	TheFs.NotifyChangeCancel();

	test(status==KErrCancel);

	// EFsNotifyChangeEx

	TheFs.NotifyChange(ENotifyAll,status,gSessionPath);

	test(status==KRequestPending);

	// EFsNotifyChangeCancelEx

	TheFs.NotifyChangeCancel(status);

	test(status==KErrCancel);

	// EFsSubClose

	// difficult  to test properly because this does not return an error value

	file.Close();

	// test that notifications are not completed when a critical notifier completes

	test.Next(_L("test notifications not completed"));

	TheFs.NotifyChange(ENotifyDisk,status);

	test(status==KRequestPending);

	TRequestStatus status2;

	TheFs.NotifyChange(ENotifyDir,status2,NotifyDir);

	test(status2==KRequestPending);

	// test some functions that are not supported when critcical notifier up

	// EFsFileOpen

	test.Next(_L("test functions that are not supported with critical notifier"));

	r=file.Open(TheFs,File2,EFileShareAny);

	// EFsFileCreate

	r=file.Create(TheFs,File2,EFileShareAny);

	// EFsMkDir

	r=TheFs.MkDir(Dir1);

	// EFsVolume

	TVolumeInfo info;

	r=TheFs.Volume(info,gSessionDrive);

	// get rid of critical notifier

	test.Printf(_L("Press escape on the critical notifier\n"));

	TRequestStatus deathStat;

	thread.Logon(deathStat);

	HungSemaphoreC.Wait();

	test(HungReturnCodeC==KErrAbort);

	User::WaitForRequest(deathStat);

	thread.Close();

	// test notifiers have not gone off

	test(status==KRequestPending&&status2==KRequestPending);

	// test that notification setup on  default drive has had the drive changed

	// to * since the critical notifier was up

	TFileName notDir=gLockedBase;

	notDir+=NotifyDir;

	r=TheFs.MkDir(notDir);

	test(status==KRequestPending&&status2==KErrNone);

	TheFs.NotifyChangeCancel();

	test(status==KErrCancel);

	r=TheFs.Delete(File1);

	r=TheFs.RmDir(notDir);

	r=TheFs.RmDir(NotifyDir);

	}

void TestParsingFunctions()	

//

// Test functions that use Parse* and Validate* functions with 

// non-critical notifier up

// 

	{

	test.Next(_L("TestParsingFunctions"));

	RThread thread;

	PutNonCriticalNotifier(NULL,thread);

	// test on same drive as notifier

	test.Next(_L("test parsing functions on same drive"));

	// Using ParseSubst

	TFileName dir=gLockedBase;

	dir+=Dir1;

	TInt r=TheFs.MkDir(dir);

	TFileName file=gLockedPath;

	file+=File1;

	RFile f;

	r=f.Create(TheFs,file,EFileShareAny);

	// Using ParsePathPtr0

	r=TheFs.SetSubst(gLockedPath,EDriveO);

	// ValidateDrive

	TVolumeInfo info;

	r=TheFs.Volume(info,gLockedDrive);

	TFileName origSessPath;

	r=TheFs.SessionPath(origSessPath);

	// test these work ok

	r=TheFs.SetSessionPath(gLockedPath);

	r=TheFs.SetSessionPath(origSessPath);

	// test on different drive from notifier - the session path

	test.Next(_L("test parsing functions on a different drive"));

	// Using ParseSubst

	r=TheFs.MkDir(Dir1);

	r=TheFs.RmDir(Dir1);

	r=f.Create(TheFs,File1,EFileShareAny);

	f.Close();

	r=TheFs.Delete(File1);

	// Using ParsePathPtr0

	r=TheFs.SetSubst(gSessionPath,EDriveO);

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

	// ValidateDrive

	r=TheFs.Volume(info,gSessionDrive);

	// get rid of non-critical notifier

	test.Printf(_L("Enter %S on the notifier\n"),&KPassword);

	TRequestStatus deathStat;

	thread.Logon( deathStat );

	HungSemaphoreNC.Wait();

	test(HungReturnCodeNC==KErrNotFound);

	User::WaitForRequest( deathStat );

	thread.Close();

//	test.End();

	}

void TestTFsFunctions()	

//

// test functions that do not use the Parse* and Validate* functions

//

	{

	test.Next(_L("TestTFsFunctions"));

	TFileName sessName,lockedName;

	TInt r=TheFs.FileSystemName(sessName,gSessionDrive);

	r=TheFs.FileSystemName(lockedName,gLockedDrive);

	RThread thread;

	PutNonCriticalNotifier(NULL,thread);

	// test functions on hung drive - should return KErrInUse

	test.Next(_L("test TFs functions on hung drive"));

	// TFsDismountFileSystem

	r=TheFs.DismountFileSystem(lockedName,gLockedDrive);

	// TFsMountFileSystem

	r=TheFs.MountFileSystem(lockedName,gLockedDrive);

	// TFsFileSystemName

	r=TheFs.FileSystemName(lockedName,gLockedDrive);

	// test functions on drive other than hung drive

	test.Next(_L("test TFs functions on drive that is not hung"));

	// TFsDismountFileSystem

#if defined(__WINS__)

	// bug in TFsMountFileSystem which needs to be fixed before running on EDriveC on WINS

	if(gSessionDrive!=EDriveC)

		{

#endif

	r=TheFs.DismountFileSystem(sessName,gSessionDrive);

	// TFsMountFileSystem

	r=TheFs.MountFileSystem(sessName,gSessionDrive);

#if defined(__WINS__)

		}

#endif

	// TFsFileSystemName

	TFileName fsName;

	r=TheFs.FileSystemName(fsName,gSessionDrive);

	test(fsName==sessName);

	// test functions that fail on all drives

	test.Next(_L("test TFs functions that fail on all drives"));

	// TFsListOpenFiles

	CFileList* list=NULL;

	TOpenFileScan fileScan(TheFs);

	TRAP(r,fileScan.NextL(list));

	// test functions that should pass on any drive

	test.Next(_L("test TFs functions that pass on all drives"));

	// TFsSetDefaultPath

	// TFsSetSessionPath

	r=TheFs.SetSessionPath(gLockedPath);

	r=TheFs.SetSessionPath(gSessionPath);

	// get rid of non-critical notifier

	test.Printf(_L("Enter %S on the notifier\n"),&KPassword);

	TRequestStatus deathStat;

	thread.Logon( deathStat );

	HungSemaphoreNC.Wait();

	test(HungReturnCodeNC==KErrNotFound);

	User::WaitForRequest( deathStat );

	thread.Close();

//	test.End();

	}

void TestSubsessions()	

//

// test subsession functions

//

	{

	test.Next(_L("TestSubsessions"));

	RThread thread;

	PutNonCriticalNotifier(NULL,thread);

	// test that subsessions cannot be opened on a hung drive

	test.Next(_L("test subsessions cannot be opened on a hung drive"));

	// EFsFileCreate

	RFile file;

	TFileName fileName=gLockedPath;

	fileName+=File1;

	TInt r=file.Create(TheFs,fileName,EFileShareAny);

	// EFsFormatOpen

	RFormat format;

	TInt count;

	r=format.Open(TheFs,gLockedPath,EHighDensity,count);

	// EFsDirOpen

	RDir dir;