// 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\manager\t_proc.cpp
// 
//

#include <f32file.h>
#include <e32test.h>
#include <e32svr.h>
#include <hal.h>
#include "t_server.h"
#include "t_chlffs.h"

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

LOCAL_C TInt ThreadMain(TAny* /*aPtr*/)
//
// Startup function for thread
//
	{

	RFs localFs;
	TInt r=localFs.Connect();
	if (r != KErrNone)
		User::Panic(_L("tm0"), r);
	
	r=localFs.SetSessionPath(gSessionPath);
	if (r != KErrNone)
		User::Panic(_L("tm1"), r);

	TInt count;
	RFormat f;
#if defined(__MARM__)
	TBuf<4> dirBuf=_L("?:\\");
	dirBuf[0] = (TText)gDriveToTest;
	r=f.Open(localFs,dirBuf,EQuickFormat,count);
#else	
	r=f.Open(localFs,_L("Y:\\"),EQuickFormat,count);
#endif
	if (r != KErrNone)
		User::Panic(_L("tm2"), r);
	f.Close();

	TInt drv;
	r = RFs::CharToDrive(gSessionPath[0], drv);
	if (r != KErrNone)
		User::Panic(_L("tm3"), r);


	RRawDisk raw;
	r=raw.Open(localFs,drv);
	if (r != KErrNone)
		User::Panic(_L("tm4"), r);

	raw.Close();
	return(KErrNone);
	}

LOCAL_C void testThreads()
//
//	Run a process that opens a file, format, directory and check that when 
//	the process closes they are all still accessible.
//
	{

	RThread thread;
	TInt r=thread.Create(_L("Thread1"),ThreadMain,KDefaultStackSize,KMinHeapSize,0x10000,NULL);
	test(r==KErrNone);
	TRequestStatus reqStat;
	thread.Logon(reqStat);
	thread.Resume();
	thread.Close();
	User::WaitForRequest(reqStat);
//
#if defined(__MARM__)
	TBuf<13> dirBuf=_L("?:\\F32-TST\\");
	dirBuf[0] = (TText)gDriveToTest;
	r=TheFs.MkDir(dirBuf);
#else
	r=TheFs.MkDir(_L("Y:\\F32-TST\\"));
#endif
	test(r==KErrNone || r==KErrAlreadyExists);
	RFile f;	

	r=f.Open(TheFs,_L("THREADFILE.TEST"),EFileRead);
	test(r==KErrNotFound || r==KErrPathNotFound || r==KErrNone);
	f.Close();

	r=f.Replace(TheFs,_L("THREADFILE.TEST"),EFileRead|EFileWrite);
	test(r==KErrNone);
	f.Close();
	}

LOCAL_C void DoTests()
//
// Run tests
//	
	{
//	TInt r=TheFs.SessionPath(gSessionPath);
//	test(r==KErrNone);
	testThreads();
	}


GLDEF_C void CallTestsL(void)
//
// Test the file server.
//
    {
	
	test.Title();

	TChar driveLetter;
	if (IsSessionDriveLFFS(TheFs,driveLetter))
		{
		test.Printf(_L("Skipped: test does not run on LFFS.\n"));
		return;
		}
	test.Start(_L("Starting T_PROC test"));
	TInt uid;
	test(HAL::Get(HAL::EMachineUid,uid)==KErrNone);
	
	if(uid==HAL::EMachineUid_Cogent || uid==HAL::EMachineUid_IQ80310 || uid==HAL::EMachineUid_Integrator || uid==HAL::EMachineUid_X86PC)
		{
		test.Printf(_L("WARNING: d: not tested on cogent or IQ80310 or Integrator\n"));
		goto End;
		}
	DoTests();
End:
	test.End();
	return;
    }