diff -r 000000000000 -r 08ec8eefde2f persistentstorage/store/USTOR/UT_UTL.CPP
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/persistentstorage/store/USTOR/UT_UTL.CPP	Fri Jan 22 11:06:30 2010 +0200
@@ -0,0 +1,122 @@
+// 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 "UT_STD.H"
+
+GLDEF_C void Panic(TStorePanic aPanic)
+//
+// Panic the process with STORE-Store as the category.
+//
+	{
+	_LIT(KCategory,"STORE-Store");
+	User::Panic(KCategory,aPanic);
+	}
+
+EXPORT_C void TStreamId::InternalizeL(RReadStream& aStream)
+/** Internalises an object of this class from a read stream.
+
+The presence of this function means that the standard templated operator>>() 
+can be used to internalise objects of this class.
+
+Note that the function has assignment semantics. It replaces the old value 
+of the object with a new value read from the read stream.
+
+@param aStream Stream from which the object should be internalised. */
+	{
+	aStream>>iVal;
+	if (iVal>KMaxStreamIdValue)
+		__LEAVE(KErrCorrupt);
+	}
+
+EXPORT_C void MIncrementalCollector::DoRelease()
+/** Implementation of the public Release() function. This signals that client has 
+no further need of the object and all necessary clean-up should be done. e.g. 
+if the implementation object is allocated on the heap, it could be deleted. */
+	{}
+
+EXPORT_C void MIncrementalCollector::DoNextL(TPckgBuf<TInt>& aStep,TRequestStatus& aStatus,TPckgBuf<TInt>& aTotal)
+/** Implementation of the public asynchronous NextL() function. The default implementation 
+invokes the synchronous form of DoNextL() and then reports the result by signalling 
+the request status.
+
+@param aStep The progress value from either the last NextL() increment of 
+from ResetL() if the reclamation/compaction was restarted. On return, 
+should contain the new progress value, which can be used in subsequent calls 
+to NextL(). This must be equal to, or less than, the previous value a 
+zero value must be used to indicate that the operation is complete.
+@param aStatus A status variable. KErrNone on successful completion, otherwise 
+another of the system-wide error codes.
+@param aTotal On return, should contain the total amount of free space in the 
+store. */
+	{
+	DoNextL(aStep(),aTotal());
+	TRequestStatus* stat=&aStatus;
+	User::RequestComplete(stat,KErrNone);
+	}
+
+HDirectStoreBuf* HDirectStoreBuf::CreateL(TStreamExchange& aHost,TStreamId& anId,TInt aMode)
+//
+// Create a stream buffer for a new 'direct' stream.
+//
+	{
+	TInt size=aHost.SizeL();
+	HDirectStoreBuf* buf=NewL(aHost,size,aMode);
+	anId=TStreamId(size);
+	return buf;
+	}
+
+HDirectStoreBuf* HDirectStoreBuf::OpenL(TStreamExchange& aHost,TStreamId anId,TInt aMode)
+//
+// Create a stream buffer for an existing 'direct' stream.
+//
+	{
+	HDirectStoreBuf* buf=NewL(aHost,anId.Value(),aMode);
+	return buf;
+	}
+
+HDirectStoreBuf* HDirectStoreBuf::NewL(TStreamExchange& aHost,TInt anOffset,TInt aMode)
+	{
+	HDirectStoreBuf* buf=new(ELeave) HDirectStoreBuf(anOffset);
+	buf->Open(aHost,TStreamPos(anOffset),aMode);
+	return buf;
+	}
+
+void HDirectStoreBuf::DoRelease()
+//
+// Finished with this stream buffer.
+//
+	{
+	delete this;
+	}
+
+TStreamPos HDirectStoreBuf::DoSeekL(TMark aMark,TStreamLocation aLocation,TInt anOffset)
+//
+// Position the mark(s) indicated by aMark at anOffset from aLocation.
+//
+	{
+	TInt off=iOff;
+	if (aLocation==EStreamBeginning)
+		anOffset+=off;
+	return RShareBuf::DoSeekL(aMark,aLocation,anOffset)-off;
+	}
+
+EXPORT_C void TStreamId::__DbgChkRange(TUint32 aValue)
+//
+// Check for values out of range.
+//
+	{
+	__ASSERT_ALWAYS(aValue<=KMaxStreamIdValue,Panic(EStoreIdOutOfRange));
+	}
+