diff -r 000000000000 -r a41df078684a kerneltest/f32test/filesystem/fat/t_raw.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/f32test/filesystem/fat/t_raw.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,359 @@
+// Copyright (c) 1996-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_raw.cpp
+//
+//
+
+#define __E32TEST_EXTENSION__
+
+#include <f32file.h>
+#include <e32test.h>
+#include "t_server.h"
+
+#include "fs_utils.h"
+#include "fat_utils.h"
+using namespace Fat_Test_Utils;
+
+
+GLDEF_D RTest test(_L("T_RAW"));
+
+LOCAL_D TInt gDrive;
+
+LOCAL_C void Test1()
+//
+// Test all methods
+//
+	{
+
+	test.Start(_L("Test all methods"));
+	RRawDisk rd;
+	TInt r=rd.Open(TheFs,gDrive);
+	test(r==KErrNone);
+	TBuf8<16> buf;
+	r=rd.Read(0,buf);
+	test(r==KErrNone);
+	r=rd.Write(0,buf);
+	test(r==KErrNone);
+	rd.Close();
+	test.End();
+	}
+
+LOCAL_C void Test2()
+//
+// Test cannot open a RRawDisk while other resources are open on it.
+//
+	{
+
+	MakeFile(_L("TRAW.TST"));
+	MakeDir(_L("\\F32-TST\\TRAW\\TRAWTEST\\"));
+
+	RFile f;
+	TInt r=f.Open(TheFs,_L("TRAW.TST"),EFileWrite);
+	test(r==KErrNone);
+	RRawDisk rd;
+	r=rd.Open(TheFs,gDrive);
+	test(r==KErrInUse);
+	f.Close();
+	r=rd.Open(TheFs,gDrive);
+	test(r==KErrNone);
+	rd.Close();
+
+	TFileName fileName;
+	r=f.Temp(TheFs,_L(""),fileName,EFileWrite);
+	test(r==KErrNone);
+	r=rd.Open(TheFs,gDrive);
+	test(r==KErrInUse);
+	f.Close();
+	r=rd.Open(TheFs,gDrive);
+	test(r==KErrNone);
+	rd.Close();
+
+	RDir d;
+	r=d.Open(TheFs,_L("TRAWTEST"),KEntryAttNormal);
+	test(r==KErrNone);
+	r=rd.Open(TheFs,gDrive);
+	test(r==KErrInUse);
+	d.Close();
+	r=rd.Open(TheFs,gDrive);
+	test(r==KErrNone);
+	rd.Close();
+
+    RFormat fmt;
+    TInt count;
+    r=fmt.Open(TheFs,gSessionPath,EQuickFormat,count);
+    test(r==KErrNone);
+    r=rd.Open(TheFs,gDrive); // Raw disk access ok during formatting
+    test.Printf(_L("open rd when fmt opn r=%d"),r);
+	test(r==KErrInUse);
+    fmt.Close();
+    r=rd.Open(TheFs,gDrive);
+	test.Printf(_L("open rd when fmt closed r=%d"),r);
+    test(r==KErrNone);
+	RRawDisk rd2;
+	r=rd2.Open(TheFs,gDrive);	//should only have one Raw object open
+	test(r==KErrInUse);
+	rd2.Close();
+    rd.Close();
+	}
+
+LOCAL_C void Test3()
+//
+// Test cannot open resources on a disk while raw access is taking place
+//
+	{
+
+	MakeFile(_L("TRAW.TST"));
+	MakeDir(_L("TRAW"));
+
+	RRawDisk rd;
+	TInt r=rd.Open(TheFs,gDrive);
+	test(r==KErrNone);
+
+	RFile f;
+	TFileName fileName;
+	r=f.Open(TheFs,_L("TRAW.TST"),EFileWrite);
+	test(r==KErrInUse);
+	r=f.Temp(TheFs,_L(""),fileName,EFileWrite);
+	test(r==KErrInUse);
+
+	RDir d;
+	r=d.Open(TheFs,_L("TRAW"),KEntryAttNormal);
+	test(r==KErrInUse);
+
+	RFormat fmt;
+	TInt count;
+	r=fmt.Open(TheFs,gSessionPath,EQuickFormat,count);
+    if (r != KErrInUse)
+        test.Printf(_L("Error %d. Sess = %S"), r, &gSessionPath);
+	test(r==KErrInUse);
+
+	CDir* dir=(CDir*)0x05;
+	r=TheFs.GetDir(_L("\\F32-TST\\*.*"),KEntryAttNormal,ESortNone,dir);
+	test(r==KErrInUse);
+	test(dir==NULL);
+
+	RRawDisk rd2;
+	r=rd2.Open(TheFs,gDrive);
+	test(r==KErrInUse);
+
+//	fmt.Close();
+	rd.Close();
+//	rd2.Close();
+	}
+
+LOCAL_C void Test4()
+//
+// Test Read and Write
+//
+	{
+
+	TBuf8<32> contents=_L8("This File says BOO");
+	MakeFile(_L("TRAW.TST"),contents);
+
+	RRawDisk rd;
+	TInt r=rd.Open(TheFs,gDrive);
+	test(r==KErrNone);
+
+	TBuf8<32> textBuf;
+	TInt64 pos=0;
+
+	test.Printf(_L("doing rawread"));
+	FOREVER
+		{
+		r=rd.Read(pos,textBuf);
+		if (r!=KErrNone)
+			{
+			test.Printf(_L("ERROR: RawDisk read returned %d at pos %ld"),r, pos);
+			test(0);
+			//test.Getch();
+			break;
+			}
+		if ((pos % (1024*1024)) == 0)
+			test.Printf(_L("Read position 0x%x            \r"), pos);
+		textBuf.SetLength(contents.Length());
+		if (textBuf==contents)
+			break;
+		pos+=512;
+		}
+	test.Printf(_L("\n"));
+
+	TBuf8<32> contents2=_L8("This File says MOO");
+	r=rd.Write(pos,contents2);
+	test(r==KErrNone);
+	rd.Close();
+
+	RFile f;
+	r=f.Open(TheFs,_L("TRAW.TST"),EFileRead);
+	test(r==KErrNone);
+	r=f.Read(textBuf);
+	test(r==KErrNone);
+	test(textBuf==contents2);
+	f.Close();
+	}
+
+enum TTestCommands
+	{
+	EThreadForgetToCloseSession,
+	EThreadForgetToCloseRaw,
+	EThreadHang
+	};
+
+RSemaphore gSemaphore;
+
+TInt MyThreadFunction(TAny* aThreadCommand)
+//
+// Do nasty things
+//
+	{
+
+	RRawDisk rd;
+	RFs fs;
+	TInt r=fs.Connect();
+	if (r!=KErrNone)
+		goto Error;
+	r=rd.Open(fs,gDrive);
+	if (r!=KErrNone)
+		goto Error;
+
+	switch((TTestCommands)(TInt)aThreadCommand)
+		{
+	case EThreadForgetToCloseSession:
+		return(KErrNone);
+
+	case EThreadForgetToCloseRaw:
+		break;
+
+	case EThreadHang:
+		gSemaphore.Signal();
+		FOREVER{};
+
+	default:
+		goto Error;
+		}
+	fs.Close();
+	return(KErrNone);
+
+Error:
+	User::Panic(_L("Shouldn't be here!"),0);
+	return(KErrNone);
+	}
+
+LOCAL_C void Test5()
+//
+// Test thread panics
+//
+	{
+
+	test.Next(_L("Test thread panics"));
+	MakeFile(_L("TEST.FILE"));
+
+	RThread thread;
+	TInt r=thread.Create(_L("MyThread"),MyThreadFunction,0x1000,0x1000,0x1000,(TAny*)EThreadForgetToCloseSession);
+	test(r==KErrNone);
+	TRequestStatus reqStat;
+	thread.Logon(reqStat);
+	thread.Resume();
+	User::WaitForRequest(reqStat);
+	CLOSE_AND_WAIT(thread);
+
+	// We know the disconnect has been sent to the file server by this point
+	// but we don't know it has been processed.
+	// Connect and disconnect a session here to make sure.
+	FsBarrier();
+
+	RFile f;
+	r=f.Open(TheFs,_L("TEST.FILE"),EFileWrite);
+	test(r==KErrNone);
+	f.Close();
+
+	r=thread.Create(_L("MyThread"),MyThreadFunction,0x1000,0x1000,0x1000,(TAny*)EThreadForgetToCloseRaw);
+	test(r==KErrNone);
+	thread.Logon(reqStat);
+	thread.Resume();
+	User::WaitForRequest(reqStat);
+	CLOSE_AND_WAIT(thread);
+
+	// We know the disconnect has been sent to the file server by this point
+	// but we don't know it has been processed.
+	// Connect and disconnect a session here to make sure.
+	FsBarrier();
+
+	r=f.Open(TheFs,_L("TEST.FILE"),EFileWrite);
+	test(r==KErrNone);
+	f.Close();
+
+	r=gSemaphore.CreateGlobal(_L("MySemaphore"),0);
+	test(r==KErrNone);
+	r=thread.Create(_L("MyThread"),MyThreadFunction,0x1000,0x1000,0x1000,(TAny*)EThreadHang);
+	test(r==KErrNone);
+	thread.Resume();
+	gSemaphore.Wait();
+	gSemaphore.Close();
+
+	r=f.Open(TheFs,_L("TEST.FILE"),EFileWrite);
+	test(r==KErrInUse);
+	TBool jit = User::JustInTime();
+	User::SetJustInTime(EFalse);
+	thread.Kill(KErrGeneral);
+	CLOSE_AND_WAIT(thread);
+	User::SetJustInTime(jit);
+
+	// We know the disconnect has been sent to the file server by this point
+	// but we don't know it has been processed.
+	// Connect and disconnect a session here to make sure.
+	FsBarrier();
+
+	r=f.Open(TheFs,_L("TEST.FILE"),EFileWrite);
+	test(r==KErrNone);
+	f.Close();
+	}
+
+
+GLDEF_C void CallTestsL()
+//
+// Do all tests
+//
+	{
+
+    //-- set up console output
+    Fat_Test_Utils::SetConsole(test.Console());
+
+	TInt r=TheFs.CharToDrive(gSessionPath[0],gDrive);
+	test(r==KErrNone);
+
+    PrintDrvInfo(TheFs, gDrive);
+
+    //-- check if this is FAT
+    if(!Is_Fat(TheFs, gDrive))
+    {
+        test.Printf(_L("Skipping. This test requires FAT drive.\n"));
+        return;
+    }
+
+    //-- format the drive.
+    r = FormatFatDrive(TheFs, gDrive, ETrue);
+    test_KErrNone(r);
+
+	CreateTestDirectory(_L("\\F32-TST\\TRAW\\"));
+
+	Test1();
+	Test2();
+	Test3();
+
+	Test4(); // (silly test) Not valid on LFFS
+
+    Test5();
+
+	DeleteTestDirectory();
+	}