diff -r 000000000000 -r 08ec8eefde2f persistentstorage/store/TFILE/t_storfrecl.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/persistentstorage/store/TFILE/t_storfrecl.cpp	Fri Jan 22 11:06:30 2010 +0200
@@ -0,0 +1,265 @@
+// 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 "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:
+//
+
+#include <s32file.h>
+#include <e32test.h>
+#include <e32math.h>
+#include <hal.h>
+
+// This is a path specification and should not be used as is
+_LIT(KFileLocationSpec, "Z:\\STOR-TST\\T_FRECL.DAT");
+const TPtrC KTestText=_L("Reclamation testing in progress...");
+const TInt 	KTestStreams=1000;
+const TInt 	KTestReplicas=5000;
+
+TFileName TheFileName; 
+
+RTest 	TheTest(_L("t_storfrecl"));
+RFs 	TheFs;
+TInt64 	TheSeed;
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+void DeleteDataFile(const TDesC& aFullName)
+	{
+	RFs fsSession;
+	TInt err = fsSession.Connect();
+	if(err == KErrNone)
+		{
+		TEntry entry;
+		if(fsSession.Entry(aFullName, entry) == KErrNone)
+			{
+			RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);
+			err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
+			if(err != KErrNone)
+				{
+				RDebug::Print(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);
+				}
+			err = fsSession.Delete(aFullName);
+			if(err != KErrNone)
+				{
+				RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);
+				}
+			}
+		fsSession.Close();
+		}
+	else
+		{
+		RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
+		}
+	}
+
+///////////////////////////////////////////////////////////////////////////////////////
+//Test macros and functions
+void Check(TInt aValue, TInt aLine)
+	{
+	if(!aValue)
+		{
+		TheTest.Printf(_L("*** Boolean expression evaluated to false\r\n"));
+		DeleteDataFile(TheFileName);
+		TheTest(EFalse, aLine);
+		}
+	}
+void Check(TInt aValue, TInt aExpected, TInt aLine)
+	{
+	if(aValue != aExpected)
+		{
+		DeleteDataFile(TheFileName);
+		TheTest.Printf(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
+		TheTest(EFalse, aLine);
+		}
+	}
+#define TEST(arg) ::Check((arg), __LINE__)
+#define TEST2(aValue, aExpected) ::Check(aValue, aExpected, __LINE__)
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+static TInt TheCounterFreq = -10000000;
+const TInt KMicroSecIn1Sec = 1000000;
+
+TUint32 CalcTickDiff(TUint32 aStartTicks, TUint32 aEndTicks)
+	{
+	TInt64 diffTicks = (TInt64)aEndTicks - (TInt64)aStartTicks;
+	if(diffTicks < 0)
+		{
+		diffTicks = KMaxTUint32 + diffTicks + 1;
+		}
+	return (TUint32)diffTicks;
+	}
+
+//Prints aFastCount parameter (converted to us) and the bytes count
+void PrintFcDiffAsUs2(const TDesC& aFormatStr, TInt aBytes, TUint32 aFastCount)
+	{
+	if(TheCounterFreq <= 0)
+		{
+		TEST2(HAL::Get(HAL::EFastCounterFrequency, TheCounterFreq), KErrNone);
+		TheTest.Printf(_L("Counter frequency=%d Hz\r\n"), TheCounterFreq);
+		}
+	double v = ((double)aFastCount * KMicroSecIn1Sec) / (double)TheCounterFreq;
+	TInt v2 = (TInt)v;
+	TheTest.Printf(aFormatStr, aBytes, v2);
+	}
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+TInt ReclaimL(CStreamStore& aStore)
+	{
+	TUint32 fc = User::FastCounter();
+	TInt total = aStore.ReclaimL();
+	TUint32 time = CalcTickDiff(fc, User::FastCounter());
+	PrintFcDiffAsUs2(_L("### CStreamStore::ReclaimL(), %d bytes reclaimable, Time=%d us\r\n"), total, time);
+	return total;
+	}
+/**
+@SYMTestCaseID          SYSLIB-STORE-CT-1159
+@SYMTestCaseDesc	    Tests CStreamStore::ReclaimL() function
+@SYMTestPriority 	    High
+@SYMTestActions  	    Tests for reclaiming the space on the store.
+                        Tests for an empty store,simple and a complex store.
+@SYMTestExpectedResults Test must not fail
+@SYMREQ                 REQ0000
+*/
+void ReclaimTestL()
+	{
+	TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-STORE-CT-1159 CPermanentFileStore::ReclaimL()"));
+	
+	TheTest.Printf(_L(" Empty store\r\n"));
+	CFileStore* store = CPermanentFileStore::ReplaceLC(TheFs, TheFileName, EFileRead | EFileWrite);
+	store->SetTypeL(store->Layout());
+	TInt bytes = ReclaimL(*store);
+	TEST2(bytes, 0);
+
+	TheTest.Printf(_L(" Simple store\r\n"));
+	RStoreWriteStream strm;
+	TStreamId id=strm.CreateLC(*store);
+	strm<<KTestText;
+	strm.CommitL();
+	strm.Release();
+	store->CommitL();
+	(void)ReclaimL(*store);
+
+	TheTest.Printf(_L(" Complex store\r\n"));
+	TInt ii;
+	for (ii=0;ii<KTestStreams;++ii)
+		{
+		id=strm.CreateL(*store);
+		TInt val=Math::Rand(TheSeed);
+		TInt len=(val>>11)%(KTestText.Length()+1);
+		if (len>0)
+			strm<<KTestText.Left(len-1);
+		strm.CommitL();
+		strm.Release();
+		if ((val>>7)&1)
+			store->DeleteL(id);
+		}
+	store->CommitL();
+	(void)ReclaimL(*store);
+
+	TheTest.Printf(_L(" Large stream\r\n"));
+	id=strm.CreateL(*store);
+	for (ii=0;ii<KTestReplicas;++ii)
+		strm<<KTestText;
+	strm.CommitL();
+	strm.Release();
+	store->CommitL();
+	(void)ReclaimL(*store);
+
+	TheTest.Printf(_L(" Deleted large stream\r\n"));
+	store->DeleteL(id);
+	store->CommitL();
+	(void)ReclaimL(*store);
+
+	TheTest.Printf(_L(" Mixed reclaim and commit\r\n"));
+	RStoreReclaim reclaim;
+	TInt step;
+	reclaim.OpenLC(*store,step);
+	TRequestStatus status;
+	TPckgBuf<TInt> pckgStep(step);
+	TRAPD(r, reclaim.NextL(pckgStep,status));
+	TEST2(r, KErrNone);
+	User::WaitForRequest(status);
+	TEST2(status.Int(), KErrNone);
+	TEST(step>0);
+	strm.CreateL(*store);
+	strm<<KTestText;
+	strm.CommitL();
+	strm.Release();
+	TRAP(r, reclaim.NextL(step));
+	TEST(r!=KErrNone);
+	reclaim.ResetL(step);
+	r = reclaim.Next(step);
+	TEST(r!=KErrNone);
+	store->CommitL();
+	TPckgBuf<TInt> pckgStep1(step);
+	reclaim.Next(pckgStep1,status) ;
+	User::WaitForRequest(status);
+	TEST(status.Int() != KErrNone);
+	reclaim.ResetL(step);
+	while (step)
+		{
+		r = reclaim.Next(step);
+		TEST2(r, KErrNone);
+		}
+
+	TInt total=reclaim.Available();
+	CleanupStack::PopAndDestroy();
+	TheTest.Printf(_L(" %d byte(s) reclaimable\n"),total);
+
+	CleanupStack::Pop();	// strm
+	CleanupStack::PopAndDestroy();	// store
+	}
+
+//Initialize TheFileName. RFs::Connect(). Prepare the test directory. 
+void CreateTestEnv()
+    {
+	TDriveUnit drive(static_cast<TUint>(RFs::GetSystemDrive()));	
+	TParse parse;
+	parse.Set(drive.Name(), &KFileLocationSpec, NULL);
+	TheFileName.Copy(parse.FullName());
+	TheTest.Printf(_L("### Test file: %S\r\n"), &TheFileName);
+    
+	TInt err = TheFs.Connect();
+	TheTest(err == KErrNone);
+
+	err = TheFs.MkDirAll(TheFileName);
+	TEST(err == KErrNone || err == KErrAlreadyExists);
+	}
+
+TInt E32Main()
+    {
+	TheTest.Title();
+	
+	CTrapCleanup* tc = CTrapCleanup::New();
+	TheTest(tc != NULL);
+	
+	__UHEAP_MARK;
+	
+	CreateTestEnv();
+	
+	TRAPD(err, ReclaimTestL());
+	::DeleteDataFile(TheFileName);
+	TheFs.Close();
+	TEST2(err, KErrNone);
+
+	__UHEAP_MARKEND;
+	
+	TheTest.End();
+	TheTest.Close();
+
+	delete tc;
+	
+	return 0;
+    }
+