// 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;

    }