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

 // e32test\pccd\t_meddrv.cpp

 // General media driver tests

 // 

 //

 #include <e32base.h>

 #include <e32base_private.h>

 #include <e32test.h>

 #include <e32svr.h>

 #include <e32hal.h>

 #include <e32uid.h>

 const TInt KHeapSize=0x4000;

 const TInt KTestDriverMediaSize=0x1000;	// 4K

 const TInt KShortBufferSize=0x100;

 #define MEDDRV_ATA_NAME _L("MEDATA")

 #define MEDDRV_SINGLE_REQ_NAME _L("MEDT1")

 #define MEDDRV_SIMULTANEOUS_REQ_NAME _L("MEDT2")

 LOCAL_D RTest test(_L("T_MEDDRV"));

 LOCAL_D TInt TheDriveNumber=3;	

 LOCAL_C TInt formatThread(TAny*)

 	{

 	TBusLocalDrive anotherDrive;

 	RTest ftest(_L("Formatting thread"));

 	ftest.Title();

 	ftest.Start(_L("Connect to local drive"));

 	TBool changeFlag=EFalse;

 	ftest(anotherDrive.Connect(TheDriveNumber,changeFlag)==KErrNone);

 	ftest.Next(_L("Format disk"));

 	ftest(anotherDrive.Format(0,KTestDriverMediaSize)==KErrNone);

 	anotherDrive.Disconnect();

     ftest.End();

 	return(KErrNone);

 	}

 GLDEF_C TInt E32Main()

     {

 	TBuf<64> b;

 	TInt r;

 	TInt i;

 	test.Title();

 	test.Start(_L("Check loader running"));

 #if !defined (__WINS__)

     test.Next(_L("Read drive information"));

 	TDriveInfoV1Buf dinfo;

 	r=UserHal::DriveInfo(dinfo);

 	test(r==KErrNone);

 	if (dinfo().iTotalSockets==2)

         TheDriveNumber=3;

     else if (dinfo().iTotalSockets==1)

         TheDriveNumber=2;

     else

 		{

 		test.Printf(_L("Test not supported on this platform"));

 		test.End();

 		return(0);

 		}

 #else

     TheDriveNumber=3;

 #endif

 	test.Next(_L("Load 1st Media Driver"));

 	r=User::LoadPhysicalDevice(MEDDRV_ATA_NAME);

 	test(r==KErrNone||r==KErrAlreadyExists);

 	r=User::LoadPhysicalDevice(MEDDRV_SINGLE_REQ_NAME);

 	test(r==KErrNone||r==KErrAlreadyExists);

 	test.Printf(_L("Media drivers installed:\n\r"));

 	TFindPhysicalDevice findMediaDrv(_L("Media.*"));

 	TFullName findResult;

 	r=findMediaDrv.Next(findResult);

 	while (r==KErrNone)

 		{

 		test.Printf(_L("   %S\n\r"),&findResult);

 		r=findMediaDrv.Next(findResult);

 		}

 	b.Format(_L("Connect to local drive %d"),TheDriveNumber);

 	test.Next(b);

 	TBusLocalDrive theDrive;

 	TBool changeFlag=EFalse;

 	test(theDrive.Connect(TheDriveNumber,changeFlag)==KErrNone);

 	test.Next(_L("Local drive: Capabilities"));

 	// Generate a media change to open the profiler media driver rather than the standard one

 //	UserSvr::ForceRemountMedia(ERemovableMedia0);

 	User::After(300000); // Wait 0.3Sec

 	TLocalDriveCapsV2Buf info;

 	test(theDrive.Caps(info)==KErrNone);

 	test(I64LOW(info().iSize)==(TUint)KTestDriverMediaSize);

 	test(info().iType==EMediaRam);

 	test.Next(_L("Local drive: Write/Read"));

 	TInt len;

 	TBuf8<KShortBufferSize> rdBuf,wrBuf;

 	wrBuf.SetLength(KShortBufferSize);

 	for (i=0;i<KShortBufferSize;i++)

 		wrBuf[i]=(TUint8)i;

 	for (i=0;i<KTestDriverMediaSize;i+=len)

 		{

 		len=Min(KShortBufferSize,(KTestDriverMediaSize-i));

 		wrBuf.SetLength(len);

 		test(theDrive.Write(i,wrBuf)==KErrNone);

 		}

 	for (i=0;i<KTestDriverMediaSize;i+=len)

 		{

 		len=Min(KShortBufferSize,(KTestDriverMediaSize-i));

 		rdBuf.Fill(0,len);

  		test(theDrive.Read(i,len,rdBuf)==KErrNone);

 		wrBuf.SetLength(len);

   	    test(rdBuf.Compare(wrBuf)==0);

 		}

 	test.Next(_L("Start 2nd thread to format drive"));

 	RThread thread;

 	TRequestStatus stat;

 	test(thread.Create(_L("Thread"),formatThread,KDefaultStackSize,KHeapSize,KHeapSize,NULL)==KErrNone);

 	thread.Logon(stat);

 	thread.Resume();

 	test.Next(_L("Drive read/write during format"));

 	User::After(2000000); // Wait 2Secs for format to get going

     rdBuf.SetLength(KShortBufferSize);

  	test(theDrive.Read(0,KShortBufferSize,rdBuf)==KErrInUse);

 	wrBuf.SetLength(KShortBufferSize);

 	test(theDrive.Write(0,wrBuf)==KErrInUse);

     // Verify format unaffected

     User::WaitForRequest(stat);

 	test(stat==KErrNone);

 	CLOSE_AND_WAIT(thread);

 	wrBuf.Fill(0xFF,KShortBufferSize);

 	for (i=0;i<KTestDriverMediaSize;i+=len)

 		{

 		len=Min(KShortBufferSize,(KTestDriverMediaSize-i));

 		rdBuf.Fill(0,len);

  		test(theDrive.Read(i,len,rdBuf)==KErrNone);

 		wrBuf.SetLength(len);

   	    test(rdBuf.Compare(wrBuf)==0);

 		}

 	test.Next(_L("Load 2nd Media Driver"));

 	r=User::FreePhysicalDevice(_L("Media.Tst1"));

 	test(r==KErrNone);

 	r=User::LoadPhysicalDevice(MEDDRV_SIMULTANEOUS_REQ_NAME);

 	test(r==KErrNone||r==KErrAlreadyExists);

 	test.Printf(_L("Media drivers installed:\n\r"));

 	findMediaDrv.Find(_L("Media.*"));

 	r=findMediaDrv.Next(findResult);

 	while (r==KErrNone)

 		{

 		test.Printf(_L("   %S\n\r"),&findResult);

 		r=findMediaDrv.Next(findResult);

 		}

 	test.Next(_L("Local drive: Capabilities"));

 	// Generate a media change to open the profiler media driver rather than the standard one

 //	UserSvr::ForceRemountMedia(ERemovableMedia0);

 	User::After(300000); // Wait 0.3Sec

 	test(theDrive.Caps(info)==KErrNone);

 	test(I64LOW(info().iSize)==(TUint)KTestDriverMediaSize);

 	test(info().iType==EMediaFlash);

 	test.Next(_L("Local drive: Write/Read"));

 	wrBuf.SetLength(KShortBufferSize);

 	for (i=0;i<KShortBufferSize;i++)

 		wrBuf[i]=(TUint8)i;

 	for (i=0;i<KTestDriverMediaSize;i+=len)

 		{

 		len=Min(KShortBufferSize,(KTestDriverMediaSize-i));

 		wrBuf.SetLength(len);

 		test(theDrive.Write(i,wrBuf)==KErrNone);

 		}

 	for (i=0;i<KTestDriverMediaSize;i+=len)

 		{

 		len=Min(KShortBufferSize,(KTestDriverMediaSize-i));

 		rdBuf.Fill(0,len);

  		test(theDrive.Read(i,len,rdBuf)==KErrNone);

 		wrBuf.SetLength(len);

   	    test(rdBuf.Compare(wrBuf)==0);

 		}

 	test.Next(_L("Start 2nd thread again to format drive"));

 	test(thread.Create(_L("Thread"),formatThread,KDefaultStackSize,KHeapSize,KHeapSize,NULL)==KErrNone);

 	thread.Logon(stat);

 	thread.Resume();

 	test.Next(_L("Drive read/write during format"));

 	User::After(2000000); // Wait 2Secs for format to get going

     rdBuf.SetLength(KShortBufferSize);

  	test(theDrive.Read(0,KShortBufferSize,rdBuf)==KErrNone);

 	wrBuf.Fill(0xFF,KShortBufferSize);

   	test(rdBuf.Compare(wrBuf)==0);

     for (i=0;i<KShortBufferSize;i++)

 		wrBuf[i]=(TUint8)i;

 	test(theDrive.Write(0,wrBuf)==KErrNone);

  	test(theDrive.Read(0,KShortBufferSize,rdBuf)==KErrNone);

   	test(rdBuf.Compare(wrBuf)==0);

     // Verify remaining part of format

     User::WaitForRequest(stat);

 	test(stat==KErrNone);

 	CLOSE_AND_WAIT(thread);

 	wrBuf.Fill(0xFF,KShortBufferSize);

 	for (i=KShortBufferSize;i<KTestDriverMediaSize;i+=len)

 		{

 		len=Min(KShortBufferSize,(KTestDriverMediaSize-i));

 		rdBuf.Fill(0,len);

  		test(theDrive.Read(i,len,rdBuf)==KErrNone);

 		wrBuf.SetLength(len);

   	    test(rdBuf.Compare(wrBuf)==0);

 		}

 	test.Next(_L("Unload 2nd Media Driver"));

 	User::FreePhysicalDevice(_L("Media.Tst2"));

 	// Generate a media change to restore the standard one next mount

 //	UserSvr::ForceRemountMedia(ERemovableMedia0);

 	User::After(300000); // Wait 0.3Sec

 	theDrive.Disconnect();

 	test.End();

 	return(0);

 	}